fluencelabs/js-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p synced 2025-04-11 11:46:05 +00:00
Code Issues Projects Releases Wiki Activity

test: Various pdd fixes (#150)

Browse Source 
* fix(pdd): url for interop pkg was pointing to non-existing branch

* fix(pdd): case-sensitive names

peer-B.json does not _actually_ exist

* fix(pdd): story 2 peer b
This commit is contained in:
Maciej Krüger 2018-01-10 15:53:24 +01:00 committed by David Dias
parent 07b0cdc30e
commit 97cde1ccb4
5 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pdd/package.json
View File

@ -14,7 +14,7 @@
"license": "MIT", "license": "MIT",
"dependencies": { "dependencies": {
"libp2p": "file:./..", "libp2p": "file:./..",
"libp2p-interop": "github:libp2p/interop#pdd", "libp2p-interop": "github:libp2p/interop#master",
"tape": "^4.8.0" "tape": "^4.8.0"
} }
} }

2
pdd/pdd-transport--story-1--peer-a.js
View File

@ -7,7 +7,7 @@ const PeerInfo = require('peer-info')
const waterfall = require('async/waterfall') const waterfall = require('async/waterfall')
const pull = require('pull-stream') const pull = require('pull-stream')
const PeerA = require('libp2p-interop/peer-a.json') const PeerA = require('libp2p-interop/peer-a.json')
const PeerB = require('libp2p-interop/peer-B.json') const PeerB = require('libp2p-interop/peer-b.json')
class MyBundle extends libp2p { class MyBundle extends libp2p {
constructor (peerInfo) { constructor (peerInfo) {

2
pdd/pdd-transport--story-1--peer-b.js
View File

@ -6,7 +6,7 @@ const TCP = require('libp2p-tcp')
const PeerInfo = require('peer-info') const PeerInfo = require('peer-info')
const waterfall = require('async/waterfall') const waterfall = require('async/waterfall')
const pull = require('pull-stream') const pull = require('pull-stream')
const PeerB = require('libp2p-interop/peer-B.json') const PeerB = require('libp2p-interop/peer-b.json')
class MyBundle extends libp2p { class MyBundle extends libp2p {
constructor (peerInfo) { constructor (peerInfo) {

2
pdd/pdd-transport--story-2--peer-a.js
View File

@ -7,7 +7,7 @@ const PeerInfo = require('peer-info')
const waterfall = require('async/waterfall') const waterfall = require('async/waterfall')
const pull = require('pull-stream') const pull = require('pull-stream')
const PeerA = require('libp2p-interop/peer-a.json') const PeerA = require('libp2p-interop/peer-a.json')
const PeerB = require('libp2p-interop/peer-B.json') const PeerB = require('libp2p-interop/peer-b.json')
class MyBundle extends libp2p { class MyBundle extends libp2p {
constructor (peerInfo) { constructor (peerInfo) {

8
pdd/pdd-transport--story-2--peer-b.js
View File

@ -6,7 +6,7 @@ const WebSockets = require('libp2p-websockets')
const PeerInfo = require('peer-info') const PeerInfo = require('peer-info')
const waterfall = require('async/waterfall') const waterfall = require('async/waterfall')
const pull = require('pull-stream') const pull = require('pull-stream')
const PeerB = require('libp2p-interop/peer-B.json') const PeerB = require('libp2p-interop/peer-b.json')
class MyBundle extends libp2p { class MyBundle extends libp2p {
constructor (peerInfo) { constructor (peerInfo) {
@ -35,14 +35,14 @@ test('story 2 - peerB', (t) => {
node.handle('/echo/1.0.0', (protocol, conn) => { node.handle('/echo/1.0.0', (protocol, conn) => {
pull( pull(
conn, conn,
conn, pull.through(v => v, err => {
pull.onEnd((err) => {
t.ifErr(err) t.ifErr(err)
t.pass('Received End of Connection') t.pass('Received End of Connection')
node.stop((err) => { node.stop((err) => {
t.ifErr(err, 'PeerB has stopped') t.ifErr(err, 'PeerB has stopped')
}) })
}) }),
conn
) )
}) })
}) })