Skip to content

Commit 7bc54c1

Browse files
cq-botcq-bot
authored
fix: Generate JavaScript Code from plugin-pb (#42)
This PR was created by a scheduled workflow to regenerate the JavaScript code from `plugin-pb`.
1 parent fae7c51 commit 7bc54c1

File tree

2 files changed

+187
-0
lines changed

2 files changed

+187
-0
lines changed

‎protos/plugin/v3/plugin.proto‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,10 @@ service Plugin {
1212
rpc GetName(GetName.Request) returns (GetName.Response);
1313
// Get the current version of the plugin
1414
rpc GetVersion(GetVersion.Request) returns (GetVersion.Response);
15+
// Get plugin spec schema.
16+
// This will allow validating the input even before calling Init.
17+
// Should be called before Init.
18+
rpc GetSpecSchema(GetSpecSchema.Request) returns (GetSpecSchema.Response);
1519
// Configure the plugin with the given credentials and mode
1620
rpc Init(Init.Request) returns (Init.Response);
1721
// Get all tables the source plugin supports. Must be called after Init
@@ -41,6 +45,15 @@ message GetVersion {
4145
}
4246
}
4347

48+
message GetSpecSchema {
49+
message Request {}
50+
message Response {
51+
// Should be a valid JSON schema for the plugin spec.
52+
// See https://json-schema.org for more details.
53+
optional string json_schema = 1;
54+
}
55+
}
56+
4457
message Init {
4558
message Request {
4659
bytes spec = 1; // Internal plugin-specific spec

‎protos/plugin/v3/plugin.ts‎

Lines changed: 174 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -305,6 +305,167 @@ export namespace cloudquery.plugin.v3 {
305305
}
306306
}
307307
}
308+
export class GetSpecSchema extends pb_1.Message {
309+
#one_of_decls: number[][] = [];
310+
constructor(data?: any[] | {}) {
311+
super();
312+
pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls);
313+
if (!Array.isArray(data) && typeof data == "object") { }
314+
}
315+
static fromObject(data: {}): GetSpecSchema {
316+
const message = new GetSpecSchema({});
317+
return message;
318+
}
319+
toObject() {
320+
const data: {} = {};
321+
return data;
322+
}
323+
serialize(): Uint8Array;
324+
serialize(w: pb_1.BinaryWriter): void;
325+
serialize(w?: pb_1.BinaryWriter): Uint8Array | void {
326+
const writer = w || new pb_1.BinaryWriter();
327+
if (!w)
328+
return writer.getResultBuffer();
329+
}
330+
static deserialize(bytes: Uint8Array | pb_1.BinaryReader): GetSpecSchema {
331+
const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new GetSpecSchema();
332+
while (reader.nextField()) {
333+
if (reader.isEndGroup())
334+
break;
335+
switch (reader.getFieldNumber()) {
336+
default: reader.skipField();
337+
}
338+
}
339+
return message;
340+
}
341+
serializeBinary(): Uint8Array {
342+
return this.serialize();
343+
}
344+
static deserializeBinary(bytes: Uint8Array): GetSpecSchema {
345+
return GetSpecSchema.deserialize(bytes);
346+
}
347+
}
348+
export namespace GetSpecSchema {
349+
export class Request extends pb_1.Message {
350+
#one_of_decls: number[][] = [];
351+
constructor(data?: any[] | {}) {
352+
super();
353+
pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls);
354+
if (!Array.isArray(data) && typeof data == "object") { }
355+
}
356+
static fromObject(data: {}): Request {
357+
const message = new Request({});
358+
return message;
359+
}
360+
toObject() {
361+
const data: {} = {};
362+
return data;
363+
}
364+
serialize(): Uint8Array;
365+
serialize(w: pb_1.BinaryWriter): void;
366+
serialize(w?: pb_1.BinaryWriter): Uint8Array | void {
367+
const writer = w || new pb_1.BinaryWriter();
368+
if (!w)
369+
return writer.getResultBuffer();
370+
}
371+
static deserialize(bytes: Uint8Array | pb_1.BinaryReader): Request {
372+
const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new Request();
373+
while (reader.nextField()) {
374+
if (reader.isEndGroup())
375+
break;
376+
switch (reader.getFieldNumber()) {
377+
default: reader.skipField();
378+
}
379+
}
380+
return message;
381+
}
382+
serializeBinary(): Uint8Array {
383+
return this.serialize();
384+
}
385+
static deserializeBinary(bytes: Uint8Array): Request {
386+
return Request.deserialize(bytes);
387+
}
388+
}
389+
export class Response extends pb_1.Message {
390+
#one_of_decls: number[][] = [[1]];
391+
constructor(data?: any[] | ({} & (({
392+
json_schema?: string;
393+
})))) {
394+
super();
395+
pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls);
396+
if (!Array.isArray(data) && typeof data == "object") {
397+
if ("json_schema" in data && data.json_schema != undefined) {
398+
this.json_schema = data.json_schema;
399+
}
400+
}
401+
}
402+
get json_schema() {
403+
return pb_1.Message.getFieldWithDefault(this, 1, "") as string;
404+
}
405+
set json_schema(value: string) {
406+
pb_1.Message.setOneofField(this, 1, this.#one_of_decls[0], value);
407+
}
408+
get has_json_schema() {
409+
return pb_1.Message.getField(this, 1) != null;
410+
}
411+
get _json_schema() {
412+
const cases: {
413+
[index: number]: "none" | "json_schema";
414+
} = {
415+
0: "none",
416+
1: "json_schema"
417+
};
418+
return cases[pb_1.Message.computeOneofCase(this, [1])];
419+
}
420+
static fromObject(data: {
421+
json_schema?: string;
422+
}): Response {
423+
const message = new Response({});
424+
if (data.json_schema != null) {
425+
message.json_schema = data.json_schema;
426+
}
427+
return message;
428+
}
429+
toObject() {
430+
const data: {
431+
json_schema?: string;
432+
} = {};
433+
if (this.json_schema != null) {
434+
data.json_schema = this.json_schema;
435+
}
436+
return data;
437+
}
438+
serialize(): Uint8Array;
439+
serialize(w: pb_1.BinaryWriter): void;
440+
serialize(w?: pb_1.BinaryWriter): Uint8Array | void {
441+
const writer = w || new pb_1.BinaryWriter();
442+
if (this.has_json_schema)
443+
writer.writeString(1, this.json_schema);
444+
if (!w)
445+
return writer.getResultBuffer();
446+
}
447+
static deserialize(bytes: Uint8Array | pb_1.BinaryReader): Response {
448+
const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new Response();
449+
while (reader.nextField()) {
450+
if (reader.isEndGroup())
451+
break;
452+
switch (reader.getFieldNumber()) {
453+
case 1:
454+
message.json_schema = reader.readString();
455+
break;
456+
default: reader.skipField();
457+
}
458+
}
459+
return message;
460+
}
461+
serializeBinary(): Uint8Array {
462+
return this.serialize();
463+
}
464+
static deserializeBinary(bytes: Uint8Array): Response {
465+
return Response.deserialize(bytes);
466+
}
467+
}
468+
}
308469
export class Init extends pb_1.Message {
309470
#one_of_decls: number[][] = [];
310471
constructor(data?: any[] | {}) {
@@ -2696,6 +2857,15 @@ export namespace cloudquery.plugin.v3 {
26962857
responseSerialize: (message: GetVersion.Response) => Buffer.from(message.serialize()),
26972858
responseDeserialize: (bytes: Buffer) => GetVersion.Response.deserialize(new Uint8Array(bytes))
26982859
},
2860+
GetSpecSchema: {
2861+
path: "/cloudquery.plugin.v3.Plugin/GetSpecSchema",
2862+
requestStream: false,
2863+
responseStream: false,
2864+
requestSerialize: (message: GetSpecSchema.Request) => Buffer.from(message.serialize()),
2865+
requestDeserialize: (bytes: Buffer) => GetSpecSchema.Request.deserialize(new Uint8Array(bytes)),
2866+
responseSerialize: (message: GetSpecSchema.Response) => Buffer.from(message.serialize()),
2867+
responseDeserialize: (bytes: Buffer) => GetSpecSchema.Response.deserialize(new Uint8Array(bytes))
2868+
},
26992869
Init: {
27002870
path: "/cloudquery.plugin.v3.Plugin/Init",
27012871
requestStream: false,
@@ -2754,6 +2924,7 @@ export namespace cloudquery.plugin.v3 {
27542924
[method: string]: grpc_1.UntypedHandleCall;
27552925
abstract GetName(call: grpc_1.ServerUnaryCall<GetName.Request, GetName.Response>, callback: grpc_1.sendUnaryData<GetName.Response>): void;
27562926
abstract GetVersion(call: grpc_1.ServerUnaryCall<GetVersion.Request, GetVersion.Response>, callback: grpc_1.sendUnaryData<GetVersion.Response>): void;
2927+
abstract GetSpecSchema(call: grpc_1.ServerUnaryCall<GetSpecSchema.Request, GetSpecSchema.Response>, callback: grpc_1.sendUnaryData<GetSpecSchema.Response>): void;
27572928
abstract Init(call: grpc_1.ServerUnaryCall<Init.Request, Init.Response>, callback: grpc_1.sendUnaryData<Init.Response>): void;
27582929
abstract GetTables(call: grpc_1.ServerUnaryCall<GetTables.Request, GetTables.Response>, callback: grpc_1.sendUnaryData<GetTables.Response>): void;
27592930
abstract Sync(call: grpc_1.ServerWritableStream<Sync.Request, Sync.Response>): void;
@@ -2771,6 +2942,9 @@ export namespace cloudquery.plugin.v3 {
27712942
GetVersion: GrpcUnaryServiceInterface<GetVersion.Request, GetVersion.Response> = (message: GetVersion.Request, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback<GetVersion.Response>, options?: grpc_1.CallOptions | grpc_1.requestCallback<GetVersion.Response>, callback?: grpc_1.requestCallback<GetVersion.Response>): grpc_1.ClientUnaryCall => {
27722943
return super.GetVersion(message, metadata, options, callback);
27732944
};
2945+
GetSpecSchema: GrpcUnaryServiceInterface<GetSpecSchema.Request, GetSpecSchema.Response> = (message: GetSpecSchema.Request, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback<GetSpecSchema.Response>, options?: grpc_1.CallOptions | grpc_1.requestCallback<GetSpecSchema.Response>, callback?: grpc_1.requestCallback<GetSpecSchema.Response>): grpc_1.ClientUnaryCall => {
2946+
return super.GetSpecSchema(message, metadata, options, callback);
2947+
};
27742948
Init: GrpcUnaryServiceInterface<Init.Request, Init.Response> = (message: Init.Request, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback<Init.Response>, options?: grpc_1.CallOptions | grpc_1.requestCallback<Init.Response>, callback?: grpc_1.requestCallback<Init.Response>): grpc_1.ClientUnaryCall => {
27752949
return super.Init(message, metadata, options, callback);
27762950
};

0 commit comments

Comments
 (0)