chore(release): 0.8.4

Author: DaxtonD

.env.example

@@ -65,6 +65,21 @@ OCR_LOG_LEVEL=
 # If unset, the server uses a temp directory.
 PADDLEOCR_HOME=
 
+# Redis (required for BullMQ reminder scheduling and optional Yjs pub/sub bridge)
+REDIS_HOST=
+REDIS_PORT=
+REDIS_PASSWORD=
+
+# Reminder worker runs in same Node process and consumes BullMQ jobs.
+# true  => process delayed reminder jobs and send push notifications
+# false => do not start worker in this instance
+ENABLE_REMINDER_WORKER=
+
+# Optional: cross-instance Yjs update propagation using Redis Pub/Sub.
+# true  => enable yjs:doc:* publish/subscribe bridge
+# false => single-instance mode (default behavior)
+ENABLE_REDIS_PUBSUB=
+
 # Notes:
 # - `.env.example` must never contain real secret values. Keep this file in source control.
 # - Put real secrets in `.env` (which is ignored) or in your deployment environment.

CHANGELOG.md

@@ -15,6 +15,30 @@ Adheres to Semantic Versioning (MAJOR.MINOR.PATCH).
 ### Fixed
 - 
 
+## [0.8.4] - 2026-02-18
+
+### Added
+- Redis-backed reminder queue architecture using BullMQ (`server/src/lib/queue.ts`, `server/src/workers/reminderWorker.ts`, `server/src/lib/redis.ts`) with delayed jobs, retry/backoff, startup resync, and graceful shutdown handling.
+- Optional Redis Pub/Sub bridge for cross-instance Yjs propagation (`server/src/lib/yjsRedisBridge.ts`) with instance tagging and rebroadcast loop prevention.
+- New environment configuration for Redis and feature toggles in `.env.example`:
+	- `REDIS_HOST`, `REDIS_PORT`, `REDIS_PASSWORD`
+	- `ENABLE_REMINDER_WORKER`
+	- `ENABLE_REDIS_PUBSUB`
+
+### Changed
+- Server startup now initializes reminder queue state from DB and conditionally starts the in-process reminder worker in `server/src/index.ts`.
+- Reminder scheduling flow moved from polling to queue-driven execution; note create/update/archive/trash/delete lifecycle paths now keep reminder jobs in sync (`server/src/notes.ts`).
+- Reminder resync now includes pending due reminders (including past-due unsent reminders), improving restart/downtime recovery behavior.
+- Legacy polling module `server/src/reminderPushJob.ts` is retained as a deprecated no-op compatibility shim.
+- Release metadata/version bumped to `0.8.4`.
+
+### Fixed
+- Reduced unnecessary DB writes during note-card drag/layout and idle states:
+	- deduplicated order persistence writes in `client/src/components/NotesGrid.tsx`,
+	- disabled per-card realtime Yjs sessions in `client/src/components/NoteCard.tsx` (editor realtime remains active).
+- Reduced Yjs persistence write pressure by debouncing DB snapshot writes in `server/src/index.ts` while preserving realtime websocket collaboration.
+- Removed file-based Prisma DB event logging to `db.log` and restored normal environment-based Prisma log output in `server/src/prismaClient.ts`.
+
 ## [0.8.3] - 2026-02-16
 
 ### Added

client/src/components/NoteCard.tsx

@@ -1005,12 +1005,18 @@ export default function NoteCard({
     };
   }, [token, viewerCollections, neededCollectionIdsKey, collectionPathById]);
   // Subscribe to Yjs checklist for live card updates
+  // IMPORTANT: card previews should not establish per-card collaborative sessions.
+  // Creating a websocket + Y.Doc for every visible card causes heavy DB churn
+  // (server persists yData on Yjs updates), especially during drag/re-layout.
+  // Full realtime collaboration remains in editors.
+  const enableCardRealtimeCollab = false;
   const ydoc = React.useMemo(() => new Y.Doc(), [note.id]);
   const collabRoom = React.useMemo(() => noteCollabRoomFromNote(note), [note.id, (note as any)?.createdAt]);
   const providerRef = React.useRef<WebsocketProvider | null>(null);
   const yarrayRef = React.useRef<Y.Array<Y.Map<any>> | null>(null);
 
   React.useEffect(() => {
+    if (!enableCardRealtimeCollab) return;
     let disposed = false;
     let cleanup: (() => void) | null = null;
 
@@ -1028,9 +1034,10 @@ export default function NoteCard({
       disposed = true;
       try { cleanup && cleanup(); } catch {}
     };
-  }, [collabRoom, ydoc]);
+  }, [collabRoom, ydoc, enableCardRealtimeCollab]);
 
   React.useEffect(() => {
+    if (!enableCardRealtimeCollab) return;
     const room = collabRoom;
     const proto = window.location.protocol === 'https:' ? 'wss' : 'ws';
     const serverUrl = `${proto}://${window.location.host}/collab`;
@@ -1054,7 +1061,7 @@ export default function NoteCard({
     yarr.observeDeep(updateFromY);
     provider.on('sync', (isSynced: boolean) => { if (isSynced) updateFromY(); });
     return () => { try { yarr.unobserveDeep(updateFromY as any); } catch {}; try { provider.destroy(); } catch {}; };
-  }, [collabRoom, ydoc]);
+  }, [collabRoom, ydoc, enableCardRealtimeCollab]);
 
   React.useEffect(() => {
     const onUploadSuccess = (evt: Event) => {
@@ -1083,6 +1090,7 @@ export default function NoteCard({
 
   // Subscribe to Yjs text doc for real-time HTML preview on cards (TEXT notes)
   React.useEffect(() => {
+    if (!enableCardRealtimeCollab) { setRtHtmlFromY(null); return; }
     if (note.type !== 'TEXT') { setRtHtmlFromY(null); return; }
     let ed: Editor | null = null;
     try {
@@ -1124,7 +1132,7 @@ export default function NoteCard({
     } catch {
       // ignore editor init failures
     }
-  }, [note.id, note.type, ydoc]);
+  }, [note.id, note.type, ydoc, enableCardRealtimeCollab]);
   // Render a minimal formatted HTML preview from TipTap JSON stored in note.body
   function bodyHtmlPreview(): string {
     const raw = textBody || '';

client/src/components/NotesGrid.tsx

@@ -563,6 +563,7 @@ export default function NotesGrid({
   const swapCandidateIdRef = useRef<number | null>(null);
   const swapDwellTimerRef = useRef<number | null>(null);
   const swapAnimColsRef = useRef<null | { section: 'pinned' | 'others'; heights: number[] }>(null);
+  const orderPersistSigRef = useRef<string>('');
 
   function getAnimMs(kind: 'resize'|'swap'|'rearrange') {
     try {
@@ -3218,9 +3219,19 @@ export default function NotesGrid({
 
   async function persistOrder(currentNotes: any[]) {
     // always save locally
-    const pinnedIds = currentNotes.filter((n: any) => !!(n as any)?.pinned).map((n: any) => n.id);
-    const otherIds = currentNotes.filter((n: any) => !(n as any)?.pinned).map((n: any) => n.id);
+    const pinnedIds = currentNotes
+      .filter((n: any) => !!(n as any)?.pinned)
+      .map((n: any) => Number((n as any)?.id))
+      .filter((id: number) => Number.isFinite(id));
+    const otherIds = currentNotes
+      .filter((n: any) => !(n as any)?.pinned)
+      .map((n: any) => Number((n as any)?.id))
+      .filter((id: number) => Number.isFinite(id));
     const ids = [...pinnedIds, ...otherIds];
+    const sig = ids.join(',');
+    if (!sig) return;
+    if (orderPersistSigRef.current === sig) return;
+    orderPersistSigRef.current = sig;
     try { localStorage.setItem('notesOrder', JSON.stringify(ids)); } catch (e) {}
     // attempt server persistence if authenticated
     if (!token) return;