Init jobs routes.

src/bin/sm_scraper.rs

@@ -2,5 +2,5 @@ use zero2prod::jobs;
 
 #[tokio::main]
 async fn main() {
-    jobs::scrape_sm::main().await;    
+    jobs::scrape_sm::main().await;
 }

src/db.rs

@@ -1,9 +1,8 @@
 use libsql::{Builder, Connection, Database, Error};
 
 use crate::models::{
-    sm_scrape::INIT_TABLE as SCRAPE_INIT, 
+    jobs::INIT_TABLE as JOBS_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> {

src/jobs/mod.rs

@@ -1,2 +1,2 @@
-pub mod scrape_sm;
 pub mod embed_scrapes;
+pub mod scrape_sm;

src/jobs/scrape_sm.rs

@@ -1,8 +1,8 @@
 use std::{thread::sleep, time::Duration};
 
+use crate::{configuration::get_configuration, db::local_db, services::scraper};
 use chrono::Utc;
 use uuid::Uuid;
-use crate::{configuration::get_configuration, db::local_db, services::scraper};
 
 macro_rules! unwrap_table_data {
     ($table_data:expr, $key:expr) => {

src/lib.rs

@@ -1,7 +1,7 @@
 pub mod configuration;
 pub mod db;
+pub mod jobs;
 pub mod models;
 pub mod routes;
 pub mod services;
 pub mod startup;
-pub mod jobs;

src/models/jobs.rs

@@ -3,15 +3,15 @@ use serde::{Deserialize, Serialize};
 #[derive(Serialize, Deserialize)]
 enum JobType {
     SMScrape,
-    Embed
+    Embed,
 }
 
 #[derive(Serialize, Deserialize)]
 enum JobStatus {
     Pending,
     Running,
     Completed,
-    Failed
+    Failed,
 }
 
 pub const INIT_TABLE: &str = r#"
@@ -23,4 +23,4 @@ CREATE TABLE IF NOT EXISTS jobs (
     updated_at timestampz NOT NULL,
     completed_at timestampz
 );
-"#;
+"#;

src/models/mod.rs

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

src/routes/jobs.rs

@@ -0,0 +1,13 @@
+use actix_web::{get, post, web, HttpResponse};
+
+// GET /jobs
+#[get("")]
+pub async fn get_jobs() -> HttpResponse {
+    HttpResponse::Ok().finish()
+}
+
+// POST /jobs
+#[post("")]
+pub async fn start_job() -> HttpResponse {
+    HttpResponse::Ok().finish()
+}

src/routes/mod.rs

@@ -1,11 +1,13 @@
 mod green_recs;
 mod health_check;
 mod index;
+mod jobs;
 mod scrapes;
 mod subscriptions;
 
 pub use green_recs::*;
 pub use health_check::*;
 pub use index::*;
+pub use jobs::*;
 pub use scrapes::*;
 pub use subscriptions::*;

src/startup.rs

@@ -1,6 +1,8 @@
 use crate::{
     db,
-    routes::{create_green_rec, get_scrapes, health_check_route, home, subscribe},
+    routes::{
+        create_green_rec, get_jobs, get_scrapes, health_check_route, home, start_job, subscribe,
+    },
 };
 use actix_web::{dev::Server, web, App, HttpServer};
 use std::net::TcpListener;
@@ -36,7 +38,8 @@ pub async fn run(listener: TcpListener, db_path: &str) -> Result<Server, std::io
                     .service(health_check_route)
                     .service(subscribe)
                     .service(create_green_rec)
-                    .service(get_scrapes),
+                    .service(get_scrapes)
+                    .service(web::scope("/jobs").service(get_jobs).service(start_job)),
             )
             .service(home)
             .app_data(connection_data.clone())