add missing src2/kiri

src2/kiri/files.js

@@ -0,0 +1,175 @@
+/** Copyright Stewart Allen <sa@grid.space> -- All Rights Reserved */
+
+class Files {
+    constructor(indexdb) {
+        let store = this;
+        this.db = indexdb;
+        this.files = {};
+        this.listeners = [];
+        this.deferredHandler = null;
+        this.concurrent = 0;
+        this.refresh();
+    }
+
+    get index() {
+        return this.db;
+    }
+
+    refresh() {
+        let store = this;
+        store.db.get('files', function(files) {
+            if (files) {
+                store.files = files;
+                notifyFileListeners(store);
+            }
+        });
+    };
+
+    wipe() {
+        let key, files = this.files;
+        for (key in files) {
+            if (files.hasOwnProperty(key)) this.deleteFile(key);
+        }
+    };
+
+    fileList() {
+        return this.files;
+    };
+
+    addFileListener(listener) {
+        if (!this.listeners.contains(listener)) {
+            this.listeners.push(listener);
+            listener(this.files);
+        }
+    };
+
+    removeFileListener(listener) {
+        this.listeners.remove(listener);
+    };
+
+    setDeferredHandler(handler) {
+        this.deferredHandler = handler;
+    };
+
+    putDeferred(name, mark) {
+        // triggers refresh callback
+        this.files[name] = {
+            deferred: mark
+        };
+        saveFileList(this);
+    };
+
+    /**
+     * @param {String} name
+     * @param {Float32Array} vertices
+     * @param {Function} [callback]
+     */
+    putFile(name, vertices, callback) {
+        console.log({ putFile: name, vertices });
+
+        let mark = Date.now();
+        let store = this;
+        let pdb = store.db.promise();
+        store.concurrent++;
+
+        function ondone(error) {
+            if (callback) callback(error);
+            if (--store.concurrent === 0) {
+                notifyFileListeners(store);
+            }
+        }
+
+        pdb.put(`file-${name}`, vertices)
+            .then(() => {
+                store.files[name] = {
+                    vertices: vertices.length / 3,
+                    updated: new Date().getTime()
+                };
+                return pdb.put('files', store.files);
+            })
+            .then(ondone)
+            .catch(ondone);
+    };
+
+    rename(name, newname, callback) {
+        if (!this.files[name]) return callback({error: 'no such file'});
+        if (!newname || newname == name) return callback({error: 'invalid new name'});
+        let done = 0;
+        let error = [];
+        let store = this;
+        function complete(ok, err) {
+            if (err) error.push(err);
+            if (++done === 1) {
+                store.files[newname] = store.files[name];
+                delete store.files[name];
+                saveFileList(store);
+                store.db.remove(`file-${name}`);
+                callback(error.length ? {error} : {});
+            }
+        }
+        store.db.get(`file-${name}`, (vertices) => {
+            if (!vertices) return complete(false, 'no raw file');
+            store.db.put(`file-${newname}`, vertices, complete);
+        });
+    };
+
+    /**
+     * @param {String} name
+     * @param {Function} callback
+     */
+    getFile(name, callback) {
+        let store = this,
+            rec = store.files[name];
+        if (rec && rec.deferred) {
+            if (store.deferredHandler) return store.deferredHandler(rec.deferred, name, callback);
+            return callback();
+        }
+        this.db.get('file-'+name, function(vertices) {
+            callback(vertices);
+        });
+    };
+
+    /**
+     * @param {String} name
+     * @param {Function} callback
+     */
+    deleteFile(name, callback) {
+        let store = this;
+        if (store.files[name]) {
+            delete store.files[name];
+            store.db.remove('file-'+name, function(ok) {
+                saveFileList(store);
+                if (callback) callback(ok);
+            });
+            return;
+        }
+        if (callback) callback(false);
+    };
+
+    deleteFilter(fn, from, to) {
+        this.db.keys(keys => {
+            for (let key of keys) {
+                if (fn(key)) {
+                    this.db.remove(key);
+                }
+            }
+        }, from, to);
+    }
+}
+
+function saveFileList(store) {
+    store.db.put('files', store.files);
+    notifyFileListeners(store);
+}
+
+function notifyFileListeners(store) {
+    for (let i=0; i<store.listeners.length; i++) {
+        store.listeners[i](store.files);
+    }
+}
+
+export const openFiles = function(indexdb) {
+    return new Files(indexdb);
+};
+
+export { saveFileList, notifyFileListeners };