LevelDB radisk adapter

.editorconfig

@@ -0,0 +1,15 @@
+# 2d0e4a3f-ac19-430c-bf1b-46c68651ce21
+root = true
+
+[*]
+end_of_line = lf
+insert_final_newline = true
+charset = utf-8
+indent_size = 2
+indent_style = space
+
+[*.{php,html}]
+indent_size = 4
+
+[Makefile*]
+indent_style = tab

lib/rlevel.js

@@ -0,0 +1,69 @@
+var Gun   = ('undefined' !== typeof window) ? window.Gun : require('../gun');
+var debug = false;
+
+// Adds opts.level, where the value is an initialized levelup (or compatible) instance
+Gun.on('create', function(root) {
+  this.to.next(root);
+  var opt = root.opt;
+
+  if (debug) debug.emit('create');
+
+  // Check if the given 'level' argument implements all the components we need
+  // Intentionally doesn't check for levelup explicitly, to allow different handlers implementing the same api
+  if (
+    (!opt.level) ||
+    ('object' !== typeof opt.level) ||
+    ('function' !== typeof opt.level.get) ||
+    ('function' !== typeof opt.level.put)
+  ) {
+    return;
+  }
+
+  // Register our store
+  opt.store = opt.store || factory(opt);
+});
+
+function factory(opt) {
+  if (debug) debug.emit('factory');
+
+  var level = opt.level;
+  var store = {};
+
+  store.put = function(key, data, cb) {
+    if (debug) debug.emit('put', key, data);
+    level.put(key, data, function(err) {
+      if (debug && err) debug.emit('error', err);
+      cb(err, 'level');
+    });
+  };
+
+  store.get = function(key, cb) {
+    if (debug) debug.emit('get', key);
+    level.get(key, function(err, data) {
+      if (err && (err.name === 'NotFoundError')) err = undefined;
+      if (debug && err) debug.emit('error', err);
+      cb(err, data);
+    });
+  };
+
+  store.list = function(cb, match, params, cbs){
+    if (debug) debug.emit('list');
+    level
+      .createKeyStream()
+      .on('data', function(key) {
+        console.log("KEY", key);
+        cb(key);
+      })
+      .on('end', function() {
+        cb();
+      });
+  };
+
+  return store;
+}
+
+// Export debug interface
+if ('undefined' === typeof window) {
+  var EventEmitter = require('events').EventEmitter;
+  module.exports = debug = new EventEmitter();
+}

package.json

@@ -78,6 +78,8 @@
     "@types/ws": "^7.2.1",
     "aws-sdk": "^2.528.0",
     "ip": "^1.1.5",
+    "leveldown": "^5.6.0",
+    "levelup": "^4.4.0",
     "mocha": "^6.2.0",
     "panic-manager": "^1.2.0",
     "panic-server": "^1.1.1",