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
2026-07-09 08:03:17 +00:00
parent 3e5995934c
commit 565fe9f8ba
3 changed files with 163 additions and 2 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.15.0-SNAPSHOT-260703134713",
"version": "1.15.0-SNAPSHOT-260709080252",
"description": "npm libs from core model proto files",
"homepage": "",
"main": "index.ts",

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 { StartWorkflowSendInputEventResult } from "./workflow";
import type { StartWorkflowSendInputEventRequest } from "./workflow";
import type { StartWorkflowSynchronizeUMAStoreResult } from "./workflow";
import type { StartWorkflowSynchronizeUMAStoreRequest } from "./workflow";
import type { StartWorkflowCleanCassandraResult } from "./workflow";
@@ -214,6 +216,10 @@ 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
@@ -462,4 +468,11 @@ export class WorkflowServiceClient implements IWorkflowServiceClient, ServiceInf
const method = this.methods[33], 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[34], opt = this._transport.mergeOptions(options);
return stackIntercept<StartWorkflowSendInputEventRequest, StartWorkflowSendInputEventResult>("unary", this._transport, method, opt, input);
}
}

150
workflow.ts
View File

@@ -907,6 +907,36 @@ 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
*/
@@ -4526,6 +4556,123 @@ 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", [
@@ -5027,5 +5174,6 @@ 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: "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 }
], { "api.k8sService": "organisation-server", "api.roleManager": true, "api.resourceManager": true });