Initial commit

Author: xuset

.gitignore

@@ -0,0 +1,3 @@
+*.swp
+node_modules
+npm-debug.log

.travis.yml

@@ -0,0 +1,8 @@
+language: node_js
+sudo: false
+node_js:
+- node
+env:
+  global:
+  - secure: EP8oid1it/TGaZkO2dfqDsBEw5GJwdRV+Cnso9L/6Gu+MRMY3YJ9Dgx8LBnHRWs+cJK0Zjg/ZX8b1ES+kMylDaCevjuY6veI83wBx717tq+oF5zLDiS1kmSN9LXCsAz5jzZePN/6/I5HswqlfDuNpdUB+RiykoKapOynPmwVAbUUGv2HgZ6lZCqANNsiALEjvfMfMVnDI6BynXLVqaawusx8dP2Af1seSDskllRfqDCMB2Cn1rWKvfJnCWnsNOMykjOWPwr/XTkHsL+qhWRci9jCstfN/ucKoeePjdJib2wtkiSyQp5P0cDzzHjb5Q3CYTNSTRl91RyvUb/EK0Kl9mrRjLwOSzF4JUvoglcTpL2zdmSDuLaYPZz43e7GbbeI5mCw9tohYXdSc3wOH5f+/iD2RKH/px0uO6I+xcXdtc9mMQwBU3kfKRcGpCxn32MP7UPABdjKoP8D7X7U3VtCiqzGv/KlHfsrHYWn0FPmgmZEkAhQzlldmqzaBVANd/MyP7lTiFwYFXGinFRROYrcm7L6eChnoyoYbCqmsnfQIFAsVNWDTRz0jPAR/0Qtjv1k7v9GHf5PT/r3wa+jHYsv9IjwF9P2a5oQeOq/ptQ7qZ+o7yxKDmJEvTbL5+NEtuuGII/E6lKlo0r2uPvoiGwGFlZ4ihmU7GEk1SEiTVJFfNY=
+  - secure: NG2ODujSmrz/7vuEaAxa4urAbQhuBnqz61ZzFe25/w7N9CwGue6/IW0EBrvBp1ERyU9iVDeYxAX2r3abSaRSgBctbf0rsQptZdVdFXcw1+MO5FAxukEJ9Cizyl+zJvZsOrBmEZMS1IbYq8MBnCkQXGwwSaxsF7xOXOf9Z9VRvpCtdfHQJ2bnw0WJiDESCyrOm09T2MFSdVBlCRQ7sR1Zj/sMicD5MCUUkMTGy9vvtw0nC5AZBfuvNe1yN4sFD4+SFRpMycLq5h40MQl9A2TB47lRGFjFDeXyYSV/CBoIAG9binz1bnnNLxYi8DV0hiBP/SUnt2Wo4u34lN6F6rBug6+8MU/dg0JHRTOI/tcanCVB06vf1iaYwmQc+aBjGkNG4K0tLOSDW9bxLlDfPUT/7OPcDJNfCHFsmGvu60WL9maY6/FTffGQvuC8CQ6wttG4weKVTBL3zXATUP5B/m/bIZD+q2BGwkSzpIqikm+otM9Uszd8Sy0vZ/31T/BFnUs9zS+q07RTnoiAuLmP49dmuMK+7h0KutGgorqe557WXAutJV0LqNVI8ydHrSh7hhuXULCDuFrC6G9Id32x/s/PM6ByIjYgSo8c+BhKdd1t5S39T3UeL8bNytFmmgJuCi594mh8I5xv6KDeGxEJc/7j9WBcJqAgn6P3KyXHXsKuR3E=

.zuul.yml

@@ -0,0 +1,12 @@
+ui: tape
+browsers:
+  - name: chrome
+    version: -1..latest
+  - name: firefox
+    version: -1..latest
+  - name: ie
+    version: latest
+  - name: edge
+    version: latest
+  - name: safari
+    version: latest

idbchunkstore.min.js

@@ -0,0 +1,64 @@
+module.exports = IdbChunkStore
+
+var IdbKvStore = require('idb-kv-store')
+
+function IdbChunkStore (chunkLength, opts) {
+  var self = this
+  if (!(this instanceof IdbChunkStore)) return new IdbChunkStore(chunkLength)
+  if (!opts) opts = {}
+
+  self.chunkLength = chunkLength
+  self._store = new IdbKvStore(opts.name || '' + Math.round(9e16 * Math.random()))
+}
+
+IdbChunkStore.prototype.put = function (index, buffer, cb) {
+  var self = this
+  if (!cb) cb = noop
+  if (!self._store) return cb(new Error('Store is closed'))
+  if (typeof index !== 'number') return cb(new Error('index must be a number'))
+  if (!buffer) return cb(new Error('buffer must be defined'))
+  if (buffer.length !== self.chunkLength) return cb(new Error('The buffer length must match the chunkLength'))
+  // TODO check if buffer is actually a buffer
+
+  self._store.set(index, buffer, cb)
+}
+
+IdbChunkStore.prototype.get = function (index, opts, cb) {
+  var self = this
+  if (typeof opts === 'function') return self.get(index, null, opts)
+  if (typeof cb !== 'function') throw new Error('cb must be a function')
+  if (!self._store) return cb(new Error('Store is closed'))
+  if (typeof index !== 'number') return cb(new Error('index must be a number'))
+  if (!opts) opts = {}
+
+  self._store.get(index, function (err, buffer) {
+    if (err) return cb(err)
+    if (typeof buffer === 'undefined') return cb(new Error('Chunk does not exist'))
+    var offset = 'offset' in opts ? opts.offset : 0
+    var length = 'length' in opts ? opts.length : buffer.length - offset
+    cb(null, buffer.slice(offset, offset + length))
+  })
+}
+
+IdbChunkStore.prototype.close = function (cb) {
+  var self = this
+  if (!cb) cb = noop
+  if (!self._store) return cb(new Error('Store is closed'))
+
+  self._store = null
+  cb(null)
+}
+
+IdbChunkStore.prototype.destroy = function (cb) {
+  var self = this
+  if (!cb) cb = noop
+  if (!self._store) return cb(new Error('Store is closed'))
+
+  var s = self._store
+  self._store = null
+  s.clear(cb)
+}
+
+function noop () {
+  // do nothing
+}

index.js

@@ -0,0 +1,40 @@
+{
+  "name": "idb-chunk-store",
+  "version": "1.0.0",
+  "description": "A Chunk Store compatible store backed by IndexDB",
+  "main": "index.js",
+  "scripts": {
+    "build": "standard && browserify -r . -s IdbChunkStore | uglifyjs -m > idbchunkstore.min.js",
+    "standard": "standard",
+    "test": "standard && zuul -- test.js",
+    "test-local": "standard && zuul --local -- test.js"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/xuset/idb-chunk-store.git"
+  },
+  "keywords": [
+    "abstract-chunk-store",
+    "chunk",
+    "store",
+    "indexdb",
+    "idb"
+  ],
+  "author": "xuset",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/xuset/idb-chunk-store/issues"
+  },
+  "homepage": "https://github.com/xuset/idb-chunk-store#readme",
+  "dependencies": {
+    "idb-kv-store": "^2.2.0"
+  },
+  "devDependencies": {
+    "abstract-chunk-store": "^1.2.1",
+    "browserify": "^13.1.1",
+    "standard": "^8.6.0",
+    "tape": "^4.6.3",
+    "uglify-js": "^2.7.4",
+    "zuul": "^3.11.1"
+  }
+}

package.json

@@ -0,0 +1,5 @@
+var IdbChunkStore = require('.')
+var abstractTests = require('abstract-chunk-store/tests')
+var test = require('tape')
+
+abstractTests(test, IdbChunkStore)