Skip to content

Commit 3443de0

Browse files
cq-botcq-bot
authored
fix: Generate JavaScript Code from plugin-pb (#99)
This PR was created by a scheduled workflow to regenerate the JavaScript code from `plugin-pb`.
1 parent 57aa232 commit 3443de0

File tree

2 files changed

+134
-4
lines changed

2 files changed

+134
-4
lines changed

‎protos/plugin/v3/plugin.proto‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,11 @@ message Sync {
9595
repeated PredicatesGroup where_clause = 2;
9696
repeated TableRelation table_relations = 3;
9797
}
98+
message MessageError {
99+
string table_name = 1;
100+
string error = 2;
101+
}
102+
98103

99104
message BackendOptions {
100105
// table name to use for state backend
@@ -119,6 +124,7 @@ message Sync {
119124
Sync.MessageMigrateTable migrate_table = 1;
120125
Sync.MessageInsert insert = 2;
121126
Sync.MessageDeleteRecord delete_record = 3;
127+
Sync.MessageError error = 4;
122128
}
123129
}
124130
}

‎protos/plugin/v3/plugin.ts‎

Lines changed: 128 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1171,6 +1171,96 @@ export namespace cloudquery.plugin.v3 {
11711171
return MessageDeleteRecord.deserialize(bytes);
11721172
}
11731173
}
1174+
export class MessageError extends pb_1.Message {
1175+
#one_of_decls: number[][] = [];
1176+
constructor(data?: any[] | {
1177+
table_name?: string;
1178+
error?: string;
1179+
}) {
1180+
super();
1181+
pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls);
1182+
if (!Array.isArray(data) && typeof data == "object") {
1183+
if ("table_name" in data && data.table_name != undefined) {
1184+
this.table_name = data.table_name;
1185+
}
1186+
if ("error" in data && data.error != undefined) {
1187+
this.error = data.error;
1188+
}
1189+
}
1190+
}
1191+
get table_name() {
1192+
return pb_1.Message.getFieldWithDefault(this, 1, "") as string;
1193+
}
1194+
set table_name(value: string) {
1195+
pb_1.Message.setField(this, 1, value);
1196+
}
1197+
get error() {
1198+
return pb_1.Message.getFieldWithDefault(this, 2, "") as string;
1199+
}
1200+
set error(value: string) {
1201+
pb_1.Message.setField(this, 2, value);
1202+
}
1203+
static fromObject(data: {
1204+
table_name?: string;
1205+
error?: string;
1206+
}): MessageError {
1207+
const message = new MessageError({});
1208+
if (data.table_name != null) {
1209+
message.table_name = data.table_name;
1210+
}
1211+
if (data.error != null) {
1212+
message.error = data.error;
1213+
}
1214+
return message;
1215+
}
1216+
toObject() {
1217+
const data: {
1218+
table_name?: string;
1219+
error?: string;
1220+
} = {};
1221+
if (this.table_name != null) {
1222+
data.table_name = this.table_name;
1223+
}
1224+
if (this.error != null) {
1225+
data.error = this.error;
1226+
}
1227+
return data;
1228+
}
1229+
serialize(): Uint8Array;
1230+
serialize(w: pb_1.BinaryWriter): void;
1231+
serialize(w?: pb_1.BinaryWriter): Uint8Array | void {
1232+
const writer = w || new pb_1.BinaryWriter();
1233+
if (this.table_name.length)
1234+
writer.writeString(1, this.table_name);
1235+
if (this.error.length)
1236+
writer.writeString(2, this.error);
1237+
if (!w)
1238+
return writer.getResultBuffer();
1239+
}
1240+
static deserialize(bytes: Uint8Array | pb_1.BinaryReader): MessageError {
1241+
const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new MessageError();
1242+
while (reader.nextField()) {
1243+
if (reader.isEndGroup())
1244+
break;
1245+
switch (reader.getFieldNumber()) {
1246+
case 1:
1247+
message.table_name = reader.readString();
1248+
break;
1249+
case 2:
1250+
message.error = reader.readString();
1251+
break;
1252+
default: reader.skipField();
1253+
}
1254+
}
1255+
return message;
1256+
}
1257+
serializeBinary(): Uint8Array {
1258+
return this.serialize();
1259+
}
1260+
static deserializeBinary(bytes: Uint8Array): MessageError {
1261+
return MessageError.deserialize(bytes);
1262+
}
1263+
}
11741264
export class BackendOptions extends pb_1.Message {
11751265
#one_of_decls: number[][] = [];
11761266
constructor(data?: any[] | {
@@ -1552,19 +1642,27 @@ export namespace cloudquery.plugin.v3 {
15521642
}
15531643
}
15541644
export class Response extends pb_1.Message {
1555-
#one_of_decls: number[][] = [[1, 2, 3]];
1645+
#one_of_decls: number[][] = [[1, 2, 3, 4]];
15561646
constructor(data?: any[] | ({} & (({
15571647
migrate_table?: Sync.MessageMigrateTable;
15581648
insert?: never;
15591649
delete_record?: never;
1650+
error?: never;
15601651
} | {
15611652
migrate_table?: never;
15621653
insert?: Sync.MessageInsert;
15631654
delete_record?: never;
1655+
error?: never;
15641656
} | {
15651657
migrate_table?: never;
15661658
insert?: never;
15671659
delete_record?: Sync.MessageDeleteRecord;
1660+
error?: never;
1661+
} | {
1662+
migrate_table?: never;
1663+
insert?: never;
1664+
delete_record?: never;
1665+
error?: Sync.MessageError;
15681666
})))) {
15691667
super();
15701668
pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls);
@@ -1578,6 +1676,9 @@ export namespace cloudquery.plugin.v3 {
15781676
if ("delete_record" in data && data.delete_record != undefined) {
15791677
this.delete_record = data.delete_record;
15801678
}
1679+
if ("error" in data && data.error != undefined) {
1680+
this.error = data.error;
1681+
}
15811682
}
15821683
}
15831684
get migrate_table() {
@@ -1607,21 +1708,32 @@ export namespace cloudquery.plugin.v3 {
16071708
get has_delete_record() {
16081709
return pb_1.Message.getField(this, 3) != null;
16091710
}
1711+
get error() {
1712+
return pb_1.Message.getWrapperField(this, Sync.MessageError, 4) as Sync.MessageError;
1713+
}
1714+
set error(value: Sync.MessageError) {
1715+
pb_1.Message.setOneofWrapperField(this, 4, this.#one_of_decls[0], value);
1716+
}
1717+
get has_error() {
1718+
return pb_1.Message.getField(this, 4) != null;
1719+
}
16101720
get message() {
16111721
const cases: {
1612-
[index: number]: "none" | "migrate_table" | "insert" | "delete_record";
1722+
[index: number]: "none" | "migrate_table" | "insert" | "delete_record" | "error";
16131723
} = {
16141724
0: "none",
16151725
1: "migrate_table",
16161726
2: "insert",
1617-
3: "delete_record"
1727+
3: "delete_record",
1728+
4: "error"
16181729
};
1619-
return cases[pb_1.Message.computeOneofCase(this, [1, 2, 3])];
1730+
return cases[pb_1.Message.computeOneofCase(this, [1, 2, 3, 4])];
16201731
}
16211732
static fromObject(data: {
16221733
migrate_table?: ReturnType<typeof Sync.MessageMigrateTable.prototype.toObject>;
16231734
insert?: ReturnType<typeof Sync.MessageInsert.prototype.toObject>;
16241735
delete_record?: ReturnType<typeof Sync.MessageDeleteRecord.prototype.toObject>;
1736+
error?: ReturnType<typeof Sync.MessageError.prototype.toObject>;
16251737
}): Response {
16261738
const message = new Response({});
16271739
if (data.migrate_table != null) {
@@ -1633,13 +1745,17 @@ export namespace cloudquery.plugin.v3 {
16331745
if (data.delete_record != null) {
16341746
message.delete_record = Sync.MessageDeleteRecord.fromObject(data.delete_record);
16351747
}
1748+
if (data.error != null) {
1749+
message.error = Sync.MessageError.fromObject(data.error);
1750+
}
16361751
return message;
16371752
}
16381753
toObject() {
16391754
const data: {
16401755
migrate_table?: ReturnType<typeof Sync.MessageMigrateTable.prototype.toObject>;
16411756
insert?: ReturnType<typeof Sync.MessageInsert.prototype.toObject>;
16421757
delete_record?: ReturnType<typeof Sync.MessageDeleteRecord.prototype.toObject>;
1758+
error?: ReturnType<typeof Sync.MessageError.prototype.toObject>;
16431759
} = {};
16441760
if (this.migrate_table != null) {
16451761
data.migrate_table = this.migrate_table.toObject();
@@ -1650,6 +1766,9 @@ export namespace cloudquery.plugin.v3 {
16501766
if (this.delete_record != null) {
16511767
data.delete_record = this.delete_record.toObject();
16521768
}
1769+
if (this.error != null) {
1770+
data.error = this.error.toObject();
1771+
}
16531772
return data;
16541773
}
16551774
serialize(): Uint8Array;
@@ -1662,6 +1781,8 @@ export namespace cloudquery.plugin.v3 {
16621781
writer.writeMessage(2, this.insert, () => this.insert.serialize(writer));
16631782
if (this.has_delete_record)
16641783
writer.writeMessage(3, this.delete_record, () => this.delete_record.serialize(writer));
1784+
if (this.has_error)
1785+
writer.writeMessage(4, this.error, () => this.error.serialize(writer));
16651786
if (!w)
16661787
return writer.getResultBuffer();
16671788
}
@@ -1680,6 +1801,9 @@ export namespace cloudquery.plugin.v3 {
16801801
case 3:
16811802
reader.readMessage(message.delete_record, () => message.delete_record = Sync.MessageDeleteRecord.deserialize(reader));
16821803
break;
1804+
case 4:
1805+
reader.readMessage(message.error, () => message.error = Sync.MessageError.deserialize(reader));
1806+
break;
16831807
default: reader.skipField();
16841808
}
16851809
}

0 commit comments

Comments
 (0)