diff --git a/alias.ts b/alias.ts index 2b88e526..4a34775b 100644 --- a/alias.ts +++ b/alias.ts @@ -12,7 +12,7 @@ import type { PartialMessage } from "@protobuf-ts/runtime"; import { reflectionMergePartial } from "@protobuf-ts/runtime"; import { MessageType } from "@protobuf-ts/runtime"; import { CommandIdentifierEntry } from "./slotbooking"; -import { AppointmentType } from "./slotbooking"; +import { AppointmentType } from "./shared"; /** * Properties specific to appointment scheduling aliases * diff --git a/appointment.ts b/appointment.ts index c37f19c4..94625c5a 100644 --- a/appointment.ts +++ b/appointment.ts @@ -14,12 +14,12 @@ import { AppointmentContent } from "./slotbooking"; import { Address } from "./repositoryShared"; import { AttachmentSummary } from "./shared"; import { DateTime } from "./shared"; -import { AppointmentStatusStruct } from "./collabShared"; +import { AppointmentStatusStruct } from "./shared"; import { Slot } from "./slotbooking"; import { MetadataElement } from "./shared"; import { SegmentationSelection } from "./slotbooking"; import { AppointmentCommission } from "./slotbooking"; -import { AppointmentType } from "./slotbooking"; +import { AppointmentType } from "./shared"; import { EntityID } from "./shared"; import { EventHeader } from "./shared"; // _common_ diff --git a/appointmentAction.ts b/appointmentAction.ts index 34a0e67c..8012daac 100644 --- a/appointmentAction.ts +++ b/appointmentAction.ts @@ -15,10 +15,10 @@ import { EntityID } from "./shared"; import { CommandHeader } from "./shared"; import { AppointmentContent } from "./slotbooking"; import { AttachmentSummary } from "./shared"; -import { AppointmentStatusStruct } from "./collabShared"; +import { AppointmentStatusStruct } from "./shared"; import { Slot } from "./slotbooking"; import { MetadataElement } from "./shared"; -import { AppointmentType } from "./slotbooking"; +import { AppointmentType } from "./shared"; // Action Summary // - Notify : Push appointment to project present into the commissions @@ -279,6 +279,178 @@ export interface AppointmentLockBooking { */ PreviousPayload?: AppointmentLockBookingPayload; } +/** + * + * AppointmentSummaryToOrder : map the appointment information to the corresponding trade order entity + * + * @generated from protobuf message api.AppointmentSummaryToOrderPayload + */ +export interface AppointmentSummaryToOrderPayload { + /** + * @generated from protobuf field: api.AppointmentContent Loading = 1 + */ + Loading?: AppointmentContent; + /** + * @generated from protobuf field: api.AppointmentContent Unloading = 2 + */ + Unloading?: AppointmentContent; + /** + * @generated from protobuf field: api.AppointmentStatusStruct Status = 3 + */ + Status?: AppointmentStatusStruct; +} +/** + * @generated from protobuf message api.AppointmentSummaryToOrder + */ +export interface AppointmentSummaryToOrder { + /** + * @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.AppointmentSummaryToOrderPayload Payload = 3 + */ + Payload?: AppointmentSummaryToOrderPayload; + /** + * @generated from protobuf field: api.AppointmentSummaryToOrderPayload EventPayload = 4 + */ + EventPayload?: AppointmentSummaryToOrderPayload; + /** + * @generated from protobuf field: api.AppointmentSummaryToOrderPayload PreviousPayload = 5 + */ + PreviousPayload?: AppointmentSummaryToOrderPayload; +} +/** + * + * AppointmentSummaryToExecutionflow : map the appointment information to the corresponding trade executionflow entity + * + * @generated from protobuf message api.AppointmentSummaryToExecutionflowPayload + */ +export interface AppointmentSummaryToExecutionflowPayload { + /** + * @generated from protobuf field: api.AppointmentContent Loading = 1 + */ + Loading?: AppointmentContent; + /** + * @generated from protobuf field: api.AppointmentContent Unloading = 2 + */ + Unloading?: AppointmentContent; + /** + * @generated from protobuf field: api.AppointmentStatusStruct Status = 3 + */ + Status?: AppointmentStatusStruct; +} +/** + * @generated from protobuf message api.AppointmentSummaryToExecutionflow + */ +export interface AppointmentSummaryToExecutionflow { + /** + * @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.AppointmentSummaryToExecutionflowPayload Payload = 3 + */ + Payload?: AppointmentSummaryToExecutionflowPayload; + /** + * @generated from protobuf field: api.AppointmentSummaryToExecutionflowPayload EventPayload = 4 + */ + EventPayload?: AppointmentSummaryToExecutionflowPayload; + /** + * @generated from protobuf field: api.AppointmentSummaryToExecutionflowPayload PreviousPayload = 5 + */ + PreviousPayload?: AppointmentSummaryToExecutionflowPayload; +} +/** + * + * AppointmentRemovedFromOrder : remove the appointment information from the corresponding trade order entity + * + * @generated from protobuf message api.AppointmentRemovedFromOrderPayload + */ +export interface AppointmentRemovedFromOrderPayload { + /** + * @generated from protobuf field: api.AppointmentContent Loading = 1 + */ + Loading?: AppointmentContent; + /** + * @generated from protobuf field: api.AppointmentContent Unloading = 2 + */ + Unloading?: AppointmentContent; +} +/** + * @generated from protobuf message api.AppointmentRemovedFromOrder + */ +export interface AppointmentRemovedFromOrder { + /** + * @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.AppointmentRemovedFromOrderPayload Payload = 3 + */ + Payload?: AppointmentRemovedFromOrderPayload; + /** + * @generated from protobuf field: api.AppointmentRemovedFromOrderPayload EventPayload = 4 + */ + EventPayload?: AppointmentRemovedFromOrderPayload; + /** + * @generated from protobuf field: api.AppointmentRemovedFromOrderPayload PreviousPayload = 5 + */ + PreviousPayload?: AppointmentRemovedFromOrderPayload; +} +/** + * + * AppointmentRemovedFromExecutionflow : remove the appointment information from the corresponding trade executionflow entity + * + * @generated from protobuf message api.AppointmentRemovedFromExecutionflowPayload + */ +export interface AppointmentRemovedFromExecutionflowPayload { + /** + * @generated from protobuf field: api.AppointmentContent Loading = 1 + */ + Loading?: AppointmentContent; + /** + * @generated from protobuf field: api.AppointmentContent Unloading = 2 + */ + Unloading?: AppointmentContent; +} +/** + * @generated from protobuf message api.AppointmentRemovedFromExecutionflow + */ +export interface AppointmentRemovedFromExecutionflow { + /** + * @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.AppointmentRemovedFromExecutionflowPayload Payload = 3 + */ + Payload?: AppointmentRemovedFromExecutionflowPayload; + /** + * @generated from protobuf field: api.AppointmentRemovedFromExecutionflowPayload EventPayload = 4 + */ + EventPayload?: AppointmentRemovedFromExecutionflowPayload; + /** + * @generated from protobuf field: api.AppointmentRemovedFromExecutionflowPayload PreviousPayload = 5 + */ + PreviousPayload?: AppointmentRemovedFromExecutionflowPayload; +} // @generated message type with reflection information, may provide speed optimized methods class AppointmentNotifyPayload$Type extends MessageType { constructor() { @@ -880,3 +1052,525 @@ class AppointmentLockBooking$Type extends MessageType { * @generated MessageType for protobuf message api.AppointmentLockBooking */ export const AppointmentLockBooking = new AppointmentLockBooking$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class AppointmentSummaryToOrderPayload$Type extends MessageType { + constructor() { + super("api.AppointmentSummaryToOrderPayload", [ + { no: 1, name: "Loading", kind: "message", localName: "Loading", jsonName: "Loading", T: () => AppointmentContent }, + { no: 2, name: "Unloading", kind: "message", localName: "Unloading", jsonName: "Unloading", T: () => AppointmentContent }, + { no: 3, name: "Status", kind: "message", localName: "Status", jsonName: "Status", T: () => AppointmentStatusStruct } + ], { "api.messageType": "Command", "api.payload": true, "api.action": "AppointmentSummaryToOrder" }); + } + create(value?: PartialMessage): AppointmentSummaryToOrderPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentSummaryToOrderPayload): AppointmentSummaryToOrderPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.AppointmentContent Loading */ 1: + message.Loading = AppointmentContent.internalBinaryRead(reader, reader.uint32(), options, message.Loading); + break; + case /* api.AppointmentContent Unloading */ 2: + message.Unloading = AppointmentContent.internalBinaryRead(reader, reader.uint32(), options, message.Unloading); + break; + case /* api.AppointmentStatusStruct Status */ 3: + message.Status = AppointmentStatusStruct.internalBinaryRead(reader, reader.uint32(), options, message.Status); + 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: AppointmentSummaryToOrderPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.AppointmentContent Loading = 1; */ + if (message.Loading) + AppointmentContent.internalBinaryWrite(message.Loading, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentContent Unloading = 2; */ + if (message.Unloading) + AppointmentContent.internalBinaryWrite(message.Unloading, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentStatusStruct Status = 3; */ + if (message.Status) + AppointmentStatusStruct.internalBinaryWrite(message.Status, 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.AppointmentSummaryToOrderPayload + */ +export const AppointmentSummaryToOrderPayload = new AppointmentSummaryToOrderPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class AppointmentSummaryToOrder$Type extends MessageType { + constructor() { + super("api.AppointmentSummaryToOrder", [ + { 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: () => AppointmentSummaryToOrderPayload }, + { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => AppointmentSummaryToOrderPayload }, + { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => AppointmentSummaryToOrderPayload } + ], { "api.messageType": "Command", "api.action": "AppointmentSummaryToOrder", "api.resultingEvent": "trade.order.AppointmentUpdated", "api.triggerEventFilters": "Created,CommissionsUpdated" }); + } + create(value?: PartialMessage): AppointmentSummaryToOrder { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentSummaryToOrder): AppointmentSummaryToOrder { + 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.AppointmentSummaryToOrderPayload Payload */ 3: + message.Payload = AppointmentSummaryToOrderPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + break; + case /* api.AppointmentSummaryToOrderPayload EventPayload */ 4: + message.EventPayload = AppointmentSummaryToOrderPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); + break; + case /* api.AppointmentSummaryToOrderPayload PreviousPayload */ 5: + message.PreviousPayload = AppointmentSummaryToOrderPayload.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: AppointmentSummaryToOrder, 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.AppointmentSummaryToOrderPayload Payload = 3; */ + if (message.Payload) + AppointmentSummaryToOrderPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentSummaryToOrderPayload EventPayload = 4; */ + if (message.EventPayload) + AppointmentSummaryToOrderPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentSummaryToOrderPayload PreviousPayload = 5; */ + if (message.PreviousPayload) + AppointmentSummaryToOrderPayload.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.AppointmentSummaryToOrder + */ +export const AppointmentSummaryToOrder = new AppointmentSummaryToOrder$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class AppointmentSummaryToExecutionflowPayload$Type extends MessageType { + constructor() { + super("api.AppointmentSummaryToExecutionflowPayload", [ + { no: 1, name: "Loading", kind: "message", localName: "Loading", jsonName: "Loading", T: () => AppointmentContent }, + { no: 2, name: "Unloading", kind: "message", localName: "Unloading", jsonName: "Unloading", T: () => AppointmentContent }, + { no: 3, name: "Status", kind: "message", localName: "Status", jsonName: "Status", T: () => AppointmentStatusStruct } + ], { "api.messageType": "Command", "api.payload": true, "api.action": "AppointmentSummaryToExecutionflow" }); + } + create(value?: PartialMessage): AppointmentSummaryToExecutionflowPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentSummaryToExecutionflowPayload): AppointmentSummaryToExecutionflowPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.AppointmentContent Loading */ 1: + message.Loading = AppointmentContent.internalBinaryRead(reader, reader.uint32(), options, message.Loading); + break; + case /* api.AppointmentContent Unloading */ 2: + message.Unloading = AppointmentContent.internalBinaryRead(reader, reader.uint32(), options, message.Unloading); + break; + case /* api.AppointmentStatusStruct Status */ 3: + message.Status = AppointmentStatusStruct.internalBinaryRead(reader, reader.uint32(), options, message.Status); + 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: AppointmentSummaryToExecutionflowPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.AppointmentContent Loading = 1; */ + if (message.Loading) + AppointmentContent.internalBinaryWrite(message.Loading, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentContent Unloading = 2; */ + if (message.Unloading) + AppointmentContent.internalBinaryWrite(message.Unloading, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentStatusStruct Status = 3; */ + if (message.Status) + AppointmentStatusStruct.internalBinaryWrite(message.Status, 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.AppointmentSummaryToExecutionflowPayload + */ +export const AppointmentSummaryToExecutionflowPayload = new AppointmentSummaryToExecutionflowPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class AppointmentSummaryToExecutionflow$Type extends MessageType { + constructor() { + super("api.AppointmentSummaryToExecutionflow", [ + { 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: () => AppointmentSummaryToExecutionflowPayload }, + { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => AppointmentSummaryToExecutionflowPayload }, + { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => AppointmentSummaryToExecutionflowPayload } + ], { "api.messageType": "Command", "api.action": "AppointmentSummaryToExecutionflow", "api.resultingEvent": "trade.executionflow.AppointmentUpdated", "api.triggerEventFilters": "Created,CommissionsUpdated" }); + } + create(value?: PartialMessage): AppointmentSummaryToExecutionflow { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentSummaryToExecutionflow): AppointmentSummaryToExecutionflow { + 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.AppointmentSummaryToExecutionflowPayload Payload */ 3: + message.Payload = AppointmentSummaryToExecutionflowPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + break; + case /* api.AppointmentSummaryToExecutionflowPayload EventPayload */ 4: + message.EventPayload = AppointmentSummaryToExecutionflowPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); + break; + case /* api.AppointmentSummaryToExecutionflowPayload PreviousPayload */ 5: + message.PreviousPayload = AppointmentSummaryToExecutionflowPayload.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: AppointmentSummaryToExecutionflow, 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.AppointmentSummaryToExecutionflowPayload Payload = 3; */ + if (message.Payload) + AppointmentSummaryToExecutionflowPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentSummaryToExecutionflowPayload EventPayload = 4; */ + if (message.EventPayload) + AppointmentSummaryToExecutionflowPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentSummaryToExecutionflowPayload PreviousPayload = 5; */ + if (message.PreviousPayload) + AppointmentSummaryToExecutionflowPayload.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.AppointmentSummaryToExecutionflow + */ +export const AppointmentSummaryToExecutionflow = new AppointmentSummaryToExecutionflow$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class AppointmentRemovedFromOrderPayload$Type extends MessageType { + constructor() { + super("api.AppointmentRemovedFromOrderPayload", [ + { no: 1, name: "Loading", kind: "message", localName: "Loading", jsonName: "Loading", T: () => AppointmentContent }, + { no: 2, name: "Unloading", kind: "message", localName: "Unloading", jsonName: "Unloading", T: () => AppointmentContent } + ], { "api.messageType": "Command", "api.payload": true, "api.action": "AppointmentRemovedFromOrder" }); + } + create(value?: PartialMessage): AppointmentRemovedFromOrderPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentRemovedFromOrderPayload): AppointmentRemovedFromOrderPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.AppointmentContent Loading */ 1: + message.Loading = AppointmentContent.internalBinaryRead(reader, reader.uint32(), options, message.Loading); + break; + case /* api.AppointmentContent Unloading */ 2: + message.Unloading = AppointmentContent.internalBinaryRead(reader, reader.uint32(), options, message.Unloading); + 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: AppointmentRemovedFromOrderPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.AppointmentContent Loading = 1; */ + if (message.Loading) + AppointmentContent.internalBinaryWrite(message.Loading, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentContent Unloading = 2; */ + if (message.Unloading) + AppointmentContent.internalBinaryWrite(message.Unloading, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.AppointmentRemovedFromOrderPayload + */ +export const AppointmentRemovedFromOrderPayload = new AppointmentRemovedFromOrderPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class AppointmentRemovedFromOrder$Type extends MessageType { + constructor() { + super("api.AppointmentRemovedFromOrder", [ + { 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: () => AppointmentRemovedFromOrderPayload }, + { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => AppointmentRemovedFromOrderPayload }, + { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => AppointmentRemovedFromOrderPayload } + ], { "api.messageType": "Command", "api.action": "AppointmentRemovedFromOrder", "api.resultingEvent": "trade.order.AppointmentUpdated", "api.triggerEventFilters": "Deleted,Canceled" }); + } + create(value?: PartialMessage): AppointmentRemovedFromOrder { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentRemovedFromOrder): AppointmentRemovedFromOrder { + 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.AppointmentRemovedFromOrderPayload Payload */ 3: + message.Payload = AppointmentRemovedFromOrderPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + break; + case /* api.AppointmentRemovedFromOrderPayload EventPayload */ 4: + message.EventPayload = AppointmentRemovedFromOrderPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); + break; + case /* api.AppointmentRemovedFromOrderPayload PreviousPayload */ 5: + message.PreviousPayload = AppointmentRemovedFromOrderPayload.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: AppointmentRemovedFromOrder, 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.AppointmentRemovedFromOrderPayload Payload = 3; */ + if (message.Payload) + AppointmentRemovedFromOrderPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentRemovedFromOrderPayload EventPayload = 4; */ + if (message.EventPayload) + AppointmentRemovedFromOrderPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentRemovedFromOrderPayload PreviousPayload = 5; */ + if (message.PreviousPayload) + AppointmentRemovedFromOrderPayload.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.AppointmentRemovedFromOrder + */ +export const AppointmentRemovedFromOrder = new AppointmentRemovedFromOrder$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class AppointmentRemovedFromExecutionflowPayload$Type extends MessageType { + constructor() { + super("api.AppointmentRemovedFromExecutionflowPayload", [ + { no: 1, name: "Loading", kind: "message", localName: "Loading", jsonName: "Loading", T: () => AppointmentContent }, + { no: 2, name: "Unloading", kind: "message", localName: "Unloading", jsonName: "Unloading", T: () => AppointmentContent } + ], { "api.messageType": "Command", "api.payload": true, "api.action": "AppointmentRemovedFromExecutionflow" }); + } + create(value?: PartialMessage): AppointmentRemovedFromExecutionflowPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentRemovedFromExecutionflowPayload): AppointmentRemovedFromExecutionflowPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.AppointmentContent Loading */ 1: + message.Loading = AppointmentContent.internalBinaryRead(reader, reader.uint32(), options, message.Loading); + break; + case /* api.AppointmentContent Unloading */ 2: + message.Unloading = AppointmentContent.internalBinaryRead(reader, reader.uint32(), options, message.Unloading); + 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: AppointmentRemovedFromExecutionflowPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.AppointmentContent Loading = 1; */ + if (message.Loading) + AppointmentContent.internalBinaryWrite(message.Loading, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentContent Unloading = 2; */ + if (message.Unloading) + AppointmentContent.internalBinaryWrite(message.Unloading, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.AppointmentRemovedFromExecutionflowPayload + */ +export const AppointmentRemovedFromExecutionflowPayload = new AppointmentRemovedFromExecutionflowPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class AppointmentRemovedFromExecutionflow$Type extends MessageType { + constructor() { + super("api.AppointmentRemovedFromExecutionflow", [ + { 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: () => AppointmentRemovedFromExecutionflowPayload }, + { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => AppointmentRemovedFromExecutionflowPayload }, + { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => AppointmentRemovedFromExecutionflowPayload } + ], { "api.messageType": "Command", "api.action": "AppointmentRemovedFromExecutionflow", "api.resultingEvent": "trade.executionflow.AppointmentUpdated", "api.triggerEventFilters": "Deleted,Canceled" }); + } + create(value?: PartialMessage): AppointmentRemovedFromExecutionflow { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentRemovedFromExecutionflow): AppointmentRemovedFromExecutionflow { + 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.AppointmentRemovedFromExecutionflowPayload Payload */ 3: + message.Payload = AppointmentRemovedFromExecutionflowPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); + break; + case /* api.AppointmentRemovedFromExecutionflowPayload EventPayload */ 4: + message.EventPayload = AppointmentRemovedFromExecutionflowPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); + break; + case /* api.AppointmentRemovedFromExecutionflowPayload PreviousPayload */ 5: + message.PreviousPayload = AppointmentRemovedFromExecutionflowPayload.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: AppointmentRemovedFromExecutionflow, 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.AppointmentRemovedFromExecutionflowPayload Payload = 3; */ + if (message.Payload) + AppointmentRemovedFromExecutionflowPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentRemovedFromExecutionflowPayload EventPayload = 4; */ + if (message.EventPayload) + AppointmentRemovedFromExecutionflowPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); + /* api.AppointmentRemovedFromExecutionflowPayload PreviousPayload = 5; */ + if (message.PreviousPayload) + AppointmentRemovedFromExecutionflowPayload.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.AppointmentRemovedFromExecutionflow + */ +export const AppointmentRemovedFromExecutionflow = new AppointmentRemovedFromExecutionflow$Type(); diff --git a/appointmentInput.ts b/appointmentInput.ts index a0dd1a6e..b7eb7931 100644 --- a/appointmentInput.ts +++ b/appointmentInput.ts @@ -20,7 +20,7 @@ import { AppointmentContent } from "./slotbooking"; import { Address } from "./repositoryShared"; import { Slot } from "./slotbooking"; import { MetadataElement } from "./shared"; -import { AppointmentType } from "./slotbooking"; +import { AppointmentType } from "./shared"; // // Created : this message tells that appointment is created diff --git a/collabShared.ts b/collabShared.ts index d065d5ca..904a2573 100644 --- a/collabShared.ts +++ b/collabShared.ts @@ -150,56 +150,6 @@ export interface NotifChanges { */ Details?: Struct; } -// -// Appointment entity status structure - -/** - * @generated from protobuf message api.AppointmentStatus - */ -export interface AppointmentStatus { - /** - * @generated from protobuf field: api.AppointmentStatusCode StatusCode = 1 - */ - StatusCode: AppointmentStatusCode; - /** - * @generated from protobuf field: string Date = 2 - */ - Date: string; - /** - * Status effective date. Set by the event's RefDate that triggered the status change. - * - * @generated from protobuf field: api.DateTime ActualDate = 3 - */ - ActualDate?: DateTime; -} -// -// AppointmentStatusStruct statuses structure - -/** - * @generated from protobuf message api.AppointmentStatusStruct - */ -export interface AppointmentStatusStruct { - /** - * Current status of the Appointment entity - * - * @generated from protobuf field: api.AppointmentStatus Current = 1 - */ - Current?: AppointmentStatus; - /** - * List of all status history of the Appointment entity - * - * @generated from protobuf field: repeated api.AppointmentStatus History = 2 - */ - History: AppointmentStatus[]; - /** - * @generated from protobuf field: string CreationDate = 3 - */ - CreationDate: string; - /** - * @generated from protobuf field: uint32 Version = 4 - */ - Version: number; -} /** * @generated from protobuf enum api.NotifTypeEnum */ @@ -245,68 +195,6 @@ export enum NotifTypeEnum { */ NOTIF_TYPE_COMPLETION = 9 } -// Appointment - -/** - * - * All statuses for Appointment entity - * - * @generated from protobuf enum api.AppointmentStatusCode - */ -export enum AppointmentStatusCode { - /** - * @generated from protobuf enum value: APPOINTMENT_0000_STATUS_UNKNOWN = 0; - */ - APPOINTMENT_0000_STATUS_UNKNOWN = 0, - /** - * @generated from protobuf enum value: APPOINTMENT_0100_CREATED = 100; - */ - APPOINTMENT_0100_CREATED = 100, - /** - * @generated from protobuf enum value: APPOINTMENT_0150_ALLOCATION_ERROR = 150; - */ - APPOINTMENT_0150_ALLOCATION_ERROR = 150, - /** - * APPOINTMENT_0200_CARRIER_VALIDATION = 200; - * - * @generated from protobuf enum value: APPOINTMENT_0300_CARRIER_EXPECTED = 300; - */ - APPOINTMENT_0300_CARRIER_EXPECTED = 300, - /** - * @generated from protobuf enum value: APPOINTMENT_0400_CARRIER_ARRIVED = 400; - */ - APPOINTMENT_0400_CARRIER_ARRIVED = 400, - /** - * APPOINTMENT_0500_SITE_VALIDATION = 500; - * - * @generated from protobuf enum value: APPOINTMENT_0600_UNLOADING = 600; - */ - APPOINTMENT_0600_UNLOADING = 600, - /** - * @generated from protobuf enum value: APPOINTMENT_0700_UNLOADED = 700; - */ - APPOINTMENT_0700_UNLOADED = 700, - /** - * @generated from protobuf enum value: APPOINTMENT_0800_LOADING = 800; - */ - APPOINTMENT_0800_LOADING = 800, - /** - * @generated from protobuf enum value: APPOINTMENT_0900_LOADED = 900; - */ - APPOINTMENT_0900_LOADED = 900, - /** - * @generated from protobuf enum value: APPOINTMENT_1000_CARRIER_DEPARTED = 1000; - */ - APPOINTMENT_1000_CARRIER_DEPARTED = 1000, - /** - * @generated from protobuf enum value: APPOINTMENT_1100_CANCELED = 1100; - */ - APPOINTMENT_1100_CANCELED = 1100, - /** - * @generated from protobuf enum value: APPOINTMENT_9500_ANOMALY = 9500; - */ - APPOINTMENT_9500_ANOMALY = 9500 -} // @generated message type with reflection information, may provide speed optimized methods class ClaimStatusDef$Type extends MessageType { constructor() { @@ -735,135 +623,3 @@ class NotifChanges$Type extends MessageType { * @generated MessageType for protobuf message api.NotifChanges */ export const NotifChanges = new NotifChanges$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class AppointmentStatus$Type extends MessageType { - constructor() { - super("api.AppointmentStatus", [ - { no: 1, name: "StatusCode", kind: "enum", localName: "StatusCode", jsonName: "StatusCode", T: () => ["api.AppointmentStatusCode", AppointmentStatusCode], options: { "api.indexationType": { Types: [{ Context: "*", Type: "generatedText" }] }, "api.kpiItems": { Items: [{ Context: "Appointment", Group: "appointment", Queryable: true }] } } }, - { no: 2, name: "Date", kind: "scalar", localName: "Date", jsonName: "Date", T: 9 /*ScalarType.STRING*/, options: { "api.indexationType": { Types: [{ Context: "*", Type: "date" }] }, "api.kpiItems": { Items: [{ Context: "Appointment", Group: "appointment", Queryable: true }] }, "api.viewType": { Types: [{ Context: "*", Type: "date" }] } } }, - { no: 3, name: "ActualDate", kind: "message", localName: "ActualDate", jsonName: "ActualDate", T: () => DateTime, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Status effective date. Set by the event's RefDate that triggered the status change." } } } - ]); - } - create(value?: PartialMessage): AppointmentStatus { - const message = globalThis.Object.create((this.messagePrototype!)); - message.StatusCode = 0; - message.Date = ""; - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentStatus): AppointmentStatus { - let message = target ?? this.create(), end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* api.AppointmentStatusCode StatusCode */ 1: - message.StatusCode = reader.int32(); - break; - case /* string Date */ 2: - message.Date = reader.string(); - break; - case /* api.DateTime ActualDate */ 3: - message.ActualDate = DateTime.internalBinaryRead(reader, reader.uint32(), options, message.ActualDate); - 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: AppointmentStatus, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* api.AppointmentStatusCode StatusCode = 1; */ - if (message.StatusCode !== 0) - writer.tag(1, WireType.Varint).int32(message.StatusCode); - /* string Date = 2; */ - if (message.Date !== "") - writer.tag(2, WireType.LengthDelimited).string(message.Date); - /* api.DateTime ActualDate = 3; */ - if (message.ActualDate) - DateTime.internalBinaryWrite(message.ActualDate, 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.AppointmentStatus - */ -export const AppointmentStatus = new AppointmentStatus$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class AppointmentStatusStruct$Type extends MessageType { - constructor() { - super("api.AppointmentStatusStruct", [ - { no: 1, name: "Current", kind: "message", localName: "Current", jsonName: "Current", T: () => AppointmentStatus }, - { no: 2, name: "History", kind: "message", localName: "History", jsonName: "History", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentStatus }, - { no: 3, name: "CreationDate", kind: "scalar", localName: "CreationDate", jsonName: "CreationDate", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { dateIso8601: true } } } }, - { no: 4, name: "Version", kind: "scalar", localName: "Version", jsonName: "Version", T: 13 /*ScalarType.UINT32*/ } - ]); - } - create(value?: PartialMessage): AppointmentStatusStruct { - const message = globalThis.Object.create((this.messagePrototype!)); - message.History = []; - message.CreationDate = ""; - message.Version = 0; - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentStatusStruct): AppointmentStatusStruct { - let message = target ?? this.create(), end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* api.AppointmentStatus Current */ 1: - message.Current = AppointmentStatus.internalBinaryRead(reader, reader.uint32(), options, message.Current); - break; - case /* repeated api.AppointmentStatus History */ 2: - message.History.push(AppointmentStatus.internalBinaryRead(reader, reader.uint32(), options)); - break; - case /* string CreationDate */ 3: - message.CreationDate = reader.string(); - break; - case /* uint32 Version */ 4: - message.Version = reader.uint32(); - 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: AppointmentStatusStruct, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* api.AppointmentStatus Current = 1; */ - if (message.Current) - AppointmentStatus.internalBinaryWrite(message.Current, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); - /* repeated api.AppointmentStatus History = 2; */ - for (let i = 0; i < message.History.length; i++) - AppointmentStatus.internalBinaryWrite(message.History[i], writer.tag(2, WireType.LengthDelimited).fork(), options).join(); - /* string CreationDate = 3; */ - if (message.CreationDate !== "") - writer.tag(3, WireType.LengthDelimited).string(message.CreationDate); - /* uint32 Version = 4; */ - if (message.Version !== 0) - writer.tag(4, WireType.Varint).uint32(message.Version); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); - return writer; - } -} -/** - * @generated MessageType for protobuf message api.AppointmentStatusStruct - */ -export const AppointmentStatusStruct = new AppointmentStatusStruct$Type(); diff --git a/executionflow.ts b/executionflow.ts index 85a97d98..44a91de7 100644 --- a/executionflow.ts +++ b/executionflow.ts @@ -15,6 +15,7 @@ import { ActorPayload } from "./actor"; import { ItemPayload } from "./item"; import { EntityID } from "./shared"; import { EventHeader } from "./shared"; +import { AppointmentSummary } from "./shared"; import { ETA } from "./tradeShared"; import { ETAbyHU } from "./tradeShared"; import { ClaimSummary } from "./shared"; @@ -144,6 +145,16 @@ export interface ExecutionflowPayload { * @generated from protobuf field: api.ETA ExecutionflowETAComputed = 22 */ ExecutionflowETAComputed?: ETA; + /** + * @generated from protobuf field: repeated api.AppointmentSummary Appointments = 23 + */ + Appointments: AppointmentSummary[]; + /** + * Appointment removed from the executionflow + * + * @generated from protobuf field: repeated api.AppointmentSummary RemovedAppointments = 24 + */ + RemovedAppointments: AppointmentSummary[]; } // Executionflow entity @@ -267,7 +278,9 @@ class ExecutionflowPayload$Type extends MessageType { { no: 19, name: "ClaimNumber", kind: "scalar", localName: "ClaimNumber", jsonName: "ClaimNumber", T: 5 /*ScalarType.INT32*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Total number of claims" } } }, { no: 20, name: "HandlingunitETAs", kind: "message", localName: "HandlingunitETAs", jsonName: "HandlingunitETAs", repeat: 2 /*RepeatType.UNPACKED*/, T: () => ETAbyHU, options: { "api.aggKey": "HandlingunitID", "api.aggSkip": "HUETAUpdated", "api.kpiExclude": { Items: [{ Context: "Executionflow", Group: "executionflow" }] }, "api.indexationSkip": true } }, { no: 21, name: "ExecutionflowETA", kind: "message", localName: "ExecutionflowETA", jsonName: "ExecutionflowETA", T: () => ETA, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Estimated Time of Arrival received directly for the Executionflow" }, "api.aggSkip": "ETAUpdated", "api.kpiExclude": { Items: [{ Context: "Executionflow", Group: "executionflow" }] }, "api.indexationSkip": true } }, - { no: 22, name: "ExecutionflowETAComputed", kind: "message", localName: "ExecutionflowETAComputed", jsonName: "ExecutionflowETAComputed", T: () => ETA, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { readOnly: true }, "api.indexationSkip": true } } + { no: 22, name: "ExecutionflowETAComputed", kind: "message", localName: "ExecutionflowETAComputed", jsonName: "ExecutionflowETAComputed", T: () => ETA, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { readOnly: true }, "api.indexationSkip": true } }, + { no: 23, name: "Appointments", kind: "message", localName: "Appointments", jsonName: "Appointments", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "List of appointments attached to the executionflow" }, "api.aggSkip": "AppointmentUpdated", "api.indexationSkip": true } }, + { no: 24, name: "RemovedAppointments", kind: "message", localName: "RemovedAppointments", jsonName: "RemovedAppointments", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { readOnly: true }, "api.aggSkip": "AppointmentUpdated" } } ]); } create(value?: PartialMessage): ExecutionflowPayload { @@ -284,6 +297,8 @@ class ExecutionflowPayload$Type extends MessageType { message.Claims = []; message.ClaimNumber = 0; message.HandlingunitETAs = []; + message.Appointments = []; + message.RemovedAppointments = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; @@ -353,6 +368,12 @@ class ExecutionflowPayload$Type extends MessageType { case /* api.ETA ExecutionflowETAComputed */ 22: message.ExecutionflowETAComputed = ETA.internalBinaryRead(reader, reader.uint32(), options, message.ExecutionflowETAComputed); break; + case /* repeated api.AppointmentSummary Appointments */ 23: + message.Appointments.push(AppointmentSummary.internalBinaryRead(reader, reader.uint32(), options)); + break; + case /* repeated api.AppointmentSummary RemovedAppointments */ 24: + message.RemovedAppointments.push(AppointmentSummary.internalBinaryRead(reader, reader.uint32(), options)); + break; default: let u = options.readUnknownField; if (u === "throw") @@ -425,6 +446,12 @@ class ExecutionflowPayload$Type extends MessageType { /* api.ETA ExecutionflowETAComputed = 22; */ if (message.ExecutionflowETAComputed) ETA.internalBinaryWrite(message.ExecutionflowETAComputed, writer.tag(22, WireType.LengthDelimited).fork(), options).join(); + /* repeated api.AppointmentSummary Appointments = 23; */ + for (let i = 0; i < message.Appointments.length; i++) + AppointmentSummary.internalBinaryWrite(message.Appointments[i], writer.tag(23, WireType.LengthDelimited).fork(), options).join(); + /* repeated api.AppointmentSummary RemovedAppointments = 24; */ + for (let i = 0; i < message.RemovedAppointments.length; i++) + AppointmentSummary.internalBinaryWrite(message.RemovedAppointments[i], writer.tag(24, WireType.LengthDelimited).fork(), options).join(); let u = options.writeUnknownFields; if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); diff --git a/executionflowAction.ts b/executionflowAction.ts index 2000483c..c2bb3f2b 100644 --- a/executionflowAction.ts +++ b/executionflowAction.ts @@ -17,6 +17,7 @@ import { DateTime } from "./shared"; import { ETA } from "./tradeShared"; import { EntityID } from "./shared"; import { CommandHeader } from "./shared"; +import { AppointmentSummary } from "./shared"; import { ClaimSummary } from "./shared"; import { AttachmentSummary } from "./shared"; import { ExeFlowLine } from "./tradeShared"; @@ -80,6 +81,10 @@ export interface ExecutionflowMapSummaryToOrderPayload { * @generated from protobuf field: int32 ClaimNumber = 19 */ ClaimNumber: number; + /** + * @generated from protobuf field: repeated api.AppointmentSummary Appointments = 20 + */ + Appointments: AppointmentSummary[]; } /** * @generated from protobuf message api.ExecutionflowMapSummaryToOrder @@ -371,7 +376,8 @@ class ExecutionflowMapSummaryToOrderPayload$Type extends MessageType AttachmentSummary }, { no: 17, name: "AttachmentNumber", kind: "scalar", localName: "AttachmentNumber", jsonName: "AttachmentNumber", T: 5 /*ScalarType.INT32*/ }, { no: 18, name: "Claims", kind: "message", localName: "Claims", jsonName: "Claims", repeat: 2 /*RepeatType.UNPACKED*/, T: () => ClaimSummary }, - { no: 19, name: "ClaimNumber", kind: "scalar", localName: "ClaimNumber", jsonName: "ClaimNumber", T: 5 /*ScalarType.INT32*/ } + { no: 19, name: "ClaimNumber", kind: "scalar", localName: "ClaimNumber", jsonName: "ClaimNumber", T: 5 /*ScalarType.INT32*/ }, + { no: 20, name: "Appointments", kind: "message", localName: "Appointments", jsonName: "Appointments", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentSummary } ], { "api.messageType": "Command", "api.payload": true, "api.action": "MapSummaryToOrder" }); } create(value?: PartialMessage): ExecutionflowMapSummaryToOrderPayload { @@ -383,6 +389,7 @@ class ExecutionflowMapSummaryToOrderPayload$Type extends MessageType(this, message, value); return message; @@ -425,6 +432,9 @@ class ExecutionflowMapSummaryToOrderPayload$Type extends MessageType; + /** + * @generated from protobuf rpc: AppointmentUpdated + */ + appointmentUpdated(input: ExecutionflowAppointmentUpdatedRequest, options?: RpcOptions): UnaryCall; } /** * @@ -456,4 +462,11 @@ export class ExecutionflowInputAPIClient implements IExecutionflowInputAPIClient const method = this.methods[32], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } + /** + * @generated from protobuf rpc: AppointmentUpdated + */ + appointmentUpdated(input: ExecutionflowAppointmentUpdatedRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[33], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } } diff --git a/executionflowInput.ts b/executionflowInput.ts index b340af23..87ea49ac 100644 --- a/executionflowInput.ts +++ b/executionflowInput.ts @@ -11,6 +11,7 @@ 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 { AppointmentSummary } from "./shared"; import { ClaimSummary } from "./shared"; import { AttachmentSummary } from "./shared"; import { ETA } from "./tradeShared"; @@ -2068,6 +2069,69 @@ export interface ExecutionflowCustomFieldsUpdatedResponse { */ ID?: EntityID; } +// +// AppointmentUpdated : this message tells that an appointment is updated for the executionFlow + +/** + * @generated from protobuf message api.ExecutionflowAppointmentUpdatedPayload + */ +export interface ExecutionflowAppointmentUpdatedPayload { + /** + * @generated from protobuf field: repeated api.AppointmentSummary Appointments = 1 + */ + Appointments: AppointmentSummary[]; + /** + * @generated from protobuf field: repeated api.AppointmentSummary RemovedAppointments = 2 + */ + RemovedAppointments: AppointmentSummary[]; +} +/** + * @generated from protobuf message api.ExecutionflowAppointmentUpdatedEvent + */ +export interface ExecutionflowAppointmentUpdatedEvent { + /** + * @generated from protobuf field: api.EventHeader Header = 1 + */ + Header?: EventHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ExecutionflowAppointmentUpdatedPayload Payload = 3 + */ + Payload?: ExecutionflowAppointmentUpdatedPayload; +} +/** + * @generated from protobuf message api.ExecutionflowAppointmentUpdatedRequest + */ +export interface ExecutionflowAppointmentUpdatedRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 + */ + Header?: RequestProjectHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.ExecutionflowAppointmentUpdatedPayload Payload = 3 + */ + Payload?: ExecutionflowAppointmentUpdatedPayload; +} +/** + * @generated from protobuf message api.ExecutionflowAppointmentUpdatedResponse + */ +export interface ExecutionflowAppointmentUpdatedResponse { + /** + * @generated from protobuf field: api.ResponseHeader Header = 1 + */ + Header?: ResponseHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; +} // @generated message type with reflection information, may provide speed optimized methods class ExecutionflowCreatedPayload$Type extends MessageType { constructor() { @@ -9306,6 +9370,234 @@ class ExecutionflowCustomFieldsUpdatedResponse$Type extends MessageType { + constructor() { + super("api.ExecutionflowAppointmentUpdatedPayload", [ + { no: 1, name: "Appointments", kind: "message", localName: "Appointments", jsonName: "Appointments", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "List of appointments updated" } } }, + { no: 2, name: "RemovedAppointments", kind: "message", localName: "RemovedAppointments", jsonName: "RemovedAppointments", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "List of appointments removed" } } } + ], { "api.messageType": "Event", "api.payload": true, "api.inputEvent": "AppointmentUpdated" }); + } + create(value?: PartialMessage): ExecutionflowAppointmentUpdatedPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + message.Appointments = []; + message.RemovedAppointments = []; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ExecutionflowAppointmentUpdatedPayload): ExecutionflowAppointmentUpdatedPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* repeated api.AppointmentSummary Appointments */ 1: + message.Appointments.push(AppointmentSummary.internalBinaryRead(reader, reader.uint32(), options)); + break; + case /* repeated api.AppointmentSummary RemovedAppointments */ 2: + message.RemovedAppointments.push(AppointmentSummary.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: ExecutionflowAppointmentUpdatedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* repeated api.AppointmentSummary Appointments = 1; */ + for (let i = 0; i < message.Appointments.length; i++) + AppointmentSummary.internalBinaryWrite(message.Appointments[i], writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* repeated api.AppointmentSummary RemovedAppointments = 2; */ + for (let i = 0; i < message.RemovedAppointments.length; i++) + AppointmentSummary.internalBinaryWrite(message.RemovedAppointments[i], writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ExecutionflowAppointmentUpdatedPayload + */ +export const ExecutionflowAppointmentUpdatedPayload = new ExecutionflowAppointmentUpdatedPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ExecutionflowAppointmentUpdatedEvent$Type extends MessageType { + constructor() { + super("api.ExecutionflowAppointmentUpdatedEvent", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ExecutionflowAppointmentUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "api.messageType": "Event", "api.inputEvent": "AppointmentUpdated", "api.preAggMethods": "updateAppointment" }); + } + create(value?: PartialMessage): ExecutionflowAppointmentUpdatedEvent { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ExecutionflowAppointmentUpdatedEvent): ExecutionflowAppointmentUpdatedEvent { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.EventHeader Header */ 1: + message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ExecutionflowAppointmentUpdatedPayload Payload */ 3: + message.Payload = ExecutionflowAppointmentUpdatedPayload.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: ExecutionflowAppointmentUpdatedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.EventHeader Header = 1; */ + if (message.Header) + EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ExecutionflowAppointmentUpdatedPayload Payload = 3; */ + if (message.Payload) + ExecutionflowAppointmentUpdatedPayload.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.ExecutionflowAppointmentUpdatedEvent + */ +export const ExecutionflowAppointmentUpdatedEvent = new ExecutionflowAppointmentUpdatedEvent$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ExecutionflowAppointmentUpdatedRequest$Type extends MessageType { + constructor() { + super("api.ExecutionflowAppointmentUpdatedRequest", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => ExecutionflowAppointmentUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "ID", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "AppointmentUpdated" }); + } + create(value?: PartialMessage): ExecutionflowAppointmentUpdatedRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ExecutionflowAppointmentUpdatedRequest): ExecutionflowAppointmentUpdatedRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.RequestProjectHeader Header */ 1: + message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.ExecutionflowAppointmentUpdatedPayload Payload */ 3: + message.Payload = ExecutionflowAppointmentUpdatedPayload.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: ExecutionflowAppointmentUpdatedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1; */ + if (message.Header) + RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.ExecutionflowAppointmentUpdatedPayload Payload = 3; */ + if (message.Payload) + ExecutionflowAppointmentUpdatedPayload.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.ExecutionflowAppointmentUpdatedRequest + */ +export const ExecutionflowAppointmentUpdatedRequest = new ExecutionflowAppointmentUpdatedRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ExecutionflowAppointmentUpdatedResponse$Type extends MessageType { + constructor() { + super("api.ExecutionflowAppointmentUpdatedResponse", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID } + ], { "api.messageType": "Response", "api.inputEvent": "AppointmentUpdated" }); + } + create(value?: PartialMessage): ExecutionflowAppointmentUpdatedResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ExecutionflowAppointmentUpdatedResponse): ExecutionflowAppointmentUpdatedResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ResponseHeader Header */ 1: + message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + default: + let u = options.readUnknownField; + if (u === "throw") + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); + let d = reader.skip(wireType); + if (u !== false) + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); + } + } + return message; + } + internalBinaryWrite(message: ExecutionflowAppointmentUpdatedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ResponseHeader Header = 1; */ + if (message.Header) + ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ExecutionflowAppointmentUpdatedResponse + */ +export const ExecutionflowAppointmentUpdatedResponse = new ExecutionflowAppointmentUpdatedResponse$Type(); /** * @generated ServiceType for protobuf service api.ExecutionflowInputAPI */ @@ -9342,5 +9634,6 @@ export const ExecutionflowInputAPI = new ServiceType("api.ExecutionflowInputAPI" { name: "LinesDetected", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["ExecutionFlow Inputs"], description: "Adding lines in the Order has been reported to an Executionflow. This is called internally." }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.platformReserved": true, "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: ExecutionflowLinesDetectedRequest, O: ExecutionflowLinesDetectedResponse }, { name: "Renotified", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["ExecutionFlow Inputs"], description: "Re-notify the connected partnerApps." }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "PUBLIC" } }, I: ExecutionflowRenotifiedRequest, O: ExecutionflowRenotifiedResponse }, { name: "Sanitised", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["ExecutionFlow Inputs"], description: "An Executionflow has been sanitised." }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.platformReserved": false, "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: ExecutionflowSanitisedRequest, O: ExecutionflowSanitisedResponse }, - { name: "CustomFieldsUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["ExecutionFlow Inputs"], description: "CustomFields have been updated." }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "PUBLIC" } }, I: ExecutionflowCustomFieldsUpdatedRequest, O: ExecutionflowCustomFieldsUpdatedResponse } + { name: "CustomFieldsUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["ExecutionFlow Inputs"], description: "CustomFields have been updated." }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "PUBLIC" } }, I: ExecutionflowCustomFieldsUpdatedRequest, O: ExecutionflowCustomFieldsUpdatedResponse }, + { name: "AppointmentUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["ExecutionFlow Inputs"], description: "An appointment is updated for the Executionflow." }, "api.rscType": "Project", "api.roles": "Platform.Project-Appointment", "api.platformReserved": true, "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: ExecutionflowAppointmentUpdatedRequest, O: ExecutionflowAppointmentUpdatedResponse } ], { "api.serviceType": "Api", "api.k8sService": "api-server" }); diff --git a/order.ts b/order.ts index 5bf33418..f11fce7c 100644 --- a/order.ts +++ b/order.ts @@ -15,6 +15,7 @@ import { ActorPayload } from "./actor"; import { ItemPayload } from "./item"; import { EntityID } from "./shared"; import { EventHeader } from "./shared"; +import { AppointmentSummary } from "./shared"; import { ETAbyExecutionflow } from "./tradeShared"; import { ClaimSummary } from "./shared"; import { AttachmentSummary } from "./shared"; @@ -145,6 +146,16 @@ export interface OrderPayload { * @generated from protobuf field: bool Anticipated = 24 */ Anticipated: boolean; + /** + * @generated from protobuf field: repeated api.AppointmentSummary Appointments = 25 + */ + Appointments: AppointmentSummary[]; + /** + * Appointment removed from the order + * + * @generated from protobuf field: repeated api.AppointmentSummary RemovedAppointments = 26 + */ + RemovedAppointments: AppointmentSummary[]; } /** * Order entity @@ -271,7 +282,9 @@ class OrderPayload$Type extends MessageType { { no: 21, name: "ClaimNumber", kind: "scalar", localName: "ClaimNumber", jsonName: "ClaimNumber", T: 5 /*ScalarType.INT32*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Total number of claims" } } }, { no: 22, name: "ExecutionflowETAs", kind: "message", localName: "ExecutionflowETAs", jsonName: "ExecutionflowETAs", repeat: 2 /*RepeatType.UNPACKED*/, T: () => ETAbyExecutionflow, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "ETA for each executionflow attached to the order" }, "api.aggKey": "ExecutionflowID", "api.aggSkip": "ExecutionflowETAUpdated" } }, { no: 23, name: "OrderETA", kind: "message", localName: "OrderETA", jsonName: "OrderETA", T: () => ETA, options: { "n1validate.rules": { message: { unauthorized: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "ETA for the order, computed from ETA of the execitionFlows" }, "api.aggSkip": "ETAUpdated" } }, - { no: 24, name: "Anticipated", kind: "scalar", localName: "Anticipated", jsonName: "Anticipated", T: 8 /*ScalarType.BOOL*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Anticipated orders are not automatically associated to an executionflow" } } } + { no: 24, name: "Anticipated", kind: "scalar", localName: "Anticipated", jsonName: "Anticipated", T: 8 /*ScalarType.BOOL*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Anticipated orders are not automatically associated to an executionflow" } } }, + { no: 25, name: "Appointments", kind: "message", localName: "Appointments", jsonName: "Appointments", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "List of appointments attached to the order" }, "api.aggSkip": "AppointmentUpdated", "api.indexationSkip": true } }, + { no: 26, name: "RemovedAppointments", kind: "message", localName: "RemovedAppointments", jsonName: "RemovedAppointments", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { readOnly: true }, "api.aggSkip": "AppointmentUpdated" } } ]); } create(value?: PartialMessage): OrderPayload { @@ -287,6 +300,8 @@ class OrderPayload$Type extends MessageType { message.ClaimNumber = 0; message.ExecutionflowETAs = []; message.Anticipated = false; + message.Appointments = []; + message.RemovedAppointments = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; @@ -365,6 +380,12 @@ class OrderPayload$Type extends MessageType { case /* bool Anticipated */ 24: message.Anticipated = reader.bool(); break; + case /* repeated api.AppointmentSummary Appointments */ 25: + message.Appointments.push(AppointmentSummary.internalBinaryRead(reader, reader.uint32(), options)); + break; + case /* repeated api.AppointmentSummary RemovedAppointments */ 26: + message.RemovedAppointments.push(AppointmentSummary.internalBinaryRead(reader, reader.uint32(), options)); + break; default: let u = options.readUnknownField; if (u === "throw") @@ -446,6 +467,12 @@ class OrderPayload$Type extends MessageType { /* bool Anticipated = 24; */ if (message.Anticipated !== false) writer.tag(24, WireType.Varint).bool(message.Anticipated); + /* repeated api.AppointmentSummary Appointments = 25; */ + for (let i = 0; i < message.Appointments.length; i++) + AppointmentSummary.internalBinaryWrite(message.Appointments[i], writer.tag(25, WireType.LengthDelimited).fork(), options).join(); + /* repeated api.AppointmentSummary RemovedAppointments = 26; */ + for (let i = 0; i < message.RemovedAppointments.length; i++) + AppointmentSummary.internalBinaryWrite(message.RemovedAppointments[i], writer.tag(26, WireType.LengthDelimited).fork(), options).join(); let u = options.writeUnknownFields; if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); diff --git a/orderInput.client.ts b/orderInput.client.ts index 6f0d5786..1ddd87f6 100644 --- a/orderInput.client.ts +++ b/orderInput.client.ts @@ -4,6 +4,8 @@ import type { RpcTransport } from "@protobuf-ts/runtime-rpc"; import type { ServiceInfo } from "@protobuf-ts/runtime-rpc"; import { OrderInputAPI } from "./orderInput"; +import type { OrderAppointmentUpdatedResponse } from "./orderInput"; +import type { OrderAppointmentUpdatedRequest } from "./orderInput"; import type { OrderReceiptCompletedResponse } from "./orderInput"; import type { OrderReceiptCompletedRequest } from "./orderInput"; import type { OrderReceiptStartedResponse } from "./orderInput"; @@ -194,6 +196,10 @@ export interface IOrderInputAPIClient { * @generated from protobuf rpc: ReceiptCompleted */ receiptCompleted(input: OrderReceiptCompletedRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: AppointmentUpdated + */ + appointmentUpdated(input: OrderAppointmentUpdatedRequest, options?: RpcOptions): UnaryCall; } /** * @@ -417,4 +423,11 @@ export class OrderInputAPIClient implements IOrderInputAPIClient, ServiceInfo { const method = this.methods[29], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } + /** + * @generated from protobuf rpc: AppointmentUpdated + */ + appointmentUpdated(input: OrderAppointmentUpdatedRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[30], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } } diff --git a/orderInput.ts b/orderInput.ts index 26e781e4..2958caf8 100644 --- a/orderInput.ts +++ b/orderInput.ts @@ -11,6 +11,7 @@ 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 { AppointmentSummary } from "./shared"; import { ClaimSummary } from "./shared"; import { AttachmentSummary } from "./shared"; import { ETAbyExecutionflow } from "./tradeShared"; @@ -2014,6 +2015,69 @@ export interface OrderReceiptCompletedResponse { */ ID?: EntityID; } +// +// AppointmentUpdated : this message tells that appointments is updated for the order + +/** + * @generated from protobuf message api.OrderAppointmentUpdatedPayload + */ +export interface OrderAppointmentUpdatedPayload { + /** + * @generated from protobuf field: repeated api.AppointmentSummary Appointments = 1 + */ + Appointments: AppointmentSummary[]; + /** + * @generated from protobuf field: repeated api.AppointmentSummary RemovedAppointments = 2 + */ + RemovedAppointments: AppointmentSummary[]; +} +/** + * @generated from protobuf message api.OrderAppointmentUpdatedEvent + */ +export interface OrderAppointmentUpdatedEvent { + /** + * @generated from protobuf field: api.EventHeader Header = 1 + */ + Header?: EventHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.OrderAppointmentUpdatedPayload Payload = 3 + */ + Payload?: OrderAppointmentUpdatedPayload; +} +/** + * @generated from protobuf message api.OrderAppointmentUpdatedRequest + */ +export interface OrderAppointmentUpdatedRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 + */ + Header?: RequestProjectHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; + /** + * @generated from protobuf field: api.OrderAppointmentUpdatedPayload Payload = 3 + */ + Payload?: OrderAppointmentUpdatedPayload; +} +/** + * @generated from protobuf message api.OrderAppointmentUpdatedResponse + */ +export interface OrderAppointmentUpdatedResponse { + /** + * @generated from protobuf field: api.ResponseHeader Header = 1 + */ + Header?: ResponseHeader; + /** + * @generated from protobuf field: api.EntityID ID = 2 + */ + ID?: EntityID; +} // @generated message type with reflection information, may provide speed optimized methods class OrderCreatedPayload$Type extends MessageType { constructor() { @@ -4384,7 +4448,7 @@ class OrderExecutionflowUpdatedEvent$Type extends MessageType EventHeader, options: { "n1validate.rules": { message: { required: true } } } }, { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => OrderExecutionflowUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } - ], { "api.messageType": "Event", "api.inputEvent": "ExecutionflowUpdated", "api.postAggMethods": "computeCarrier,computeShippedGoods" }); + ], { "api.messageType": "Event", "api.inputEvent": "ExecutionflowUpdated", "api.postAggMethods": "computeCarrier,computeShippedGoods", "api.preAggMethods": "updateExecutionflowAppointment" }); } create(value?: PartialMessage): OrderExecutionflowUpdatedEvent { const message = globalThis.Object.create((this.messagePrototype!)); @@ -8711,6 +8775,234 @@ class OrderReceiptCompletedResponse$Type extends MessageType { + constructor() { + super("api.OrderAppointmentUpdatedPayload", [ + { no: 1, name: "Appointments", kind: "message", localName: "Appointments", jsonName: "Appointments", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "List of appointments updated" } } }, + { no: 2, name: "RemovedAppointments", kind: "message", localName: "RemovedAppointments", jsonName: "RemovedAppointments", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "List of appointments removed" } } } + ], { "api.messageType": "Event", "api.payload": true, "api.inputEvent": "AppointmentUpdated" }); + } + create(value?: PartialMessage): OrderAppointmentUpdatedPayload { + const message = globalThis.Object.create((this.messagePrototype!)); + message.Appointments = []; + message.RemovedAppointments = []; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OrderAppointmentUpdatedPayload): OrderAppointmentUpdatedPayload { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* repeated api.AppointmentSummary Appointments */ 1: + message.Appointments.push(AppointmentSummary.internalBinaryRead(reader, reader.uint32(), options)); + break; + case /* repeated api.AppointmentSummary RemovedAppointments */ 2: + message.RemovedAppointments.push(AppointmentSummary.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: OrderAppointmentUpdatedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* repeated api.AppointmentSummary Appointments = 1; */ + for (let i = 0; i < message.Appointments.length; i++) + AppointmentSummary.internalBinaryWrite(message.Appointments[i], writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* repeated api.AppointmentSummary RemovedAppointments = 2; */ + for (let i = 0; i < message.RemovedAppointments.length; i++) + AppointmentSummary.internalBinaryWrite(message.RemovedAppointments[i], writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.OrderAppointmentUpdatedPayload + */ +export const OrderAppointmentUpdatedPayload = new OrderAppointmentUpdatedPayload$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class OrderAppointmentUpdatedEvent$Type extends MessageType { + constructor() { + super("api.OrderAppointmentUpdatedEvent", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => OrderAppointmentUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "api.messageType": "Event", "api.inputEvent": "AppointmentUpdated", "api.preAggMethods": "updateAppointment" }); + } + create(value?: PartialMessage): OrderAppointmentUpdatedEvent { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OrderAppointmentUpdatedEvent): OrderAppointmentUpdatedEvent { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.EventHeader Header */ 1: + message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.OrderAppointmentUpdatedPayload Payload */ 3: + message.Payload = OrderAppointmentUpdatedPayload.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: OrderAppointmentUpdatedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.EventHeader Header = 1; */ + if (message.Header) + EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.OrderAppointmentUpdatedPayload Payload = 3; */ + if (message.Payload) + OrderAppointmentUpdatedPayload.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.OrderAppointmentUpdatedEvent + */ +export const OrderAppointmentUpdatedEvent = new OrderAppointmentUpdatedEvent$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class OrderAppointmentUpdatedRequest$Type extends MessageType { + constructor() { + super("api.OrderAppointmentUpdatedRequest", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => OrderAppointmentUpdatedPayload, options: { "n1validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "ID", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "AppointmentUpdated" }); + } + create(value?: PartialMessage): OrderAppointmentUpdatedRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OrderAppointmentUpdatedRequest): OrderAppointmentUpdatedRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.RequestProjectHeader Header */ 1: + message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + case /* api.OrderAppointmentUpdatedPayload Payload */ 3: + message.Payload = OrderAppointmentUpdatedPayload.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: OrderAppointmentUpdatedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1; */ + if (message.Header) + RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* api.OrderAppointmentUpdatedPayload Payload = 3; */ + if (message.Payload) + OrderAppointmentUpdatedPayload.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.OrderAppointmentUpdatedRequest + */ +export const OrderAppointmentUpdatedRequest = new OrderAppointmentUpdatedRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class OrderAppointmentUpdatedResponse$Type extends MessageType { + constructor() { + super("api.OrderAppointmentUpdatedResponse", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader }, + { no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID } + ], { "api.messageType": "Response", "api.inputEvent": "AppointmentUpdated" }); + } + create(value?: PartialMessage): OrderAppointmentUpdatedResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OrderAppointmentUpdatedResponse): OrderAppointmentUpdatedResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ResponseHeader Header */ 1: + message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); + break; + case /* api.EntityID ID */ 2: + message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID); + break; + default: + let u = options.readUnknownField; + if (u === "throw") + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); + let d = reader.skip(wireType); + if (u !== false) + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); + } + } + return message; + } + internalBinaryWrite(message: OrderAppointmentUpdatedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ResponseHeader Header = 1; */ + if (message.Header) + ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityID ID = 2; */ + if (message.ID) + EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.OrderAppointmentUpdatedResponse + */ +export const OrderAppointmentUpdatedResponse = new OrderAppointmentUpdatedResponse$Type(); /** * @generated ServiceType for protobuf service api.OrderInputAPI */ @@ -8744,5 +9036,6 @@ export const OrderInputAPI = new ServiceType("api.OrderInputAPI", [ { name: "TransportCompleted", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Order Inputs"], description: "Transport is completed on the Order. This is typically called from a WMS. " }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "PUBLIC" } }, I: OrderTransportCompletedRequest, O: OrderTransportCompletedResponse }, { name: "ReceiptExpected", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Order Inputs"], description: "Receipt is expected on the Order. This is typically called from a WMS. " }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "PUBLIC" } }, I: OrderReceiptExpectedRequest, O: OrderReceiptExpectedResponse }, { name: "ReceiptStarted", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Order Inputs"], description: "Receipt has started on the Order. This is typically called from a WMS. " }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "PUBLIC" } }, I: OrderReceiptStartedRequest, O: OrderReceiptStartedResponse }, - { name: "ReceiptCompleted", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Order Inputs"], description: "Receipt is completed on the Order. This is typically called from a WMS. " }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "PUBLIC" } }, I: OrderReceiptCompletedRequest, O: OrderReceiptCompletedResponse } + { name: "ReceiptCompleted", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Order Inputs"], description: "Receipt is completed on the Order. This is typically called from a WMS. " }, "api.rscType": "Project", "api.roles": "Platform.Project-Input", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "PUBLIC" } }, I: OrderReceiptCompletedRequest, O: OrderReceiptCompletedResponse }, + { name: "AppointmentUpdated", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Order Inputs"], description: "An appointment is updated for the Order." }, "api.rscType": "Project", "api.roles": "Platform.Project-Appointment", "api.platformReserved": true, "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: OrderAppointmentUpdatedRequest, O: OrderAppointmentUpdatedResponse } ], { "api.serviceType": "Api", "api.k8sService": "api-server" }); diff --git a/package.json b/package.json index e37c87b2..98215f61 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@reflex-platform/npm-core-sdk", - "version": "1.14.0-SNAPSHOT-260527160510", + "version": "1.14.0-SNAPSHOT-260528081247", "description": "npm libs from core model proto files", "homepage": "", "main": "index.ts", diff --git a/shared.ts b/shared.ts index fad845eb..f1027d7e 100644 --- a/shared.ts +++ b/shared.ts @@ -2194,6 +2194,77 @@ export interface CrossFindByMatchResult { */ MatchResults: MatchFieldResult[]; } +// +// Appointment entity status structure + +/** + * @generated from protobuf message api.AppointmentStatus + */ +export interface AppointmentStatus { + /** + * @generated from protobuf field: api.AppointmentStatusCode StatusCode = 1 + */ + StatusCode: AppointmentStatusCode; + /** + * @generated from protobuf field: string Date = 2 + */ + Date: string; + /** + * Status effective date. Set by the event's RefDate that triggered the status change. + * + * @generated from protobuf field: api.DateTime ActualDate = 3 + */ + ActualDate?: DateTime; +} +// +// AppointmentStatusStruct statuses structure + +/** + * @generated from protobuf message api.AppointmentStatusStruct + */ +export interface AppointmentStatusStruct { + /** + * Current status of the Appointment entity + * + * @generated from protobuf field: api.AppointmentStatus Current = 1 + */ + Current?: AppointmentStatus; + /** + * List of all status history of the Appointment entity + * + * @generated from protobuf field: repeated api.AppointmentStatus History = 2 + */ + History: AppointmentStatus[]; + /** + * @generated from protobuf field: string CreationDate = 3 + */ + CreationDate: string; + /** + * @generated from protobuf field: uint32 Version = 4 + */ + Version: number; +} +/** + * @generated from protobuf message api.AppointmentSummary + */ +export interface AppointmentSummary { + /** + * @generated from protobuf field: string SiteID = 1 + */ + SiteID: string; + /** + * @generated from protobuf field: string AppointmentID = 2 + */ + AppointmentID: string; + /** + * @generated from protobuf field: api.AppointmentType AppointmentType = 3 + */ + AppointmentType: AppointmentType; + /** + * @generated from protobuf field: api.AppointmentStatus Status = 4 + */ + Status?: AppointmentStatus; +} /** * @generated from protobuf enum api.WeekDay */ @@ -2930,6 +3001,93 @@ export enum ProjectType { */ PROJECT_TYPE_SITE = 2 } +// Appointment + +/** + * + * All statuses for Appointment entity + * + * @generated from protobuf enum api.AppointmentStatusCode + */ +export enum AppointmentStatusCode { + /** + * @generated from protobuf enum value: APPOINTMENT_0000_STATUS_UNKNOWN = 0; + */ + APPOINTMENT_0000_STATUS_UNKNOWN = 0, + /** + * @generated from protobuf enum value: APPOINTMENT_0100_CREATED = 100; + */ + APPOINTMENT_0100_CREATED = 100, + /** + * @generated from protobuf enum value: APPOINTMENT_0150_ALLOCATION_ERROR = 150; + */ + APPOINTMENT_0150_ALLOCATION_ERROR = 150, + /** + * APPOINTMENT_0200_CARRIER_VALIDATION = 200; + * + * @generated from protobuf enum value: APPOINTMENT_0300_CARRIER_EXPECTED = 300; + */ + APPOINTMENT_0300_CARRIER_EXPECTED = 300, + /** + * @generated from protobuf enum value: APPOINTMENT_0400_CARRIER_ARRIVED = 400; + */ + APPOINTMENT_0400_CARRIER_ARRIVED = 400, + /** + * APPOINTMENT_0500_SITE_VALIDATION = 500; + * + * @generated from protobuf enum value: APPOINTMENT_0600_UNLOADING = 600; + */ + APPOINTMENT_0600_UNLOADING = 600, + /** + * @generated from protobuf enum value: APPOINTMENT_0700_UNLOADED = 700; + */ + APPOINTMENT_0700_UNLOADED = 700, + /** + * @generated from protobuf enum value: APPOINTMENT_0800_LOADING = 800; + */ + APPOINTMENT_0800_LOADING = 800, + /** + * @generated from protobuf enum value: APPOINTMENT_0900_LOADED = 900; + */ + APPOINTMENT_0900_LOADED = 900, + /** + * @generated from protobuf enum value: APPOINTMENT_1000_CARRIER_DEPARTED = 1000; + */ + APPOINTMENT_1000_CARRIER_DEPARTED = 1000, + /** + * @generated from protobuf enum value: APPOINTMENT_1100_CANCELED = 1100; + */ + APPOINTMENT_1100_CANCELED = 1100, + /** + * @generated from protobuf enum value: APPOINTMENT_9500_ANOMALY = 9500; + */ + APPOINTMENT_9500_ANOMALY = 9500 +} +/** + * @generated from protobuf enum api.AppointmentType + */ +export enum AppointmentType { + /** + * @generated from protobuf enum value: APPOINTMENT_TYPE_UNKNOWN = 0; + */ + APPOINTMENT_TYPE_UNKNOWN = 0, + /** + * @generated from protobuf enum value: APPOINTMENT_TYPE_LOADING = 1; + */ + APPOINTMENT_TYPE_LOADING = 1, + /** + * @generated from protobuf enum value: APPOINTMENT_TYPE_UNLOADING = 2; + */ + APPOINTMENT_TYPE_UNLOADING = 2, + /** + * @generated from protobuf enum value: APPOINTMENT_TYPE_UNDEFINED = 3; + */ + APPOINTMENT_TYPE_UNDEFINED = 3, + /** + * @generated from protobuf enum value: APPOINTMENT_TYPE_BOTH = 4; + */ + APPOINTMENT_TYPE_BOTH = 4 +} // @generated message type with reflection information, may provide speed optimized methods class RequestHeader$Type extends MessageType { constructor() { @@ -9195,3 +9353,205 @@ class CrossFindByMatchResult$Type extends MessageType { * @generated MessageType for protobuf message api.CrossFindByMatchResult */ export const CrossFindByMatchResult = new CrossFindByMatchResult$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class AppointmentStatus$Type extends MessageType { + constructor() { + super("api.AppointmentStatus", [ + { no: 1, name: "StatusCode", kind: "enum", localName: "StatusCode", jsonName: "StatusCode", T: () => ["api.AppointmentStatusCode", AppointmentStatusCode], options: { "api.indexationType": { Types: [{ Context: "*", Type: "generatedText" }] }, "api.kpiItems": { Items: [{ Context: "Appointment", Group: "appointment", Queryable: true }] } } }, + { no: 2, name: "Date", kind: "scalar", localName: "Date", jsonName: "Date", T: 9 /*ScalarType.STRING*/, options: { "api.indexationType": { Types: [{ Context: "*", Type: "date" }] }, "api.kpiItems": { Items: [{ Context: "Appointment", Group: "appointment", Queryable: true }] }, "api.viewType": { Types: [{ Context: "*", Type: "date" }] } } }, + { no: 3, name: "ActualDate", kind: "message", localName: "ActualDate", jsonName: "ActualDate", T: () => DateTime, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Status effective date. Set by the event's RefDate that triggered the status change." } } } + ]); + } + create(value?: PartialMessage): AppointmentStatus { + const message = globalThis.Object.create((this.messagePrototype!)); + message.StatusCode = 0; + message.Date = ""; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentStatus): AppointmentStatus { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.AppointmentStatusCode StatusCode */ 1: + message.StatusCode = reader.int32(); + break; + case /* string Date */ 2: + message.Date = reader.string(); + break; + case /* api.DateTime ActualDate */ 3: + message.ActualDate = DateTime.internalBinaryRead(reader, reader.uint32(), options, message.ActualDate); + 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: AppointmentStatus, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.AppointmentStatusCode StatusCode = 1; */ + if (message.StatusCode !== 0) + writer.tag(1, WireType.Varint).int32(message.StatusCode); + /* string Date = 2; */ + if (message.Date !== "") + writer.tag(2, WireType.LengthDelimited).string(message.Date); + /* api.DateTime ActualDate = 3; */ + if (message.ActualDate) + DateTime.internalBinaryWrite(message.ActualDate, 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.AppointmentStatus + */ +export const AppointmentStatus = new AppointmentStatus$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class AppointmentStatusStruct$Type extends MessageType { + constructor() { + super("api.AppointmentStatusStruct", [ + { no: 1, name: "Current", kind: "message", localName: "Current", jsonName: "Current", T: () => AppointmentStatus }, + { no: 2, name: "History", kind: "message", localName: "History", jsonName: "History", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentStatus }, + { no: 3, name: "CreationDate", kind: "scalar", localName: "CreationDate", jsonName: "CreationDate", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { dateIso8601: true } } } }, + { no: 4, name: "Version", kind: "scalar", localName: "Version", jsonName: "Version", T: 13 /*ScalarType.UINT32*/ } + ]); + } + create(value?: PartialMessage): AppointmentStatusStruct { + const message = globalThis.Object.create((this.messagePrototype!)); + message.History = []; + message.CreationDate = ""; + message.Version = 0; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentStatusStruct): AppointmentStatusStruct { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.AppointmentStatus Current */ 1: + message.Current = AppointmentStatus.internalBinaryRead(reader, reader.uint32(), options, message.Current); + break; + case /* repeated api.AppointmentStatus History */ 2: + message.History.push(AppointmentStatus.internalBinaryRead(reader, reader.uint32(), options)); + break; + case /* string CreationDate */ 3: + message.CreationDate = reader.string(); + break; + case /* uint32 Version */ 4: + message.Version = reader.uint32(); + 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: AppointmentStatusStruct, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.AppointmentStatus Current = 1; */ + if (message.Current) + AppointmentStatus.internalBinaryWrite(message.Current, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* repeated api.AppointmentStatus History = 2; */ + for (let i = 0; i < message.History.length; i++) + AppointmentStatus.internalBinaryWrite(message.History[i], writer.tag(2, WireType.LengthDelimited).fork(), options).join(); + /* string CreationDate = 3; */ + if (message.CreationDate !== "") + writer.tag(3, WireType.LengthDelimited).string(message.CreationDate); + /* uint32 Version = 4; */ + if (message.Version !== 0) + writer.tag(4, WireType.Varint).uint32(message.Version); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.AppointmentStatusStruct + */ +export const AppointmentStatusStruct = new AppointmentStatusStruct$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class AppointmentSummary$Type extends MessageType { + constructor() { + super("api.AppointmentSummary", [ + { no: 1, name: "SiteID", kind: "scalar", localName: "SiteID", jsonName: "SiteID", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { minLen: "1" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "ID of the site on which the appointment is booked" }, "api.indexationType": { Types: [{ Context: "*", Type: "generatedText,keyword" }] }, "api.viewType": { Types: [{ Context: "*", Type: "shortKeyword" }] } } }, + { no: 2, name: "AppointmentID", kind: "scalar", localName: "AppointmentID", jsonName: "AppointmentID", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { minLen: "1" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "ID of the appointment" }, "api.indexationType": { Types: [{ Context: "*", Type: "generatedText,keyword" }] }, "api.viewType": { Types: [{ Context: "*", Type: "shortKeyword" }] } } }, + { no: 3, name: "AppointmentType", kind: "enum", localName: "AppointmentType", jsonName: "AppointmentType", T: () => ["api.AppointmentType", AppointmentType], options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Type of the appointment" } } }, + { no: 4, name: "Status", kind: "message", localName: "Status", jsonName: "Status", T: () => AppointmentStatus, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Status of the appointment" } } } + ]); + } + create(value?: PartialMessage): AppointmentSummary { + const message = globalThis.Object.create((this.messagePrototype!)); + message.SiteID = ""; + message.AppointmentID = ""; + message.AppointmentType = 0; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AppointmentSummary): AppointmentSummary { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* string SiteID */ 1: + message.SiteID = reader.string(); + break; + case /* string AppointmentID */ 2: + message.AppointmentID = reader.string(); + break; + case /* api.AppointmentType AppointmentType */ 3: + message.AppointmentType = reader.int32(); + break; + case /* api.AppointmentStatus Status */ 4: + message.Status = AppointmentStatus.internalBinaryRead(reader, reader.uint32(), options, message.Status); + 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: AppointmentSummary, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* string SiteID = 1; */ + if (message.SiteID !== "") + writer.tag(1, WireType.LengthDelimited).string(message.SiteID); + /* string AppointmentID = 2; */ + if (message.AppointmentID !== "") + writer.tag(2, WireType.LengthDelimited).string(message.AppointmentID); + /* api.AppointmentType AppointmentType = 3; */ + if (message.AppointmentType !== 0) + writer.tag(3, WireType.Varint).int32(message.AppointmentType); + /* api.AppointmentStatus Status = 4; */ + if (message.Status) + AppointmentStatus.internalBinaryWrite(message.Status, 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.AppointmentSummary + */ +export const AppointmentSummary = new AppointmentSummary$Type(); diff --git a/site.ts b/site.ts index 2f7a8894..bd95c765 100644 --- a/site.ts +++ b/site.ts @@ -26,7 +26,7 @@ import { SlotGroup } from "./slotbooking"; import { MetadataElement } from "./shared"; import { SegmentationSelection } from "./slotbooking"; import { Commission } from "./slotbooking"; -import { AppointmentType } from "./slotbooking"; +import { AppointmentType } from "./shared"; import { FileDataRequest } from "./shared"; import { RequestProjectHeader } from "./shared"; import { Document } from "./slotbooking"; diff --git a/siteBooking.ts b/siteBooking.ts index ee64bd45..bce2dfd8 100644 --- a/siteBooking.ts +++ b/siteBooking.ts @@ -18,7 +18,7 @@ import { BookableSlot } from "./slotbooking"; import { AppointmentContent } from "./slotbooking"; import { MetadataElement } from "./shared"; import { SegmentationSelection } from "./slotbooking"; -import { AppointmentType } from "./slotbooking"; +import { AppointmentType } from "./shared"; import { RequestProjectHeader } from "./shared"; /** * GetAvailableSlots diff --git a/slotbooking.ts b/slotbooking.ts index 0829cd0f..8e84452d 100644 --- a/slotbooking.ts +++ b/slotbooking.ts @@ -12,6 +12,7 @@ import { reflectionMergePartial } from "@protobuf-ts/runtime"; import { MessageType } from "@protobuf-ts/runtime"; import { MetadataElement } from "./shared"; import { Period } from "./shared"; +import { AppointmentType } from "./shared"; import { TimeRange } from "./shared"; import { WeekDay } from "./shared"; import { LabelByLanguage } from "./shared"; @@ -770,31 +771,6 @@ export interface BookableSlot { */ ReachedLimitations: CapacityDefinition[]; // Capacity definition of the slot, to explain the reason code when the availability is not 100. } -/** - * @generated from protobuf enum api.AppointmentType - */ -export enum AppointmentType { - /** - * @generated from protobuf enum value: APPOINTMENT_TYPE_UNKNOWN = 0; - */ - APPOINTMENT_TYPE_UNKNOWN = 0, - /** - * @generated from protobuf enum value: APPOINTMENT_TYPE_LOADING = 1; - */ - APPOINTMENT_TYPE_LOADING = 1, - /** - * @generated from protobuf enum value: APPOINTMENT_TYPE_UNLOADING = 2; - */ - APPOINTMENT_TYPE_UNLOADING = 2, - /** - * @generated from protobuf enum value: APPOINTMENT_TYPE_UNDEFINED = 3; - */ - APPOINTMENT_TYPE_UNDEFINED = 3, - /** - * @generated from protobuf enum value: APPOINTMENT_TYPE_BOTH = 4; - */ - APPOINTMENT_TYPE_BOTH = 4 -} /** * @generated from protobuf enum api.CapacityRuleScope */ diff --git a/tradeShared.ts b/tradeShared.ts index 9b0dec2f..1815f197 100644 --- a/tradeShared.ts +++ b/tradeShared.ts @@ -10,6 +10,7 @@ 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 { AppointmentSummary } from "./shared"; import { ClaimSummary } from "./shared"; import { AttachmentSummary } from "./shared"; import { PartnerPayload } from "./partner"; @@ -408,6 +409,10 @@ export interface ExecutionflowSummary { * @generated from protobuf field: int32 ClaimNumber = 21 */ ClaimNumber: number; + /** + * @generated from protobuf field: repeated api.AppointmentSummary Appointments = 22 + */ + Appointments: AppointmentSummary[]; } /** * Not a GS1 Object. @@ -1579,7 +1584,8 @@ class ExecutionflowSummary$Type extends MessageType { { no: 18, name: "Attachments", kind: "message", localName: "Attachments", jsonName: "Attachments", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AttachmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Number of executionflow attachments per type" } } }, { no: 19, name: "AttachmentNumber", kind: "scalar", localName: "AttachmentNumber", jsonName: "AttachmentNumber", T: 5 /*ScalarType.INT32*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Total number of executionflow attachments" } } }, { no: 20, name: "Claims", kind: "message", localName: "Claims", jsonName: "Claims", repeat: 2 /*RepeatType.UNPACKED*/, T: () => ClaimSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Number of executionflow claims per type" } } }, - { no: 21, name: "ClaimNumber", kind: "scalar", localName: "ClaimNumber", jsonName: "ClaimNumber", T: 5 /*ScalarType.INT32*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Total number of executionflow claims" } } } + { no: 21, name: "ClaimNumber", kind: "scalar", localName: "ClaimNumber", jsonName: "ClaimNumber", T: 5 /*ScalarType.INT32*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Total number of executionflow claims" } } }, + { no: 22, name: "Appointments", kind: "message", localName: "Appointments", jsonName: "Appointments", repeat: 2 /*RepeatType.UNPACKED*/, T: () => AppointmentSummary, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "List of appointments attached to the executionflow" }, "api.aggSkip": "ExecutionflowUpdated" } } ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ExecutionflowID"] } } }); } create(value?: PartialMessage): ExecutionflowSummary { @@ -1589,6 +1595,7 @@ class ExecutionflowSummary$Type extends MessageType { message.AttachmentNumber = 0; message.Claims = []; message.ClaimNumber = 0; + message.Appointments = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; @@ -1625,6 +1632,9 @@ class ExecutionflowSummary$Type extends MessageType { case /* int32 ClaimNumber */ 21: message.ClaimNumber = reader.int32(); break; + case /* repeated api.AppointmentSummary Appointments */ 22: + message.Appointments.push(AppointmentSummary.internalBinaryRead(reader, reader.uint32(), options)); + break; default: let u = options.readUnknownField; if (u === "throw") @@ -1664,6 +1674,9 @@ class ExecutionflowSummary$Type extends MessageType { /* int32 ClaimNumber = 21; */ if (message.ClaimNumber !== 0) writer.tag(21, WireType.Varint).int32(message.ClaimNumber); + /* repeated api.AppointmentSummary Appointments = 22; */ + for (let i = 0; i < message.Appointments.length; i++) + AppointmentSummary.internalBinaryWrite(message.Appointments[i], writer.tag(22, WireType.LengthDelimited).fork(), options).join(); let u = options.writeUnknownFields; if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);