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

#433) * 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 --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
googleapis · Apr 2, 2024 · cf51780 · cf51780
1 parent 267e46b
commit cf51780
Show file tree

Hide file tree

Showing 9 changed files with 198 additions and 73 deletions.
diff --git a/samples/customer_record_pb.js b/samples/customer_record_pb.js
@@ -224,8 +224,8 @@ $root.CustomerRecord = (function () {
           options.longs === String
             ? long.toString()
             : options.longs === Number
-            ? long.toNumber()
-            : long;
+              ? long.toNumber()
+              : long;
       } else object.rowNum = options.longs === String ? '0' : 0;
     }
     if (message.customerName != null && message.hasOwnProperty('customerName'))
@@ -239,11 +239,11 @@ $root.CustomerRecord = (function () {
           options.longs === String
             ? $util.Long.prototype.toString.call(message.rowNum)
             : options.longs === Number
-            ? new $util.LongBits(
-                message.rowNum.low >>> 0,
-                message.rowNum.high >>> 0
-              ).toNumber()
-            : message.rowNum;
+              ? new $util.LongBits(
+                  message.rowNum.low >>> 0,
+                  message.rowNum.high >>> 0
+                ).toNumber()
+              : message.rowNum;
     return object;
   };
 

diff --git a/samples/sample_data_pb.js b/samples/sample_data_pb.js
@@ -562,9 +562,8 @@ $root.SampleData = (function () {
       message.float64Col = Number(object.float64Col);
     if (object.int64Col != null)
       if ($util.Long)
-        (message.int64Col = $util.Long.fromValue(
-          object.int64Col
-        )).unsigned = false;
+        (message.int64Col = $util.Long.fromValue(object.int64Col)).unsigned =
+          false;
       else if (typeof object.int64Col === 'string')
         message.int64Col = parseInt(object.int64Col, 10);
       else if (typeof object.int64Col === 'number')
@@ -577,9 +576,8 @@ $root.SampleData = (function () {
     if (object.stringCol != null) message.stringCol = String(object.stringCol);
     if (object.dateCol != null)
       if ($util.Long)
-        (message.dateCol = $util.Long.fromValue(
-          object.dateCol
-        )).unsigned = false;
+        (message.dateCol = $util.Long.fromValue(object.dateCol)).unsigned =
+          false;
       else if (typeof object.dateCol === 'string')
         message.dateCol = parseInt(object.dateCol, 10);
       else if (typeof object.dateCol === 'number')
@@ -696,8 +694,8 @@ $root.SampleData = (function () {
           options.longs === String
             ? long.toString()
             : options.longs === Number
-            ? long.toNumber()
-            : long;
+              ? long.toNumber()
+              : long;
       } else object.int64Col = options.longs === String ? '0' : 0;
       object.stringCol = '';
       if ($util.Long) {
@@ -706,8 +704,8 @@ $root.SampleData = (function () {
           options.longs === String
             ? long.toString()
             : options.longs === Number
-            ? long.toNumber()
-            : long;
+              ? long.toNumber()
+              : long;
       } else object.dateCol = options.longs === String ? '0' : 0;
       object.datetimeCol = '';
       object.geographyCol = '';
@@ -720,8 +718,8 @@ $root.SampleData = (function () {
           options.longs === String
             ? long.toString()
             : options.longs === Number
-            ? long.toNumber()
-            : long;
+              ? long.toNumber()
+              : long;
       } else object.timestampCol = options.longs === String ? '0' : 0;
       object.structCol = null;
       if ($util.Long) {
@@ -730,8 +728,8 @@ $root.SampleData = (function () {
           options.longs === String
             ? long.toString()
             : options.longs === Number
-            ? long.toNumber()
-            : long;
+              ? long.toNumber()
+              : long;
       } else object.rowNum = options.longs === String ? '0' : 0;
     }
     if (message.boolCol != null && message.hasOwnProperty('boolCol'))
@@ -741,8 +739,8 @@ $root.SampleData = (function () {
         options.bytes === String
           ? $util.base64.encode(message.bytesCol, 0, message.bytesCol.length)
           : options.bytes === Array
-          ? Array.prototype.slice.call(message.bytesCol)
-          : message.bytesCol;
+            ? Array.prototype.slice.call(message.bytesCol)
+            : message.bytesCol;
     if (message.float64Col != null && message.hasOwnProperty('float64Col'))
       object.float64Col =
         options.json && !isFinite(message.float64Col)
@@ -759,11 +757,11 @@ $root.SampleData = (function () {
           options.longs === String
             ? $util.Long.prototype.toString.call(message.int64Col)
             : options.longs === Number
-            ? new $util.LongBits(
-                message.int64Col.low >>> 0,
-                message.int64Col.high >>> 0
-              ).toNumber()
-            : message.int64Col;
+              ? new $util.LongBits(
+                  message.int64Col.low >>> 0,
+                  message.int64Col.high >>> 0
+                ).toNumber()
+              : message.int64Col;
     if (message.stringCol != null && message.hasOwnProperty('stringCol'))
       object.stringCol = message.stringCol;
     if (message.dateCol != null && message.hasOwnProperty('dateCol'))
@@ -775,11 +773,11 @@ $root.SampleData = (function () {
           options.longs === String
             ? $util.Long.prototype.toString.call(message.dateCol)
             : options.longs === Number
-            ? new $util.LongBits(
-                message.dateCol.low >>> 0,
-                message.dateCol.high >>> 0
-              ).toNumber()
-            : message.dateCol;
+              ? new $util.LongBits(
+                  message.dateCol.low >>> 0,
+                  message.dateCol.high >>> 0
+                ).toNumber()
+              : message.dateCol;
     if (message.datetimeCol != null && message.hasOwnProperty('datetimeCol'))
       object.datetimeCol = message.datetimeCol;
     if (message.geographyCol != null && message.hasOwnProperty('geographyCol'))
@@ -804,11 +802,11 @@ $root.SampleData = (function () {
           options.longs === String
             ? $util.Long.prototype.toString.call(message.timestampCol)
             : options.longs === Number
-            ? new $util.LongBits(
-                message.timestampCol.low >>> 0,
-                message.timestampCol.high >>> 0
-              ).toNumber()
-            : message.timestampCol;
+              ? new $util.LongBits(
+                  message.timestampCol.low >>> 0,
+                  message.timestampCol.high >>> 0
+                ).toNumber()
+              : message.timestampCol;
     if (message.int64List && message.int64List.length) {
       object.int64List = [];
       for (var j = 0; j < message.int64List.length; ++j)
@@ -822,11 +820,11 @@ $root.SampleData = (function () {
             options.longs === String
               ? $util.Long.prototype.toString.call(message.int64List[j])
               : options.longs === Number
-              ? new $util.LongBits(
-                  message.int64List[j].low >>> 0,
-                  message.int64List[j].high >>> 0
-                ).toNumber()
-              : message.int64List[j];
+                ? new $util.LongBits(
+                    message.int64List[j].low >>> 0,
+                    message.int64List[j].high >>> 0
+                  ).toNumber()
+                : message.int64List[j];
     }
     if (message.structCol != null && message.hasOwnProperty('structCol'))
       object.structCol = $root.SampleData.SampleStruct.toObject(
@@ -850,11 +848,11 @@ $root.SampleData = (function () {
           options.longs === String
             ? $util.Long.prototype.toString.call(message.rowNum)
             : options.longs === Number
-            ? new $util.LongBits(
-                message.rowNum.low >>> 0,
-                message.rowNum.high >>> 0
-              ).toNumber()
-            : message.rowNum;
+              ? new $util.LongBits(
+                  message.rowNum.low >>> 0,
+                  message.rowNum.high >>> 0
+                ).toNumber()
+              : message.rowNum;
     return object;
   };
 
@@ -1076,8 +1074,8 @@ $root.SampleData = (function () {
             options.longs === String
               ? long.toString()
               : options.longs === Number
-              ? long.toNumber()
-              : long;
+                ? long.toNumber()
+                : long;
         } else object.subIntCol = options.longs === String ? '0' : 0;
       if (message.subIntCol != null && message.hasOwnProperty('subIntCol'))
         if (typeof message.subIntCol === 'number')
@@ -1090,11 +1088,11 @@ $root.SampleData = (function () {
             options.longs === String
               ? $util.Long.prototype.toString.call(message.subIntCol)
               : options.longs === Number
-              ? new $util.LongBits(
-                  message.subIntCol.low >>> 0,
-                  message.subIntCol.high >>> 0
-                ).toNumber()
-              : message.subIntCol;
+                ? new $util.LongBits(
+                    message.subIntCol.low >>> 0,
+                    message.subIntCol.high >>> 0
+                  ).toNumber()
+                : message.subIntCol;
       return object;
     };
 

diff --git a/src/managedwriter/stream_connection.ts b/src/managedwriter/stream_connection.ts
@@ -176,9 +176,8 @@ export class StreamConnection extends EventEmitter {
     }
     // This header is required so that the BigQuery Storage API
     // knows which region to route the request to.
-    callOptions.otherArgs.headers[
-      'x-goog-request-params'
-    ] = `write_stream=${streamId}`;
+    callOptions.otherArgs.headers['x-goog-request-params'] =
+      `write_stream=${streamId}`;
     return callOptions;
   }
 

diff --git a/src/v1/big_query_read_client.ts b/src/v1/big_query_read_client.ts
@@ -119,8 +119,15 @@ export class BigQueryReadClient {
         '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 = 'bigquerystorage.' + this._universeDomain;
     const servicePath =
       opts?.servicePath || opts?.apiEndpoint || this._servicePath;
@@ -169,7 +176,7 @@ export class BigQueryReadClient {
 
     // 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}`);
@@ -318,7 +325,7 @@ export class BigQueryReadClient {
    */
   static get servicePath() {
     if (
-      typeof process !== undefined &&
+      typeof process === 'object' &&
       typeof process.emitWarning === 'function'
     ) {
       process.emitWarning(
@@ -336,7 +343,7 @@ export class BigQueryReadClient {
    */
   static get apiEndpoint() {
     if (
-      typeof process !== undefined &&
+      typeof process === 'object' &&
       typeof process.emitWarning === 'function'
     ) {
       process.emitWarning(

diff --git a/src/v1/big_query_write_client.ts b/src/v1/big_query_write_client.ts
@@ -122,8 +122,15 @@ export class BigQueryWriteClient {
         '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 = 'bigquerystorage.' + this._universeDomain;
     const servicePath =
       opts?.servicePath || opts?.apiEndpoint || this._servicePath;
@@ -172,7 +179,7 @@ export class BigQueryWriteClient {
 
     // 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}`);
@@ -324,7 +331,7 @@ export class BigQueryWriteClient {
    */
   static get servicePath() {
     if (
-      typeof process !== undefined &&
+      typeof process === 'object' &&
       typeof process.emitWarning === 'function'
     ) {
       process.emitWarning(
@@ -342,7 +349,7 @@ export class BigQueryWriteClient {
    */
   static get apiEndpoint() {
     if (
-      typeof process !== undefined &&
+      typeof process === 'object' &&
       typeof process.emitWarning === 'function'
     ) {
       process.emitWarning(

diff --git a/src/v1beta1/big_query_storage_client.ts b/src/v1beta1/big_query_storage_client.ts
@@ -124,8 +124,15 @@ export class BigQueryStorageClient {
         '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 = 'bigquerystorage.' + this._universeDomain;
     const servicePath =
       opts?.servicePath || opts?.apiEndpoint || this._servicePath;
@@ -174,7 +181,7 @@ export class BigQueryStorageClient {
 
     // 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}`);
@@ -320,7 +327,7 @@ export class BigQueryStorageClient {
    */
   static get servicePath() {
     if (
-      typeof process !== undefined &&
+      typeof process === 'object' &&
       typeof process.emitWarning === 'function'
     ) {
       process.emitWarning(
@@ -338,7 +345,7 @@ export class BigQueryStorageClient {
    */
   static get apiEndpoint() {
     if (
-      typeof process !== undefined &&
+      typeof process === 'object' &&
       typeof process.emitWarning === 'function'
     ) {
       process.emitWarning(