Generate insertId if not provided.

googleapis · Nov 9, 2017 · 2e44af4 · 2e44af4
1 parent f10f61f
commit 2e44af4
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 1 deletion.
diff --git a/packages/bigquery/src/table.js b/packages/bigquery/src/table.js
@@ -1007,6 +1007,7 @@ Table.prototype.insert = function(rows, options, callback) {
   if (!options.raw) {
     json.rows = arrify(rows).map(function(row) {
       return {
+        insertId: uuid.v4(),
         json: Table.encodeValue_(row)
       };
     });

diff --git a/packages/bigquery/test/table.js b/packages/bigquery/test/table.js
@@ -63,7 +63,7 @@ var fakePaginator = {
   }
 };
 
-var fakeUuid = extend({}, uuid);
+var fakeUuid = extend(true, {}, uuid);
 
 function FakeServiceObject() {
   this.calledWith_ = arguments;
@@ -135,6 +135,7 @@ describe('BigQuery/Table', function() {
   });
 
   beforeEach(function() {
+    fakeUuid = extend(fakeUuid, uuid);
     isCustomTypeOverride = null;
     makeWritableStreamOverride = null;
     tableOverrides = {};
@@ -1016,6 +1017,8 @@ describe('BigQuery/Table', function() {
   });
 
   describe('insert', function() {
+    var fakeInsertId = 'fake-insert-id';
+
     var data = [
       { state: 'MI', gender: 'M', year: '2015', name: 'Berkley', count: '0' },
       { state: 'MI', gender: 'M', year: '2015', name: 'Berkley', count: '0' },
@@ -1035,11 +1038,18 @@ describe('BigQuery/Table', function() {
     var dataApiFormat = {
       rows: data.map(function(row) {
         return {
+          insertId: fakeInsertId,
           json: row
         };
       })
     };
 
+    beforeEach(function() {
+      fakeUuid.v4 = function() {
+        return fakeInsertId;
+      };
+    });
+
     it('should throw an error if rows is empty', function() {
       assert.throws(function() {
         table.insert([]);
@@ -1057,6 +1067,15 @@ describe('BigQuery/Table', function() {
       table.insert(data, done);
     });
 
+    it('should generate insertId', function(done) {
+      table.request = function(reqOpts) {
+        assert.strictEqual(reqOpts.json.rows[0].insertId, fakeInsertId);
+        done();
+      };
+
+      table.insert([data[0]], done);
+    });
+
     it('should execute callback with API response', function(done) {
       var apiResponse = { insertErrors: [] };