You've already forked npm-core-sdk
Release 1.14.3
This commit is contained in:
ci core model
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@reflex-platform/npm-core-sdk",
|
||||
"version": "1.15.0-SNAPSHOT-260720121810",
|
||||
"version": "1.14.3",
|
||||
"description": "npm libs from core model proto files",
|
||||
"homepage": "",
|
||||
"main": "index.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
|
||||
|
||||
315
site.ts
315
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<DeleteInstructi
|
||||
*/
|
||||
export const DeleteInstructionDocumentResponse = new DeleteInstructionDocumentResponse$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class GetAvailableSlotsRequest$Type extends MessageType<GetAvailableSlotsRequest> {
|
||||
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>): 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<GetAvailableSlotsRequest>(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<GetAvailableSlotsResponse> {
|
||||
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>): GetAvailableSlotsResponse {
|
||||
const message = globalThis.Object.create((this.messagePrototype!));
|
||||
message.SlotGroups = [];
|
||||
message.EstimatedNeededDurationInMinutes = 0n;
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<GetAvailableSlotsResponse>(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<GetAllSlotsResponse> {
|
||||
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>): GetAllSlotsResponse {
|
||||
const message = globalThis.Object.create((this.messagePrototype!));
|
||||
message.SlotGroupAndReasons = [];
|
||||
message.EstimatedNeededDurationInMinutes = 0n;
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<GetAllSlotsResponse>(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<CheckAppointmentCommissionRequest> {
|
||||
constructor() {
|
||||
super("api.CheckAppointmentCommissionRequest", [
|
||||
|
||||
@@ -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<StartWorkflowSynchronizeUMAStoreRequest, StartWorkflowSynchronizeUMAStoreResult>;
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowSendInputEvent
|
||||
*/
|
||||
startWorkflowSendInputEvent(input: StartWorkflowSendInputEventRequest, options?: RpcOptions): UnaryCall<StartWorkflowSendInputEventRequest, StartWorkflowSendInputEventResult>;
|
||||
}
|
||||
/**
|
||||
* @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<StartWorkflowSynchronizeUMAStoreRequest, StartWorkflowSynchronizeUMAStoreResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowSendInputEvent
|
||||
*/
|
||||
startWorkflowSendInputEvent(input: StartWorkflowSendInputEventRequest, options?: RpcOptions): UnaryCall<StartWorkflowSendInputEventRequest, StartWorkflowSendInputEventResult> {
|
||||
const method = this.methods[33], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowSendInputEventRequest, StartWorkflowSendInputEventResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
}
|
||||
|
||||
150
workflow.ts
150
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<StartWorkflowUpgr
|
||||
*/
|
||||
export const StartWorkflowUpgradeModelResult = new StartWorkflowUpgradeModelResult$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class StartWorkflowSendInputEventRequest$Type extends MessageType<StartWorkflowSendInputEventRequest> {
|
||||
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>): StartWorkflowSendInputEventRequest {
|
||||
const message = globalThis.Object.create((this.messagePrototype!));
|
||||
message.OrganisationID = "";
|
||||
message.ProjectID = "";
|
||||
message.Entity = 0;
|
||||
message.EventName = "";
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<StartWorkflowSendInputEventRequest>(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<StartWorkflowSendInputEventResult> {
|
||||
constructor() {
|
||||
super("api.StartWorkflowSendInputEventResult", [
|
||||
{ no: 1, name: "WorkflowExecution", kind: "message", localName: "WorkflowExecution", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult }
|
||||
]);
|
||||
}
|
||||
create(value?: PartialMessage<StartWorkflowSendInputEventResult>): StartWorkflowSendInputEventResult {
|
||||
const message = globalThis.Object.create((this.messagePrototype!));
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<StartWorkflowSendInputEventResult>(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<StartWorkflowSweepRequest> {
|
||||
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 });
|
||||
|
||||
Reference in New Issue
Block a user