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

Latest generation

Browse Source
This commit is contained in:
ci core model
2025-04-23 12:43:45 +00:00
parent 79d8e5b70b
commit 38c570ecb0
4 changed files with 119 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
package.json
View File

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

6
shared.ts
View File

@@ -1986,7 +1986,11 @@ export enum WorkflowTypeEnum {
/**
* @generated from protobuf enum value: UPGRADE_MODEL = 27;
*/
UPGRADE_MODEL = 27
UPGRADE_MODEL = 27,
/**
* @generated from protobuf enum value: SWEEP = 28;
*/
SWEEP = 28
}
/**
* @generated from protobuf enum api.ModuleWorkflowTypeEnum

13
workflow.client.ts
View File

@@ -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 { StartWorkflowSweepResult } from "./workflow";
import type { StartWorkflowSweepRequest } from "./workflow";
import type { StartWorkflowUpgradeModelResult } from "./workflow";
import type { StartWorkflowUpgradeModelRequest } from "./workflow";
import type { StartWorkflowAnonymizeDataResult } from "./workflow";
@@ -179,6 +181,10 @@ export interface IWorkflowServiceClient {
* @generated from protobuf rpc: StartWorkflowUpgradeModel(api.StartWorkflowUpgradeModelRequest) returns (api.StartWorkflowUpgradeModelResult);
*/
startWorkflowUpgradeModel(input: StartWorkflowUpgradeModelRequest, options?: RpcOptions): UnaryCall<StartWorkflowUpgradeModelRequest, StartWorkflowUpgradeModelResult>;
/**
* @generated from protobuf rpc: StartWorkflowSweep(api.StartWorkflowSweepRequest) returns (api.StartWorkflowSweepResult);
*/
startWorkflowSweep(input: StartWorkflowSweepRequest, options?: RpcOptions): UnaryCall<StartWorkflowSweepRequest, StartWorkflowSweepResult>;
}
/**
* @generated from protobuf service api.WorkflowService
@@ -385,4 +391,11 @@ export class WorkflowServiceClient implements IWorkflowServiceClient, ServiceInf
const method = this.methods[27], opt = this._transport.mergeOptions(options);
return stackIntercept<StartWorkflowUpgradeModelRequest, StartWorkflowUpgradeModelResult>("unary", this._transport, method, opt, input);
}
/**
* @generated from protobuf rpc: StartWorkflowSweep(api.StartWorkflowSweepRequest) returns (api.StartWorkflowSweepResult);
*/
startWorkflowSweep(input: StartWorkflowSweepRequest, options?: RpcOptions): UnaryCall<StartWorkflowSweepRequest, StartWorkflowSweepResult> {
const method = this.methods[28], opt = this._transport.mergeOptions(options);
return stackIntercept<StartWorkflowSweepRequest, StartWorkflowSweepResult>("unary", this._transport, method, opt, input);
}
}

101
workflow.ts
View File

@@ -806,6 +806,20 @@ export interface StartWorkflowUpgradeModelResult {
*/
workflowExecution?: WorkflowExecutionResult;
}
/**
* @generated from protobuf message api.StartWorkflowSweepRequest
*/
export interface StartWorkflowSweepRequest {
}
/**
* @generated from protobuf message api.StartWorkflowSweepResult
*/
export interface StartWorkflowSweepResult {
/**
* @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1 [json_name = "WorkflowExecution"];
*/
workflowExecution?: WorkflowExecutionResult;
}
/**
* @generated from protobuf enum api.WorkflowStatusEnum
*/
@@ -4071,6 +4085,90 @@ class StartWorkflowUpgradeModelResult$Type extends MessageType<StartWorkflowUpgr
* @generated MessageType for protobuf message api.StartWorkflowUpgradeModelResult
*/
export const StartWorkflowUpgradeModelResult = new StartWorkflowUpgradeModelResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowSweepRequest$Type extends MessageType<StartWorkflowSweepRequest> {
constructor() {
super("api.StartWorkflowSweepRequest", [], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: {} } });
}
create(value?: PartialMessage<StartWorkflowSweepRequest>): StartWorkflowSweepRequest {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<StartWorkflowSweepRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowSweepRequest): StartWorkflowSweepRequest {
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: StartWorkflowSweepRequest, 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.StartWorkflowSweepRequest
*/
export const StartWorkflowSweepRequest = new StartWorkflowSweepRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowSweepResult$Type extends MessageType<StartWorkflowSweepResult> {
constructor() {
super("api.StartWorkflowSweepResult", [
{ no: 1, name: "WorkflowExecution", kind: "message", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult }
]);
}
create(value?: PartialMessage<StartWorkflowSweepResult>): StartWorkflowSweepResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<StartWorkflowSweepResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowSweepResult): StartWorkflowSweepResult {
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: StartWorkflowSweepResult, 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.StartWorkflowSweepResult
*/
export const StartWorkflowSweepResult = new StartWorkflowSweepResult$Type();
/**
* @generated ServiceType for protobuf service api.WorkflowService
*/
@@ -4102,5 +4200,6 @@ export const WorkflowService = new ServiceType("api.WorkflowService", [
{ 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: "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 }
{ 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 },
{ name: "StartWorkflowSweep", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to sweep the platform." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowSweepRequest, O: StartWorkflowSweepResult }
], { "api.k8sService": "organisation-server", "api.roleManager": true, "api.resourceManager": true });