You've already forked npm-core-sdk
1404 lines
83 KiB
TypeScript
1404 lines
83 KiB
TypeScript
// @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<HandlingunitMapContentToExecutionFlowPayload> {
|
|
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>): 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<HandlingunitMapContentToExecutionFlowPayload>(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<HandlingunitMapContentToExecutionFlow> {
|
|
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>): HandlingunitMapContentToExecutionFlow {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitMapContentToExecutionFlow>(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<HandlingunitMapTrackingToExecutionFlowPayload> {
|
|
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>): HandlingunitMapTrackingToExecutionFlowPayload {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.PreparedContents = [];
|
|
message.ReceivedContents = [];
|
|
message.TrackingIDs = [];
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitMapTrackingToExecutionFlowPayload>(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<HandlingunitMapTrackingToExecutionFlow> {
|
|
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>): HandlingunitMapTrackingToExecutionFlow {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitMapTrackingToExecutionFlow>(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<HandlingunitMapETAToExecutionFlowPayload> {
|
|
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>): HandlingunitMapETAToExecutionFlowPayload {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.PreparedContents = [];
|
|
message.ReceivedContents = [];
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitMapETAToExecutionFlowPayload>(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<HandlingunitMapETAToExecutionFlow> {
|
|
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>): HandlingunitMapETAToExecutionFlow {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitMapETAToExecutionFlow>(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<HandlingunitPropagateTrackingPayload> {
|
|
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>): HandlingunitPropagateTrackingPayload {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.ContainsHUs = false;
|
|
message.IncludedHandlingunitIDs = [];
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitPropagateTrackingPayload>(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<HandlingunitPropagateTracking> {
|
|
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>): HandlingunitPropagateTracking {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitPropagateTracking>(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<HandlingunitPropagateETAPayload> {
|
|
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>): HandlingunitPropagateETAPayload {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.IncludedHandlingunitIDs = [];
|
|
message.ContainsHUs = false;
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitPropagateETAPayload>(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<HandlingunitPropagateETA> {
|
|
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>): HandlingunitPropagateETA {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitPropagateETA>(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<HandlingunitPropagateParentHUPayload> {
|
|
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>): HandlingunitPropagateParentHUPayload {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.ContainsHUs = false;
|
|
message.IncludedHandlingunitIDs = [];
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitPropagateParentHUPayload>(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<HandlingunitPropagateParentHU> {
|
|
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>): HandlingunitPropagateParentHU {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitPropagateParentHU>(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<HandlingunitMoveStockPayload> {
|
|
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>): HandlingunitMoveStockPayload {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.PreparedContents = [];
|
|
message.ReceivedContents = [];
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitMoveStockPayload>(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<HandlingunitMoveStock> {
|
|
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>): HandlingunitMoveStock {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<HandlingunitMoveStock>(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();
|