#merge support to PubKeyRing

js/models/PublicKeyRing.js

@@ -76,13 +76,13 @@ PublicKeyRing.read = function (id, passphrase) {
   if (data.id !== id) 
     throw new Error('Wrong id in data');
 
-  var config = { network: data.network === 'livenet' ? 
+  var config = { network: data.networkName === 'livenet' ? 
       bitcore.networks.livenet : bitcore.networks.testnet
   };
 
   var w = new PublicKeyRing(config);
 
-  w.requiredCopayers = data.neededCopayers;
+  w.requiredCopayers = data.requiredCopayers;
   w.totalCopayers = data.totalCopayers;
   w.addressIndex = data.addressIndex;
   w.changeAddressIndex = data.changeAddressIndex;
@@ -97,22 +97,24 @@ PublicKeyRing.read = function (id, passphrase) {
   return w;
 };
 
-PublicKeyRing.prototype._toObj = function() {
+PublicKeyRing.prototype.toObj = function() {
   return {
     id: this.id,
-    network: this.network.name,
-    requiredCopayers: this.neededCopayers,
+    networkName: this.network.name,
+    requiredCopayers: this.requiredCopayers,
     totalCopayers: this.totalCopayers,
+
     changeAddressIndex: this.changeAddressIndex,
     addressIndex: this.addressIndex,
     copayersExtPubKeys: this.copayersBIP32.map( function (b) { 
       return b.extendedPublicKeyString(); 
     }),
+    ts: parseInt(Date.now() / 1000),
   };
 };
 
 PublicKeyRing.prototype.serialize = function () {
-  return JSON.stringify(this._toObj());
+  return JSON.stringify(this.toObj());
 };
 
 
@@ -236,4 +238,78 @@ PublicKeyRing.prototype.getAddresses = function() {
   return ret;
 };
 
+PublicKeyRing.prototype._checkInPRK = function(inPKR) {
+  if (this.id !== inPKR.id)
+    throw new Error('inPRK id mismatch');
+
+  if (this.network.name !== inPKR.networkName)
+    throw new Error('inPRK network mismatch');
+
+  if (
+    this.requiredCopayers && inPKR.requiredCopayers &&
+    (this.requiredCopayers !== inPKR.requiredCopayers))
+    throw new Error('inPRK requiredCopayers mismatch');
+
+  if (
+    this.totalCopayers && inPKR.totalCopayers &&
+    (this.totalCopayers !== inPKR.totalCopayers))
+    throw new Error('inPRK requiredCopayers mismatch');
+
+  if (! inPKR.ts)
+    throw new Error('no ts at inPRK');
+};
+
+
+PublicKeyRing.prototype._mergeIndexes = function(inPKR) {
+  var hasChanged = false;
+
+  // Indexes
+  if (inPKR.changeAddressIndex > this.changeAddressIndex) {
+    this.changeAddressIndex = inPKR.changeAddressIndex;
+    hasChanged = true;
+  }
+
+  if (inPKR.addressIndex > this.addressIndex) {
+    this.addressIndex = inPKR.addressIndex;
+    hasChanged = true;
+  }
+  return hasChanged;
+};
+
+PublicKeyRing.prototype._mergePubkeys = function(inPKR) {
+  var hasChanged = false;
+  var l= this.copayersBIP32.length;
+
+  var self = this;
+
+  inPKR.copayersExtPubKeys.forEach( function(epk) {
+    var haveIt = false;
+    for(var j=0; j<l; j++) {
+      if (self.copayersBIP32[j].extendedPublicKeyString() === epk) {
+        haveIt=true;
+        break;
+      }
+    }
+    if (!haveIt) {
+      self.copayersBIP32.push(new BIP32(epk));
+      hasChanged=true;
+    }
+  });
+  return hasChanged;
+};
+
+PublicKeyRing.prototype.merge = function(inPKR) {
+  var hasChanged = false;
+
+  this._checkInPRK(inPKR);
+
+  if (this._mergeIndexes(inPKR))
+    hasChanged = true;
+
+  if (this._mergePubkeys(inPKR))
+    hasChanged = true;
+
+  return hasChanged;
+};
+
 module.exports = require('soop')(PublicKeyRing);

test/test.network.js

@@ -1,21 +0,0 @@
-'use strict';
-
-var should = chai.should();
-describe('Network service', function() {
-
-  var network;
-  beforeEach(angular.mock.module('cosign'));
-
-  it('should exist', function() {
-    inject(function($injector) {
-      network = $injector.get('network');
-      should.exist(network);
-    });
-  });
-  it('should return 2', function() {
-    network.f().should.equal(2);
-  });
-  it('can start a tx signing request', function() {});
-  it('should', function() {});
-
-});

test/test.publickeyring.js

@@ -148,6 +148,116 @@ describe('PublicKeyRing model', function() {
     w.addressIndex.should.equal(5); 
   });
 
+  it('#merge index tests', function () {
+    var k = createW();
+    var w = k.w;
+
+    for(var i=0; i<2; i++)
+      w.generateAddress(true);
+    for(var i=0; i<3; i++)
+      w.generateAddress(false);
+
+    var w2 = new PublicKeyRing({
+      network: 'livenet',
+      id: w.id,
+    });
+    w2.merge(w.toObj()).should.equal(true);
+    w2.requiredCopayers.should.equal(3);   
+    w2.totalCopayers.should.equal(5);   
+    w2.changeAddressIndex.should.equal(2);   
+    w2.addressIndex.should.equal(3); 
+
+    //
+    w2.merge(w.toObj()).should.equal(false);
+  });
+
+
+  it('#merge check tests', function () {
+    var k = createW();
+    var w = k.w;
+
+    for(var i=0; i<2; i++)
+      w.generateAddress(true);
+    for(var i=0; i<3; i++)
+      w.generateAddress(false);
+
+
+    var w3 = new PublicKeyRing({
+      network: 'livenet',
+      id: w.id,
+      requiredCopayers: 2,
+    });
+    (function() { w3.merge(w.toObj());}).should.throw();
+
+    var w4 = new PublicKeyRing({
+      network: 'testnet',
+      id: w.id,
+    });
+    (function() { w4.merge(w.toObj());}).should.throw();
+
+    var w5 = new PublicKeyRing({
+      network: 'livenet',
+      id: w.id,
+      totalCopayers: 4, 
+    });
+    (function() { w5.merge(w.toObj());}).should.throw();
+
+    var w6 = new PublicKeyRing({
+      network: 'livenet',
+      id: w.id,
+    });
+    (function() { w6.merge(w);}).should.throw();
+    w.networkName= 'livenet';
+    (function() { w6.merge(w);}).should.throw();
+  });
+
+
+  it('#merge pubkey tests', function () {
+    var w = new PublicKeyRing(config);
+    should.exist(w);
+    var copayers = [];
+    for(var i=0; i<2; i++) {
+      w.haveAllRequiredPubKeys().should.equal(false);
+      w.addCopayer();
+    }
+
+    var w2 = new PublicKeyRing({
+      network: 'livenet',
+      id: w.id,
+    });
+    should.exist(w);
+    var copayers = [];
+    for(var i=0; i<3; i++) {
+      w2.haveAllRequiredPubKeys().should.equal(false);
+      w2.addCopayer();
+    }
+    w2.merge(w.toObj()).should.equal(true);
+    w2.haveAllRequiredPubKeys().should.equal(true);
+    w2.merge(w.toObj()).should.equal(false);
+
+    w.haveAllRequiredPubKeys().should.equal(false);
+    w.merge(w2.toObj()).should.equal(true);
+    w.haveAllRequiredPubKeys().should.equal(true);
+    w.merge(w2.toObj()).should.equal(false);
+  });
+
+  it('#merge pubkey tests (case 2)', function () {
+    var w = new PublicKeyRing(config);
+    should.exist(w);
+
+    for(var i=0; i<5; i++) {
+      w.haveAllRequiredPubKeys().should.equal(false);
+      var w2 = new PublicKeyRing({
+        network: 'livenet',
+        id: w.id,
+      });
+      w2.addCopayer();
+      w.merge(w2.toObj());
+    }
+    w.haveAllRequiredPubKeys().should.equal(true);
+  });
+
+
 
 });