pear seed add new. test

Author: AndreiRegiani

test/03-seed.test.js

@@ -4,6 +4,7 @@ const Corestore = require('corestore')
 const Hyperdrive = require('hyperdrive')
 const Hyperswarm = require('hyperswarm')
 const hypercoreid = require('hypercore-id-encoding')
+const Localdrive = require('localdrive')
 const Helper = require('./helper')
 
 test('pear seed basic stage and seed', async function ({ ok, plan, comment, teardown, timeout }) {
@@ -109,3 +110,51 @@ test('pear seed announces, join, drop', async function ({
   const dropped = await until['peer-remove']
   ok(dropped, 'peer drops')
 })
+
+test('pear seed fully syncs db and blobs cores', async function ({
+  is,
+  plan,
+  comment,
+  teardown,
+  timeout,
+  tmp
+}) {
+  timeout(180000)
+  plan(2)
+
+  const sourceStore = new Corestore(await tmp())
+  teardown(() => sourceStore.close())
+  await sourceStore.ready()
+  const sourceDrive = new Hyperdrive(sourceStore)
+  await sourceDrive.ready()
+  await new Localdrive(Helper.fixture('minimal')).mirror(sourceDrive).done()
+  const sourceBlobs = await sourceDrive.getBlobs()
+  const blocks = sourceDrive.db.core.length + sourceBlobs.core.length
+
+  let dbBlocks = 0
+  sourceDrive.db.core.on('upload', () => dbBlocks++)
+
+  let blobBlocks = 0
+  sourceBlobs.core.on('upload', () => blobBlocks++)
+
+  const sourceSwarm = new Hyperswarm({ bootstrap: Helper.dhtBootstrap })
+  teardown(() => sourceSwarm.destroy())
+  sourceSwarm.on('connection', (conn) => {
+    sourceStore.replicate(conn)
+  })
+  const topic = sourceSwarm.join(sourceDrive.discoveryKey, { server: true, client: false })
+  await topic.flushed()
+
+  const helper = new Helper()
+  teardown(() => helper.close(), { order: Infinity })
+  await helper.ready()
+
+  comment('seeding external app')
+  const link = `pear://${hypercoreid.encode(sourceDrive.key)}`
+  const seeding = helper.seed({ link })
+  teardown(() => Helper.teardownStream(seeding))
+  await Helper.pick(seeding, { tag: 'stats', data: { download: { totalBlocks: blocks } } })
+
+  is(dbBlocks, sourceDrive.db.core.length, 'seed synced db core')
+  is(blobBlocks, sourceBlobs.core.length, 'seed synced blobs core')
+})