// @generated by protobuf-ts 2.11.1 with parameter use_proto_field_name,keep_enum_prefix // @generated from protobuf file "handlingunitAction.proto" (package "api", syntax proto3) // tslint:disable import type { BinaryWriteOptions } from "@protobuf-ts/runtime"; import type { IBinaryWriter } from "@protobuf-ts/runtime"; import { WireType } from "@protobuf-ts/runtime"; import type { BinaryReadOptions } from "@protobuf-ts/runtime"; import type { IBinaryReader } from "@protobuf-ts/runtime"; import { UnknownFieldHandler } from "@protobuf-ts/runtime"; import type { PartialMessage } from "@protobuf-ts/runtime"; import { reflectionMergePartial } from "@protobuf-ts/runtime"; import { MessageType } from "@protobuf-ts/runtime"; import { DateTime } from "./shared"; import { ETA } from "./tradeShared"; import { EntityID } from "./shared"; import { CommandHeader } from "./shared"; import { QuantifiedDatedGoodsByExeflow } from "./warehousingShared"; import { MetadataElement } from "./shared"; import { HandlingunitStatusStruct } from "./warehousingShared"; import { TrackingSummary } from "./transportShared"; import { QuantifiedGoodsByExeflow } from "./warehousingShared"; import { HandlingunitInformation } from "./warehousingShared"; // Action Summary // - MapContentToExecutionFlow : Map entity content to ExecutionFlow entity > executionflow.HUContentUpdated // - MapTrackingToExecutionFlow : Map entity status to ExecutionFlow entity > executionflow.HUTrackingUpdated // - PropagateTracking : Propagate tracking status on all included logistic units > warehousing.handlingunit.TrackingUpdated // - PropagateETA : Propagate ETA status on all included logistic units > warehousing.handlingunit.TrackingETAUpdated // - PropagateParentHU : Propagate ParentHU on all included HU > warehousing.handlingunit.ParentHUUpdated // - MoveStock : Substract the HU Content from the stock > warehousing.stock.Moved /** * * HandlingunitMapContentToExecutionFlow : map the Handlingunit content to the corresponding Executionflow * * @generated from protobuf message api.HandlingunitMapContentToExecutionFlowPayload */ export interface HandlingunitMapContentToExecutionFlowPayload { /** * @generated from protobuf field: api.HandlingunitInformation Information = 1 */ Information?: HandlingunitInformation; /** * @generated from protobuf field: bool ContainsGoods = 2 */ ContainsGoods: boolean; /** * @generated from protobuf field: bool ContainsHUs = 3 */ ContainsHUs: boolean; /** * @generated from protobuf field: repeated api.QuantifiedGoodsByExeflow PreparedContents = 4 */ PreparedContents: QuantifiedGoodsByExeflow[]; /** * @generated from protobuf field: repeated string IncludedHandlingunitIDs = 5 */ IncludedHandlingunitIDs: string[]; /** * @generated from protobuf field: api.TrackingSummary CurrentTrackingSummary = 6 */ CurrentTrackingSummary?: TrackingSummary; /** * @generated from protobuf field: api.HandlingunitStatusStruct Status = 7 */ Status?: HandlingunitStatusStruct; /** * Metadata are characteristics specific to the project. They can be of several data form (string, integer, float, boolean or timestamp) * * @generated from protobuf field: repeated api.MetadataElement MetaData = 8 */ MetaData: MetadataElement[]; /** * @generated from protobuf field: repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents = 9 */ ReceivedContents: QuantifiedDatedGoodsByExeflow[]; } /** * @generated from protobuf message api.HandlingunitMapContentToExecutionFlow */ export interface HandlingunitMapContentToExecutionFlow { /** * @generated from protobuf field: api.CommandHeader Header = 1 */ Header?: CommandHeader; /** * @generated from protobuf field: api.EntityID ID = 2 */ ID?: EntityID; /** * @generated from protobuf field: api.HandlingunitMapContentToExecutionFlowPayload Payload = 3 */ Payload?: HandlingunitMapContentToExecutionFlowPayload; /** * @generated from protobuf field: api.HandlingunitMapContentToExecutionFlowPayload EventPayload = 4 */ EventPayload?: HandlingunitMapContentToExecutionFlowPayload; /** * @generated from protobuf field: api.HandlingunitMapContentToExecutionFlowPayload PreviousPayload = 5 */ PreviousPayload?: HandlingunitMapContentToExecutionFlowPayload; } /** * * HandlingunitMapTrackingToExecutionFlow : map the Handlingunit Tracking status to the corresponding Executionflow * * @generated from protobuf message api.HandlingunitMapTrackingToExecutionFlowPayload */ export interface HandlingunitMapTrackingToExecutionFlowPayload { /** * @generated from protobuf field: api.TrackingSummary CurrentTrackingSummary = 1 */ CurrentTrackingSummary?: TrackingSummary; /** * @generated from protobuf field: api.HandlingunitStatusStruct Status = 2 */ Status?: HandlingunitStatusStruct; /** * @generated from protobuf field: repeated api.QuantifiedGoodsByExeflow PreparedContents = 3 */ PreparedContents: QuantifiedGoodsByExeflow[]; /** * @generated from protobuf field: repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents = 4 */ ReceivedContents: QuantifiedDatedGoodsByExeflow[]; /** * @generated from protobuf field: repeated string TrackingIDs = 11 */ TrackingIDs: string[]; } /** * @generated from protobuf message api.HandlingunitMapTrackingToExecutionFlow */ export interface HandlingunitMapTrackingToExecutionFlow { /** * @generated from protobuf field: api.CommandHeader Header = 1 */ Header?: CommandHeader; /** * @generated from protobuf field: api.EntityID ID = 2 */ ID?: EntityID; /** * @generated from protobuf field: api.HandlingunitMapTrackingToExecutionFlowPayload Payload = 3 */ Payload?: HandlingunitMapTrackingToExecutionFlowPayload; /** * @generated from protobuf field: api.HandlingunitMapTrackingToExecutionFlowPayload EventPayload = 4 */ EventPayload?: HandlingunitMapTrackingToExecutionFlowPayload; /** * @generated from protobuf field: api.HandlingunitMapTrackingToExecutionFlowPayload PreviousPayload = 5 */ PreviousPayload?: HandlingunitMapTrackingToExecutionFlowPayload; } /** * * HandlingunitMapETAToExecutionFlow : map the Handlingunit ETA to the corresponding Executionflow * * @generated from protobuf message api.HandlingunitMapETAToExecutionFlowPayload */ export interface HandlingunitMapETAToExecutionFlowPayload { /** * @generated from protobuf field: api.ETA HandlingunitETA = 1 */ HandlingunitETA?: ETA; /** * @generated from protobuf field: repeated api.QuantifiedGoodsByExeflow PreparedContents = 3 */ PreparedContents: QuantifiedGoodsByExeflow[]; /** * @generated from protobuf field: repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents = 4 */ ReceivedContents: QuantifiedDatedGoodsByExeflow[]; } /** * @generated from protobuf message api.HandlingunitMapETAToExecutionFlow */ export interface HandlingunitMapETAToExecutionFlow { /** * @generated from protobuf field: api.CommandHeader Header = 1 */ Header?: CommandHeader; /** * @generated from protobuf field: api.EntityID ID = 2 */ ID?: EntityID; /** * @generated from protobuf field: api.HandlingunitMapETAToExecutionFlowPayload Payload = 3 */ Payload?: HandlingunitMapETAToExecutionFlowPayload; /** * @generated from protobuf field: api.HandlingunitMapETAToExecutionFlowPayload EventPayload = 4 */ EventPayload?: HandlingunitMapETAToExecutionFlowPayload; /** * @generated from protobuf field: api.HandlingunitMapETAToExecutionFlowPayload PreviousPayload = 5 */ PreviousPayload?: HandlingunitMapETAToExecutionFlowPayload; } /** * * PropagateTracking : replicate tracking status on all included logistic units * * @generated from protobuf message api.HandlingunitPropagateTrackingPayload */ export interface HandlingunitPropagateTrackingPayload { /** * @generated from protobuf field: bool ContainsHUs = 1 */ ContainsHUs: boolean; /** * @generated from protobuf field: repeated string IncludedHandlingunitIDs = 2 */ IncludedHandlingunitIDs: string[]; /** * @generated from protobuf field: api.TrackingSummary CurrentTrackingSummary = 3 */ CurrentTrackingSummary?: TrackingSummary; /** * @generated from protobuf field: api.DateTime DispatchedDateTime = 4 */ DispatchedDateTime?: DateTime; } /** * @generated from protobuf message api.HandlingunitPropagateTracking */ export interface HandlingunitPropagateTracking { /** * @generated from protobuf field: api.CommandHeader Header = 1 */ Header?: CommandHeader; /** * @generated from protobuf field: api.EntityID ID = 2 */ ID?: EntityID; /** * @generated from protobuf field: api.HandlingunitPropagateTrackingPayload Payload = 3 */ Payload?: HandlingunitPropagateTrackingPayload; /** * @generated from protobuf field: api.HandlingunitPropagateTrackingPayload EventPayload = 4 */ EventPayload?: HandlingunitPropagateTrackingPayload; /** * @generated from protobuf field: api.HandlingunitPropagateTrackingPayload PreviousPayload = 5 */ PreviousPayload?: HandlingunitPropagateTrackingPayload; } /** * * PropagateETA : replicate ETA on all included logistic units * * @generated from protobuf message api.HandlingunitPropagateETAPayload */ export interface HandlingunitPropagateETAPayload { /** * @generated from protobuf field: api.ETA HandlingunitETA = 1 */ HandlingunitETA?: ETA; /** * @generated from protobuf field: repeated string IncludedHandlingunitIDs = 2 */ IncludedHandlingunitIDs: string[]; /** * @generated from protobuf field: bool ContainsHUs = 3 */ ContainsHUs: boolean; } /** * @generated from protobuf message api.HandlingunitPropagateETA */ export interface HandlingunitPropagateETA { /** * @generated from protobuf field: api.CommandHeader Header = 1 */ Header?: CommandHeader; /** * @generated from protobuf field: api.EntityID ID = 2 */ ID?: EntityID; /** * @generated from protobuf field: api.HandlingunitPropagateETAPayload Payload = 3 */ Payload?: HandlingunitPropagateETAPayload; /** * @generated from protobuf field: api.HandlingunitPropagateETAPayload EventPayload = 4 */ EventPayload?: HandlingunitPropagateETAPayload; /** * @generated from protobuf field: api.HandlingunitPropagateETAPayload PreviousPayload = 5 */ PreviousPayload?: HandlingunitPropagateETAPayload; } /** * * PropagateParentHU : Propagate ParentHU on all included logistic units * * @generated from protobuf message api.HandlingunitPropagateParentHUPayload */ export interface HandlingunitPropagateParentHUPayload { /** * @generated from protobuf field: bool ContainsHUs = 1 */ ContainsHUs: boolean; /** * @generated from protobuf field: repeated string IncludedHandlingunitIDs = 2 */ IncludedHandlingunitIDs: string[]; } /** * @generated from protobuf message api.HandlingunitPropagateParentHU */ export interface HandlingunitPropagateParentHU { /** * @generated from protobuf field: api.CommandHeader Header = 1 */ Header?: CommandHeader; /** * @generated from protobuf field: api.EntityID ID = 2 */ ID?: EntityID; /** * @generated from protobuf field: api.HandlingunitPropagateParentHUPayload Payload = 3 */ Payload?: HandlingunitPropagateParentHUPayload; /** * @generated from protobuf field: api.HandlingunitPropagateParentHUPayload EventPayload = 4 */ EventPayload?: HandlingunitPropagateParentHUPayload; /** * @generated from protobuf field: api.HandlingunitPropagateParentHUPayload PreviousPayload = 5 */ PreviousPayload?: HandlingunitPropagateParentHUPayload; } /** * * MoveStock : Send a 'moved' event to the stock to decrement the content of the HU * * @generated from protobuf message api.HandlingunitMoveStockPayload */ export interface HandlingunitMoveStockPayload { /** * @generated from protobuf field: repeated api.QuantifiedGoodsByExeflow PreparedContents = 1 */ PreparedContents: QuantifiedGoodsByExeflow[]; /** * @generated from protobuf field: repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents = 2 */ ReceivedContents: QuantifiedDatedGoodsByExeflow[]; /** * @generated from protobuf field: api.HandlingunitStatusStruct Status = 8 */ Status?: HandlingunitStatusStruct; /** * @generated from protobuf field: api.DateTime DispatchedDateTime = 9 */ DispatchedDateTime?: DateTime; } /** * @generated from protobuf message api.HandlingunitMoveStock */ export interface HandlingunitMoveStock { /** * @generated from protobuf field: api.CommandHeader Header = 1 */ Header?: CommandHeader; /** * @generated from protobuf field: api.EntityID ID = 2 */ ID?: EntityID; /** * @generated from protobuf field: api.HandlingunitMoveStockPayload Payload = 3 */ Payload?: HandlingunitMoveStockPayload; /** * @generated from protobuf field: api.HandlingunitMoveStockPayload EventPayload = 4 */ EventPayload?: HandlingunitMoveStockPayload; /** * @generated from protobuf field: api.HandlingunitMoveStockPayload PreviousPayload = 5 */ PreviousPayload?: HandlingunitMoveStockPayload; } // @generated message type with reflection information, may provide speed optimized methods class HandlingunitMapContentToExecutionFlowPayload$Type extends MessageType { constructor() { super("api.HandlingunitMapContentToExecutionFlowPayload", [ { no: 1, name: "Information", kind: "message", localName: "Information", jsonName: "Information", T: () => HandlingunitInformation }, { no: 2, name: "ContainsGoods", kind: "scalar", localName: "ContainsGoods", jsonName: "ContainsGoods", T: 8 /*ScalarType.BOOL*/ }, { no: 3, name: "ContainsHUs", kind: "scalar", localName: "ContainsHUs", jsonName: "ContainsHUs", T: 8 /*ScalarType.BOOL*/ }, { no: 4, name: "PreparedContents", kind: "message", localName: "PreparedContents", jsonName: "PreparedContents", repeat: 2 /*RepeatType.UNPACKED*/, T: () => QuantifiedGoodsByExeflow }, { no: 5, name: "IncludedHandlingunitIDs", kind: "scalar", localName: "IncludedHandlingunitIDs", jsonName: "IncludedHandlingunitIDs", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ }, { no: 6, name: "CurrentTrackingSummary", kind: "message", localName: "CurrentTrackingSummary", jsonName: "CurrentTrackingSummary", T: () => TrackingSummary }, { no: 7, name: "Status", kind: "message", localName: "Status", jsonName: "Status", T: () => HandlingunitStatusStruct }, { no: 8, name: "MetaData", kind: "message", localName: "MetaData", jsonName: "MetaData", repeat: 2 /*RepeatType.UNPACKED*/, T: () => MetadataElement, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Metadata are characteristics specific to the project. They can be of several data form (string, integer, float, boolean or timestamp)" }, "api.metadata": true, "api.aggKey": "Key" } }, { no: 9, name: "ReceivedContents", kind: "message", localName: "ReceivedContents", jsonName: "ReceivedContents", repeat: 2 /*RepeatType.UNPACKED*/, T: () => QuantifiedDatedGoodsByExeflow } ], { "api.messageType": "Command", "api.payload": true, "api.action": "MapContentToExecutionFlow" }); } create(value?: PartialMessage): HandlingunitMapContentToExecutionFlowPayload { const message = globalThis.Object.create((this.messagePrototype!)); message.ContainsGoods = false; message.ContainsHUs = false; message.PreparedContents = []; message.IncludedHandlingunitIDs = []; message.MetaData = []; message.ReceivedContents = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitMapContentToExecutionFlowPayload): HandlingunitMapContentToExecutionFlowPayload { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.HandlingunitInformation Information */ 1: message.Information = HandlingunitInformation.internalBinaryRead(reader, reader.uint32(), options, message.Information); break; case /* bool ContainsGoods */ 2: message.ContainsGoods = reader.bool(); break; case /* bool ContainsHUs */ 3: message.ContainsHUs = reader.bool(); break; case /* repeated api.QuantifiedGoodsByExeflow PreparedContents */ 4: message.PreparedContents.push(QuantifiedGoodsByExeflow.internalBinaryRead(reader, reader.uint32(), options)); break; case /* repeated string IncludedHandlingunitIDs */ 5: message.IncludedHandlingunitIDs.push(reader.string()); break; case /* api.TrackingSummary CurrentTrackingSummary */ 6: message.CurrentTrackingSummary = TrackingSummary.internalBinaryRead(reader, reader.uint32(), options, message.CurrentTrackingSummary); break; case /* api.HandlingunitStatusStruct Status */ 7: message.Status = HandlingunitStatusStruct.internalBinaryRead(reader, reader.uint32(), options, message.Status); break; case /* repeated api.MetadataElement MetaData */ 8: message.MetaData.push(MetadataElement.internalBinaryRead(reader, reader.uint32(), options)); break; case /* repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents */ 9: message.ReceivedContents.push(QuantifiedDatedGoodsByExeflow.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: HandlingunitMapContentToExecutionFlowPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.HandlingunitInformation Information = 1; */ if (message.Information) HandlingunitInformation.internalBinaryWrite(message.Information, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); /* bool ContainsGoods = 2; */ if (message.ContainsGoods !== false) writer.tag(2, WireType.Varint).bool(message.ContainsGoods); /* bool ContainsHUs = 3; */ if (message.ContainsHUs !== false) writer.tag(3, WireType.Varint).bool(message.ContainsHUs); /* repeated api.QuantifiedGoodsByExeflow PreparedContents = 4; */ for (let i = 0; i < message.PreparedContents.length; i++) QuantifiedGoodsByExeflow.internalBinaryWrite(message.PreparedContents[i], writer.tag(4, WireType.LengthDelimited).fork(), options).join(); /* repeated string IncludedHandlingunitIDs = 5; */ for (let i = 0; i < message.IncludedHandlingunitIDs.length; i++) writer.tag(5, WireType.LengthDelimited).string(message.IncludedHandlingunitIDs[i]); /* api.TrackingSummary CurrentTrackingSummary = 6; */ if (message.CurrentTrackingSummary) TrackingSummary.internalBinaryWrite(message.CurrentTrackingSummary, writer.tag(6, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitStatusStruct Status = 7; */ if (message.Status) HandlingunitStatusStruct.internalBinaryWrite(message.Status, writer.tag(7, WireType.LengthDelimited).fork(), options).join(); /* repeated api.MetadataElement MetaData = 8; */ for (let i = 0; i < message.MetaData.length; i++) MetadataElement.internalBinaryWrite(message.MetaData[i], writer.tag(8, WireType.LengthDelimited).fork(), options).join(); /* repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents = 9; */ for (let i = 0; i < message.ReceivedContents.length; i++) QuantifiedDatedGoodsByExeflow.internalBinaryWrite(message.ReceivedContents[i], writer.tag(9, 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.HandlingunitMapContentToExecutionFlowPayload */ export const HandlingunitMapContentToExecutionFlowPayload = new HandlingunitMapContentToExecutionFlowPayload$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitMapContentToExecutionFlow$Type extends MessageType { constructor() { super("api.HandlingunitMapContentToExecutionFlow", [ { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => CommandHeader }, { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID }, { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => HandlingunitMapContentToExecutionFlowPayload }, { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => HandlingunitMapContentToExecutionFlowPayload }, { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => HandlingunitMapContentToExecutionFlowPayload } ], { "api.messageType": "Command", "api.action": "MapContentToExecutionFlow", "api.resultingEvent": "executionflow.HUContentUpdated", "api.triggerEventFilters": "GoodsPrepared,GoodsReceived", "api.windowMethod": "TumblingProcessingTimeWindows", "api.keyByExpression": "obj.getHeader().getProject()" }); } create(value?: PartialMessage): HandlingunitMapContentToExecutionFlow { const message = globalThis.Object.create((this.messagePrototype!)); if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitMapContentToExecutionFlow): HandlingunitMapContentToExecutionFlow { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.CommandHeader Header */ 1: message.Header = CommandHeader.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.HandlingunitMapContentToExecutionFlowPayload Payload */ 3: message.Payload = HandlingunitMapContentToExecutionFlowPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); break; case /* api.HandlingunitMapContentToExecutionFlowPayload EventPayload */ 4: message.EventPayload = HandlingunitMapContentToExecutionFlowPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); break; case /* api.HandlingunitMapContentToExecutionFlowPayload PreviousPayload */ 5: message.PreviousPayload = HandlingunitMapContentToExecutionFlowPayload.internalBinaryRead(reader, reader.uint32(), options, message.PreviousPayload); 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: HandlingunitMapContentToExecutionFlow, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.CommandHeader Header = 1; */ if (message.Header) CommandHeader.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.HandlingunitMapContentToExecutionFlowPayload Payload = 3; */ if (message.Payload) HandlingunitMapContentToExecutionFlowPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitMapContentToExecutionFlowPayload EventPayload = 4; */ if (message.EventPayload) HandlingunitMapContentToExecutionFlowPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitMapContentToExecutionFlowPayload PreviousPayload = 5; */ if (message.PreviousPayload) HandlingunitMapContentToExecutionFlowPayload.internalBinaryWrite(message.PreviousPayload, writer.tag(5, 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.HandlingunitMapContentToExecutionFlow */ export const HandlingunitMapContentToExecutionFlow = new HandlingunitMapContentToExecutionFlow$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitMapTrackingToExecutionFlowPayload$Type extends MessageType { constructor() { super("api.HandlingunitMapTrackingToExecutionFlowPayload", [ { no: 1, name: "CurrentTrackingSummary", kind: "message", localName: "CurrentTrackingSummary", jsonName: "CurrentTrackingSummary", T: () => TrackingSummary }, { no: 2, name: "Status", kind: "message", localName: "Status", jsonName: "Status", T: () => HandlingunitStatusStruct }, { no: 3, name: "PreparedContents", kind: "message", localName: "PreparedContents", jsonName: "PreparedContents", repeat: 2 /*RepeatType.UNPACKED*/, T: () => QuantifiedGoodsByExeflow }, { no: 4, name: "ReceivedContents", kind: "message", localName: "ReceivedContents", jsonName: "ReceivedContents", repeat: 2 /*RepeatType.UNPACKED*/, T: () => QuantifiedDatedGoodsByExeflow }, { no: 11, name: "TrackingIDs", kind: "scalar", localName: "TrackingIDs", jsonName: "TrackingIDs", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ } ], { "api.messageType": "Command", "api.payload": true, "api.action": "MapTrackingToExecutionFlow" }); } create(value?: PartialMessage): HandlingunitMapTrackingToExecutionFlowPayload { const message = globalThis.Object.create((this.messagePrototype!)); message.PreparedContents = []; message.ReceivedContents = []; message.TrackingIDs = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitMapTrackingToExecutionFlowPayload): HandlingunitMapTrackingToExecutionFlowPayload { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.TrackingSummary CurrentTrackingSummary */ 1: message.CurrentTrackingSummary = TrackingSummary.internalBinaryRead(reader, reader.uint32(), options, message.CurrentTrackingSummary); break; case /* api.HandlingunitStatusStruct Status */ 2: message.Status = HandlingunitStatusStruct.internalBinaryRead(reader, reader.uint32(), options, message.Status); break; case /* repeated api.QuantifiedGoodsByExeflow PreparedContents */ 3: message.PreparedContents.push(QuantifiedGoodsByExeflow.internalBinaryRead(reader, reader.uint32(), options)); break; case /* repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents */ 4: message.ReceivedContents.push(QuantifiedDatedGoodsByExeflow.internalBinaryRead(reader, reader.uint32(), options)); break; case /* repeated string TrackingIDs */ 11: message.TrackingIDs.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: HandlingunitMapTrackingToExecutionFlowPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.TrackingSummary CurrentTrackingSummary = 1; */ if (message.CurrentTrackingSummary) TrackingSummary.internalBinaryWrite(message.CurrentTrackingSummary, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitStatusStruct Status = 2; */ if (message.Status) HandlingunitStatusStruct.internalBinaryWrite(message.Status, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); /* repeated api.QuantifiedGoodsByExeflow PreparedContents = 3; */ for (let i = 0; i < message.PreparedContents.length; i++) QuantifiedGoodsByExeflow.internalBinaryWrite(message.PreparedContents[i], writer.tag(3, WireType.LengthDelimited).fork(), options).join(); /* repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents = 4; */ for (let i = 0; i < message.ReceivedContents.length; i++) QuantifiedDatedGoodsByExeflow.internalBinaryWrite(message.ReceivedContents[i], writer.tag(4, WireType.LengthDelimited).fork(), options).join(); /* repeated string TrackingIDs = 11; */ for (let i = 0; i < message.TrackingIDs.length; i++) writer.tag(11, WireType.LengthDelimited).string(message.TrackingIDs[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.HandlingunitMapTrackingToExecutionFlowPayload */ export const HandlingunitMapTrackingToExecutionFlowPayload = new HandlingunitMapTrackingToExecutionFlowPayload$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitMapTrackingToExecutionFlow$Type extends MessageType { constructor() { super("api.HandlingunitMapTrackingToExecutionFlow", [ { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => CommandHeader }, { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID }, { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => HandlingunitMapTrackingToExecutionFlowPayload }, { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => HandlingunitMapTrackingToExecutionFlowPayload }, { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => HandlingunitMapTrackingToExecutionFlowPayload } ], { "api.messageType": "Command", "api.action": "MapTrackingToExecutionFlow", "api.resultingEvent": "executionflow.HUTrackingUpdated", "api.triggerEventFilters": "TrackingUpdated,Dispatched,ReadyToBeCollected", "api.windowMethod": "TumblingProcessingTimeWindows", "api.keyByExpression": "obj.getHeader().getProject()" }); } create(value?: PartialMessage): HandlingunitMapTrackingToExecutionFlow { const message = globalThis.Object.create((this.messagePrototype!)); if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitMapTrackingToExecutionFlow): HandlingunitMapTrackingToExecutionFlow { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.CommandHeader Header */ 1: message.Header = CommandHeader.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.HandlingunitMapTrackingToExecutionFlowPayload Payload */ 3: message.Payload = HandlingunitMapTrackingToExecutionFlowPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); break; case /* api.HandlingunitMapTrackingToExecutionFlowPayload EventPayload */ 4: message.EventPayload = HandlingunitMapTrackingToExecutionFlowPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); break; case /* api.HandlingunitMapTrackingToExecutionFlowPayload PreviousPayload */ 5: message.PreviousPayload = HandlingunitMapTrackingToExecutionFlowPayload.internalBinaryRead(reader, reader.uint32(), options, message.PreviousPayload); 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: HandlingunitMapTrackingToExecutionFlow, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.CommandHeader Header = 1; */ if (message.Header) CommandHeader.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.HandlingunitMapTrackingToExecutionFlowPayload Payload = 3; */ if (message.Payload) HandlingunitMapTrackingToExecutionFlowPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitMapTrackingToExecutionFlowPayload EventPayload = 4; */ if (message.EventPayload) HandlingunitMapTrackingToExecutionFlowPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitMapTrackingToExecutionFlowPayload PreviousPayload = 5; */ if (message.PreviousPayload) HandlingunitMapTrackingToExecutionFlowPayload.internalBinaryWrite(message.PreviousPayload, writer.tag(5, 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.HandlingunitMapTrackingToExecutionFlow */ export const HandlingunitMapTrackingToExecutionFlow = new HandlingunitMapTrackingToExecutionFlow$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitMapETAToExecutionFlowPayload$Type extends MessageType { constructor() { super("api.HandlingunitMapETAToExecutionFlowPayload", [ { no: 1, name: "HandlingunitETA", kind: "message", localName: "HandlingunitETA", jsonName: "HandlingunitETA", T: () => ETA }, { no: 3, name: "PreparedContents", kind: "message", localName: "PreparedContents", jsonName: "PreparedContents", repeat: 2 /*RepeatType.UNPACKED*/, T: () => QuantifiedGoodsByExeflow }, { no: 4, name: "ReceivedContents", kind: "message", localName: "ReceivedContents", jsonName: "ReceivedContents", repeat: 2 /*RepeatType.UNPACKED*/, T: () => QuantifiedDatedGoodsByExeflow } ], { "api.messageType": "Command", "api.payload": true, "api.action": "MapETAToExecutionFlow" }); } create(value?: PartialMessage): HandlingunitMapETAToExecutionFlowPayload { const message = globalThis.Object.create((this.messagePrototype!)); message.PreparedContents = []; message.ReceivedContents = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitMapETAToExecutionFlowPayload): HandlingunitMapETAToExecutionFlowPayload { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.ETA HandlingunitETA */ 1: message.HandlingunitETA = ETA.internalBinaryRead(reader, reader.uint32(), options, message.HandlingunitETA); break; case /* repeated api.QuantifiedGoodsByExeflow PreparedContents */ 3: message.PreparedContents.push(QuantifiedGoodsByExeflow.internalBinaryRead(reader, reader.uint32(), options)); break; case /* repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents */ 4: message.ReceivedContents.push(QuantifiedDatedGoodsByExeflow.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: HandlingunitMapETAToExecutionFlowPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.ETA HandlingunitETA = 1; */ if (message.HandlingunitETA) ETA.internalBinaryWrite(message.HandlingunitETA, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); /* repeated api.QuantifiedGoodsByExeflow PreparedContents = 3; */ for (let i = 0; i < message.PreparedContents.length; i++) QuantifiedGoodsByExeflow.internalBinaryWrite(message.PreparedContents[i], writer.tag(3, WireType.LengthDelimited).fork(), options).join(); /* repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents = 4; */ for (let i = 0; i < message.ReceivedContents.length; i++) QuantifiedDatedGoodsByExeflow.internalBinaryWrite(message.ReceivedContents[i], writer.tag(4, 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.HandlingunitMapETAToExecutionFlowPayload */ export const HandlingunitMapETAToExecutionFlowPayload = new HandlingunitMapETAToExecutionFlowPayload$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitMapETAToExecutionFlow$Type extends MessageType { constructor() { super("api.HandlingunitMapETAToExecutionFlow", [ { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => CommandHeader }, { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID }, { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => HandlingunitMapETAToExecutionFlowPayload }, { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => HandlingunitMapETAToExecutionFlowPayload }, { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => HandlingunitMapETAToExecutionFlowPayload } ], { "api.messageType": "Command", "api.action": "MapETAToExecutionFlow", "api.resultingEvent": "executionflow.HUETAUpdated", "api.triggerEventFilters": "ETAUpdated,TrackingETAUpdated,GoodsPrepared", "api.windowMethod": "TumblingProcessingTimeWindows", "api.keyByExpression": "obj.getHeader().getProject()" }); } create(value?: PartialMessage): HandlingunitMapETAToExecutionFlow { const message = globalThis.Object.create((this.messagePrototype!)); if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitMapETAToExecutionFlow): HandlingunitMapETAToExecutionFlow { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.CommandHeader Header */ 1: message.Header = CommandHeader.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.HandlingunitMapETAToExecutionFlowPayload Payload */ 3: message.Payload = HandlingunitMapETAToExecutionFlowPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); break; case /* api.HandlingunitMapETAToExecutionFlowPayload EventPayload */ 4: message.EventPayload = HandlingunitMapETAToExecutionFlowPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); break; case /* api.HandlingunitMapETAToExecutionFlowPayload PreviousPayload */ 5: message.PreviousPayload = HandlingunitMapETAToExecutionFlowPayload.internalBinaryRead(reader, reader.uint32(), options, message.PreviousPayload); 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: HandlingunitMapETAToExecutionFlow, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.CommandHeader Header = 1; */ if (message.Header) CommandHeader.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.HandlingunitMapETAToExecutionFlowPayload Payload = 3; */ if (message.Payload) HandlingunitMapETAToExecutionFlowPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitMapETAToExecutionFlowPayload EventPayload = 4; */ if (message.EventPayload) HandlingunitMapETAToExecutionFlowPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitMapETAToExecutionFlowPayload PreviousPayload = 5; */ if (message.PreviousPayload) HandlingunitMapETAToExecutionFlowPayload.internalBinaryWrite(message.PreviousPayload, writer.tag(5, 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.HandlingunitMapETAToExecutionFlow */ export const HandlingunitMapETAToExecutionFlow = new HandlingunitMapETAToExecutionFlow$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitPropagateTrackingPayload$Type extends MessageType { constructor() { super("api.HandlingunitPropagateTrackingPayload", [ { no: 1, name: "ContainsHUs", kind: "scalar", localName: "ContainsHUs", jsonName: "ContainsHUs", T: 8 /*ScalarType.BOOL*/ }, { no: 2, name: "IncludedHandlingunitIDs", kind: "scalar", localName: "IncludedHandlingunitIDs", jsonName: "IncludedHandlingunitIDs", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ }, { no: 3, name: "CurrentTrackingSummary", kind: "message", localName: "CurrentTrackingSummary", jsonName: "CurrentTrackingSummary", T: () => TrackingSummary }, { no: 4, name: "DispatchedDateTime", kind: "message", localName: "DispatchedDateTime", jsonName: "DispatchedDateTime", T: () => DateTime } ], { "api.messageType": "Command", "api.payload": true, "api.action": "PropagateTracking" }); } create(value?: PartialMessage): HandlingunitPropagateTrackingPayload { const message = globalThis.Object.create((this.messagePrototype!)); message.ContainsHUs = false; message.IncludedHandlingunitIDs = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitPropagateTrackingPayload): HandlingunitPropagateTrackingPayload { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* bool ContainsHUs */ 1: message.ContainsHUs = reader.bool(); break; case /* repeated string IncludedHandlingunitIDs */ 2: message.IncludedHandlingunitIDs.push(reader.string()); break; case /* api.TrackingSummary CurrentTrackingSummary */ 3: message.CurrentTrackingSummary = TrackingSummary.internalBinaryRead(reader, reader.uint32(), options, message.CurrentTrackingSummary); break; case /* api.DateTime DispatchedDateTime */ 4: message.DispatchedDateTime = DateTime.internalBinaryRead(reader, reader.uint32(), options, message.DispatchedDateTime); 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: HandlingunitPropagateTrackingPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* bool ContainsHUs = 1; */ if (message.ContainsHUs !== false) writer.tag(1, WireType.Varint).bool(message.ContainsHUs); /* repeated string IncludedHandlingunitIDs = 2; */ for (let i = 0; i < message.IncludedHandlingunitIDs.length; i++) writer.tag(2, WireType.LengthDelimited).string(message.IncludedHandlingunitIDs[i]); /* api.TrackingSummary CurrentTrackingSummary = 3; */ if (message.CurrentTrackingSummary) TrackingSummary.internalBinaryWrite(message.CurrentTrackingSummary, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); /* api.DateTime DispatchedDateTime = 4; */ if (message.DispatchedDateTime) DateTime.internalBinaryWrite(message.DispatchedDateTime, writer.tag(4, 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.HandlingunitPropagateTrackingPayload */ export const HandlingunitPropagateTrackingPayload = new HandlingunitPropagateTrackingPayload$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitPropagateTracking$Type extends MessageType { constructor() { super("api.HandlingunitPropagateTracking", [ { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => CommandHeader }, { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID }, { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => HandlingunitPropagateTrackingPayload }, { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => HandlingunitPropagateTrackingPayload }, { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => HandlingunitPropagateTrackingPayload } ], { "api.messageType": "Command", "api.action": "PropagateTracking", "api.resultingEvent": "TrackingUpdated", "api.triggerEventFilters": "TrackingUpdated,HUsAdded" }); } create(value?: PartialMessage): HandlingunitPropagateTracking { const message = globalThis.Object.create((this.messagePrototype!)); if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitPropagateTracking): HandlingunitPropagateTracking { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.CommandHeader Header */ 1: message.Header = CommandHeader.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.HandlingunitPropagateTrackingPayload Payload */ 3: message.Payload = HandlingunitPropagateTrackingPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); break; case /* api.HandlingunitPropagateTrackingPayload EventPayload */ 4: message.EventPayload = HandlingunitPropagateTrackingPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); break; case /* api.HandlingunitPropagateTrackingPayload PreviousPayload */ 5: message.PreviousPayload = HandlingunitPropagateTrackingPayload.internalBinaryRead(reader, reader.uint32(), options, message.PreviousPayload); 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: HandlingunitPropagateTracking, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.CommandHeader Header = 1; */ if (message.Header) CommandHeader.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.HandlingunitPropagateTrackingPayload Payload = 3; */ if (message.Payload) HandlingunitPropagateTrackingPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitPropagateTrackingPayload EventPayload = 4; */ if (message.EventPayload) HandlingunitPropagateTrackingPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitPropagateTrackingPayload PreviousPayload = 5; */ if (message.PreviousPayload) HandlingunitPropagateTrackingPayload.internalBinaryWrite(message.PreviousPayload, writer.tag(5, 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.HandlingunitPropagateTracking */ export const HandlingunitPropagateTracking = new HandlingunitPropagateTracking$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitPropagateETAPayload$Type extends MessageType { constructor() { super("api.HandlingunitPropagateETAPayload", [ { no: 1, name: "HandlingunitETA", kind: "message", localName: "HandlingunitETA", jsonName: "HandlingunitETA", T: () => ETA }, { no: 2, name: "IncludedHandlingunitIDs", kind: "scalar", localName: "IncludedHandlingunitIDs", jsonName: "IncludedHandlingunitIDs", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ }, { no: 3, name: "ContainsHUs", kind: "scalar", localName: "ContainsHUs", jsonName: "ContainsHUs", T: 8 /*ScalarType.BOOL*/ } ], { "api.messageType": "Command", "api.payload": true, "api.action": "PropagateETA" }); } create(value?: PartialMessage): HandlingunitPropagateETAPayload { const message = globalThis.Object.create((this.messagePrototype!)); message.IncludedHandlingunitIDs = []; message.ContainsHUs = false; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitPropagateETAPayload): HandlingunitPropagateETAPayload { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.ETA HandlingunitETA */ 1: message.HandlingunitETA = ETA.internalBinaryRead(reader, reader.uint32(), options, message.HandlingunitETA); break; case /* repeated string IncludedHandlingunitIDs */ 2: message.IncludedHandlingunitIDs.push(reader.string()); break; case /* bool ContainsHUs */ 3: message.ContainsHUs = 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: HandlingunitPropagateETAPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.ETA HandlingunitETA = 1; */ if (message.HandlingunitETA) ETA.internalBinaryWrite(message.HandlingunitETA, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); /* repeated string IncludedHandlingunitIDs = 2; */ for (let i = 0; i < message.IncludedHandlingunitIDs.length; i++) writer.tag(2, WireType.LengthDelimited).string(message.IncludedHandlingunitIDs[i]); /* bool ContainsHUs = 3; */ if (message.ContainsHUs !== false) writer.tag(3, WireType.Varint).bool(message.ContainsHUs); let u = options.writeUnknownFields; if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); return writer; } } /** * @generated MessageType for protobuf message api.HandlingunitPropagateETAPayload */ export const HandlingunitPropagateETAPayload = new HandlingunitPropagateETAPayload$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitPropagateETA$Type extends MessageType { constructor() { super("api.HandlingunitPropagateETA", [ { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => CommandHeader }, { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID }, { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => HandlingunitPropagateETAPayload }, { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => HandlingunitPropagateETAPayload }, { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => HandlingunitPropagateETAPayload } ], { "api.messageType": "Command", "api.action": "PropagateETA", "api.resultingEvent": "TrackingETAUpdated", "api.triggerEventFilters": "ETAUpdated,TrackingETAUpdated" }); } create(value?: PartialMessage): HandlingunitPropagateETA { const message = globalThis.Object.create((this.messagePrototype!)); if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitPropagateETA): HandlingunitPropagateETA { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.CommandHeader Header */ 1: message.Header = CommandHeader.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.HandlingunitPropagateETAPayload Payload */ 3: message.Payload = HandlingunitPropagateETAPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); break; case /* api.HandlingunitPropagateETAPayload EventPayload */ 4: message.EventPayload = HandlingunitPropagateETAPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); break; case /* api.HandlingunitPropagateETAPayload PreviousPayload */ 5: message.PreviousPayload = HandlingunitPropagateETAPayload.internalBinaryRead(reader, reader.uint32(), options, message.PreviousPayload); 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: HandlingunitPropagateETA, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.CommandHeader Header = 1; */ if (message.Header) CommandHeader.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.HandlingunitPropagateETAPayload Payload = 3; */ if (message.Payload) HandlingunitPropagateETAPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitPropagateETAPayload EventPayload = 4; */ if (message.EventPayload) HandlingunitPropagateETAPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitPropagateETAPayload PreviousPayload = 5; */ if (message.PreviousPayload) HandlingunitPropagateETAPayload.internalBinaryWrite(message.PreviousPayload, writer.tag(5, 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.HandlingunitPropagateETA */ export const HandlingunitPropagateETA = new HandlingunitPropagateETA$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitPropagateParentHUPayload$Type extends MessageType { constructor() { super("api.HandlingunitPropagateParentHUPayload", [ { no: 1, name: "ContainsHUs", kind: "scalar", localName: "ContainsHUs", jsonName: "ContainsHUs", T: 8 /*ScalarType.BOOL*/ }, { no: 2, name: "IncludedHandlingunitIDs", kind: "scalar", localName: "IncludedHandlingunitIDs", jsonName: "IncludedHandlingunitIDs", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ } ], { "api.messageType": "Command", "api.payload": true, "api.action": "PropagateParentHU" }); } create(value?: PartialMessage): HandlingunitPropagateParentHUPayload { const message = globalThis.Object.create((this.messagePrototype!)); message.ContainsHUs = false; message.IncludedHandlingunitIDs = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitPropagateParentHUPayload): HandlingunitPropagateParentHUPayload { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* bool ContainsHUs */ 1: message.ContainsHUs = reader.bool(); break; case /* repeated string IncludedHandlingunitIDs */ 2: message.IncludedHandlingunitIDs.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: HandlingunitPropagateParentHUPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* bool ContainsHUs = 1; */ if (message.ContainsHUs !== false) writer.tag(1, WireType.Varint).bool(message.ContainsHUs); /* repeated string IncludedHandlingunitIDs = 2; */ for (let i = 0; i < message.IncludedHandlingunitIDs.length; i++) writer.tag(2, WireType.LengthDelimited).string(message.IncludedHandlingunitIDs[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.HandlingunitPropagateParentHUPayload */ export const HandlingunitPropagateParentHUPayload = new HandlingunitPropagateParentHUPayload$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitPropagateParentHU$Type extends MessageType { constructor() { super("api.HandlingunitPropagateParentHU", [ { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => CommandHeader }, { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID }, { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => HandlingunitPropagateParentHUPayload }, { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => HandlingunitPropagateParentHUPayload }, { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => HandlingunitPropagateParentHUPayload } ], { "api.messageType": "Command", "api.action": "PropagateParentHU", "api.resultingEvent": "ParentHUUpdated", "api.triggerEventFilters": "HUsAdded" }); } create(value?: PartialMessage): HandlingunitPropagateParentHU { const message = globalThis.Object.create((this.messagePrototype!)); if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitPropagateParentHU): HandlingunitPropagateParentHU { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.CommandHeader Header */ 1: message.Header = CommandHeader.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.HandlingunitPropagateParentHUPayload Payload */ 3: message.Payload = HandlingunitPropagateParentHUPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); break; case /* api.HandlingunitPropagateParentHUPayload EventPayload */ 4: message.EventPayload = HandlingunitPropagateParentHUPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); break; case /* api.HandlingunitPropagateParentHUPayload PreviousPayload */ 5: message.PreviousPayload = HandlingunitPropagateParentHUPayload.internalBinaryRead(reader, reader.uint32(), options, message.PreviousPayload); 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: HandlingunitPropagateParentHU, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.CommandHeader Header = 1; */ if (message.Header) CommandHeader.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.HandlingunitPropagateParentHUPayload Payload = 3; */ if (message.Payload) HandlingunitPropagateParentHUPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitPropagateParentHUPayload EventPayload = 4; */ if (message.EventPayload) HandlingunitPropagateParentHUPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitPropagateParentHUPayload PreviousPayload = 5; */ if (message.PreviousPayload) HandlingunitPropagateParentHUPayload.internalBinaryWrite(message.PreviousPayload, writer.tag(5, 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.HandlingunitPropagateParentHU */ export const HandlingunitPropagateParentHU = new HandlingunitPropagateParentHU$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitMoveStockPayload$Type extends MessageType { constructor() { super("api.HandlingunitMoveStockPayload", [ { no: 1, name: "PreparedContents", kind: "message", localName: "PreparedContents", jsonName: "PreparedContents", repeat: 2 /*RepeatType.UNPACKED*/, T: () => QuantifiedGoodsByExeflow }, { no: 2, name: "ReceivedContents", kind: "message", localName: "ReceivedContents", jsonName: "ReceivedContents", repeat: 2 /*RepeatType.UNPACKED*/, T: () => QuantifiedDatedGoodsByExeflow }, { no: 8, name: "Status", kind: "message", localName: "Status", jsonName: "Status", T: () => HandlingunitStatusStruct }, { no: 9, name: "DispatchedDateTime", kind: "message", localName: "DispatchedDateTime", jsonName: "DispatchedDateTime", T: () => DateTime } ], { "api.messageType": "Command", "api.payload": true, "api.action": "MoveStock" }); } create(value?: PartialMessage): HandlingunitMoveStockPayload { const message = globalThis.Object.create((this.messagePrototype!)); message.PreparedContents = []; message.ReceivedContents = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitMoveStockPayload): HandlingunitMoveStockPayload { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* repeated api.QuantifiedGoodsByExeflow PreparedContents */ 1: message.PreparedContents.push(QuantifiedGoodsByExeflow.internalBinaryRead(reader, reader.uint32(), options)); break; case /* repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents */ 2: message.ReceivedContents.push(QuantifiedDatedGoodsByExeflow.internalBinaryRead(reader, reader.uint32(), options)); break; case /* api.HandlingunitStatusStruct Status */ 8: message.Status = HandlingunitStatusStruct.internalBinaryRead(reader, reader.uint32(), options, message.Status); break; case /* api.DateTime DispatchedDateTime */ 9: message.DispatchedDateTime = DateTime.internalBinaryRead(reader, reader.uint32(), options, message.DispatchedDateTime); 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: HandlingunitMoveStockPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* repeated api.QuantifiedGoodsByExeflow PreparedContents = 1; */ for (let i = 0; i < message.PreparedContents.length; i++) QuantifiedGoodsByExeflow.internalBinaryWrite(message.PreparedContents[i], writer.tag(1, WireType.LengthDelimited).fork(), options).join(); /* repeated api.QuantifiedDatedGoodsByExeflow ReceivedContents = 2; */ for (let i = 0; i < message.ReceivedContents.length; i++) QuantifiedDatedGoodsByExeflow.internalBinaryWrite(message.ReceivedContents[i], writer.tag(2, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitStatusStruct Status = 8; */ if (message.Status) HandlingunitStatusStruct.internalBinaryWrite(message.Status, writer.tag(8, WireType.LengthDelimited).fork(), options).join(); /* api.DateTime DispatchedDateTime = 9; */ if (message.DispatchedDateTime) DateTime.internalBinaryWrite(message.DispatchedDateTime, writer.tag(9, 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.HandlingunitMoveStockPayload */ export const HandlingunitMoveStockPayload = new HandlingunitMoveStockPayload$Type(); // @generated message type with reflection information, may provide speed optimized methods class HandlingunitMoveStock$Type extends MessageType { constructor() { super("api.HandlingunitMoveStock", [ { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => CommandHeader }, { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID }, { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => HandlingunitMoveStockPayload }, { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => HandlingunitMoveStockPayload }, { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => HandlingunitMoveStockPayload } ], { "api.messageType": "Command", "api.action": "MoveStock", "api.resultingEvent": "movement.Generated", "api.triggerEventFilters": "TrackingUpdated,Dispatched,GoodsPrepared,GoodsReceived" }); } create(value?: PartialMessage): HandlingunitMoveStock { const message = globalThis.Object.create((this.messagePrototype!)); if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: HandlingunitMoveStock): HandlingunitMoveStock { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.CommandHeader Header */ 1: message.Header = CommandHeader.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.HandlingunitMoveStockPayload Payload */ 3: message.Payload = HandlingunitMoveStockPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); break; case /* api.HandlingunitMoveStockPayload EventPayload */ 4: message.EventPayload = HandlingunitMoveStockPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); break; case /* api.HandlingunitMoveStockPayload PreviousPayload */ 5: message.PreviousPayload = HandlingunitMoveStockPayload.internalBinaryRead(reader, reader.uint32(), options, message.PreviousPayload); 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: HandlingunitMoveStock, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.CommandHeader Header = 1; */ if (message.Header) CommandHeader.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.HandlingunitMoveStockPayload Payload = 3; */ if (message.Payload) HandlingunitMoveStockPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitMoveStockPayload EventPayload = 4; */ if (message.EventPayload) HandlingunitMoveStockPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); /* api.HandlingunitMoveStockPayload PreviousPayload = 5; */ if (message.PreviousPayload) HandlingunitMoveStockPayload.internalBinaryWrite(message.PreviousPayload, writer.tag(5, 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.HandlingunitMoveStock */ export const HandlingunitMoveStock = new HandlingunitMoveStock$Type();