interop/test/circuit/browser.js at 42f2f78a20ce798e3b17f98ea3decdbfec1db22f · ipfs/interop · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
/* eslint max-nested-callbacks: ["error", 8] */
/* eslint-env mocha */
'use strict'

const series = require('async/series')

const utils = require('../utils/circuit')

const createJs = utils.createJsNode
const createProc = utils.createProcNode
const createGo = utils.createGoNode
const connWithTimeout = utils.connWithTimeout

const getWsAddr = utils.getWsAddr
const getWsStarAddr = utils.getWsStarAddr
const getCircuitAddr = utils.getCircuitAddr

const base = '/ip4/127.0.0.1/tcp/0'

module.exports = {
  'browser-go-js': {
    create:
      (callback) => series([
        (cb) => createProc([], cb),
        (cb) => createGo([`${base}/ws`], cb),
        (cb) => createJs([`${base}/ws`], cb)
      ], callback),
    connect: connWithTimeout(1500)
  },
  'browser-go-go': {
    create: (callback) => series([
      (cb) => createProc([], cb),
      (cb) => createGo([`${base}/ws`], cb),
      (cb) => createGo([`${base}/ws`], cb)
    ], callback),
    connect: connWithTimeout(1500)
  },
  'browser-js-js': {
    create: (callback) => series([
      (cb) => createProc([], cb),
      (cb) => createJs([`${base}/ws`], cb),
      (cb) => createJs([`${base}/ws`], cb)
    ], callback),
    connect: connWithTimeout(1500)
  },
  'browser-js-go': {
    create: (callback) => series([
      (cb) => createProc([], cb),
      (cb) => createJs([`${base}/ws`], cb),
      (cb) => createJs([`${base}/ws`], cb)
    ], callback),
    connect: connWithTimeout(1500)
  },
  'js-go-browser': {
    create: (callback) => series([
      (cb) => createJs([`${base}/ws`], cb),
      (cb) => createGo([`${base}/ws`], cb),
      (cb) => createProc([], cb)
    ], callback),
    connect: connWithTimeout(1500)
  },
  'go-go-browser': {
    create: (callback) => series([
      (cb) => createGo([`${base}/ws`], cb),
      (cb) => createGo([`${base}/ws`], cb),
      (cb) => createProc([], cb)
    ], callback),
    connect: connWithTimeout(1500)
  },
  'js-js-browser': {
    create: (callback) => series([
      (cb) => createJs([`${base}/ws`], cb),
      (cb) => createJs([`${base}/ws`], cb),
      (cb) => createProc([], cb)
    ], callback),
    connect: connWithTimeout(1500)
  },
  'go-js-browser': {
    create: (callback) => series([
      (cb) => createGo([`${base}/ws`], cb),
      (cb) => createJs([`${base}/ws`], cb),
      (cb) => createProc([], cb)
    ], callback),
    connect: connWithTimeout(1500)
  },
  'go-browser-browser': {
    create: (callback) => series([
      (cb) => createGo([`${base}/ws`], cb),
      (cb) => createProc(['/ip4/127.0.0.1/tcp/24642/ws/p2p-websocket-star'], cb),
      (cb) => createProc(['/ip4/127.0.0.1/tcp/24642/ws/p2p-websocket-star'], cb)
    ], callback),
    connect: (nodeA, nodeB, relay, callback) => {
      series([
        (cb) => relay.ipfsd.api.swarm.connect(getWsAddr(nodeA.addrs), cb),
        (cb) => relay.ipfsd.api.swarm.connect(getWsStarAddr(nodeB.addrs), cb),
        // TODO: needed until https://github.com/ipfs/interop/issues/17 is resolved
        (cb) => setTimeout(cb, 5000),
        (cb) => nodeA.ipfsd.api.swarm.connect(getCircuitAddr(nodeB.addrs), cb)
      ], callback)
    },
    skip: () => false
  },
  'js-browser-browser': {
    create: (callback) => series([
      (cb) => createJs([`${base}/ws`], cb),
      (cb) => createProc(['/ip4/127.0.0.1/tcp/24642/ws/p2p-websocket-star'], cb),
      (cb) => createProc(['/ip4/127.0.0.1/tcp/24642/ws/p2p-websocket-star'], cb)
    ], callback),
    connect: (nodeA, nodeB, relay, callback) => {
      series([
        (cb) => relay.ipfsd.api.swarm.connect(getWsAddr(nodeA.addrs), cb),
        (cb) => relay.ipfsd.api.swarm.connect(getWsStarAddr(nodeB.addrs), cb),
        // TODO: needed until https://github.com/ipfs/interop/issues/17 is resolved
        (cb) => setTimeout(cb, 3000),
        (cb) => nodeA.ipfsd.api.swarm.connect(getCircuitAddr(nodeB.addrs), cb)
      ], callback)
    }
  },
  'browser-browser-go': {
    create: (callback) => series([
      (cb) => createProc(['/ip4/127.0.0.1/tcp/24642/ws/p2p-websocket-star'], cb),
      (cb) => createProc(['/ip4/127.0.0.1/tcp/24642/ws/p2p-websocket-star'], cb),
      (cb) => createGo([`${base}/ws`], cb)
    ], callback),
    connect: (nodeA, nodeB, relay, callback) => {
      series([
        (cb) => relay.ipfsd.api.swarm.connect(getWsStarAddr(nodeA.addrs), cb),
        (cb) => relay.ipfsd.api.swarm.connect(getWsAddr(nodeB.addrs), cb),
        // TODO: needed until https://github.com/ipfs/interop/issues/17 is resolved
        (cb) => setTimeout(cb, 5000),
        (cb) => nodeA.ipfsd.api.swarm.connect(getCircuitAddr(nodeB.addrs), cb)
      ], callback)
    }
  },
  'browser-browser-js': {
    create: (callback) => series([
      (cb) => createProc(['/ip4/127.0.0.1/tcp/24642/ws/p2p-websocket-star'], cb),
      (cb) => createProc(['/ip4/127.0.0.1/tcp/24642/ws/p2p-websocket-star'], cb),
      (cb) => createJs([`${base}/ws`], cb)
    ], callback),
    connect: (nodeA, nodeB, relay, callback) => {
      series([
        (cb) => relay.ipfsd.api.swarm.connect(getWsStarAddr(nodeA.addrs), cb),
        (cb) => relay.ipfsd.api.swarm.connect(getWsAddr(nodeB.addrs), cb),
        // TODO: needed until https://github.com/ipfs/interop/issues/17 is resolved
        (cb) => setTimeout(cb, 3000),
        (cb) => nodeA.ipfsd.api.swarm.connect(getCircuitAddr(nodeB.addrs), cb)
      ], callback)
    }
  }
}