feat: add several fields to manage state of database encryption update (

#1904) * feat: add custom datetime format for Cloud Storage subscriptions PiperOrigin-RevId: 619178723 Source-Link: googleapis/googleapis@811a857 Source-Link: googleapis/googleapis-gen@768fb44 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNzY4ZmI0NGQ0ZGFhZWE5NDZhMjkxZjY3OTVhNTBhZjI2YTUxNTQ4OCJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add several fields to manage state of database encryption update PiperOrigin-RevId: 619289281 Source-Link: googleapis/googleapis@3a7c334 Source-Link: googleapis/googleapis-gen@6a8c733 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNmE4YzczMzA2MmQ4MzNkMTFjNTI0NWVkYTUwZjUxMDhlMGU1NTMyNCJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
googleapis · Apr 2, 2024 · aba9aee · aba9aee
1 parent 9589e9f
commit aba9aee
Show file tree

Hide file tree

Showing 10 changed files with 174 additions and 16 deletions.
diff --git a/protos/google/pubsub/v1/pubsub.proto b/protos/google/pubsub/v1/pubsub.proto
@@ -203,7 +203,7 @@ message IngestionDataSourceSettings {
  KINESIS_PERMISSION_DENIED = 2;
 
  // Permission denied encountered while publishing to the topic. This can
- // happen due to Pub/Sub SA has not been granted the [appropriate publish
+ // happen if the Pub/Sub SA has not been granted the [appropriate publish
  // permissions](https://cloud.google.com/pubsub/docs/access-control#pubsub.publisher)
  PUBLISH_PERMISSION_DENIED = 3;
 
@@ -1197,6 +1197,11 @@ message CloudStorageConfig {
  // Must not end in "/".
  string filename_suffix = 3 [(google.api.field_behavior) = OPTIONAL];
 
+ // Optional. User-provided format string specifying how to represent datetimes
+ // in Cloud Storage filenames. See the [datetime format
+ // guidance](https://cloud.google.com/pubsub/docs/create-cloudstorage-subscription#file_names).
+ string filename_datetime_format = 10 [(google.api.field_behavior) = OPTIONAL];
+
  // Defaults to text format.
  oneof output_format {
  // Optional. If set, message data will be written to Cloud Storage in text

diff --git a/protos/protos.d.ts b/protos/protos.d.ts
diff --git a/protos/protos.js b/protos/protos.js
diff --git a/protos/protos.json b/protos/protos.json
diff --git a/src/v1/publisher_client.ts b/src/v1/publisher_client.ts
@@ -123,8 +123,15 @@ export class PublisherClient {
  'Please set either universe_domain or universeDomain, but not both.'
  );
  }
+ const universeDomainEnvVar =
+ typeof process === 'object' && typeof process.env === 'object'
+ ? process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN']
+ : undefined;
  this._universeDomain =
- opts?.universeDomain ?? opts?.universe_domain ?? 'googleapis.com';
+ opts?.universeDomain ??
+ opts?.universe_domain ??
+ universeDomainEnvVar ??
+ 'googleapis.com';
  this._servicePath = 'pubsub.' + this._universeDomain;
  const servicePath =
  opts?.servicePath || opts?.apiEndpoint || this._servicePath;
@@ -177,7 +184,7 @@ export class PublisherClient {
 
  // Determine the client header string.
  const clientHeader = [`gax/${this._gaxModule.version}`, `gapic/${version}`];
- if (typeof process !== 'undefined' && 'versions' in process) {
+ if (typeof process === 'object' && 'versions' in process) {
  clientHeader.push(`gl-node/${process.versions.node}`);
  } else {
  clientHeader.push(`gl-web/${this._gaxModule.version}`);
@@ -350,7 +357,7 @@ export class PublisherClient {
  */
  static get servicePath() {
  if (
- typeof process !== undefined &&
+ typeof process === 'object' &&
  typeof process.emitWarning === 'function'
  ) {
  process.emitWarning(
@@ -368,7 +375,7 @@ export class PublisherClient {
  */
  static get apiEndpoint() {
  if (
- typeof process !== undefined &&
+ typeof process === 'object' &&
  typeof process.emitWarning === 'function'
  ) {
  process.emitWarning(

diff --git a/src/v1/schema_service_client.ts b/src/v1/schema_service_client.ts
@@ -122,8 +122,15 @@ export class SchemaServiceClient {
  'Please set either universe_domain or universeDomain, but not both.'
  );
  }
+ const universeDomainEnvVar =
+ typeof process === 'object' && typeof process.env === 'object'
+ ? process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN']
+ : undefined;
  this._universeDomain =
- opts?.universeDomain ?? opts?.universe_domain ?? 'googleapis.com';
+ opts?.universeDomain ??
+ opts?.universe_domain ??
+ universeDomainEnvVar ??
+ 'googleapis.com';
  this._servicePath = 'pubsub.' + this._universeDomain;
  const servicePath =
  opts?.servicePath || opts?.apiEndpoint || this._servicePath;
@@ -176,7 +183,7 @@ export class SchemaServiceClient {
 
  // Determine the client header string.
  const clientHeader = [`gax/${this._gaxModule.version}`, `gapic/${version}`];
- if (typeof process !== 'undefined' && 'versions' in process) {
+ if (typeof process === 'object' && 'versions' in process) {
  clientHeader.push(`gl-node/${process.versions.node}`);
  } else {
  clientHeader.push(`gl-web/${this._gaxModule.version}`);
@@ -326,7 +333,7 @@ export class SchemaServiceClient {
  */
  static get servicePath() {
  if (
- typeof process !== undefined &&
+ typeof process === 'object' &&
  typeof process.emitWarning === 'function'
  ) {
  process.emitWarning(
@@ -344,7 +351,7 @@ export class SchemaServiceClient {
  */
  static get apiEndpoint() {
  if (
- typeof process !== undefined &&
+ typeof process === 'object' &&
  typeof process.emitWarning === 'function'
  ) {
  process.emitWarning(

diff --git a/src/v1/subscriber_client.ts b/src/v1/subscriber_client.ts
@@ -124,8 +124,15 @@ export class SubscriberClient {
  'Please set either universe_domain or universeDomain, but not both.'
  );
  }
+ const universeDomainEnvVar =
+ typeof process === 'object' && typeof process.env === 'object'
+ ? process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN']
+ : undefined;
  this._universeDomain =
- opts?.universeDomain ?? opts?.universe_domain ?? 'googleapis.com';
+ opts?.universeDomain ??
+ opts?.universe_domain ??
+ universeDomainEnvVar ??
+ 'googleapis.com';
  this._servicePath = 'pubsub.' + this._universeDomain;
  const servicePath =
  opts?.servicePath || opts?.apiEndpoint || this._servicePath;
@@ -178,7 +185,7 @@ export class SubscriberClient {
 
  // Determine the client header string.
  const clientHeader = [`gax/${this._gaxModule.version}`, `gapic/${version}`];
- if (typeof process !== 'undefined' && 'versions' in process) {
+ if (typeof process === 'object' && 'versions' in process) {
  clientHeader.push(`gl-node/${process.versions.node}`);
  } else {
  clientHeader.push(`gl-web/${this._gaxModule.version}`);
@@ -359,7 +366,7 @@ export class SubscriberClient {
  */
  static get servicePath() {
  if (
- typeof process !== undefined &&
+ typeof process === 'object' &&
  typeof process.emitWarning === 'function'
  ) {
  process.emitWarning(
@@ -377,7 +384,7 @@ export class SubscriberClient {
  */
  static get apiEndpoint() {
  if (
- typeof process !== undefined &&
+ typeof process === 'object' &&
  typeof process.emitWarning === 'function'
  ) {
  process.emitWarning(

diff --git a/test/gapic_publisher_v1.ts b/test/gapic_publisher_v1.ts
@@ -142,7 +142,7 @@ describe('v1.PublisherClient', () => {
  });
 
  if (
- typeof process !== 'undefined' &&
+ typeof process === 'object' &&
  typeof process.emitWarning === 'function'
  ) {
  it('throws DeprecationWarning if static servicePath is used', () => {
@@ -176,6 +176,38 @@ describe('v1.PublisherClient', () => {
  const servicePath = client.apiEndpoint;
  assert.strictEqual(servicePath, 'pubsub.example.com');
  });
+
+ if (typeof process === 'object' && 'env' in process) {
+ describe('GOOGLE_CLOUD_UNIVERSE_DOMAIN environment variable', () => {
+ it('sets apiEndpoint from environment variable', () => {
+ const saved = process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'];
+ process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'] = 'example.com';
+ const client = new publisherModule.v1.PublisherClient();
+ const servicePath = client.apiEndpoint;
+ assert.strictEqual(servicePath, 'pubsub.example.com');
+ if (saved) {
+ process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'] = saved;
+ } else {
+ delete process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'];
+ }
+ });
+
+ it('value configured in code has priority over environment variable', () => {
+ const saved = process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'];
+ process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'] = 'example.com';
+ const client = new publisherModule.v1.PublisherClient({
+ universeDomain: 'configured.example.com',
+ });
+ const servicePath = client.apiEndpoint;
+ assert.strictEqual(servicePath, 'pubsub.configured.example.com');
+ if (saved) {
+ process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'] = saved;
+ } else {
+ delete process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'];
+ }
+ });
+ });
+ }
  it('does not allow setting both universeDomain and universe_domain', () => {
  assert.throws(() => {
  new publisherModule.v1.PublisherClient({

diff --git a/test/gapic_schema_service_v1.ts b/test/gapic_schema_service_v1.ts
@@ -142,7 +142,7 @@ describe('v1.SchemaServiceClient', () => {
  });
 
  if (
- typeof process !== 'undefined' &&
+ typeof process === 'object' &&
  typeof process.emitWarning === 'function'
  ) {
  it('throws DeprecationWarning if static servicePath is used', () => {
@@ -178,6 +178,38 @@ describe('v1.SchemaServiceClient', () => {
  const servicePath = client.apiEndpoint;
  assert.strictEqual(servicePath, 'pubsub.example.com');
  });
+
+ if (typeof process === 'object' && 'env' in process) {
+ describe('GOOGLE_CLOUD_UNIVERSE_DOMAIN environment variable', () => {
+ it('sets apiEndpoint from environment variable', () => {
+ const saved = process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'];
+ process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'] = 'example.com';
+ const client = new schemaserviceModule.v1.SchemaServiceClient();
+ const servicePath = client.apiEndpoint;
+ assert.strictEqual(servicePath, 'pubsub.example.com');
+ if (saved) {
+ process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'] = saved;
+ } else {
+ delete process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'];
+ }
+ });
+
+ it('value configured in code has priority over environment variable', () => {
+ const saved = process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'];
+ process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'] = 'example.com';
+ const client = new schemaserviceModule.v1.SchemaServiceClient({
+ universeDomain: 'configured.example.com',
+ });
+ const servicePath = client.apiEndpoint;
+ assert.strictEqual(servicePath, 'pubsub.configured.example.com');
+ if (saved) {
+ process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'] = saved;
+ } else {
+ delete process.env['GOOGLE_CLOUD_UNIVERSE_DOMAIN'];
+ }
+ });
+ });
+ }
  it('does not allow setting both universeDomain and universe_domain', () => {
  assert.throws(() => {
  new schemaserviceModule.v1.SchemaServiceClient({