From c91f8607721ca2337abea0de8ff482a536fe5422 Mon Sep 17 00:00:00 2001 From: Darkness4 Date: Wed, 14 Feb 2024 00:11:24 +0000 Subject: [PATCH] chore(grpc): update protobuf types Signed-off-by: GitHub --- .../generated/logger/v1alpha1/log.client.ts | 111 +-- src/grpc/generated/logger/v1alpha1/log.ts | 935 +++++++----------- 2 files changed, 404 insertions(+), 642 deletions(-) diff --git a/src/grpc/generated/logger/v1alpha1/log.client.ts b/src/grpc/generated/logger/v1alpha1/log.client.ts index 930e69a2..f19694a2 100644 --- a/src/grpc/generated/logger/v1alpha1/log.client.ts +++ b/src/grpc/generated/logger/v1alpha1/log.client.ts @@ -1,4 +1,4 @@ -// @generated by protobuf-ts 2.9.0 +// @generated by protobuf-ts 2.9.3 // @generated from protobuf file "logger/v1alpha1/log.proto" (package "logger.v1alpha1", syntax proto3) // tslint:disable import type { RpcTransport } from "@protobuf-ts/runtime-rpc"; @@ -18,80 +18,47 @@ import type { RpcOptions } from "@protobuf-ts/runtime-rpc"; * @generated from protobuf service logger.v1alpha1.LoggerAPI */ export interface ILoggerAPIClient { - /** - * @generated from protobuf rpc: Write(stream logger.v1alpha1.WriteRequest) returns (logger.v1alpha1.WriteResponse); - */ - write(options?: RpcOptions): ClientStreamingCall; - /** - * @generated from protobuf rpc: Read(logger.v1alpha1.ReadRequest) returns (stream logger.v1alpha1.ReadResponse); - */ - read( - input: ReadRequest, - options?: RpcOptions, - ): ServerStreamingCall; - /** - * @generated from protobuf rpc: WatchList(logger.v1alpha1.WatchListRequest) returns (stream logger.v1alpha1.WatchListResponse); - */ - watchList( - input: WatchListRequest, - options?: RpcOptions, - ): ServerStreamingCall; + /** + * @generated from protobuf rpc: Write(stream logger.v1alpha1.WriteRequest) returns (logger.v1alpha1.WriteResponse); + */ + write(options?: RpcOptions): ClientStreamingCall; + /** + * @generated from protobuf rpc: Read(logger.v1alpha1.ReadRequest) returns (stream logger.v1alpha1.ReadResponse); + */ + read(input: ReadRequest, options?: RpcOptions): ServerStreamingCall; + /** + * @generated from protobuf rpc: WatchList(logger.v1alpha1.WatchListRequest) returns (stream logger.v1alpha1.WatchListResponse); + */ + watchList(input: WatchListRequest, options?: RpcOptions): ServerStreamingCall; } /** * @generated from protobuf service logger.v1alpha1.LoggerAPI */ export class LoggerAPIClient implements ILoggerAPIClient, ServiceInfo { - typeName = LoggerAPI.typeName; - methods = LoggerAPI.methods; - options = LoggerAPI.options; - constructor(private readonly _transport: RpcTransport) {} - /** - * @generated from protobuf rpc: Write(stream logger.v1alpha1.WriteRequest) returns (logger.v1alpha1.WriteResponse); - */ - write( - options?: RpcOptions, - ): ClientStreamingCall { - const method = this.methods[0], - opt = this._transport.mergeOptions(options); - return stackIntercept( - "clientStreaming", - this._transport, - method, - opt, - ); - } - /** - * @generated from protobuf rpc: Read(logger.v1alpha1.ReadRequest) returns (stream logger.v1alpha1.ReadResponse); - */ - read( - input: ReadRequest, - options?: RpcOptions, - ): ServerStreamingCall { - const method = this.methods[1], - opt = this._transport.mergeOptions(options); - return stackIntercept( - "serverStreaming", - this._transport, - method, - opt, - input, - ); - } - /** - * @generated from protobuf rpc: WatchList(logger.v1alpha1.WatchListRequest) returns (stream logger.v1alpha1.WatchListResponse); - */ - watchList( - input: WatchListRequest, - options?: RpcOptions, - ): ServerStreamingCall { - const method = this.methods[2], - opt = this._transport.mergeOptions(options); - return stackIntercept( - "serverStreaming", - this._transport, - method, - opt, - input, - ); - } + typeName = LoggerAPI.typeName; + methods = LoggerAPI.methods; + options = LoggerAPI.options; + constructor(private readonly _transport: RpcTransport) { + } + /** + * @generated from protobuf rpc: Write(stream logger.v1alpha1.WriteRequest) returns (logger.v1alpha1.WriteResponse); + */ + write(options?: RpcOptions): ClientStreamingCall { + const method = this.methods[0], opt = this._transport.mergeOptions(options); + return stackIntercept("clientStreaming", this._transport, method, opt); + } + /** + * @generated from protobuf rpc: Read(logger.v1alpha1.ReadRequest) returns (stream logger.v1alpha1.ReadResponse); + */ + read(input: ReadRequest, options?: RpcOptions): ServerStreamingCall { + const method = this.methods[1], opt = this._transport.mergeOptions(options); + return stackIntercept("serverStreaming", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: WatchList(logger.v1alpha1.WatchListRequest) returns (stream logger.v1alpha1.WatchListResponse); + */ + watchList(input: WatchListRequest, options?: RpcOptions): ServerStreamingCall { + const method = this.methods[2], opt = this._transport.mergeOptions(options); + return stackIntercept("serverStreaming", this._transport, method, opt, input); + } } diff --git a/src/grpc/generated/logger/v1alpha1/log.ts b/src/grpc/generated/logger/v1alpha1/log.ts index be11c113..1515b1a1 100644 --- a/src/grpc/generated/logger/v1alpha1/log.ts +++ b/src/grpc/generated/logger/v1alpha1/log.ts @@ -1,4 +1,4 @@ -// @generated by protobuf-ts 2.9.0 +// @generated by protobuf-ts 2.9.3 // @generated from protobuf file "logger/v1alpha1/log.proto" (package "logger.v1alpha1", syntax proto3) // tslint:disable import { ServiceType } from "@protobuf-ts/runtime-rpc"; @@ -10,210 +10,177 @@ import type { IBinaryReader } from "@protobuf-ts/runtime"; import { UnknownFieldHandler } from "@protobuf-ts/runtime"; import type { PartialMessage } from "@protobuf-ts/runtime"; import { reflectionMergePartial } from "@protobuf-ts/runtime"; -import { MESSAGE_TYPE } from "@protobuf-ts/runtime"; import { MessageType } from "@protobuf-ts/runtime"; /** * @generated from protobuf message logger.v1alpha1.WriteRequest */ export interface WriteRequest { - /** - * / log_name is used as key for the logs - * - * @generated from protobuf field: string log_name = 1; - */ - logName: string; - /** - * / user represents the owner of the logs - * - * @generated from protobuf field: string user = 2; - */ - user: string; - /** - * / data is the actual log - * - * @generated from protobuf field: bytes data = 3; - */ - data: Uint8Array; - /** - * / timestamp of the log (in nanoseconds) - * - * @generated from protobuf field: int64 timestamp = 4; - */ - timestamp: bigint; + /** + * / log_name is used as key for the logs + * + * @generated from protobuf field: string log_name = 1; + */ + logName: string; + /** + * / user represents the owner of the logs + * + * @generated from protobuf field: string user = 2; + */ + user: string; + /** + * / data is the actual log + * + * @generated from protobuf field: bytes data = 3; + */ + data: Uint8Array; + /** + * / timestamp of the log (in nanoseconds) + * + * @generated from protobuf field: int64 timestamp = 4; + */ + timestamp: bigint; } /** * @generated from protobuf message logger.v1alpha1.WriteResponse */ -export interface WriteResponse {} +export interface WriteResponse { +} /** * @generated from protobuf message logger.v1alpha1.ReadRequest */ export interface ReadRequest { - /** - * @generated from protobuf field: string address = 1; - */ - address: string; - /** - * @generated from protobuf field: string log_name = 2; - */ - logName: string; - /** - * / timestamp of the log (in nanoseconds) - * - * @generated from protobuf field: uint64 timestamp = 3; - */ - timestamp: bigint; - /** - * signedHash = sign(hash('read:'+address + '/' + log_name + '/' + timestamp)) - * - * @generated from protobuf field: bytes signed_hash = 4; - */ - signedHash: Uint8Array; + /** + * @generated from protobuf field: string address = 1; + */ + address: string; + /** + * @generated from protobuf field: string log_name = 2; + */ + logName: string; + /** + * / timestamp of the log (in nanoseconds) + * + * @generated from protobuf field: uint64 timestamp = 3; + */ + timestamp: bigint; + /** + * signedHash = sign(hash('read:'+address + '/' + log_name + '/' + timestamp)) + * + * @generated from protobuf field: bytes signed_hash = 4; + */ + signedHash: Uint8Array; } /** * @generated from protobuf message logger.v1alpha1.ReadResponse */ export interface ReadResponse { - /** - * / data is the actual log - * - * @generated from protobuf field: bytes data = 1; - */ - data: Uint8Array; - /** - * / timestamp of the log (in nanoseconds) - * - * @generated from protobuf field: int64 timestamp = 2; - */ - timestamp: bigint; + /** + * / data is the actual log + * + * @generated from protobuf field: bytes data = 1; + */ + data: Uint8Array; + /** + * / timestamp of the log (in nanoseconds) + * + * @generated from protobuf field: int64 timestamp = 2; + */ + timestamp: bigint; } /** * @generated from protobuf message logger.v1alpha1.WatchListRequest */ export interface WatchListRequest { - /** - * @generated from protobuf field: string address = 1; - */ - address: string; - /** - * @generated from protobuf field: uint64 timestamp = 2; - */ - timestamp: bigint; - /** - * signedHash = sign(hash('watchList:'+address + '/' + timestamp)) - * - * @generated from protobuf field: bytes signed_hash = 3; - */ - signedHash: Uint8Array; + /** + * @generated from protobuf field: string address = 1; + */ + address: string; + /** + * @generated from protobuf field: uint64 timestamp = 2; + */ + timestamp: bigint; + /** + * signedHash = sign(hash('watchList:'+address + '/' + timestamp)) + * + * @generated from protobuf field: bytes signed_hash = 3; + */ + signedHash: Uint8Array; } /** * @generated from protobuf message logger.v1alpha1.WatchListResponse */ export interface WatchListResponse { - /** - * @generated from protobuf field: repeated string log_names = 1; - */ - logNames: string[]; + /** + * @generated from protobuf field: repeated string log_names = 1; + */ + logNames: string[]; } // @generated message type with reflection information, may provide speed optimized methods class WriteRequest$Type extends MessageType { - constructor() { - super("logger.v1alpha1.WriteRequest", [ - { no: 1, name: "log_name", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, - { no: 2, name: "user", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, - { no: 3, name: "data", kind: "scalar", T: 12 /*ScalarType.BYTES*/ }, - { - no: 4, - name: "timestamp", - kind: "scalar", - T: 3 /*ScalarType.INT64*/, - L: 0 /*LongType.BIGINT*/, - }, - ]); - } - create(value?: PartialMessage): WriteRequest { - const message = { - logName: "", - user: "", - data: new Uint8Array(0), - timestamp: 0n, - }; - globalThis.Object.defineProperty(message, MESSAGE_TYPE, { - enumerable: false, - value: this, - }); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead( - reader: IBinaryReader, - length: number, - options: BinaryReadOptions, - target?: WriteRequest, - ): WriteRequest { - let message = target ?? this.create(), - end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* string log_name */ 1: - message.logName = reader.string(); - break; - case /* string user */ 2: - message.user = reader.string(); - break; - case /* bytes data */ 3: - message.data = reader.bytes(); - break; - case /* int64 timestamp */ 4: - message.timestamp = reader.int64().toBigInt(); - break; - default: - let u = options.readUnknownField; - if (u === "throw") - throw new globalThis.Error( - `Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`, - ); - let d = reader.skip(wireType); - if (u !== false) - (u === true ? UnknownFieldHandler.onRead : u)( - this.typeName, - message, - fieldNo, - wireType, - d, - ); - } + constructor() { + super("logger.v1alpha1.WriteRequest", [ + { no: 1, name: "log_name", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, + { no: 2, name: "user", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, + { no: 3, name: "data", kind: "scalar", T: 12 /*ScalarType.BYTES*/ }, + { no: 4, name: "timestamp", kind: "scalar", T: 3 /*ScalarType.INT64*/, L: 0 /*LongType.BIGINT*/ } + ]); + } + create(value?: PartialMessage): WriteRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + message.logName = ""; + message.user = ""; + message.data = new Uint8Array(0); + message.timestamp = 0n; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: WriteRequest): WriteRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* string log_name */ 1: + message.logName = reader.string(); + break; + case /* string user */ 2: + message.user = reader.string(); + break; + case /* bytes data */ 3: + message.data = reader.bytes(); + break; + case /* int64 timestamp */ 4: + message.timestamp = reader.int64().toBigInt(); + break; + default: + let u = options.readUnknownField; + if (u === "throw") + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); + let d = reader.skip(wireType); + if (u !== false) + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); + } + } + return message; + } + internalBinaryWrite(message: WriteRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* string log_name = 1; */ + if (message.logName !== "") + writer.tag(1, WireType.LengthDelimited).string(message.logName); + /* string user = 2; */ + if (message.user !== "") + writer.tag(2, WireType.LengthDelimited).string(message.user); + /* bytes data = 3; */ + if (message.data.length) + writer.tag(3, WireType.LengthDelimited).bytes(message.data); + /* int64 timestamp = 4; */ + if (message.timestamp !== 0n) + writer.tag(4, WireType.Varint).int64(message.timestamp); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; } - return message; - } - internalBinaryWrite( - message: WriteRequest, - writer: IBinaryWriter, - options: BinaryWriteOptions, - ): IBinaryWriter { - /* string log_name = 1; */ - if (message.logName !== "") - writer.tag(1, WireType.LengthDelimited).string(message.logName); - /* string user = 2; */ - if (message.user !== "") - writer.tag(2, WireType.LengthDelimited).string(message.user); - /* bytes data = 3; */ - if (message.data.length) - writer.tag(3, WireType.LengthDelimited).bytes(message.data); - /* int64 timestamp = 4; */ - if (message.timestamp !== 0n) - writer.tag(4, WireType.Varint).int64(message.timestamp); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)( - this.typeName, - message, - writer, - ); - return writer; - } } /** * @generated MessageType for protobuf message logger.v1alpha1.WriteRequest @@ -221,41 +188,24 @@ class WriteRequest$Type extends MessageType { export const WriteRequest = new WriteRequest$Type(); // @generated message type with reflection information, may provide speed optimized methods class WriteResponse$Type extends MessageType { - constructor() { - super("logger.v1alpha1.WriteResponse", []); - } - create(value?: PartialMessage): WriteResponse { - const message = {}; - globalThis.Object.defineProperty(message, MESSAGE_TYPE, { - enumerable: false, - value: this, - }); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead( - reader: IBinaryReader, - length: number, - options: BinaryReadOptions, - target?: WriteResponse, - ): WriteResponse { - return target ?? this.create(); - } - internalBinaryWrite( - message: WriteResponse, - writer: IBinaryWriter, - options: BinaryWriteOptions, - ): IBinaryWriter { - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)( - this.typeName, - message, - writer, - ); - return writer; - } + constructor() { + super("logger.v1alpha1.WriteResponse", []); + } + create(value?: PartialMessage): WriteResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: WriteResponse): WriteResponse { + return target ?? this.create(); + } + internalBinaryWrite(message: WriteResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } } /** * @generated MessageType for protobuf message logger.v1alpha1.WriteResponse @@ -263,108 +213,70 @@ class WriteResponse$Type extends MessageType { export const WriteResponse = new WriteResponse$Type(); // @generated message type with reflection information, may provide speed optimized methods class ReadRequest$Type extends MessageType { - constructor() { - super("logger.v1alpha1.ReadRequest", [ - { no: 1, name: "address", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, - { no: 2, name: "log_name", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, - { - no: 3, - name: "timestamp", - kind: "scalar", - T: 4 /*ScalarType.UINT64*/, - L: 0 /*LongType.BIGINT*/, - }, - { - no: 4, - name: "signed_hash", - kind: "scalar", - T: 12 /*ScalarType.BYTES*/, - }, - ]); - } - create(value?: PartialMessage): ReadRequest { - const message = { - address: "", - logName: "", - timestamp: 0n, - signedHash: new Uint8Array(0), - }; - globalThis.Object.defineProperty(message, MESSAGE_TYPE, { - enumerable: false, - value: this, - }); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead( - reader: IBinaryReader, - length: number, - options: BinaryReadOptions, - target?: ReadRequest, - ): ReadRequest { - let message = target ?? this.create(), - end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* string address */ 1: - message.address = reader.string(); - break; - case /* string log_name */ 2: - message.logName = reader.string(); - break; - case /* uint64 timestamp */ 3: - message.timestamp = reader.uint64().toBigInt(); - break; - case /* bytes signed_hash */ 4: - message.signedHash = reader.bytes(); - break; - default: - let u = options.readUnknownField; - if (u === "throw") - throw new globalThis.Error( - `Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`, - ); - let d = reader.skip(wireType); - if (u !== false) - (u === true ? UnknownFieldHandler.onRead : u)( - this.typeName, - message, - fieldNo, - wireType, - d, - ); - } + constructor() { + super("logger.v1alpha1.ReadRequest", [ + { no: 1, name: "address", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, + { no: 2, name: "log_name", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, + { no: 3, name: "timestamp", kind: "scalar", T: 4 /*ScalarType.UINT64*/, L: 0 /*LongType.BIGINT*/ }, + { no: 4, name: "signed_hash", kind: "scalar", T: 12 /*ScalarType.BYTES*/ } + ]); + } + create(value?: PartialMessage): ReadRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + message.address = ""; + message.logName = ""; + message.timestamp = 0n; + message.signedHash = new Uint8Array(0); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ReadRequest): ReadRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* string address */ 1: + message.address = reader.string(); + break; + case /* string log_name */ 2: + message.logName = reader.string(); + break; + case /* uint64 timestamp */ 3: + message.timestamp = reader.uint64().toBigInt(); + break; + case /* bytes signed_hash */ 4: + message.signedHash = reader.bytes(); + break; + default: + let u = options.readUnknownField; + if (u === "throw") + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); + let d = reader.skip(wireType); + if (u !== false) + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); + } + } + return message; + } + internalBinaryWrite(message: ReadRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* string address = 1; */ + if (message.address !== "") + writer.tag(1, WireType.LengthDelimited).string(message.address); + /* string log_name = 2; */ + if (message.logName !== "") + writer.tag(2, WireType.LengthDelimited).string(message.logName); + /* uint64 timestamp = 3; */ + if (message.timestamp !== 0n) + writer.tag(3, WireType.Varint).uint64(message.timestamp); + /* bytes signed_hash = 4; */ + if (message.signedHash.length) + writer.tag(4, WireType.LengthDelimited).bytes(message.signedHash); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; } - return message; - } - internalBinaryWrite( - message: ReadRequest, - writer: IBinaryWriter, - options: BinaryWriteOptions, - ): IBinaryWriter { - /* string address = 1; */ - if (message.address !== "") - writer.tag(1, WireType.LengthDelimited).string(message.address); - /* string log_name = 2; */ - if (message.logName !== "") - writer.tag(2, WireType.LengthDelimited).string(message.logName); - /* uint64 timestamp = 3; */ - if (message.timestamp !== 0n) - writer.tag(3, WireType.Varint).uint64(message.timestamp); - /* bytes signed_hash = 4; */ - if (message.signedHash.length) - writer.tag(4, WireType.LengthDelimited).bytes(message.signedHash); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)( - this.typeName, - message, - writer, - ); - return writer; - } } /** * @generated MessageType for protobuf message logger.v1alpha1.ReadRequest @@ -372,84 +284,54 @@ class ReadRequest$Type extends MessageType { export const ReadRequest = new ReadRequest$Type(); // @generated message type with reflection information, may provide speed optimized methods class ReadResponse$Type extends MessageType { - constructor() { - super("logger.v1alpha1.ReadResponse", [ - { no: 1, name: "data", kind: "scalar", T: 12 /*ScalarType.BYTES*/ }, - { - no: 2, - name: "timestamp", - kind: "scalar", - T: 3 /*ScalarType.INT64*/, - L: 0 /*LongType.BIGINT*/, - }, - ]); - } - create(value?: PartialMessage): ReadResponse { - const message = { data: new Uint8Array(0), timestamp: 0n }; - globalThis.Object.defineProperty(message, MESSAGE_TYPE, { - enumerable: false, - value: this, - }); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead( - reader: IBinaryReader, - length: number, - options: BinaryReadOptions, - target?: ReadResponse, - ): ReadResponse { - let message = target ?? this.create(), - end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* bytes data */ 1: - message.data = reader.bytes(); - break; - case /* int64 timestamp */ 2: - message.timestamp = reader.int64().toBigInt(); - break; - default: - let u = options.readUnknownField; - if (u === "throw") - throw new globalThis.Error( - `Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`, - ); - let d = reader.skip(wireType); - if (u !== false) - (u === true ? UnknownFieldHandler.onRead : u)( - this.typeName, - message, - fieldNo, - wireType, - d, - ); - } + constructor() { + super("logger.v1alpha1.ReadResponse", [ + { no: 1, name: "data", kind: "scalar", T: 12 /*ScalarType.BYTES*/ }, + { no: 2, name: "timestamp", kind: "scalar", T: 3 /*ScalarType.INT64*/, L: 0 /*LongType.BIGINT*/ } + ]); + } + create(value?: PartialMessage): ReadResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + message.data = new Uint8Array(0); + message.timestamp = 0n; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ReadResponse): ReadResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* bytes data */ 1: + message.data = reader.bytes(); + break; + case /* int64 timestamp */ 2: + message.timestamp = reader.int64().toBigInt(); + break; + default: + let u = options.readUnknownField; + if (u === "throw") + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); + let d = reader.skip(wireType); + if (u !== false) + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); + } + } + return message; + } + internalBinaryWrite(message: ReadResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* bytes data = 1; */ + if (message.data.length) + writer.tag(1, WireType.LengthDelimited).bytes(message.data); + /* int64 timestamp = 2; */ + if (message.timestamp !== 0n) + writer.tag(2, WireType.Varint).int64(message.timestamp); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; } - return message; - } - internalBinaryWrite( - message: ReadResponse, - writer: IBinaryWriter, - options: BinaryWriteOptions, - ): IBinaryWriter { - /* bytes data = 1; */ - if (message.data.length) - writer.tag(1, WireType.LengthDelimited).bytes(message.data); - /* int64 timestamp = 2; */ - if (message.timestamp !== 0n) - writer.tag(2, WireType.Varint).int64(message.timestamp); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)( - this.typeName, - message, - writer, - ); - return writer; - } } /** * @generated MessageType for protobuf message logger.v1alpha1.ReadResponse @@ -457,100 +339,62 @@ class ReadResponse$Type extends MessageType { export const ReadResponse = new ReadResponse$Type(); // @generated message type with reflection information, may provide speed optimized methods class WatchListRequest$Type extends MessageType { - constructor() { - super("logger.v1alpha1.WatchListRequest", [ - { no: 1, name: "address", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, - { - no: 2, - name: "timestamp", - kind: "scalar", - T: 4 /*ScalarType.UINT64*/, - L: 0 /*LongType.BIGINT*/, - }, - { - no: 3, - name: "signed_hash", - kind: "scalar", - T: 12 /*ScalarType.BYTES*/, - }, - ]); - } - create(value?: PartialMessage): WatchListRequest { - const message = { - address: "", - timestamp: 0n, - signedHash: new Uint8Array(0), - }; - globalThis.Object.defineProperty(message, MESSAGE_TYPE, { - enumerable: false, - value: this, - }); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead( - reader: IBinaryReader, - length: number, - options: BinaryReadOptions, - target?: WatchListRequest, - ): WatchListRequest { - let message = target ?? this.create(), - end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* string address */ 1: - message.address = reader.string(); - break; - case /* uint64 timestamp */ 2: - message.timestamp = reader.uint64().toBigInt(); - break; - case /* bytes signed_hash */ 3: - message.signedHash = reader.bytes(); - break; - default: - let u = options.readUnknownField; - if (u === "throw") - throw new globalThis.Error( - `Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`, - ); - let d = reader.skip(wireType); - if (u !== false) - (u === true ? UnknownFieldHandler.onRead : u)( - this.typeName, - message, - fieldNo, - wireType, - d, - ); - } + constructor() { + super("logger.v1alpha1.WatchListRequest", [ + { no: 1, name: "address", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, + { no: 2, name: "timestamp", kind: "scalar", T: 4 /*ScalarType.UINT64*/, L: 0 /*LongType.BIGINT*/ }, + { no: 3, name: "signed_hash", kind: "scalar", T: 12 /*ScalarType.BYTES*/ } + ]); + } + create(value?: PartialMessage): WatchListRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + message.address = ""; + message.timestamp = 0n; + message.signedHash = new Uint8Array(0); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: WatchListRequest): WatchListRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* string address */ 1: + message.address = reader.string(); + break; + case /* uint64 timestamp */ 2: + message.timestamp = reader.uint64().toBigInt(); + break; + case /* bytes signed_hash */ 3: + message.signedHash = reader.bytes(); + break; + default: + let u = options.readUnknownField; + if (u === "throw") + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); + let d = reader.skip(wireType); + if (u !== false) + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); + } + } + return message; + } + internalBinaryWrite(message: WatchListRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* string address = 1; */ + if (message.address !== "") + writer.tag(1, WireType.LengthDelimited).string(message.address); + /* uint64 timestamp = 2; */ + if (message.timestamp !== 0n) + writer.tag(2, WireType.Varint).uint64(message.timestamp); + /* bytes signed_hash = 3; */ + if (message.signedHash.length) + writer.tag(3, WireType.LengthDelimited).bytes(message.signedHash); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; } - return message; - } - internalBinaryWrite( - message: WatchListRequest, - writer: IBinaryWriter, - options: BinaryWriteOptions, - ): IBinaryWriter { - /* string address = 1; */ - if (message.address !== "") - writer.tag(1, WireType.LengthDelimited).string(message.address); - /* uint64 timestamp = 2; */ - if (message.timestamp !== 0n) - writer.tag(2, WireType.Varint).uint64(message.timestamp); - /* bytes signed_hash = 3; */ - if (message.signedHash.length) - writer.tag(3, WireType.LengthDelimited).bytes(message.signedHash); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)( - this.typeName, - message, - writer, - ); - return writer; - } } /** * @generated MessageType for protobuf message logger.v1alpha1.WatchListRequest @@ -558,77 +402,46 @@ class WatchListRequest$Type extends MessageType { export const WatchListRequest = new WatchListRequest$Type(); // @generated message type with reflection information, may provide speed optimized methods class WatchListResponse$Type extends MessageType { - constructor() { - super("logger.v1alpha1.WatchListResponse", [ - { - no: 1, - name: "log_names", - kind: "scalar", - repeat: 2 /*RepeatType.UNPACKED*/, - T: 9 /*ScalarType.STRING*/, - }, - ]); - } - create(value?: PartialMessage): WatchListResponse { - const message = { logNames: [] }; - globalThis.Object.defineProperty(message, MESSAGE_TYPE, { - enumerable: false, - value: this, - }); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead( - reader: IBinaryReader, - length: number, - options: BinaryReadOptions, - target?: WatchListResponse, - ): WatchListResponse { - let message = target ?? this.create(), - end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* repeated string log_names */ 1: - message.logNames.push(reader.string()); - break; - default: - let u = options.readUnknownField; - if (u === "throw") - throw new globalThis.Error( - `Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`, - ); - let d = reader.skip(wireType); - if (u !== false) - (u === true ? UnknownFieldHandler.onRead : u)( - this.typeName, - message, - fieldNo, - wireType, - d, - ); - } + constructor() { + super("logger.v1alpha1.WatchListResponse", [ + { no: 1, name: "log_names", kind: "scalar", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ } + ]); + } + create(value?: PartialMessage): WatchListResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + message.logNames = []; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: WatchListResponse): WatchListResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* repeated string log_names */ 1: + message.logNames.push(reader.string()); + break; + default: + let u = options.readUnknownField; + if (u === "throw") + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); + let d = reader.skip(wireType); + if (u !== false) + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); + } + } + return message; + } + internalBinaryWrite(message: WatchListResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* repeated string log_names = 1; */ + for (let i = 0; i < message.logNames.length; i++) + writer.tag(1, WireType.LengthDelimited).string(message.logNames[i]); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; } - return message; - } - internalBinaryWrite( - message: WatchListResponse, - writer: IBinaryWriter, - options: BinaryWriteOptions, - ): IBinaryWriter { - /* repeated string log_names = 1; */ - for (let i = 0; i < message.logNames.length; i++) - writer.tag(1, WireType.LengthDelimited).string(message.logNames[i]); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)( - this.typeName, - message, - writer, - ); - return writer; - } } /** * @generated MessageType for protobuf message logger.v1alpha1.WatchListResponse @@ -638,25 +451,7 @@ export const WatchListResponse = new WatchListResponse$Type(); * @generated ServiceType for protobuf service logger.v1alpha1.LoggerAPI */ export const LoggerAPI = new ServiceType("logger.v1alpha1.LoggerAPI", [ - { - name: "Write", - clientStreaming: true, - options: {}, - I: WriteRequest, - O: WriteResponse, - }, - { - name: "Read", - serverStreaming: true, - options: {}, - I: ReadRequest, - O: ReadResponse, - }, - { - name: "WatchList", - serverStreaming: true, - options: {}, - I: WatchListRequest, - O: WatchListResponse, - }, + { name: "Write", clientStreaming: true, options: {}, I: WriteRequest, O: WriteResponse }, + { name: "Read", serverStreaming: true, options: {}, I: ReadRequest, O: ReadResponse }, + { name: "WatchList", serverStreaming: true, options: {}, I: WatchListRequest, O: WatchListResponse } ]);