// @generated by protobuf-ts 2.11.1 with parameter use_proto_field_name,keep_enum_prefix // @generated from protobuf file "actorAction.proto" (package "api", syntax proto3) // tslint:disable import type { BinaryWriteOptions } from "@protobuf-ts/runtime"; import type { IBinaryWriter } from "@protobuf-ts/runtime"; import { WireType } from "@protobuf-ts/runtime"; import type { BinaryReadOptions } from "@protobuf-ts/runtime"; import type { IBinaryReader } from "@protobuf-ts/runtime"; import { UnknownFieldHandler } from "@protobuf-ts/runtime"; import type { PartialMessage } from "@protobuf-ts/runtime"; import { reflectionMergePartial } from "@protobuf-ts/runtime"; import { MessageType } from "@protobuf-ts/runtime"; import { EntityID } from "./shared"; import { CommandHeader } from "./shared"; import { ActorSnapshot } from "./repositoryShared"; // Action Summary // - CompleteSnapshot : After each Snapshot completed, reset the quantity of the missing Stocks > stock.Snapshotted // /** * * CompleteSnapshot : finalize a actor snapshot * by sending cumulated snapshotted quantity on stock id not already cumulated, * by reseting the quantity of missing stock entry for the current snapshot * * @generated from protobuf message api.ActorCompleteSnapshotPayload */ export interface ActorCompleteSnapshotPayload { /** * @generated from protobuf field: api.ActorSnapshot Snapshot = 1 */ Snapshot?: ActorSnapshot; } /** * @generated from protobuf message api.ActorCompleteSnapshot */ export interface ActorCompleteSnapshot { /** * @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.ActorCompleteSnapshotPayload Payload = 3 */ Payload?: ActorCompleteSnapshotPayload; /** * @generated from protobuf field: api.ActorCompleteSnapshotPayload EventPayload = 4 */ EventPayload?: ActorCompleteSnapshotPayload; /** * @generated from protobuf field: api.ActorCompleteSnapshotPayload PreviousPayload = 5 */ PreviousPayload?: ActorCompleteSnapshotPayload; } // @generated message type with reflection information, may provide speed optimized methods class ActorCompleteSnapshotPayload$Type extends MessageType { constructor() { super("api.ActorCompleteSnapshotPayload", [ { no: 1, name: "Snapshot", kind: "message", localName: "Snapshot", jsonName: "Snapshot", T: () => ActorSnapshot } ], { "api.messageType": "Command", "api.payload": true, "api.action": "CompleteSnapshot" }); } create(value?: PartialMessage): ActorCompleteSnapshotPayload { const message = globalThis.Object.create((this.messagePrototype!)); if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorCompleteSnapshotPayload): ActorCompleteSnapshotPayload { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.ActorSnapshot Snapshot */ 1: message.Snapshot = ActorSnapshot.internalBinaryRead(reader, reader.uint32(), options, message.Snapshot); 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: ActorCompleteSnapshotPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.ActorSnapshot Snapshot = 1; */ if (message.Snapshot) ActorSnapshot.internalBinaryWrite(message.Snapshot, writer.tag(1, 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.ActorCompleteSnapshotPayload */ export const ActorCompleteSnapshotPayload = new ActorCompleteSnapshotPayload$Type(); // @generated message type with reflection information, may provide speed optimized methods class ActorCompleteSnapshot$Type extends MessageType { constructor() { super("api.ActorCompleteSnapshot", [ { 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: () => ActorCompleteSnapshotPayload }, { no: 4, name: "EventPayload", kind: "message", localName: "EventPayload", jsonName: "EventPayload", T: () => ActorCompleteSnapshotPayload }, { no: 5, name: "PreviousPayload", kind: "message", localName: "PreviousPayload", jsonName: "PreviousPayload", T: () => ActorCompleteSnapshotPayload } ], { "api.messageType": "Command", "api.action": "CompleteSnapshot", "api.resultingEvent": "stock.Snapshotted", "api.additionalSource": "stock,getActorID()", "api.triggerEventFilters": "SnapshotCompleted" }); } create(value?: PartialMessage): ActorCompleteSnapshot { const message = globalThis.Object.create((this.messagePrototype!)); if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ActorCompleteSnapshot): ActorCompleteSnapshot { 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.ActorCompleteSnapshotPayload Payload */ 3: message.Payload = ActorCompleteSnapshotPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload); break; case /* api.ActorCompleteSnapshotPayload EventPayload */ 4: message.EventPayload = ActorCompleteSnapshotPayload.internalBinaryRead(reader, reader.uint32(), options, message.EventPayload); break; case /* api.ActorCompleteSnapshotPayload PreviousPayload */ 5: message.PreviousPayload = ActorCompleteSnapshotPayload.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: ActorCompleteSnapshot, 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.ActorCompleteSnapshotPayload Payload = 3; */ if (message.Payload) ActorCompleteSnapshotPayload.internalBinaryWrite(message.Payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); /* api.ActorCompleteSnapshotPayload EventPayload = 4; */ if (message.EventPayload) ActorCompleteSnapshotPayload.internalBinaryWrite(message.EventPayload, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); /* api.ActorCompleteSnapshotPayload PreviousPayload = 5; */ if (message.PreviousPayload) ActorCompleteSnapshotPayload.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.ActorCompleteSnapshot */ export const ActorCompleteSnapshot = new ActorCompleteSnapshot$Type();