Compare commits

...

2 Commits

Author SHA1 Message Date
ci core model
f51a9c106d Release 1.14.2 2026-07-10 09:34:43 +00:00
ci core model
b5d741aaf8 Latest generation 2026-07-10 08:58:27 +00:00
6 changed files with 322 additions and 172 deletions

View File

@@ -34,7 +34,7 @@ export interface MessagingSettings {
/**
* @generated from protobuf field: string SenderLabel = 4
*/
SenderLabel: string; // SenderLabel is the label for the sender that will be displayed in messaging communications. Must be an alphanumeric sender ID (up to 11 chars, ASCII letters/digits/spaces)If not set, will use the default Hardis SCN label.
SenderLabel: string; // SenderLabel is the label for the sender that will be displayed in messaging communications. Must be uppercase letters only (up to 11 chars). If not set, will use the default Hardis SCN label.
}
/**
* MessagingSettingsHistory represents a record of changes made to the messaging settings for a specific project. It contains information about the user who made the change, the details of the messaging settings that were changed, and the timestamp of when the change was made.
@@ -110,7 +110,7 @@ export interface PutMessagingSettingsRequest {
/**
* @generated from protobuf field: string SenderLabel = 4
*/
SenderLabel: string; // SenderLabel is the label for the sender that will be displayed in messaging communications. Must be an alphanumeric sender ID (up to 11 chars, ASCII letters/digits/spaces). If not set, will use the default Hardis SCN label.
SenderLabel: string; // SenderLabel is the label for the sender that will be displayed in messaging communications. Must be uppercase letters only (up to 11 chars). If not set, will use the default Hardis SCN label.
}
/**
* @generated from protobuf message api.PutMessagingSettingsResponse
@@ -152,7 +152,7 @@ class MessagingSettings$Type extends MessageType<MessagingSettings> {
{ no: 1, name: "ProjectID", kind: "scalar", localName: "ProjectID", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { minLen: "1" } } } },
{ no: 2, name: "MaxUsage", kind: "scalar", localName: "MaxUsage", jsonName: "MaxUsage", T: 2 /*ScalarType.FLOAT*/, options: { "n1validate.rules": { float: { gte: 0 } } } },
{ no: 3, name: "Currency", kind: "enum", localName: "Currency", jsonName: "Currency", T: () => ["api.Currency", Currency], options: { "n1validate.rules": { enum: { definedOnly: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "<a href='https://en.wikipedia.org/wiki/ISO_4217'>ISO 4217</a> currency code", example: "[\"EUR\", \"USD\"]" } } },
{ no: 4, name: "SenderLabel", kind: "scalar", localName: "SenderLabel", jsonName: "SenderLabel", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { pattern: "^[a-zA-Z0-9 &]{1,11}$", ignoreEmpty: true } } } }
{ no: 4, name: "SenderLabel", kind: "scalar", localName: "SenderLabel", jsonName: "SenderLabel", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { pattern: "^[A-Z]{1,11}$", ignoreEmpty: true } } } }
]);
}
create(value?: PartialMessage<MessagingSettings>): MessagingSettings {
@@ -470,7 +470,7 @@ class PutMessagingSettingsRequest$Type extends MessageType<PutMessagingSettingsR
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "n1validate.rules": { message: { required: true } } } },
{ no: 2, name: "MaxUsage", kind: "scalar", localName: "MaxUsage", jsonName: "MaxUsage", T: 2 /*ScalarType.FLOAT*/, options: { "n1validate.rules": { float: { gte: 0 } } } },
{ no: 3, name: "Currency", kind: "enum", localName: "Currency", jsonName: "Currency", T: () => ["api.Currency", Currency], options: { "n1validate.rules": { enum: { definedOnly: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "<a href='https://en.wikipedia.org/wiki/ISO_4217'>ISO 4217</a> currency code", example: "[\"EUR\", \"USD\"]" } } },
{ no: 4, name: "SenderLabel", kind: "scalar", localName: "SenderLabel", jsonName: "SenderLabel", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { pattern: "^[a-zA-Z0-9 &]{1,11}$", ignoreEmpty: true } } } }
{ no: 4, name: "SenderLabel", kind: "scalar", localName: "SenderLabel", jsonName: "SenderLabel", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { pattern: "^[A-Z]{1,11}$", ignoreEmpty: true } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "MaxUsage", "Currency", "SenderLabel"] } } });
}
create(value?: PartialMessage<PutMessagingSettingsRequest>): PutMessagingSettingsRequest {

View File

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

View File

@@ -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
View File

@@ -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", [

View File

@@ -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);
}
}

View File

@@ -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 });