feat(object): add lru cache to object get/put

Author: daviddias

package.json

@@ -28,6 +28,7 @@
     "ipfs-merkle-dag": "^0.7.1",
     "is-ipfs": "^0.2.0",
     "isstream": "^0.1.2",
+    "lru-cache": "^4.0.1",
     "multiaddr": "^2.0.2",
     "multipart-stream": "^2.0.1",
     "ndjson": "^1.4.3",
@@ -103,4 +104,4 @@
     "url": "https://github.com/ipfs/js-ipfs-api/issues"
   },
   "homepage": "https://github.com/ipfs/js-ipfs-api"
-}
+}

src/api/object.js

@@ -6,6 +6,12 @@ const promisify = require('promisify-es6')
 const bs58 = require('bs58')
 const bl = require('bl')
 const cleanMultihash = require('../clean-multihash')
+const LRU = require('lru-cache')
+const lruOptions = {
+  max: 128
+}
+
+const cache = LRU(lruOptions)
 
 module.exports = (send) => {
   const api = {
@@ -14,6 +20,7 @@ module.exports = (send) => {
         callback = options
         options = {}
       }
+
       if (!options) {
         options = {}
       }
@@ -24,6 +31,12 @@ module.exports = (send) => {
         return callback(err)
       }
 
+      const node = cache.get(multihash)
+
+      if (node) {
+        return callback(null, node)
+      }
+
       send({
         path: 'object/get',
         args: multihash
@@ -37,9 +50,12 @@ module.exports = (send) => {
             return new DAGLink(l.Name, l.Size, new Buffer(bs58.decode(l.Hash)))
           }))
 
+        cache.set(multihash, node)
+
         callback(null, node)
       })
     }),
+
     put: promisify((obj, options, callback) => {
       if (typeof options === 'function') {
         callback = options
@@ -107,6 +123,8 @@ module.exports = (send) => {
           return callback(new Error('Stored object was different from constructed object'))
         }
 
+        cache.set(result.Hash, node)
+
         callback(null, node)
       })
     }),