diff --git a/src/db/migrations/050_notify_only_insert.ts b/src/db/migrations/050_notify_only_insert.ts new file mode 100644 index 00000000..1e6bd4cb --- /dev/null +++ b/src/db/migrations/050_notify_only_insert.ts @@ -0,0 +1,21 @@ +import { Kysely, sql } from 'kysely'; + +export async function up(db: Kysely): Promise { + await sql`DROP TRIGGER IF EXISTS nostr_event_trigger ON nostr_events`.execute(db); + + await sql` + CREATE TRIGGER nostr_event_trigger + AFTER INSERT ON nostr_events + FOR EACH ROW EXECUTE FUNCTION notify_nostr_event() + `.execute(db); +} + +export async function down(db: Kysely): Promise { + await sql`DROP TRIGGER IF EXISTS nostr_event_trigger ON nostr_events`.execute(db); + + await sql` + CREATE TRIGGER nostr_event_trigger + AFTER INSERT OR UPDATE ON nostr_events + FOR EACH ROW EXECUTE FUNCTION notify_nostr_event() + `.execute(db); +}