light9 Changeset - f2c6b39c155c

Changeset - f2c6b39c155c

Parent rev.

Child rev.

[Not reviewed]

default

0 2 0

drewp@bigasterisk.com - 20 months ago 2023-05-30 05:49:40
drewp@bigasterisk.com

fix messagesSend counter

2 files changed with 4 insertions and 3 deletions:

light9/web/RdfDbChannel.ts

light9/web/rdfdbclient.ts

0 comments (0 inline, 0 general)

light9/web/RdfDbChannel.ts

➞

Show inline comments

@@ @@ -49,12 +49,14 @@ export class RdfDbChannel { @@
     // one try, best effort, true if we think it worked
     if (!this.ws || this.ws.readyState !== this.ws.OPEN) {
       return false;
+    }
     log("send patch to server, " + body.length + " bytes");
     this.ws.send(body);
     this.messagesSent++;
     this.updateStatus();
     return true;
+  }
   disconnect() {
     // will be followed by an autoconnect
     log("disconnect requested");

light9/web/rdfdbclient.ts

➞

Show inline comments

 import debug from "debug";
 import { parseJsonPatch, Patch } from "./patch";
 import { RdfDbChannel } from "./RdfDbChannel";
-export const log = debug("rdfdbclient");
 const log = debug("rdfdbclient");
 export class RdfDbClient {
   private channel: RdfDbChannel;
   _patchesToSend: Patch[];
   // Send and receive patches from rdfdb. Primarily used in SyncedGraph.
   //
@@ @@ -25,13 +25,12 @@ export class RdfDbClient { @@
       setStatus(st + `; ${this._patchesToSend.length} pending `);
     });
     this.channel.newConnection.subscribe(() => {
       this.clearGraphOnNewConnection();
     });
     this.channel.serverMessage.subscribe((m) => {
       log('got server json', m.body)
       parseJsonPatch(m.body, (p: Patch) => {
         log('patch from server:', p.dump())
         if (p.isEmpty()) {
           return;
+        }
         this.applyPatch(p);
@@ @@ -48,13 +47,13 @@ export class RdfDbClient { @@
   disconnect() {
     this.channel.disconnect();
+  }
   async _continueSending() {
     // we could call this less often and coalesce patches together to optimize
     // the dragging cases.
+    // the dragging cases. See rdfdb 'compactPatches' and 'processInbox'.
     while (this._patchesToSend.length) {
       const patch = this._patchesToSend.splice(0, 1)[0];
       const json = await patch.toJsonPatch();
       const ret = this.channel.sendMessage(json);
       if (!ret) {
         setTimeout(this._continueSending.bind(this), 500);

0 comments (0 inline, 0 general)