Skip to content

Commit

Permalink
fix: better support for fallback mode (#192)
Browse files Browse the repository at this point in the history
- [ ] Regenerate this pull request now.

PiperOrigin-RevId: 468790263

Source-Link: googleapis/googleapis@873ab45

Source-Link: googleapis/googleapis-gen@cb6f37a
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiY2I2ZjM3YWVmZjJhMzQ3MmU0MGE3YmJhY2U4YzY3ZDc1ZTI0YmVlNSJ9
  • Loading branch information
gcf-owl-bot[bot] authored Aug 23, 2022
1 parent bca7a13 commit 5084f02
Show file tree
Hide file tree
Showing 11 changed files with 119 additions and 93 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
"segments": [
{
"start": 25,
"end": 56,
"end": 59,
"type": "FULL"
}
],
Expand Down Expand Up @@ -66,7 +66,7 @@
"segments": [
{
"start": 25,
"end": 71,
"end": 74,
"type": "FULL"
}
],
Expand Down Expand Up @@ -122,7 +122,7 @@
"segments": [
{
"start": 25,
"end": 51,
"end": 54,
"type": "FULL"
}
],
Expand Down Expand Up @@ -162,7 +162,7 @@
"segments": [
{
"start": 25,
"end": 56,
"end": 59,
"type": "FULL"
}
],
Expand Down Expand Up @@ -206,7 +206,7 @@
"segments": [
{
"start": 25,
"end": 64,
"end": 67,
"type": "FULL"
}
],
Expand Down Expand Up @@ -254,7 +254,7 @@
"segments": [
{
"start": 25,
"end": 72,
"end": 75,
"type": "FULL"
}
],
Expand Down Expand Up @@ -310,7 +310,7 @@
"segments": [
{
"start": 25,
"end": 52,
"end": 55,
"type": "FULL"
}
],
Expand Down Expand Up @@ -350,7 +350,7 @@
"segments": [
{
"start": 25,
"end": 56,
"end": 59,
"type": "FULL"
}
],
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,9 @@
function main(parent, job) {
// [START transcoder_v1_generated_TranscoderService_CreateJob_async]
/**
* This snippet has been automatically generated and should be regarded as a code template only.
* It will require modifications to work.
* It may require correct/in-range values for request initialization.
* TODO(developer): Uncomment these variables before running the sample.
*/
/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,9 @@
function main(parent, jobTemplate, jobTemplateId) {
// [START transcoder_v1_generated_TranscoderService_CreateJobTemplate_async]
/**
* This snippet has been automatically generated and should be regarded as a code template only.
* It will require modifications to work.
* It may require correct/in-range values for request initialization.
* TODO(developer): Uncomment these variables before running the sample.
*/
/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,9 @@
function main(name) {
// [START transcoder_v1_generated_TranscoderService_DeleteJob_async]
/**
* This snippet has been automatically generated and should be regarded as a code template only.
* It will require modifications to work.
* It may require correct/in-range values for request initialization.
* TODO(developer): Uncomment these variables before running the sample.
*/
/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,9 @@
function main(name) {
// [START transcoder_v1_generated_TranscoderService_DeleteJobTemplate_async]
/**
* This snippet has been automatically generated and should be regarded as a code template only.
* It will require modifications to work.
* It may require correct/in-range values for request initialization.
* TODO(developer): Uncomment these variables before running the sample.
*/
/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,9 @@
function main(name) {
// [START transcoder_v1_generated_TranscoderService_GetJob_async]
/**
* This snippet has been automatically generated and should be regarded as a code template only.
* It will require modifications to work.
* It may require correct/in-range values for request initialization.
* TODO(developer): Uncomment these variables before running the sample.
*/
/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,9 @@
function main(name) {
// [START transcoder_v1_generated_TranscoderService_GetJobTemplate_async]
/**
* This snippet has been automatically generated and should be regarded as a code template only.
* It will require modifications to work.
* It may require correct/in-range values for request initialization.
* TODO(developer): Uncomment these variables before running the sample.
*/
/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,9 @@
function main(parent) {
// [START transcoder_v1_generated_TranscoderService_ListJobTemplates_async]
/**
* This snippet has been automatically generated and should be regarded as a code template only.
* It will require modifications to work.
* It may require correct/in-range values for request initialization.
* TODO(developer): Uncomment these variables before running the sample.
*/
/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,9 @@
function main(parent) {
// [START transcoder_v1_generated_TranscoderService_ListJobs_async]
/**
* This snippet has been automatically generated and should be regarded as a code template only.
* It will require modifications to work.
* It may require correct/in-range values for request initialization.
* TODO(developer): Uncomment these variables before running the sample.
*/
/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@ import {
} from 'google-gax';

import {Transform} from 'stream';
import {RequestType} from 'google-gax/build/src/apitypes';
import * as protos from '../../protos/protos';
import jsonProtos = require('../../protos/protos.json');
/**
Expand Down Expand Up @@ -274,7 +273,8 @@ export class TranscoderServiceClient {
const apiCall = this._gaxModule.createApiCall(
callPromise,
this._defaults[methodName],
descriptor
descriptor,
this._opts.fallback
);

this.innerApiCalls[methodName] = apiCall;
Expand Down Expand Up @@ -1069,7 +1069,7 @@ export class TranscoderServiceClient {
const callSettings = defaultCallSettings.merge(options);
this.initialize();
return this.descriptors.page.listJobs.createStream(
this.innerApiCalls.listJobs as gax.GaxCall,
this.innerApiCalls.listJobs as GaxCall,
request,
callSettings
);
Expand Down Expand Up @@ -1124,7 +1124,7 @@ export class TranscoderServiceClient {
this.initialize();
return this.descriptors.page.listJobs.asyncIterate(
this.innerApiCalls['listJobs'] as GaxCall,
request as unknown as RequestType,
request as {},
callSettings
) as AsyncIterable<protos.google.cloud.video.transcoder.v1.IJob>;
}
Expand Down Expand Up @@ -1281,7 +1281,7 @@ export class TranscoderServiceClient {
const callSettings = defaultCallSettings.merge(options);
this.initialize();
return this.descriptors.page.listJobTemplates.createStream(
this.innerApiCalls.listJobTemplates as gax.GaxCall,
this.innerApiCalls.listJobTemplates as GaxCall,
request,
callSettings
);
Expand Down Expand Up @@ -1337,7 +1337,7 @@ export class TranscoderServiceClient {
this.initialize();
return this.descriptors.page.listJobTemplates.asyncIterate(
this.innerApiCalls['listJobTemplates'] as GaxCall,
request as unknown as RequestType,
request as {},
callSettings
) as AsyncIterable<protos.google.cloud.video.transcoder.v1.IJobTemplate>;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -113,101 +113,103 @@ function stubAsyncIterationCall<ResponseType>(
}

describe('v1.TranscoderServiceClient', () => {
it('has servicePath', () => {
const servicePath =
transcoderserviceModule.v1.TranscoderServiceClient.servicePath;
assert(servicePath);
});

it('has apiEndpoint', () => {
const apiEndpoint =
transcoderserviceModule.v1.TranscoderServiceClient.apiEndpoint;
assert(apiEndpoint);
});

it('has port', () => {
const port = transcoderserviceModule.v1.TranscoderServiceClient.port;
assert(port);
assert(typeof port === 'number');
});

it('should create a client with no option', () => {
const client = new transcoderserviceModule.v1.TranscoderServiceClient();
assert(client);
});
describe('Common methods', () => {
it('has servicePath', () => {
const servicePath =
transcoderserviceModule.v1.TranscoderServiceClient.servicePath;
assert(servicePath);
});

it('should create a client with gRPC fallback', () => {
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
fallback: true,
it('has apiEndpoint', () => {
const apiEndpoint =
transcoderserviceModule.v1.TranscoderServiceClient.apiEndpoint;
assert(apiEndpoint);
});
assert(client);
});

it('has initialize method and supports deferred initialization', async () => {
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
credentials: {client_email: 'bogus', private_key: 'bogus'},
projectId: 'bogus',
it('has port', () => {
const port = transcoderserviceModule.v1.TranscoderServiceClient.port;
assert(port);
assert(typeof port === 'number');
});
assert.strictEqual(client.transcoderServiceStub, undefined);
await client.initialize();
assert(client.transcoderServiceStub);
});

it('has close method for the initialized client', done => {
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
credentials: {client_email: 'bogus', private_key: 'bogus'},
projectId: 'bogus',
it('should create a client with no option', () => {
const client = new transcoderserviceModule.v1.TranscoderServiceClient();
assert(client);
});
client.initialize();
assert(client.transcoderServiceStub);
client.close().then(() => {
done();

it('should create a client with gRPC fallback', () => {
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
fallback: true,
});
assert(client);
});
});

it('has close method for the non-initialized client', done => {
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
credentials: {client_email: 'bogus', private_key: 'bogus'},
projectId: 'bogus',
it('has initialize method and supports deferred initialization', async () => {
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
credentials: {client_email: 'bogus', private_key: 'bogus'},
projectId: 'bogus',
});
assert.strictEqual(client.transcoderServiceStub, undefined);
await client.initialize();
assert(client.transcoderServiceStub);
});
assert.strictEqual(client.transcoderServiceStub, undefined);
client.close().then(() => {
done();

it('has close method for the initialized client', done => {
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
credentials: {client_email: 'bogus', private_key: 'bogus'},
projectId: 'bogus',
});
client.initialize();
assert(client.transcoderServiceStub);
client.close().then(() => {
done();
});
});
});

it('has getProjectId method', async () => {
const fakeProjectId = 'fake-project-id';
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
credentials: {client_email: 'bogus', private_key: 'bogus'},
projectId: 'bogus',
it('has close method for the non-initialized client', done => {
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
credentials: {client_email: 'bogus', private_key: 'bogus'},
projectId: 'bogus',
});
assert.strictEqual(client.transcoderServiceStub, undefined);
client.close().then(() => {
done();
});
});
client.auth.getProjectId = sinon.stub().resolves(fakeProjectId);
const result = await client.getProjectId();
assert.strictEqual(result, fakeProjectId);
assert((client.auth.getProjectId as SinonStub).calledWithExactly());
});

it('has getProjectId method with callback', async () => {
const fakeProjectId = 'fake-project-id';
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
credentials: {client_email: 'bogus', private_key: 'bogus'},
projectId: 'bogus',
it('has getProjectId method', async () => {
const fakeProjectId = 'fake-project-id';
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
credentials: {client_email: 'bogus', private_key: 'bogus'},
projectId: 'bogus',
});
client.auth.getProjectId = sinon.stub().resolves(fakeProjectId);
const result = await client.getProjectId();
assert.strictEqual(result, fakeProjectId);
assert((client.auth.getProjectId as SinonStub).calledWithExactly());
});
client.auth.getProjectId = sinon
.stub()
.callsArgWith(0, null, fakeProjectId);
const promise = new Promise((resolve, reject) => {
client.getProjectId((err?: Error | null, projectId?: string | null) => {
if (err) {
reject(err);
} else {
resolve(projectId);
}

it('has getProjectId method with callback', async () => {
const fakeProjectId = 'fake-project-id';
const client = new transcoderserviceModule.v1.TranscoderServiceClient({
credentials: {client_email: 'bogus', private_key: 'bogus'},
projectId: 'bogus',
});
client.auth.getProjectId = sinon
.stub()
.callsArgWith(0, null, fakeProjectId);
const promise = new Promise((resolve, reject) => {
client.getProjectId((err?: Error | null, projectId?: string | null) => {
if (err) {
reject(err);
} else {
resolve(projectId);
}
});
});
const result = await promise;
assert.strictEqual(result, fakeProjectId);
});
const result = await promise;
assert.strictEqual(result, fakeProjectId);
});

describe('createJob', () => {
Expand Down

0 comments on commit 5084f02

Please sign in to comment.