Keystore#verifiers

tests: add v0 address test

tests: remove unused config options

package.json

@@ -18,19 +18,18 @@
     "localstorage-down": "^0.6.7",
     "logplease": "^1.2.14",
     "multihashes": "^0.4.12",
-    "orbit-db-access-controllers": "github:orbitdb/orbit-db-access-controllers",
+    "orbit-db-access-controllers": "github:orbitdb/orbit-db-access-controllers#libp2p",
     "orbit-db-cache": "~0.2.4",
-    "orbit-db-counterstore": "github:orbitdb/orbit-db-counterstore",
-    "orbit-db-docstore": "github:orbitdb/orbit-db-docstore",
-    "orbit-db-eventstore": "github:orbitdb/orbit-db-eventstore",
-    "orbit-db-feedstore": "github:orbitdb/orbit-db-feedstore",
+    "orbit-db-counterstore": "github:orbitdb/orbit-db-counterstore#feat/backwards-compatible",
+    "orbit-db-docstore": "github:orbitdb/orbit-db-docstore#feat/backwards-compatible",
+    "orbit-db-eventstore": "github:orbitdb/orbit-db-eventstore#feat/backwards-compatible",
+    "orbit-db-feedstore": "github:orbitdb/orbit-db-feedstore#feat/backwards-compatible",
     "orbit-db-identity-provider": "github:orbitdb/orbit-db-identity-provider#libp2p",
     "orbit-db-io": "~0.0.1",
     "orbit-db-keystore": "github:orbitdb/orbit-db-keystore#libp2p",
-    "orbit-db-kvstore": "github:orbitdb/orbit-db-kvstore",
+    "orbit-db-kvstore": "github:orbitdb/orbit-db-kvstore#feat/backwards-compatible",
     "orbit-db-pubsub": "~0.5.5",
-    "orbit-db-store": "github:orbitdb/orbit-db-store",
-    "pify": "^4.0.1"
+    "orbit-db-store": "github:orbitdb/orbit-db-store#feat/backwards-compatible"
   },
   "devDependencies": {
     "babel-core": "^6.26.0",
@@ -39,6 +38,7 @@
     "babel-polyfill": "^6.26.0",
     "babel-preset-env": "^1.7.0",
     "datastore-level": "~0.10.0",
+    "fs-extra": "^7.0.1",
     "go-ipfs-dep": "^0.4.18",
     "ipfs": "^0.34.4",
     "ipfs-repo": "^0.26.2",
@@ -49,6 +49,7 @@
     "p-map": "^1.2.0",
     "p-map-series": "^1.0.0",
     "p-whilst": "^1.0.0",
+    "pify": "^4.0.1",
     "remark-cli": "^5.0.0",
     "remark-validate-links": "^7.0.0",
     "rimraf": "^2.6.2",

test/fixtures/ipfs/blocks/4D/CIQBLKWGZUKWMXAVXNDUSP5ZNOG2Y2XOAET5JJBVNS76QVLYK7QU4DY.data

@@ -0,0 +1,2 @@
+
+Û{"hash":null,"id":"/orbitdb/QmWDUfC4zcWJGgc9UHn1X3qQ5KZqBv4KCiCtjnpMmBT8JC/v0-db","payload":{"op":"ADD","key":null,"value":{"thing":"1"}},"next":[],"v":0,"clock":{"id":"04b54f6ef529cd2dd2f9c6897a382c492222d42e57826269a38101ffe752aa07260ecd092a970d7eef08c4ddae2b7006ee25f07e4ab62fa5262ae3b51fdea29f78","time":1},"sig":"30460221008067ac541ab9b8ef6de41318220c6927f046188ae63620c34666d1ca00574001022100b9427217bb79b4bdad8645bb361745ffffa0bfa264778202c68aa8f2b9857ada","key":"04b54f6ef529cd2dd2f9c6897a382c492222d42e57826269a38101ffe752aa07260ecd092a970d7eef08c4ddae2b7006ee25f07e4ab62fa5262ae3b51fdea29f78"}

test/fixtures/ipfs/blocks/DE/CIQHKBYQ3XDBVGNYMBH4O7SAM62TYJGQJCGNFD62JSZUJ77OSWTTDEI.data

@@ -0,0 +1,2 @@
+
+h{"name":"v0-db","type":"feed","accessController":"/ipfs/Qmc3S7aMSmH8oGmx7Zdp8UxVWcDyCq5o2H9qYFgT3GW6nM"}

test/fixtures/ipfs/blocks/DM/CIQMXGUANCZ5ASD36UTAW4EHGSAPYJ77YZZTOMXKBAX64NRAC6PMDMQ.data

@@ -0,0 +1,8 @@
+
+º
{
+  "admin": [],
+  "write": [
+    "04b54f6ef529cd2dd2f9c6897a382c492222d42e57826269a38101ffe752aa07260ecd092a970d7eef08c4ddae2b7006ee25f07e4ab62fa5262ae3b51fdea29f78"
+  ],
+  "read": []
+}

test/fixtures/ipfs/blocks/HL/CIQKYEXBLUP5DZSEWWSTE3VDCUPVZX7LCVXS6WT3USYCBHQIXZJNHLI.data

@@ -0,0 +1,2 @@
+
+‹{"hash":null,"id":"/orbitdb/QmWDUfC4zcWJGgc9UHn1X3qQ5KZqBv4KCiCtjnpMmBT8JC/v0-db","payload":{"op":"ADD","key":null,"value":{"thing":"2"}},"next":["QmPoEJkWCkgDkuNdshm6Srw9haEBtgn1e352dkF1wpEfXt"],"v":0,"clock":{"id":"04b54f6ef529cd2dd2f9c6897a382c492222d42e57826269a38101ffe752aa07260ecd092a970d7eef08c4ddae2b7006ee25f07e4ab62fa5262ae3b51fdea29f78","time":2},"sig":"30460221008067ac541ab9b8ef6de41318220c6927f046188ae63620c34666d1ca00574001022100b9427217bb79b4bdad8645bb361745ffffa0bfa264778202c68aa8f2b9857ada","key":"04b54f6ef529cd2dd2f9c6897a382c492222d42e57826269a38101ffe752aa07260ecd092a970d7eef08c4ddae2b7006ee25f07e4ab62fa5262ae3b51fdea29f78"}

test/fixtures/ipfs/blocks/IL/CIQN7GU6K64HNLHAHLWF6J4VQI4MLPOZUXPRJV3KW3E7IFOGFT3LILQ.data

@@ -0,0 +1,2 @@
+
+¼{"hash":null,"id":"/orbitdb/QmWDUfC4zcWJGgc9UHn1X3qQ5KZqBv4KCiCtjnpMmBT8JC/v0-db","payload":{"op":"ADD","key":null,"value":{"thing":"3"}},"next":["QmZvMXmv66vXQ9u2q8UTWPmH59eQUKzVb24bKv8j9zbVuN","QmPoEJkWCkgDkuNdshm6Srw9haEBtgn1e352dkF1wpEfXt"],"v":0,"clock":{"id":"04b54f6ef529cd2dd2f9c6897a382c492222d42e57826269a38101ffe752aa07260ecd092a970d7eef08c4ddae2b7006ee25f07e4ab62fa5262ae3b51fdea29f78","time":3},"sig":"30460221008067ac541ab9b8ef6de41318220c6927f046188ae63620c34666d1ca00574001022100b9427217bb79b4bdad8645bb361745ffffa0bfa264778202c68aa8f2b9857ada","key":"04b54f6ef529cd2dd2f9c6897a382c492222d42e57826269a38101ffe752aa07260ecd092a970d7eef08c4ddae2b7006ee25f07e4ab62fa5262ae3b51fdea29f78"}

test/fixtures/ipfs/datastore/CURRENT

@@ -0,0 +1 @@
+MANIFEST-000200

test/fixtures/v0/QmWDUfC4zcWJGgc9UHn1X3qQ5KZqBv4KCiCtjnpMmBT8JC/v0-db/CURRENT

@@ -0,0 +1 @@
+MANIFEST-000371

test/replicate.test.js

@@ -237,7 +237,7 @@ Object.keys(testAPIs).forEach(API => {
       })
     })
 
-    it.only('emits correct replication info on fresh replication', async () => {
+    it('emits correct replication info on fresh replication', async () => {
       return new Promise(async (resolve, reject) => {
         let finished = false
         let eventCount = { 'replicate': 0, 'replicate.progress': 0, 'replicated': 0 }

test/utils/config.js

@@ -25,8 +25,6 @@ module.exports = {
     }
   },
   daemon1: {
-    repo: './ipfs/orbitdb/tests/daemon1',
-    start: true,
     EXPERIMENTAL: {
       pubsub: true
     },
@@ -49,8 +47,6 @@ module.exports = {
     },
   },
   daemon2: {
-    repo: './ipfs/orbitdb/tests/daemon2',
-    start: true,
     EXPERIMENTAL: {
       pubsub: true
     },
@@ -71,5 +67,5 @@ module.exports = {
         }
       },
     },
-  },
+  }
 }

test/v0-open-load.js

@@ -0,0 +1,90 @@
+'use strict'
+
+const assert = require('assert')
+const mapSeries = require('p-map-series')
+const fs = require('fs-extra')
+const path = require('path')
+const rmrf = require('rimraf')
+const levelup = require('levelup')
+const leveldown = require('leveldown')
+const OrbitDB = require('../src/OrbitDB')
+const OrbitDBAddress = require('../src/orbit-db-address')
+const io = require('orbit-db-io')
+const IPFS = require('ipfs')
+// Include test utilities
+const {
+  config,
+  startIpfs,
+  stopIpfs,
+  testAPIs,
+} = require('./utils')
+
+const dbPath = './orbitdb/tests/v0'
+
+var dbFixturesDir = './test/fixtures/v0'
+var ipfsFixturesDir = './test/fixtures/ipfs'
+
+Object.keys(testAPIs).forEach(API => {
+  describe(`orbit-db - Backward-Compatibility - Open & Load (${API})`, function() {
+    this.timeout(config.timeout)
+
+    let ipfsd, ipfs, orbitdb, db, address
+    let localDataPath
+
+    before(async () => {
+      ipfsd = await startIpfs(API, config.daemon1)
+      ipfs = ipfsd.api
+
+      //copy data files to ipfs and orbitdb repos
+      await fs.copy(path.join(ipfsFixturesDir, 'blocks'), path.join(ipfsd.path, 'blocks'))
+      await fs.copy(path.join(ipfsFixturesDir, 'datastore'), path.join(ipfsd.path, 'datastore'))
+      await fs.copy(dbFixturesDir, dbPath)
+
+      orbitdb = await OrbitDB.createInstance(ipfs, { directory: dbPath })
+    })
+
+    after(async () => {
+      if(orbitdb)
+        await orbitdb.stop()
+
+      if (ipfsd)
+        await stopIpfs(ipfsd)
+    })
+
+    describe('Open & Load', function() {
+      before(async () => {
+        db = await orbitdb.open('/orbitdb/QmWDUfC4zcWJGgc9UHn1X3qQ5KZqBv4KCiCtjnpMmBT8JC/v0-db')
+      })
+
+      after(async () => {
+        if (db)
+          await db.close()
+      })
+
+      it('open v0 orbitdb address', async () => {
+        assert.notEqual(db, null)
+      })
+
+      it('database has the correct v0 address', async () => {
+        assert.equal(db.address.toString().indexOf('/orbitdb'), 0)
+        assert.equal(db.address.toString().indexOf('Qm'), 9)
+        assert.equal(db.address.toString().indexOf('v0-db'), 56)
+      })
+
+      it('has the correct type', async () => {
+        assert.equal(db.type, 'feed')
+      })
+
+      it('database has the correct access-controller', async () => {
+        assert.equal(db.options.accessControllerAddress, '/ipfs/Qmc3S7aMSmH8oGmx7Zdp8UxVWcDyCq5o2H9qYFgT3GW6nM')
+        assert.equal(db.access.type, 'ipfs')
+        assert.strictEqual(db.access.write[0], '04b54f6ef529cd2dd2f9c6897a382c492222d42e57826269a38101ffe752aa07260ecd092a970d7eef08c4ddae2b7006ee25f07e4ab62fa5262ae3b51fdea29f78')
+      })
+
+      it('load v0 orbitdb address', async () => {
+        await db.load()
+        assert.equal(db.all.length, 3)
+      })
+    })
+  })
+})