ipfs · Jul 3, 2015 · Jul 5, 2015 · Jul 5, 2015 · Jul 5, 2015 · Jul 6, 2015
diff --git a/.gitignore b/.gitignore
@@ -1 +1,2 @@
-node_modules/
+**/node_modules/
+**/*.log
diff --git a/README.md b/README.md
@@ -1,7 +1,14 @@
-# ipfs implementation in node.
+# THIS REPO IS DEPRECATED
 
+### Check the new node-ipfs roadmap and respective code at: https://github.com/ipfs/node-ipfs
 
-# This is a work in progress. it's not ready yet. we'll be pushing efforts into this implementation shortly. stay tuned + come hang out on irc.
+
+===================================
+
+
+
+
+> This is a work in progress. it's not ready yet. we'll be pushing efforts into this implementation shortly. stay tuned + come hang out on irc.
 
 `#ipfs` on freenode.
 

diff --git a/Makefile → legacy-Makefile b/Makefile → legacy-Makefile
diff --git a/index.js → legacy-index.js b/index.js → legacy-index.js
diff --git a/submodules/README.md → legacy-submodules/README.md b/submodules/README.md → legacy-submodules/README.md
diff --git a/submodules/ipfs-bitswap/index.js → legacy-submodules/ipfs-bitswap/index.js b/submodules/ipfs-bitswap/index.js → legacy-submodules/ipfs-bitswap/index.js
diff --git a/submodules/ipfs-block/README.md → legacy-submodules/ipfs-block/README.md b/submodules/ipfs-block/README.md → legacy-submodules/ipfs-block/README.md
diff --git a/submodules/ipfs-block/index.js → legacy-submodules/ipfs-block/index.js b/submodules/ipfs-block/index.js → legacy-submodules/ipfs-block/index.js
diff --git a/submodules/ipfs-block/package.json → legacy-submodules/ipfs-block/package.json b/submodules/ipfs-block/package.json → legacy-submodules/ipfs-block/package.json
diff --git a/submodules/ipfs-blocks/README.md → legacy-submodules/ipfs-blocks/README.md b/submodules/ipfs-blocks/README.md → legacy-submodules/ipfs-blocks/README.md
diff --git a/submodules/ipfs-blocks/index.js → legacy-submodules/ipfs-blocks/index.js b/submodules/ipfs-blocks/index.js → legacy-submodules/ipfs-blocks/index.js
diff --git a/submodules/ipfs-blocks/package.json → legacy-submodules/ipfs-blocks/package.json b/submodules/ipfs-blocks/package.json → legacy-submodules/ipfs-blocks/package.json
diff --git a/submodules/ipfs-cli/README.md → legacy-submodules/ipfs-cli/README.md b/submodules/ipfs-cli/README.md → legacy-submodules/ipfs-cli/README.md
diff --git a/submodules/ipfs-cli/add.js → legacy-submodules/ipfs-cli/add.js b/submodules/ipfs-cli/add.js → legacy-submodules/ipfs-cli/add.js
diff --git a/submodules/ipfs-cli/cat.js → legacy-submodules/ipfs-cli/cat.js b/submodules/ipfs-cli/cat.js → legacy-submodules/ipfs-cli/cat.js
diff --git a/submodules/ipfs-cli/cli.js → legacy-submodules/ipfs-cli/cli.js b/submodules/ipfs-cli/cli.js → legacy-submodules/ipfs-cli/cli.js
diff --git a/submodules/ipfs-cli/index.js → legacy-submodules/ipfs-cli/index.js b/submodules/ipfs-cli/index.js → legacy-submodules/ipfs-cli/index.js
diff --git a/submodules/ipfs-cli/ls.js → legacy-submodules/ipfs-cli/ls.js b/submodules/ipfs-cli/ls.js → legacy-submodules/ipfs-cli/ls.js
diff --git a/submodules/ipfs-cli/mount.js → legacy-submodules/ipfs-cli/mount.js b/submodules/ipfs-cli/mount.js → legacy-submodules/ipfs-cli/mount.js
diff --git a/submodules/ipfs-cli/package.json → legacy-submodules/ipfs-cli/package.json b/submodules/ipfs-cli/package.json → legacy-submodules/ipfs-cli/package.json
diff --git a/submodules/ipfs-cli/refs.js → legacy-submodules/ipfs-cli/refs.js b/submodules/ipfs-cli/refs.js → legacy-submodules/ipfs-cli/refs.js
diff --git a/submodules/ipfs-core/index.js → legacy-submodules/ipfs-core/index.js b/submodules/ipfs-core/index.js → legacy-submodules/ipfs-core/index.js
diff --git a/submodules/ipfs-core/package.json → legacy-submodules/ipfs-core/package.json b/submodules/ipfs-core/package.json → legacy-submodules/ipfs-core/package.json
diff --git a/submodules/ipfs-core/try/ipfs-nc.js → legacy-submodules/ipfs-core/try/ipfs-nc.js b/submodules/ipfs-core/try/ipfs-nc.js → legacy-submodules/ipfs-core/try/ipfs-nc.js
diff --git a/submodules/ipfs-dht-routing/index.js → legacy-submodules/ipfs-dht-routing/index.js b/submodules/ipfs-dht-routing/index.js → legacy-submodules/ipfs-dht-routing/index.js
diff --git a/submodules/ipfs-dht/index.js → legacy-submodules/ipfs-dht/index.js b/submodules/ipfs-dht/index.js → legacy-submodules/ipfs-dht/index.js
diff --git a/submodules/ipfs-dht/js/routing-table.js → ...y-submodules/ipfs-dht/js/routing-table.js b/submodules/ipfs-dht/js/routing-table.js → ...y-submodules/ipfs-dht/js/routing-table.js
diff --git a/submodules/ipfs-dht/package.json → legacy-submodules/ipfs-dht/package.json b/submodules/ipfs-dht/package.json → legacy-submodules/ipfs-dht/package.json
diff --git a/submodules/ipfs-errors/index.js → legacy-submodules/ipfs-errors/index.js b/submodules/ipfs-errors/index.js → legacy-submodules/ipfs-errors/index.js
diff --git a/submodules/ipfs-message/README.md → legacy-submodules/ipfs-message/README.md b/submodules/ipfs-message/README.md → legacy-submodules/ipfs-message/README.md
diff --git a/submodules/ipfs-message/index.js → legacy-submodules/ipfs-message/index.js b/submodules/ipfs-message/index.js → legacy-submodules/ipfs-message/index.js
diff --git a/submodules/ipfs-message/message.proto → legacy-submodules/ipfs-message/message.proto b/submodules/ipfs-message/message.proto → legacy-submodules/ipfs-message/message.proto
diff --git a/submodules/ipfs-message/test.js → legacy-submodules/ipfs-message/test.js b/submodules/ipfs-message/test.js → legacy-submodules/ipfs-message/test.js
diff --git a/submodules/ipfs-mount/README.md → legacy-submodules/ipfs-mount/README.md b/submodules/ipfs-mount/README.md → legacy-submodules/ipfs-mount/README.md
diff --git a/submodules/ipfs-mount/cli.js → legacy-submodules/ipfs-mount/cli.js b/submodules/ipfs-mount/cli.js → legacy-submodules/ipfs-mount/cli.js
diff --git a/submodules/ipfs-mount/destroy.js → legacy-submodules/ipfs-mount/destroy.js b/submodules/ipfs-mount/destroy.js → legacy-submodules/ipfs-mount/destroy.js
diff --git a/submodules/ipfs-mount/fuse.js → legacy-submodules/ipfs-mount/fuse.js b/submodules/ipfs-mount/fuse.js → legacy-submodules/ipfs-mount/fuse.js
diff --git a/submodules/ipfs-mount/index.js → legacy-submodules/ipfs-mount/index.js b/submodules/ipfs-mount/index.js → legacy-submodules/ipfs-mount/index.js
diff --git a/submodules/ipfs-mount/package.json → legacy-submodules/ipfs-mount/package.json b/submodules/ipfs-mount/package.json → legacy-submodules/ipfs-mount/package.json
diff --git a/submodules/ipfs-mount/umount.js → legacy-submodules/ipfs-mount/umount.js b/submodules/ipfs-mount/umount.js → legacy-submodules/ipfs-mount/umount.js
diff --git a/submodules/ipfs-network-pipe/README.md → ...cy-submodules/ipfs-network-pipe/README.md b/submodules/ipfs-network-pipe/README.md → ...cy-submodules/ipfs-network-pipe/README.md
diff --git a/submodules/ipfs-network-pipe/addr.js → legacy-submodules/ipfs-network-pipe/addr.js b/submodules/ipfs-network-pipe/addr.js → legacy-submodules/ipfs-network-pipe/addr.js
diff --git a/submodules/ipfs-network-pipe/index.js → legacy-submodules/ipfs-network-pipe/index.js b/submodules/ipfs-network-pipe/index.js → legacy-submodules/ipfs-network-pipe/index.js
diff --git a/submodules/ipfs-network-pipe/package.json → ...submodules/ipfs-network-pipe/package.json b/submodules/ipfs-network-pipe/package.json → ...submodules/ipfs-network-pipe/package.json
diff --git a/submodules/ipfs-network-pipe/scoped-pair.js → ...bmodules/ipfs-network-pipe/scoped-pair.js b/submodules/ipfs-network-pipe/scoped-pair.js → ...bmodules/ipfs-network-pipe/scoped-pair.js
diff --git a/submodules/ipfs-network-pipe/test.js → legacy-submodules/ipfs-network-pipe/test.js b/submodules/ipfs-network-pipe/test.js → legacy-submodules/ipfs-network-pipe/test.js
diff --git a/submodules/ipfs-network-pipe/wire.js → legacy-submodules/ipfs-network-pipe/wire.js b/submodules/ipfs-network-pipe/wire.js → legacy-submodules/ipfs-network-pipe/wire.js
diff --git a/submodules/ipfs-network/README.md → legacy-submodules/ipfs-network/README.md b/submodules/ipfs-network/README.md → legacy-submodules/ipfs-network/README.md
diff --git a/submodules/ipfs-network/index.js → legacy-submodules/ipfs-network/index.js b/submodules/ipfs-network/index.js → legacy-submodules/ipfs-network/index.js
diff --git a/submodules/ipfs-network/test.js → legacy-submodules/ipfs-network/test.js b/submodules/ipfs-network/test.js → legacy-submodules/ipfs-network/test.js
diff --git a/submodules/ipfs-object/README.md → legacy-submodules/ipfs-object/README.md b/submodules/ipfs-object/README.md → legacy-submodules/ipfs-object/README.md
diff --git a/submodules/ipfs-object/index.js → legacy-submodules/ipfs-object/index.js b/submodules/ipfs-object/index.js → legacy-submodules/ipfs-object/index.js
diff --git a/submodules/ipfs-object/object.proto → legacy-submodules/ipfs-object/object.proto b/submodules/ipfs-object/object.proto → legacy-submodules/ipfs-object/object.proto
diff --git a/submodules/ipfs-object/package.json → legacy-submodules/ipfs-object/package.json b/submodules/ipfs-object/package.json → legacy-submodules/ipfs-object/package.json
diff --git a/submodules/ipfs-object/test.js → legacy-submodules/ipfs-object/test.js b/submodules/ipfs-object/test.js → legacy-submodules/ipfs-object/test.js
diff --git a/submodules/ipfs-objects-git/README.md → legacy-submodules/ipfs-objects-git/README.md b/submodules/ipfs-objects-git/README.md → legacy-submodules/ipfs-objects-git/README.md
diff --git a/submodules/ipfs-objects-git/block.js → legacy-submodules/ipfs-objects-git/block.js b/submodules/ipfs-objects-git/block.js → legacy-submodules/ipfs-objects-git/block.js
diff --git a/submodules/ipfs-objects-git/commit.js → legacy-submodules/ipfs-objects-git/commit.js b/submodules/ipfs-objects-git/commit.js → legacy-submodules/ipfs-objects-git/commit.js
diff --git a/...odules/ipfs-objects-git/git-objects.proto → ...odules/ipfs-objects-git/git-objects.proto b/...odules/ipfs-objects-git/git-objects.proto → ...odules/ipfs-objects-git/git-objects.proto
diff --git a/submodules/ipfs-objects-git/index.js → legacy-submodules/ipfs-objects-git/index.js b/submodules/ipfs-objects-git/index.js → legacy-submodules/ipfs-objects-git/index.js
diff --git a/submodules/ipfs-objects-git/list.js → legacy-submodules/ipfs-objects-git/list.js b/submodules/ipfs-objects-git/list.js → legacy-submodules/ipfs-objects-git/list.js
diff --git a/submodules/ipfs-objects-git/package.json → ...-submodules/ipfs-objects-git/package.json b/submodules/ipfs-objects-git/package.json → ...-submodules/ipfs-objects-git/package.json
diff --git a/submodules/ipfs-objects-git/test.js → legacy-submodules/ipfs-objects-git/test.js b/submodules/ipfs-objects-git/test.js → legacy-submodules/ipfs-objects-git/test.js
diff --git a/submodules/ipfs-objects-git/tree.js → legacy-submodules/ipfs-objects-git/tree.js b/submodules/ipfs-objects-git/tree.js → legacy-submodules/ipfs-objects-git/tree.js
diff --git a/submodules/ipfs-objects-git/types.js → legacy-submodules/ipfs-objects-git/types.js b/submodules/ipfs-objects-git/types.js → legacy-submodules/ipfs-objects-git/types.js
diff --git a/submodules/ipfs-path-resolver/README.md → ...y-submodules/ipfs-path-resolver/README.md b/submodules/ipfs-path-resolver/README.md → ...y-submodules/ipfs-path-resolver/README.md
diff --git a/submodules/ipfs-path-resolver/index.js → ...cy-submodules/ipfs-path-resolver/index.js b/submodules/ipfs-path-resolver/index.js → ...cy-submodules/ipfs-path-resolver/index.js
diff --git a/submodules/ipfs-path-resolver/package.json → ...ubmodules/ipfs-path-resolver/package.json b/submodules/ipfs-path-resolver/package.json → ...ubmodules/ipfs-path-resolver/package.json
diff --git a/submodules/ipfs-path-resolver/test.js → legacy-submodules/ipfs-path-resolver/test.js b/submodules/ipfs-path-resolver/test.js → legacy-submodules/ipfs-path-resolver/test.js
diff --git a/submodules/ipfs-path/README.md → legacy-submodules/ipfs-path/README.md b/submodules/ipfs-path/README.md → legacy-submodules/ipfs-path/README.md
diff --git a/submodules/ipfs-path/index.js → legacy-submodules/ipfs-path/index.js b/submodules/ipfs-path/index.js → legacy-submodules/ipfs-path/index.js
diff --git a/submodules/ipfs-path/package.json → legacy-submodules/ipfs-path/package.json b/submodules/ipfs-path/package.json → legacy-submodules/ipfs-path/package.json
diff --git a/submodules/ipfs-path/test.js → legacy-submodules/ipfs-path/test.js b/submodules/ipfs-path/test.js → legacy-submodules/ipfs-path/test.js
diff --git a/submodules/ipfs-peer-book/README.md → legacy-submodules/ipfs-peer-book/README.md b/submodules/ipfs-peer-book/README.md → legacy-submodules/ipfs-peer-book/README.md
diff --git a/submodules/ipfs-peer-book/index.js → legacy-submodules/ipfs-peer-book/index.js b/submodules/ipfs-peer-book/index.js → legacy-submodules/ipfs-peer-book/index.js
diff --git a/submodules/ipfs-peer-book/package.json → ...cy-submodules/ipfs-peer-book/package.json b/submodules/ipfs-peer-book/package.json → ...cy-submodules/ipfs-peer-book/package.json
diff --git a/submodules/ipfs-peer-book/test.js → legacy-submodules/ipfs-peer-book/test.js b/submodules/ipfs-peer-book/test.js → legacy-submodules/ipfs-peer-book/test.js
diff --git a/submodules/ipfs-peer/README.md → legacy-submodules/ipfs-peer/README.md b/submodules/ipfs-peer/README.md → legacy-submodules/ipfs-peer/README.md
diff --git a/submodules/ipfs-peer/index.js → legacy-submodules/ipfs-peer/index.js b/submodules/ipfs-peer/index.js → legacy-submodules/ipfs-peer/index.js
diff --git a/submodules/ipfs-peer/package.json → legacy-submodules/ipfs-peer/package.json b/submodules/ipfs-peer/package.json → legacy-submodules/ipfs-peer/package.json
diff --git a/submodules/ipfs-peer/test.js → legacy-submodules/ipfs-peer/test.js b/submodules/ipfs-peer/test.js → legacy-submodules/ipfs-peer/test.js
diff --git a/submodules/ipfs-storage/README.md → legacy-submodules/ipfs-storage/README.md b/submodules/ipfs-storage/README.md → legacy-submodules/ipfs-storage/README.md
diff --git a/submodules/ipfs-storage/index.js → legacy-submodules/ipfs-storage/index.js b/submodules/ipfs-storage/index.js → legacy-submodules/ipfs-storage/index.js
diff --git a/submodules/ipfs-storage/package.json → legacy-submodules/ipfs-storage/package.json b/submodules/ipfs-storage/package.json → legacy-submodules/ipfs-storage/package.json
diff --git a/submodules/ipfs-storage/test.js → legacy-submodules/ipfs-storage/test.js b/submodules/ipfs-storage/test.js → legacy-submodules/ipfs-storage/test.js
diff --git a/submodules/npm-install.sh → legacy-submodules/npm-install.sh b/submodules/npm-install.sh → legacy-submodules/npm-install.sh
diff --git a/package.json b/package.json
@@ -1,10 +1,11 @@
 {
   "name": "ipfs",
-  "version": "0.1.1",
+  "version": "0.0.0",
   "description": "ipfs implementation in node",
-  "main": "index.js",
+  "main": "src/index.js",
   "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "test": "echo \"Error: no test specified\" && exit 1",
+    "start": "IPFS_LOG=* node src/index.js | ./node_modules/.bin/bunyan -o short"
   },
   "repository": {
     "type": "git",
@@ -18,5 +19,17 @@
   "bugs": {
     "url": "https://github.com/jbenet/node-ipfs/issues"
   },
-  "homepage": "https://github.com/jbenet/node-ipfs"
+  "homepage": "https://github.com/jbenet/node-ipfs",
+  "devDependencies": {
+    "standard": "^4.5.1"
+  },
+  "dependencies": {
+    "bs58": "^2.0.1",
+    "bunyan": "^1.4.0",
+    "k-bucket": "^0.5.0",
+    "multiaddr": "^0.1.2",
+    "multicast-dns": "^2.2.0",
+    "multihashing": "^0.1.2",
+    "network": "^0.1.3"
+  }
 }
diff --git a/src/index.js b/src/index.js
@@ -0,0 +1,5 @@
+var Routing = require('./routing')
+
+var r = new Routing()
+
+r.start()
diff --git a/src/routing/discovery/mdns/index.js b/src/routing/discovery/mdns/index.js
@@ -0,0 +1,107 @@
+var mdns = require('multicast-dns')()
+var Id = require('./../../routers/dht/peer/id')
+var Peer = require('./../../routers/dht/peer')
+var Multiaddr = require('multiaddr')
+var log = require('ipfs-logger').group('discovery')
+
+exports = module.exports = sonar
+
+function sonar (cb) {
+  var serviceTag = 'discovery.ipfs.io.local'
+
+  mdns.on('warning', function (err) {
+    cb(err)
+  })
+
+  mdns.on('response', function (response) {
+    if (!response.answers) {
+      return
+    }
+
+    var answers = {
+      ptr: {},
+      srv: {},
+      txt: {},
+      a: []
+    }
+
+    response.answers.forEach(function (answer) {
+      switch (answer.type) {
+        case 'PTR': answers.ptr = answer; break
+        case 'SRV': answers.srv = answer; break
+        case 'TXT': answers.txt = answer; break
+        case 'A': answers.a.push(answer); break
+        default: break
+      }
+    })
+
+    if (answers.ptr.name !== serviceTag) {
+      return
+    }
+
+    var b58Id = answers.txt.data
+    var port = answers.srv.data.port
+    var multiaddrs = []
+
+    answers.a.forEach(function (a) {
+      multiaddrs.push(new Multiaddr('/ip4/' + a.data + '/tcp/' + port))
+    })
+
+    log.info('peer found -', b58Id)
+    var peerId = Id.createFromB58String(b58Id)
+    cb(null, new Peer(peerId, multiaddrs))
+  })
+
+  mdns.on('query', function (query) {
+    // answer with PTR, SRV and A for several IP addr
+  })
+
+  setInterval(function () {
+    mdns.query({
+      questions: [{
+        name: serviceTag,
+        type: 'PTR'
+      }]
+    })
+  }, 1e3 * 5)
+}
+
+/* for reference
+
+   [ { name: 'discovery.ipfs.io.local',
+       type: 'PTR',
+       class: 1,
+       ttl: 120,
+       data: 'QmbBHw1Xx9pUpAbrVZUKTPL5Rsph5Q9GQhRvcWVBPFgGtC.discovery.ipfs.io.local' },
+
+     { name: 'QmbBHw1Xx9pUpAbrVZUKTPL5Rsph5Q9GQhRvcWVBPFgGtC.discovery.ipfs.io.local',
+       type: 'SRV',
+       class: 1,
+       ttl: 120,
+       data: { priority: 10, weight: 1, port: 4001, target: 'lorien.local' } },
+
+     { name: 'lorien.local',
+       type: 'A',
+       class: 1,
+       ttl: 120,
+       data: '127.0.0.1' },
+
+     { name: 'lorien.local',
+       type: 'A',
+       class: 1,
+       ttl: 120,
+       data: '127.94.0.1' },
+
+     { name: 'lorien.local',
+       type: 'A',
+       class: 1,
+       ttl: 120,
+       data: '172.16.38.224' },
+
+     { name: 'QmbBHw1Xx9pUpAbrVZUKTPL5Rsph5Q9GQhRvcWVBPFgGtC.discovery.ipfs.io.local',
+       type: 'TXT',
+       class: 1,
+       ttl: 120,
+       data: 'QmbBHw1Xx9pUpAbrVZUKTPL5Rsph5Q9GQhRvcWVBPFgGtC' } ],
+
+*/
diff --git a/src/routing/index.js b/src/routing/index.js
@@ -0,0 +1,76 @@
+/*
+ * routing/index.js Routing is the front door for everything that happens on the routing layer.
+ * Other modules present in the remaining layers should not require to interact with modules
+ * behind this level
+ */
+
+var mDNSDiscovery = require('./discovery/mdns')
+var Peer = require('./routers/dht/peer')
+var Id = require('./routers/dht/peer/id')
+var network = require('network')
+var Multiaddr = require('multiaddr')
+var DHT = require('./routers/dht')
+
+exports = module.exports = Routing
+
+function Routing () {
+  var self = this
+
+  if (!(self instanceof Routing)) {
+    throw new Error('Routing should be called with new')
+  }
+
+  self.router
+  self.peer
+
+  // instantiate this peer
+
+  self.start = function (cb) {
+    network.get_private_ip(function (err, ip) {
+      if (err) {
+        cb(err)
+      }
+      var multiaddrs = []
+      multiaddrs.push(new Multiaddr('/ip4/' + ip + '/tcp/' + 4001))
+      self.peer = new Peer(Id.create(), multiaddrs)
+      self.useRouterDHT()
+      self.useDiscoveryMDNS()
+      if (cb) {
+        cb()
+      }
+    })
+  }
+
+  // routing interface
+
+  self.putValue = function (key, buf) {}
+  self.getValue = function (key) {}
+  self.provide = function (key) {}
+  self.findPeer = function (key) {}
+  self.ping = function (key) {}
+
+  // select strategies (plugins) used
+
+  self.useRouterDHT = function () {
+    self.router = new DHT(self.peer)
+  }
+
+  self.useRouterMDNS = function () {}
+
+  self.useDiscoveryBootstrapList = function () {}
+
+  self.useDiscoveryMDNS = function () {
+    mDNSDiscovery(function (err, peer) {
+      if (err) {
+        return console.log('mDNS Discovery err: ', err)
+      }
+      self.router.addPeer(peer)
+    })
+  }
+
+  self.useDiscoveryRandomWalk = function () {
+    // use router to find a random peer
+  }
+
+}
+
diff --git a/src/routing/routers/dht/index.js b/src/routing/routers/dht/index.js
@@ -0,0 +1,46 @@
+/*
+ * DHT routing plugin for router
+ */
+
+var KBucket = require('k-bucket')
+var log = require('ipfs-logger').group('router')
+
+exports = module.exports = DHT
+
+function DHT (peerSelf) {
+  var self = this
+
+  if (!(self instanceof DHT)) {
+    throw new Error('DHT must be called with new')
+  }
+
+  var kBucket = new KBucket({
+    localNodeId: peerSelf.id.toBytes(),
+    numberOfNodesPerKBucket: 20 // same as go-ipfs
+  })
+
+  kBucket.on('ping', function (oldContacts, newContact) {
+    log.info('kbucket ping')
+    log.info('old', oldContacts)
+    log.info('new', newContact)
+    // 1. ping each oldContact
+    // 2. those who respond should be readded (kBucket.add)
+    // 3. those who didn't respond should be removed (kBucket.remove)
+    // 4. if at least one is removed, then newContact can be added (kBucket.add)
+  })
+
+  self.addPeer = function (peer) {
+    log.info('New DHT candidate -', peer.id.toB58String())
+    kBucket.add({
+      id: peer.id.toBytes(),
+      peer: peer
+    })
+  }
+
+  self.candidatesToId = function (id) {
+    return kBucket.closest({
+      id: id.toBytes(),
+      n: 3
+    })
+  }
+}
diff --git a/src/routing/routers/dht/peer/id.js b/src/routing/routers/dht/peer/id.js
@@ -0,0 +1,79 @@
+/*
+ * Id is an object representation of a peer Id. a peer Id is a multihash
+ */
+
+var multihashing = require('multihashing')
+var base58 = require('bs58')
+var crypto = require('crypto')
+
+exports = module.exports = Id
+
+function Id (id, pubKey, privKey) {
+  var self = this
+
+  if (!(self instanceof Id)) {
+    throw new Error('Id must be called with new')
+  }
+
+  self.privKey = privKey
+  self.pubKey = pubKey
+  self.id = id // multihash - sha256 - buffer
+
+  // pretty print
+
+  self.toPrint = function () {
+    return {
+      id: id.toHexString(),
+      privKey: privKey.toString('hex'),
+      pubKey: pubKey.toString('hex')
+    }
+  }
+
+  // encode/decode functions
+
+  self.toHexString = function () {
+    return self.id.toString('hex')
+  }
+
+  self.toBytes = function () {
+    return self.id
+  }
+
+  self.toB58String = function () {
+    return base58.encode(self.id)
+  }
+
+}
+
+// generation
+
+exports.create = function () {
+  var ecdh = crypto.createECDH('secp256k1')
+  ecdh.generateKeys()
+
+  var mhId = multihashing(ecdh.getPublicKey(), 'sha2-256')
+
+  return new Id(mhId, ecdh.getPrivateKey(), ecdh.getPublicKey())
+}
+
+exports.createFromHexString = function (str) {
+  return new Id(new Buffer(str), 'hex')
+}
+
+exports.createFromBytes = function (buf) {
+  return new Id(buf)
+}
+
+exports.createFromB58String = function (str) {
+  return new Id(new Buffer(base58.decode(str)))
+}
+
+exports.createFromPubKey = function (pubKey) {
+  var mhId = multihashing(pubKey, 'sha2-256')
+
+  return new Id(mhId, null, pubKey)
+}
+
+exports.createFromPrivKey = function () {
+  // TODO(daviddias) derive PubKey from priv
+}
diff --git a/src/routing/routers/dht/peer/index.js b/src/routing/routers/dht/peer/index.js
@@ -0,0 +1,22 @@
+/*
+ * Peer represents a peer on the IPFS network
+ */
+
+var Id = require('./id.js')
+
+exports = module.exports = Peer
+
+function Peer (peerId, multiaddrs) {
+  var self = this
+
+  if (!(self instanceof Peer)) {
+    throw new Error('Peer must be called with new')
+  }
+
+  if (!(peerId instanceof Id)) {
+    throw new Error('Peer must be created with an instance of Id')
+  }
+
+  self.id = peerId
+  self.multiaddrs = multiaddrs
+}