diff --git a/package.json b/package.json index b424e96..a02c86d 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@reflex-platform/npm-core-sdk", - "version": "1.15.0-SNAPSHOT-260710085802", + "version": "1.14.2", "description": "npm libs from core model proto files", "homepage": "", "main": "index.ts", diff --git a/shared.ts b/shared.ts index 173002d..11f7654 100644 --- a/shared.ts +++ b/shared.ts @@ -2521,11 +2521,7 @@ export enum WorkflowTypeEnum { /** * @generated from protobuf enum value: SYNCHRONIZE_UMA_STORE = 32; */ - SYNCHRONIZE_UMA_STORE = 32, - /** - * @generated from protobuf enum value: SEND_INPUT_EVENT = 33; - */ - SEND_INPUT_EVENT = 33 + SYNCHRONIZE_UMA_STORE = 32 } /** * @generated from protobuf enum api.ModuleWorkflowTypeEnum diff --git a/site.ts b/site.ts index 828f68d..0319c7f 100644 --- a/site.ts +++ b/site.ts @@ -19,6 +19,10 @@ import { PrjMetadata } from "./metadatadef"; import { ResponseHeader } from "./shared"; import { DateTime } from "./shared"; import { AppointmentCommission } from "./slotbooking"; +import { SlotGroupAndReason } from "./slotbooking"; +import { SlotGroup } from "./slotbooking"; +import { MetadataElement } from "./shared"; +import { SegmentationSelection } from "./slotbooking"; import { Commission } from "./slotbooking"; import { AppointmentType } from "./shared"; import { FileDataRequest } from "./shared"; @@ -485,6 +489,89 @@ export interface DeleteInstructionDocumentRequest { */ export interface DeleteInstructionDocumentResponse { } +/** + * GetAvailableSlots + * + * @generated from protobuf message api.GetAvailableSlotsRequest + */ +export interface GetAvailableSlotsRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 + */ + Header?: RequestProjectHeader; + /** + * Type of appointment : Loading / Unloading / Both + * + * @generated from protobuf field: api.AppointmentType AppointmentType = 2 + */ + AppointmentType: AppointmentType; + /** + * List of the orders and projects for which the appointment is made, with the quantities + * + * @generated from protobuf field: repeated api.Commission Commissions = 3 + */ + Commissions: Commission[]; + /** + * Set of segmentation constraining the slot booking + * + * @generated from protobuf field: repeated api.SegmentationSelection SegmentationSelections = 4 + */ + SegmentationSelections: SegmentationSelection[]; + /** + * @generated from protobuf field: string StartDate = 5 + */ + StartDate: string; // Start date of the range to look for available slots, format yyyy-mm-dd. + /** + * @generated from protobuf field: string EndDate = 6 + */ + EndDate: string; // End date of the range to look for available slots, format yyyy-mm-dd. + /** + * Optional, needed to skip counting those appointments in the capacity rules + * + * @generated from protobuf field: repeated string SkippedAppointmentIDs = 7 + */ + SkippedAppointmentIDs: string[]; + /** + * @generated from protobuf field: string ActorID = 8 + */ + ActorID: string; // actor with which the siteID/project-depositID will be processed + /** + * Carrier information metadata + * + * @generated from protobuf field: repeated api.MetadataElement CarrierInformation = 9 + */ + CarrierInformation: MetadataElement[]; + /** + * @generated from protobuf field: repeated api.MetadataElement MetaData = 10 + */ + MetaData: MetadataElement[]; +} +/** + * @generated from protobuf message api.GetAvailableSlotsResponse + */ +export interface GetAvailableSlotsResponse { + /** + * @generated from protobuf field: repeated api.SlotGroup SlotGroups = 1 + */ + SlotGroups: SlotGroup[]; // List of slot groups available for the current request + /** + * @generated from protobuf field: uint64 EstimatedNeededDurationInMinutes = 2 + */ + EstimatedNeededDurationInMinutes: bigint; // Computed needed slot duration in minutes +} +/** + * @generated from protobuf message api.GetAllSlotsResponse + */ +export interface GetAllSlotsResponse { + /** + * @generated from protobuf field: repeated api.SlotGroupAndReason SlotGroupAndReasons = 1 + */ + SlotGroupAndReasons: SlotGroupAndReason[]; // List of slot groups and the reason of their status + /** + * @generated from protobuf field: uint64 EstimatedNeededDurationInMinutes = 2 + */ + EstimatedNeededDurationInMinutes: bigint; // Computed needed slot duration in minutes +} /** * CheckAppointmentCommission * @@ -2362,6 +2449,234 @@ class DeleteInstructionDocumentResponse$Type extends MessageType { + constructor() { + super("api.GetAvailableSlotsRequest", [ + { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "n1validate.rules": { message: { required: true } } } }, + { no: 2, name: "AppointmentType", kind: "enum", localName: "AppointmentType", jsonName: "AppointmentType", T: () => ["api.AppointmentType", AppointmentType], options: { "n1validate.rules": { enum: { definedOnly: true } } } }, + { no: 3, name: "Commissions", kind: "message", localName: "Commissions", jsonName: "Commissions", repeat: 2 /*RepeatType.UNPACKED*/, T: () => Commission }, + { no: 4, name: "SegmentationSelections", kind: "message", localName: "SegmentationSelections", jsonName: "SegmentationSelections", repeat: 2 /*RepeatType.UNPACKED*/, T: () => SegmentationSelection }, + { no: 5, name: "StartDate", kind: "scalar", localName: "StartDate", jsonName: "StartDate", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { pattern: "^20[0-9]{2}-(0[1-9]|1[0-2])-(0[1-9]|[12][0-9]|3[01])$" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { pattern: "^20[0-9]{2}-(0[1-9]|1[0-2])-(0[1-9]|[12][0-9]|3[01])$" } } }, + { no: 6, name: "EndDate", kind: "scalar", localName: "EndDate", jsonName: "EndDate", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { pattern: "^20[0-9]{2}-(0[1-9]|1[0-2])-(0[1-9]|[12][0-9]|3[01])$" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { pattern: "^20[0-9]{2}-(0[1-9]|1[0-2])-(0[1-9]|[12][0-9]|3[01])$" } } }, + { no: 7, name: "SkippedAppointmentIDs", kind: "scalar", localName: "SkippedAppointmentIDs", jsonName: "SkippedAppointmentIDs", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ }, + { no: 8, name: "ActorID", kind: "scalar", localName: "ActorID", jsonName: "ActorID", T: 9 /*ScalarType.STRING*/ }, + { no: 9, name: "CarrierInformation", kind: "message", localName: "CarrierInformation", jsonName: "CarrierInformation", repeat: 2 /*RepeatType.UNPACKED*/, T: () => MetadataElement, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Carrier information metadata" }, "api.metadata": true, "api.aggKey": "Key" } }, + { no: 10, name: "MetaData", kind: "message", localName: "MetaData", jsonName: "MetaData", repeat: 2 /*RepeatType.UNPACKED*/, T: () => MetadataElement, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Metadata are characteristics specific to the site. They can be of several data form (string, integer, float, boolean or timestamp)" }, "api.metadata": true, "api.aggKey": "Key" } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "SegmentationSelection", "ActorID"] } } }); + } + create(value?: PartialMessage): GetAvailableSlotsRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + message.AppointmentType = 0; + message.Commissions = []; + message.SegmentationSelections = []; + message.StartDate = ""; + message.EndDate = ""; + message.SkippedAppointmentIDs = []; + message.ActorID = ""; + message.CarrierInformation = []; + message.MetaData = []; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetAvailableSlotsRequest): GetAvailableSlotsRequest { + 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.AppointmentType AppointmentType */ 2: + message.AppointmentType = reader.int32(); + break; + case /* repeated api.Commission Commissions */ 3: + message.Commissions.push(Commission.internalBinaryRead(reader, reader.uint32(), options)); + break; + case /* repeated api.SegmentationSelection SegmentationSelections */ 4: + message.SegmentationSelections.push(SegmentationSelection.internalBinaryRead(reader, reader.uint32(), options)); + break; + case /* string StartDate */ 5: + message.StartDate = reader.string(); + break; + case /* string EndDate */ 6: + message.EndDate = reader.string(); + break; + case /* repeated string SkippedAppointmentIDs */ 7: + message.SkippedAppointmentIDs.push(reader.string()); + break; + case /* string ActorID */ 8: + message.ActorID = reader.string(); + break; + case /* repeated api.MetadataElement CarrierInformation */ 9: + message.CarrierInformation.push(MetadataElement.internalBinaryRead(reader, reader.uint32(), options)); + break; + case /* repeated api.MetadataElement MetaData */ 10: + message.MetaData.push(MetadataElement.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: GetAvailableSlotsRequest, 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.AppointmentType AppointmentType = 2; */ + if (message.AppointmentType !== 0) + writer.tag(2, WireType.Varint).int32(message.AppointmentType); + /* repeated api.Commission Commissions = 3; */ + for (let i = 0; i < message.Commissions.length; i++) + Commission.internalBinaryWrite(message.Commissions[i], writer.tag(3, WireType.LengthDelimited).fork(), options).join(); + /* repeated api.SegmentationSelection SegmentationSelections = 4; */ + for (let i = 0; i < message.SegmentationSelections.length; i++) + SegmentationSelection.internalBinaryWrite(message.SegmentationSelections[i], writer.tag(4, WireType.LengthDelimited).fork(), options).join(); + /* string StartDate = 5; */ + if (message.StartDate !== "") + writer.tag(5, WireType.LengthDelimited).string(message.StartDate); + /* string EndDate = 6; */ + if (message.EndDate !== "") + writer.tag(6, WireType.LengthDelimited).string(message.EndDate); + /* repeated string SkippedAppointmentIDs = 7; */ + for (let i = 0; i < message.SkippedAppointmentIDs.length; i++) + writer.tag(7, WireType.LengthDelimited).string(message.SkippedAppointmentIDs[i]); + /* string ActorID = 8; */ + if (message.ActorID !== "") + writer.tag(8, WireType.LengthDelimited).string(message.ActorID); + /* repeated api.MetadataElement CarrierInformation = 9; */ + for (let i = 0; i < message.CarrierInformation.length; i++) + MetadataElement.internalBinaryWrite(message.CarrierInformation[i], writer.tag(9, WireType.LengthDelimited).fork(), options).join(); + /* repeated api.MetadataElement MetaData = 10; */ + for (let i = 0; i < message.MetaData.length; i++) + MetadataElement.internalBinaryWrite(message.MetaData[i], writer.tag(10, 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.GetAvailableSlotsRequest + */ +export const GetAvailableSlotsRequest = new GetAvailableSlotsRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class GetAvailableSlotsResponse$Type extends MessageType { + constructor() { + super("api.GetAvailableSlotsResponse", [ + { no: 1, name: "SlotGroups", kind: "message", localName: "SlotGroups", jsonName: "SlotGroups", repeat: 2 /*RepeatType.UNPACKED*/, T: () => SlotGroup }, + { no: 2, name: "EstimatedNeededDurationInMinutes", kind: "scalar", localName: "EstimatedNeededDurationInMinutes", jsonName: "EstimatedNeededDurationInMinutes", T: 4 /*ScalarType.UINT64*/, L: 0 /*LongType.BIGINT*/ } + ]); + } + create(value?: PartialMessage): GetAvailableSlotsResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + message.SlotGroups = []; + message.EstimatedNeededDurationInMinutes = 0n; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetAvailableSlotsResponse): GetAvailableSlotsResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* repeated api.SlotGroup SlotGroups */ 1: + message.SlotGroups.push(SlotGroup.internalBinaryRead(reader, reader.uint32(), options)); + break; + case /* uint64 EstimatedNeededDurationInMinutes */ 2: + message.EstimatedNeededDurationInMinutes = reader.uint64().toBigInt(); + 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: GetAvailableSlotsResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* repeated api.SlotGroup SlotGroups = 1; */ + for (let i = 0; i < message.SlotGroups.length; i++) + SlotGroup.internalBinaryWrite(message.SlotGroups[i], writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* uint64 EstimatedNeededDurationInMinutes = 2; */ + if (message.EstimatedNeededDurationInMinutes !== 0n) + writer.tag(2, WireType.Varint).uint64(message.EstimatedNeededDurationInMinutes); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.GetAvailableSlotsResponse + */ +export const GetAvailableSlotsResponse = new GetAvailableSlotsResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class GetAllSlotsResponse$Type extends MessageType { + constructor() { + super("api.GetAllSlotsResponse", [ + { no: 1, name: "SlotGroupAndReasons", kind: "message", localName: "SlotGroupAndReasons", jsonName: "SlotGroupAndReasons", repeat: 2 /*RepeatType.UNPACKED*/, T: () => SlotGroupAndReason }, + { no: 2, name: "EstimatedNeededDurationInMinutes", kind: "scalar", localName: "EstimatedNeededDurationInMinutes", jsonName: "EstimatedNeededDurationInMinutes", T: 4 /*ScalarType.UINT64*/, L: 0 /*LongType.BIGINT*/ } + ]); + } + create(value?: PartialMessage): GetAllSlotsResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + message.SlotGroupAndReasons = []; + message.EstimatedNeededDurationInMinutes = 0n; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetAllSlotsResponse): GetAllSlotsResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* repeated api.SlotGroupAndReason SlotGroupAndReasons */ 1: + message.SlotGroupAndReasons.push(SlotGroupAndReason.internalBinaryRead(reader, reader.uint32(), options)); + break; + case /* uint64 EstimatedNeededDurationInMinutes */ 2: + message.EstimatedNeededDurationInMinutes = reader.uint64().toBigInt(); + 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: GetAllSlotsResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* repeated api.SlotGroupAndReason SlotGroupAndReasons = 1; */ + for (let i = 0; i < message.SlotGroupAndReasons.length; i++) + SlotGroupAndReason.internalBinaryWrite(message.SlotGroupAndReasons[i], writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* uint64 EstimatedNeededDurationInMinutes = 2; */ + if (message.EstimatedNeededDurationInMinutes !== 0n) + writer.tag(2, WireType.Varint).uint64(message.EstimatedNeededDurationInMinutes); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.GetAllSlotsResponse + */ +export const GetAllSlotsResponse = new GetAllSlotsResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods class CheckAppointmentCommissionRequest$Type extends MessageType { constructor() { super("api.CheckAppointmentCommissionRequest", [ diff --git a/workflow.client.ts b/workflow.client.ts index 86ee7ff..5137067 100644 --- a/workflow.client.ts +++ b/workflow.client.ts @@ -4,8 +4,6 @@ import type { RpcTransport } from "@protobuf-ts/runtime-rpc"; import type { ServiceInfo } from "@protobuf-ts/runtime-rpc"; import { WorkflowService } from "./workflow"; -import type { StartWorkflowSendInputEventResult } from "./workflow"; -import type { StartWorkflowSendInputEventRequest } from "./workflow"; import type { StartWorkflowSynchronizeUMAStoreResult } from "./workflow"; import type { StartWorkflowSynchronizeUMAStoreRequest } from "./workflow"; import type { StartWorkflowCleanCassandraResult } from "./workflow"; @@ -210,10 +208,6 @@ export interface IWorkflowServiceClient { * @generated from protobuf rpc: StartWorkflowSynchronizeUMAStore */ startWorkflowSynchronizeUMAStore(input: StartWorkflowSynchronizeUMAStoreRequest, options?: RpcOptions): UnaryCall; - /** - * @generated from protobuf rpc: StartWorkflowSendInputEvent - */ - startWorkflowSendInputEvent(input: StartWorkflowSendInputEventRequest, options?: RpcOptions): UnaryCall; } /** * @generated from protobuf service api.WorkflowService @@ -455,11 +449,4 @@ export class WorkflowServiceClient implements IWorkflowServiceClient, ServiceInf const method = this.methods[32], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } - /** - * @generated from protobuf rpc: StartWorkflowSendInputEvent - */ - startWorkflowSendInputEvent(input: StartWorkflowSendInputEventRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[33], opt = this._transport.mergeOptions(options); - return stackIntercept("unary", this._transport, method, opt, input); - } } diff --git a/workflow.ts b/workflow.ts index 0cd904c..ee3437c 100644 --- a/workflow.ts +++ b/workflow.ts @@ -893,36 +893,6 @@ export interface StartWorkflowUpgradeModelResult { */ WorkflowExecution?: WorkflowExecutionResult; } -/** - * @generated from protobuf message api.StartWorkflowSendInputEventRequest - */ -export interface StartWorkflowSendInputEventRequest { - /** - * @generated from protobuf field: string OrganisationID = 1 - */ - OrganisationID: string; - /** - * @generated from protobuf field: string ProjectID = 2 - */ - ProjectID: string; - /** - * @generated from protobuf field: api.EntityType Entity = 3 - */ - Entity: EntityType; - /** - * @generated from protobuf field: string EventName = 4 - */ - EventName: string; -} -/** - * @generated from protobuf message api.StartWorkflowSendInputEventResult - */ -export interface StartWorkflowSendInputEventResult { - /** - * @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1 - */ - WorkflowExecution?: WorkflowExecutionResult; -} /** * @generated from protobuf message api.StartWorkflowSweepRequest */ @@ -4458,123 +4428,6 @@ class StartWorkflowUpgradeModelResult$Type extends MessageType { - constructor() { - super("api.StartWorkflowSendInputEventRequest", [ - { no: 1, name: "OrganisationID", kind: "scalar", localName: "OrganisationID", jsonName: "OrganisationID", T: 9 /*ScalarType.STRING*/ }, - { no: 2, name: "ProjectID", kind: "scalar", localName: "ProjectID", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/ }, - { no: 3, name: "Entity", kind: "enum", localName: "Entity", jsonName: "Entity", T: () => ["api.EntityType", EntityType] }, - { no: 4, name: "EventName", kind: "scalar", localName: "EventName", jsonName: "EventName", T: 9 /*ScalarType.STRING*/ } - ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: {} } }); - } - create(value?: PartialMessage): StartWorkflowSendInputEventRequest { - const message = globalThis.Object.create((this.messagePrototype!)); - message.OrganisationID = ""; - message.ProjectID = ""; - message.Entity = 0; - message.EventName = ""; - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowSendInputEventRequest): StartWorkflowSendInputEventRequest { - let message = target ?? this.create(), end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* string OrganisationID */ 1: - message.OrganisationID = reader.string(); - break; - case /* string ProjectID */ 2: - message.ProjectID = reader.string(); - break; - case /* api.EntityType Entity */ 3: - message.Entity = reader.int32(); - break; - case /* string EventName */ 4: - message.EventName = reader.string(); - 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: StartWorkflowSendInputEventRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* string OrganisationID = 1; */ - if (message.OrganisationID !== "") - writer.tag(1, WireType.LengthDelimited).string(message.OrganisationID); - /* string ProjectID = 2; */ - if (message.ProjectID !== "") - writer.tag(2, WireType.LengthDelimited).string(message.ProjectID); - /* api.EntityType Entity = 3; */ - if (message.Entity !== 0) - writer.tag(3, WireType.Varint).int32(message.Entity); - /* string EventName = 4; */ - if (message.EventName !== "") - writer.tag(4, WireType.LengthDelimited).string(message.EventName); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); - return writer; - } -} -/** - * @generated MessageType for protobuf message api.StartWorkflowSendInputEventRequest - */ -export const StartWorkflowSendInputEventRequest = new StartWorkflowSendInputEventRequest$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class StartWorkflowSendInputEventResult$Type extends MessageType { - constructor() { - super("api.StartWorkflowSendInputEventResult", [ - { no: 1, name: "WorkflowExecution", kind: "message", localName: "WorkflowExecution", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult } - ]); - } - create(value?: PartialMessage): StartWorkflowSendInputEventResult { - const message = globalThis.Object.create((this.messagePrototype!)); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowSendInputEventResult): StartWorkflowSendInputEventResult { - let message = target ?? this.create(), end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* api.WorkflowExecutionResult WorkflowExecution */ 1: - message.WorkflowExecution = WorkflowExecutionResult.internalBinaryRead(reader, reader.uint32(), options, message.WorkflowExecution); - 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: StartWorkflowSendInputEventResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* api.WorkflowExecutionResult WorkflowExecution = 1; */ - if (message.WorkflowExecution) - WorkflowExecutionResult.internalBinaryWrite(message.WorkflowExecution, 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.StartWorkflowSendInputEventResult - */ -export const StartWorkflowSendInputEventResult = new StartWorkflowSendInputEventResult$Type(); -// @generated message type with reflection information, may provide speed optimized methods class StartWorkflowSweepRequest$Type extends MessageType { constructor() { super("api.StartWorkflowSweepRequest", [ @@ -5075,6 +4928,5 @@ export const WorkflowService = new ServiceType("api.WorkflowService", [ { name: "StartWorkflowCreateClickhouse", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will create clickhouse database for the project and the resource" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowCreateClickhouseRequest, O: StartWorkflowCreateClickhouseResult }, { name: "StartWorkflowDeleteClickhouse", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will delete clickhouse database for the project and the resource" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowDeleteClickhouseRequest, O: StartWorkflowDeleteClickhouseResult }, { name: "StartWorkflowCleanCassandra", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will clean data in cassandra tables for the project and the resource" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowCleanCassandraRequest, O: StartWorkflowCleanCassandraResult }, - { name: "StartWorkflowSynchronizeUMAStore", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will synchronize UMA store for all users or for a specific user if UserID is provided" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowSynchronizeUMAStoreRequest, O: StartWorkflowSynchronizeUMAStoreResult }, - { name: "StartWorkflowSendInputEvent", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to send an input event." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowSendInputEventRequest, O: StartWorkflowSendInputEventResult } + { name: "StartWorkflowSynchronizeUMAStore", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will synchronize UMA store for all users or for a specific user if UserID is provided" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowSynchronizeUMAStoreRequest, O: StartWorkflowSynchronizeUMAStoreResult } ], { "api.k8sService": "organisation-server", "api.roleManager": true, "api.resourceManager": true });