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

Latest generation

Browse Source
This commit is contained in:
ci core model
2026-05-28 08:13:32 +00:00
parent b5ebc4997e
commit 5dc7b22fdf
18 changed files with 1763 additions and 285 deletions
Download Patch File Download Diff File Expand all files Collapse all files

297
orderInput.ts
View File

@@ -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<OrderCreatedPayload> {
constructor() {
@@ -4384,7 +4448,7 @@ class OrderExecutionflowUpdatedEvent$Type extends MessageType<OrderExecutionflow
{ 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: () => 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>): OrderExecutionflowUpdatedEvent {
const message = globalThis.Object.create((this.messagePrototype!));
@@ -8711,6 +8775,234 @@ class OrderReceiptCompletedResponse$Type extends MessageType<OrderReceiptComplet
* @generated MessageType for protobuf message api.OrderReceiptCompletedResponse
*/
export const OrderReceiptCompletedResponse = new OrderReceiptCompletedResponse$Type();
// @generated message type with reflection information, may provide speed optimized methods
class OrderAppointmentUpdatedPayload$Type extends MessageType<OrderAppointmentUpdatedPayload> {
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>): OrderAppointmentUpdatedPayload {
const message = globalThis.Object.create((this.messagePrototype!));
message.Appointments = [];
message.RemovedAppointments = [];
if (value !== undefined)
reflectionMergePartial<OrderAppointmentUpdatedPayload>(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<OrderAppointmentUpdatedEvent> {
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>): OrderAppointmentUpdatedEvent {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<OrderAppointmentUpdatedEvent>(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<OrderAppointmentUpdatedRequest> {
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>): OrderAppointmentUpdatedRequest {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<OrderAppointmentUpdatedRequest>(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<OrderAppointmentUpdatedResponse> {
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>): OrderAppointmentUpdatedResponse {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<OrderAppointmentUpdatedResponse>(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" });