From d14c71c05a920d46b728023715dee86a7bd94d6f Mon Sep 17 00:00:00 2001 From: ci core model Date: Wed, 19 Mar 2025 08:45:21 +0000 Subject: [PATCH] Latest generation --- index.ts | 2 + package.json | 2 +- project-lifecycle.client.ts | 102 ++++ project-lifecycle.ts | 1024 +++++++++++++++++++++++++++++++++++ 4 files changed, 1129 insertions(+), 1 deletion(-) create mode 100644 project-lifecycle.client.ts create mode 100644 project-lifecycle.ts diff --git a/index.ts b/index.ts index d5ee409a..b5ac2987 100644 --- a/index.ts +++ b/index.ts @@ -123,6 +123,8 @@ export * from './partnerQuery' export * from './proj.client' export * from './proj' + export * from './project-lifecycle.client' + export * from './project-lifecycle' export * from './repositoryShared' export * from './resource.client' export * from './resource' diff --git a/package.json b/package.json index 2dad0756..cd396cff 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@reflex-platform/npm-core-sdk", - "version": "1.10.0-SNAPSHOT-250318154109", + "version": "1.10.0-SNAPSHOT-250319084506", "description": "npm libs from core model proto files", "homepage": "", "main": "index.ts", diff --git a/project-lifecycle.client.ts b/project-lifecycle.client.ts new file mode 100644 index 00000000..f641c05f --- /dev/null +++ b/project-lifecycle.client.ts @@ -0,0 +1,102 @@ +// @generated by protobuf-ts 2.9.5 +// @generated from protobuf file "project-lifecycle.proto" (package "api", syntax proto3) +// tslint:disable +import type { RpcTransport } from "@protobuf-ts/runtime-rpc"; +import type { ServiceInfo } from "@protobuf-ts/runtime-rpc"; +import { ProjectLifecycleService } from "./project-lifecycle"; +import type { SetTaskNextRunAtResponse } from "./project-lifecycle"; +import type { SetTaskNextRunAtRequest } from "./project-lifecycle"; +import type { SetTaskExecutedAtResponse } from "./project-lifecycle"; +import type { SetTaskExecutedAtRequest } from "./project-lifecycle"; +import type { SetTaskStatusResponse } from "./project-lifecycle"; +import type { SetTaskStatusRequest } from "./project-lifecycle"; +import type { ListTasksResponse } from "./project-lifecycle"; +import type { ListTasksRequest } from "./project-lifecycle"; +import type { GetTaskResponse } from "./project-lifecycle"; +import type { GetTaskRequest } from "./project-lifecycle"; +import { stackIntercept } from "@protobuf-ts/runtime-rpc"; +import type { SetTaskRuleResponse } from "./project-lifecycle"; +import type { SetTaskRuleRequest } from "./project-lifecycle"; +import type { UnaryCall } from "@protobuf-ts/runtime-rpc"; +import type { RpcOptions } from "@protobuf-ts/runtime-rpc"; +/** + * @generated from protobuf service api.ProjectLifecycleService + */ +export interface IProjectLifecycleServiceClient { + /** + * @generated from protobuf rpc: SetTaskRule(api.SetTaskRuleRequest) returns (api.SetTaskRuleResponse); + */ + setTaskRule(input: SetTaskRuleRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: GetTask(api.GetTaskRequest) returns (api.GetTaskResponse); + */ + getTask(input: GetTaskRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: ListTasks(api.ListTasksRequest) returns (api.ListTasksResponse); + */ + listTasks(input: ListTasksRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: SetTaskStatus(api.SetTaskStatusRequest) returns (api.SetTaskStatusResponse); + */ + setTaskStatus(input: SetTaskStatusRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: SetTaskExecutedAt(api.SetTaskExecutedAtRequest) returns (api.SetTaskExecutedAtResponse); + */ + setTaskExecutedAt(input: SetTaskExecutedAtRequest, options?: RpcOptions): UnaryCall; + /** + * @generated from protobuf rpc: SetTaskNextRunAt(api.SetTaskNextRunAtRequest) returns (api.SetTaskNextRunAtResponse); + */ + setTaskNextRunAt(input: SetTaskNextRunAtRequest, options?: RpcOptions): UnaryCall; +} +/** + * @generated from protobuf service api.ProjectLifecycleService + */ +export class ProjectLifecycleServiceClient implements IProjectLifecycleServiceClient, ServiceInfo { + typeName = ProjectLifecycleService.typeName; + methods = ProjectLifecycleService.methods; + options = ProjectLifecycleService.options; + constructor(private readonly _transport: RpcTransport) { + } + /** + * @generated from protobuf rpc: SetTaskRule(api.SetTaskRuleRequest) returns (api.SetTaskRuleResponse); + */ + setTaskRule(input: SetTaskRuleRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[0], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: GetTask(api.GetTaskRequest) returns (api.GetTaskResponse); + */ + getTask(input: GetTaskRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[1], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: ListTasks(api.ListTasksRequest) returns (api.ListTasksResponse); + */ + listTasks(input: ListTasksRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[2], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: SetTaskStatus(api.SetTaskStatusRequest) returns (api.SetTaskStatusResponse); + */ + setTaskStatus(input: SetTaskStatusRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[3], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: SetTaskExecutedAt(api.SetTaskExecutedAtRequest) returns (api.SetTaskExecutedAtResponse); + */ + setTaskExecutedAt(input: SetTaskExecutedAtRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[4], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } + /** + * @generated from protobuf rpc: SetTaskNextRunAt(api.SetTaskNextRunAtRequest) returns (api.SetTaskNextRunAtResponse); + */ + setTaskNextRunAt(input: SetTaskNextRunAtRequest, options?: RpcOptions): UnaryCall { + const method = this.methods[5], opt = this._transport.mergeOptions(options); + return stackIntercept("unary", this._transport, method, opt, input); + } +} diff --git a/project-lifecycle.ts b/project-lifecycle.ts new file mode 100644 index 00000000..a3a0769e --- /dev/null +++ b/project-lifecycle.ts @@ -0,0 +1,1024 @@ +// @generated by protobuf-ts 2.9.5 +// @generated from protobuf file "project-lifecycle.proto" (package "api", syntax proto3) +// tslint:disable +import { ServiceType } from "@protobuf-ts/runtime-rpc"; +import type { BinaryWriteOptions } from "@protobuf-ts/runtime"; +import type { IBinaryWriter } from "@protobuf-ts/runtime"; +import { WireType } from "@protobuf-ts/runtime"; +import type { BinaryReadOptions } from "@protobuf-ts/runtime"; +import type { IBinaryReader } from "@protobuf-ts/runtime"; +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 { RequestProjectHeader } from "./shared"; +import { EntityType } from "./shared"; +/** + * @generated from protobuf message api.ProjectLifecycleTask + */ +export interface ProjectLifecycleTask { + /** + * @generated from protobuf field: string ProjectID = 1 [json_name = "ProjectID"]; + */ + projectID: string; + /** + * @generated from protobuf field: api.EntityType Entity = 2 [json_name = "Entity"]; + */ + entity: EntityType; + /** + * @generated from protobuf field: api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; + */ + taskType: ProjectLifecycleTaskType; + /** + * @generated from protobuf field: api.ProjectLifecycleTaskStatus TaskStatus = 4 [json_name = "TaskStatus"]; + */ + taskStatus: ProjectLifecycleTaskStatus; + /** + * @generated from protobuf field: string RuleDefinition = 5 [json_name = "RuleDefinition"]; + */ + ruleDefinition: string; + /** + * @generated from protobuf field: string ExecutedAt = 6 [json_name = "ExecutedAt"]; + */ + executedAt: string; + /** + * @generated from protobuf field: string NextRunAt = 7 [json_name = "NextRunAt"]; + */ + nextRunAt: string; +} +/** + * @generated from protobuf message api.SetTaskRuleRequest + */ +export interface SetTaskRuleRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 [json_name = "Header"]; + */ + header?: RequestProjectHeader; + /** + * @generated from protobuf field: api.EntityType Entity = 2 [json_name = "Entity"]; + */ + entity: EntityType; + /** + * @generated from protobuf field: api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; + */ + taskType: ProjectLifecycleTaskType; + /** + * @generated from protobuf field: string RuleDefinition = 4 [json_name = "RuleDefinition"]; + */ + ruleDefinition: string; +} +/** + * @generated from protobuf message api.SetTaskRuleResponse + */ +export interface SetTaskRuleResponse { + /** + * @generated from protobuf field: api.ProjectLifecycleTask Task = 1 [json_name = "Task"]; + */ + task?: ProjectLifecycleTask; +} +/** + * @generated from protobuf message api.GetTaskRequest + */ +export interface GetTaskRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 [json_name = "Header"]; + */ + header?: RequestProjectHeader; + /** + * @generated from protobuf field: api.EntityType Entity = 2 [json_name = "Entity"]; + */ + entity: EntityType; + /** + * @generated from protobuf field: api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; + */ + taskType: ProjectLifecycleTaskType; +} +/** + * @generated from protobuf message api.GetTaskResponse + */ +export interface GetTaskResponse { + /** + * @generated from protobuf field: api.ProjectLifecycleTask Task = 1 [json_name = "Task"]; + */ + task?: ProjectLifecycleTask; +} +/** + * @generated from protobuf message api.ListTasksRequest + */ +export interface ListTasksRequest { + /** + * @generated from protobuf field: api.RequestProjectHeader Header = 1 [json_name = "Header"]; + */ + header?: RequestProjectHeader; +} +/** + * @generated from protobuf message api.ListTasksResponse + */ +export interface ListTasksResponse { + /** + * @generated from protobuf field: repeated api.ProjectLifecycleTask Tasks = 1 [json_name = "Tasks"]; + */ + tasks: ProjectLifecycleTask[]; +} +/** + * @generated from protobuf message api.SetTaskStatusRequest + */ +export interface SetTaskStatusRequest { + /** + * @generated from protobuf field: string ProjectID = 1 [json_name = "ProjectID"]; + */ + projectID: string; + /** + * @generated from protobuf field: api.EntityType Entity = 2 [json_name = "Entity"]; + */ + entity: EntityType; + /** + * @generated from protobuf field: api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; + */ + taskType: ProjectLifecycleTaskType; + /** + * @generated from protobuf field: api.ProjectLifecycleTaskStatus TaskStatus = 4 [json_name = "TaskStatus"]; + */ + taskStatus: ProjectLifecycleTaskStatus; +} +/** + * @generated from protobuf message api.SetTaskStatusResponse + */ +export interface SetTaskStatusResponse { + /** + * @generated from protobuf field: api.ProjectLifecycleTask Task = 1 [json_name = "Task"]; + */ + task?: ProjectLifecycleTask; +} +/** + * @generated from protobuf message api.SetTaskNextRunAtRequest + */ +export interface SetTaskNextRunAtRequest { + /** + * @generated from protobuf field: string ProjectID = 1 [json_name = "ProjectID"]; + */ + projectID: string; + /** + * @generated from protobuf field: api.EntityType Entity = 2 [json_name = "Entity"]; + */ + entity: EntityType; + /** + * @generated from protobuf field: api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; + */ + taskType: ProjectLifecycleTaskType; + /** + * @generated from protobuf field: string NextRunAt = 4 [json_name = "NextRunAt"]; + */ + nextRunAt: string; +} +/** + * @generated from protobuf message api.SetTaskNextRunAtResponse + */ +export interface SetTaskNextRunAtResponse { + /** + * @generated from protobuf field: api.ProjectLifecycleTask Task = 1 [json_name = "Task"]; + */ + task?: ProjectLifecycleTask; +} +/** + * @generated from protobuf message api.SetTaskExecutedAtRequest + */ +export interface SetTaskExecutedAtRequest { + /** + * @generated from protobuf field: string ProjectID = 1 [json_name = "ProjectID"]; + */ + projectID: string; + /** + * @generated from protobuf field: api.EntityType Entity = 2 [json_name = "Entity"]; + */ + entity: EntityType; + /** + * @generated from protobuf field: api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; + */ + taskType: ProjectLifecycleTaskType; + /** + * @generated from protobuf field: string ExecutedAt = 4 [json_name = "ExecutedAt"]; + */ + executedAt: string; +} +/** + * @generated from protobuf message api.SetTaskExecutedAtResponse + */ +export interface SetTaskExecutedAtResponse { + /** + * @generated from protobuf field: api.ProjectLifecycleTask Task = 1 [json_name = "Task"]; + */ + task?: ProjectLifecycleTask; +} +/** + * @generated from protobuf enum api.ProjectLifecycleTaskType + */ +export enum ProjectLifecycleTaskType { + /** + * @generated from protobuf enum value: PROJECT_LIFECYCLE_TASK_UNKNOWN = 0; + */ + PROJECT_LIFECYCLE_TASK_UNKNOWN = 0, + /** + * @generated from protobuf enum value: PROJECT_LIFECYCLE_TASK_ANONYMIZE = 1; + */ + PROJECT_LIFECYCLE_TASK_ANONYMIZE = 1, + /** + * @generated from protobuf enum value: PROJECT_LIFECYCLE_TASK_PRUNE = 2; + */ + PROJECT_LIFECYCLE_TASK_PRUNE = 2 +} +/** + * @generated from protobuf enum api.ProjectLifecycleTaskStatus + */ +export enum ProjectLifecycleTaskStatus { + /** + * @generated from protobuf enum value: PROJECT_LIFECYCLE_TASK_STATUS_UNKNOWN = 0; + */ + UNKNOWN = 0, + /** + * @generated from protobuf enum value: PROJECT_LIFECYCLE_TASK_STATUS_RUNNING = 1; + */ + RUNNING = 1, + /** + * @generated from protobuf enum value: PROJECT_LIFECYCLE_TASK_STATUS_DONE = 2; + */ + DONE = 2, + /** + * @generated from protobuf enum value: PROJECT_LIFECYCLE_TASK_STATUS_FAILED = 3; + */ + FAILED = 3 +} +// @generated message type with reflection information, may provide speed optimized methods +class ProjectLifecycleTask$Type extends MessageType { + constructor() { + super("api.ProjectLifecycleTask", [ + { no: 1, name: "ProjectID", kind: "scalar", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/ }, + { no: 2, name: "Entity", kind: "enum", jsonName: "Entity", T: () => ["api.EntityType", EntityType, "ENTITY_TYPE_"] }, + { no: 3, name: "TaskType", kind: "enum", jsonName: "TaskType", T: () => ["api.ProjectLifecycleTaskType", ProjectLifecycleTaskType] }, + { no: 4, name: "TaskStatus", kind: "enum", jsonName: "TaskStatus", T: () => ["api.ProjectLifecycleTaskStatus", ProjectLifecycleTaskStatus, "PROJECT_LIFECYCLE_TASK_STATUS_"] }, + { no: 5, name: "RuleDefinition", kind: "scalar", jsonName: "RuleDefinition", T: 9 /*ScalarType.STRING*/ }, + { no: 6, name: "ExecutedAt", kind: "scalar", jsonName: "ExecutedAt", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "UTC date/time in ISO 8601 format" } } }, + { no: 7, name: "NextRunAt", kind: "scalar", jsonName: "NextRunAt", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "UTC date/time in ISO 8601 format" } } } + ]); + } + create(value?: PartialMessage): ProjectLifecycleTask { + const message = globalThis.Object.create((this.messagePrototype!)); + message.projectID = ""; + message.entity = 0; + message.taskType = 0; + message.taskStatus = 0; + message.ruleDefinition = ""; + message.executedAt = ""; + message.nextRunAt = ""; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ProjectLifecycleTask): ProjectLifecycleTask { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* string ProjectID = 1 [json_name = "ProjectID"];*/ 1: + message.projectID = reader.string(); + break; + case /* api.EntityType Entity = 2 [json_name = "Entity"];*/ 2: + message.entity = reader.int32(); + break; + case /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"];*/ 3: + message.taskType = reader.int32(); + break; + case /* api.ProjectLifecycleTaskStatus TaskStatus = 4 [json_name = "TaskStatus"];*/ 4: + message.taskStatus = reader.int32(); + break; + case /* string RuleDefinition = 5 [json_name = "RuleDefinition"];*/ 5: + message.ruleDefinition = reader.string(); + break; + case /* string ExecutedAt = 6 [json_name = "ExecutedAt"];*/ 6: + message.executedAt = reader.string(); + break; + case /* string NextRunAt = 7 [json_name = "NextRunAt"];*/ 7: + message.nextRunAt = 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: ProjectLifecycleTask, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* string ProjectID = 1 [json_name = "ProjectID"]; */ + if (message.projectID !== "") + writer.tag(1, WireType.LengthDelimited).string(message.projectID); + /* api.EntityType Entity = 2 [json_name = "Entity"]; */ + if (message.entity !== 0) + writer.tag(2, WireType.Varint).int32(message.entity); + /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; */ + if (message.taskType !== 0) + writer.tag(3, WireType.Varint).int32(message.taskType); + /* api.ProjectLifecycleTaskStatus TaskStatus = 4 [json_name = "TaskStatus"]; */ + if (message.taskStatus !== 0) + writer.tag(4, WireType.Varint).int32(message.taskStatus); + /* string RuleDefinition = 5 [json_name = "RuleDefinition"]; */ + if (message.ruleDefinition !== "") + writer.tag(5, WireType.LengthDelimited).string(message.ruleDefinition); + /* string ExecutedAt = 6 [json_name = "ExecutedAt"]; */ + if (message.executedAt !== "") + writer.tag(6, WireType.LengthDelimited).string(message.executedAt); + /* string NextRunAt = 7 [json_name = "NextRunAt"]; */ + if (message.nextRunAt !== "") + writer.tag(7, WireType.LengthDelimited).string(message.nextRunAt); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.ProjectLifecycleTask + */ +export const ProjectLifecycleTask = new ProjectLifecycleTask$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class SetTaskRuleRequest$Type extends MessageType { + constructor() { + super("api.SetTaskRuleRequest", [ + { no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => RequestProjectHeader, options: { "validate.rules": { message: { required: true } } } }, + { no: 2, name: "Entity", kind: "enum", jsonName: "Entity", T: () => ["api.EntityType", EntityType, "ENTITY_TYPE_"], options: { "validate.rules": { enum: { definedOnly: true } } } }, + { no: 3, name: "TaskType", kind: "enum", jsonName: "TaskType", T: () => ["api.ProjectLifecycleTaskType", ProjectLifecycleTaskType], options: { "validate.rules": { enum: { definedOnly: true } } } }, + { no: 4, name: "RuleDefinition", kind: "scalar", jsonName: "RuleDefinition", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "Entity", "TaskType", "RuleDefinition"] } } }); + } + create(value?: PartialMessage): SetTaskRuleRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + message.entity = 0; + message.taskType = 0; + message.ruleDefinition = ""; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SetTaskRuleRequest): SetTaskRuleRequest { + 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 [json_name = "Header"];*/ 1: + message.header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.header); + break; + case /* api.EntityType Entity = 2 [json_name = "Entity"];*/ 2: + message.entity = reader.int32(); + break; + case /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"];*/ 3: + message.taskType = reader.int32(); + break; + case /* string RuleDefinition = 4 [json_name = "RuleDefinition"];*/ 4: + message.ruleDefinition = 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: SetTaskRuleRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1 [json_name = "Header"]; */ + if (message.header) + RequestProjectHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityType Entity = 2 [json_name = "Entity"]; */ + if (message.entity !== 0) + writer.tag(2, WireType.Varint).int32(message.entity); + /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; */ + if (message.taskType !== 0) + writer.tag(3, WireType.Varint).int32(message.taskType); + /* string RuleDefinition = 4 [json_name = "RuleDefinition"]; */ + if (message.ruleDefinition !== "") + writer.tag(4, WireType.LengthDelimited).string(message.ruleDefinition); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.SetTaskRuleRequest + */ +export const SetTaskRuleRequest = new SetTaskRuleRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class SetTaskRuleResponse$Type extends MessageType { + constructor() { + super("api.SetTaskRuleResponse", [ + { no: 1, name: "Task", kind: "message", jsonName: "Task", T: () => ProjectLifecycleTask } + ]); + } + create(value?: PartialMessage): SetTaskRuleResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SetTaskRuleResponse): SetTaskRuleResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ProjectLifecycleTask Task = 1 [json_name = "Task"];*/ 1: + message.task = ProjectLifecycleTask.internalBinaryRead(reader, reader.uint32(), options, message.task); + 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: SetTaskRuleResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ProjectLifecycleTask Task = 1 [json_name = "Task"]; */ + if (message.task) + ProjectLifecycleTask.internalBinaryWrite(message.task, 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.SetTaskRuleResponse + */ +export const SetTaskRuleResponse = new SetTaskRuleResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class GetTaskRequest$Type extends MessageType { + constructor() { + super("api.GetTaskRequest", [ + { no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => RequestProjectHeader, options: { "validate.rules": { message: { required: true } } } }, + { no: 2, name: "Entity", kind: "enum", jsonName: "Entity", T: () => ["api.EntityType", EntityType, "ENTITY_TYPE_"], options: { "validate.rules": { enum: { definedOnly: true } } } }, + { no: 3, name: "TaskType", kind: "enum", jsonName: "TaskType", T: () => ["api.ProjectLifecycleTaskType", ProjectLifecycleTaskType], options: { "validate.rules": { enum: { definedOnly: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "Entity", "TaskType"] } } }); + } + create(value?: PartialMessage): GetTaskRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + message.entity = 0; + message.taskType = 0; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetTaskRequest): GetTaskRequest { + 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 [json_name = "Header"];*/ 1: + message.header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.header); + break; + case /* api.EntityType Entity = 2 [json_name = "Entity"];*/ 2: + message.entity = reader.int32(); + break; + case /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"];*/ 3: + message.taskType = reader.int32(); + 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: GetTaskRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1 [json_name = "Header"]; */ + if (message.header) + RequestProjectHeader.internalBinaryWrite(message.header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); + /* api.EntityType Entity = 2 [json_name = "Entity"]; */ + if (message.entity !== 0) + writer.tag(2, WireType.Varint).int32(message.entity); + /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; */ + if (message.taskType !== 0) + writer.tag(3, WireType.Varint).int32(message.taskType); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.GetTaskRequest + */ +export const GetTaskRequest = new GetTaskRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class GetTaskResponse$Type extends MessageType { + constructor() { + super("api.GetTaskResponse", [ + { no: 1, name: "Task", kind: "message", jsonName: "Task", T: () => ProjectLifecycleTask } + ]); + } + create(value?: PartialMessage): GetTaskResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetTaskResponse): GetTaskResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ProjectLifecycleTask Task = 1 [json_name = "Task"];*/ 1: + message.task = ProjectLifecycleTask.internalBinaryRead(reader, reader.uint32(), options, message.task); + 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: GetTaskResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ProjectLifecycleTask Task = 1 [json_name = "Task"]; */ + if (message.task) + ProjectLifecycleTask.internalBinaryWrite(message.task, 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.GetTaskResponse + */ +export const GetTaskResponse = new GetTaskResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ListTasksRequest$Type extends MessageType { + constructor() { + super("api.ListTasksRequest", [ + { no: 1, name: "Header", kind: "message", jsonName: "Header", T: () => RequestProjectHeader, options: { "validate.rules": { message: { required: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header"] } } }); + } + create(value?: PartialMessage): ListTasksRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ListTasksRequest): ListTasksRequest { + 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 [json_name = "Header"];*/ 1: + message.header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.header); + 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: ListTasksRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.RequestProjectHeader Header = 1 [json_name = "Header"]; */ + if (message.header) + RequestProjectHeader.internalBinaryWrite(message.header, 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.ListTasksRequest + */ +export const ListTasksRequest = new ListTasksRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class ListTasksResponse$Type extends MessageType { + constructor() { + super("api.ListTasksResponse", [ + { no: 1, name: "Tasks", kind: "message", jsonName: "Tasks", repeat: 1 /*RepeatType.PACKED*/, T: () => ProjectLifecycleTask } + ]); + } + create(value?: PartialMessage): ListTasksResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + message.tasks = []; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ListTasksResponse): ListTasksResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* repeated api.ProjectLifecycleTask Tasks = 1 [json_name = "Tasks"];*/ 1: + message.tasks.push(ProjectLifecycleTask.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: ListTasksResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* repeated api.ProjectLifecycleTask Tasks = 1 [json_name = "Tasks"]; */ + for (let i = 0; i < message.tasks.length; i++) + ProjectLifecycleTask.internalBinaryWrite(message.tasks[i], 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.ListTasksResponse + */ +export const ListTasksResponse = new ListTasksResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class SetTaskStatusRequest$Type extends MessageType { + constructor() { + super("api.SetTaskStatusRequest", [ + { no: 1, name: "ProjectID", kind: "scalar", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }, + { no: 2, name: "Entity", kind: "enum", jsonName: "Entity", T: () => ["api.EntityType", EntityType, "ENTITY_TYPE_"], options: { "validate.rules": { enum: { definedOnly: true } } } }, + { no: 3, name: "TaskType", kind: "enum", jsonName: "TaskType", T: () => ["api.ProjectLifecycleTaskType", ProjectLifecycleTaskType], options: { "validate.rules": { enum: { definedOnly: true } } } }, + { no: 4, name: "TaskStatus", kind: "enum", jsonName: "TaskStatus", T: () => ["api.ProjectLifecycleTaskStatus", ProjectLifecycleTaskStatus, "PROJECT_LIFECYCLE_TASK_STATUS_"], options: { "validate.rules": { enum: { definedOnly: true } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ProjectID", "Entity", "TaskType", "TaskStatus"] } } }); + } + create(value?: PartialMessage): SetTaskStatusRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + message.projectID = ""; + message.entity = 0; + message.taskType = 0; + message.taskStatus = 0; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SetTaskStatusRequest): SetTaskStatusRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* string ProjectID = 1 [json_name = "ProjectID"];*/ 1: + message.projectID = reader.string(); + break; + case /* api.EntityType Entity = 2 [json_name = "Entity"];*/ 2: + message.entity = reader.int32(); + break; + case /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"];*/ 3: + message.taskType = reader.int32(); + break; + case /* api.ProjectLifecycleTaskStatus TaskStatus = 4 [json_name = "TaskStatus"];*/ 4: + message.taskStatus = reader.int32(); + 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: SetTaskStatusRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* string ProjectID = 1 [json_name = "ProjectID"]; */ + if (message.projectID !== "") + writer.tag(1, WireType.LengthDelimited).string(message.projectID); + /* api.EntityType Entity = 2 [json_name = "Entity"]; */ + if (message.entity !== 0) + writer.tag(2, WireType.Varint).int32(message.entity); + /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; */ + if (message.taskType !== 0) + writer.tag(3, WireType.Varint).int32(message.taskType); + /* api.ProjectLifecycleTaskStatus TaskStatus = 4 [json_name = "TaskStatus"]; */ + if (message.taskStatus !== 0) + writer.tag(4, WireType.Varint).int32(message.taskStatus); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.SetTaskStatusRequest + */ +export const SetTaskStatusRequest = new SetTaskStatusRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class SetTaskStatusResponse$Type extends MessageType { + constructor() { + super("api.SetTaskStatusResponse", [ + { no: 1, name: "Task", kind: "message", jsonName: "Task", T: () => ProjectLifecycleTask } + ]); + } + create(value?: PartialMessage): SetTaskStatusResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SetTaskStatusResponse): SetTaskStatusResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ProjectLifecycleTask Task = 1 [json_name = "Task"];*/ 1: + message.task = ProjectLifecycleTask.internalBinaryRead(reader, reader.uint32(), options, message.task); + 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: SetTaskStatusResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ProjectLifecycleTask Task = 1 [json_name = "Task"]; */ + if (message.task) + ProjectLifecycleTask.internalBinaryWrite(message.task, 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.SetTaskStatusResponse + */ +export const SetTaskStatusResponse = new SetTaskStatusResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class SetTaskNextRunAtRequest$Type extends MessageType { + constructor() { + super("api.SetTaskNextRunAtRequest", [ + { no: 1, name: "ProjectID", kind: "scalar", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }, + { no: 2, name: "Entity", kind: "enum", jsonName: "Entity", T: () => ["api.EntityType", EntityType, "ENTITY_TYPE_"], options: { "validate.rules": { enum: { definedOnly: true } } } }, + { no: 3, name: "TaskType", kind: "enum", jsonName: "TaskType", T: () => ["api.ProjectLifecycleTaskType", ProjectLifecycleTaskType], options: { "validate.rules": { enum: { definedOnly: true } } } }, + { no: 4, name: "NextRunAt", kind: "scalar", jsonName: "NextRunAt", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ProjectID", "Entity", "TaskType", "NextRunAt"] } } }); + } + create(value?: PartialMessage): SetTaskNextRunAtRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + message.projectID = ""; + message.entity = 0; + message.taskType = 0; + message.nextRunAt = ""; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SetTaskNextRunAtRequest): SetTaskNextRunAtRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* string ProjectID = 1 [json_name = "ProjectID"];*/ 1: + message.projectID = reader.string(); + break; + case /* api.EntityType Entity = 2 [json_name = "Entity"];*/ 2: + message.entity = reader.int32(); + break; + case /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"];*/ 3: + message.taskType = reader.int32(); + break; + case /* string NextRunAt = 4 [json_name = "NextRunAt"];*/ 4: + message.nextRunAt = 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: SetTaskNextRunAtRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* string ProjectID = 1 [json_name = "ProjectID"]; */ + if (message.projectID !== "") + writer.tag(1, WireType.LengthDelimited).string(message.projectID); + /* api.EntityType Entity = 2 [json_name = "Entity"]; */ + if (message.entity !== 0) + writer.tag(2, WireType.Varint).int32(message.entity); + /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; */ + if (message.taskType !== 0) + writer.tag(3, WireType.Varint).int32(message.taskType); + /* string NextRunAt = 4 [json_name = "NextRunAt"]; */ + if (message.nextRunAt !== "") + writer.tag(4, WireType.LengthDelimited).string(message.nextRunAt); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.SetTaskNextRunAtRequest + */ +export const SetTaskNextRunAtRequest = new SetTaskNextRunAtRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class SetTaskNextRunAtResponse$Type extends MessageType { + constructor() { + super("api.SetTaskNextRunAtResponse", [ + { no: 1, name: "Task", kind: "message", jsonName: "Task", T: () => ProjectLifecycleTask } + ]); + } + create(value?: PartialMessage): SetTaskNextRunAtResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SetTaskNextRunAtResponse): SetTaskNextRunAtResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ProjectLifecycleTask Task = 1 [json_name = "Task"];*/ 1: + message.task = ProjectLifecycleTask.internalBinaryRead(reader, reader.uint32(), options, message.task); + 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: SetTaskNextRunAtResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ProjectLifecycleTask Task = 1 [json_name = "Task"]; */ + if (message.task) + ProjectLifecycleTask.internalBinaryWrite(message.task, 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.SetTaskNextRunAtResponse + */ +export const SetTaskNextRunAtResponse = new SetTaskNextRunAtResponse$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class SetTaskExecutedAtRequest$Type extends MessageType { + constructor() { + super("api.SetTaskExecutedAtRequest", [ + { no: 1, name: "ProjectID", kind: "scalar", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }, + { no: 2, name: "Entity", kind: "enum", jsonName: "Entity", T: () => ["api.EntityType", EntityType, "ENTITY_TYPE_"], options: { "validate.rules": { enum: { definedOnly: true } } } }, + { no: 3, name: "TaskType", kind: "enum", jsonName: "TaskType", T: () => ["api.ProjectLifecycleTaskType", ProjectLifecycleTaskType], options: { "validate.rules": { enum: { definedOnly: true } } } }, + { no: 4, name: "ExecutedAt", kind: "scalar", jsonName: "ExecutedAt", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } } + ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ProjectID", "Entity", "TaskType", "ExecutedAt"] } } }); + } + create(value?: PartialMessage): SetTaskExecutedAtRequest { + const message = globalThis.Object.create((this.messagePrototype!)); + message.projectID = ""; + message.entity = 0; + message.taskType = 0; + message.executedAt = ""; + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SetTaskExecutedAtRequest): SetTaskExecutedAtRequest { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* string ProjectID = 1 [json_name = "ProjectID"];*/ 1: + message.projectID = reader.string(); + break; + case /* api.EntityType Entity = 2 [json_name = "Entity"];*/ 2: + message.entity = reader.int32(); + break; + case /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"];*/ 3: + message.taskType = reader.int32(); + break; + case /* string ExecutedAt = 4 [json_name = "ExecutedAt"];*/ 4: + message.executedAt = 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: SetTaskExecutedAtRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* string ProjectID = 1 [json_name = "ProjectID"]; */ + if (message.projectID !== "") + writer.tag(1, WireType.LengthDelimited).string(message.projectID); + /* api.EntityType Entity = 2 [json_name = "Entity"]; */ + if (message.entity !== 0) + writer.tag(2, WireType.Varint).int32(message.entity); + /* api.ProjectLifecycleTaskType TaskType = 3 [json_name = "TaskType"]; */ + if (message.taskType !== 0) + writer.tag(3, WireType.Varint).int32(message.taskType); + /* string ExecutedAt = 4 [json_name = "ExecutedAt"]; */ + if (message.executedAt !== "") + writer.tag(4, WireType.LengthDelimited).string(message.executedAt); + let u = options.writeUnknownFields; + if (u !== false) + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); + return writer; + } +} +/** + * @generated MessageType for protobuf message api.SetTaskExecutedAtRequest + */ +export const SetTaskExecutedAtRequest = new SetTaskExecutedAtRequest$Type(); +// @generated message type with reflection information, may provide speed optimized methods +class SetTaskExecutedAtResponse$Type extends MessageType { + constructor() { + super("api.SetTaskExecutedAtResponse", [ + { no: 1, name: "Task", kind: "message", jsonName: "Task", T: () => ProjectLifecycleTask } + ]); + } + create(value?: PartialMessage): SetTaskExecutedAtResponse { + const message = globalThis.Object.create((this.messagePrototype!)); + if (value !== undefined) + reflectionMergePartial(this, message, value); + return message; + } + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: SetTaskExecutedAtResponse): SetTaskExecutedAtResponse { + let message = target ?? this.create(), end = reader.pos + length; + while (reader.pos < end) { + let [fieldNo, wireType] = reader.tag(); + switch (fieldNo) { + case /* api.ProjectLifecycleTask Task = 1 [json_name = "Task"];*/ 1: + message.task = ProjectLifecycleTask.internalBinaryRead(reader, reader.uint32(), options, message.task); + 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: SetTaskExecutedAtResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { + /* api.ProjectLifecycleTask Task = 1 [json_name = "Task"]; */ + if (message.task) + ProjectLifecycleTask.internalBinaryWrite(message.task, 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.SetTaskExecutedAtResponse + */ +export const SetTaskExecutedAtResponse = new SetTaskExecutedAtResponse$Type(); +/** + * @generated ServiceType for protobuf service api.ProjectLifecycleService + */ +export const ProjectLifecycleService = new ServiceType("api.ProjectLifecycleService", [ + { name: "SetTaskRule", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project Lifecycle"], description: "Set the rule that will be performed when running the given task on an entity of a project" }, "api.rscType": "Project", "api.roles": "", "google.api.method_visibility": { restriction: "SDK" } }, I: SetTaskRuleRequest, O: SetTaskRuleResponse }, + { name: "GetTask", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project Lifecycle"], description: "Get the rule that performs a task on an entity of a project" }, "api.rscType": "Project", "api.roles": "Platform.Project-Task", "google.api.method_visibility": { restriction: "SDK" } }, I: GetTaskRequest, O: GetTaskResponse }, + { name: "ListTasks", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project Lifecycle"], description: "List the project lifecycle tasks registered on a project" }, "api.rscType": "Project", "api.roles": "", "google.api.method_visibility": { restriction: "SDK" } }, I: ListTasksRequest, O: ListTasksResponse }, + { name: "SetTaskStatus", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project Lifecycle"], description: "Update the status of the rule performing a task on an entity of a project" }, "api.rscType": "Platform", "api.roles": "Platform.Project-Task", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: SetTaskStatusRequest, O: SetTaskStatusResponse }, + { name: "SetTaskExecutedAt", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project Lifecycle"], description: "Set the execution time of the rule performing a task on an entity of a project" }, "api.rscType": "Platform", "api.roles": "Platform.Project-Task", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: SetTaskExecutedAtRequest, O: SetTaskExecutedAtResponse }, + { name: "SetTaskNextRunAt", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project Lifecycle"], description: "Set the next run time of the rule performing a task on an entity of a project" }, "api.rscType": "Platform", "api.roles": "Platform.Project-Task", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: SetTaskNextRunAtRequest, O: SetTaskNextRunAtResponse } +], { "api.k8sService": "project-lifecycle-server" });