From a78c507f4df3257200580f47c4ae8004e2d5ad8a Mon Sep 17 00:00:00 2001 From: ci core model Date: Tue, 29 Jul 2025 08:44:59 +0000 Subject: [PATCH] Latest generation --- org.client.ts | 67 +------ org.ts | 512 ------------------------------------------------- package.json | 2 +- proj.client.ts | 15 +- proj.ts | 112 ----------- shared.ts | 43 ++--- 6 files changed, 14 insertions(+), 737 deletions(-) diff --git a/org.client.ts b/org.client.ts index 7d56c85a..b18f93b1 100644 --- a/org.client.ts +++ b/org.client.ts @@ -6,16 +6,6 @@ import type { ServiceInfo } from "@protobuf-ts/runtime-rpc"; import { OrganisationService } from "./org"; import type { DeleteOrganisationInDBResult } from "./org"; import type { DeleteOrganisationInDBRequest } from "./org"; -import type { CreateAllPulsarMissPartitionsResult } from "./org"; -import type { CreateAllPulsarMissPartitionsRequest } from "./org"; -import type { CreatePulsarMissPartitionsResult } from "./org"; -import type { CreatePulsarMissPartitionsRequest } from "./org"; -import type { DeletePulsarResult } from "./org"; -import type { DeletePulsarRequest } from "./org"; -import type { CreatePulsarSubscriptionsResult } from "./org"; -import type { CreatePulsarSubscriptionsRequest } from "./org"; -import type { CreatePulsarResult } from "./org"; -import type { CreatePulsarRequest } from "./org"; import type { DeprovisionGitOrgResult } from "./org"; import type { DeprovisionGitOrgRequest } from "./org"; import type { ProvisionGitOrgResult } from "./org"; @@ -143,26 +133,6 @@ export interface IOrganisationServiceClient { * @generated from protobuf rpc: DeprovisionGitOrg */ deprovisionGitOrg(input: DeprovisionGitOrgRequest, options?: RpcOptions): UnaryCall; - /** - * @generated from protobuf rpc: CreatePulsar - */ - createPulsar(input: CreatePulsarRequest, options?: RpcOptions): UnaryCall; - /** - * @generated from protobuf rpc: CreatePulsarSubscriptions - */ - createPulsarSubscriptions(input: CreatePulsarSubscriptionsRequest, options?: RpcOptions): UnaryCall; - /** - * @generated from protobuf rpc: DeletePulsar - */ - deletePulsar(input: DeletePulsarRequest, options?: RpcOptions): UnaryCall; - /** - * @generated from protobuf rpc: CreatePulsarMissPartitions - */ - createPulsarMissPartitions(input: CreatePulsarMissPartitionsRequest, options?: RpcOptions): UnaryCall; - /** - * @generated from protobuf rpc: CreateAllPulsarMissPartitions - */ - createAllPulsarMissPartitions(input: CreateAllPulsarMissPartitionsRequest, options?: RpcOptions): UnaryCall; /** * @generated from protobuf rpc: DeleteOrganisationInDB */ @@ -317,46 +287,11 @@ export class OrganisationServiceClient implements IOrganisationServiceClient, Se const method = this.methods[19], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } - /** - * @generated from protobuf rpc: CreatePulsar - */ - createPulsar(input: CreatePulsarRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[20], opt = this._transport.mergeOptions(options); - return stackIntercept("unary", this._transport, method, opt, input); - } - /** - * @generated from protobuf rpc: CreatePulsarSubscriptions - */ - createPulsarSubscriptions(input: CreatePulsarSubscriptionsRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[21], opt = this._transport.mergeOptions(options); - return stackIntercept("unary", this._transport, method, opt, input); - } - /** - * @generated from protobuf rpc: DeletePulsar - */ - deletePulsar(input: DeletePulsarRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[22], opt = this._transport.mergeOptions(options); - return stackIntercept("unary", this._transport, method, opt, input); - } - /** - * @generated from protobuf rpc: CreatePulsarMissPartitions - */ - createPulsarMissPartitions(input: CreatePulsarMissPartitionsRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[23], opt = this._transport.mergeOptions(options); - return stackIntercept("unary", this._transport, method, opt, input); - } - /** - * @generated from protobuf rpc: CreateAllPulsarMissPartitions - */ - createAllPulsarMissPartitions(input: CreateAllPulsarMissPartitionsRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[24], opt = this._transport.mergeOptions(options); - return stackIntercept("unary", this._transport, method, opt, input); - } /** * @generated from protobuf rpc: DeleteOrganisationInDB */ deleteOrganisationInDB(input: DeleteOrganisationInDBRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[25], opt = this._transport.mergeOptions(options); + const method = this.methods[20], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } } diff --git a/org.ts b/org.ts index 50966c2c..3fb70fbf 100644 --- a/org.ts +++ b/org.ts @@ -437,80 +437,6 @@ export interface DeprovisionGitOrgRequest { */ export interface DeprovisionGitOrgResult { } -/** - * @generated from protobuf message api.CreatePulsarRequest - */ -export interface CreatePulsarRequest { - /** - * @generated from protobuf field: string OrganisationID = 2 - */ - OrganisationID: string; - /** - * @generated from protobuf field: bool CreateSubscriptions = 3 - */ - CreateSubscriptions: boolean; -} -/** - * @generated from protobuf message api.CreatePulsarSubscriptionsRequest - */ -export interface CreatePulsarSubscriptionsRequest { - /** - * @generated from protobuf field: string OrganisationID = 2 - */ - OrganisationID: string; -} -/** - * @generated from protobuf message api.CreatePulsarMissPartitionsRequest - */ -export interface CreatePulsarMissPartitionsRequest { - /** - * @generated from protobuf field: string OrganisationID = 1 - */ - OrganisationID: string; -} -/** - * @generated from protobuf message api.CreatePulsarResult - */ -export interface CreatePulsarResult { - /** - * @generated from protobuf field: string ID = 1 - */ - ID: string; -} -/** - * @generated from protobuf message api.CreatePulsarSubscriptionsResult - */ -export interface CreatePulsarSubscriptionsResult { -} -/** - * @generated from protobuf message api.CreatePulsarMissPartitionsResult - */ -export interface CreatePulsarMissPartitionsResult { -} -/** - * @generated from protobuf message api.CreateAllPulsarMissPartitionsRequest - */ -export interface CreateAllPulsarMissPartitionsRequest { -} -/** - * @generated from protobuf message api.CreateAllPulsarMissPartitionsResult - */ -export interface CreateAllPulsarMissPartitionsResult { -} -/** - * @generated from protobuf message api.DeletePulsarRequest - */ -export interface DeletePulsarRequest { - /** - * @generated from protobuf field: string OrganisationID = 2 - */ - OrganisationID: string; -} -/** - * @generated from protobuf message api.DeletePulsarResult - */ -export interface DeletePulsarResult { -} /** * @generated from protobuf message api.DeleteOrganisationInDBRequest */ @@ -2556,439 +2482,6 @@ class DeprovisionGitOrgResult$Type extends MessageType */ export const DeprovisionGitOrgResult = new DeprovisionGitOrgResult$Type(); // @generated message type with reflection information, may provide speed optimized methods -class CreatePulsarRequest$Type extends MessageType { - constructor() { - super("api.CreatePulsarRequest", [ - { no: 2, name: "OrganisationID", kind: "scalar", localName: "OrganisationID", jsonName: "OrganisationID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }, - { no: 3, name: "CreateSubscriptions", kind: "scalar", localName: "CreateSubscriptions", jsonName: "CreateSubscriptions", T: 8 /*ScalarType.BOOL*/ } - ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["OrganisationId"] } } }); - } - create(value?: PartialMessage): CreatePulsarRequest { - const message = globalThis.Object.create((this.messagePrototype!)); - message.OrganisationID = ""; - message.CreateSubscriptions = false; - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreatePulsarRequest): CreatePulsarRequest { - let message = target ?? this.create(), end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* string OrganisationID */ 2: - message.OrganisationID = reader.string(); - break; - case /* bool CreateSubscriptions */ 3: - message.CreateSubscriptions = reader.bool(); - 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: CreatePulsarRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* string OrganisationID = 2; */ - if (message.OrganisationID !== "") - writer.tag(2, WireType.LengthDelimited).string(message.OrganisationID); - /* bool CreateSubscriptions = 3; */ - if (message.CreateSubscriptions !== false) - writer.tag(3, WireType.Varint).bool(message.CreateSubscriptions); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); - return writer; - } -} -/** - * @generated MessageType for protobuf message api.CreatePulsarRequest - */ -export const CreatePulsarRequest = new CreatePulsarRequest$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class CreatePulsarSubscriptionsRequest$Type extends MessageType { - constructor() { - super("api.CreatePulsarSubscriptionsRequest", [ - { no: 2, name: "OrganisationID", kind: "scalar", localName: "OrganisationID", jsonName: "OrganisationID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } } - ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["OrganisationId"] } } }); - } - create(value?: PartialMessage): CreatePulsarSubscriptionsRequest { - const message = globalThis.Object.create((this.messagePrototype!)); - message.OrganisationID = ""; - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreatePulsarSubscriptionsRequest): CreatePulsarSubscriptionsRequest { - let message = target ?? this.create(), end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* string OrganisationID */ 2: - message.OrganisationID = 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: CreatePulsarSubscriptionsRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* string OrganisationID = 2; */ - if (message.OrganisationID !== "") - writer.tag(2, WireType.LengthDelimited).string(message.OrganisationID); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); - return writer; - } -} -/** - * @generated MessageType for protobuf message api.CreatePulsarSubscriptionsRequest - */ -export const CreatePulsarSubscriptionsRequest = new CreatePulsarSubscriptionsRequest$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class CreatePulsarMissPartitionsRequest$Type extends MessageType { - constructor() { - super("api.CreatePulsarMissPartitionsRequest", [ - { no: 1, name: "OrganisationID", kind: "scalar", localName: "OrganisationID", jsonName: "OrganisationID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } } - ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["OrganisationId"] } } }); - } - create(value?: PartialMessage): CreatePulsarMissPartitionsRequest { - const message = globalThis.Object.create((this.messagePrototype!)); - message.OrganisationID = ""; - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreatePulsarMissPartitionsRequest): CreatePulsarMissPartitionsRequest { - 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; - 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: CreatePulsarMissPartitionsRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* string OrganisationID = 1; */ - if (message.OrganisationID !== "") - writer.tag(1, WireType.LengthDelimited).string(message.OrganisationID); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); - return writer; - } -} -/** - * @generated MessageType for protobuf message api.CreatePulsarMissPartitionsRequest - */ -export const CreatePulsarMissPartitionsRequest = new CreatePulsarMissPartitionsRequest$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class CreatePulsarResult$Type extends MessageType { - constructor() { - super("api.CreatePulsarResult", [ - { no: 1, name: "ID", kind: "scalar", localName: "ID", jsonName: "ID", T: 9 /*ScalarType.STRING*/ } - ]); - } - create(value?: PartialMessage): CreatePulsarResult { - const message = globalThis.Object.create((this.messagePrototype!)); - message.ID = ""; - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreatePulsarResult): CreatePulsarResult { - let message = target ?? this.create(), end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* string ID */ 1: - message.ID = 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: CreatePulsarResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* string ID = 1; */ - if (message.ID !== "") - writer.tag(1, WireType.LengthDelimited).string(message.ID); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); - return writer; - } -} -/** - * @generated MessageType for protobuf message api.CreatePulsarResult - */ -export const CreatePulsarResult = new CreatePulsarResult$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class CreatePulsarSubscriptionsResult$Type extends MessageType { - constructor() { - super("api.CreatePulsarSubscriptionsResult", []); - } - create(value?: PartialMessage): CreatePulsarSubscriptionsResult { - const message = globalThis.Object.create((this.messagePrototype!)); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreatePulsarSubscriptionsResult): CreatePulsarSubscriptionsResult { - 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: CreatePulsarSubscriptionsResult, 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.CreatePulsarSubscriptionsResult - */ -export const CreatePulsarSubscriptionsResult = new CreatePulsarSubscriptionsResult$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class CreatePulsarMissPartitionsResult$Type extends MessageType { - constructor() { - super("api.CreatePulsarMissPartitionsResult", []); - } - create(value?: PartialMessage): CreatePulsarMissPartitionsResult { - const message = globalThis.Object.create((this.messagePrototype!)); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreatePulsarMissPartitionsResult): CreatePulsarMissPartitionsResult { - 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: CreatePulsarMissPartitionsResult, 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.CreatePulsarMissPartitionsResult - */ -export const CreatePulsarMissPartitionsResult = new CreatePulsarMissPartitionsResult$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class CreateAllPulsarMissPartitionsRequest$Type extends MessageType { - constructor() { - super("api.CreateAllPulsarMissPartitionsRequest", []); - } - create(value?: PartialMessage): CreateAllPulsarMissPartitionsRequest { - const message = globalThis.Object.create((this.messagePrototype!)); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreateAllPulsarMissPartitionsRequest): CreateAllPulsarMissPartitionsRequest { - 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: CreateAllPulsarMissPartitionsRequest, 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.CreateAllPulsarMissPartitionsRequest - */ -export const CreateAllPulsarMissPartitionsRequest = new CreateAllPulsarMissPartitionsRequest$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class CreateAllPulsarMissPartitionsResult$Type extends MessageType { - constructor() { - super("api.CreateAllPulsarMissPartitionsResult", []); - } - create(value?: PartialMessage): CreateAllPulsarMissPartitionsResult { - const message = globalThis.Object.create((this.messagePrototype!)); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreateAllPulsarMissPartitionsResult): CreateAllPulsarMissPartitionsResult { - 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: CreateAllPulsarMissPartitionsResult, 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.CreateAllPulsarMissPartitionsResult - */ -export const CreateAllPulsarMissPartitionsResult = new CreateAllPulsarMissPartitionsResult$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class DeletePulsarRequest$Type extends MessageType { - constructor() { - super("api.DeletePulsarRequest", [ - { no: 2, name: "OrganisationID", kind: "scalar", localName: "OrganisationID", jsonName: "OrganisationID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } } - ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["OrganisationId"] } } }); - } - create(value?: PartialMessage): DeletePulsarRequest { - const message = globalThis.Object.create((this.messagePrototype!)); - message.OrganisationID = ""; - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DeletePulsarRequest): DeletePulsarRequest { - let message = target ?? this.create(), end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* string OrganisationID */ 2: - message.OrganisationID = 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: DeletePulsarRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* string OrganisationID = 2; */ - if (message.OrganisationID !== "") - writer.tag(2, WireType.LengthDelimited).string(message.OrganisationID); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); - return writer; - } -} -/** - * @generated MessageType for protobuf message api.DeletePulsarRequest - */ -export const DeletePulsarRequest = new DeletePulsarRequest$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class DeletePulsarResult$Type extends MessageType { - constructor() { - super("api.DeletePulsarResult", []); - } - create(value?: PartialMessage): DeletePulsarResult { - const message = globalThis.Object.create((this.messagePrototype!)); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DeletePulsarResult): DeletePulsarResult { - 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: DeletePulsarResult, 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.DeletePulsarResult - */ -export const DeletePulsarResult = new DeletePulsarResult$Type(); -// @generated message type with reflection information, may provide speed optimized methods class DeleteOrganisationInDBRequest$Type extends MessageType { constructor() { super("api.DeleteOrganisationInDBRequest", [ @@ -3097,10 +2590,5 @@ export const OrganisationService = new ServiceType("api.OrganisationService", [ { name: "StopIndividualStreamingJob", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Streaming"], description: "Stop one streaming job for the organisation" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StopIndividualStreamingJobRequest, O: StopIndividualStreamingJobResult }, { name: "ProvisionGitOrg", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Organisation"], description: "Provision a git organisation " }, "api.rscType": "Platform", "api.roles": "Platform.Gitea", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: ProvisionGitOrgRequest, O: ProvisionGitOrgResult }, { name: "DeprovisionGitOrg", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Organisation"], description: "Deprovision a git organisation " }, "api.rscType": "Platform", "api.roles": "Platform.Gitea", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DeprovisionGitOrgRequest, O: DeprovisionGitOrgResult }, - { name: "CreatePulsar", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Organisation"], description: "Create Pulsar resources (topics and subscriptions) in connection with the organisation" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: CreatePulsarRequest, O: CreatePulsarResult }, - { name: "CreatePulsarSubscriptions", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Organisation"], description: "Create Pulsar subsciptions to the topics in connection with the organisation" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: CreatePulsarSubscriptionsRequest, O: CreatePulsarSubscriptionsResult }, - { name: "DeletePulsar", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Organisation"], description: "Delete Pulsar resources in connection with the organisation" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DeletePulsarRequest, O: DeletePulsarResult }, - { name: "CreatePulsarMissPartitions", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Organisation"], description: "Fix Pulsar miss topics partitions in connection with the organisation" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: CreatePulsarMissPartitionsRequest, O: CreatePulsarMissPartitionsResult }, - { name: "CreateAllPulsarMissPartitions", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Organisation"], description: "Fix Pulsar miss topics partitions for all organisations" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: CreateAllPulsarMissPartitionsRequest, O: CreateAllPulsarMissPartitionsResult }, { name: "DeleteOrganisationInDB", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Organisation"], description: "Delete the organisation in database" }, "api.rscType": "Platform", "api.roles": "Platform.Organisation-Deletion", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DeleteOrganisationInDBRequest, O: DeleteOrganisationInDBResult } ], { "api.k8sService": "organisation-server", "api.roleManager": true, "api.resourceManager": true }); diff --git a/package.json b/package.json index eaf8d89d..c99473fc 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@reflex-platform/npm-core-sdk", - "version": "1.11.0-SNAPSHOT-250729082710", + "version": "1.11.0-SNAPSHOT-250729084441", "description": "npm libs from core model proto files", "homepage": "", "main": "index.ts", diff --git a/proj.client.ts b/proj.client.ts index 628ebd1c..6c07ed48 100644 --- a/proj.client.ts +++ b/proj.client.ts @@ -6,8 +6,6 @@ import type { ServiceInfo } from "@protobuf-ts/runtime-rpc"; import { ProjectService } from "./proj"; import type { CleanDeletedProjectsResult } from "./proj"; import type { CleanDeletedProjectsRequest } from "./proj"; -import type { OptimizeClickhouseResult } from "./proj"; -import type { OptimizeClickhouseRequest } from "./proj"; import type { DeleteCassandraResult } from "./proj"; import type { DeleteCassandraRequest } from "./proj"; import type { DeleteProjectInDBResult } from "./proj"; @@ -103,10 +101,6 @@ export interface IProjectServiceClient { * @generated from protobuf rpc: DeleteCassandra */ deleteCassandra(input: DeleteCassandraRequest, options?: RpcOptions): UnaryCall; - /** - * @generated from protobuf rpc: OptimizeClickhouse - */ - optimizeClickhouse(input: OptimizeClickhouseRequest, options?: RpcOptions): UnaryCall; /** * @generated from protobuf rpc: CleanDeletedProjects */ @@ -226,18 +220,11 @@ export class ProjectServiceClient implements IProjectServiceClient, ServiceInfo const method = this.methods[14], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } - /** - * @generated from protobuf rpc: OptimizeClickhouse - */ - optimizeClickhouse(input: OptimizeClickhouseRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[15], opt = this._transport.mergeOptions(options); - return stackIntercept("unary", this._transport, method, opt, input); - } /** * @generated from protobuf rpc: CleanDeletedProjects */ cleanDeletedProjects(input: CleanDeletedProjectsRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[16], opt = this._transport.mergeOptions(options); + const method = this.methods[15], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } } diff --git a/proj.ts b/proj.ts index 6e858224..a2dda984 100644 --- a/proj.ts +++ b/proj.ts @@ -264,24 +264,6 @@ export interface CreateClickhouseResult { */ ID: string; } -/** - * @generated from protobuf message api.OptimizeClickhouseRequest - */ -export interface OptimizeClickhouseRequest { - /** - * @generated from protobuf field: string ProjectID = 1 - */ - ProjectID: string; - /** - * @generated from protobuf field: bool Final = 2 - */ - Final: boolean; -} -/** - * @generated from protobuf message api.OptimizeClickhouseResult - */ -export interface OptimizeClickhouseResult { -} /** * @generated from protobuf message api.DeleteCassandraRequest */ @@ -1488,99 +1470,6 @@ class CreateClickhouseResult$Type extends MessageType { */ export const CreateClickhouseResult = new CreateClickhouseResult$Type(); // @generated message type with reflection information, may provide speed optimized methods -class OptimizeClickhouseRequest$Type extends MessageType { - constructor() { - super("api.OptimizeClickhouseRequest", [ - { no: 1, name: "ProjectID", kind: "scalar", localName: "ProjectID", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }, - { no: 2, name: "Final", kind: "scalar", localName: "Final", jsonName: "Final", T: 8 /*ScalarType.BOOL*/ } - ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ProjectID"] } } }); - } - create(value?: PartialMessage): OptimizeClickhouseRequest { - const message = globalThis.Object.create((this.messagePrototype!)); - message.ProjectID = ""; - message.Final = false; - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OptimizeClickhouseRequest): OptimizeClickhouseRequest { - let message = target ?? this.create(), end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* string ProjectID */ 1: - message.ProjectID = reader.string(); - break; - case /* bool Final */ 2: - message.Final = reader.bool(); - 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: OptimizeClickhouseRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* string ProjectID = 1; */ - if (message.ProjectID !== "") - writer.tag(1, WireType.LengthDelimited).string(message.ProjectID); - /* bool Final = 2; */ - if (message.Final !== false) - writer.tag(2, WireType.Varint).bool(message.Final); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); - return writer; - } -} -/** - * @generated MessageType for protobuf message api.OptimizeClickhouseRequest - */ -export const OptimizeClickhouseRequest = new OptimizeClickhouseRequest$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class OptimizeClickhouseResult$Type extends MessageType { - constructor() { - super("api.OptimizeClickhouseResult", []); - } - create(value?: PartialMessage): OptimizeClickhouseResult { - const message = globalThis.Object.create((this.messagePrototype!)); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: OptimizeClickhouseResult): OptimizeClickhouseResult { - 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: OptimizeClickhouseResult, 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.OptimizeClickhouseResult - */ -export const OptimizeClickhouseResult = new OptimizeClickhouseResult$Type(); -// @generated message type with reflection information, may provide speed optimized methods class DeleteCassandraRequest$Type extends MessageType { constructor() { super("api.DeleteCassandraRequest", [ @@ -2436,6 +2325,5 @@ export const ProjectService = new ServiceType("api.ProjectService", [ { name: "GetMyContext", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "List all user accessible projects. For non-SA users, it is advised to use GetMyUIContext instead." }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "SDK" } }, I: GetMyContextRequest, O: GetMyContextResult }, { name: "DeleteProjectInDB", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Delete the project in database" }, "api.rscType": "Platform", "api.roles": "Platform.Project-Deletion", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DeleteProjectInDBRequest, O: DeleteProjectInDBResult }, { name: "DeleteCassandra", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Delete Cassandra resources in connection with the project" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DeleteCassandraRequest, O: DeleteCassandraResult }, - { name: "OptimizeClickhouse", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Initiate an unscheduled merge of data parts for Clickhouse tables in connection with the project" }, "api.rscType": "Platform", "api.roles": "Platform.Project-Admin", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: OptimizeClickhouseRequest, O: OptimizeClickhouseResult }, { name: "CleanDeletedProjects", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Clear deleted projects in database" }, "api.rscType": "Platform", "api.roles": "Platform.Project", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: CleanDeletedProjectsRequest, O: CleanDeletedProjectsResult } ], { "api.k8sService": "organisation-server", "api.roleManager": true, "api.resourceManager": true }); diff --git a/shared.ts b/shared.ts index c96c8599..c736ab91 100644 --- a/shared.ts +++ b/shared.ts @@ -2181,26 +2181,16 @@ export enum WorkflowTypeEnum { */ EXTRACT_DATA = 6, /** - * @generated from protobuf enum value: STOP_FLINK = 7; - */ - STOP_FLINK = 7, - /** - * @generated from protobuf enum value: START_FLINK = 8; - */ - START_FLINK = 8, - /** - * @generated from protobuf enum value: STOP_IDLE_FLINK = 9; - */ - STOP_IDLE_FLINK = 9, - /** + * STOP_FLINK = 7; deprecated + * START_FLINK = 8; deprecated + * STOP_IDLE_FLINK = 9; deprecated + * * @generated from protobuf enum value: OPTIMIZE_CLICKHOUSE = 10; */ OPTIMIZE_CLICKHOUSE = 10, /** - * @generated from protobuf enum value: WAKEUP_FLINK = 11; - */ - WAKEUP_FLINK = 11, - /** + * WAKEUP_FLINK = 11; deprecated + * * @generated from protobuf enum value: CREATE_ORGANISATION = 12; */ CREATE_ORGANISATION = 12, @@ -2209,22 +2199,11 @@ export enum WorkflowTypeEnum { */ DELETE_ORGANISATION = 13, /** - * @generated from protobuf enum value: PROVISION_PULSAR_DOMAIN = 14; - */ - PROVISION_PULSAR_DOMAIN = 14, - /** - * @generated from protobuf enum value: DEPROVISION_PULSAR_DOMAIN = 15; - */ - DEPROVISION_PULSAR_DOMAIN = 15, - /** - * @generated from protobuf enum value: PROVISION_PULSAR_ORGANISATION = 16; - */ - PROVISION_PULSAR_ORGANISATION = 16, - /** - * @generated from protobuf enum value: DEPROVISION_PULSAR_ORGANISATION = 17; - */ - DEPROVISION_PULSAR_ORGANISATION = 17, - /** + * PROVISION_PULSAR_DOMAIN = 14; deprecated + * DEPROVISION_PULSAR_DOMAIN = 15; deprecated + * PROVISION_PULSAR_ORGANISATION = 16; deprecated + * DEPROVISION_PULSAR_ORGANISATION = 17; deprecated + * * @generated from protobuf enum value: RECOVER_DATA = 18; */ RECOVER_DATA = 18,