fix: wake other clients after a sync push (Plugin-Sync#1)

CHANGELOG.md

@@ -14,6 +14,7 @@
 - The log line for a rejected proxy login now shows the source address, so you can add it to TRUSTED_PROXY_AUTH_TRUSTED_PROXIES
 - Deleting your own account now removes all of its data, like an admin delete does, instead of leaving some behind
 - An SSH key with a passphrase is unlocked once and kept unlocked in memory for a short time, so connecting to many hosts with it no longer freezes the server for minutes
+- A change pushed from one linked desktop or phone now reaches your other linked devices right away, instead of on their next check a few minutes later
 
 ## 26.10.5
 

src/backend/sync/server/feed.ts

@@ -161,7 +161,7 @@ async function reconcileListeners(): Promise<void> {
   }
 }
 
-function notifyListeners(userId: string): void {
+export function notifyListeners(userId: string): void {
   const set = listeners.get(userId);
   if (!set) return;
   for (const res of set) {

src/backend/sync/server/push.ts

@@ -25,7 +25,7 @@ import {
 } from "../store.js";
 import { allocateSeq, getRecord, putRecord, recordKey } from "../records.js";
 import { orderSelfReferences } from "../wire.js";
-import { reconcileUser } from "./feed.js";
+import { markChanged, notifyListeners, reconcileUser } from "./feed.js";
 
 export interface PushOp {
   entityType: string;
@@ -278,6 +278,12 @@ export async function applyPush(
 
   // Refresh the snapshot so the next pull serves what was just written.
   await reconcileUser(userId, { force: true });
+  // The reconcile finds nothing new, since the push wrote the records itself,
+  // so tell this user's other clients, and other users who may share a row.
+  if ([...results.values()].some((result) => result.status === "ok")) {
+    notifyListeners(userId);
+    markChanged();
+  }
   return ops.map(
     (op) =>
       results.get(recordKey(op.entityType, op.syncId)) ?? {