BM-613: Use postgres by default in the broker

crates/broker/Cargo.toml

@@ -36,7 +36,7 @@ risc0-ethereum-contracts = { workspace = true, features = ["unstable"] }
 risc0-zkvm = { workspace = true, features = ["std", "client"] }
 serde = { workspace = true }
 serde_json = { workspace = true }
-sqlx = { workspace = true, features = [ "sqlite", "runtime-tokio", "json", "migrate", "macros" ] }
+sqlx = { workspace = true, features = [ "postgres", "runtime-tokio-native-tls", "sqlite", "runtime-tokio", "json", "migrate", "macros" ] }
 tempfile = { workspace = true }
 thiserror = { workspace = true }
 tokio = { workspace = true, features = ["rt-multi-thread", "macros", "fs"] }

crates/broker/migrations/postgres/1_broker.sql

@@ -0,0 +1,39 @@
+-- Postgres requires us to create the enum before using it as a column type
+-- as it does not store enums as strings internally as sqlite does
+CREATE TYPE order_status AS ENUM (
+    'New',
+    'Pricing',
+    'Locking',
+    'Locked',
+    'Proving',
+    'PendingAgg',
+    'Aggregating',
+    'PendingSubmission',
+    'Done',
+    'Failed',
+    'Skipped'
+);
+
+CREATE TYPE batch_status AS ENUM (
+    'Aggregating',
+    'PendingCompression',
+    'Complete',
+    'PendingSubmission',
+    'Submitted',
+    'Failed'
+);
+
+CREATE TABLE orders (
+    id TEXT PRIMARY KEY,
+    data JSONB
+);
+
+CREATE TABLE batches (
+    id BIGSERIAL PRIMARY KEY,
+    data JSONB
+);
+
+CREATE TABLE last_block (
+    id INTEGER PRIMARY KEY,
+    block TEXT
+)

crates/broker/src/aggregator.rs

@@ -536,7 +536,7 @@ mod tests {
     use super::*;
     use crate::{
         chain_monitor::ChainMonitorService,
-        db::SqliteDb,
+        db::{DBPoolManager, SqliteDb},
         now_timestamp,
         provers::{encode_input, MockProver, Prover},
         BatchStatus, Order, OrderStatus,

crates/broker/src/db/fuzz_db.rs

@@ -17,6 +17,7 @@ use std::sync::Arc;
 use tempfile::NamedTempFile;
 use tokio::runtime::Builder;
 
+use crate::db::DBPoolManager;
 use crate::{db::AggregationOrder, AggregationState, Order, OrderStatus};
 
 use super::{BrokerDb, SqliteDb};