Fix DV failures

Change-Id: I2f62153db38a06c07aca2e994fbae8de3300d26e

argon.js

@@ -21,6 +21,7 @@ const util = require('util');
 const {BigQuery} = require('@google-cloud/bigquery');
 const {GoogleAuth} = require('google-auth-library');
 const {pipeline: pipeline_} = require('stream');
+const got = require('got');
 
 const pipeline = util.promisify(pipeline_);
 
@@ -115,6 +116,7 @@ async function argon(req, res) {
     info('Initializing the API client.');
     const auth = new GoogleAuth({scopes: REPORTING_SCOPES});
     const client = await auth.getClient();
+    const headers = await client.getRequestHeaders();
 
     info(`Checking for existence of Report ${reportId}.`);
     const reportName = await getReportName({client, profileId, reportId});
@@ -180,8 +182,7 @@ async function argon(req, res) {
       info(`Fetching report file ${fileId}.`);
       try {
         const url = reports.get(fileId);
-        const fileOpts = {responseType: 'stream'};
-        const {data: file} = await client.request({url, ...fileOpts});
+        const file = got.stream(url, {headers});
         if (!file) {
           warn('Report file not found.');
           continue;

bq.js

@@ -71,6 +71,16 @@ function compareSchema(left, right) {
   return true;
 }
 
+/**
+ * Deep copies a JSON-encodable object.
+ *
+ * @param {!object} obj JSON encodable object
+ * @return {!object} Deep copy of original
+ */
+function deepCopy(obj) {
+  return JSON.parse(JSON.stringify(obj));
+}
+
 /**
  * Transform column names in schema using regex.
  *
@@ -79,7 +89,7 @@ function compareSchema(left, right) {
  * @return {?object} New schema, if renamed, else null
  */
 function transformSchema(schema, patternMap) {
-  const fields = schema.fields.slice();
+  const fields = deepCopy(schema.fields);
   let renamed = false;
 
   for (const i in fields) {
@@ -93,9 +103,7 @@ function transformSchema(schema, patternMap) {
   }
 
   if (renamed) {
-    // update schema with new fields
-    schema.fields = fields;
-    return schema;
+    return {fields};
   } else {
     return null;
   }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "argon",
-  "version": "3.3.0",
+  "version": "3.3.1",
   "author": "Google Inc.",
   "license": "Apache-2.0",
   "description": "Google Marketing Platform Reporting to BigQuery connector",
@@ -21,13 +21,14 @@
     "test": "echo 'Error: No tests defined' && exit 1"
   },
   "dependencies": {
-    "@google-cloud/bigquery": "^5.5.0",
+    "@google-cloud/bigquery": "^5.6.0",
     "express": "^4.17.1",
     "google-auth-library": "^7.0.3",
+    "got": "^11.8.2",
     "split2": "^3.2.2"
   },
   "devDependencies": {
-    "eslint": "^7.22.0",
+    "eslint": "^7.25.0",
     "eslint-config-google": "^0.14.0",
     "nodemon": "^2.0.7",
     "prettier": "^2.2.1",