Mercurial > code > home > repos > streamed-graph

changeset 5:8aa42fa04b17

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
enable more code
author drewp@bigasterisk.com
date Wed, 04 Dec 2019 00:32:24 -0800
parents a668a774b162
children a5bc13dcce41
files src/streamed_graph_client.ts
diffstat 1 files changed, 78 insertions(+), 94 deletions(-) [+]
line wrap: on
line diff
--- a/src/streamed_graph_client.ts	Wed Dec 04 00:23:28 2019 -0800
+++ b/src/streamed_graph_client.ts	Wed Dec 04 00:32:24 2019 -0800
@@ -21,41 +21,40 @@
         prefixes: Array<Record<string, string>>,
         staticGraphUrls: Array<string>) {
         console.log('new StreamedGraph', eventsUrl);
-        // holds a rdfstore.js store, which is synced to a server-side
-    //     // store that sends patches over SSE
-    //     this.onStatus = onStatus;
-    //     this.onGraphChanged = onGraphChanged;
-    //     this.onStatus('startup...');
+        // holds a n3 Store, which is synced to a server-side
+        // store that sends patches over SSE
+        this.onStatus = onStatus;
+        this.onGraphChanged = onGraphChanged;
+        this.onStatus('startup...');
 
         this.store = new Store({});
 
-    //     //             Object.keys(prefixes).forEach((prefix) => {
-    //     //                 this.store.setPrefix(prefix, prefixes[prefix]);
-    //     //             });
+        //     //             Object.keys(prefixes).forEach((prefix) => {
+        //     //                 this.store.setPrefix(prefix, prefixes[prefix]);
+        //     //             });
 
         this.connect(eventsUrl);
         this.reconnectOnWake();
 
-    //     staticGraphUrls.forEach((url) => {
-    //         fetch(url).then((response) => response.text())
-    //             .then((body) => {
-    //                 // parse with n3, add to output
-    //             });
-    //     });
+        //     staticGraphUrls.forEach((url) => {
+        //         fetch(url).then((response) => response.text())
+        //             .then((body) => {
+        //                 // parse with n3, add to output
+        //             });
+        //     });
 
     }
 
     reconnectOnWake() {
         // it's not this, which fires on every mouse-in on a browser window, and doesn't seem to work for screen-turned-back-on
         //window.addEventListener('focus', function() { this.connect(eventsUrl); }.bind(this));
-
     }
 
     connect(eventsUrl: string) {
         // need to exit here if this obj has been replaced
 
         this.onStatus('start connect...');
-        // this.close();
+        this.close();
         if (this.events && this.events.readyState != EventSource.CLOSED) {
             this.onStatus('zombie');
             throw new Error("zombie eventsource");
@@ -76,93 +75,78 @@
         });
 
         this.events.addEventListener('fullGraph', (ev) => {
-            // this.updates.push({ type: 'fullGraph', data: ev.data });
-            // this.flushUpdates();
+            this.onStatus('sync- full graph update');
+            let onReplaced = () => {
+                this.onStatus('synced');
+                this.onGraphChanged();
+            };
+            this.replaceFullGraph(ev.data, onReplaced);
         });
 
         this.events.addEventListener('patch', (ev) => {
-            // this.updates.push({ type: 'patch', data: ev.data });
-            // this.flushUpdates();
+            this.onStatus('sync- updating');
+            let onPatched = () => {
+                this.onStatus('synced');
+                this.onGraphChanged();
+            };
+            this.patchGraph(ev.data, onPatched);
         });
         this.onStatus('connecting...');
     }
 
-    // replaceFullGraph(jsonLdText: string, done: () => void) {
-    //     // this.quadStore.clear();
-    //     // eachJsonLdQuad(this.store.rdf, JSON.parse(jsonLdText),
-    //     //     this.quadStore.add.bind(this.quadStore), function () {
-    //     //         done();
-    //     //     });
-    //     // or this.store.insert([quad], quad.graph, function() {});
-    // }
-
-
-    // patchGraph(patchJson: string, done: () => void) {
-    //     var patch = JSON.parse(patchJson).patch;
-
-    //     // if (!this.store) {
-    //     //     throw new Error('store ' + this.store);
-    //     // }
+    replaceFullGraph(jsonLdText: string, done: () => void) {
+        // this.quadStore.clear();
+        // eachJsonLdQuad(this.store.rdf, JSON.parse(jsonLdText),
+        //     this.quadStore.add.bind(this.quadStore), function () {
+        //         done();
+        //     });
+        // or this.store.insert([quad], quad.graph, function() {});
+    }
 
-    //     async.series([
-    //         // (done) => {
-    //         //     eachJsonLdQuad(this.store.rdf, patch.deletes,
-    //         //         this.quadStore.remove.bind(this.quadStore), done);
-    //         // },
-    //         (done) => {
-    //             // eachJsonLdQuad(this.store.rdf, patch.adds,
-    //             //     this.quadStore.add.bind(this.quadStore), done);
-    //         },
-    //         /* seriesDone */ (done) => {
-    //             done();
-    //         }
-    //     ], done);
-    // }
-    // close() {
-    //     if (this.events) {
-    //         this.events.close();
-    //     }
-    // }
+    patchGraph(patchJson: string, done: () => void) {
+        var patch = JSON.parse(patchJson).patch;
+
+        // if (!this.store) {
+        //     throw new Error('store ' + this.store);
+        // }
 
-    // testEventUrl(eventsUrl: string): Promise<void> {
-    //     return new Promise<void>((resolve, reject) => {
-    //         this.onStatus('testing connection');
-    //         fetch(eventsUrl, {
-    //             method: "HEAD",
-    //             credentials: "include",
-    //         }).then((value) => {
-    //             if (value.status == 403) {
-    //                 reject();
-    //                 return;
-    //             }
-    //             resolve();
-    //         }).catch((err) => {
-    //             reject();
-    //         });
-    //     });
-    // }
+        async.series([
+            // (done) => {
+            //     eachJsonLdQuad(this.store.rdf, patch.deletes,
+            //         this.quadStore.remove.bind(this.quadStore), done);
+            // },
+            (done) => {
+                // eachJsonLdQuad(this.store.rdf, patch.adds,
+                //     this.quadStore.add.bind(this.quadStore), done);
+            },
+            /* seriesDone */ (done) => {
+                done();
+            }
+        ], done);
+    }
 
-    // flushOneUpdate(update: Update, done: () => void) {
-    //     if (update.type == 'fullGraph') {
-    //         this.onStatus('sync- full graph update');
-    //         let onReplaced = () => {
-    //             this.onStatus('synced');
-    //             this.onGraphChanged();
-    //             done();
-    //         };
-    //         this.replaceFullGraph(update.data, onReplaced);
-    //     } else if (update.type == 'patch') {
-    //         this.onStatus('sync- updating');
-    //         let onPatched = () => {
-    //             this.onStatus('synced');
-    //             this.onGraphChanged();
-    //             done();
-    //         };
-    //         this.patchGraph(update.data, onPatched);
-    //     } else {
-    //         this.onStatus('sync- unknown update');
-    //         throw new Error(update.type);
-    //     }
-    // }
+    close() {
+        if (this.events) {
+            this.events.close();
+        }
+    }
+
+    testEventUrl(eventsUrl: string): Promise<void> {
+        return new Promise<void>((resolve, reject) => {
+            this.onStatus('testing connection');
+            fetch(eventsUrl, {
+                method: "HEAD",
+                credentials: "include",
+            }).then((value) => {
+                if (value.status == 403) {
+                    reject();
+                    return;
+                }
+                resolve();
+            }).catch((err) => {
+                reject();
+            });
+        });
+    }
 
 }
\ No newline at end of file