Rename DbWorker message types for clarity

Renamed the 'onChange' message type to 'onQueryPatches' and 'onReceive' to 'refreshQueries' throughout the Db worker, Evolu instance, and related tests.

Author: steida

packages/common/src/Evolu/Db.ts

@@ -127,13 +127,13 @@ export type DbWorkerOutput =
         | TransferableError;
     }
   | {
-      readonly type: "onChange";
+      readonly type: "onQueryPatches";
       readonly tabId: Id;
       readonly queryPatches: ReadonlyArray<QueryPatches>;
       readonly onCompleteIds: ReadonlyArray<CallbackId>;
     }
   | {
-      readonly type: "onReceive";
+      readonly type: "refreshQueries";
       readonly tabId?: Id;
     }
   | {
@@ -289,7 +289,7 @@ const createDbWorkerDeps =
           postMessage({ type: "onError", error });
         },
         onReceive: () => {
-          postMessage({ type: "onReceive" });
+          postMessage({ type: "refreshQueries" });
         },
       });
       if (!sync.ok) return sync;
@@ -449,16 +449,16 @@ const handlers: Omit<MessageHandlers<DbWorkerInput, DbWorkerDeps>, "init"> = {
       );
       if (!queryPatches.ok) return queryPatches;
 
-      // Notify the tab that performed the mutation.
+      // Update the tab that performed the mutation.
       deps.postMessage({
-        type: "onChange",
+        type: "onQueryPatches",
         tabId: message.tabId,
         queryPatches: queryPatches.value,
         onCompleteIds: message.onCompleteIds,
       });
 
       // Notify other tabs to refresh their queries.
-      deps.postMessage({ type: "onReceive", tabId: message.tabId });
+      deps.postMessage({ type: "refreshQueries", tabId: message.tabId });
 
       return ok();
     });
@@ -478,7 +478,7 @@ const handlers: Omit<MessageHandlers<DbWorkerInput, DbWorkerDeps>, "init"> = {
     }
 
     deps.postMessage({
-      type: "onChange",
+      type: "onQueryPatches",
       tabId: message.tabId,
       queryPatches: queryPatches.value,
       onCompleteIds: [],

packages/common/src/Evolu/Evolu.ts

@@ -699,7 +699,7 @@ const createEvoluInstance =
           break;
         }
 
-        case "onChange": {
+        case "onQueryPatches": {
           if (message.tabId !== getTabId()) return;
 
           const state = rowsStore.get();
@@ -731,7 +731,7 @@ const createEvoluInstance =
           break;
         }
 
-        case "onReceive": {
+        case "refreshQueries": {
           if (message.tabId && message.tabId === getTabId()) return;
 
           loadingPromises.releaseUnsubscribed();

packages/common/test/Evolu/Db.test.ts

@@ -358,11 +358,11 @@ test("local mutations", async () => {
           },
         ],
         "tabId": "LhGnhts9rNnUeri8bzhS5",
-        "type": "onChange",
+        "type": "onQueryPatches",
       },
       {
         "tabId": "LhGnhts9rNnUeri8bzhS5",
-        "type": "onReceive",
+        "type": "refreshQueries",
       },
     ]
   `);
@@ -386,7 +386,7 @@ test("local mutations", async () => {
           },
         ],
         "tabId": "LhGnhts9rNnUeri8bzhS5",
-        "type": "onChange",
+        "type": "onQueryPatches",
       },
     ]
   `,
@@ -466,11 +466,11 @@ test("local mutations", async () => {
           },
         ],
         "tabId": "LhGnhts9rNnUeri8bzhS5",
-        "type": "onChange",
+        "type": "onQueryPatches",
       },
       {
         "tabId": "LhGnhts9rNnUeri8bzhS5",
-        "type": "onReceive",
+        "type": "refreshQueries",
       },
     ]
   `);
@@ -625,11 +625,11 @@ test("sync mutations", async () => {
           },
         ],
         "tabId": "LhGnhts9rNnUeri8bzhS5",
-        "type": "onChange",
+        "type": "onQueryPatches",
       },
       {
         "tabId": "LhGnhts9rNnUeri8bzhS5",
-        "type": "onReceive",
+        "type": "refreshQueries",
       },
     ]
   `);
@@ -765,11 +765,11 @@ test("sync mutations", async () => {
           },
         ],
         "tabId": "LhGnhts9rNnUeri8bzhS5",
-        "type": "onChange",
+        "type": "onQueryPatches",
       },
       {
         "tabId": "LhGnhts9rNnUeri8bzhS5",
-        "type": "onReceive",
+        "type": "refreshQueries",
       },
     ]
   `);
@@ -913,11 +913,11 @@ test("sync mutations", async () => {
           },
         ],
         "tabId": "LhGnhts9rNnUeri8bzhS5",
-        "type": "onChange",
+        "type": "onQueryPatches",
       },
       {
         "tabId": "LhGnhts9rNnUeri8bzhS5",
-        "type": "onReceive",
+        "type": "refreshQueries",
       },
     ]
   `);