Init jobs table.

src/db.rs

@@ -1,7 +1,9 @@
 use libsql::{Builder, Connection, Database, Error};
 
 use crate::models::{
- sm_scrape::INIT_TABLE as SCRAPE_INIT, subscriptions::INIT_TABLE as SUBSCRIPTIONS_INIT,
+ sm_scrape::INIT_TABLE as SCRAPE_INIT, 
+ subscriptions::INIT_TABLE as SUBSCRIPTIONS_INIT,
+ jobs::INIT_TABLE as JOBS_INIT,
 };
 
 pub async fn local_db(db_path: &str) -> Result<Database, Error> {
@@ -23,5 +25,6 @@ pub async fn local_db(db_path: &str) -> Result<Database, Error> {
 async fn init_schema(conn: &Connection) -> Result<(), Error> {
  conn.execute(SUBSCRIPTIONS_INIT, ()).await?;
  conn.execute(SCRAPE_INIT, ()).await?;
+ conn.execute(JOBS_INIT, ()).await?;
  Ok(())
 }

src/models/jobs.rs

@@ -0,0 +1,26 @@
+use serde::{Deserialize, Serialize};
+
+#[derive(Serialize, Deserialize)]
+enum JobType {
+ SMScrape,
+ Embed
+}
+
+#[derive(Serialize, Deserialize)]
+enum JobStatus {
+ Pending,
+ Running,
+ Completed,
+ Failed
+}
+
+pub const INIT_TABLE: &str = r#"
+CREATE TABLE IF NOT EXISTS jobs (
+ id uuid NOT NULL PRIMARY KEY,
+ type INTEGER NOT NULL,
+ status INTEGER NOT NULL,
+ created_at timestampz NOT NULL,
+ updated_at timestampz NOT NULL,
+ completed_at timestampz,
+);
+"#;

src/models/mod.rs

@@ -1,2 +1,3 @@
 pub mod sm_scrape;
 pub mod subscriptions;
+pub mod jobs;