Skip to content

Commit cb16b3f

Browse files
committed
backend: move get_charger_from_db function to utils
1 parent 5c69bed commit cb16b3f

File tree

7 files changed

+34
-34
lines changed

7 files changed

+34
-34
lines changed

backend/src/routes/charger/add.rs

Lines changed: 1 addition & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ use actix_web::{put, web, HttpResponse, Responder};
2121
use argon2::{Argon2, PasswordHash, PasswordVerifier};
2222
use base64::prelude::*;
2323
use db_connector::models::{allowed_users::AllowedUser, chargers::Charger, wg_keys::WgKey};
24-
use diesel::{prelude::*, result::Error::NotFound};
24+
use diesel::prelude::*;
2525
use ipnetwork::IpNetwork;
2626
use rand::{distr::Alphanumeric, Rng, TryRngCore};
2727
use rand_core::OsRng;
@@ -201,28 +201,6 @@ pub async fn register_charger(
201201
Ok(resp)
202202
}
203203

204-
pub async fn get_charger_from_db(
205-
charger_id: uuid::Uuid,
206-
state: &web::Data<AppState>,
207-
) -> actix_web::Result<Charger> {
208-
let mut conn = get_connection(state)?;
209-
let charger: Charger = web_block_unpacked(move || {
210-
use db_connector::schema::chargers::dsl::*;
211-
212-
match chargers
213-
.filter(id.eq(charger_id))
214-
.select(Charger::as_select())
215-
.get_result(&mut conn)
216-
{
217-
Ok(c) => Ok(c),
218-
Err(NotFound) => Err(Error::WrongCredentials),
219-
Err(_err) => Err(Error::InternalError),
220-
}
221-
})
222-
.await?;
223-
224-
Ok(charger)
225-
}
226204

227205
pub fn password_matches(password: &str, password_in_db: &str) -> actix_web::Result<bool> {
228206
let password_hash = match PasswordHash::new(password_in_db) {

backend/src/routes/charger/allow_user.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,10 +29,9 @@ use crate::{
2929
rate_limit::ChargerRateLimiter,
3030
routes::{
3131
auth::login::{validate_password, FindBy},
32-
charger::add::get_charger_from_db,
3332
user::get_user_id,
3433
},
35-
utils::{get_connection, parse_uuid, validate_auth_token, web_block_unpacked},
34+
utils::{get_charger_from_db, get_connection, parse_uuid, validate_auth_token, web_block_unpacked},
3635
AppState,
3736
};
3837

backend/src/routes/management.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,9 +32,9 @@ use utoipa::ToSchema;
3232
use crate::{
3333
error::Error,
3434
rate_limit::ChargerRateLimiter,
35-
routes::{auth::login::FindBy, charger::add::get_charger_from_db, user::get_user_id},
35+
routes::{auth::login::FindBy, user::get_user_id},
3636
utils::{
37-
get_charger_by_uid, get_connection, parse_uuid, update_charger_state_change,
37+
get_charger_by_uid, get_charger_from_db, get_connection, parse_uuid, update_charger_state_change,
3838
web_block_unpacked,
3939
},
4040
AppState, BridgeState,

backend/src/routes/mod.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ pub mod management;
2424
pub mod selfdestruct;
2525
pub mod send_chargelog_to_user;
2626
pub mod state;
27-
pub mod static_files;
27+
pub mod webinterface;
2828
pub mod user;
2929

3030
use actix_web::web::{self, scope};
@@ -35,7 +35,6 @@ pub fn configure(cfg: &mut web::ServiceConfig) {
3535
cfg.configure(user::configure);
3636
cfg.configure(auth::configure);
3737
cfg.configure(charger::configure);
38-
cfg.configure(static_files::configure);
3938

4039
cfg.service(management::management);
4140
cfg.service(send_chargelog_to_user::send_chargelog);
@@ -47,6 +46,7 @@ pub fn configure(cfg: &mut web::ServiceConfig) {
4746

4847
let scope = scope("")
4948
.wrap(JwtMiddleware)
50-
.service(ws_udp_bridge::start_ws);
49+
.service(ws_udp_bridge::start_ws)
50+
.service(webinterface::get_webinterface);
5151
cfg.service(scope);
5252
}

backend/src/routes/selfdestruct.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,8 @@ use utoipa::ToSchema;
77
use crate::{
88
error::Error,
99
rate_limit::ChargerRateLimiter,
10-
routes::charger::add::{get_charger_from_db, password_matches},
11-
utils::{get_charger_by_uid, get_connection, parse_uuid, web_block_unpacked},
10+
routes::charger::add::password_matches,
11+
utils::{get_charger_by_uid, get_charger_from_db, get_connection, parse_uuid, web_block_unpacked},
1212
AppState,
1313
};
1414

backend/src/routes/send_chargelog_to_user.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,10 +7,10 @@ use crate::{
77
error::Error,
88
rate_limit::ChargerRateLimiter,
99
routes::{
10-
charger::add::{get_charger_from_db, password_matches},
10+
charger::add::password_matches,
1111
user::get_user,
1212
},
13-
utils::{parse_uuid, send_email_with_attachment},
13+
utils::{get_charger_from_db, parse_uuid, send_email_with_attachment},
1414
AppState,
1515
};
1616

backend/src/utils.rs

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -117,6 +117,29 @@ pub async fn get_charger_by_uid(
117117
Err(Error::ChargerCredentialsWrong.into())
118118
}
119119

120+
pub async fn get_charger_from_db(
121+
charger_id: uuid::Uuid,
122+
state: &web::Data<AppState>,
123+
) -> actix_web::Result<Charger> {
124+
let mut conn = get_connection(state)?;
125+
let charger: Charger = web_block_unpacked(move || {
126+
use db_connector::schema::chargers::dsl::*;
127+
128+
match chargers
129+
.filter(id.eq(charger_id))
130+
.select(Charger::as_select())
131+
.get_result(&mut conn)
132+
{
133+
Ok(c) => Ok(c),
134+
Err(NotFound) => Err(Error::WrongCredentials),
135+
Err(_err) => Err(Error::InternalError),
136+
}
137+
})
138+
.await?;
139+
140+
Ok(charger)
141+
}
142+
120143
pub async fn validate_auth_token(
121144
token: String,
122145
user_id: uuid::Uuid,

0 commit comments

Comments
 (0)