Fix events table key scoping by environment

Author: cursoragent

src/lib/events-store.test.ts

@@ -74,6 +74,16 @@ describe('events-store (sqlite)', () => {
     expect(events).toHaveLength(1);
   });
 
+  test('appendEvent allows same event ID in different environments', () => {
+    appendEvent(makeEvent('evt_shared', 'video.asset.ready', 'env-aaa'));
+    appendEvent(makeEvent('evt_shared', 'video.asset.ready', 'env-bbb'));
+
+    expect(getEventById('evt_shared', 'env-aaa')).toBeDefined();
+    expect(getEventById('evt_shared', 'env-bbb')).toBeDefined();
+    expect(listEvents('env-aaa')).toHaveLength(1);
+    expect(listEvents('env-bbb')).toHaveLength(1);
+  });
+
   test('appendEvent does not cap at 100 events', () => {
     for (let i = 0; i < 150; i++) {
       appendEvent(makeEvent(`evt_${i}`));

src/lib/events-store.ts

@@ -23,11 +23,12 @@ function getDb(): Database {
   db.run('PRAGMA journal_mode = WAL');
   db.run(`
     CREATE TABLE IF NOT EXISTS events (
-      id          TEXT PRIMARY KEY,
+      id          TEXT NOT NULL,
       type        TEXT NOT NULL,
       timestamp   TEXT NOT NULL,
       environment_id TEXT NOT NULL,
-      payload     TEXT NOT NULL
+      payload     TEXT NOT NULL,
+      PRIMARY KEY (id, environment_id)
     )
   `);
   db.run(