diff --git a/.release-please-manifest.json b/.release-please-manifest.json index a4c7ad2..d1b9552 100644 --- a/.release-please-manifest.json +++ b/.release-please-manifest.json @@ -1,3 +1,3 @@ { - ".": "0.0.35" + ".": "0.0.36" } diff --git a/CHANGELOG.md b/CHANGELOG.md index 449f4f6..9d2e822 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,14 @@ # Changelog +## [0.0.36](https://github.com/cloudquery/plugin-pb-javascript/compare/v0.0.35...v0.0.36) (2025-07-01) + + +### Bug Fixes + +* **deps:** Update dependency @grpc/grpc-js to v1.13.4 ([#103](https://github.com/cloudquery/plugin-pb-javascript/issues/103)) ([e3ff70e](https://github.com/cloudquery/plugin-pb-javascript/commit/e3ff70e8952e76abad9352f8efe0b4b9cf85789a)) +* **deps:** Update dependency @tsconfig/node16 to v16.1.4 ([#104](https://github.com/cloudquery/plugin-pb-javascript/issues/104)) ([579ce9f](https://github.com/cloudquery/plugin-pb-javascript/commit/579ce9fcf349a7858702943df54aef660a481546)) +* Generate JavaScript Code from `plugin-pb` ([#101](https://github.com/cloudquery/plugin-pb-javascript/issues/101)) ([8a6e8b7](https://github.com/cloudquery/plugin-pb-javascript/commit/8a6e8b7eb4fbe3ae20ba8869d51563f0ff37a777)) + ## [0.0.35](https://github.com/cloudquery/plugin-pb-javascript/compare/v0.0.34...v0.0.35) (2025-06-25) diff --git a/package-lock.json b/package-lock.json index 2dea3ac..4433f63 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "@cloudquery/plugin-pb-javascript", - "version": "0.0.35", + "version": "0.0.36", "lockfileVersion": 3, "requires": true, "packages": { "": { "name": "@cloudquery/plugin-pb-javascript", - "version": "0.0.35", + "version": "0.0.36", "license": "MPL-2.0", "dependencies": { "google-protobuf": "^3.21.2" @@ -24,9 +24,9 @@ } }, "node_modules/@grpc/grpc-js": { - "version": "1.13.3", - "resolved": "https://registry.npmjs.org/@grpc/grpc-js/-/grpc-js-1.13.3.tgz", - "integrity": "sha512-FTXHdOoPbZrBjlVLHuKbDZnsTxXv2BlHF57xw6LuThXacXvtkahEPED0CKMk6obZDf65Hv4k3z62eyPNpvinIg==", + "version": "1.13.4", + "resolved": "https://registry.npmjs.org/@grpc/grpc-js/-/grpc-js-1.13.4.tgz", + "integrity": "sha512-GsFaMXCkMqkKIvwCQjCrwH+GHbPKBjhwo/8ZuUkWHqbI73Kky9I+pQltrlT0+MWpedCoosda53lgjYfyEPgxBg==", "dev": true, "license": "Apache-2.0", "dependencies": { @@ -150,10 +150,11 @@ "dev": true }, "node_modules/@tsconfig/node16": { - "version": "16.1.3", - "resolved": "https://registry.npmjs.org/@tsconfig/node16/-/node16-16.1.3.tgz", - "integrity": "sha512-9nTOUBn+EMKO6rtSZJk+DcqsfgtlERGT9XPJ5PRj/HNENPCBY1yu/JEj5wT6GLtbCLBO2k46SeXDaY0pjMqypw==", - "dev": true + "version": "16.1.4", + "resolved": "https://registry.npmjs.org/@tsconfig/node16/-/node16-16.1.4.tgz", + "integrity": "sha512-tkWPDtk18K2qJK/DhU010f03iDlw+C8qjXvhwZ4KKpJQC4QFOG3r8tIf2q6aWD0mz9N7RcZcaD9SPlrVLKiDoQ==", + "dev": true, + "license": "MIT" }, "node_modules/@types/google-protobuf": { "version": "3.15.12", diff --git a/package.json b/package.json index 344a2cb..7a31156 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@cloudquery/plugin-pb-javascript", - "version": "0.0.35", + "version": "0.0.36", "files": [ "dist" ], diff --git a/protos/plugin/v3/plugin.proto b/protos/plugin/v3/plugin.proto index fd423aa..5822eef 100644 --- a/protos/plugin/v3/plugin.proto +++ b/protos/plugin/v3/plugin.proto @@ -118,6 +118,7 @@ message Sync { bool deterministic_cq_id = 4; BackendOptions backend = 5; optional Shard shard = 6; + bool withErrorMessages = 7; // If true, the plugin will send error messages in the response stream } message Response { oneof message { diff --git a/protos/plugin/v3/plugin.ts b/protos/plugin/v3/plugin.ts index 93ca71c..fd71507 100644 --- a/protos/plugin/v3/plugin.ts +++ b/protos/plugin/v3/plugin.ts @@ -1359,6 +1359,7 @@ export namespace cloudquery.plugin.v3 { skip_dependent_tables?: boolean; deterministic_cq_id?: boolean; backend?: Sync.BackendOptions; + withErrorMessages?: boolean; } & (({ shard?: Sync.Request.Shard; })))) { @@ -1383,6 +1384,9 @@ export namespace cloudquery.plugin.v3 { if ("shard" in data && data.shard != undefined) { this.shard = data.shard; } + if ("withErrorMessages" in data && data.withErrorMessages != undefined) { + this.withErrorMessages = data.withErrorMessages; + } } } get tables() { @@ -1427,6 +1431,12 @@ export namespace cloudquery.plugin.v3 { get has_shard() { return pb_1.Message.getField(this, 6) != null; } + get withErrorMessages() { + return pb_1.Message.getFieldWithDefault(this, 7, false) as boolean; + } + set withErrorMessages(value: boolean) { + pb_1.Message.setField(this, 7, value); + } get _shard() { const cases: { [index: number]: "none" | "shard"; @@ -1443,6 +1453,7 @@ export namespace cloudquery.plugin.v3 { deterministic_cq_id?: boolean; backend?: ReturnType; shard?: ReturnType; + withErrorMessages?: boolean; }): Request { const message = new Request({}); if (data.tables != null) { @@ -1463,6 +1474,9 @@ export namespace cloudquery.plugin.v3 { if (data.shard != null) { message.shard = Sync.Request.Shard.fromObject(data.shard); } + if (data.withErrorMessages != null) { + message.withErrorMessages = data.withErrorMessages; + } return message; } toObject() { @@ -1473,6 +1487,7 @@ export namespace cloudquery.plugin.v3 { deterministic_cq_id?: boolean; backend?: ReturnType; shard?: ReturnType; + withErrorMessages?: boolean; } = {}; if (this.tables != null) { data.tables = this.tables; @@ -1492,6 +1507,9 @@ export namespace cloudquery.plugin.v3 { if (this.shard != null) { data.shard = this.shard.toObject(); } + if (this.withErrorMessages != null) { + data.withErrorMessages = this.withErrorMessages; + } return data; } serialize(): Uint8Array; @@ -1510,6 +1528,8 @@ export namespace cloudquery.plugin.v3 { writer.writeMessage(5, this.backend, () => this.backend.serialize(writer)); if (this.has_shard) writer.writeMessage(6, this.shard, () => this.shard.serialize(writer)); + if (this.withErrorMessages != false) + writer.writeBool(7, this.withErrorMessages); if (!w) return writer.getResultBuffer(); } @@ -1537,6 +1557,9 @@ export namespace cloudquery.plugin.v3 { case 6: reader.readMessage(message.shard, () => message.shard = Sync.Request.Shard.deserialize(reader)); break; + case 7: + message.withErrorMessages = reader.readBool(); + break; default: reader.skipField(); } }