Skip to content

Commit

Permalink
chore: update deps
Browse files Browse the repository at this point in the history
Signed-off-by: Christian Stewart <christian@aperture.us>
  • Loading branch information
paralin committed May 11, 2024
1 parent 4021de3 commit 72cd22d
Show file tree
Hide file tree
Showing 15 changed files with 285 additions and 326 deletions.
2 changes: 1 addition & 1 deletion e2e/mock/mock.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

24 changes: 13 additions & 11 deletions e2e/mock/mock.pb.ts
Expand Up @@ -2,10 +2,10 @@
// @generated from file github.com/aperturerobotics/starpc/e2e/mock/mock.proto (package e2e.mock, syntax proto3)
/* eslint-disable */

import type { MessageType, PartialFieldInfo } from '@aptre/protobuf-es-lite'
import { createMessageType, Message, ScalarType } from '@aptre/protobuf-es-lite'
import type { MessageType, PartialFieldInfo } from "@aptre/protobuf-es-lite";
import { createMessageType, Message, ScalarType } from "@aptre/protobuf-es-lite";

export const protobufPackage = 'e2e.mock'
export const protobufPackage = "e2e.mock";

/**
* MockMsg is the mock message body.
Expand All @@ -16,14 +16,16 @@ export type MockMsg = Message<{
/**
* @generated from field: string body = 1;
*/
body?: string
}>
body?: string;

}>;

// MockMsg contains the message type declaration for MockMsg.
export const MockMsg: MessageType<MockMsg> = createMessageType({
typeName: 'e2e.mock.MockMsg',
fields: [
{ no: 1, name: 'body', kind: 'scalar', T: ScalarType.STRING },
] as readonly PartialFieldInfo[],
packedByDefault: true,
})
typeName: "e2e.mock.MockMsg",
fields: [
{ no: 1, name: "body", kind: "scalar", T: ScalarType.STRING },
] as readonly PartialFieldInfo[],
packedByDefault: true,
});

28 changes: 15 additions & 13 deletions e2e/mock/mock_srpc.pb.ts
Expand Up @@ -2,31 +2,31 @@
// @generated from file github.com/aperturerobotics/starpc/e2e/mock/mock.proto (package e2e.mock, syntax proto3)
/* eslint-disable */

import { MockMsg } from './mock.pb.js'
import { Message, MethodKind } from '@aptre/protobuf-es-lite'
import { ProtoRpc } from 'starpc'
import { MockMsg } from "./mock.pb.js";
import { Message, MethodKind } from "@aptre/protobuf-es-lite";
import { ProtoRpc } from "starpc";

/**
* Mock service mocks some RPCs for the e2e tests.
*
* @generated from service e2e.mock.Mock
*/
export const MockDefinition = {
typeName: 'e2e.mock.Mock',
typeName: "e2e.mock.Mock",
methods: {
/**
* MockRequest runs a mock unary request.
*
* @generated from rpc e2e.mock.Mock.MockRequest
*/
MockRequest: {
name: 'MockRequest',
name: "MockRequest",
I: MockMsg,
O: MockMsg,
kind: MethodKind.Unary,
},
},
} as const
}
} as const;

/**
* Mock service mocks some RPCs for the e2e tests.
Expand All @@ -40,9 +40,10 @@ export interface Mock {
* @generated from rpc e2e.mock.Mock.MockRequest
*/
MockRequest(
request: Message<MockMsg>,
abortSignal?: AbortSignal,
): Promise<Message<MockMsg>>
request: Message<MockMsg>, abortSignal?: AbortSignal
):
Promise<Message<MockMsg>>

}

export const MockServiceName = MockDefinition.typeName
Expand All @@ -61,9 +62,9 @@ export class MockClient implements Mock {
* @generated from rpc e2e.mock.Mock.MockRequest
*/
async MockRequest(
request: Message<MockMsg>,
abortSignal?: AbortSignal,
): Promise<Message<MockMsg>> {
request: Message<MockMsg>, abortSignal?: AbortSignal
):
Promise<Message<MockMsg>> {
const requestMsg = MockMsg.create(request)
const result = await this.rpc.request(
this.service,
Expand All @@ -73,4 +74,5 @@ export class MockClient implements Mock {
)
return MockMsg.fromBinary(result)
}

}
2 changes: 1 addition & 1 deletion echo/echo.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

24 changes: 13 additions & 11 deletions echo/echo.pb.ts
Expand Up @@ -2,10 +2,10 @@
// @generated from file github.com/aperturerobotics/starpc/echo/echo.proto (package echo, syntax proto3)
/* eslint-disable */

import type { MessageType, PartialFieldInfo } from '@aptre/protobuf-es-lite'
import { createMessageType, Message, ScalarType } from '@aptre/protobuf-es-lite'
import type { MessageType, PartialFieldInfo } from "@aptre/protobuf-es-lite";
import { createMessageType, Message, ScalarType } from "@aptre/protobuf-es-lite";

export const protobufPackage = 'echo'
export const protobufPackage = "echo";

/**
* EchoMsg is the message body for Echo.
Expand All @@ -16,14 +16,16 @@ export type EchoMsg = Message<{
/**
* @generated from field: string body = 1;
*/
body?: string
}>
body?: string;

}>;

// EchoMsg contains the message type declaration for EchoMsg.
export const EchoMsg: MessageType<EchoMsg> = createMessageType({
typeName: 'echo.EchoMsg',
fields: [
{ no: 1, name: 'body', kind: 'scalar', T: ScalarType.STRING },
] as readonly PartialFieldInfo[],
packedByDefault: true,
})
typeName: "echo.EchoMsg",
fields: [
{ no: 1, name: "body", kind: "scalar", T: ScalarType.STRING },
] as readonly PartialFieldInfo[],
packedByDefault: true,
});

91 changes: 44 additions & 47 deletions echo/echo_srpc.pb.ts
Expand Up @@ -2,31 +2,26 @@
// @generated from file github.com/aperturerobotics/starpc/echo/echo.proto (package echo, syntax proto3)
/* eslint-disable */

import { EchoMsg } from './echo.pb.js'
import { Message, MethodKind } from '@aptre/protobuf-es-lite'
import { RpcStreamPacket } from '../rpcstream/rpcstream.pb.js'
import {
buildDecodeMessageTransform,
buildEncodeMessageTransform,
MessageStream,
ProtoRpc,
} from 'starpc'
import { EchoMsg } from "./echo.pb.js";
import { Message, MethodKind } from "@aptre/protobuf-es-lite";
import { RpcStreamPacket } from "../rpcstream/rpcstream.pb.js";
import { buildDecodeMessageTransform, buildEncodeMessageTransform, MessageStream, ProtoRpc } from "starpc";

/**
* Echoer service returns the given message.
*
* @generated from service echo.Echoer
*/
export const EchoerDefinition = {
typeName: 'echo.Echoer',
typeName: "echo.Echoer",
methods: {
/**
* Echo returns the given message.
*
* @generated from rpc echo.Echoer.Echo
*/
Echo: {
name: 'Echo',
name: "Echo",
I: EchoMsg,
O: EchoMsg,
kind: MethodKind.Unary,
Expand All @@ -37,7 +32,7 @@ export const EchoerDefinition = {
* @generated from rpc echo.Echoer.EchoServerStream
*/
EchoServerStream: {
name: 'EchoServerStream',
name: "EchoServerStream",
I: EchoMsg,
O: EchoMsg,
kind: MethodKind.ServerStreaming,
Expand All @@ -48,7 +43,7 @@ export const EchoerDefinition = {
* @generated from rpc echo.Echoer.EchoClientStream
*/
EchoClientStream: {
name: 'EchoClientStream',
name: "EchoClientStream",
I: EchoMsg,
O: EchoMsg,
kind: MethodKind.ClientStreaming,
Expand All @@ -59,7 +54,7 @@ export const EchoerDefinition = {
* @generated from rpc echo.Echoer.EchoBidiStream
*/
EchoBidiStream: {
name: 'EchoBidiStream',
name: "EchoBidiStream",
I: EchoMsg,
O: EchoMsg,
kind: MethodKind.BiDiStreaming,
Expand All @@ -70,13 +65,13 @@ export const EchoerDefinition = {
* @generated from rpc echo.Echoer.RpcStream
*/
RpcStream: {
name: 'RpcStream',
name: "RpcStream",
I: RpcStreamPacket,
O: RpcStreamPacket,
kind: MethodKind.BiDiStreaming,
},
},
} as const
}
} as const;

/**
* Echoer service returns the given message.
Expand All @@ -90,49 +85,50 @@ export interface Echoer {
* @generated from rpc echo.Echoer.Echo
*/
Echo(
request: Message<EchoMsg>,
abortSignal?: AbortSignal,
): Promise<Message<EchoMsg>>
request: Message<EchoMsg>, abortSignal?: AbortSignal
):
Promise<Message<EchoMsg>>

/**
* EchoServerStream is an example of a server -> client one-way stream.
*
* @generated from rpc echo.Echoer.EchoServerStream
*/
EchoServerStream(
request: Message<EchoMsg>,
abortSignal?: AbortSignal,
): MessageStream<EchoMsg>
request: Message<EchoMsg>, abortSignal?: AbortSignal
):
MessageStream<EchoMsg>

/**
* EchoClientStream is an example of client->server one-way stream.
*
* @generated from rpc echo.Echoer.EchoClientStream
*/
EchoClientStream(
request: MessageStream<EchoMsg>,
abortSignal?: AbortSignal,
): Promise<Message<EchoMsg>>
request: MessageStream<EchoMsg>, abortSignal?: AbortSignal
):
Promise<Message<EchoMsg>>

/**
* EchoBidiStream is an example of a two-way stream.
*
* @generated from rpc echo.Echoer.EchoBidiStream
*/
EchoBidiStream(
request: MessageStream<EchoMsg>,
abortSignal?: AbortSignal,
): MessageStream<EchoMsg>
request: MessageStream<EchoMsg>, abortSignal?: AbortSignal
):
MessageStream<EchoMsg>

/**
* RpcStream opens a nested rpc call stream.
*
* @generated from rpc echo.Echoer.RpcStream
*/
RpcStream(
request: MessageStream<RpcStreamPacket>,
abortSignal?: AbortSignal,
): MessageStream<RpcStreamPacket>
request: MessageStream<RpcStreamPacket>, abortSignal?: AbortSignal
):
MessageStream<RpcStreamPacket>

}

export const EchoerServiceName = EchoerDefinition.typeName
Expand All @@ -155,9 +151,9 @@ export class EchoerClient implements Echoer {
* @generated from rpc echo.Echoer.Echo
*/
async Echo(
request: Message<EchoMsg>,
abortSignal?: AbortSignal,
): Promise<Message<EchoMsg>> {
request: Message<EchoMsg>, abortSignal?: AbortSignal
):
Promise<Message<EchoMsg>> {
const requestMsg = EchoMsg.create(request)
const result = await this.rpc.request(
this.service,
Expand All @@ -174,9 +170,9 @@ export class EchoerClient implements Echoer {
* @generated from rpc echo.Echoer.EchoServerStream
*/
EchoServerStream(
request: Message<EchoMsg>,
abortSignal?: AbortSignal,
): MessageStream<EchoMsg> {
request: Message<EchoMsg>, abortSignal?: AbortSignal
):
MessageStream<EchoMsg> {
const requestMsg = EchoMsg.create(request)
const result = this.rpc.serverStreamingRequest(
this.service,
Expand All @@ -193,9 +189,9 @@ export class EchoerClient implements Echoer {
* @generated from rpc echo.Echoer.EchoClientStream
*/
async EchoClientStream(
request: MessageStream<EchoMsg>,
abortSignal?: AbortSignal,
): Promise<Message<EchoMsg>> {
request: MessageStream<EchoMsg>, abortSignal?: AbortSignal
):
Promise<Message<EchoMsg>> {
const result = await this.rpc.clientStreamingRequest(
this.service,
EchoerDefinition.methods.EchoClientStream.name,
Expand All @@ -211,9 +207,9 @@ export class EchoerClient implements Echoer {
* @generated from rpc echo.Echoer.EchoBidiStream
*/
EchoBidiStream(
request: MessageStream<EchoMsg>,
abortSignal?: AbortSignal,
): MessageStream<EchoMsg> {
request: MessageStream<EchoMsg>, abortSignal?: AbortSignal
):
MessageStream<EchoMsg> {
const result = this.rpc.bidirectionalStreamingRequest(
this.service,
EchoerDefinition.methods.EchoBidiStream.name,
Expand All @@ -229,9 +225,9 @@ export class EchoerClient implements Echoer {
* @generated from rpc echo.Echoer.RpcStream
*/
RpcStream(
request: MessageStream<RpcStreamPacket>,
abortSignal?: AbortSignal,
): MessageStream<RpcStreamPacket> {
request: MessageStream<RpcStreamPacket>, abortSignal?: AbortSignal
):
MessageStream<RpcStreamPacket> {
const result = this.rpc.bidirectionalStreamingRequest(
this.service,
EchoerDefinition.methods.RpcStream.name,
Expand All @@ -240,4 +236,5 @@ export class EchoerClient implements Echoer {
)
return buildDecodeMessageTransform(RpcStreamPacket)(result)
}

}

0 comments on commit 72cd22d

Please sign in to comment.