From 0d6615e62f546fc4acb8a04a10f7681f1e097266 Mon Sep 17 00:00:00 2001
From: masterchief164 <63920595+masterchief164@users.noreply.github.com>
Date: Tue, 11 Jul 2023 00:59:27 +0530
Subject: [PATCH] test: headers first sync tests

---
 test/neutrino-test.js | 64 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 64 insertions(+)
 create mode 100644 test/neutrino-test.js

diff --git a/test/neutrino-test.js b/test/neutrino-test.js
new file mode 100644
index 000000000..c0c768576
--- /dev/null
+++ b/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);
+  });
+});