Skip to content

Commit

Permalink
feat!: Replace protobuf.js
Browse files Browse the repository at this point in the history
  • Loading branch information
@stephenh
stephenh committed Aug 15, 2024
1 parent 290d0c5 commit 6a9ee1d
Show file tree
Hide file tree
Showing 262 changed files with 5,078 additions and 6,156 deletions.
18 changes: 9 additions & 9 deletions integration/affixes/affixes.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
// source: affixes.proto

/* eslint-disable */
import * as _m0 from "protobufjs/minimal";
import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire";

export const protobufPackage = "affixes";

Expand Down Expand Up @@ -56,12 +56,12 @@ function createBasePrefixAwesomeMessageSuffix(): PrefixAwesomeMessageSuffix {
}

export const PrefixAwesomeMessageSuffix = {
encode(_: PrefixAwesomeMessageSuffix, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
encode(_: PrefixAwesomeMessageSuffix, writer: BinaryWriter = new BinaryWriter()): BinaryWriter {
return writer;
},

decode(input: _m0.Reader | Uint8Array, length?: number): PrefixAwesomeMessageSuffix {
const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
decode(input: BinaryReader | Uint8Array, length?: number): PrefixAwesomeMessageSuffix {
const reader = input instanceof BinaryReader ? input : new BinaryReader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBasePrefixAwesomeMessageSuffix();
while (reader.pos < end) {
Expand All @@ -71,7 +71,7 @@ export const PrefixAwesomeMessageSuffix = {
if ((tag & 7) === 4 || tag === 0) {
break;
}
reader.skipType(tag & 7);
reader.skip(tag & 7);
}
return message;
},
Expand Down Expand Up @@ -99,12 +99,12 @@ function createBasePrefixAwesomeMessage_InnerSuffix(): PrefixAwesomeMessage_Inne
}

export const PrefixAwesomeMessage_InnerSuffix = {
encode(_: PrefixAwesomeMessage_InnerSuffix, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
encode(_: PrefixAwesomeMessage_InnerSuffix, writer: BinaryWriter = new BinaryWriter()): BinaryWriter {
return writer;
},

decode(input: _m0.Reader | Uint8Array, length?: number): PrefixAwesomeMessage_InnerSuffix {
const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
decode(input: BinaryReader | Uint8Array, length?: number): PrefixAwesomeMessage_InnerSuffix {
const reader = input instanceof BinaryReader ? input : new BinaryReader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBasePrefixAwesomeMessage_InnerSuffix();
while (reader.pos < end) {
Expand All @@ -114,7 +114,7 @@ export const PrefixAwesomeMessage_InnerSuffix = {
if ((tag & 7) === 4 || tag === 0) {
break;
}
reader.skipType(tag & 7);
reader.skip(tag & 7);
}
return message;
},
Expand Down
10 changes: 5 additions & 5 deletions integration/angular/simple-message.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
// source: simple-message.proto

/* eslint-disable */
import * as _m0 from "protobufjs/minimal";
import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire";

export const protobufPackage = "angular";

Expand All @@ -15,15 +15,15 @@ function createBaseSimpleMessage(): SimpleMessage {
}

export const SimpleMessage = {
encode(message: SimpleMessage, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
encode(message: SimpleMessage, writer: BinaryWriter = new BinaryWriter()): BinaryWriter {
if (message.numberField !== 0) {
writer.uint32(8).int32(message.numberField);
}
return writer;
},

decode(input: _m0.Reader | Uint8Array, length?: number): SimpleMessage {
const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
decode(input: BinaryReader | Uint8Array, length?: number): SimpleMessage {
const reader = input instanceof BinaryReader ? input : new BinaryReader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseSimpleMessage();
while (reader.pos < end) {
Expand All @@ -40,7 +40,7 @@ export const SimpleMessage = {
if ((tag & 7) === 4 || tag === 0) {
break;
}
reader.skipType(tag & 7);
reader.skip(tag & 7);
}
return message;
},
Expand Down
14 changes: 7 additions & 7 deletions integration/async-iterable-services-abort-signal/simple.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
// source: simple.proto

/* eslint-disable */
import * as _m0 from "protobufjs/minimal";
import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire";

export const protobufPackage = "simple";

Expand All @@ -16,15 +16,15 @@ function createBaseEchoMsg(): EchoMsg {
}

export const EchoMsg = {
encode(message: EchoMsg, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
encode(message: EchoMsg, writer: BinaryWriter = new BinaryWriter()): BinaryWriter {
if (message.body !== "") {
writer.uint32(10).string(message.body);
}
return writer;
},

decode(input: _m0.Reader | Uint8Array, length?: number): EchoMsg {
const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
decode(input: BinaryReader | Uint8Array, length?: number): EchoMsg {
const reader = input instanceof BinaryReader ? input : new BinaryReader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseEchoMsg();
while (reader.pos < end) {
Expand All @@ -41,7 +41,7 @@ export const EchoMsg = {
if ((tag & 7) === 4 || tag === 0) {
break;
}
reader.skipType(tag & 7);
reader.skip(tag & 7);
}
return message;
},
Expand Down Expand Up @@ -127,7 +127,7 @@ export class EchoerClientImpl implements Echoer {
Echo(request: EchoMsg, abortSignal?: AbortSignal): Promise<EchoMsg> {
const data = EchoMsg.encode(request).finish();
const promise = this.rpc.request(this.service, "Echo", data, abortSignal || undefined);
return promise.then((data) => EchoMsg.decode(_m0.Reader.create(data)));
return promise.then((data) => EchoMsg.decode(new BinaryReader(data)));
}

EchoServerStream(request: EchoMsg, abortSignal?: AbortSignal): AsyncIterable<EchoMsg> {
Expand All @@ -139,7 +139,7 @@ export class EchoerClientImpl implements Echoer {
EchoClientStream(request: AsyncIterable<EchoMsg>, abortSignal?: AbortSignal): Promise<EchoMsg> {
const data = EchoMsg.encodeTransform(request);
const promise = this.rpc.clientStreamingRequest(this.service, "EchoClientStream", data, abortSignal || undefined);
return promise.then((data) => EchoMsg.decode(_m0.Reader.create(data)));
return promise.then((data) => EchoMsg.decode(new BinaryReader(data)));
}

EchoBidiStream(request: AsyncIterable<EchoMsg>, abortSignal?: AbortSignal): AsyncIterable<EchoMsg> {
Expand Down
14 changes: 7 additions & 7 deletions integration/async-iterable-services/simple.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
// source: simple.proto

/* eslint-disable */
import * as _m0 from "protobufjs/minimal";
import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire";

export const protobufPackage = "simple";

Expand All @@ -16,15 +16,15 @@ function createBaseEchoMsg(): EchoMsg {
}

export const EchoMsg = {
encode(message: EchoMsg, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
encode(message: EchoMsg, writer: BinaryWriter = new BinaryWriter()): BinaryWriter {
if (message.body !== "") {
writer.uint32(10).string(message.body);
}
return writer;
},

decode(input: _m0.Reader | Uint8Array, length?: number): EchoMsg {
const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
decode(input: BinaryReader | Uint8Array, length?: number): EchoMsg {
const reader = input instanceof BinaryReader ? input : new BinaryReader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseEchoMsg();
while (reader.pos < end) {
Expand All @@ -41,7 +41,7 @@ export const EchoMsg = {
if ((tag & 7) === 4 || tag === 0) {
break;
}
reader.skipType(tag & 7);
reader.skip(tag & 7);
}
return message;
},
Expand Down Expand Up @@ -127,7 +127,7 @@ export class EchoerClientImpl implements Echoer {
Echo(request: EchoMsg): Promise<EchoMsg> {
const data = EchoMsg.encode(request).finish();
const promise = this.rpc.request(this.service, "Echo", data);
return promise.then((data) => EchoMsg.decode(_m0.Reader.create(data)));
return promise.then((data) => EchoMsg.decode(new BinaryReader(data)));
}

EchoServerStream(request: EchoMsg): AsyncIterable<EchoMsg> {
Expand All @@ -139,7 +139,7 @@ export class EchoerClientImpl implements Echoer {
EchoClientStream(request: AsyncIterable<EchoMsg>): Promise<EchoMsg> {
const data = EchoMsg.encodeTransform(request);
const promise = this.rpc.clientStreamingRequest(this.service, "EchoClientStream", data);
return promise.then((data) => EchoMsg.decode(_m0.Reader.create(data)));
return promise.then((data) => EchoMsg.decode(new BinaryReader(data)));
}

EchoBidiStream(request: AsyncIterable<EchoMsg>): AsyncIterable<EchoMsg> {
Expand Down
10 changes: 5 additions & 5 deletions integration/avoid-import-conflicts-folder-name/ui.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
// source: ui.proto

/* eslint-disable */
import * as _m0 from "protobufjs/minimal";
import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire";

export const protobufPackage = "simple2";

Expand Down Expand Up @@ -55,7 +55,7 @@ function createBaseSimple(): Simple {
}

export const Simple = {
encode(message: Simple, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
encode(message: Simple, writer: BinaryWriter = new BinaryWriter()): BinaryWriter {
if (message.simple2Name !== "") {
writer.uint32(10).string(message.simple2Name);
}
Expand All @@ -65,8 +65,8 @@ export const Simple = {
return writer;
},

decode(input: _m0.Reader | Uint8Array, length?: number): Simple {
const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
decode(input: BinaryReader | Uint8Array, length?: number): Simple {
const reader = input instanceof BinaryReader ? input : new BinaryReader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseSimple();
while (reader.pos < end) {
Expand All @@ -90,7 +90,7 @@ export const Simple = {
if ((tag & 7) === 4 || tag === 0) {
break;
}
reader.skipType(tag & 7);
reader.skip(tag & 7);
}
return message;
},
Expand Down
20 changes: 10 additions & 10 deletions integration/avoid-import-conflicts-folder-name/ui/simple.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
// source: ui/simple.proto

/* eslint-disable */
import * as _m0 from "protobufjs/minimal";
import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire";
import {
Simple as Simple2,
SimpleEnum as SimpleEnum1,
Expand Down Expand Up @@ -66,18 +66,18 @@ function createBaseSimple(): Simple {
}

export const Simple = {
encode(message: Simple, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
encode(message: Simple, writer: BinaryWriter = new BinaryWriter()): BinaryWriter {
if (message.name !== "") {
writer.uint32(10).string(message.name);
}
if (message.otherSimple !== undefined) {
Simple2.encode(message.otherSimple, writer.uint32(18).fork()).ldelim();
Simple2.encode(message.otherSimple, writer.uint32(18).fork()).join();
}
return writer;
},

decode(input: _m0.Reader | Uint8Array, length?: number): Simple {
const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
decode(input: BinaryReader | Uint8Array, length?: number): Simple {
const reader = input instanceof BinaryReader ? input : new BinaryReader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseSimple();
while (reader.pos < end) {
Expand All @@ -101,7 +101,7 @@ export const Simple = {
if ((tag & 7) === 4 || tag === 0) {
break;
}
reader.skipType(tag & 7);
reader.skip(tag & 7);
}
return message;
},
Expand Down Expand Up @@ -142,7 +142,7 @@ function createBaseSimpleEnums(): SimpleEnums {
}

export const SimpleEnums = {
encode(message: SimpleEnums, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
encode(message: SimpleEnums, writer: BinaryWriter = new BinaryWriter()): BinaryWriter {
if (message.localEnum !== 0) {
writer.uint32(8).int32(message.localEnum);
}
Expand All @@ -152,8 +152,8 @@ export const SimpleEnums = {
return writer;
},

decode(input: _m0.Reader | Uint8Array, length?: number): SimpleEnums {
const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
decode(input: BinaryReader | Uint8Array, length?: number): SimpleEnums {
const reader = input instanceof BinaryReader ? input : new BinaryReader(input);
let end = length === undefined ? reader.len : reader.pos + length;
const message = createBaseSimpleEnums();
while (reader.pos < end) {
Expand All @@ -177,7 +177,7 @@ export const SimpleEnums = {
if ((tag & 7) === 4 || tag === 0) {
break;
}
reader.skipType(tag & 7);
reader.skip(tag & 7);
}
return message;
},
Expand Down
Loading

0 comments on commit 6a9ee1d

Please sign in to comment.