clippy + fmt
This commit is contained in:
parent
67a67c1688
commit
e7913736e5
@ -1,5 +1,5 @@
|
|||||||
use axum::{body::Body, response::Response, routing::get, Router};
|
use axum::{Router, body::Body, response::Response, routing::get};
|
||||||
use maud::{html, Markup};
|
use maud::{Markup, html};
|
||||||
use partials::page;
|
use partials::page;
|
||||||
use sqlx::SqlitePool;
|
use sqlx::SqlitePool;
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
|
50
src/route.rs
50
src/route.rs
@ -1,11 +1,11 @@
|
|||||||
use crate::{err, page, station::Station, succ};
|
use crate::{err, page, station::Station, succ};
|
||||||
use axum::{
|
use axum::{
|
||||||
|
Form, Router,
|
||||||
extract::State,
|
extract::State,
|
||||||
response::{IntoResponse, Redirect},
|
response::{IntoResponse, Redirect},
|
||||||
routing::{get, post},
|
routing::{get, post},
|
||||||
Form, Router,
|
|
||||||
};
|
};
|
||||||
use maud::{html, Markup, PreEscaped};
|
use maud::{Markup, PreEscaped, html};
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
use sqlx::{FromRow, SqlitePool};
|
use sqlx::{FromRow, SqlitePool};
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
@ -133,13 +133,13 @@ DROP TABLE temp_pos;",
|
|||||||
|
|
||||||
async fn stations(&self, db: &SqlitePool) -> Vec<Station> {
|
async fn stations(&self, db: &SqlitePool) -> Vec<Station> {
|
||||||
sqlx::query_as::<_, Station>(
|
sqlx::query_as::<_, Station>(
|
||||||
r#"
|
"
|
||||||
SELECT s.id, s.name, s.notes, s.amount_people, s.last_login, s.pw, s.lat, s.lng
|
SELECT s.id, s.name, s.notes, s.amount_people, s.last_login, s.pw, s.lat, s.lng
|
||||||
FROM station s
|
FROM station s
|
||||||
JOIN route_station rs ON s.id = rs.station_id
|
JOIN route_station rs ON s.id = rs.station_id
|
||||||
WHERE rs.route_id = ?
|
WHERE rs.route_id = ?
|
||||||
ORDER BY rs.pos
|
ORDER BY rs.pos
|
||||||
"#,
|
",
|
||||||
)
|
)
|
||||||
.bind(self.id)
|
.bind(self.id)
|
||||||
.fetch_all(db)
|
.fetch_all(db)
|
||||||
@ -149,16 +149,16 @@ DROP TABLE temp_pos;",
|
|||||||
|
|
||||||
async fn stations_not_in_route(&self, db: &SqlitePool) -> Vec<Station> {
|
async fn stations_not_in_route(&self, db: &SqlitePool) -> Vec<Station> {
|
||||||
sqlx::query_as::<_, Station>(
|
sqlx::query_as::<_, Station>(
|
||||||
r#"
|
"
|
||||||
SELECT id, name, notes, amount_people, last_login, pw, lat, lng
|
SELECT id, name, notes, amount_people, last_login, pw, lat, lng
|
||||||
FROM station
|
FROM station
|
||||||
WHERE id NOT IN (
|
WHERE id NOT IN (
|
||||||
SELECT station_id
|
SELECT station_id
|
||||||
FROM route_station
|
FROM route_station
|
||||||
WHERE route_id = ?
|
WHERE route_id = ?
|
||||||
)
|
)
|
||||||
ORDER BY name
|
ORDER BY name
|
||||||
"#,
|
",
|
||||||
)
|
)
|
||||||
.bind(self.id)
|
.bind(self.id)
|
||||||
.fetch_all(db)
|
.fetch_all(db)
|
||||||
@ -226,7 +226,7 @@ async fn create(
|
|||||||
Form(form): Form<CreateForm>,
|
Form(form): Form<CreateForm>,
|
||||||
) -> impl IntoResponse {
|
) -> impl IntoResponse {
|
||||||
match Route::create(&db, &form.name).await {
|
match Route::create(&db, &form.name).await {
|
||||||
Ok(_) => succ!(session,"Route '{}' erfolgreich erstellt!", form.name),
|
Ok(()) => succ!(session, "Route '{}' erfolgreich erstellt!", form.name),
|
||||||
Err(e) => err!(
|
Err(e) => err!(
|
||||||
session,
|
session,
|
||||||
"Route '{}' konnte _NICHT_ erstellt werden, da es bereits eine Route mit diesem Namen gibt ({e})!",
|
"Route '{}' konnte _NICHT_ erstellt werden, da es bereits eine Route mit diesem Namen gibt ({e})!",
|
||||||
@ -252,7 +252,7 @@ async fn delete(
|
|||||||
};
|
};
|
||||||
|
|
||||||
match route.delete(&db).await {
|
match route.delete(&db).await {
|
||||||
Ok(_) => succ!(session, "Route '{}' erfolgreich gelöscht!", route.name),
|
Ok(()) => succ!(session, "Route '{}' erfolgreich gelöscht!", route.name),
|
||||||
Err(e) => err!(
|
Err(e) => err!(
|
||||||
session,
|
session,
|
||||||
"Route '{}' kann nicht gelöscht werden, da sie bereits verwendet wird. ({e})",
|
"Route '{}' kann nicht gelöscht werden, da sie bereits verwendet wird. ({e})",
|
||||||
@ -403,7 +403,7 @@ async fn add_station(
|
|||||||
};
|
};
|
||||||
|
|
||||||
match route.add_station(&db, &station).await {
|
match route.add_station(&db, &station).await {
|
||||||
Ok(_) => succ!(
|
Ok(()) => succ!(
|
||||||
session,
|
session,
|
||||||
"Station {} wurde der Route {} hinzugefügt",
|
"Station {} wurde der Route {} hinzugefügt",
|
||||||
station.name,
|
station.name,
|
||||||
@ -436,7 +436,8 @@ async fn delete_station(
|
|||||||
let Some(station) = Station::find_by_id(&db, station_id).await else {
|
let Some(station) = Station::find_by_id(&db, station_id).await else {
|
||||||
err!(
|
err!(
|
||||||
session,
|
session,
|
||||||
"Konnte Station mit der ID {station_id} nicht von der Route {} entfernen, da die Station nicht existiert.", route.name
|
"Konnte Station mit der ID {station_id} nicht von der Route {} entfernen, da die Station nicht existiert.",
|
||||||
|
route.name
|
||||||
);
|
);
|
||||||
|
|
||||||
return Redirect::to(&format!("/route/{route_id}"));
|
return Redirect::to(&format!("/route/{route_id}"));
|
||||||
@ -477,7 +478,8 @@ async fn move_station_higher(
|
|||||||
let Some(station) = Station::find_by_id(&db, station_id).await else {
|
let Some(station) = Station::find_by_id(&db, station_id).await else {
|
||||||
err!(
|
err!(
|
||||||
session,
|
session,
|
||||||
"Konnte Station mit der ID {station_id} nicht in der Route {} verschieben, da die Station nicht existiert.", route.name
|
"Konnte Station mit der ID {station_id} nicht in der Route {} verschieben, da die Station nicht existiert.",
|
||||||
|
route.name
|
||||||
);
|
);
|
||||||
|
|
||||||
return Redirect::to(&format!("/route/{route_id}"));
|
return Redirect::to(&format!("/route/{route_id}"));
|
||||||
|
@ -114,13 +114,13 @@ impl Station {
|
|||||||
|
|
||||||
async fn routes(&self, db: &SqlitePool) -> Vec<Route> {
|
async fn routes(&self, db: &SqlitePool) -> Vec<Route> {
|
||||||
sqlx::query_as::<_, Route>(
|
sqlx::query_as::<_, Route>(
|
||||||
r#"
|
"
|
||||||
SELECT r.id, r.name
|
SELECT r.id, r.name
|
||||||
FROM route r
|
FROM route r
|
||||||
JOIN route_station rs ON r.id = rs.route_id
|
JOIN route_station rs ON r.id = rs.route_id
|
||||||
WHERE rs.station_id = ?
|
WHERE rs.station_id = ?
|
||||||
ORDER BY rs.pos
|
ORDER BY rs.pos
|
||||||
"#,
|
",
|
||||||
)
|
)
|
||||||
.bind(self.id)
|
.bind(self.id)
|
||||||
.fetch_all(db)
|
.fetch_all(db)
|
||||||
|
@ -1,11 +1,11 @@
|
|||||||
use crate::{err, partials::page, station::Station, succ};
|
use crate::{err, partials::page, station::Station, succ};
|
||||||
use axum::{
|
use axum::{
|
||||||
|
Form, Router,
|
||||||
extract::State,
|
extract::State,
|
||||||
response::{IntoResponse, Redirect},
|
response::{IntoResponse, Redirect},
|
||||||
routing::{get, post},
|
routing::{get, post},
|
||||||
Form, Router,
|
|
||||||
};
|
};
|
||||||
use maud::{html, Markup};
|
use maud::{Markup, html};
|
||||||
use serde::Deserialize;
|
use serde::Deserialize;
|
||||||
use sqlx::SqlitePool;
|
use sqlx::SqlitePool;
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
@ -22,7 +22,7 @@ async fn create(
|
|||||||
Form(form): Form<CreateForm>,
|
Form(form): Form<CreateForm>,
|
||||||
) -> impl IntoResponse {
|
) -> impl IntoResponse {
|
||||||
match Station::create(&db, &form.name).await {
|
match Station::create(&db, &form.name).await {
|
||||||
Ok(_) => succ!(session,"Station '{}' erfolgreich erstellt!", form.name),
|
Ok(()) => succ!(session, "Station '{}' erfolgreich erstellt!", form.name),
|
||||||
Err(e) => err!(
|
Err(e) => err!(
|
||||||
session,
|
session,
|
||||||
"Station '{}' konnte _NICHT_ erstellt werden, da es bereits eine Station mit diesem Namen gibt ({e})!",
|
"Station '{}' konnte _NICHT_ erstellt werden, da es bereits eine Station mit diesem Namen gibt ({e})!",
|
||||||
@ -48,7 +48,7 @@ async fn delete(
|
|||||||
};
|
};
|
||||||
|
|
||||||
match station.delete(&db).await {
|
match station.delete(&db).await {
|
||||||
Ok(_) => succ!(session, "Station '{}' erfolgreich gelöscht!", station.name),
|
Ok(()) => succ!(session, "Station '{}' erfolgreich gelöscht!", station.name),
|
||||||
Err(e) => err!(
|
Err(e) => err!(
|
||||||
session,
|
session,
|
||||||
"Station '{}' kann nicht gelöscht werden, da sie bereits verwendet wird. ({e})",
|
"Station '{}' kann nicht gelöscht werden, da sie bereits verwendet wird. ({e})",
|
||||||
|
Loading…
x
Reference in New Issue
Block a user