reflex-platform/npm-core-sdk
0
Fork 0
Code Pull Requests Projects Releases Wiki Activity

Latest generation

Browse Source
This commit is contained in:
ci core model
2025-03-21 13:35:27 +00:00
parent d42679cbd6
commit 27ece28db3
16 changed files with 8467 additions and 482 deletions
Download Patch File Download Diff File Expand all files Collapse all files

633
trackingInput.ts
View File

@@ -16,8 +16,9 @@ import { ETA } from "./tradeShared";
import { TradeTier } from "./tradeShared";
import { DateTime } from "./shared";
import { ResponseHeader } from "./shared";
import { EntityID } from "./shared";
import { RequestProjectHeader } from "./shared";
import { EntityID } from "./shared";
import { EventHeader } from "./shared";
import { TrackingEvent } from "./transportShared";
// Notified
@@ -36,6 +37,23 @@ export interface TrackingNotifiedPayload {
*/
events: TrackingEvent[];
}
/**
* @generated from protobuf message api.TrackingNotifiedEvent
*/
export interface TrackingNotifiedEvent {
/**
* @generated from protobuf field: api.EventHeader Header = 1 [json_name = "Header"];
*/
header?: EventHeader;
/**
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
/**
* @generated from protobuf field: api.TrackingNotifiedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: TrackingNotifiedPayload;
}
/**
* @generated from protobuf message api.TrackingNotifiedRequest
*/
@@ -113,6 +131,23 @@ export interface TrackingDispatchedPayload {
*/
hUShipTo?: TradeTier;
}
/**
* @generated from protobuf message api.TrackingDispatchedEvent
*/
export interface TrackingDispatchedEvent {
/**
* @generated from protobuf field: api.EventHeader Header = 1 [json_name = "Header"];
*/
header?: EventHeader;
/**
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
/**
* @generated from protobuf field: api.TrackingDispatchedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: TrackingDispatchedPayload;
}
/**
* @generated from protobuf message api.TrackingDispatchedRequest
*/
@@ -178,6 +213,23 @@ export interface TrackingHULabeledPayload {
*/
hUShipTo?: TradeTier;
}
/**
* @generated from protobuf message api.TrackingHULabeledEvent
*/
export interface TrackingHULabeledEvent {
/**
* @generated from protobuf field: api.EventHeader Header = 1 [json_name = "Header"];
*/
header?: EventHeader;
/**
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
/**
* @generated from protobuf field: api.TrackingHULabeledPayload Payload = 3 [json_name = "Payload"];
*/
payload?: TrackingHULabeledPayload;
}
/**
* @generated from protobuf message api.TrackingHULabeledRequest
*/
@@ -243,6 +295,23 @@ export interface TrackingSwitchedPayload {
*/
nextHUShipTo?: TradeTier;
}
/**
* @generated from protobuf message api.TrackingSwitchedEvent
*/
export interface TrackingSwitchedEvent {
/**
* @generated from protobuf field: api.EventHeader Header = 1 [json_name = "Header"];
*/
header?: EventHeader;
/**
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
/**
* @generated from protobuf field: api.TrackingSwitchedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: TrackingSwitchedPayload;
}
/**
* @generated from protobuf message api.TrackingSwitchedRequest
*/
@@ -287,6 +356,23 @@ export interface TrackingETAUpdatedPayload {
*/
trackingETA?: ETA;
}
/**
* @generated from protobuf message api.TrackingETAUpdatedEvent
*/
export interface TrackingETAUpdatedEvent {
/**
* @generated from protobuf field: api.EventHeader Header = 1 [json_name = "Header"];
*/
header?: EventHeader;
/**
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
/**
* @generated from protobuf field: api.TrackingETAUpdatedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: TrackingETAUpdatedPayload;
}
/**
* @generated from protobuf message api.TrackingETAUpdatedRequest
*/
@@ -329,6 +415,23 @@ export interface TrackingAttachmentAddedPayload {
*/
attachments: AttachmentSummary[];
}
/**
* @generated from protobuf message api.TrackingAttachmentAddedEvent
*/
export interface TrackingAttachmentAddedEvent {
/**
* @generated from protobuf field: api.EventHeader Header = 1 [json_name = "Header"];
*/
header?: EventHeader;
/**
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
/**
* @generated from protobuf field: api.TrackingAttachmentAddedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: TrackingAttachmentAddedPayload;
}
/**
* @generated from protobuf message api.TrackingAttachmentAddedRequest
*/
@@ -371,6 +474,23 @@ export interface TrackingAttachmentRemovedPayload {
*/
attachments: AttachmentSummary[];
}
/**
* @generated from protobuf message api.TrackingAttachmentRemovedEvent
*/
export interface TrackingAttachmentRemovedEvent {
/**
* @generated from protobuf field: api.EventHeader Header = 1 [json_name = "Header"];
*/
header?: EventHeader;
/**
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
/**
* @generated from protobuf field: api.TrackingAttachmentRemovedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: TrackingAttachmentRemovedPayload;
}
/**
* @generated from protobuf message api.TrackingAttachmentRemovedRequest
*/
@@ -408,6 +528,25 @@ export interface TrackingAttachmentRemovedResponse {
*/
export interface TrackingDeletedPayload {
}
/**
* Event message
*
* @generated from protobuf message api.TrackingDeletedEvent
*/
export interface TrackingDeletedEvent {
/**
* @generated from protobuf field: api.EventHeader Header = 1 [json_name = "Header"];
*/
header?: EventHeader;
/**
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
/**
* @generated from protobuf field: api.TrackingDeletedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: TrackingDeletedPayload;
}
/**
* API Request
*
@@ -490,6 +629,66 @@ class TrackingNotifiedPayload$Type extends MessageType<TrackingNotifiedPayload>
*/
export const TrackingNotifiedPayload = new TrackingNotifiedPayload$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingNotifiedEvent$Type extends MessageType<TrackingNotifiedEvent> {
constructor() {
super("api.TrackingNotifiedEvent", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => TrackingNotifiedPayload, options: { "validate.rules": { message: { required: true } } } }
], { "api.messageType": "Event", "api.inputEvent": "Notified" });
}
create(value?: PartialMessage<TrackingNotifiedEvent>): TrackingNotifiedEvent {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<TrackingNotifiedEvent>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TrackingNotifiedEvent): TrackingNotifiedEvent {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EventHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
break;
case /* api.TrackingNotifiedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = TrackingNotifiedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
break;
default:
let u = options.readUnknownField;
if (u === "throw")
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
let d = reader.skip(wireType);
if (u !== false)
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
}
}
return message;
}
internalBinaryWrite(message: TrackingNotifiedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EventHeader Header = 1 [json_name = "Header"]; */
if (message.header)
EventHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
/* api.TrackingNotifiedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
TrackingNotifiedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.TrackingNotifiedEvent
*/
export const TrackingNotifiedEvent = new TrackingNotifiedEvent$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingNotifiedRequest$Type extends MessageType<TrackingNotifiedRequest> {
constructor() {
super("api.TrackingNotifiedRequest", [
@@ -612,7 +811,7 @@ class TrackingDispatchedPayload$Type extends MessageType<TrackingDispatchedPaylo
{ no: 6, name: "HUCarrier", kind: "message", jsonName: "HUCarrier", T: () => TradeTier, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "The carrier which tracks the Handling unit" } } },
{ no: 7, name: "HUShipFrom", kind: "message", jsonName: "HUShipFrom", T: () => TradeTier, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Where the Handling unit is shipped from" } } },
{ no: 8, name: "HUShipTo", kind: "message", jsonName: "HUShipTo", T: () => TradeTier, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Where the Handling unit is shipped to" } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["HandlingunitID", "DispatchedDateTime"] } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "Dispatched", "api.preAggMethods": "verifyActorPartner" });
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["HandlingunitID", "DispatchedDateTime"] } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "Dispatched" });
}
create(value?: PartialMessage<TrackingDispatchedPayload>): TrackingDispatchedPayload {
const message = globalThis.Object.create((this.messagePrototype!));
@@ -686,6 +885,66 @@ class TrackingDispatchedPayload$Type extends MessageType<TrackingDispatchedPaylo
*/
export const TrackingDispatchedPayload = new TrackingDispatchedPayload$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingDispatchedEvent$Type extends MessageType<TrackingDispatchedEvent> {
constructor() {
super("api.TrackingDispatchedEvent", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => TrackingDispatchedPayload, options: { "validate.rules": { message: { required: true } } } }
], { "api.messageType": "Event", "api.inputEvent": "Dispatched", "api.preAggMethods": "verifyActorPartner" });
}
create(value?: PartialMessage<TrackingDispatchedEvent>): TrackingDispatchedEvent {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<TrackingDispatchedEvent>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TrackingDispatchedEvent): TrackingDispatchedEvent {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EventHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
break;
case /* api.TrackingDispatchedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = TrackingDispatchedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
break;
default:
let u = options.readUnknownField;
if (u === "throw")
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
let d = reader.skip(wireType);
if (u !== false)
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
}
}
return message;
}
internalBinaryWrite(message: TrackingDispatchedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EventHeader Header = 1 [json_name = "Header"]; */
if (message.header)
EventHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
/* api.TrackingDispatchedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
TrackingDispatchedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.TrackingDispatchedEvent
*/
export const TrackingDispatchedEvent = new TrackingDispatchedEvent$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingDispatchedRequest$Type extends MessageType<TrackingDispatchedRequest> {
constructor() {
super("api.TrackingDispatchedRequest", [
@@ -807,7 +1066,7 @@ class TrackingHULabeledPayload$Type extends MessageType<TrackingHULabeledPayload
{ no: 6, name: "HUCarrier", kind: "message", jsonName: "HUCarrier", T: () => TradeTier, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "The carrier which tracks the Handling unit" } } },
{ no: 7, name: "HUShipFrom", kind: "message", jsonName: "HUShipFrom", T: () => TradeTier, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Where the Handling unit is shipped from" } } },
{ no: 8, name: "HUShipTo", kind: "message", jsonName: "HUShipTo", T: () => TradeTier, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Where the Handling unit is shipped to" } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["HandlingunitID", "DispatchedDateTime"] } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "HULabeled", "api.preAggMethods": "verifyActorPartner" });
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["HandlingunitID", "DispatchedDateTime"] } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "HULabeled" });
}
create(value?: PartialMessage<TrackingHULabeledPayload>): TrackingHULabeledPayload {
const message = globalThis.Object.create((this.messagePrototype!));
@@ -875,6 +1134,66 @@ class TrackingHULabeledPayload$Type extends MessageType<TrackingHULabeledPayload
*/
export const TrackingHULabeledPayload = new TrackingHULabeledPayload$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingHULabeledEvent$Type extends MessageType<TrackingHULabeledEvent> {
constructor() {
super("api.TrackingHULabeledEvent", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => TrackingHULabeledPayload, options: { "validate.rules": { message: { required: true } } } }
], { "api.messageType": "Event", "api.inputEvent": "HULabeled", "api.preAggMethods": "verifyActorPartner" });
}
create(value?: PartialMessage<TrackingHULabeledEvent>): TrackingHULabeledEvent {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<TrackingHULabeledEvent>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TrackingHULabeledEvent): TrackingHULabeledEvent {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EventHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
break;
case /* api.TrackingHULabeledPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = TrackingHULabeledPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
break;
default:
let u = options.readUnknownField;
if (u === "throw")
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
let d = reader.skip(wireType);
if (u !== false)
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
}
}
return message;
}
internalBinaryWrite(message: TrackingHULabeledEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EventHeader Header = 1 [json_name = "Header"]; */
if (message.header)
EventHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
/* api.TrackingHULabeledPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
TrackingHULabeledPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.TrackingHULabeledEvent
*/
export const TrackingHULabeledEvent = new TrackingHULabeledEvent$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingHULabeledRequest$Type extends MessageType<TrackingHULabeledRequest> {
constructor() {
super("api.TrackingHULabeledRequest", [
@@ -996,7 +1315,7 @@ class TrackingSwitchedPayload$Type extends MessageType<TrackingSwitchedPayload>
{ no: 3, name: "NextHUCarrier", kind: "message", jsonName: "NextHUCarrier", T: () => TradeTier, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "The new carrier which will track the Handling unit" } } },
{ no: 4, name: "NextHUShipFrom", kind: "message", jsonName: "NextHUShipFrom", T: () => TradeTier, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Where the Handling unit will be shipped from" } } },
{ no: 5, name: "NextHUShipTo", kind: "message", jsonName: "NextHUShipTo", T: () => TradeTier, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Where the Handling unit will be shipped to" } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["NextTrackingID"] } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "Switched", "api.preAggMethods": "verifyActorPartner" });
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["NextTrackingID"] } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "Switched" });
}
create(value?: PartialMessage<TrackingSwitchedPayload>): TrackingSwitchedPayload {
const message = globalThis.Object.create((this.messagePrototype!));
@@ -1064,6 +1383,66 @@ class TrackingSwitchedPayload$Type extends MessageType<TrackingSwitchedPayload>
*/
export const TrackingSwitchedPayload = new TrackingSwitchedPayload$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingSwitchedEvent$Type extends MessageType<TrackingSwitchedEvent> {
constructor() {
super("api.TrackingSwitchedEvent", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => TrackingSwitchedPayload, options: { "validate.rules": { message: { required: true } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["HandlingunitID", "DispatchedDateTime"] } }, "api.messageType": "Event", "api.inputEvent": "Switched", "api.preAggMethods": "verifyActorPartner" });
}
create(value?: PartialMessage<TrackingSwitchedEvent>): TrackingSwitchedEvent {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<TrackingSwitchedEvent>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TrackingSwitchedEvent): TrackingSwitchedEvent {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EventHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
break;
case /* api.TrackingSwitchedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = TrackingSwitchedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
break;
default:
let u = options.readUnknownField;
if (u === "throw")
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
let d = reader.skip(wireType);
if (u !== false)
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
}
}
return message;
}
internalBinaryWrite(message: TrackingSwitchedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EventHeader Header = 1 [json_name = "Header"]; */
if (message.header)
EventHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
/* api.TrackingSwitchedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
TrackingSwitchedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.TrackingSwitchedEvent
*/
export const TrackingSwitchedEvent = new TrackingSwitchedEvent$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingSwitchedRequest$Type extends MessageType<TrackingSwitchedRequest> {
constructor() {
super("api.TrackingSwitchedRequest", [
@@ -1181,7 +1560,7 @@ class TrackingETAUpdatedPayload$Type extends MessageType<TrackingETAUpdatedPaylo
constructor() {
super("api.TrackingETAUpdatedPayload", [
{ no: 1, name: "TrackingETA", kind: "message", jsonName: "TrackingETA", T: () => ETA, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "The ETA for the tracked HU" } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["TrackingETA"] } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "ETAUpdated", "api.preAggMethods": "setETAActualDate" });
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["TrackingETA"] } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "ETAUpdated" });
}
create(value?: PartialMessage<TrackingETAUpdatedPayload>): TrackingETAUpdatedPayload {
const message = globalThis.Object.create((this.messagePrototype!));
@@ -1223,6 +1602,66 @@ class TrackingETAUpdatedPayload$Type extends MessageType<TrackingETAUpdatedPaylo
*/
export const TrackingETAUpdatedPayload = new TrackingETAUpdatedPayload$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingETAUpdatedEvent$Type extends MessageType<TrackingETAUpdatedEvent> {
constructor() {
super("api.TrackingETAUpdatedEvent", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => TrackingETAUpdatedPayload, options: { "validate.rules": { message: { required: true } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["TrackingETA"] } }, "api.messageType": "Event", "api.inputEvent": "ETAUpdated", "api.preAggMethods": "setETAActualDate" });
}
create(value?: PartialMessage<TrackingETAUpdatedEvent>): TrackingETAUpdatedEvent {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<TrackingETAUpdatedEvent>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TrackingETAUpdatedEvent): TrackingETAUpdatedEvent {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EventHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
break;
case /* api.TrackingETAUpdatedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = TrackingETAUpdatedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
break;
default:
let u = options.readUnknownField;
if (u === "throw")
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
let d = reader.skip(wireType);
if (u !== false)
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
}
}
return message;
}
internalBinaryWrite(message: TrackingETAUpdatedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EventHeader Header = 1 [json_name = "Header"]; */
if (message.header)
EventHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
/* api.TrackingETAUpdatedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
TrackingETAUpdatedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.TrackingETAUpdatedEvent
*/
export const TrackingETAUpdatedEvent = new TrackingETAUpdatedEvent$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingETAUpdatedRequest$Type extends MessageType<TrackingETAUpdatedRequest> {
constructor() {
super("api.TrackingETAUpdatedRequest", [
@@ -1340,7 +1779,7 @@ class TrackingAttachmentAddedPayload$Type extends MessageType<TrackingAttachment
constructor() {
super("api.TrackingAttachmentAddedPayload", [
{ no: 1, name: "Attachments", kind: "message", jsonName: "Attachments", repeat: 1 /*RepeatType.PACKED*/, T: () => AttachmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Number of attachments added per type" } } }
], { "api.messageType": "Event", "api.payload": true, "api.inputEvent": "AttachmentAdded", "api.preAggMethods": "addAttachment" });
], { "api.messageType": "Event", "api.payload": true, "api.inputEvent": "AttachmentAdded" });
}
create(value?: PartialMessage<TrackingAttachmentAddedPayload>): TrackingAttachmentAddedPayload {
const message = globalThis.Object.create((this.messagePrototype!));
@@ -1383,6 +1822,66 @@ class TrackingAttachmentAddedPayload$Type extends MessageType<TrackingAttachment
*/
export const TrackingAttachmentAddedPayload = new TrackingAttachmentAddedPayload$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingAttachmentAddedEvent$Type extends MessageType<TrackingAttachmentAddedEvent> {
constructor() {
super("api.TrackingAttachmentAddedEvent", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => TrackingAttachmentAddedPayload, options: { "validate.rules": { message: { required: true } } } }
], { "api.messageType": "Event", "api.inputEvent": "AttachmentAdded", "api.preAggMethods": "addAttachment" });
}
create(value?: PartialMessage<TrackingAttachmentAddedEvent>): TrackingAttachmentAddedEvent {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<TrackingAttachmentAddedEvent>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TrackingAttachmentAddedEvent): TrackingAttachmentAddedEvent {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EventHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
break;
case /* api.TrackingAttachmentAddedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = TrackingAttachmentAddedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
break;
default:
let u = options.readUnknownField;
if (u === "throw")
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
let d = reader.skip(wireType);
if (u !== false)
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
}
}
return message;
}
internalBinaryWrite(message: TrackingAttachmentAddedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EventHeader Header = 1 [json_name = "Header"]; */
if (message.header)
EventHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
/* api.TrackingAttachmentAddedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
TrackingAttachmentAddedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.TrackingAttachmentAddedEvent
*/
export const TrackingAttachmentAddedEvent = new TrackingAttachmentAddedEvent$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingAttachmentAddedRequest$Type extends MessageType<TrackingAttachmentAddedRequest> {
constructor() {
super("api.TrackingAttachmentAddedRequest", [
@@ -1500,7 +1999,7 @@ class TrackingAttachmentRemovedPayload$Type extends MessageType<TrackingAttachme
constructor() {
super("api.TrackingAttachmentRemovedPayload", [
{ no: 1, name: "Attachments", kind: "message", jsonName: "Attachments", repeat: 1 /*RepeatType.PACKED*/, T: () => AttachmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Number of attachments removed per type" } } }
], { "api.messageType": "Event", "api.payload": true, "api.inputEvent": "AttachmentRemoved", "api.preAggMethods": "removeAttachment" });
], { "api.messageType": "Event", "api.payload": true, "api.inputEvent": "AttachmentRemoved" });
}
create(value?: PartialMessage<TrackingAttachmentRemovedPayload>): TrackingAttachmentRemovedPayload {
const message = globalThis.Object.create((this.messagePrototype!));
@@ -1543,6 +2042,66 @@ class TrackingAttachmentRemovedPayload$Type extends MessageType<TrackingAttachme
*/
export const TrackingAttachmentRemovedPayload = new TrackingAttachmentRemovedPayload$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingAttachmentRemovedEvent$Type extends MessageType<TrackingAttachmentRemovedEvent> {
constructor() {
super("api.TrackingAttachmentRemovedEvent", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => TrackingAttachmentRemovedPayload, options: { "validate.rules": { message: { required: true } } } }
], { "api.messageType": "Event", "api.inputEvent": "AttachmentRemoved", "api.preAggMethods": "removeAttachment" });
}
create(value?: PartialMessage<TrackingAttachmentRemovedEvent>): TrackingAttachmentRemovedEvent {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<TrackingAttachmentRemovedEvent>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TrackingAttachmentRemovedEvent): TrackingAttachmentRemovedEvent {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EventHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
break;
case /* api.TrackingAttachmentRemovedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = TrackingAttachmentRemovedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
break;
default:
let u = options.readUnknownField;
if (u === "throw")
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
let d = reader.skip(wireType);
if (u !== false)
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
}
}
return message;
}
internalBinaryWrite(message: TrackingAttachmentRemovedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EventHeader Header = 1 [json_name = "Header"]; */
if (message.header)
EventHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
/* api.TrackingAttachmentRemovedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
TrackingAttachmentRemovedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.TrackingAttachmentRemovedEvent
*/
export const TrackingAttachmentRemovedEvent = new TrackingAttachmentRemovedEvent$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingAttachmentRemovedRequest$Type extends MessageType<TrackingAttachmentRemovedRequest> {
constructor() {
super("api.TrackingAttachmentRemovedRequest", [
@@ -1694,6 +2253,66 @@ class TrackingDeletedPayload$Type extends MessageType<TrackingDeletedPayload> {
*/
export const TrackingDeletedPayload = new TrackingDeletedPayload$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingDeletedEvent$Type extends MessageType<TrackingDeletedEvent> {
constructor() {
super("api.TrackingDeletedEvent", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => EventHeader },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => TrackingDeletedPayload }
], { "api.messageType": "Event", "api.inputEvent": "Deleted" });
}
create(value?: PartialMessage<TrackingDeletedEvent>): TrackingDeletedEvent {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<TrackingDeletedEvent>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: TrackingDeletedEvent): TrackingDeletedEvent {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EventHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
break;
case /* api.TrackingDeletedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = TrackingDeletedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
break;
default:
let u = options.readUnknownField;
if (u === "throw")
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
let d = reader.skip(wireType);
if (u !== false)
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
}
}
return message;
}
internalBinaryWrite(message: TrackingDeletedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EventHeader Header = 1 [json_name = "Header"]; */
if (message.header)
EventHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
/* api.TrackingDeletedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
TrackingDeletedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.TrackingDeletedEvent
*/
export const TrackingDeletedEvent = new TrackingDeletedEvent$Type();
// @generated message type with reflection information, may provide speed optimized methods
class TrackingDeletedRequest$Type extends MessageType<TrackingDeletedRequest> {
constructor() {
super("api.TrackingDeletedRequest", [