This commit is contained in:
2023-12-19 12:30:47 +02:00
parent 136b8ea2aa
commit 1a49b551b3

View File

@@ -1,7 +1,9 @@
use actix_web::{get, web, HttpResponse, Responder};
pub fn init_arrivals_scope() -> actix_web::Scope {
let scope = web::scope("/arrivals").service(show_arrivals);
let scope = web::scope("/arrivals")
.service(show_arrivals)
.service(show_specific);
scope
}
use chrono::NaiveTime;
@@ -15,8 +17,8 @@ pub struct Arrival {
direction: bool,
}
use sqlx::{query_as, Execute, PgPool, QueryBuilder};
use web::Data;
use sqlx::{PgPool, query_as, QueryBuilder, Execute};
#[get("all")]
async fn show_arrivals(db_pool: Data<PgPool>) -> impl Responder {
let arrivals = query_as!(Arrival, r#"SELECT * FROM arrivals"#)
@@ -36,14 +38,17 @@ struct ArrivalFilter {
#[get("specific")]
async fn show_specific(db_pool: Data<PgPool>, filter: web::Query<ArrivalFilter>) -> impl Responder {
//Le query
let arrivals = query_as!(Arrival, "SELECT * FROM arrivals WHERE tram_line = $1 AND week_day = $2", filter.tram_line, filter.week_day)
let arrivals = query_as!(
Arrival,
"SELECT * FROM arrivals WHERE tram_line = $1 AND week_day = $2",
filter.tram_line,
filter.week_day
)
.fetch_all(db_pool.get_ref())
.await
.expect("Could not fetch arrivals");
// Delet cuz we hardcoding
// dbg!(&arrivals);