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

Latest generation

Browse Source
This commit is contained in:
ci core model
2025-04-28 12:35:42 +00:00
parent 595d5e3e36
commit 09d656c554
197 changed files with 25094 additions and 25094 deletions
Download Patch File Download Diff File Expand all files Collapse all files

358
stockInput.ts
View File

@@ -1,4 +1,4 @@
// @generated by protobuf-ts 2.9.6
// @generated by protobuf-ts 2.9.6 with parameter use_proto_field_name
// @generated from protobuf file "stockInput.proto" (package "api", syntax proto3)
// tslint:disable
import { ServiceType } from "@protobuf-ts/runtime-rpc";
@@ -39,19 +39,19 @@ export interface StockMovedPayload {
/**
* @generated from protobuf field: api.EnrichedGoods Goods = 1 [json_name = "Goods"];
*/
goods?: EnrichedGoods;
Goods?: EnrichedGoods;
/**
* @generated from protobuf field: string ActorID = 2 [json_name = "ActorID"];
*/
actorID: string;
ActorID: string;
/**
* @generated from protobuf field: api.ActorPayload Actor = 7 [json_name = "Actor"];
*/
actor?: ActorPayload;
Actor?: ActorPayload;
/**
* @generated from protobuf field: api.StockMovement Movement = 8 [json_name = "Movement"];
*/
movement?: StockMovement;
Movement?: StockMovement;
}
/**
* @generated from protobuf message api.StockMovedEvent
@@ -60,15 +60,15 @@ export interface StockMovedEvent {
/**
* @generated from protobuf field: api.EventHeader Header = 1 [json_name = "Header"];
*/
header?: EventHeader;
Header?: EventHeader;
/**
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
ID?: EntityID;
/**
* @generated from protobuf field: api.StockMovedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: StockMovedPayload;
Payload?: StockMovedPayload;
}
/**
* @generated from protobuf message api.StockMovedRequest
@@ -79,17 +79,17 @@ export interface StockMovedRequest {
*
* @generated from protobuf field: api.RequestProjectHeader Header = 1 [json_name = "Header"];
*/
header?: RequestProjectHeader;
Header?: RequestProjectHeader;
/**
* @generated from protobuf field: api.NoID ID = 4 [json_name = "ID"];
*/
iD?: NoID;
ID?: NoID;
/**
* Content of the event request
*
* @generated from protobuf field: api.StockMovedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: StockMovedPayload;
Payload?: StockMovedPayload;
}
/**
* @generated from protobuf message api.StockMovedResponse
@@ -100,13 +100,13 @@ export interface StockMovedResponse {
*
* @generated from protobuf field: api.ResponseHeader Header = 1 [json_name = "Header"];
*/
header?: ResponseHeader;
Header?: ResponseHeader;
/**
* Identifier of the stock the request event was applied on
*
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
ID?: EntityID;
}
/**
*
@@ -124,23 +124,23 @@ export interface StockSnapshottedPayload {
*
* @generated from protobuf field: api.EnrichedGoods Goods = 1 [json_name = "Goods"];
*/
goods?: EnrichedGoods;
Goods?: EnrichedGoods;
/**
* Identifier of the actor where the stock is located
*
* @generated from protobuf field: string ActorID = 2 [json_name = "ActorID"];
*/
actorID: string;
ActorID: string;
/**
* @generated from protobuf field: api.ActorPayload Actor = 7 [json_name = "Actor"];
*/
actor?: ActorPayload;
Actor?: ActorPayload;
/**
* Description of the snapshot
*
* @generated from protobuf field: api.StockSnapshot Snapshot = 8 [json_name = "Snapshot"];
*/
snapshot?: StockSnapshot;
Snapshot?: StockSnapshot;
}
/**
* @generated from protobuf message api.StockSnapshottedEvent
@@ -149,15 +149,15 @@ export interface StockSnapshottedEvent {
/**
* @generated from protobuf field: api.EventHeader Header = 1 [json_name = "Header"];
*/
header?: EventHeader;
Header?: EventHeader;
/**
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
ID?: EntityID;
/**
* @generated from protobuf field: api.StockSnapshottedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: StockSnapshottedPayload;
Payload?: StockSnapshottedPayload;
}
/**
* @generated from protobuf message api.StockSnapshottedRequest
@@ -168,17 +168,17 @@ export interface StockSnapshottedRequest {
*
* @generated from protobuf field: api.RequestProjectHeader Header = 1 [json_name = "Header"];
*/
header?: RequestProjectHeader;
Header?: RequestProjectHeader;
/**
* @generated from protobuf field: api.NoID ID = 4 [json_name = "ID"];
*/
iD?: NoID;
ID?: NoID;
/**
* Content of the event request
*
* @generated from protobuf field: api.StockSnapshottedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: StockSnapshottedPayload;
Payload?: StockSnapshottedPayload;
}
/**
* @generated from protobuf message api.StockSnapshottedResponse
@@ -189,13 +189,13 @@ export interface StockSnapshottedResponse {
*
* @generated from protobuf field: api.ResponseHeader Header = 1 [json_name = "Header"];
*/
header?: ResponseHeader;
Header?: ResponseHeader;
/**
* Identifier of the stock the request event was applied on
*
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
ID?: EntityID;
}
/**
*
@@ -214,17 +214,17 @@ export interface StockDeletedPayload {
*
* @generated from protobuf field: api.EnrichedGoods Goods = 1 [json_name = "Goods"];
*/
goods?: EnrichedGoods;
Goods?: EnrichedGoods;
/**
* Identifier of the actor where the stock is located
*
* @generated from protobuf field: string ActorID = 2 [json_name = "ActorID"];
*/
actorID: string;
ActorID: string;
/**
* @generated from protobuf field: api.ActorPayload Actor = 7 [json_name = "Actor"];
*/
actor?: ActorPayload;
Actor?: ActorPayload;
}
/**
* @generated from protobuf message api.StockDeletedEvent
@@ -233,15 +233,15 @@ export interface StockDeletedEvent {
/**
* @generated from protobuf field: api.EventHeader Header = 1 [json_name = "Header"];
*/
header?: EventHeader;
Header?: EventHeader;
/**
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
ID?: EntityID;
/**
* @generated from protobuf field: api.StockDeletedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: StockDeletedPayload;
Payload?: StockDeletedPayload;
}
/**
* @generated from protobuf message api.StockDeletedRequest
@@ -252,17 +252,17 @@ export interface StockDeletedRequest {
*
* @generated from protobuf field: api.RequestProjectHeader Header = 1 [json_name = "Header"];
*/
header?: RequestProjectHeader;
Header?: RequestProjectHeader;
/**
* @generated from protobuf field: api.NoID ID = 4 [json_name = "ID"];
*/
iD?: NoID;
ID?: NoID;
/**
* Content of the event request
*
* @generated from protobuf field: api.StockDeletedPayload Payload = 3 [json_name = "Payload"];
*/
payload?: StockDeletedPayload;
Payload?: StockDeletedPayload;
}
/**
* @generated from protobuf message api.StockDeletedResponse
@@ -273,27 +273,27 @@ export interface StockDeletedResponse {
*
* @generated from protobuf field: api.ResponseHeader Header = 1 [json_name = "Header"];
*/
header?: ResponseHeader;
Header?: ResponseHeader;
/**
* Identifier of the stock the request event was applied on
*
* @generated from protobuf field: api.EntityID ID = 2 [json_name = "ID"];
*/
iD?: EntityID;
ID?: EntityID;
}
// @generated message type with reflection information, may provide speed optimized methods
class StockMovedPayload$Type extends MessageType<StockMovedPayload> {
constructor() {
super("api.StockMovedPayload", [
{ no: 1, name: "Goods", kind: "message", jsonName: "Goods", T: () => EnrichedGoods, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ActorID", kind: "scalar", jsonName: "ActorID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } }, "api.entityRef": "Actor" } },
{ no: 7, name: "Actor", kind: "message", jsonName: "Actor", T: () => ActorPayload, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { readOnly: true } } },
{ no: 8, name: "Movement", kind: "message", jsonName: "Movement", T: () => StockMovement, options: { "validate.rules": { message: { required: true } } } }
{ no: 1, name: "Goods", kind: "message", localName: "Goods", jsonName: "Goods", T: () => EnrichedGoods, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ActorID", kind: "scalar", localName: "ActorID", jsonName: "ActorID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } }, "api.entityRef": "Actor" } },
{ no: 7, name: "Actor", kind: "message", localName: "Actor", jsonName: "Actor", T: () => ActorPayload, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { readOnly: true } } },
{ no: 8, name: "Movement", kind: "message", localName: "Movement", jsonName: "Movement", T: () => StockMovement, options: { "validate.rules": { message: { required: true } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { description: "Update the goods stock counter with the provided goods quantity", required: ["Goods", "ActorID", "Movement"] } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "Moved", "api.postAggMethods": "computeMovementQuantity,quantityByBranchLVs", "api.preAggMethods": "filterMovement,stackMovement", "api.idGenMethod": "genStockMovedId" });
}
create(value?: PartialMessage<StockMovedPayload>): StockMovedPayload {
const message = globalThis.Object.create((this.messagePrototype!));
message.actorID = "";
message.ActorID = "";
if (value !== undefined)
reflectionMergePartial<StockMovedPayload>(this, message, value);
return message;
@@ -304,16 +304,16 @@ class StockMovedPayload$Type extends MessageType<StockMovedPayload> {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EnrichedGoods Goods = 1 [json_name = "Goods"];*/ 1:
message.goods = EnrichedGoods.internalBinaryRead(reader, reader.uint32(), options, message.goods);
message.Goods = EnrichedGoods.internalBinaryRead(reader, reader.uint32(), options, message.Goods);
break;
case /* string ActorID = 2 [json_name = "ActorID"];*/ 2:
message.actorID = reader.string();
message.ActorID = reader.string();
break;
case /* api.ActorPayload Actor = 7 [json_name = "Actor"];*/ 7:
message.actor = ActorPayload.internalBinaryRead(reader, reader.uint32(), options, message.actor);
message.Actor = ActorPayload.internalBinaryRead(reader, reader.uint32(), options, message.Actor);
break;
case /* api.StockMovement Movement = 8 [json_name = "Movement"];*/ 8:
message.movement = StockMovement.internalBinaryRead(reader, reader.uint32(), options, message.movement);
message.Movement = StockMovement.internalBinaryRead(reader, reader.uint32(), options, message.Movement);
break;
default:
let u = options.readUnknownField;
@@ -328,17 +328,17 @@ class StockMovedPayload$Type extends MessageType<StockMovedPayload> {
}
internalBinaryWrite(message: StockMovedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EnrichedGoods Goods = 1 [json_name = "Goods"]; */
if (message.goods)
EnrichedGoods.internalBinaryWrite(message.goods, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Goods)
EnrichedGoods.internalBinaryWrite(message.Goods, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* string ActorID = 2 [json_name = "ActorID"]; */
if (message.actorID !== "")
writer.tag(2, WireType.LengthDelimited).string(message.actorID);
if (message.ActorID !== "")
writer.tag(2, WireType.LengthDelimited).string(message.ActorID);
/* api.ActorPayload Actor = 7 [json_name = "Actor"]; */
if (message.actor)
ActorPayload.internalBinaryWrite(message.actor, writer.tag(7, WireType.LengthDelimited).fork(), options).join();
if (message.Actor)
ActorPayload.internalBinaryWrite(message.Actor, writer.tag(7, WireType.LengthDelimited).fork(), options).join();
/* api.StockMovement Movement = 8 [json_name = "Movement"]; */
if (message.movement)
StockMovement.internalBinaryWrite(message.movement, writer.tag(8, WireType.LengthDelimited).fork(), options).join();
if (message.Movement)
StockMovement.internalBinaryWrite(message.Movement, writer.tag(8, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
@@ -353,9 +353,9 @@ export const StockMovedPayload = new StockMovedPayload$Type();
class StockMovedEvent$Type extends MessageType<StockMovedEvent> {
constructor() {
super("api.StockMovedEvent", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => StockMovedPayload, options: { "validate.rules": { message: { required: true } } } }
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => StockMovedPayload, options: { "validate.rules": { message: { required: true } } } }
], { "api.messageType": "Event", "api.inputEvent": "Moved" });
}
create(value?: PartialMessage<StockMovedEvent>): StockMovedEvent {
@@ -370,13 +370,13 @@ class StockMovedEvent$Type extends MessageType<StockMovedEvent> {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EventHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID);
break;
case /* api.StockMovedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = StockMovedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
message.Payload = StockMovedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload);
break;
default:
let u = options.readUnknownField;
@@ -391,14 +391,14 @@ class StockMovedEvent$Type extends MessageType<StockMovedEvent> {
}
internalBinaryWrite(message: StockMovedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EventHeader Header = 1 [json_name = "Header"]; */
if (message.header)
EventHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Header)
EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
if (message.ID)
EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
/* api.StockMovedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
StockMovedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
if (message.Payload)
StockMovedPayload.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);
@@ -413,9 +413,9 @@ export const StockMovedEvent = new StockMovedEvent$Type();
class StockMovedRequest$Type extends MessageType<StockMovedRequest> {
constructor() {
super("api.StockMovedRequest", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => RequestProjectHeader, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the event request" } } },
{ no: 4, name: "ID", kind: "message", jsonName: "ID", T: () => NoID },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => StockMovedPayload, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Content of the event request" } } }
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the event request" } } },
{ no: 4, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => NoID },
{ no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => StockMovedPayload, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Content of the event request" } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "Moved" });
}
create(value?: PartialMessage<StockMovedRequest>): StockMovedRequest {
@@ -430,13 +430,13 @@ class StockMovedRequest$Type extends MessageType<StockMovedRequest> {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.RequestProjectHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
break;
case /* api.NoID ID = 4 [json_name = "ID"];*/ 4:
message.iD = NoID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
message.ID = NoID.internalBinaryRead(reader, reader.uint32(), options, message.ID);
break;
case /* api.StockMovedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = StockMovedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
message.Payload = StockMovedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload);
break;
default:
let u = options.readUnknownField;
@@ -451,14 +451,14 @@ class StockMovedRequest$Type extends MessageType<StockMovedRequest> {
}
internalBinaryWrite(message: StockMovedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.RequestProjectHeader Header = 1 [json_name = "Header"]; */
if (message.header)
RequestProjectHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Header)
RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.NoID ID = 4 [json_name = "ID"]; */
if (message.iD)
NoID.internalBinaryWrite(message.iD, writer.tag(4, WireType.LengthDelimited).fork(), options).join();
if (message.ID)
NoID.internalBinaryWrite(message.ID, writer.tag(4, WireType.LengthDelimited).fork(), options).join();
/* api.StockMovedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
StockMovedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
if (message.Payload)
StockMovedPayload.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);
@@ -473,8 +473,8 @@ export const StockMovedRequest = new StockMovedRequest$Type();
class StockMovedResponse$Type extends MessageType<StockMovedResponse> {
constructor() {
super("api.StockMovedResponse", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => ResponseHeader, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the response" } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Identifier of the stock the request event was applied on" } } }
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the response" } } },
{ no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Identifier of the stock the request event was applied on" } } }
], { "api.messageType": "Response", "api.inputEvent": "Moved" });
}
create(value?: PartialMessage<StockMovedResponse>): StockMovedResponse {
@@ -489,10 +489,10 @@ class StockMovedResponse$Type extends MessageType<StockMovedResponse> {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.ResponseHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID);
break;
default:
let u = options.readUnknownField;
@@ -507,11 +507,11 @@ class StockMovedResponse$Type extends MessageType<StockMovedResponse> {
}
internalBinaryWrite(message: StockMovedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.ResponseHeader Header = 1 [json_name = "Header"]; */
if (message.header)
ResponseHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Header)
ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
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);
@@ -526,15 +526,15 @@ export const StockMovedResponse = new StockMovedResponse$Type();
class StockSnapshottedPayload$Type extends MessageType<StockSnapshottedPayload> {
constructor() {
super("api.StockSnapshottedPayload", [
{ no: 1, name: "Goods", kind: "message", jsonName: "Goods", T: () => EnrichedGoods, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Description of the goods" } } },
{ no: 2, name: "ActorID", kind: "scalar", jsonName: "ActorID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Identifier of the actor where the stock is located" }, "api.entityRef": "Actor" } },
{ no: 7, name: "Actor", kind: "message", jsonName: "Actor", T: () => ActorPayload, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { readOnly: true } } },
{ no: 8, name: "Snapshot", kind: "message", jsonName: "Snapshot", T: () => StockSnapshot, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Description of the snapshot" } } }
{ no: 1, name: "Goods", kind: "message", localName: "Goods", jsonName: "Goods", T: () => EnrichedGoods, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Description of the goods" } } },
{ no: 2, name: "ActorID", kind: "scalar", localName: "ActorID", jsonName: "ActorID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Identifier of the actor where the stock is located" }, "api.entityRef": "Actor" } },
{ no: 7, name: "Actor", kind: "message", localName: "Actor", jsonName: "Actor", T: () => ActorPayload, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { readOnly: true } } },
{ no: 8, name: "Snapshot", kind: "message", localName: "Snapshot", jsonName: "Snapshot", T: () => StockSnapshot, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Description of the snapshot" } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { description: "The measured stock quantity at the given date time", required: ["Goods", "ActorID", "Snapshot"] } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "Snapshotted", "api.postAggMethods": "computeSnapshotQuantity,quantityByBranchLVs", "api.preAggMethods": "cumulateSnapshotQuantity", "api.idGenMethod": "genStockSnapshottedId" });
}
create(value?: PartialMessage<StockSnapshottedPayload>): StockSnapshottedPayload {
const message = globalThis.Object.create((this.messagePrototype!));
message.actorID = "";
message.ActorID = "";
if (value !== undefined)
reflectionMergePartial<StockSnapshottedPayload>(this, message, value);
return message;
@@ -545,16 +545,16 @@ class StockSnapshottedPayload$Type extends MessageType<StockSnapshottedPayload>
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EnrichedGoods Goods = 1 [json_name = "Goods"];*/ 1:
message.goods = EnrichedGoods.internalBinaryRead(reader, reader.uint32(), options, message.goods);
message.Goods = EnrichedGoods.internalBinaryRead(reader, reader.uint32(), options, message.Goods);
break;
case /* string ActorID = 2 [json_name = "ActorID"];*/ 2:
message.actorID = reader.string();
message.ActorID = reader.string();
break;
case /* api.ActorPayload Actor = 7 [json_name = "Actor"];*/ 7:
message.actor = ActorPayload.internalBinaryRead(reader, reader.uint32(), options, message.actor);
message.Actor = ActorPayload.internalBinaryRead(reader, reader.uint32(), options, message.Actor);
break;
case /* api.StockSnapshot Snapshot = 8 [json_name = "Snapshot"];*/ 8:
message.snapshot = StockSnapshot.internalBinaryRead(reader, reader.uint32(), options, message.snapshot);
message.Snapshot = StockSnapshot.internalBinaryRead(reader, reader.uint32(), options, message.Snapshot);
break;
default:
let u = options.readUnknownField;
@@ -569,17 +569,17 @@ class StockSnapshottedPayload$Type extends MessageType<StockSnapshottedPayload>
}
internalBinaryWrite(message: StockSnapshottedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EnrichedGoods Goods = 1 [json_name = "Goods"]; */
if (message.goods)
EnrichedGoods.internalBinaryWrite(message.goods, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Goods)
EnrichedGoods.internalBinaryWrite(message.Goods, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* string ActorID = 2 [json_name = "ActorID"]; */
if (message.actorID !== "")
writer.tag(2, WireType.LengthDelimited).string(message.actorID);
if (message.ActorID !== "")
writer.tag(2, WireType.LengthDelimited).string(message.ActorID);
/* api.ActorPayload Actor = 7 [json_name = "Actor"]; */
if (message.actor)
ActorPayload.internalBinaryWrite(message.actor, writer.tag(7, WireType.LengthDelimited).fork(), options).join();
if (message.Actor)
ActorPayload.internalBinaryWrite(message.Actor, writer.tag(7, WireType.LengthDelimited).fork(), options).join();
/* api.StockSnapshot Snapshot = 8 [json_name = "Snapshot"]; */
if (message.snapshot)
StockSnapshot.internalBinaryWrite(message.snapshot, writer.tag(8, WireType.LengthDelimited).fork(), options).join();
if (message.Snapshot)
StockSnapshot.internalBinaryWrite(message.Snapshot, writer.tag(8, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
@@ -594,9 +594,9 @@ export const StockSnapshottedPayload = new StockSnapshottedPayload$Type();
class StockSnapshottedEvent$Type extends MessageType<StockSnapshottedEvent> {
constructor() {
super("api.StockSnapshottedEvent", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => StockSnapshottedPayload, options: { "validate.rules": { message: { required: true } } } }
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => StockSnapshottedPayload, options: { "validate.rules": { message: { required: true } } } }
], { "api.messageType": "Event", "api.inputEvent": "Snapshotted" });
}
create(value?: PartialMessage<StockSnapshottedEvent>): StockSnapshottedEvent {
@@ -611,13 +611,13 @@ class StockSnapshottedEvent$Type extends MessageType<StockSnapshottedEvent> {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EventHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID);
break;
case /* api.StockSnapshottedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = StockSnapshottedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
message.Payload = StockSnapshottedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload);
break;
default:
let u = options.readUnknownField;
@@ -632,14 +632,14 @@ class StockSnapshottedEvent$Type extends MessageType<StockSnapshottedEvent> {
}
internalBinaryWrite(message: StockSnapshottedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EventHeader Header = 1 [json_name = "Header"]; */
if (message.header)
EventHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Header)
EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
if (message.ID)
EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
/* api.StockSnapshottedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
StockSnapshottedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
if (message.Payload)
StockSnapshottedPayload.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);
@@ -654,9 +654,9 @@ export const StockSnapshottedEvent = new StockSnapshottedEvent$Type();
class StockSnapshottedRequest$Type extends MessageType<StockSnapshottedRequest> {
constructor() {
super("api.StockSnapshottedRequest", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => RequestProjectHeader, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the event request" } } },
{ no: 4, name: "ID", kind: "message", jsonName: "ID", T: () => NoID },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => StockSnapshottedPayload, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Content of the event request" } } }
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the event request" } } },
{ no: 4, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => NoID },
{ no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => StockSnapshottedPayload, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Content of the event request" } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "Snapshotted" });
}
create(value?: PartialMessage<StockSnapshottedRequest>): StockSnapshottedRequest {
@@ -671,13 +671,13 @@ class StockSnapshottedRequest$Type extends MessageType<StockSnapshottedRequest>
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.RequestProjectHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
break;
case /* api.NoID ID = 4 [json_name = "ID"];*/ 4:
message.iD = NoID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
message.ID = NoID.internalBinaryRead(reader, reader.uint32(), options, message.ID);
break;
case /* api.StockSnapshottedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = StockSnapshottedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
message.Payload = StockSnapshottedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload);
break;
default:
let u = options.readUnknownField;
@@ -692,14 +692,14 @@ class StockSnapshottedRequest$Type extends MessageType<StockSnapshottedRequest>
}
internalBinaryWrite(message: StockSnapshottedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.RequestProjectHeader Header = 1 [json_name = "Header"]; */
if (message.header)
RequestProjectHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Header)
RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.NoID ID = 4 [json_name = "ID"]; */
if (message.iD)
NoID.internalBinaryWrite(message.iD, writer.tag(4, WireType.LengthDelimited).fork(), options).join();
if (message.ID)
NoID.internalBinaryWrite(message.ID, writer.tag(4, WireType.LengthDelimited).fork(), options).join();
/* api.StockSnapshottedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
StockSnapshottedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
if (message.Payload)
StockSnapshottedPayload.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);
@@ -714,8 +714,8 @@ export const StockSnapshottedRequest = new StockSnapshottedRequest$Type();
class StockSnapshottedResponse$Type extends MessageType<StockSnapshottedResponse> {
constructor() {
super("api.StockSnapshottedResponse", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => ResponseHeader, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the response" } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Identifier of the stock the request event was applied on" } } }
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the response" } } },
{ no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Identifier of the stock the request event was applied on" } } }
], { "api.messageType": "Response", "api.inputEvent": "Snapshotted" });
}
create(value?: PartialMessage<StockSnapshottedResponse>): StockSnapshottedResponse {
@@ -730,10 +730,10 @@ class StockSnapshottedResponse$Type extends MessageType<StockSnapshottedResponse
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.ResponseHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID);
break;
default:
let u = options.readUnknownField;
@@ -748,11 +748,11 @@ class StockSnapshottedResponse$Type extends MessageType<StockSnapshottedResponse
}
internalBinaryWrite(message: StockSnapshottedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.ResponseHeader Header = 1 [json_name = "Header"]; */
if (message.header)
ResponseHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Header)
ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
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);
@@ -767,14 +767,14 @@ export const StockSnapshottedResponse = new StockSnapshottedResponse$Type();
class StockDeletedPayload$Type extends MessageType<StockDeletedPayload> {
constructor() {
super("api.StockDeletedPayload", [
{ no: 1, name: "Goods", kind: "message", jsonName: "Goods", T: () => EnrichedGoods, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Description of the goods" } } },
{ no: 2, name: "ActorID", kind: "scalar", jsonName: "ActorID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Identifier of the actor where the stock is located" }, "api.entityRef": "Actor" } },
{ no: 7, name: "Actor", kind: "message", jsonName: "Actor", T: () => ActorPayload, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { readOnly: true } } }
{ no: 1, name: "Goods", kind: "message", localName: "Goods", jsonName: "Goods", T: () => EnrichedGoods, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Description of the goods" } } },
{ no: 2, name: "ActorID", kind: "scalar", localName: "ActorID", jsonName: "ActorID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Identifier of the actor where the stock is located" }, "api.entityRef": "Actor" } },
{ no: 7, name: "Actor", kind: "message", localName: "Actor", jsonName: "Actor", T: () => ActorPayload, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { readOnly: true } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { description: "The stock entry has been deleted", required: ["Goods", "ActorID"] } }, "api.messageType": "Event", "api.payload": true, "api.inputEvent": "Deleted", "api.preAggMethods": "checkEmptyStock", "api.idGenMethod": "genStockDeletedId" });
}
create(value?: PartialMessage<StockDeletedPayload>): StockDeletedPayload {
const message = globalThis.Object.create((this.messagePrototype!));
message.actorID = "";
message.ActorID = "";
if (value !== undefined)
reflectionMergePartial<StockDeletedPayload>(this, message, value);
return message;
@@ -785,13 +785,13 @@ class StockDeletedPayload$Type extends MessageType<StockDeletedPayload> {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EnrichedGoods Goods = 1 [json_name = "Goods"];*/ 1:
message.goods = EnrichedGoods.internalBinaryRead(reader, reader.uint32(), options, message.goods);
message.Goods = EnrichedGoods.internalBinaryRead(reader, reader.uint32(), options, message.Goods);
break;
case /* string ActorID = 2 [json_name = "ActorID"];*/ 2:
message.actorID = reader.string();
message.ActorID = reader.string();
break;
case /* api.ActorPayload Actor = 7 [json_name = "Actor"];*/ 7:
message.actor = ActorPayload.internalBinaryRead(reader, reader.uint32(), options, message.actor);
message.Actor = ActorPayload.internalBinaryRead(reader, reader.uint32(), options, message.Actor);
break;
default:
let u = options.readUnknownField;
@@ -806,14 +806,14 @@ class StockDeletedPayload$Type extends MessageType<StockDeletedPayload> {
}
internalBinaryWrite(message: StockDeletedPayload, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EnrichedGoods Goods = 1 [json_name = "Goods"]; */
if (message.goods)
EnrichedGoods.internalBinaryWrite(message.goods, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Goods)
EnrichedGoods.internalBinaryWrite(message.Goods, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* string ActorID = 2 [json_name = "ActorID"]; */
if (message.actorID !== "")
writer.tag(2, WireType.LengthDelimited).string(message.actorID);
if (message.ActorID !== "")
writer.tag(2, WireType.LengthDelimited).string(message.ActorID);
/* api.ActorPayload Actor = 7 [json_name = "Actor"]; */
if (message.actor)
ActorPayload.internalBinaryWrite(message.actor, writer.tag(7, WireType.LengthDelimited).fork(), options).join();
if (message.Actor)
ActorPayload.internalBinaryWrite(message.Actor, writer.tag(7, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
@@ -828,9 +828,9 @@ export const StockDeletedPayload = new StockDeletedPayload$Type();
class StockDeletedEvent$Type extends MessageType<StockDeletedEvent> {
constructor() {
super("api.StockDeletedEvent", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => StockDeletedPayload, options: { "validate.rules": { message: { required: true } } } }
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => EventHeader, options: { "validate.rules": { message: { required: true } } } },
{ no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "validate.rules": { message: { required: true } } } },
{ no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => StockDeletedPayload, options: { "validate.rules": { message: { required: true } } } }
], { "api.messageType": "Event", "api.inputEvent": "Deleted" });
}
create(value?: PartialMessage<StockDeletedEvent>): StockDeletedEvent {
@@ -845,13 +845,13 @@ class StockDeletedEvent$Type extends MessageType<StockDeletedEvent> {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.EventHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
message.Header = EventHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID);
break;
case /* api.StockDeletedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = StockDeletedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
message.Payload = StockDeletedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload);
break;
default:
let u = options.readUnknownField;
@@ -866,14 +866,14 @@ class StockDeletedEvent$Type extends MessageType<StockDeletedEvent> {
}
internalBinaryWrite(message: StockDeletedEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.EventHeader Header = 1 [json_name = "Header"]; */
if (message.header)
EventHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Header)
EventHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
if (message.ID)
EntityID.internalBinaryWrite(message.ID, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
/* api.StockDeletedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
StockDeletedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
if (message.Payload)
StockDeletedPayload.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);
@@ -888,9 +888,9 @@ export const StockDeletedEvent = new StockDeletedEvent$Type();
class StockDeletedRequest$Type extends MessageType<StockDeletedRequest> {
constructor() {
super("api.StockDeletedRequest", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => RequestProjectHeader, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the event request" } } },
{ no: 4, name: "ID", kind: "message", jsonName: "ID", T: () => NoID },
{ no: 3, name: "Payload", kind: "message", jsonName: "Payload", T: () => StockDeletedPayload, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Content of the event request" } } }
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the event request" } } },
{ no: 4, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => NoID },
{ no: 3, name: "Payload", kind: "message", localName: "Payload", jsonName: "Payload", T: () => StockDeletedPayload, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Content of the event request" } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "Payload"] } }, "api.messageType": "Request", "api.inputEvent": "Deleted" });
}
create(value?: PartialMessage<StockDeletedRequest>): StockDeletedRequest {
@@ -905,13 +905,13 @@ class StockDeletedRequest$Type extends MessageType<StockDeletedRequest> {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.RequestProjectHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
break;
case /* api.NoID ID = 4 [json_name = "ID"];*/ 4:
message.iD = NoID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
message.ID = NoID.internalBinaryRead(reader, reader.uint32(), options, message.ID);
break;
case /* api.StockDeletedPayload Payload = 3 [json_name = "Payload"];*/ 3:
message.payload = StockDeletedPayload.internalBinaryRead(reader, reader.uint32(), options, message.payload);
message.Payload = StockDeletedPayload.internalBinaryRead(reader, reader.uint32(), options, message.Payload);
break;
default:
let u = options.readUnknownField;
@@ -926,14 +926,14 @@ class StockDeletedRequest$Type extends MessageType<StockDeletedRequest> {
}
internalBinaryWrite(message: StockDeletedRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.RequestProjectHeader Header = 1 [json_name = "Header"]; */
if (message.header)
RequestProjectHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Header)
RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.NoID ID = 4 [json_name = "ID"]; */
if (message.iD)
NoID.internalBinaryWrite(message.iD, writer.tag(4, WireType.LengthDelimited).fork(), options).join();
if (message.ID)
NoID.internalBinaryWrite(message.ID, writer.tag(4, WireType.LengthDelimited).fork(), options).join();
/* api.StockDeletedPayload Payload = 3 [json_name = "Payload"]; */
if (message.payload)
StockDeletedPayload.internalBinaryWrite(message.payload, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
if (message.Payload)
StockDeletedPayload.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);
@@ -948,8 +948,8 @@ export const StockDeletedRequest = new StockDeletedRequest$Type();
class StockDeletedResponse$Type extends MessageType<StockDeletedResponse> {
constructor() {
super("api.StockDeletedResponse", [
{ no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => ResponseHeader, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the response" } } },
{ no: 2, name: "ID", kind: "message", jsonName: "ID", T: () => EntityID, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Identifier of the stock the request event was applied on" } } }
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResponseHeader, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Header of the response" } } },
{ no: 2, name: "ID", kind: "message", localName: "ID", jsonName: "ID", T: () => EntityID, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Identifier of the stock the request event was applied on" } } }
], { "api.messageType": "Response", "api.inputEvent": "Deleted" });
}
create(value?: PartialMessage<StockDeletedResponse>): StockDeletedResponse {
@@ -964,10 +964,10 @@ class StockDeletedResponse$Type extends MessageType<StockDeletedResponse> {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.ResponseHeader Header = 1 [json_name = "Header"];*/ 1:
message.header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.header);
message.Header = ResponseHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
break;
case /* api.EntityID ID = 2 [json_name = "ID"];*/ 2:
message.iD = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.iD);
message.ID = EntityID.internalBinaryRead(reader, reader.uint32(), options, message.ID);
break;
default:
let u = options.readUnknownField;
@@ -982,11 +982,11 @@ class StockDeletedResponse$Type extends MessageType<StockDeletedResponse> {
}
internalBinaryWrite(message: StockDeletedResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.ResponseHeader Header = 1 [json_name = "Header"]; */
if (message.header)
ResponseHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
if (message.Header)
ResponseHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.EntityID ID = 2 [json_name = "ID"]; */
if (message.iD)
EntityID.internalBinaryWrite(message.iD, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
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);