aboutsummaryrefslogtreecommitdiff
path: root/backend/src/routes
diff options
context:
space:
mode:
authorIlion Beyst <ilion.beyst@gmail.com>2021-12-30 11:45:59 +0100
committerIlion Beyst <ilion.beyst@gmail.com>2021-12-30 11:45:59 +0100
commit3edf5d60f54bfd0cd2c818e5fb1ca133e324325d (patch)
tree9b8bd057e3e27c9e2488957f02ffc8de4ed4c438 /backend/src/routes
parent71ee6c99e963d96286cae8d0bfc2f20a9c9c920b (diff)
downloadplanetwars.dev-3edf5d60f54bfd0cd2c818e5fb1ca133e324325d.tar.xz
planetwars.dev-3edf5d60f54bfd0cd2c818e5fb1ca133e324325d.zip
rename to planetwars-server
Diffstat (limited to 'backend/src/routes')
-rw-r--r--backend/src/routes/bots.rs75
-rw-r--r--backend/src/routes/mod.rs2
-rw-r--r--backend/src/routes/users.rs94
3 files changed, 0 insertions, 171 deletions
diff --git a/backend/src/routes/bots.rs b/backend/src/routes/bots.rs
deleted file mode 100644
index da09669..0000000
--- a/backend/src/routes/bots.rs
+++ /dev/null
@@ -1,75 +0,0 @@
-use axum::extract::{Path, RawBody};
-use axum::http::StatusCode;
-use axum::Json;
-use rand::Rng;
-use serde::{Deserialize, Serialize};
-use std::io::Cursor;
-use std::path;
-
-use crate::db::bots::{self, CodeBundle};
-use crate::db::users::User;
-use crate::DatabaseConnection;
-use bots::Bot;
-
-#[derive(Serialize, Deserialize, Debug)]
-pub struct BotParams {
- name: String,
-}
-
-pub async fn create_bot(
- conn: DatabaseConnection,
- user: User,
- params: Json<BotParams>,
-) -> (StatusCode, Json<Bot>) {
- let bot_params = bots::NewBot {
- owner_id: user.id,
- name: &params.name,
- };
- let bot = bots::create_bot(&bot_params, &conn).unwrap();
- (StatusCode::CREATED, Json(bot))
-}
-
-// TODO: handle errors
-pub async fn get_bot(conn: DatabaseConnection, Path(bot_id): Path<i32>) -> Json<Bot> {
- let bot = bots::find_bot(bot_id, &conn).unwrap();
- Json(bot)
-}
-
-// TODO: proper error handling
-pub async fn upload_bot_code(
- conn: DatabaseConnection,
- user: User,
- Path(bot_id): Path<i32>,
- RawBody(body): RawBody,
-) -> (StatusCode, Json<CodeBundle>) {
- // TODO: put in config somewhere
- let data_path = "./data/bots";
-
- let bot = bots::find_bot(bot_id, &conn).expect("Bot not found");
-
- assert_eq!(user.id, bot.owner_id);
-
- // generate a random filename
- let token: [u8; 16] = rand::thread_rng().gen();
- let name = base64::encode(&token);
-
- let path = path::Path::new(data_path).join(name);
- // let capped_buf = data.open(10usize.megabytes()).into_bytes().await.unwrap();
- // assert!(capped_buf.is_complete());
- // let buf = capped_buf.into_inner();
- let buf = hyper::body::to_bytes(body).await.unwrap();
-
- zip::ZipArchive::new(Cursor::new(buf))
- .unwrap()
- .extract(&path)
- .unwrap();
-
- let bundle = bots::NewCodeBundle {
- bot_id: bot.id,
- path: path.to_str().unwrap(),
- };
- let code_bundle =
- bots::create_code_bundle(&bundle, &conn).expect("Failed to create code bundle");
-
- (StatusCode::CREATED, Json(code_bundle))
-}
diff --git a/backend/src/routes/mod.rs b/backend/src/routes/mod.rs
deleted file mode 100644
index 718d7ef..0000000
--- a/backend/src/routes/mod.rs
+++ /dev/null
@@ -1,2 +0,0 @@
-pub mod bots;
-pub mod users;
diff --git a/backend/src/routes/users.rs b/backend/src/routes/users.rs
deleted file mode 100644
index fc77d7b..0000000
--- a/backend/src/routes/users.rs
+++ /dev/null
@@ -1,94 +0,0 @@
-use crate::db::users::{Credentials, User};
-use crate::db::{sessions, users};
-use crate::DatabaseConnection;
-use axum::extract::{FromRequest, RequestParts, TypedHeader};
-use axum::headers::authorization::Bearer;
-use axum::headers::Authorization;
-use axum::http::StatusCode;
-use axum::{async_trait, Json};
-use serde::{Deserialize, Serialize};
-
-type AuthorizationHeader = TypedHeader<Authorization<Bearer>>;
-
-#[async_trait]
-impl<B> FromRequest<B> for User
-where
- B: Send,
-{
- type Rejection = (StatusCode, String);
-
- async fn from_request(req: &mut RequestParts<B>) -> Result<Self, Self::Rejection> {
- let conn = DatabaseConnection::from_request(req).await?;
- let TypedHeader(Authorization(bearer)) = AuthorizationHeader::from_request(req)
- .await
- .map_err(|_| (StatusCode::UNAUTHORIZED, "".to_string()))?;
-
- let (_session, user) = sessions::find_user_by_session(bearer.token(), &conn)
- .map_err(|_| (StatusCode::UNAUTHORIZED, "".to_string()))?;
-
- Ok(user)
- }
-}
-
-#[derive(Serialize, Deserialize)]
-pub struct UserData {
- pub user_id: i32,
- pub username: String,
-}
-
-impl From<User> for UserData {
- fn from(user: User) -> Self {
- UserData {
- user_id: user.id,
- username: user.username,
- }
- }
-}
-
-#[derive(Deserialize)]
-pub struct RegistrationParams {
- pub username: String,
- pub password: String,
-}
-
-pub async fn register(
- conn: DatabaseConnection,
- params: Json<RegistrationParams>,
-) -> Json<UserData> {
- let credentials = Credentials {
- username: &params.username,
- password: &params.password,
- };
- let user = users::create_user(&credentials, &conn).unwrap();
- Json(user.into())
-}
-
-#[derive(Deserialize)]
-pub struct LoginParams {
- pub username: String,
- pub password: String,
-}
-
-pub async fn login(
- conn: DatabaseConnection,
- params: Json<LoginParams>,
-) -> Result<String, StatusCode> {
- let credentials = Credentials {
- username: &params.username,
- password: &params.password,
- };
- // TODO: handle failures
- let authenticated = users::authenticate_user(&credentials, &conn);
-
- match authenticated {
- None => Err(StatusCode::FORBIDDEN),
- Some(user) => {
- let session = sessions::create_session(&user, &conn);
- Ok(session.token)
- }
- }
-}
-
-pub async fn current_user(user: User) -> Json<UserData> {
- Json(user.into())
-}