dat - npm Package Compare versions

Comparing version 9.6.0 to 9.7.0

cli.js

@@ -27,3 +27,6 @@ #!/usr/bin/env node
 var dns = require('dns-discovery')
+var swarm = require('discovery-swarm')
 var chalk = require('chalk')
+var crypto = require('crypto')
+var pump = require('pump')
 var dat = require('./index.js')
@@ -62,10 +65,48 @@ var usage = require('./usage')
 
-  client.whoami(function (err, me) {
-    if (err) return console.error('Could not detect public ip / port')
-    console.log('Public IP: ' + me.host)
-    console.log('Your public port was ' + (me.port ? 'consistent' : 'inconsistent') + ' across remote multiple hosts')
-    if (!me.port) console.log('Looks like you are behind a symmetric nat. Try enabling upnp.')
-    else console.log('Looks like you can accept incoming p2p connections.')
-    client.destroy()
+  var id = typeof args.doctor === 'string' ? args.doctor : crypto.randomBytes(32).toString('hex')
+  var sw = swarm({
+    dns: {
+      servers: dat.DNS_SERVERS
+    }
   })
+
+  sw.on('error', function () {
+    sw.listen(0)
+  })
+  sw.listen(3282)
+  sw.on('listening', function () {
+    client.whoami(function (err, me) {
+      if (err) return console.error('Could not detect public ip / port')
+      console.log('Public IP: ' + me.host)
+      console.log('Your public port was ' + (me.port ? 'consistent' : 'inconsistent') + ' across remote multiple hosts')
+      if (!me.port) console.log('Looks like you are behind a symmetric nat. Try enabling upnp.')
+      else console.log('Looks like you can accept incoming p2p connections.')
+      client.destroy()
+      sw.add(id)
+      sw.on('connection', function (connection) {
+        var data = crypto.randomBytes(16).toString('hex')
+        console.log('[%s] Connection established to remote peer', data)
+        var buf = ''
+        connection.setEncoding('utf-8')
+        connection.write(data)
+        connection.on('data', function (remote) {
+          buf += remote
+          if (buf.length === data.length) {
+            console.log('[%s] Remote peer echoed expected data back', data)
+          }
+        })
+        pump(connection, connection, function () {
+          console.log('[%s] Connected closed', data)
+        })
+      })
+
+      console.log('')
+      console.log('To test p2p connectivity ppen another client on another computer and run:')
+      console.log('')
+      console.log('  dat --doctor=' + id)
+      console.log('')
+      console.log('Waiting for incoming connections... (local port: %d)', sw.address().port)
+      console.log('')
+    })
+  })
 }
@@ -72,0 +113,0 @@

package.json

 {
   "name": "dat",
-  "version": "9.6.0",
+  "version": "9.7.0",
   "description": "Share datasets on the Internet",
@@ -5,0 +5,0 @@ "keywords": [

No alert changes

Improved metrics

Total package byte prevSize

41273

increased by3.37%

Lines of code

881

increased by4.63%

No dependency changes