pubsub: set sslCreds when apiEndpoint is used (#2583)

packages/pubsub/src/index.js

@@ -23,6 +23,7 @@
 var common = require('@google-cloud/common');
 var extend = require('extend');
 var googleAuth = require('google-auto-auth');
+var grpc = require('grpc');
 var is = require('is');
 
 var PKG = require('../package.json');
@@ -291,6 +292,7 @@ PubSub.prototype.determineBaseUrl_ = function() {
 
   this.options.servicePath = baseUrlParts[0];
   this.options.port = baseUrlParts[1];
+  this.options.sslCreds = grpc.credentials.createInsecure();
 };
 
 /**

packages/pubsub/test/index.js

@@ -19,12 +19,15 @@
 var arrify = require('arrify');
 var assert = require('assert');
 var extend = require('extend');
+var grpc = require('grpc');
 var proxyquire = require('proxyquire');
 var util = require('@google-cloud/common').util;
 
 var PKG = require('../package.json');
 var v1 = require('../src/v1/index.js');
 
+var fakeGrpc = extend({}, grpc);
+
 var SubscriptionCached = require('../src/subscription.js');
 var SubscriptionOverride;
 
@@ -122,6 +125,7 @@ describe('PubSub', function() {
         util: fakeUtil
       },
       'google-auto-auth': fakeGoogleAutoAuth,
+      grpc: fakeGrpc,
       './snapshot.js': FakeSnapshot,
       './subscription.js': Subscription,
       './topic.js': FakeTopic,
@@ -604,12 +608,18 @@ describe('PubSub', function() {
       var defaultBaseUrl_ = 'defaulturl';
       var testingUrl = 'localhost:8085';
 
+      var fakeCreds = {};
+      fakeGrpc.credentials.createInsecure = function() {
+        return fakeCreds;
+      };
+
       setHost(defaultBaseUrl_);
       pubsub.options.apiEndpoint = testingUrl;
       pubsub.determineBaseUrl_();
 
       assert.strictEqual(pubsub.options.servicePath, 'localhost');
       assert.strictEqual(pubsub.options.port, '8085');
+      assert.strictEqual(pubsub.options.sslCreds, fakeCreds);
     });
 
     it('should remove slashes from the baseUrl', function() {