diff --git a/actorInput.client.ts b/actorInput.client.ts index 7454769..0b5d7a7 100644 --- a/actorInput.client.ts +++ b/actorInput.client.ts @@ -4,6 +4,20 @@ import type { RpcTransport } from "@protobuf-ts/runtime-rpc"; import type { ServiceInfo } from "@protobuf-ts/runtime-rpc"; import { ActorInputAPI } from "./actorInput"; +import type { ActorWMSUpdatedResponse } from "./actorInput"; +import type { ActorWMSUpdatedRequest } from "./actorInput"; +import type { ActorConnectionUpdatedResponse } from "./actorInput"; +import type { ActorConnectionUpdatedRequest } from "./actorInput"; +import type { ActorPhotoURIUpdatedResponse } from "./actorInput"; +import type { ActorPhotoURIUpdatedRequest } from "./actorInput"; +import type { ActorCarrierInformationUpdatedResponse } from "./actorInput"; +import type { ActorCarrierInformationUpdatedRequest } from "./actorInput"; +import type { ActorTypologyUpdatedResponse } from "./actorInput"; +import type { ActorTypologyUpdatedRequest } from "./actorInput"; +import type { ActorPartnerLinkUpdatedResponse } from "./actorInput"; +import type { ActorPartnerLinkUpdatedRequest } from "./actorInput"; +import type { ActorStockManagementUpdatedResponse } from "./actorInput"; +import type { ActorStockManagementUpdatedRequest } from "./actorInput"; import type { ActorCustomFieldsUpdatedResponse } from "./actorInput"; import type { ActorCustomFieldsUpdatedRequest } from "./actorInput"; import type { ActorSanitisedResponse } from "./actorInput"; @@ -80,6 +94,34 @@ export interface IActorInputAPIClient { * @generated from protobuf rpc: CustomFieldsUpdated */ customFieldsUpdated(input: ActorCustomFieldsUpdatedRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: StockManagementUpdated + */ + stockManagementUpdated(input: ActorStockManagementUpdatedRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: PartnerLinkUpdated + */ + partnerLinkUpdated(input: ActorPartnerLinkUpdatedRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: TypologyUpdated + */ + typologyUpdated(input: ActorTypologyUpdatedRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: CarrierInformationUpdated + */ + carrierInformationUpdated(input: ActorCarrierInformationUpdatedRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: PhotoURIUpdated + */ + photoURIUpdated(input: ActorPhotoURIUpdatedRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: ConnectionUpdated + */ + connectionUpdated(input: ActorConnectionUpdatedRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: WMSUpdated + */ + wMSUpdated(input: ActorWMSUpdatedRequest, options?: RpcOptions): UnaryCall; } /** * @@ -170,4 +212,53 @@ export class ActorInputAPIClient implements IActorInputAPIClient, ServiceInfo { const method = this.methods[10], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } + /** + * @generated from protobuf rpc: StockManagementUpdated + */ + stockManagementUpdated(input: ActorStockManagementUpdatedRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[11], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: PartnerLinkUpdated + */ + partnerLinkUpdated(input: ActorPartnerLinkUpdatedRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[12], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: TypologyUpdated + */ + typologyUpdated(input: ActorTypologyUpdatedRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[13], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: CarrierInformationUpdated + */ + carrierInformationUpdated(input: ActorCarrierInformationUpdatedRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[14], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: PhotoURIUpdated + */ + photoURIUpdated(input: ActorPhotoURIUpdatedRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[15], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: ConnectionUpdated + */ + connectionUpdated(input: ActorConnectionUpdatedRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[16], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: WMSUpdated + */ + wMSUpdated(input: ActorWMSUpdatedRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[17], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } } diff --git a/actorInput.ts b/actorInput.ts index d2f8b96..452b7a5 100644 --- a/actorInput.ts +++ b/actorInput.ts @@ -286,6 +286,512 @@ export interface ActorCreatedv2Response { */ ID?: EntityID; } +/** + * Event Payload + * + * @generated from protobuf message api.ActorWMSUpdatedPayload + */ +export interface ActorWMSUpdatedPayload { + /** + * Actor Name + * + * @generated from protobuf field: string Name = 1 + */ + Name: string; + /** + * @generated from protobuf field: api.IdType IdType = 2 + */ + IdType: IdType; + /** + * @generated from protobuf field: api.Address Address = 3 + */ + Address?: Address; + /** + * @generated from protobuf field: string AdditionalInformation = 4 + */ + AdditionalInformation: string; + /** + * Must be a valid email address + * + * @generated from protobuf field: repeated string Emails = 5 + */ + Emails: string[]; + /** + * @generated from protobuf field: repeated string Phones = 6 + */ + Phones: string[]; +} +/** + * Event message + * + * @generated from protobuf message api.ActorWMSUpdatedEvent + */ +export interface ActorWMSUpdatedEvent { + /** + * @generated from protobuf field: api.EventHeader Header = 1 + */ + Header?: EventHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorWMSUpdatedPayload Payload = 3 + */ + Payload?: ActorWMSUpdatedPayload; +} +/** + * API Request + * + * @generated from protobuf message api.ActorWMSUpdatedRequest + */ +export interface ActorWMSUpdatedRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 + */ + Header?: RequestProjectHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorWMSUpdatedPayload Payload = 3 + */ + Payload?: ActorWMSUpdatedPayload; +} +/** + * API Response + * + * @generated from protobuf message api.ActorWMSUpdatedResponse + */ +export interface ActorWMSUpdatedResponse { + /** + * @generated from protobuf field: api.ResponseHeader Header = 1 + */ + Header?: ResponseHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; +} +/** + * Event Payload + * + * @generated from protobuf message api.ActorTypologyUpdatedPayload + */ +export interface ActorTypologyUpdatedPayload { + /** + * @generated from protobuf field: api.ActorTypology Typology = 1 + */ + Typology: ActorTypology; +} +/** + * Event message + * + * @generated from protobuf message api.ActorTypologyUpdatedEvent + */ +export interface ActorTypologyUpdatedEvent { + /** + * @generated from protobuf field: api.EventHeader Header = 1 + */ + Header?: EventHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorTypologyUpdatedPayload Payload = 3 + */ + Payload?: ActorTypologyUpdatedPayload; +} +/** + * API Request + * + * @generated from protobuf message api.ActorTypologyUpdatedRequest + */ +export interface ActorTypologyUpdatedRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 + */ + Header?: RequestProjectHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorTypologyUpdatedPayload Payload = 3 + */ + Payload?: ActorTypologyUpdatedPayload; +} +/** + * API Response + * + * @generated from protobuf message api.ActorTypologyUpdatedResponse + */ +export interface ActorTypologyUpdatedResponse { + /** + * @generated from protobuf field: api.ResponseHeader Header = 1 + */ + Header?: ResponseHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; +} +/** + * Event Payload + * + * @generated from protobuf message api.ActorCarrierInformationUpdatedPayload + */ +export interface ActorCarrierInformationUpdatedPayload { + /** + * Can be used as carrier + * + * @generated from protobuf field: bool IsCarrier = 1 + */ + IsCarrier: boolean; + /** + * List of carrier services + * + * @generated from protobuf field: repeated api.CarrierService CarrierServices = 2 + */ + CarrierServices: CarrierService[]; +} +/** + * Event message + * + * @generated from protobuf message api.ActorCarrierInformationUpdatedEvent + */ +export interface ActorCarrierInformationUpdatedEvent { + /** + * @generated from protobuf field: api.EventHeader Header = 1 + */ + Header?: EventHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorCarrierInformationUpdatedPayload Payload = 3 + */ + Payload?: ActorCarrierInformationUpdatedPayload; +} +/** + * API Request + * + * @generated from protobuf message api.ActorCarrierInformationUpdatedRequest + */ +export interface ActorCarrierInformationUpdatedRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 + */ + Header?: RequestProjectHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorCarrierInformationUpdatedPayload Payload = 3 + */ + Payload?: ActorCarrierInformationUpdatedPayload; +} +/** + * API Response + * + * @generated from protobuf message api.ActorCarrierInformationUpdatedResponse + */ +export interface ActorCarrierInformationUpdatedResponse { + /** + * @generated from protobuf field: api.ResponseHeader Header = 1 + */ + Header?: ResponseHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; +} +/** + * Event Payload + * + * @generated from protobuf message api.ActorStockManagementUpdatedPayload + */ +export interface ActorStockManagementUpdatedPayload { + /** + * Can manage stock + * + * @generated from protobuf field: bool ManagedStock = 1 + */ + ManagedStock: boolean; +} +/** + * Event message + * + * @generated from protobuf message api.ActorStockManagementUpdatedEvent + */ +export interface ActorStockManagementUpdatedEvent { + /** + * @generated from protobuf field: api.EventHeader Header = 1 + */ + Header?: EventHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorStockManagementUpdatedPayload Payload = 3 + */ + Payload?: ActorStockManagementUpdatedPayload; +} +/** + * API Request + * + * @generated from protobuf message api.ActorStockManagementUpdatedRequest + */ +export interface ActorStockManagementUpdatedRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 + */ + Header?: RequestProjectHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorStockManagementUpdatedPayload Payload = 3 + */ + Payload?: ActorStockManagementUpdatedPayload; +} +/** + * API Response + * + * @generated from protobuf message api.ActorStockManagementUpdatedResponse + */ +export interface ActorStockManagementUpdatedResponse { + /** + * @generated from protobuf field: api.ResponseHeader Header = 1 + */ + Header?: ResponseHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; +} +/** + * Event Payload + * + * @generated from protobuf message api.ActorPartnerLinkUpdatedPayload + */ +export interface ActorPartnerLinkUpdatedPayload { + /** + * Existing PartnerID + * + * @generated from protobuf field: string PartnerID = 1 + */ + PartnerID: string; +} +/** + * Event message + * + * @generated from protobuf message api.ActorPartnerLinkUpdatedEvent + */ +export interface ActorPartnerLinkUpdatedEvent { + /** + * @generated from protobuf field: api.EventHeader Header = 1 + */ + Header?: EventHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorPartnerLinkUpdatedPayload Payload = 3 + */ + Payload?: ActorPartnerLinkUpdatedPayload; +} +/** + * API Request + * + * @generated from protobuf message api.ActorPartnerLinkUpdatedRequest + */ +export interface ActorPartnerLinkUpdatedRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 + */ + Header?: RequestProjectHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorPartnerLinkUpdatedPayload Payload = 3 + */ + Payload?: ActorPartnerLinkUpdatedPayload; +} +/** + * API Response + * + * @generated from protobuf message api.ActorPartnerLinkUpdatedResponse + */ +export interface ActorPartnerLinkUpdatedResponse { + /** + * @generated from protobuf field: api.ResponseHeader Header = 1 + */ + Header?: ResponseHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; +} +/** + * Event Payload + * + * @generated from protobuf message api.ActorPhotoURIUpdatedPayload + */ +export interface ActorPhotoURIUpdatedPayload { + /** + * @generated from protobuf field: string PhotoURI = 1 + */ + PhotoURI: string; +} +/** + * Event message + * + * @generated from protobuf message api.ActorPhotoURIUpdatedEvent + */ +export interface ActorPhotoURIUpdatedEvent { + /** + * @generated from protobuf field: api.EventHeader Header = 1 + */ + Header?: EventHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorPhotoURIUpdatedPayload Payload = 3 + */ + Payload?: ActorPhotoURIUpdatedPayload; +} +/** + * API Request + * + * @generated from protobuf message api.ActorPhotoURIUpdatedRequest + */ +export interface ActorPhotoURIUpdatedRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 + */ + Header?: RequestProjectHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorPhotoURIUpdatedPayload Payload = 3 + */ + Payload?: ActorPhotoURIUpdatedPayload; +} +/** + * API Response + * + * @generated from protobuf message api.ActorPhotoURIUpdatedResponse + */ +export interface ActorPhotoURIUpdatedResponse { + /** + * @generated from protobuf field: api.ResponseHeader Header = 1 + */ + Header?: ResponseHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; +} +/** + * Event Payload + * + * @generated from protobuf message api.ActorConnectionUpdatedPayload + */ +export interface ActorConnectionUpdatedPayload { + /** + * @generated from protobuf field: bool IsShipToConnected = 1 + */ + IsShipToConnected: boolean; + /** + * @generated from protobuf field: bool IsShipFromConnected = 2 + */ + IsShipFromConnected: boolean; + /** + * Must be existing partner ID + * + * @generated from protobuf field: string ShipToPartnerAppID = 3 + */ + ShipToPartnerAppID: string; + /** + * Must be existing partner ID + * + * @generated from protobuf field: string ShipFromPartnerAppID = 4 + */ + ShipFromPartnerAppID: string; + /** + * Prefix used to create executionflow identifiers + * + * @generated from protobuf field: repeated string ConnectionIdentifierPrefixes = 5 + */ + ConnectionIdentifierPrefixes: string[]; +} +/** + * Event message + * + * @generated from protobuf message api.ActorConnectionUpdatedEvent + */ +export interface ActorConnectionUpdatedEvent { + /** + * @generated from protobuf field: api.EventHeader Header = 1 + */ + Header?: EventHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorConnectionUpdatedPayload Payload = 3 + */ + Payload?: ActorConnectionUpdatedPayload; +} +/** + * API Request + * + * @generated from protobuf message api.ActorConnectionUpdatedRequest + */ +export interface ActorConnectionUpdatedRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 + */ + Header?: RequestProjectHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ActorConnectionUpdatedPayload Payload = 3 + */ + Payload?: ActorConnectionUpdatedPayload; +} +/** + * API Response + * + * @generated from protobuf message api.ActorConnectionUpdatedResponse + */ +export interface ActorConnectionUpdatedResponse { + /** + * @generated from protobuf field: api.ResponseHeader Header = 1 + */ + Header?: ResponseHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; +} /** * Event Payload * @@ -1472,6 +1978,1625 @@ class ActorCreatedv2Response$Type extends MessageType { */ export const ActorCreatedv2Response = new ActorCreatedv2Response$Type(); // @generated message type with reflection information, may provide speed optimized methods +class ActorWMSUpdatedPayload$Type extends MessageType { + constructor() { + super("api.ActorWMSUpdatedPayload", [ + { no: 1, name: "Name", kind: "scalar", localName: "Name", jsonName: "Name", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Actor Name" } } }, + { no: 2, name: "IdType", kind: "enum", localName: "IdType", jsonName: "IdType", T: () => ["api.IdType", IdType], options: { "api.indexationType": { Types: [{ Context: "*", Type: "generatedText" }] }, "api.viewType": { Types: [{ Context: "*", Type: "shortText" }] } } }, + { no: 3, name: "Address", kind: "message", localName: "Address", jsonName: "Address", T: () => Address }, + { no: 4, name: "AdditionalInformation", kind: "scalar", localName: "AdditionalInformation", jsonName: "AdditionalInformation", T: 9 /*ScalarType.STRING*/ }, + { no: 5, name: "Emails", kind: "scalar", localName: "Emails", jsonName: "Emails", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Must be a valid email address", example: "[\"John.doe@reflex.com\", \"will.smith@reflex.com\"]" }, "n1validate.rules": { repeated: { items: { string: { email: true, ignoreEmpty: true } } } } } }, + { no: 6, name: "Phones", kind: "scalar", localName: "Phones", jsonName: "Phones", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { example: "[\"06 00 00 00 00\", \"+49 00 0000 0000\"]" } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { description: "Event Payload" } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "WMSUpdated" }); + } + create(value?: PartialMessage): ActorWMSUpdatedPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + message.Name = ""; + message.IdType = 0; + message.AdditionalInformation = ""; + message.Emails = []; + message.Phones = []; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorWMSUpdatedPayload): ActorWMSUpdatedPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* string Name */ 1: + message.Name = reader.string(); + break; + case /* api.IdType IdType */ 2: + message.IdType = reader.int32(); + break; + case /* api.Address Address */ 3: + message.Address = Address.internalBinaryRead(reader, reader.uint32(), options, message.Address); + break; + case /* string AdditionalInformation */ 4: + message.AdditionalInformation = reader.string(); + break; + case /* repeated string Emails */ 5: + message.Emails.push(reader.string()); + break; + case /* repeated string Phones */ 6: + message.Phones.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: ActorWMSUpdatedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* string Name = 1; */ + if (message.Name !== "") + writer.tag(1, WireType.LengthDelimited).string(message.Name); + /* api.IdType IdType = 2; */ + if (message.IdType !== 0) + writer.tag(2, WireType.Varint).int32(message.IdType); + /* api.Address Address = 3; */ + if (message.Address) + Address.internalBinaryWrite(message.Address, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + /* string AdditionalInformation = 4; */ + if (message.AdditionalInformation !== "") + writer.tag(4, WireType.LengthDelimited).string(message.AdditionalInformation); + /* repeated string Emails = 5; */ + for (let i = 0; i < message.Emails.length; i++) + writer.tag(5, WireType.LengthDelimited).string(message.Emails[i]); + /* repeated string Phones = 6; */ + for (let i = 0; i < message.Phones.length; i++) + writer.tag(6, WireType.LengthDelimited).string(message.Phones[i]); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorWMSUpdatedPayload + */ +export const ActorWMSUpdatedPayload = new ActorWMSUpdatedPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorWMSUpdatedEvent$Type extends MessageType { + constructor() { + super("api.ActorWMSUpdatedEvent", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorWMSUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "EntityID", "Payload"] } }, "api.messageType": "Event", "api.inputEvent": "WMSUpdated", "api.preAggMethods": "checkPartnerAppId" }); + } + create(value?: PartialMessage): ActorWMSUpdatedEvent { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorWMSUpdatedEvent): ActorWMSUpdatedEvent { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.EventHeader Header */ 1: + message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorWMSUpdatedPayload Payload */ 3: + message.Payload = ActorWMSUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorWMSUpdatedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.EventHeader Header = 1; */ + if (message.Header) + EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorWMSUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorWMSUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorWMSUpdatedEvent + */ +export const ActorWMSUpdatedEvent = new ActorWMSUpdatedEvent$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorWMSUpdatedRequest$Type extends MessageType { + constructor() { + super("api.ActorWMSUpdatedRequest", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorWMSUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "ID", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "WMSUpdated" }); + } + create(value?: PartialMessage): ActorWMSUpdatedRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorWMSUpdatedRequest): ActorWMSUpdatedRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.RequestProjectHeader Header */ 1: + message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorWMSUpdatedPayload Payload */ 3: + message.Payload = ActorWMSUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorWMSUpdatedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1; */ + if (message.Header) + RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorWMSUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorWMSUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorWMSUpdatedRequest + */ +export const ActorWMSUpdatedRequest = new ActorWMSUpdatedRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorWMSUpdatedResponse$Type extends MessageType { + constructor() { + super("api.ActorWMSUpdatedResponse", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID } + ], { "api.messageType": "Response", "api.inputEvent": "WMSUpdated" }); + } + create(value?: PartialMessage): ActorWMSUpdatedResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorWMSUpdatedResponse): ActorWMSUpdatedResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ResponseHeader Header */ 1: + message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + 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: ActorWMSUpdatedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ResponseHeader Header = 1; */ + if (message.Header) + ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorWMSUpdatedResponse + */ +export const ActorWMSUpdatedResponse = new ActorWMSUpdatedResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorTypologyUpdatedPayload$Type extends MessageType { + constructor() { + super("api.ActorTypologyUpdatedPayload", [ + { no: 1, name: "Typology", kind: "enum", localName: "Typology", jsonName: "Typology", T: () => ["api.ActorTypology", ActorTypology] } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { description: "Event Payload" } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "TypologyUpdated" }); + } + create(value?: PartialMessage): ActorTypologyUpdatedPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + message.Typology = 0; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorTypologyUpdatedPayload): ActorTypologyUpdatedPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ActorTypology Typology */ 1: + message.Typology = reader.int32(); + 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: ActorTypologyUpdatedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ActorTypology Typology = 1; */ + if (message.Typology !== 0) + writer.tag(1, WireType.Varint).int32(message.Typology); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorTypologyUpdatedPayload + */ +export const ActorTypologyUpdatedPayload = new ActorTypologyUpdatedPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorTypologyUpdatedEvent$Type extends MessageType { + constructor() { + super("api.ActorTypologyUpdatedEvent", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorTypologyUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "EntityID", "Payload"] } }, "api.messageType": "Event", "api.inputEvent": "TypologyUpdated", "api.preAggMethods": "checkPartnerAppId" }); + } + create(value?: PartialMessage): ActorTypologyUpdatedEvent { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorTypologyUpdatedEvent): ActorTypologyUpdatedEvent { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.EventHeader Header */ 1: + message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorTypologyUpdatedPayload Payload */ 3: + message.Payload = ActorTypologyUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorTypologyUpdatedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.EventHeader Header = 1; */ + if (message.Header) + EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorTypologyUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorTypologyUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorTypologyUpdatedEvent + */ +export const ActorTypologyUpdatedEvent = new ActorTypologyUpdatedEvent$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorTypologyUpdatedRequest$Type extends MessageType { + constructor() { + super("api.ActorTypologyUpdatedRequest", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorTypologyUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "ID", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "TypologyUpdated" }); + } + create(value?: PartialMessage): ActorTypologyUpdatedRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorTypologyUpdatedRequest): ActorTypologyUpdatedRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.RequestProjectHeader Header */ 1: + message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorTypologyUpdatedPayload Payload */ 3: + message.Payload = ActorTypologyUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorTypologyUpdatedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1; */ + if (message.Header) + RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorTypologyUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorTypologyUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorTypologyUpdatedRequest + */ +export const ActorTypologyUpdatedRequest = new ActorTypologyUpdatedRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorTypologyUpdatedResponse$Type extends MessageType { + constructor() { + super("api.ActorTypologyUpdatedResponse", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID } + ], { "api.messageType": "Response", "api.inputEvent": "TypologyUpdated" }); + } + create(value?: PartialMessage): ActorTypologyUpdatedResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorTypologyUpdatedResponse): ActorTypologyUpdatedResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ResponseHeader Header */ 1: + message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + 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: ActorTypologyUpdatedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ResponseHeader Header = 1; */ + if (message.Header) + ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorTypologyUpdatedResponse + */ +export const ActorTypologyUpdatedResponse = new ActorTypologyUpdatedResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorCarrierInformationUpdatedPayload$Type extends MessageType { + constructor() { + super("api.ActorCarrierInformationUpdatedPayload", [ + { no: 1, name: "IsCarrier", kind: "scalar", localName: "IsCarrier", jsonName: "IsCarrier", T: 8 /*ScalarType.BOOL*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Can be used as carrier" } } }, + { no: 2, name: "CarrierServices", kind: "message", localName: "CarrierServices", jsonName: "CarrierServices", repeat: 2 /*RepeatType.UNPACKED*/, T: () => CarrierService, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "List of carrier services" }, "api.aggKey": "ID" } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { description: "Event Payload" } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "CarrierInformationUpdated" }); + } + create(value?: PartialMessage): ActorCarrierInformationUpdatedPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + message.IsCarrier = false; + message.CarrierServices = []; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorCarrierInformationUpdatedPayload): ActorCarrierInformationUpdatedPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* bool IsCarrier */ 1: + message.IsCarrier = reader.bool(); + break; + case /* repeated api.CarrierService CarrierServices */ 2: + message.CarrierServices.push(CarrierService.internalBinaryRead(reader, reader.uint32(), options)); + 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: ActorCarrierInformationUpdatedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* bool IsCarrier = 1; */ + if (message.IsCarrier !== false) + writer.tag(1, WireType.Varint).bool(message.IsCarrier); + /* repeated api.CarrierService CarrierServices = 2; */ + for (let i = 0; i < message.CarrierServices.length; i++) + CarrierService.internalBinaryWrite(message.CarrierServices[i], writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorCarrierInformationUpdatedPayload + */ +export const ActorCarrierInformationUpdatedPayload = new ActorCarrierInformationUpdatedPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorCarrierInformationUpdatedEvent$Type extends MessageType { + constructor() { + super("api.ActorCarrierInformationUpdatedEvent", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorCarrierInformationUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "EntityID", "Payload"] } }, "api.messageType": "Event", "api.inputEvent": "CarrierInformationUpdated", "api.preAggMethods": "checkPartnerAppId" }); + } + create(value?: PartialMessage): ActorCarrierInformationUpdatedEvent { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorCarrierInformationUpdatedEvent): ActorCarrierInformationUpdatedEvent { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.EventHeader Header */ 1: + message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorCarrierInformationUpdatedPayload Payload */ 3: + message.Payload = ActorCarrierInformationUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorCarrierInformationUpdatedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.EventHeader Header = 1; */ + if (message.Header) + EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorCarrierInformationUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorCarrierInformationUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorCarrierInformationUpdatedEvent + */ +export const ActorCarrierInformationUpdatedEvent = new ActorCarrierInformationUpdatedEvent$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorCarrierInformationUpdatedRequest$Type extends MessageType { + constructor() { + super("api.ActorCarrierInformationUpdatedRequest", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorCarrierInformationUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "ID", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "CarrierInformationUpdated" }); + } + create(value?: PartialMessage): ActorCarrierInformationUpdatedRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorCarrierInformationUpdatedRequest): ActorCarrierInformationUpdatedRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.RequestProjectHeader Header */ 1: + message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorCarrierInformationUpdatedPayload Payload */ 3: + message.Payload = ActorCarrierInformationUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorCarrierInformationUpdatedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1; */ + if (message.Header) + RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorCarrierInformationUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorCarrierInformationUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorCarrierInformationUpdatedRequest + */ +export const ActorCarrierInformationUpdatedRequest = new ActorCarrierInformationUpdatedRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorCarrierInformationUpdatedResponse$Type extends MessageType { + constructor() { + super("api.ActorCarrierInformationUpdatedResponse", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID } + ], { "api.messageType": "Response", "api.inputEvent": "CarrierInformationUpdated" }); + } + create(value?: PartialMessage): ActorCarrierInformationUpdatedResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorCarrierInformationUpdatedResponse): ActorCarrierInformationUpdatedResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ResponseHeader Header */ 1: + message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + 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: ActorCarrierInformationUpdatedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ResponseHeader Header = 1; */ + if (message.Header) + ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorCarrierInformationUpdatedResponse + */ +export const ActorCarrierInformationUpdatedResponse = new ActorCarrierInformationUpdatedResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorStockManagementUpdatedPayload$Type extends MessageType { + constructor() { + super("api.ActorStockManagementUpdatedPayload", [ + { no: 1, name: "ManagedStock", kind: "scalar", localName: "ManagedStock", jsonName: "ManagedStock", T: 8 /*ScalarType.BOOL*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Can manage stock" } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { description: "Event Payload" } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "StockManagementUpdated" }); + } + create(value?: PartialMessage): ActorStockManagementUpdatedPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + message.ManagedStock = false; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorStockManagementUpdatedPayload): ActorStockManagementUpdatedPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* bool ManagedStock */ 1: + message.ManagedStock = reader.bool(); + 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: ActorStockManagementUpdatedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* bool ManagedStock = 1; */ + if (message.ManagedStock !== false) + writer.tag(1, WireType.Varint).bool(message.ManagedStock); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorStockManagementUpdatedPayload + */ +export const ActorStockManagementUpdatedPayload = new ActorStockManagementUpdatedPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorStockManagementUpdatedEvent$Type extends MessageType { + constructor() { + super("api.ActorStockManagementUpdatedEvent", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorStockManagementUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "EntityID", "Payload"] } }, "api.messageType": "Event", "api.inputEvent": "StockManagementUpdated", "api.preAggMethods": "checkPartnerAppId" }); + } + create(value?: PartialMessage): ActorStockManagementUpdatedEvent { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorStockManagementUpdatedEvent): ActorStockManagementUpdatedEvent { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.EventHeader Header */ 1: + message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorStockManagementUpdatedPayload Payload */ 3: + message.Payload = ActorStockManagementUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorStockManagementUpdatedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.EventHeader Header = 1; */ + if (message.Header) + EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorStockManagementUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorStockManagementUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorStockManagementUpdatedEvent + */ +export const ActorStockManagementUpdatedEvent = new ActorStockManagementUpdatedEvent$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorStockManagementUpdatedRequest$Type extends MessageType { + constructor() { + super("api.ActorStockManagementUpdatedRequest", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorStockManagementUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "ID", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "StockManagementUpdated" }); + } + create(value?: PartialMessage): ActorStockManagementUpdatedRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorStockManagementUpdatedRequest): ActorStockManagementUpdatedRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.RequestProjectHeader Header */ 1: + message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorStockManagementUpdatedPayload Payload */ 3: + message.Payload = ActorStockManagementUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorStockManagementUpdatedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1; */ + if (message.Header) + RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorStockManagementUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorStockManagementUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorStockManagementUpdatedRequest + */ +export const ActorStockManagementUpdatedRequest = new ActorStockManagementUpdatedRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorStockManagementUpdatedResponse$Type extends MessageType { + constructor() { + super("api.ActorStockManagementUpdatedResponse", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID } + ], { "api.messageType": "Response", "api.inputEvent": "StockManagementUpdated" }); + } + create(value?: PartialMessage): ActorStockManagementUpdatedResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorStockManagementUpdatedResponse): ActorStockManagementUpdatedResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ResponseHeader Header */ 1: + message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + 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: ActorStockManagementUpdatedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ResponseHeader Header = 1; */ + if (message.Header) + ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorStockManagementUpdatedResponse + */ +export const ActorStockManagementUpdatedResponse = new ActorStockManagementUpdatedResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorPartnerLinkUpdatedPayload$Type extends MessageType { + constructor() { + super("api.ActorPartnerLinkUpdatedPayload", [ + { no: 1, name: "PartnerID", kind: "scalar", localName: "PartnerID", jsonName: "PartnerID", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Existing PartnerID" }, "api.entityRef": "Partner" } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { description: "Event Payload" } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "PartnerLinkUpdated" }); + } + create(value?: PartialMessage): ActorPartnerLinkUpdatedPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + message.PartnerID = ""; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorPartnerLinkUpdatedPayload): ActorPartnerLinkUpdatedPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* string PartnerID */ 1: + message.PartnerID = 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: ActorPartnerLinkUpdatedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* string PartnerID = 1; */ + if (message.PartnerID !== "") + writer.tag(1, WireType.LengthDelimited).string(message.PartnerID); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorPartnerLinkUpdatedPayload + */ +export const ActorPartnerLinkUpdatedPayload = new ActorPartnerLinkUpdatedPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorPartnerLinkUpdatedEvent$Type extends MessageType { + constructor() { + super("api.ActorPartnerLinkUpdatedEvent", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorPartnerLinkUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "EntityID", "Payload"] } }, "api.messageType": "Event", "api.inputEvent": "PartnerLinkUpdated", "api.preAggMethods": "checkPartnerAppId" }); + } + create(value?: PartialMessage): ActorPartnerLinkUpdatedEvent { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorPartnerLinkUpdatedEvent): ActorPartnerLinkUpdatedEvent { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.EventHeader Header */ 1: + message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorPartnerLinkUpdatedPayload Payload */ 3: + message.Payload = ActorPartnerLinkUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorPartnerLinkUpdatedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.EventHeader Header = 1; */ + if (message.Header) + EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorPartnerLinkUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorPartnerLinkUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorPartnerLinkUpdatedEvent + */ +export const ActorPartnerLinkUpdatedEvent = new ActorPartnerLinkUpdatedEvent$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorPartnerLinkUpdatedRequest$Type extends MessageType { + constructor() { + super("api.ActorPartnerLinkUpdatedRequest", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorPartnerLinkUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "ID", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "PartnerLinkUpdated" }); + } + create(value?: PartialMessage): ActorPartnerLinkUpdatedRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorPartnerLinkUpdatedRequest): ActorPartnerLinkUpdatedRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.RequestProjectHeader Header */ 1: + message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorPartnerLinkUpdatedPayload Payload */ 3: + message.Payload = ActorPartnerLinkUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorPartnerLinkUpdatedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1; */ + if (message.Header) + RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorPartnerLinkUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorPartnerLinkUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorPartnerLinkUpdatedRequest + */ +export const ActorPartnerLinkUpdatedRequest = new ActorPartnerLinkUpdatedRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorPartnerLinkUpdatedResponse$Type extends MessageType { + constructor() { + super("api.ActorPartnerLinkUpdatedResponse", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID } + ], { "api.messageType": "Response", "api.inputEvent": "PartnerLinkUpdated" }); + } + create(value?: PartialMessage): ActorPartnerLinkUpdatedResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorPartnerLinkUpdatedResponse): ActorPartnerLinkUpdatedResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ResponseHeader Header */ 1: + message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + 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: ActorPartnerLinkUpdatedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ResponseHeader Header = 1; */ + if (message.Header) + ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorPartnerLinkUpdatedResponse + */ +export const ActorPartnerLinkUpdatedResponse = new ActorPartnerLinkUpdatedResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorPhotoURIUpdatedPayload$Type extends MessageType { + constructor() { + super("api.ActorPhotoURIUpdatedPayload", [ + { no: 1, name: "PhotoURI", kind: "scalar", localName: "PhotoURI", jsonName: "PhotoURI", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { example: "\"https://reflex-visibility-forever.jpg\"" }, "api.viewType": { Types: [{ Context: "*", Type: "image" }] } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { description: "Event Payload" } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "PhotoURIUpdated" }); + } + create(value?: PartialMessage): ActorPhotoURIUpdatedPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + message.PhotoURI = ""; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorPhotoURIUpdatedPayload): ActorPhotoURIUpdatedPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* string PhotoURI */ 1: + message.PhotoURI = 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: ActorPhotoURIUpdatedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* string PhotoURI = 1; */ + if (message.PhotoURI !== "") + writer.tag(1, WireType.LengthDelimited).string(message.PhotoURI); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorPhotoURIUpdatedPayload + */ +export const ActorPhotoURIUpdatedPayload = new ActorPhotoURIUpdatedPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorPhotoURIUpdatedEvent$Type extends MessageType { + constructor() { + super("api.ActorPhotoURIUpdatedEvent", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorPhotoURIUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "EntityID", "Payload"] } }, "api.messageType": "Event", "api.inputEvent": "PhotoURIUpdated", "api.preAggMethods": "checkPartnerAppId" }); + } + create(value?: PartialMessage): ActorPhotoURIUpdatedEvent { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorPhotoURIUpdatedEvent): ActorPhotoURIUpdatedEvent { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.EventHeader Header */ 1: + message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorPhotoURIUpdatedPayload Payload */ 3: + message.Payload = ActorPhotoURIUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorPhotoURIUpdatedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.EventHeader Header = 1; */ + if (message.Header) + EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorPhotoURIUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorPhotoURIUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorPhotoURIUpdatedEvent + */ +export const ActorPhotoURIUpdatedEvent = new ActorPhotoURIUpdatedEvent$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorPhotoURIUpdatedRequest$Type extends MessageType { + constructor() { + super("api.ActorPhotoURIUpdatedRequest", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorPhotoURIUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "ID", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "PhotoURIUpdated" }); + } + create(value?: PartialMessage): ActorPhotoURIUpdatedRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorPhotoURIUpdatedRequest): ActorPhotoURIUpdatedRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.RequestProjectHeader Header */ 1: + message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorPhotoURIUpdatedPayload Payload */ 3: + message.Payload = ActorPhotoURIUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorPhotoURIUpdatedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1; */ + if (message.Header) + RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorPhotoURIUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorPhotoURIUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorPhotoURIUpdatedRequest + */ +export const ActorPhotoURIUpdatedRequest = new ActorPhotoURIUpdatedRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorPhotoURIUpdatedResponse$Type extends MessageType { + constructor() { + super("api.ActorPhotoURIUpdatedResponse", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID } + ], { "api.messageType": "Response", "api.inputEvent": "PhotoURIUpdated" }); + } + create(value?: PartialMessage): ActorPhotoURIUpdatedResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorPhotoURIUpdatedResponse): ActorPhotoURIUpdatedResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ResponseHeader Header */ 1: + message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + 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: ActorPhotoURIUpdatedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ResponseHeader Header = 1; */ + if (message.Header) + ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorPhotoURIUpdatedResponse + */ +export const ActorPhotoURIUpdatedResponse = new ActorPhotoURIUpdatedResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorConnectionUpdatedPayload$Type extends MessageType { + constructor() { + super("api.ActorConnectionUpdatedPayload", [ + { no: 1, name: "IsShipToConnected", kind: "scalar", localName: "IsShipToConnected", jsonName: "IsShipToConnected", T: 8 /*ScalarType.BOOL*/ }, + { no: 2, name: "IsShipFromConnected", kind: "scalar", localName: "IsShipFromConnected", jsonName: "IsShipFromConnected", T: 8 /*ScalarType.BOOL*/ }, + { no: 3, name: "ShipToPartnerAppID", kind: "scalar", localName: "ShipToPartnerAppID", jsonName: "ShipToPartnerAppID", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Must be existing partner ID" } } }, + { no: 4, name: "ShipFromPartnerAppID", kind: "scalar", localName: "ShipFromPartnerAppID", jsonName: "ShipFromPartnerAppID", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Must be existing partner ID" } } }, + { no: 5, name: "ConnectionIdentifierPrefixes", kind: "scalar", localName: "ConnectionIdentifierPrefixes", jsonName: "ConnectionIdentifierPrefixes", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { repeated: { items: { string: { pattern: "^[a-zA-Z0-9]*" } } } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { description: "Event Payload" } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "ConnectionUpdated" }); + } + create(value?: PartialMessage): ActorConnectionUpdatedPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + message.IsShipToConnected = false; + message.IsShipFromConnected = false; + message.ShipToPartnerAppID = ""; + message.ShipFromPartnerAppID = ""; + message.ConnectionIdentifierPrefixes = []; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorConnectionUpdatedPayload): ActorConnectionUpdatedPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* bool IsShipToConnected */ 1: + message.IsShipToConnected = reader.bool(); + break; + case /* bool IsShipFromConnected */ 2: + message.IsShipFromConnected = reader.bool(); + break; + case /* string ShipToPartnerAppID */ 3: + message.ShipToPartnerAppID = reader.string(); + break; + case /* string ShipFromPartnerAppID */ 4: + message.ShipFromPartnerAppID = reader.string(); + break; + case /* repeated string ConnectionIdentifierPrefixes */ 5: + message.ConnectionIdentifierPrefixes.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: ActorConnectionUpdatedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* bool IsShipToConnected = 1; */ + if (message.IsShipToConnected !== false) + writer.tag(1, WireType.Varint).bool(message.IsShipToConnected); + /* bool IsShipFromConnected = 2; */ + if (message.IsShipFromConnected !== false) + writer.tag(2, WireType.Varint).bool(message.IsShipFromConnected); + /* string ShipToPartnerAppID = 3; */ + if (message.ShipToPartnerAppID !== "") + writer.tag(3, WireType.LengthDelimited).string(message.ShipToPartnerAppID); + /* string ShipFromPartnerAppID = 4; */ + if (message.ShipFromPartnerAppID !== "") + writer.tag(4, WireType.LengthDelimited).string(message.ShipFromPartnerAppID); + /* repeated string ConnectionIdentifierPrefixes = 5; */ + for (let i = 0; i < message.ConnectionIdentifierPrefixes.length; i++) + writer.tag(5, WireType.LengthDelimited).string(message.ConnectionIdentifierPrefixes[i]); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorConnectionUpdatedPayload + */ +export const ActorConnectionUpdatedPayload = new ActorConnectionUpdatedPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorConnectionUpdatedEvent$Type extends MessageType { + constructor() { + super("api.ActorConnectionUpdatedEvent", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorConnectionUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "EntityID", "Payload"] } }, "api.messageType": "Event", "api.inputEvent": "ConnectionUpdated", "api.preAggMethods": "checkPartnerAppId" }); + } + create(value?: PartialMessage): ActorConnectionUpdatedEvent { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorConnectionUpdatedEvent): ActorConnectionUpdatedEvent { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.EventHeader Header */ 1: + message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorConnectionUpdatedPayload Payload */ 3: + message.Payload = ActorConnectionUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorConnectionUpdatedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.EventHeader Header = 1; */ + if (message.Header) + EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorConnectionUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorConnectionUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorConnectionUpdatedEvent + */ +export const ActorConnectionUpdatedEvent = new ActorConnectionUpdatedEvent$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorConnectionUpdatedRequest$Type extends MessageType { + constructor() { + super("api.ActorConnectionUpdatedRequest", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ActorConnectionUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "ID", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "ConnectionUpdated" }); + } + create(value?: PartialMessage): ActorConnectionUpdatedRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorConnectionUpdatedRequest): ActorConnectionUpdatedRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.RequestProjectHeader Header */ 1: + message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ActorConnectionUpdatedPayload Payload */ 3: + message.Payload = ActorConnectionUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + 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: ActorConnectionUpdatedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1; */ + if (message.Header) + RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ActorConnectionUpdatedPayload Payload = 3; */ + if (message.Payload) + ActorConnectionUpdatedPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorConnectionUpdatedRequest + */ +export const ActorConnectionUpdatedRequest = new ActorConnectionUpdatedRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ActorConnectionUpdatedResponse$Type extends MessageType { + constructor() { + super("api.ActorConnectionUpdatedResponse", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID } + ], { "api.messageType": "Response", "api.inputEvent": "ConnectionUpdated" }); + } + create(value?: PartialMessage): ActorConnectionUpdatedResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorConnectionUpdatedResponse): ActorConnectionUpdatedResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ResponseHeader Header */ 1: + message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + 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: ActorConnectionUpdatedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ResponseHeader Header = 1; */ + if (message.Header) + ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ActorConnectionUpdatedResponse + */ +export const ActorConnectionUpdatedResponse = new ActorConnectionUpdatedResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods class ActorDeletedPayload$Type extends MessageType { constructor() { super("api.ActorDeletedPayload", [], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { description: "Event Payload" } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "Deleted" }); @@ -3451,5 +5576,12 @@ export const ActorInputAPI = new ServiceType("api.ActorInputAPI", [ { name: "MetaDataUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "Some metadata have been updated on an Actor. This is typically called from OMS or ERP." }, "google.api.method_visibility": { restriction: "PUBLIC" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY" }, I: ActorMetaDataUpdatedRequest, O: ActorMetaDataUpdatedResponse }, { name: "AppointmentConfigurationUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "Appointment configuration is updated on an Actor." }, "google.api.method_visibility": { restriction: "PUBLIC" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY" }, I: ActorAppointmentConfigurationUpdatedRequest, O: ActorAppointmentConfigurationUpdatedResponse }, { name: "Sanitised", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "An Actor has been sanitised." }, "google.api.method_visibility": { restriction: "INTERNAL" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.platformReserved": false, "api.tags": "PROJECT_ACTIVITY" }, I: ActorSanitisedRequest, O: ActorSanitisedResponse }, - { name: "CustomFieldsUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "CustomFields have been updated." }, "google.api.method_visibility": { restriction: "PUBLIC" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY" }, I: ActorCustomFieldsUpdatedRequest, O: ActorCustomFieldsUpdatedResponse } + { name: "CustomFieldsUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "CustomFields have been updated." }, "google.api.method_visibility": { restriction: "PUBLIC" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY" }, I: ActorCustomFieldsUpdatedRequest, O: ActorCustomFieldsUpdatedResponse }, + { name: "StockManagementUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "Stock management has been updated." }, "google.api.method_visibility": { restriction: "PUBLIC" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY" }, I: ActorStockManagementUpdatedRequest, O: ActorStockManagementUpdatedResponse }, + { name: "PartnerLinkUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "Partner link has been updated." }, "google.api.method_visibility": { restriction: "PUBLIC" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY" }, I: ActorPartnerLinkUpdatedRequest, O: ActorPartnerLinkUpdatedResponse }, + { name: "TypologyUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "Typology has been updated." }, "google.api.method_visibility": { restriction: "PUBLIC" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY" }, I: ActorTypologyUpdatedRequest, O: ActorTypologyUpdatedResponse }, + { name: "CarrierInformationUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "Carrier information has been updated." }, "google.api.method_visibility": { restriction: "PUBLIC" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY" }, I: ActorCarrierInformationUpdatedRequest, O: ActorCarrierInformationUpdatedResponse }, + { name: "PhotoURIUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "Photo URI has been updated." }, "google.api.method_visibility": { restriction: "PUBLIC" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY" }, I: ActorPhotoURIUpdatedRequest, O: ActorPhotoURIUpdatedResponse }, + { name: "ConnectionUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "Connection has been updated." }, "google.api.method_visibility": { restriction: "PUBLIC" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY" }, I: ActorConnectionUpdatedRequest, O: ActorConnectionUpdatedResponse }, + { name: "WMSUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Actor Inputs"], description: "WMS definition has been updated." }, "google.api.method_visibility": { restriction: "PUBLIC" }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY" }, I: ActorWMSUpdatedRequest, O: ActorWMSUpdatedResponse } ], { "api.serviceType": "Api", "api.k8sService": "api-server" }); diff --git a/package.json b/package.json index d14428e..47d8701 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@reflex-platform/npm-core-sdk", - "version": "1.15.0-SNAPSHOT-260824125212", + "version": "1.15.0-SNAPSHOT-260824152245", "description": "npm libs from core model proto files", "homepage": "", "main": "index.ts",