rayan/bruno
1
0
Fork 0
mirror of https://github.com/usebruno/bruno.git synced 2026-06-11 09:51:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

rm: adding metadata to credentials

Browse Source
This commit is contained in:
sanish-bruno
2025-11-10 12:51:53 +05:30
parent 044fcce49f
commit 2ef451c80b
1 changed files with 22 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
packages/bruno-requests/src/grpc/grpc-client.js
View File

@@ -174,6 +174,22 @@ class GrpcClient {
this.eventCallback = eventCallback;
}
/**
* Creates call options from metadata for gRPC calls
* @param {grpc.Metadata} metadata - metadata to be sent with calls
* @returns {Object} callOptions object with credentials if metadata is provided
*/
#createCallOptions(metadata) {
if (metadata && Object.keys(metadata.getMap()).length > 0) {
// Create CallCredentials from metadata generator
const callCredentials = CallCredentials.createFromMetadataGenerator((options, callback) => {
callback(null, metadata);
});
return { credentials: callCredentials };
}
return {};
}
/**
* Creates a reflection client that works for v1, v1alpha, or both.
*
@@ -181,20 +197,11 @@ class GrpcClient {
* @param {grpc.ChannelCredentials} credentials - defaults to insecure
* @param {grpc.Metadata} metadata - metadata to be sent with reflection calls (used for insecure connections where credentials can't include metadata)
* @param {grpc.ChannelOptions} options - channel options
* @returns {Promise<{ client: GrpcReflection, version: 'v1' | 'v1alpha' }>}
* @returns {Promise<{ client: GrpcReflection, services: string[], callOptions: Object }>}
*/
async #getReflectionClient(host, credentials = ChannelCredentials.createInsecure(), metadata = null, options = {}) {
const makeClient = (version) => new GrpcReflection(host, credentials, options, version);
// For insecure connections, we can't combine CallCredentials with insecure ChannelCredentials,
// but we CAN pass CallCredentials in CallOptions.credentials for individual calls
let callOptions = {};
if (metadata && Object.keys(metadata.getMap()).length > 0) {
// Create CallCredentials from metadata generator
const callCredentials = CallCredentials.createFromMetadataGenerator((options, callback) => {
callback(null, metadata);
});
callOptions = { credentials: callCredentials };
}
const callOptions = this.#createCallOptions(metadata);
let client;
let services;
@@ -202,14 +209,14 @@ class GrpcClient {
try {
client = makeClient('v1');
services = await client.listServices('*', callOptions);
return { client, services };
return { client, services, callOptions };
} catch (e) {
console.warn(`gRPC reflection v1 failed:`, e);
}
client = makeClient('v1alpha');
services = await client.listServices('*', callOptions);
return { client, services };
return { client, services, callOptions };
}
/**
@@ -620,19 +627,9 @@ class GrpcClient {
});
try {
const { client, services } = await this.#getReflectionClient(host, credentials, metadata, {});
const methods = [];
// For insecure connections, we can't combine CallCredentials with insecure ChannelCredentials,
// but we CAN pass CallCredentials in CallOptions.credentials for individual calls
let callOptions = {};
if (metadata && Object.keys(metadata.getMap()).length > 0) {
// Create CallCredentials from metadata generator
const callCredentials = CallCredentials.createFromMetadataGenerator((options, callback) => {
callback(null, metadata);
});
callOptions = { credentials: callCredentials };
}
const { client, services, callOptions } = await this.#getReflectionClient(host, credentials, metadata, {});
const methods = [];
for (const service of services) {
if (reflectionServices.includes(service)) {
continue;