test: headers first sync tests

test/neutrino-test.js

@@ -0,0 +1,64 @@
+'use strict';
+
+const FullNode = require('../lib/node/fullnode');
+const NeutrinoNode = require('../lib/node/neutrino');
+const {forValue} = require('./util/common');
+
+describe('Neutrino', function () {
+  this.timeout(10000);
+
+  const node1 = new NeutrinoNode({
+    network: 'regtest',
+    memory: true,
+    port: 10000,
+    httpPort: 20000,
+    neutrino: true,
+    only: '127.0.0.1'
+  });
+
+  const node2 = new FullNode({
+    network: 'regtest',
+    memory: true,
+    listen: true,
+    indexFilter: true,
+    bip157: true
+  });
+
+  async function mineBlocks(n) {
+    while (n) {
+      const block = await node2.miner.mineBlock();
+      await node2.chain.add(block);
+      n--;
+    }
+  }
+
+  before(async () => {
+    const waitForConnection = new Promise((resolve, reject) => {
+      node2.pool.once('peer open', async (peer) => {
+        resolve(peer);
+      });
+    });
+
+    await node1.open();
+    await node2.open();
+    await node1.connect();
+    await node2.connect();
+    await mineBlocks(200);
+    await waitForConnection;
+  });
+
+  after(async () => {
+    await node1.close();
+    await node2.close();
+  });
+
+  it('should initial sync', async () => {
+    node1.startSync();
+    await forValue(node1.chain, 'height', node2.chain.height);
+  });
+
+  it('should get new blocks headers-only', async () => {
+    await mineBlocks(10);
+    await forValue(node1.chain, 'height', node2.chain.height);
+  });
+});