Latest generation

orderAction.ts

@@ -10,7 +10,6 @@ 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 { ExecutionflowSummary } from "./tradeShared";
 import { EntityID } from "./shared";
 import { CommandHeader } from "./shared";
 import { OrderLine } from "./tradeShared";
@@ -160,52 +159,6 @@ export interface OrderPropagateLinesToExecutionflow {
      */
     PreviousPayload?: OrderPropagateLinesToExecutionflowPayload;
 }
-/**
- *
- * Retrieve Anticipated Order Shipped Goods
- *  Triggered on Order Created to retrieve shipped goods for anticipated orders
- *
- * @generated from protobuf message api.OrderRetrieveAnticipatedOrderShippedGoodsPayload
- */
-export interface OrderRetrieveAnticipatedOrderShippedGoodsPayload {
-    /**
-     * @generated from protobuf field: repeated api.OrderLine Lines = 1
-     */
-    Lines: OrderLine[];
-    /**
-     * @generated from protobuf field: bool Anticipated = 2
-     */
-    Anticipated: boolean;
-    /**
-     * @generated from protobuf field: repeated api.ExecutionflowSummary ExecutionflowSummary = 3
-     */
-    ExecutionflowSummary: ExecutionflowSummary[];
-}
-/**
- * @generated from protobuf message api.OrderRetrieveAnticipatedOrderShippedGoods
- */
-export interface OrderRetrieveAnticipatedOrderShippedGoods {
-    /**
-     * @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.OrderRetrieveAnticipatedOrderShippedGoodsPayload Payload = 3
-     */
-    Payload?: OrderRetrieveAnticipatedOrderShippedGoodsPayload;
-    /**
-     * @generated from protobuf field: api.OrderRetrieveAnticipatedOrderShippedGoodsPayload EventPayload = 4
-     */
-    EventPayload?: OrderRetrieveAnticipatedOrderShippedGoodsPayload;
-    /**
-     * @generated from protobuf field: api.OrderRetrieveAnticipatedOrderShippedGoodsPayload PreviousPayload = 5
-     */
-    PreviousPayload?: OrderRetrieveAnticipatedOrderShippedGoodsPayload;
-}
 // @generated message type with reflection information, may provide speed optimized methods
 class OrderBuildExecutionflowPayload$Type extends MessageType<OrderBuildExecutionflowPayload> {
     constructor() {
@@ -544,140 +497,3 @@ class OrderPropagateLinesToExecutionflow$Type extends MessageType<OrderPropagate
  * @generated MessageType for protobuf message api.OrderPropagateLinesToExecutionflow
  */
 export const OrderPropagateLinesToExecutionflow = new OrderPropagateLinesToExecutionflow$Type();
-// @generated message type with reflection information, may provide speed optimized methods
-class OrderRetrieveAnticipatedOrderShippedGoodsPayload$Type extends MessageType<OrderRetrieveAnticipatedOrderShippedGoodsPayload> {
-    constructor() {
-        super("api.OrderRetrieveAnticipatedOrderShippedGoodsPayload", [
-            { no: 1, name: "Lines", kind: "message", localName: "Lines", jsonName: "Lines", repeat: 2 /*RepeatType.UNPACKED*/, T: () => OrderLine, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Lines of the order" }, "api.aggKey": "LineID" } },
-            { no: 2, 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: 3, name: "ExecutionflowSummary", kind: "message", localName: "ExecutionflowSummary", jsonName: "ExecutionflowSummary", repeat: 2 /*RepeatType.UNPACKED*/, T: () => ExecutionflowSummary, options: { "api.aggKey": "ExecutionflowID" } }
-        ], { "api.messageType": "Command", "api.payload": true, "api.action": "RetrieveAnticipatedOrderShippedGoods" });
-    }
-    create(value?: PartialMessage<OrderRetrieveAnticipatedOrderShippedGoodsPayload>): OrderRetrieveAnticipatedOrderShippedGoodsPayload {
-        const message = globalThis.Object.create((this.messagePrototype!));
-        message.Lines = [];
-        message.Anticipated = false;
-        message.ExecutionflowSummary = [];
-        if (value !== undefined)
-            reflectionMergePartial<OrderRetrieveAnticipatedOrderShippedGoodsPayload>(this, message, value);
-        return message;
-    }
-    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OrderRetrieveAnticipatedOrderShippedGoodsPayload): OrderRetrieveAnticipatedOrderShippedGoodsPayload {
-        let message = target ?? this.create(), end = reader.pos + length;
-        while (reader.pos < end) {
-            let [fieldNo, wireType] = reader.tag();
-            switch (fieldNo) {
-                case /* repeated api.OrderLine Lines */ 1:
-                    message.Lines.push(OrderLine.internalBinaryRead(reader, reader.uint32(), options));
-                    break;
-                case /* bool Anticipated */ 2:
-                    message.Anticipated = reader.bool();
-                    break;
-                case /* repeated api.ExecutionflowSummary ExecutionflowSummary */ 3:
-                    message.ExecutionflowSummary.push(ExecutionflowSummary.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: OrderRetrieveAnticipatedOrderShippedGoodsPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
-        /* repeated api.OrderLine Lines = 1; */
-        for (let i = 0; i < message.Lines.length; i++)
-            OrderLine.internalBinaryWrite(message.Lines[i], writer.tag(1, WireType.LengthDelimited).fork(), options).join();
-        /* bool Anticipated = 2; */
-        if (message.Anticipated !== false)
-            writer.tag(2, WireType.Varint).bool(message.Anticipated);
-        /* repeated api.ExecutionflowSummary ExecutionflowSummary = 3; */
-        for (let i = 0; i < message.ExecutionflowSummary.length; i++)
-            ExecutionflowSummary.internalBinaryWrite(message.ExecutionflowSummary[i], 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.OrderRetrieveAnticipatedOrderShippedGoodsPayload
- */
-export const OrderRetrieveAnticipatedOrderShippedGoodsPayload = new OrderRetrieveAnticipatedOrderShippedGoodsPayload$Type();
-// @generated message type with reflection information, may provide speed optimized methods
-class OrderRetrieveAnticipatedOrderShippedGoods$Type extends MessageType<OrderRetrieveAnticipatedOrderShippedGoods> {
-    constructor() {
-        super("api.OrderRetrieveAnticipatedOrderShippedGoods", [
-            { 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: () => OrderRetrieveAnticipatedOrderShippedGoodsPayload },
-            { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => OrderRetrieveAnticipatedOrderShippedGoodsPayload },
-            { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => OrderRetrieveAnticipatedOrderShippedGoodsPayload }
-        ], { "api.messageType": "Command", "api.action": "RetrieveAnticipatedOrderShippedGoods", "api.triggerEventFilters": "Created" });
-    }
-    create(value?: PartialMessage<OrderRetrieveAnticipatedOrderShippedGoods>): OrderRetrieveAnticipatedOrderShippedGoods {
-        const message = globalThis.Object.create((this.messagePrototype!));
-        if (value !== undefined)
-            reflectionMergePartial<OrderRetrieveAnticipatedOrderShippedGoods>(this, message, value);
-        return message;
-    }
-    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OrderRetrieveAnticipatedOrderShippedGoods): OrderRetrieveAnticipatedOrderShippedGoods {
-        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.OrderRetrieveAnticipatedOrderShippedGoodsPayload Payload */ 3:
-                    message.Payload = OrderRetrieveAnticipatedOrderShippedGoodsPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload);
-                    break;
-                case /* api.OrderRetrieveAnticipatedOrderShippedGoodsPayload EventPayload */ 4:
-                    message.EventPayload = OrderRetrieveAnticipatedOrderShippedGoodsPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload);
-                    break;
-                case /* api.OrderRetrieveAnticipatedOrderShippedGoodsPayload PreviousPayload */ 5:
-                    message.PreviousPayload = OrderRetrieveAnticipatedOrderShippedGoodsPayload.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: OrderRetrieveAnticipatedOrderShippedGoods, 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.OrderRetrieveAnticipatedOrderShippedGoodsPayload Payload = 3; */
-        if (message.Payload)
-            OrderRetrieveAnticipatedOrderShippedGoodsPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
-        /* api.OrderRetrieveAnticipatedOrderShippedGoodsPayload EventPayload = 4; */
-        if (message.EventPayload)
-            OrderRetrieveAnticipatedOrderShippedGoodsPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join();
-        /* api.OrderRetrieveAnticipatedOrderShippedGoodsPayload PreviousPayload = 5; */
-        if (message.PreviousPayload)
-            OrderRetrieveAnticipatedOrderShippedGoodsPayload.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.OrderRetrieveAnticipatedOrderShippedGoods
- */
-export const OrderRetrieveAnticipatedOrderShippedGoods = new OrderRetrieveAnticipatedOrderShippedGoods$Type();

orderInput.ts

@@ -2276,7 +2276,7 @@ class OrderCreatedEvent$Type extends MessageType<OrderCreatedEvent> {
             { 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: () => OrderCreatedPayload, options: { "n1validate.rules": { message: { required: true } } } }
-        ], { "api.messageType": "Event", "api.inputEvent": "Created", "api.postAggMethods": "computeEquivalentLVBaseQuantity", "api.preAggMethods": "verifyActorPartner,verifyDraftCreatedStatus" });
+        ], { "api.messageType": "Event", "api.inputEvent": "Created", "api.postAggMethods": "computeEquivalentLVBaseQuantity", "api.preAggMethods": "verifyActorPartner,verifyDraftCreatedStatus,retrieveAnticipatedOrderShippedGoods" });
     }
     create(value?: PartialMessage<OrderCreatedEvent>): OrderCreatedEvent {
         const message = globalThis.Object.create((this.messagePrototype!));

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@reflex-platform/npm-core-sdk",
-  "version": "1.14.0-SNAPSHOT-260616140505",
+  "version": "1.14.0-SNAPSHOT-260616140647",
   "description": "npm libs from core model proto files",
   "homepage": "",
   "main": "index.ts",