ddbac4f feat! drop "status" column from event queue — radicle-ci-broker

Radicle CI broker

feat! drop "status" column from event queue

Lars Wirzenius committed 1 year ago

commit ddbac4fd6efef20f9fcd9aace88456ee6a4ee5fc
parent fbb123d953753b75cc13940f5a064d7a5ba4df00

1 file changed +3 -9

modified src/db.rs

@@ -58,7 +58,7 @@ impl Db {

     fn create_tables(&self) -> Result<(), DbError> {
         const TABLES: &[&str] = &[
             "CREATE TABLE IF NOT EXISTS counter_test (counter INT)",
             "CREATE TABLE IF NOT EXISTS event_queue (id TEXT PRIMARY KEY, timestamp TEXT, event TEXT, status TEXT)",
             "CREATE TABLE IF NOT EXISTS event_queue (id TEXT PRIMARY KEY, timestamp TEXT, event TEXT)",
             "CREATE TABLE IF NOT EXISTS ci_runs (run_id TEXT PRIMARY KEY, json TEXT)",
         ];

@@ -237,11 +237,9 @@ impl Db {

         let id = QueueId::default();
         let ts = now();
         let status = "FIXME";
         let mut insert = self.prepare(
             "INSERT INTO event_queue (id, timestamp, event, status) VALUES (:id, :ts, :e, :s)",
         )?;
         let mut insert =
             self.prepare("INSERT INTO event_queue (id, timestamp, event) VALUES (:id, :ts, :e)")?;
         insert
             .stmt
             .bind((":id", id.as_str()))

@@ -254,10 +252,6 @@ impl Db {

             .stmt
             .bind((":e", json.as_str()))
             .map_err(|e| DbError::bind(&insert.sql, e))?;
         insert
             .stmt
             .bind((":s", status))
             .map_err(|e| DbError::bind(&insert.sql, e))?;
         match insert.stmt.next() {
             Ok(_) => (),
             Err(e) => return Err(DbError::push_event(&insert.sql, e)),