jedarden/spaxel
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat: add migration_007 for webhook_log, trigger_state tables and trigger error columns

Browse source 
Formalizes the webhook audit infrastructure (webhook_log table, trigger_state
persistence, error_message/error_count columns) that was previously created
via ALTER TABLE in Store.init(). All webhook action firing, fault tolerance,
test endpoint, enable/disable, and dashboard UI were already implemented
in prior commits.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
jedarden 2026-04-06 21:27:57 -04:00
parent 61512fdb88
commit eb5b43f279
1 changed files with 41 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
mothership/internal/db/migrations.go
View file

@ -38,6 +38,11 @@ func AllMigrations() []Migration {
Description: "add virtual node columns for passive radar AP",
Up: migration_006_add_virtual_node_columns,
},
{
Version: 7,
Description: "add webhook_log, trigger_state tables and trigger error columns",
Up: migration_007_add_webhook_tables,
},
}
}
@ -411,3 +416,39 @@ func migration_006_add_virtual_node_columns(tx *sql.Tx) error {
return err
}
// migration_007_add_webhook_tables adds webhook_log, trigger_state tables
// and error_message/error_count columns to the triggers table.
func migration_007_add_webhook_tables(tx *sql.Tx) error {
schema := `
-- Error tracking columns on triggers
ALTER TABLE triggers ADD COLUMN error_message TEXT DEFAULT '';
ALTER TABLE triggers ADD COLUMN error_count INTEGER NOT NULL DEFAULT 0;
-- Trigger blob state persistence across restarts
CREATE TABLE IF NOT EXISTS trigger_state (
trigger_id INTEGER NOT NULL,
blob_id INTEGER NOT NULL,
inside INTEGER NOT NULL DEFAULT 0,
enter_time INTEGER NOT NULL DEFAULT 0,
last_check INTEGER NOT NULL DEFAULT 0,
PRIMARY KEY (trigger_id, blob_id),
FOREIGN KEY (trigger_id) REFERENCES triggers(id) ON DELETE CASCADE
);
-- Webhook audit log
CREATE TABLE IF NOT EXISTS webhook_log (
id INTEGER PRIMARY KEY AUTOINCREMENT,
trigger_id INTEGER NOT NULL,
fired_at_ms INTEGER NOT NULL,
url TEXT NOT NULL,
status_code INTEGER,
latency_ms INTEGER NOT NULL DEFAULT 0,
error TEXT DEFAULT '',
FOREIGN KEY (trigger_id) REFERENCES triggers(id) ON DELETE CASCADE
);
CREATE INDEX IF NOT EXISTS idx_webhook_log_trigger ON webhook_log(trigger_id, fired_at_ms DESC);
`
_, err := tx.Exec(schema)
return err
}