[DO NOT MERGE] Debug flaky test (not reproducible on own machine)

Author: HDegroote

.github/workflows/test-node.yml

@@ -3,6 +3,7 @@ on:
   push:
     branches:
       - main
+      - debug-flaky-test # temp
     tags: # To trigger the canary
       - '*'
   pull_request:

package.json

@@ -4,7 +4,7 @@
   "description": "Hypercore is a secure, distributed append-only log",
   "main": "index.js",
   "scripts": {
-    "test": "standard && node test/all.js",
+    "test": "npx brittle test/replicate.js",
     "test:generate": "brittle -r test/all.js test/*.js"
   },
   "repository": {

test/replicate.js

@@ -6,6 +6,7 @@ const { create, replicate, unreplicate, eventFlush } = require('./helpers')
 const { makeStreamPair } = require('./helpers/networking.js')
 const Hypercore = require('../')
 
+/*
 test('basic replication', async function (t) {
   const a = await create()
 
@@ -1215,44 +1216,48 @@ test('cancel block', async function (t) {
   await a.close()
   await b.close()
 })
+*/
 
-test('try cancel block from a different session', async function (t) {
-  t.plan(3)
+for (let i = 0; i < 100; i++) {
+  test('try cancel block from a different session', async function (t) {
+    t.plan(3)
 
-  const a = await create()
-  const b = await create(a.key)
+    const a = await create()
+    const b = await create(a.key)
 
-  await a.append(['a', 'b', 'c'])
+    await a.append(['a', 'b', 'c'])
 
-  const [n1, n2] = makeStreamPair(t, { latency: [50, 50] })
-  a.replicate(n1)
-  b.replicate(n2)
+    const [n1, n2] = makeStreamPair(t, { latency: [50, 50] })
+    a.replicate(n1)
+    b.replicate(n2)
 
-  const s1 = b.session()
-  const s2 = b.session()
+    const s1 = b.session()
+    const s2 = b.session()
 
-  const cancelling = waitForRequestBlock(s1).then(() => s1.close())
+    const cancelling = waitForRequestBlock(s1).then(() => s1.close())
 
-  const b1 = s1.get(0)
-  const b2 = s2.get(0)
+    const b1 = s1.get(0)
+    const b2 = s2.get(0)
 
-  try {
-    await b1
-    t.fail('Should have failed')
-  } catch (err) {
-    t.is(err.code, 'REQUEST_CANCELLED')
-  }
+    try {
+      await b1
+      t.fail('Should have failed')
+    } catch (err) {
+      t.is(err.code, 'REQUEST_CANCELLED')
+    }
 
-  await cancelling
+    await cancelling
 
-  t.alike(await b2, b4a.from('a'))
-  t.alike(await s2.get(1), b4a.from('b'))
-  await s2.close()
+    t.alike(await b2, b4a.from('a'))
+    t.alike(await s2.get(1), b4a.from('b'))
+    await s2.close()
 
-  await a.close()
-  await b.close()
-})
+    await a.close()
+    await b.close()
+  })
+}
 
+/*
 test('retry failed block requests to another peer', async function (t) {
   t.plan(6)
 
@@ -1485,6 +1490,7 @@ test('replication updates on core copy', async function (t) {
 
   await t.execution(promise)
 })
+*/
 
 async function waitForRequestBlock (core, opts) {
   while (true) {