diff --git a/.release-please-manifest.json b/.release-please-manifest.json index a244a27..9740c6d 100644 --- a/.release-please-manifest.json +++ b/.release-please-manifest.json @@ -1,3 +1,3 @@ { - ".": "0.0.23" + ".": "0.0.24" } diff --git a/CHANGELOG.md b/CHANGELOG.md index 84a0208..e02da2a 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,12 @@ # Changelog +## [0.0.24](https://github.com/cloudquery/plugin-pb-javascript/compare/v0.0.23...v0.0.24) (2024-07-30) + + +### Bug Fixes + +* Generate JavaScript Code from `plugin-pb` ([#68](https://github.com/cloudquery/plugin-pb-javascript/issues/68)) ([fa30808](https://github.com/cloudquery/plugin-pb-javascript/commit/fa30808735c8e4c4713fe807f1e6c53a4d5905ab)) + ## [0.0.23](https://github.com/cloudquery/plugin-pb-javascript/compare/v0.0.22...v0.0.23) (2024-07-30) diff --git a/package-lock.json b/package-lock.json index 040764b..96f890c 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "@cloudquery/plugin-pb-javascript", - "version": "0.0.23", + "version": "0.0.24", "lockfileVersion": 3, "requires": true, "packages": { "": { "name": "@cloudquery/plugin-pb-javascript", - "version": "0.0.23", + "version": "0.0.24", "license": "MPL-2.0", "dependencies": { "google-protobuf": "^3.21.2" diff --git a/package.json b/package.json index ac660dc..330f90b 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@cloudquery/plugin-pb-javascript", - "version": "0.0.23", + "version": "0.0.24", "files": [ "dist" ], diff --git a/protos/plugin/v3/plugin.proto b/protos/plugin/v3/plugin.proto index 8cbddcf..3dd5189 100644 --- a/protos/plugin/v3/plugin.proto +++ b/protos/plugin/v3/plugin.proto @@ -30,7 +30,7 @@ service Plugin { // Transform resources. rpc Transform(stream Transform.Request) returns (stream Transform.Response); // Transform schemas. - rpc TransformSchema(stream TransformSchema.Request) returns (stream TransformSchema.Response); + rpc TransformSchema(TransformSchema.Request) returns (TransformSchema.Response); // Send signal to flush and close open connections rpc Close(Close.Request) returns (Close.Response); // Validate and test the connections used by the plugin diff --git a/protos/plugin/v3/plugin.ts b/protos/plugin/v3/plugin.ts index df0f70e..afd64d9 100644 --- a/protos/plugin/v3/plugin.ts +++ b/protos/plugin/v3/plugin.ts @@ -3519,8 +3519,8 @@ export namespace cloudquery.plugin.v3 { }, TransformSchema: { path: "/cloudquery.plugin.v3.Plugin/TransformSchema", - requestStream: true, - responseStream: true, + requestStream: false, + responseStream: false, requestSerialize: (message: TransformSchema.Request) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => TransformSchema.Request.deserialize(new Uint8Array(bytes)), responseSerialize: (message: TransformSchema.Response) => Buffer.from(message.serialize()), @@ -3555,7 +3555,7 @@ export namespace cloudquery.plugin.v3 { abstract Read(call: grpc_1.ServerWritableStream): void; abstract Write(call: grpc_1.ServerReadableStream, callback: grpc_1.sendUnaryData): void; abstract Transform(call: grpc_1.ServerDuplexStream): void; - abstract TransformSchema(call: grpc_1.ServerDuplexStream): void; + abstract TransformSchema(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract Close(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract TestConnection(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; } @@ -3590,8 +3590,8 @@ export namespace cloudquery.plugin.v3 { Transform: GrpcChunkServiceInterface = (metadata?: grpc_1.Metadata | grpc_1.CallOptions, options?: grpc_1.CallOptions): grpc_1.ClientDuplexStream => { return super.Transform(metadata, options); }; - TransformSchema: GrpcChunkServiceInterface = (metadata?: grpc_1.Metadata | grpc_1.CallOptions, options?: grpc_1.CallOptions): grpc_1.ClientDuplexStream => { - return super.TransformSchema(metadata, options); + TransformSchema: GrpcUnaryServiceInterface = (message: TransformSchema.Request, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { + return super.TransformSchema(message, metadata, options, callback); }; Close: GrpcUnaryServiceInterface = (message: Close.Request, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.Close(message, metadata, options, callback);