use google-service-account

Author: stephenplusplus

lib/bigquery/index.js

@@ -24,12 +24,6 @@ var extend = require('extend');
 var streamEvents = require('stream-events');
 var through = require('through2');
 
-/**
- * @type module:common/connection
- * @private
- */
-var conn = require('../common/connection.js');
-
 /**
  * @type module:bigquery/dataset
  * @private
@@ -115,9 +109,9 @@ function BigQuery(options) {
 
   options = options || {};
 
-  this.connection_ = new conn.Connection({
+  this.makeAuthorizedRequest_ = util.makeAuthorizedRequest(this, {
     credentials: options.credentials,
-    keyFilename: options.keyFilename,
+    keyFile: options.keyFilename,
     scopes: SCOPES
   });
 
@@ -565,9 +559,7 @@ BigQuery.prototype.makeReq_ = function(method, path, query, body, callback) {
     reqOpts.json = body;
   }
 
-  this.connection_.req(reqOpts, function(err, res, body) {
-    util.handleResp(err, res, body, callback);
-  });
+  this.makeAuthorizedRequest_(reqOpts, callback);
 };
 
 module.exports = BigQuery;

lib/bigquery/table.js

@@ -306,7 +306,7 @@ Table.prototype.createWriteStream = function(metadata) {
 
   dup.once('writing', function() {
     util.makeWritableStream(dup, {
-      connection: that.bigQuery.connection_,
+      makeAuthorizedRequest: that.bigQuery.makeAuthorizedRequest_,
       metadata: {
         configuration: {
           load: metadata