bytelyst/learning_ai_clock
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(backend): Phase C.1-C.2 wire domain events from timer + routine repositories to webhook dispatch

Browse Source
This commit is contained in:
saravanakumardb1 2026-04-18 18:09:04 -07:00
parent 9973c548fc
commit 79ac0bb1d6
2 changed files with 21 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
backend/src/modules/routines/repository.ts
View File

@ -6,6 +6,7 @@
import { getCollection } from '../../lib/datastore.js';
import { getEncryptor, isEncryptedField } from '../../lib/field-encrypt.js';
import { getEventBus } from '../../lib/event-bus.js';
import type { RoutineDoc, RoutineQuery, BatchUpsertRoutinesResult } from './types.js';
import type { FilterMap } from '@bytelyst/datastore';
@ -126,7 +127,14 @@ export async function updateRoutine(
};
const encrypted = await encryptRoutineFields(merged);
const doc = await collection().upsert(encrypted);
return { doc: await decryptRoutineFields(doc), conflict: false };
const decrypted = await decryptRoutineFields(doc);
if (decrypted.status === 'active' && existing.status !== 'active') {
getEventBus().emit('routine.started', { routineId: decrypted.id, userId: decrypted.userId, name: decrypted.name });
}
if (decrypted.status === 'completed' && existing.status !== 'completed') {
getEventBus().emit('routine.completed', { routineId: decrypted.id, userId: decrypted.userId, name: decrypted.name });
}
return { doc: decrypted, conflict: false };
} catch {
return { doc: null, conflict: false };
}

14
backend/src/modules/timers/repository.ts
View File

@ -6,6 +6,7 @@
import { getCollection } from '../../lib/datastore.js';
import { getEncryptor, isEncryptedField } from '../../lib/field-encrypt.js';
import { getEventBus } from '../../lib/event-bus.js';
import type { TimerDoc, TimerQuery, BatchUpsertResult } from './types.js';
import type { FilterMap } from '@bytelyst/datastore';
@ -75,7 +76,9 @@ export async function getTimer(id: string, userId: string): Promise<TimerDoc | n
export async function createTimer(doc: TimerDoc): Promise<TimerDoc> {
const encrypted = await encryptTimerFields(doc);
const created = await collection().create(encrypted);
return decryptTimerFields(created);
const decrypted = await decryptTimerFields(created);
getEventBus().emit('timer.created', { timerId: decrypted.id, userId: decrypted.userId, label: decrypted.label });
return decrypted;
}
export async function updateTimer(
@ -102,7 +105,14 @@ export async function updateTimer(
};
const encrypted = await encryptTimerFields(merged);
const doc = await collection().upsert(encrypted);
return { doc: await decryptTimerFields(doc), conflict: false };
const decrypted = await decryptTimerFields(doc);
if (decrypted.state === 'fired' && existing.state !== 'fired') {
getEventBus().emit('timer.fired', { timerId: decrypted.id, userId: decrypted.userId, label: decrypted.label });
}
if (decrypted.state === 'completed' && existing.state !== 'completed') {
getEventBus().emit('timer.completed', { timerId: decrypted.id, userId: decrypted.userId, label: decrypted.label });
}
return { doc: decrypted, conflict: false };
} catch {
return { doc: null, conflict: false };
}