From 078410d022ac951ee0bbe0f1745061041017269e Mon Sep 17 00:00:00 2001 From: ci core model Date: Thu, 3 Apr 2025 14:00:34 +0000 Subject: [PATCH] Latest generation --- package.json | 2 +- workflow.client.ts | 13 ++++++ workflow.ts | 101 ++++++++++++++++++++++++++++++++++++++++++++- 3 files changed, 114 insertions(+), 2 deletions(-) diff --git a/package.json b/package.json index 3c97ceb5..9038db42 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@reflex-platform/npm-core-sdk", - "version": "1.10.0-SNAPSHOT-250403134918", + "version": "1.10.0-SNAPSHOT-250403140001", "description": "npm libs from core model proto files", "homepage": "", "main": "index.ts", diff --git a/workflow.client.ts b/workflow.client.ts index ba308b77..95527c0c 100644 --- a/workflow.client.ts +++ b/workflow.client.ts @@ -4,6 +4,8 @@ import type { RpcTransport } from "@protobuf-ts/runtime-rpc"; import type { ServiceInfo } from "@protobuf-ts/runtime-rpc"; import { WorkflowService } from "./workflow"; +import type { StartWorkflowUpgradeModelResult } from "./workflow"; +import type { StartWorkflowUpgradeModelRequest } from "./workflow"; import type { StartWorkflowAnonymizeDataResult } from "./workflow"; import type { StartWorkflowAnonymizeDataRequest } from "./workflow"; import type { StartWorkflowSynchronizeRulesOnGitResult } from "./workflow"; @@ -173,6 +175,10 @@ export interface IWorkflowServiceClient { * @generated from protobuf rpc: StartWorkflowAnonymizeData(api.StartWorkflowAnonymizeDataRequest) returns (api.StartWorkflowAnonymizeDataResult); */ startWorkflowAnonymizeData(input: StartWorkflowAnonymizeDataRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: StartWorkflowUpgradeModel(api.StartWorkflowUpgradeModelRequest) returns (api.StartWorkflowUpgradeModelResult); + */ + startWorkflowUpgradeModel(input: StartWorkflowUpgradeModelRequest, options?: RpcOptions): UnaryCall; } /** * @generated from protobuf service api.WorkflowService @@ -372,4 +378,11 @@ export class WorkflowServiceClient implements IWorkflowServiceClient, ServiceInf const method = this.methods[26], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } + /** + * @generated from protobuf rpc: StartWorkflowUpgradeModel(api.StartWorkflowUpgradeModelRequest) returns (api.StartWorkflowUpgradeModelResult); + */ + startWorkflowUpgradeModel(input: StartWorkflowUpgradeModelRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[27], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } } diff --git a/workflow.ts b/workflow.ts index ad3f0b05..c06f793d 100644 --- a/workflow.ts +++ b/workflow.ts @@ -788,6 +788,20 @@ export interface StartWorkflowAnonymizeDataResult { */ workflowExecution?: WorkflowExecutionResult; } +/** + * @generated from protobuf message api.StartWorkflowUpgradeModelRequest + */ +export interface StartWorkflowUpgradeModelRequest { +} +/** + * @generated from protobuf message api.StartWorkflowUpgradeModelResult + */ +export interface StartWorkflowUpgradeModelResult { + /** + * @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1 [json_name = "WorkflowExecution"]; + */ + workflowExecution?: WorkflowExecutionResult; +} /** * @generated from protobuf enum api.WorkflowStatusEnum */ @@ -3960,6 +3974,90 @@ class StartWorkflowAnonymizeDataResult$Type extends MessageType { + constructor() { + super("api.StartWorkflowUpgradeModelRequest", [], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: {} } }); + } + create(value?: PartialMessage): StartWorkflowUpgradeModelRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowUpgradeModelRequest): StartWorkflowUpgradeModelRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + 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: StartWorkflowUpgradeModelRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.StartWorkflowUpgradeModelRequest + */ +export const StartWorkflowUpgradeModelRequest = new StartWorkflowUpgradeModelRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class StartWorkflowUpgradeModelResult$Type extends MessageType { + constructor() { + super("api.StartWorkflowUpgradeModelResult", [ + { no: 1, name: "WorkflowExecution", kind: "message", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult } + ]); + } + create(value?: PartialMessage): StartWorkflowUpgradeModelResult { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowUpgradeModelResult): StartWorkflowUpgradeModelResult { + 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 [json_name = "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: StartWorkflowUpgradeModelResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.WorkflowExecutionResult WorkflowExecution = 1 [json_name = "WorkflowExecution"]; */ + 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.StartWorkflowUpgradeModelResult + */ +export const StartWorkflowUpgradeModelResult = new StartWorkflowUpgradeModelResult$Type(); /** * @generated ServiceType for protobuf service api.WorkflowService */ @@ -3990,5 +4088,6 @@ export const WorkflowService = new ServiceType("api.WorkflowService", [ { name: "StartWorkflowExtractKPI", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to extract kpi" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowExtractKPIRequest, O: StartWorkflowExtractKPIResult }, { name: "StartWorkflowPruneData", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to prune project entity data." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowPruneDataRequest, O: StartWorkflowPruneDataResult }, { name: "StartWorkflowSynchronizeRulesOnGit", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to synchronize rules on git" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowSynchronizeRulesOnGitRequest, O: StartWorkflowSynchronizeRulesOnGitResult }, - { name: "StartWorkflowAnonymizeData", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to anonymize project entity data." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowAnonymizeDataRequest, O: StartWorkflowAnonymizeDataResult } + { name: "StartWorkflowAnonymizeData", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to anonymize project entity data." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowAnonymizeDataRequest, O: StartWorkflowAnonymizeDataResult }, + { name: "StartWorkflowUpgradeModel", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to run upgrade script according to the model version." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowUpgradeModelRequest, O: StartWorkflowUpgradeModelResult } ], { "api.k8sService": "organisation-server", "api.roleManager": true, "api.resourceManager": true });