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-10-03 14:29:18 +00:00
parent 49115fd1f1
commit 97566d4520
35 changed files with 1176 additions and 7397 deletions
Download Patch File Download Diff File Expand all files Collapse all files

305
workflow.ts
View File

@@ -11,7 +11,6 @@ import { UnknownFieldHandler } from "@protobuf-ts/runtime";
import type { PartialMessage } from "@protobuf-ts/runtime";
import { reflectionMergePartial } from "@protobuf-ts/runtime";
import { MessageType } from "@protobuf-ts/runtime";
import { ResourceType } from "./shared";
import { EntityType } from "./shared";
import { RecoverType } from "./shared";
import { ModelDataSetEnum } from "./shared";
@@ -138,58 +137,6 @@ export interface StartWorkflowDeleteCoreResult {
*/
WorkflowExecution?: WorkflowExecutionResult;
}
/**
* @generated from protobuf message api.StartWorkflowDeleteSiteRequest
*/
export interface StartWorkflowDeleteSiteRequest {
/**
* @generated from protobuf field: string SiteId = 1
*/
SiteId: string;
/**
* @generated from protobuf field: string UserId = 2
*/
UserId: string;
}
/**
* @generated from protobuf message api.StartWorkflowDeleteSiteResult
*/
export interface StartWorkflowDeleteSiteResult {
/**
* @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1
*/
WorkflowExecution?: WorkflowExecutionResult;
}
/**
* @generated from protobuf message api.StartWorkflowCreateSiteRequest
*/
export interface StartWorkflowCreateSiteRequest {
/**
* @generated from protobuf field: string OrganisationId = 1
*/
OrganisationId: string;
/**
* @generated from protobuf field: string SiteId = 2
*/
SiteId: string;
/**
* @generated from protobuf field: string UserSub = 3
*/
UserSub: string;
/**
* @generated from protobuf field: string ManagerEmail = 4
*/
ManagerEmail: string;
}
/**
* @generated from protobuf message api.StartWorkflowCreateSiteResult
*/
export interface StartWorkflowCreateSiteResult {
/**
* @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1
*/
WorkflowExecution?: WorkflowExecutionResult;
}
/**
* @generated from protobuf message api.StartWorkflowDeletePartnerAppRequest
*/
@@ -889,10 +836,6 @@ export interface StartWorkflowCreateClickhouseRequest {
* @generated from protobuf field: string ResourceID = 1
*/
ResourceID: string;
/**
* @generated from protobuf field: api.ResourceType ResourceType = 2
*/
ResourceType: ResourceType;
}
/**
* @generated from protobuf message api.StartWorkflowCreateClickhouseResult
@@ -929,10 +872,6 @@ export interface StartWorkflowCleanCassandraRequest {
* @generated from protobuf field: string ResourceID = 1
*/
ResourceID: string;
/**
* @generated from protobuf field: api.ResourceType ResourceType = 2
*/
ResourceType: ResourceType;
}
/**
* @generated from protobuf message api.StartWorkflowCleanCassandraResult
@@ -1405,224 +1344,6 @@ class StartWorkflowDeleteCoreResult$Type extends MessageType<StartWorkflowDelete
*/
export const StartWorkflowDeleteCoreResult = new StartWorkflowDeleteCoreResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowDeleteSiteRequest$Type extends MessageType<StartWorkflowDeleteSiteRequest> {
constructor() {
super("api.StartWorkflowDeleteSiteRequest", [
{ no: 1, name: "SiteId", kind: "scalar", localName: "SiteId", jsonName: "SiteId", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 2, name: "UserId", kind: "scalar", localName: "UserId", jsonName: "UserId", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["SiteId", "UserId"] } } });
}
create(value?: PartialMessage<StartWorkflowDeleteSiteRequest>): StartWorkflowDeleteSiteRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.SiteId = "";
message.UserId = "";
if (value !== undefined)
reflectionMergePartial<StartWorkflowDeleteSiteRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowDeleteSiteRequest): StartWorkflowDeleteSiteRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string SiteId */ 1:
message.SiteId = reader.string();
break;
case /* string UserId */ 2:
message.UserId = 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: StartWorkflowDeleteSiteRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string SiteId = 1; */
if (message.SiteId !== "")
writer.tag(1, WireType.LengthDelimited).string(message.SiteId);
/* string UserId = 2; */
if (message.UserId !== "")
writer.tag(2, WireType.LengthDelimited).string(message.UserId);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.StartWorkflowDeleteSiteRequest
*/
export const StartWorkflowDeleteSiteRequest = new StartWorkflowDeleteSiteRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowDeleteSiteResult$Type extends MessageType<StartWorkflowDeleteSiteResult> {
constructor() {
super("api.StartWorkflowDeleteSiteResult", [
{ no: 1, name: "WorkflowExecution", kind: "message", localName: "WorkflowExecution", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult }
]);
}
create(value?: PartialMessage<StartWorkflowDeleteSiteResult>): StartWorkflowDeleteSiteResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<StartWorkflowDeleteSiteResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowDeleteSiteResult): StartWorkflowDeleteSiteResult {
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: StartWorkflowDeleteSiteResult, 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.StartWorkflowDeleteSiteResult
*/
export const StartWorkflowDeleteSiteResult = new StartWorkflowDeleteSiteResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowCreateSiteRequest$Type extends MessageType<StartWorkflowCreateSiteRequest> {
constructor() {
super("api.StartWorkflowCreateSiteRequest", [
{ no: 1, name: "OrganisationId", kind: "scalar", localName: "OrganisationId", jsonName: "OrganisationId", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 2, name: "SiteId", kind: "scalar", localName: "SiteId", jsonName: "SiteId", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 3, name: "UserSub", kind: "scalar", localName: "UserSub", jsonName: "UserSub", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 4, name: "ManagerEmail", kind: "scalar", localName: "ManagerEmail", jsonName: "ManagerEmail", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["OrganisationId", "SiteId", "UserSub", "ManagerEmail"] } } });
}
create(value?: PartialMessage<StartWorkflowCreateSiteRequest>): StartWorkflowCreateSiteRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.OrganisationId = "";
message.SiteId = "";
message.UserSub = "";
message.ManagerEmail = "";
if (value !== undefined)
reflectionMergePartial<StartWorkflowCreateSiteRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowCreateSiteRequest): StartWorkflowCreateSiteRequest {
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 SiteId */ 2:
message.SiteId = reader.string();
break;
case /* string UserSub */ 3:
message.UserSub = reader.string();
break;
case /* string ManagerEmail */ 4:
message.ManagerEmail = 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: StartWorkflowCreateSiteRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string OrganisationId = 1; */
if (message.OrganisationId !== "")
writer.tag(1, WireType.LengthDelimited).string(message.OrganisationId);
/* string SiteId = 2; */
if (message.SiteId !== "")
writer.tag(2, WireType.LengthDelimited).string(message.SiteId);
/* string UserSub = 3; */
if (message.UserSub !== "")
writer.tag(3, WireType.LengthDelimited).string(message.UserSub);
/* string ManagerEmail = 4; */
if (message.ManagerEmail !== "")
writer.tag(4, WireType.LengthDelimited).string(message.ManagerEmail);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.StartWorkflowCreateSiteRequest
*/
export const StartWorkflowCreateSiteRequest = new StartWorkflowCreateSiteRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowCreateSiteResult$Type extends MessageType<StartWorkflowCreateSiteResult> {
constructor() {
super("api.StartWorkflowCreateSiteResult", [
{ no: 1, name: "WorkflowExecution", kind: "message", localName: "WorkflowExecution", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult }
]);
}
create(value?: PartialMessage<StartWorkflowCreateSiteResult>): StartWorkflowCreateSiteResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<StartWorkflowCreateSiteResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowCreateSiteResult): StartWorkflowCreateSiteResult {
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: StartWorkflowCreateSiteResult, 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.StartWorkflowCreateSiteResult
*/
export const StartWorkflowCreateSiteResult = new StartWorkflowCreateSiteResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowDeletePartnerAppRequest$Type extends MessageType<StartWorkflowDeletePartnerAppRequest> {
constructor() {
super("api.StartWorkflowDeletePartnerAppRequest", [
@@ -4531,14 +4252,12 @@ export const StartWorkflowSweepResult = new StartWorkflowSweepResult$Type();
class StartWorkflowCreateClickhouseRequest$Type extends MessageType<StartWorkflowCreateClickhouseRequest> {
constructor() {
super("api.StartWorkflowCreateClickhouseRequest", [
{ no: 1, name: "ResourceID", kind: "scalar", localName: "ResourceID", jsonName: "ResourceID", T: 9 /*ScalarType.STRING*/ },
{ no: 2, name: "ResourceType", kind: "enum", localName: "ResourceType", jsonName: "ResourceType", T: () => ["api.ResourceType", ResourceType] }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ResourceID", "ResourceType"] } } });
{ no: 1, name: "ResourceID", kind: "scalar", localName: "ResourceID", jsonName: "ResourceID", T: 9 /*ScalarType.STRING*/ }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ResourceID"] } } });
}
create(value?: PartialMessage<StartWorkflowCreateClickhouseRequest>): StartWorkflowCreateClickhouseRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.ResourceID = "";
message.ResourceType = 0;
if (value !== undefined)
reflectionMergePartial<StartWorkflowCreateClickhouseRequest>(this, message, value);
return message;
@@ -4551,9 +4270,6 @@ class StartWorkflowCreateClickhouseRequest$Type extends MessageType<StartWorkflo
case /* string ResourceID */ 1:
message.ResourceID = reader.string();
break;
case /* api.ResourceType ResourceType */ 2:
message.ResourceType = reader.int32();
break;
default:
let u = options.readUnknownField;
if (u === "throw")
@@ -4569,9 +4285,6 @@ class StartWorkflowCreateClickhouseRequest$Type extends MessageType<StartWorkflo
/* string ResourceID = 1; */
if (message.ResourceID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ResourceID);
/* api.ResourceType ResourceType = 2; */
if (message.ResourceType !== 0)
writer.tag(2, WireType.Varint).int32(message.ResourceType);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
@@ -4725,14 +4438,12 @@ export const StartWorkflowDeleteClickhouseResult = new StartWorkflowDeleteClickh
class StartWorkflowCleanCassandraRequest$Type extends MessageType<StartWorkflowCleanCassandraRequest> {
constructor() {
super("api.StartWorkflowCleanCassandraRequest", [
{ no: 1, name: "ResourceID", kind: "scalar", localName: "ResourceID", jsonName: "ResourceID", T: 9 /*ScalarType.STRING*/ },
{ no: 2, name: "ResourceType", kind: "enum", localName: "ResourceType", jsonName: "ResourceType", T: () => ["api.ResourceType", ResourceType] }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ResourceID", "ResourceType"] } } });
{ no: 1, name: "ResourceID", kind: "scalar", localName: "ResourceID", jsonName: "ResourceID", T: 9 /*ScalarType.STRING*/ }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ResourceID"] } } });
}
create(value?: PartialMessage<StartWorkflowCleanCassandraRequest>): StartWorkflowCleanCassandraRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.ResourceID = "";
message.ResourceType = 0;
if (value !== undefined)
reflectionMergePartial<StartWorkflowCleanCassandraRequest>(this, message, value);
return message;
@@ -4745,9 +4456,6 @@ class StartWorkflowCleanCassandraRequest$Type extends MessageType<StartWorkflowC
case /* string ResourceID */ 1:
message.ResourceID = reader.string();
break;
case /* api.ResourceType ResourceType */ 2:
message.ResourceType = reader.int32();
break;
default:
let u = options.readUnknownField;
if (u === "throw")
@@ -4763,9 +4471,6 @@ class StartWorkflowCleanCassandraRequest$Type extends MessageType<StartWorkflowC
/* string ResourceID = 1; */
if (message.ResourceID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ResourceID);
/* api.ResourceType ResourceType = 2; */
if (message.ResourceType !== 0)
writer.tag(2, WireType.Varint).int32(message.ResourceType);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
@@ -4830,8 +4535,6 @@ export const WorkflowService = new ServiceType("api.WorkflowService", [
{ name: "StartWorkflowCreateProject", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow CreateProject" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowCreateProjectRequest, O: StartWorkflowCreateProjectResult },
{ name: "StartWorkflowDeleteProject", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow DeleteProject" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowDeleteProjectRequest, O: StartWorkflowDeleteProjectResult },
{ name: "StartWorkflowDeleteCore", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow DeleteCore" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowDeleteCoreRequest, O: StartWorkflowDeleteCoreResult },
{ name: "StartWorkflowCreateSite", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow CreateSite" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowCreateSiteRequest, O: StartWorkflowCreateSiteResult },
{ name: "StartWorkflowDeleteSite", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow DeleteSite" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowDeleteSiteRequest, O: StartWorkflowDeleteSiteResult },
{ name: "StartWorkflowDeletePartnerApp", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow DeletePartnerApp" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowDeletePartnerAppRequest, O: StartWorkflowDeletePartnerAppResult },
{ name: "StartWorkflowDeleteConnection", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow DeleteConnection" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowDeleteConnectionRequest, O: StartWorkflowDeleteConnectionResult },
{ name: "StartWorkflowBilling", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow Billing" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowBillingRequest, O: StartWorkflowBillingResult },