forked from Roflin/gamenight
Merge pull request 'gamenight-participants' (#6) from gamenight-participants into main
Reviewed-on: Roflin/gamenight#6
This commit is contained in:
commit
8a318e877f
25
backend/Cargo.lock
generated
25
backend/Cargo.lock
generated
@ -518,6 +518,7 @@ checksum = "f73fe65f54d1e12b726f517d3e2135ca3125a437b6d998caf1962961f7172d9e"
|
|||||||
dependencies = [
|
dependencies = [
|
||||||
"futures-channel",
|
"futures-channel",
|
||||||
"futures-core",
|
"futures-core",
|
||||||
|
"futures-executor",
|
||||||
"futures-io",
|
"futures-io",
|
||||||
"futures-sink",
|
"futures-sink",
|
||||||
"futures-task",
|
"futures-task",
|
||||||
@ -540,12 +541,34 @@ version = "0.3.21"
|
|||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "0c09fd04b7e4073ac7156a9539b57a484a8ea920f79c7c675d05d289ab6110d3"
|
checksum = "0c09fd04b7e4073ac7156a9539b57a484a8ea920f79c7c675d05d289ab6110d3"
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "futures-executor"
|
||||||
|
version = "0.3.21"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "9420b90cfa29e327d0429f19be13e7ddb68fa1cccb09d65e5706b8c7a749b8a6"
|
||||||
|
dependencies = [
|
||||||
|
"futures-core",
|
||||||
|
"futures-task",
|
||||||
|
"futures-util",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "futures-io"
|
name = "futures-io"
|
||||||
version = "0.3.21"
|
version = "0.3.21"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "fc4045962a5a5e935ee2fdedaa4e08284547402885ab326734432bed5d12966b"
|
checksum = "fc4045962a5a5e935ee2fdedaa4e08284547402885ab326734432bed5d12966b"
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "futures-macro"
|
||||||
|
version = "0.3.21"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "33c1e13800337f4d4d7a316bf45a567dbcb6ffe087f16424852d97e97a91f512"
|
||||||
|
dependencies = [
|
||||||
|
"proc-macro2",
|
||||||
|
"quote",
|
||||||
|
"syn",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "futures-sink"
|
name = "futures-sink"
|
||||||
version = "0.3.21"
|
version = "0.3.21"
|
||||||
@ -567,6 +590,7 @@ dependencies = [
|
|||||||
"futures-channel",
|
"futures-channel",
|
||||||
"futures-core",
|
"futures-core",
|
||||||
"futures-io",
|
"futures-io",
|
||||||
|
"futures-macro",
|
||||||
"futures-sink",
|
"futures-sink",
|
||||||
"futures-task",
|
"futures-task",
|
||||||
"memchr",
|
"memchr",
|
||||||
@ -584,6 +608,7 @@ dependencies = [
|
|||||||
"diesel",
|
"diesel",
|
||||||
"diesel-derive-enum",
|
"diesel-derive-enum",
|
||||||
"diesel_migrations",
|
"diesel_migrations",
|
||||||
|
"futures",
|
||||||
"jsonwebtoken",
|
"jsonwebtoken",
|
||||||
"local-ip-address",
|
"local-ip-address",
|
||||||
"password-hash",
|
"password-hash",
|
||||||
|
@ -23,3 +23,4 @@ validator = { version = "0.14", features = ["derive"] }
|
|||||||
rocket_cors = "0.6.0-alpha1"
|
rocket_cors = "0.6.0-alpha1"
|
||||||
local-ip-address = "0.4"
|
local-ip-address = "0.4"
|
||||||
uuid = { version = "0.8.2", features = ["v4", "serde"] }
|
uuid = { version = "0.8.2", features = ["v4", "serde"] }
|
||||||
|
futures = "0.3.21"
|
@ -0,0 +1,3 @@
|
|||||||
|
-- This file should undo anything in `up.sql`
|
||||||
|
|
||||||
|
drop table gamenight_participants;
|
@ -0,0 +1,9 @@
|
|||||||
|
-- Your SQL goes here
|
||||||
|
|
||||||
|
create table gamenight_participants (
|
||||||
|
gamenight_id UUID NOT NULL,
|
||||||
|
user_id UUID NOT NULL,
|
||||||
|
CONSTRAINT FK_gamenight_id FOREIGN KEY (gamenight_id) REFERENCES gamenight(id) ON DELETE CASCADE,
|
||||||
|
CONSTRAINT FK_user_id FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE,
|
||||||
|
PRIMARY KEY(gamenight_id, user_id)
|
||||||
|
)
|
@ -1,35 +1,24 @@
|
|||||||
use uuid::Uuid;
|
use crate::schema::gamenight::*;
|
||||||
use crate::schema;
|
use crate::schema::users::*;
|
||||||
|
use crate::schema::DatabaseError;
|
||||||
use crate::schema::DbConn;
|
use crate::schema::DbConn;
|
||||||
use crate::AppConfig;
|
use crate::AppConfig;
|
||||||
use chrono::Utc;
|
use chrono::Utc;
|
||||||
use jsonwebtoken::decode;
|
use futures::future::join_all;
|
||||||
use jsonwebtoken::encode;
|
use jsonwebtoken::{decode, encode, DecodingKey, EncodingKey, Header, Validation};
|
||||||
use jsonwebtoken::DecodingKey;
|
|
||||||
use jsonwebtoken::Validation;
|
|
||||||
use jsonwebtoken::{EncodingKey, Header};
|
|
||||||
use rocket::http::Status;
|
use rocket::http::Status;
|
||||||
use rocket::request::Outcome;
|
use rocket::request::{FromRequest, Outcome, Request};
|
||||||
use rocket::request::{FromRequest, Request};
|
|
||||||
use rocket::serde::json::{json, Json, Value};
|
use rocket::serde::json::{json, Json, Value};
|
||||||
use rocket::State;
|
use rocket::State;
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
use std::borrow::Cow;
|
use std::borrow::Cow;
|
||||||
|
use uuid::Uuid;
|
||||||
use validator::ValidateArgs;
|
use validator::ValidateArgs;
|
||||||
|
|
||||||
#[derive(Debug, Responder)]
|
#[derive(Debug, Responder)]
|
||||||
pub enum ApiResponseVariant {
|
pub enum ApiResponseVariant {
|
||||||
Status(Status),
|
Status(Status),
|
||||||
// Redirect(Redirect),
|
|
||||||
Value(Value),
|
Value(Value),
|
||||||
// Flash(Flash<Redirect>)
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Serialize, Deserialize)]
|
|
||||||
pub struct UserWithToken {
|
|
||||||
#[serde(flatten)]
|
|
||||||
pub user: schema::User,
|
|
||||||
pub jwt: String,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug)]
|
#[derive(Serialize, Deserialize, Debug)]
|
||||||
@ -40,9 +29,9 @@ struct ApiResponse {
|
|||||||
#[serde(skip_serializing_if = "Option::is_none")]
|
#[serde(skip_serializing_if = "Option::is_none")]
|
||||||
user: Option<UserWithToken>,
|
user: Option<UserWithToken>,
|
||||||
#[serde(skip_serializing_if = "Option::is_none")]
|
#[serde(skip_serializing_if = "Option::is_none")]
|
||||||
gamenights: Option<Vec<schema::GameNight>>,
|
gamenights: Option<Vec<GamenightOutput>>,
|
||||||
#[serde(skip_serializing_if = "Option::is_none")]
|
#[serde(skip_serializing_if = "Option::is_none")]
|
||||||
games: Option<Vec<schema::Game>>,
|
games: Option<Vec<Game>>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl ApiResponse {
|
impl ApiResponse {
|
||||||
@ -67,20 +56,20 @@ impl ApiResponse {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn login_response(user: schema::User, jwt: String) -> Self {
|
fn login_response(user: User, jwt: String) -> Self {
|
||||||
Self {
|
Self {
|
||||||
result: Self::SUCCES_RESULT,
|
result: Self::SUCCES_RESULT,
|
||||||
message: None,
|
message: None,
|
||||||
user: Some(UserWithToken {
|
user: Some(UserWithToken {
|
||||||
user: user,
|
user: user,
|
||||||
jwt: jwt
|
jwt: jwt,
|
||||||
}),
|
}),
|
||||||
gamenights: None,
|
gamenights: None,
|
||||||
games: None,
|
games: None,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn gamenight_response(gamenights: Vec<schema::GameNight>) -> Self {
|
fn gamenight_response(gamenights: Vec<GamenightOutput>) -> Self {
|
||||||
Self {
|
Self {
|
||||||
result: Self::SUCCES_RESULT,
|
result: Self::SUCCES_RESULT,
|
||||||
message: None,
|
message: None,
|
||||||
@ -90,7 +79,7 @@ impl ApiResponse {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn games_response(games: Vec<schema::Game>) -> Self {
|
fn games_response(games: Vec<Game>) -> Self {
|
||||||
Self {
|
Self {
|
||||||
result: Self::SUCCES_RESULT,
|
result: Self::SUCCES_RESULT,
|
||||||
message: None,
|
message: None,
|
||||||
@ -110,15 +99,13 @@ const AUTH_HEADER: &str = "Authorization";
|
|||||||
const BEARER: &str = "Bearer ";
|
const BEARER: &str = "Bearer ";
|
||||||
|
|
||||||
#[rocket::async_trait]
|
#[rocket::async_trait]
|
||||||
impl<'r> FromRequest<'r> for schema::User {
|
impl<'r> FromRequest<'r> for User {
|
||||||
type Error = ApiError;
|
type Error = ApiError;
|
||||||
|
|
||||||
async fn from_request(req: &'r Request<'_>) -> Outcome<Self, Self::Error> {
|
async fn from_request(req: &'r Request<'_>) -> Outcome<Self, Self::Error> {
|
||||||
let header = match req.headers().get_one(AUTH_HEADER) {
|
let header = match req.headers().get_one(AUTH_HEADER) {
|
||||||
Some(header) => header,
|
Some(header) => header,
|
||||||
None => {
|
None => return Outcome::Forward(()),
|
||||||
return Outcome::Forward(())
|
|
||||||
}
|
|
||||||
};
|
};
|
||||||
|
|
||||||
if !header.starts_with(BEARER) {
|
if !header.starts_with(BEARER) {
|
||||||
@ -133,25 +120,52 @@ impl<'r> FromRequest<'r> for schema::User {
|
|||||||
&Validation::default(),
|
&Validation::default(),
|
||||||
) {
|
) {
|
||||||
Ok(token) => token,
|
Ok(token) => token,
|
||||||
Err(_) => {
|
Err(_) => return Outcome::Forward(()),
|
||||||
return Outcome::Forward(())
|
|
||||||
}
|
|
||||||
};
|
};
|
||||||
let id = token.claims.uid;
|
let id = token.claims.uid;
|
||||||
|
|
||||||
let conn = req.guard::<DbConn>().await.unwrap();
|
let conn = req.guard::<DbConn>().await.unwrap();
|
||||||
return match schema::get_user(conn, id).await {
|
return match get_user(conn, id).await {
|
||||||
Ok(o) => Outcome::Success(o),
|
Ok(o) => Outcome::Success(o),
|
||||||
Err(_) => Outcome::Forward(())
|
Err(_) => Outcome::Forward(()),
|
||||||
}
|
};
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[derive(Debug, Serialize, Deserialize)]
|
||||||
|
pub struct GamenightOutput {
|
||||||
|
#[serde(flatten)]
|
||||||
|
gamenight: Gamenight,
|
||||||
|
game_list: Vec<Game>,
|
||||||
|
participants: Vec<User>,
|
||||||
|
}
|
||||||
|
|
||||||
#[get("/gamenights")]
|
#[get("/gamenights")]
|
||||||
pub async fn gamenights(conn: DbConn, _user: schema::User) -> ApiResponseVariant {
|
pub async fn gamenights(conn: DbConn, _user: User) -> ApiResponseVariant {
|
||||||
match schema::get_all_gamenights(conn).await {
|
let gamenights = match get_all_gamenights(&conn).await {
|
||||||
Ok(gamenights) => ApiResponseVariant::Value(json!(ApiResponse::gamenight_response(gamenights))),
|
Ok(result) => result,
|
||||||
Err(error) => ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string())))
|
Err(err) => return ApiResponseVariant::Value(json!(ApiResponse::error(err.to_string()))),
|
||||||
|
};
|
||||||
|
|
||||||
|
let conn_ref = &conn;
|
||||||
|
|
||||||
|
let game_results: Result<Vec<GamenightOutput>, DatabaseError> =
|
||||||
|
join_all(gamenights.iter().map(|gn| async move {
|
||||||
|
let games = get_games_of_gamenight(conn_ref, gn.id).await?;
|
||||||
|
let participants = load_participants(conn_ref, gn.id).await?;
|
||||||
|
Ok(GamenightOutput {
|
||||||
|
gamenight: gn.clone(),
|
||||||
|
game_list: games,
|
||||||
|
participants: participants,
|
||||||
|
})
|
||||||
|
}))
|
||||||
|
.await
|
||||||
|
.into_iter()
|
||||||
|
.collect();
|
||||||
|
|
||||||
|
match game_results {
|
||||||
|
Ok(result) => ApiResponseVariant::Value(json!(ApiResponse::gamenight_response(result))),
|
||||||
|
Err(err) => ApiResponseVariant::Value(json!(ApiResponse::error(err.to_string()))),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -161,21 +175,20 @@ pub async fn gamenights_unauthorized() -> ApiResponseVariant {
|
|||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, Deserialize, Clone)]
|
#[derive(Debug, Serialize, Deserialize, Clone)]
|
||||||
pub struct GameNightInput {
|
pub struct GamenightInput {
|
||||||
pub name: String,
|
pub name: String,
|
||||||
pub datetime: String,
|
pub datetime: String,
|
||||||
pub owner_id: Option<Uuid>,
|
pub owner_id: Option<Uuid>,
|
||||||
pub game_list: Vec<schema::Game>,
|
pub game_list: Vec<Game>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl Into<schema::GameNight> for GameNightInput {
|
impl Into<Gamenight> for GamenightInput {
|
||||||
|
fn into(self) -> Gamenight {
|
||||||
fn into(self) -> schema::GameNight {
|
Gamenight {
|
||||||
schema::GameNight {
|
|
||||||
id: Uuid::new_v4(),
|
id: Uuid::new_v4(),
|
||||||
name: self.name,
|
name: self.name,
|
||||||
datetime: self.datetime,
|
datetime: self.datetime,
|
||||||
owner_id: self.owner_id.unwrap()
|
owner_id: self.owner_id.unwrap(),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -183,22 +196,33 @@ impl Into<schema::GameNight> for GameNightInput {
|
|||||||
#[post("/gamenights", format = "application/json", data = "<gamenight_json>")]
|
#[post("/gamenights", format = "application/json", data = "<gamenight_json>")]
|
||||||
pub async fn gamenights_post_json(
|
pub async fn gamenights_post_json(
|
||||||
conn: DbConn,
|
conn: DbConn,
|
||||||
user: schema::User,
|
user: User,
|
||||||
gamenight_json: Json<GameNightInput>,
|
gamenight_json: Json<GamenightInput>,
|
||||||
) -> ApiResponseVariant {
|
) -> ApiResponseVariant {
|
||||||
let mut gamenight = gamenight_json.into_inner();
|
let mut gamenight = gamenight_json.into_inner();
|
||||||
gamenight.owner_id = Some(user.id);
|
gamenight.owner_id = Some(user.id);
|
||||||
|
|
||||||
let mut mutable_game_list = gamenight.game_list.clone();
|
let mut mutable_game_list = gamenight.game_list.clone();
|
||||||
|
|
||||||
match schema::add_unknown_games(&conn, &mut mutable_game_list).await {
|
match add_unknown_games(&conn, &mut mutable_game_list).await {
|
||||||
Ok(_) => (),
|
Ok(_) => (),
|
||||||
Err(err) => return ApiResponseVariant::Value(json!(ApiResponse::error(err.to_string())))
|
Err(err) => return ApiResponseVariant::Value(json!(ApiResponse::error(err.to_string()))),
|
||||||
};
|
};
|
||||||
|
|
||||||
match schema::insert_gamenight(conn, gamenight.clone().into(), mutable_game_list).await {
|
let gamenight_id = match insert_gamenight(&conn, gamenight.clone().into(), mutable_game_list)
|
||||||
|
.await
|
||||||
|
{
|
||||||
|
Ok(id) => id,
|
||||||
|
Err(err) => return ApiResponseVariant::Value(json!(ApiResponse::error(err.to_string()))),
|
||||||
|
};
|
||||||
|
|
||||||
|
let participant = GamenightParticipantsEntry {
|
||||||
|
gamenight_id: gamenight_id,
|
||||||
|
user_id: user.id,
|
||||||
|
};
|
||||||
|
match insert_participant(&conn, participant).await {
|
||||||
Ok(_) => ApiResponseVariant::Value(json!(ApiResponse::SUCCES)),
|
Ok(_) => ApiResponseVariant::Value(json!(ApiResponse::SUCCES)),
|
||||||
Err(err) => ApiResponseVariant::Value(json!(ApiResponse::error(err.to_string())))
|
Err(err) => ApiResponseVariant::Value(json!(ApiResponse::error(err.to_string()))),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -207,44 +231,46 @@ pub async fn gamenights_post_json_unauthorized() -> ApiResponseVariant {
|
|||||||
ApiResponseVariant::Status(Status::Unauthorized)
|
ApiResponseVariant::Status(Status::Unauthorized)
|
||||||
}
|
}
|
||||||
|
|
||||||
#[delete("/gamenights", format = "application/json", data = "<delete_gamenight_json>")]
|
#[delete(
|
||||||
|
"/gamenights",
|
||||||
|
format = "application/json",
|
||||||
|
data = "<delete_gamenight_json>"
|
||||||
|
)]
|
||||||
pub async fn gamenights_delete_json(
|
pub async fn gamenights_delete_json(
|
||||||
conn: DbConn,
|
conn: DbConn,
|
||||||
user: schema::User,
|
user: User,
|
||||||
delete_gamenight_json: Json<schema::DeleteGameNight>
|
delete_gamenight_json: Json<DeleteGamenight>,
|
||||||
) -> ApiResponseVariant {
|
) -> ApiResponseVariant {
|
||||||
if user.role == schema::Role::Admin {
|
if user.role == Role::Admin {
|
||||||
if let Err(error) = schema::delete_gamenight(&conn, delete_gamenight_json.game_id).await {
|
if let Err(error) = delete_gamenight(&conn, delete_gamenight_json.game_id).await {
|
||||||
return ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string())))
|
return ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string())));
|
||||||
}
|
}
|
||||||
return ApiResponseVariant::Value(json!(ApiResponse::SUCCES))
|
return ApiResponseVariant::Value(json!(ApiResponse::SUCCES));
|
||||||
}
|
}
|
||||||
|
|
||||||
match schema::get_gamenight(&conn, delete_gamenight_json.game_id).await {
|
match get_gamenight(&conn, delete_gamenight_json.game_id).await {
|
||||||
Ok(gamenight) => {
|
Ok(gamenight) => {
|
||||||
if user.id == gamenight.owner_id {
|
if user.id == gamenight.owner_id {
|
||||||
if let Err(error) = schema::delete_gamenight(&conn, delete_gamenight_json.game_id).await {
|
if let Err(error) = delete_gamenight(&conn, delete_gamenight_json.game_id).await {
|
||||||
return ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string())))
|
return ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string())));
|
||||||
}
|
}
|
||||||
return ApiResponseVariant::Value(json!(ApiResponse::SUCCES))
|
return ApiResponseVariant::Value(json!(ApiResponse::SUCCES));
|
||||||
}
|
}
|
||||||
},
|
}
|
||||||
Err(error) => return ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string())))
|
Err(error) => {
|
||||||
|
return ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string())))
|
||||||
|
}
|
||||||
}
|
}
|
||||||
ApiResponseVariant::Status(Status::Unauthorized)
|
ApiResponseVariant::Status(Status::Unauthorized)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
#[delete("/gamenights", rank = 2)]
|
#[delete("/gamenights", rank = 2)]
|
||||||
pub async fn gamenights_delete_json_unauthorized() -> ApiResponseVariant {
|
pub async fn gamenights_delete_json_unauthorized() -> ApiResponseVariant {
|
||||||
ApiResponseVariant::Status(Status::Unauthorized)
|
ApiResponseVariant::Status(Status::Unauthorized)
|
||||||
}
|
}
|
||||||
|
|
||||||
#[post("/register", format = "application/json", data = "<register_json>")]
|
#[post("/register", format = "application/json", data = "<register_json>")]
|
||||||
pub async fn register_post_json(
|
pub async fn register_post_json(conn: DbConn, register_json: Json<Register>) -> ApiResponseVariant {
|
||||||
conn: DbConn,
|
|
||||||
register_json: Json<schema::Register>,
|
|
||||||
) -> ApiResponseVariant {
|
|
||||||
let register = register_json.into_inner();
|
let register = register_json.into_inner();
|
||||||
let register_clone = register.clone();
|
let register_clone = register.clone();
|
||||||
match conn
|
match conn
|
||||||
@ -257,7 +283,7 @@ pub async fn register_post_json(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
match schema::insert_user(conn, register).await {
|
match insert_user(conn, register).await {
|
||||||
Ok(_) => ApiResponseVariant::Value(json!(ApiResponse::SUCCES)),
|
Ok(_) => ApiResponseVariant::Value(json!(ApiResponse::SUCCES)),
|
||||||
Err(err) => ApiResponseVariant::Value(json!(ApiResponse::error(err.to_string()))),
|
Err(err) => ApiResponseVariant::Value(json!(ApiResponse::error(err.to_string()))),
|
||||||
}
|
}
|
||||||
@ -267,16 +293,16 @@ pub async fn register_post_json(
|
|||||||
struct Claims {
|
struct Claims {
|
||||||
exp: i64,
|
exp: i64,
|
||||||
uid: Uuid,
|
uid: Uuid,
|
||||||
role: schema::Role,
|
role: Role,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[post("/login", format = "application/json", data = "<login_json>")]
|
#[post("/login", format = "application/json", data = "<login_json>")]
|
||||||
pub async fn login_post_json(
|
pub async fn login_post_json(
|
||||||
conn: DbConn,
|
conn: DbConn,
|
||||||
config: &State<AppConfig>,
|
config: &State<AppConfig>,
|
||||||
login_json: Json<schema::Login>,
|
login_json: Json<Login>,
|
||||||
) -> ApiResponseVariant {
|
) -> ApiResponseVariant {
|
||||||
match schema::login(conn, login_json.into_inner()).await {
|
match login(conn, login_json.into_inner()).await {
|
||||||
Err(err) => ApiResponseVariant::Value(json!(ApiResponse::error(err.to_string()))),
|
Err(err) => ApiResponseVariant::Value(json!(ApiResponse::error(err.to_string()))),
|
||||||
Ok(login_result) => {
|
Ok(login_result) => {
|
||||||
if !login_result.result {
|
if !login_result.result {
|
||||||
@ -298,7 +324,9 @@ pub async fn login_post_json(
|
|||||||
&my_claims,
|
&my_claims,
|
||||||
&EncodingKey::from_secret(secret.as_bytes()),
|
&EncodingKey::from_secret(secret.as_bytes()),
|
||||||
) {
|
) {
|
||||||
Ok(token) => ApiResponseVariant::Value(json!(ApiResponse::login_response(user, token))),
|
Ok(token) => {
|
||||||
|
ApiResponseVariant::Value(json!(ApiResponse::login_response(user, token)))
|
||||||
|
}
|
||||||
Err(error) => {
|
Err(error) => {
|
||||||
ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string())))
|
ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string())))
|
||||||
}
|
}
|
||||||
@ -308,10 +336,10 @@ pub async fn login_post_json(
|
|||||||
}
|
}
|
||||||
|
|
||||||
#[get("/games")]
|
#[get("/games")]
|
||||||
pub async fn games(conn: DbConn, _user: schema::User) -> ApiResponseVariant {
|
pub async fn games(conn: DbConn, _user: User) -> ApiResponseVariant {
|
||||||
match schema::get_all_known_games(&conn).await {
|
match get_all_known_games(&conn).await {
|
||||||
Ok(games) => ApiResponseVariant::Value(json!(ApiResponse::games_response(games))),
|
Ok(games) => ApiResponseVariant::Value(json!(ApiResponse::games_response(games))),
|
||||||
Err(error) => ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string())))
|
Err(error) => ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string()))),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -320,3 +348,57 @@ pub async fn games_unauthorized() -> ApiResponseVariant {
|
|||||||
ApiResponseVariant::Status(Status::Unauthorized)
|
ApiResponseVariant::Status(Status::Unauthorized)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[get(
|
||||||
|
"/participants",
|
||||||
|
format = "application/json",
|
||||||
|
data = "<gamenight_id_json>"
|
||||||
|
)]
|
||||||
|
pub async fn get_participants(
|
||||||
|
conn: DbConn,
|
||||||
|
_user: User,
|
||||||
|
gamenight_id_json: Json<GamenightId>,
|
||||||
|
) -> ApiResponseVariant {
|
||||||
|
match load_participants(&conn, gamenight_id_json.into_inner().gamenight_id).await {
|
||||||
|
Ok(_) => ApiResponseVariant::Value(json!(ApiResponse::SUCCES)),
|
||||||
|
Err(error) => ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string()))),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[get("/participants", rank = 2)]
|
||||||
|
pub async fn get_participants_unauthorized() -> ApiResponseVariant {
|
||||||
|
ApiResponseVariant::Status(Status::Unauthorized)
|
||||||
|
}
|
||||||
|
|
||||||
|
#[post("/participants", format = "application/json", data = "<entry_json>")]
|
||||||
|
pub async fn post_participants(
|
||||||
|
conn: DbConn,
|
||||||
|
_user: User,
|
||||||
|
entry_json: Json<GamenightParticipantsEntry>,
|
||||||
|
) -> ApiResponseVariant {
|
||||||
|
match insert_participant(&conn, entry_json.into_inner()).await {
|
||||||
|
Ok(_) => ApiResponseVariant::Value(json!(ApiResponse::SUCCES)),
|
||||||
|
Err(error) => ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string()))),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[post("/participants", rank = 2)]
|
||||||
|
pub async fn post_participants_unauthorized() -> ApiResponseVariant {
|
||||||
|
ApiResponseVariant::Status(Status::Unauthorized)
|
||||||
|
}
|
||||||
|
|
||||||
|
#[delete("/participants", format = "application/json", data = "<entry_json>")]
|
||||||
|
pub async fn delete_participants(
|
||||||
|
conn: DbConn,
|
||||||
|
_user: User,
|
||||||
|
entry_json: Json<GamenightParticipantsEntry>,
|
||||||
|
) -> ApiResponseVariant {
|
||||||
|
match remove_participant(&conn, entry_json.into_inner()).await {
|
||||||
|
Ok(_) => ApiResponseVariant::Value(json!(ApiResponse::SUCCES)),
|
||||||
|
Err(error) => ApiResponseVariant::Value(json!(ApiResponse::error(error.to_string()))),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[delete("/participants", rank = 2)]
|
||||||
|
pub async fn delete_participants_unauthorized() -> ApiResponseVariant {
|
||||||
|
ApiResponseVariant::Status(Status::Unauthorized)
|
||||||
|
}
|
||||||
|
@ -46,13 +46,7 @@ async fn rocket() -> _ {
|
|||||||
.attach(AdHoc::on_ignite("Run Migrations", schema::run_migrations))
|
.attach(AdHoc::on_ignite("Run Migrations", schema::run_migrations))
|
||||||
.attach(AdHoc::config::<AppConfig>())
|
.attach(AdHoc::config::<AppConfig>())
|
||||||
.attach(site::make_cors())
|
.attach(site::make_cors())
|
||||||
.mount(
|
.mount("/", routes![site::index, site::files])
|
||||||
"/",
|
|
||||||
routes![
|
|
||||||
site::index,
|
|
||||||
site::files
|
|
||||||
],
|
|
||||||
)
|
|
||||||
.mount(
|
.mount(
|
||||||
"/api",
|
"/api",
|
||||||
routes![
|
routes![
|
||||||
@ -66,6 +60,12 @@ async fn rocket() -> _ {
|
|||||||
api::gamenights_delete_json_unauthorized,
|
api::gamenights_delete_json_unauthorized,
|
||||||
api::games,
|
api::games,
|
||||||
api::games_unauthorized,
|
api::games_unauthorized,
|
||||||
|
api::get_participants,
|
||||||
|
api::get_participants_unauthorized,
|
||||||
|
api::post_participants,
|
||||||
|
api::post_participants_unauthorized,
|
||||||
|
api::delete_participants,
|
||||||
|
api::delete_participants_unauthorized,
|
||||||
],
|
],
|
||||||
);
|
);
|
||||||
|
|
||||||
|
@ -1,360 +0,0 @@
|
|||||||
use uuid::Uuid;
|
|
||||||
use crate::diesel::Connection;
|
|
||||||
use crate::diesel::ExpressionMethods;
|
|
||||||
use crate::diesel::QueryDsl;
|
|
||||||
use argon2::password_hash::SaltString;
|
|
||||||
use argon2::PasswordHash;
|
|
||||||
use argon2::PasswordVerifier;
|
|
||||||
use argon2::{
|
|
||||||
password_hash::{rand_core::OsRng, PasswordHasher},
|
|
||||||
Argon2,
|
|
||||||
};
|
|
||||||
use diesel::RunQueryDsl;
|
|
||||||
use diesel_derive_enum::DbEnum;
|
|
||||||
use rocket::{Build, Rocket};
|
|
||||||
use rocket_sync_db_pools::database;
|
|
||||||
use serde::{Deserialize, Serialize};
|
|
||||||
use std::ops::Deref;
|
|
||||||
use validator::{Validate, ValidationError};
|
|
||||||
|
|
||||||
#[database("gamenight_database")]
|
|
||||||
pub struct DbConn(diesel::PgConnection);
|
|
||||||
|
|
||||||
impl Deref for DbConn {
|
|
||||||
type Target = rocket_sync_db_pools::Connection<DbConn, diesel::PgConnection>;
|
|
||||||
|
|
||||||
fn deref(&self) -> &Self::Target {
|
|
||||||
&self.0
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
table! {
|
|
||||||
gamenight (id) {
|
|
||||||
id -> diesel::sql_types::Uuid,
|
|
||||||
name -> VarChar,
|
|
||||||
datetime -> VarChar,
|
|
||||||
owner_id -> Uuid,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
table! {
|
|
||||||
known_games (id) {
|
|
||||||
id -> diesel::sql_types::Uuid,
|
|
||||||
name -> VarChar,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
table! {
|
|
||||||
users(id) {
|
|
||||||
id -> diesel::sql_types::Uuid,
|
|
||||||
username -> VarChar,
|
|
||||||
email -> VarChar,
|
|
||||||
role -> crate::schema::RoleMapping,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
table! {
|
|
||||||
pwd(user_id) {
|
|
||||||
user_id -> diesel::sql_types::Uuid,
|
|
||||||
password -> VarChar,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
table! {
|
|
||||||
gamenight_gamelist(gamenight_id, game_id) {
|
|
||||||
gamenight_id -> diesel::sql_types::Uuid,
|
|
||||||
game_id -> diesel::sql_types::Uuid,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
allow_tables_to_appear_in_same_query!(gamenight, known_games,);
|
|
||||||
|
|
||||||
pub enum DatabaseError {
|
|
||||||
Hash(password_hash::Error),
|
|
||||||
Query(String),
|
|
||||||
}
|
|
||||||
|
|
||||||
impl From<diesel::result::Error> for DatabaseError {
|
|
||||||
fn from(error: diesel::result::Error) -> Self {
|
|
||||||
Self::Query(error.to_string())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl From<password_hash::Error> for DatabaseError {
|
|
||||||
fn from(error: password_hash::Error) -> Self {
|
|
||||||
Self::Hash(error)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl std::fmt::Display for DatabaseError {
|
|
||||||
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::result::Result<(), std::fmt::Error> {
|
|
||||||
match self {
|
|
||||||
DatabaseError::Hash(err) => write!(f, "{}", err),
|
|
||||||
DatabaseError::Query(err) => write!(f, "{}", err),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn get_all_gamenights(conn: DbConn) -> Result<Vec<GameNight>, DatabaseError> {
|
|
||||||
Ok(conn.run(|c|
|
|
||||||
gamenight::table.load::<GameNight>(c)
|
|
||||||
).await?)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn insert_gamenight(conn: DbConn, new_gamenight: GameNight, game_list: Vec<Game>) -> Result<usize, DatabaseError> {
|
|
||||||
Ok(conn.run(move |c|
|
|
||||||
c.transaction(|| {
|
|
||||||
diesel::insert_into(gamenight::table)
|
|
||||||
.values(&new_gamenight)
|
|
||||||
.execute(c)?;
|
|
||||||
|
|
||||||
let entries: Vec<GamenightGameListEntry> = game_list.iter().map(
|
|
||||||
|g| GamenightGameListEntry { gamenight_id: new_gamenight.id.clone(), game_id: g.id.clone() }
|
|
||||||
).collect();
|
|
||||||
|
|
||||||
diesel::insert_into(gamenight_gamelist::table)
|
|
||||||
.values(entries)
|
|
||||||
.execute(c)
|
|
||||||
})
|
|
||||||
).await?)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn get_gamenight(conn: &DbConn, game_id: Uuid) -> Result<GameNight, DatabaseError> {
|
|
||||||
Ok(conn.run(move |c|
|
|
||||||
gamenight::table.find(game_id).first(c)
|
|
||||||
).await?)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn delete_gamenight(conn: &DbConn, game_id: Uuid) -> Result<usize, DatabaseError> {
|
|
||||||
Ok(conn.run(move |c|
|
|
||||||
diesel::delete(
|
|
||||||
gamenight::table.filter(
|
|
||||||
gamenight::id.eq(game_id)
|
|
||||||
)
|
|
||||||
).execute(c)
|
|
||||||
).await?)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn insert_user(conn: DbConn, new_user: Register) -> Result<usize, DatabaseError> {
|
|
||||||
let salt = SaltString::generate(&mut OsRng);
|
|
||||||
|
|
||||||
let argon2 = Argon2::default();
|
|
||||||
|
|
||||||
let password_hash = argon2.hash_password(new_user.password.as_bytes(), &salt)?.to_string();
|
|
||||||
|
|
||||||
Ok(conn.run(move |c| {
|
|
||||||
c.transaction(|| {
|
|
||||||
let id = Uuid::new_v4();
|
|
||||||
|
|
||||||
diesel::insert_into(users::table)
|
|
||||||
.values(User {
|
|
||||||
id: id.clone(),
|
|
||||||
username: new_user.username,
|
|
||||||
email: new_user.email,
|
|
||||||
role: Role::User
|
|
||||||
})
|
|
||||||
.execute(c)?;
|
|
||||||
|
|
||||||
diesel::insert_into(pwd::table)
|
|
||||||
.values(Pwd {
|
|
||||||
user_id: id,
|
|
||||||
password: password_hash
|
|
||||||
})
|
|
||||||
.execute(c)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
.await?)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn login(conn: DbConn, login: Login) -> Result<LoginResult, DatabaseError> {
|
|
||||||
conn.run(move |c| -> Result<LoginResult, DatabaseError> {
|
|
||||||
let id: Uuid = users::table
|
|
||||||
.filter(users::username.eq(&login.username))
|
|
||||||
.or_filter(users::email.eq(&login.username))
|
|
||||||
.select(users::id)
|
|
||||||
.first(c)?;
|
|
||||||
|
|
||||||
let pwd: String = pwd::table
|
|
||||||
.filter(pwd::user_id.eq(id))
|
|
||||||
.select(pwd::password)
|
|
||||||
.first(c)?;
|
|
||||||
|
|
||||||
let parsed_hash = PasswordHash::new(&pwd)?;
|
|
||||||
|
|
||||||
if Argon2::default()
|
|
||||||
.verify_password(&login.password.as_bytes(), &parsed_hash)
|
|
||||||
.is_ok()
|
|
||||||
{
|
|
||||||
let user: User = users::table.find(id).first(c)?;
|
|
||||||
|
|
||||||
Ok(LoginResult {
|
|
||||||
result: true,
|
|
||||||
user : Some(user)
|
|
||||||
})
|
|
||||||
} else {
|
|
||||||
Ok(LoginResult {
|
|
||||||
result: false,
|
|
||||||
user: None
|
|
||||||
})
|
|
||||||
}
|
|
||||||
})
|
|
||||||
.await
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn get_user(conn: DbConn, id: Uuid) -> Result<User, DatabaseError> {
|
|
||||||
Ok(conn.run(move |c| users::table.filter(users::id.eq(id)).first(c))
|
|
||||||
.await?)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn get_all_known_games(conn: &DbConn) -> Result<Vec<Game>, DatabaseError> {
|
|
||||||
Ok(conn.run(|c|
|
|
||||||
known_games::table.load::<Game>(c)
|
|
||||||
).await?)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn add_game(conn: &DbConn, game: Game) -> Result<usize, DatabaseError> {
|
|
||||||
Ok(conn.run(|c|
|
|
||||||
diesel::insert_into(known_games::table)
|
|
||||||
.values(game)
|
|
||||||
.execute(c)
|
|
||||||
|
|
||||||
).await?)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn add_unknown_games(conn: &DbConn, games: &mut Vec<Game>) -> Result<(), DatabaseError> {
|
|
||||||
let all_games = get_all_known_games(conn).await?;
|
|
||||||
for game in games.iter_mut() {
|
|
||||||
if !all_games.iter().any(|g| g.name == game.name) {
|
|
||||||
game.id = Uuid::new_v4();
|
|
||||||
add_game(conn, game.clone()).await?;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
pub fn unique_username(
|
|
||||||
username: &String,
|
|
||||||
conn: &diesel::PgConnection,
|
|
||||||
) -> Result<(), ValidationError> {
|
|
||||||
match users::table
|
|
||||||
.count()
|
|
||||||
.filter(users::username.eq(username))
|
|
||||||
.get_result(conn)
|
|
||||||
{
|
|
||||||
Ok(0) => Ok(()),
|
|
||||||
Ok(_) => Err(ValidationError::new("User already exists")),
|
|
||||||
Err(_) => Err(ValidationError::new("Database error while validating user")),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn unique_email(
|
|
||||||
email: &String,
|
|
||||||
conn: &diesel::PgConnection,
|
|
||||||
) -> Result<(), ValidationError> {
|
|
||||||
match users::table
|
|
||||||
.count()
|
|
||||||
.filter(users::email.eq(email))
|
|
||||||
.get_result(conn)
|
|
||||||
{
|
|
||||||
Ok(0) => Ok(()),
|
|
||||||
Ok(_) => Err(ValidationError::new("email already exists")),
|
|
||||||
Err(_) => Err(ValidationError::new(
|
|
||||||
"Database error while validating email",
|
|
||||||
)),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn run_migrations(rocket: Rocket<Build>) -> Rocket<Build> {
|
|
||||||
// This macro from `diesel_migrations` defines an `embedded_migrations`
|
|
||||||
// module containing a function named `run`. This allows the example to be
|
|
||||||
// run and tested without any outside setup of the database.
|
|
||||||
embed_migrations!();
|
|
||||||
|
|
||||||
let conn = DbConn::get_one(&rocket).await.expect("database connection");
|
|
||||||
conn.run(|c| embedded_migrations::run(c))
|
|
||||||
.await
|
|
||||||
.expect("can run migrations");
|
|
||||||
|
|
||||||
rocket
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Serialize, Deserialize, DbEnum, Clone, Copy, PartialEq)]
|
|
||||||
pub enum Role {
|
|
||||||
Admin,
|
|
||||||
User,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug, Insertable, Queryable)]
|
|
||||||
#[table_name = "users"]
|
|
||||||
pub struct User {
|
|
||||||
pub id: Uuid,
|
|
||||||
pub username: String,
|
|
||||||
pub email: String,
|
|
||||||
pub role: Role,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug, Insertable, Queryable)]
|
|
||||||
#[table_name = "pwd"]
|
|
||||||
struct Pwd {
|
|
||||||
user_id: Uuid,
|
|
||||||
password: String,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug, Queryable, Clone, Insertable)]
|
|
||||||
#[table_name = "known_games"]
|
|
||||||
pub struct Game {
|
|
||||||
pub id: Uuid,
|
|
||||||
pub name: String,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug, Queryable, Insertable)]
|
|
||||||
#[table_name = "gamenight"]
|
|
||||||
pub struct GameNight {
|
|
||||||
pub id: Uuid,
|
|
||||||
pub name: String,
|
|
||||||
pub datetime: String,
|
|
||||||
pub owner_id: Uuid,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug, Queryable, Insertable)]
|
|
||||||
#[table_name="gamenight_gamelist"]
|
|
||||||
pub struct GamenightGameListEntry {
|
|
||||||
pub gamenight_id: Uuid,
|
|
||||||
pub game_id: Uuid
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug, Queryable)]
|
|
||||||
pub struct DeleteGameNight {
|
|
||||||
pub game_id: Uuid,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug, Validate, Clone)]
|
|
||||||
pub struct Register {
|
|
||||||
#[validate(
|
|
||||||
length(min = 1),
|
|
||||||
custom(function = "unique_username", arg = "&'v_a diesel::PgConnection")
|
|
||||||
)]
|
|
||||||
pub username: String,
|
|
||||||
#[validate(
|
|
||||||
email,
|
|
||||||
custom(function = "unique_email", arg = "&'v_a diesel::PgConnection")
|
|
||||||
)]
|
|
||||||
pub email: String,
|
|
||||||
#[validate(length(min = 10), must_match = "password_repeat")]
|
|
||||||
pub password: String,
|
|
||||||
pub password_repeat: String,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug)]
|
|
||||||
pub struct Login {
|
|
||||||
pub username: String,
|
|
||||||
pub password: String,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Serialize, Deserialize, Debug)]
|
|
||||||
pub struct LoginResult {
|
|
||||||
pub result: bool,
|
|
||||||
pub user: Option<User>,
|
|
||||||
}
|
|
219
backend/src/schema/gamenight.rs
Normal file
219
backend/src/schema/gamenight.rs
Normal file
@ -0,0 +1,219 @@
|
|||||||
|
use crate::schema::users::{users, User};
|
||||||
|
use crate::schema::{DatabaseError, DbConn};
|
||||||
|
use diesel::{Connection, ExpressionMethods, QueryDsl, RunQueryDsl};
|
||||||
|
use serde::{Deserialize, Serialize};
|
||||||
|
use uuid::Uuid;
|
||||||
|
|
||||||
|
table! {
|
||||||
|
gamenight (id) {
|
||||||
|
id -> diesel::sql_types::Uuid,
|
||||||
|
name -> VarChar,
|
||||||
|
datetime -> VarChar,
|
||||||
|
owner_id -> Uuid,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
table! {
|
||||||
|
known_games (id) {
|
||||||
|
id -> diesel::sql_types::Uuid,
|
||||||
|
name -> VarChar,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
table! {
|
||||||
|
gamenight_gamelist(gamenight_id, game_id) {
|
||||||
|
gamenight_id -> diesel::sql_types::Uuid,
|
||||||
|
game_id -> diesel::sql_types::Uuid,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
table! {
|
||||||
|
gamenight_participants(gamenight_id, user_id) {
|
||||||
|
gamenight_id -> diesel::sql_types::Uuid,
|
||||||
|
user_id -> diesel::sql_types::Uuid,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize, Deserialize, Debug, Queryable, Clone, Insertable)]
|
||||||
|
#[table_name = "known_games"]
|
||||||
|
pub struct Game {
|
||||||
|
pub id: Uuid,
|
||||||
|
pub name: String,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize, Deserialize, Debug, Queryable, Insertable, Clone)]
|
||||||
|
#[table_name = "gamenight"]
|
||||||
|
pub struct Gamenight {
|
||||||
|
pub id: Uuid,
|
||||||
|
pub name: String,
|
||||||
|
pub datetime: String,
|
||||||
|
pub owner_id: Uuid,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize, Deserialize, Debug, Queryable, Insertable)]
|
||||||
|
#[table_name = "gamenight_gamelist"]
|
||||||
|
pub struct GamenightGameListEntry {
|
||||||
|
pub gamenight_id: Uuid,
|
||||||
|
pub game_id: Uuid,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize, Deserialize, Debug, Queryable, Insertable, Identifiable)]
|
||||||
|
#[table_name = "gamenight_participants"]
|
||||||
|
#[primary_key(gamenight_id, user_id)]
|
||||||
|
pub struct GamenightParticipantsEntry {
|
||||||
|
pub gamenight_id: Uuid,
|
||||||
|
pub user_id: Uuid,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize, Deserialize, Debug, Queryable)]
|
||||||
|
pub struct DeleteGamenight {
|
||||||
|
pub game_id: Uuid,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize, Deserialize, Debug, Queryable)]
|
||||||
|
pub struct GamenightId {
|
||||||
|
pub gamenight_id: Uuid,
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn get_all_gamenights(conn: &DbConn) -> Result<Vec<Gamenight>, DatabaseError> {
|
||||||
|
Ok(conn.run(|c| gamenight::table.load::<Gamenight>(c)).await?)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn insert_gamenight(
|
||||||
|
conn: &DbConn,
|
||||||
|
new_gamenight: Gamenight,
|
||||||
|
game_list: Vec<Game>,
|
||||||
|
) -> Result<Uuid, DatabaseError> {
|
||||||
|
Ok(conn
|
||||||
|
.run(move |c| {
|
||||||
|
c.transaction::<_, DatabaseError, _>(|| {
|
||||||
|
let id: Uuid = diesel::insert_into(gamenight::table)
|
||||||
|
.values(&new_gamenight)
|
||||||
|
.returning(gamenight::id)
|
||||||
|
.get_result(c)?;
|
||||||
|
|
||||||
|
let entries: Vec<GamenightGameListEntry> = game_list
|
||||||
|
.iter()
|
||||||
|
.map(|g| GamenightGameListEntry {
|
||||||
|
gamenight_id: new_gamenight.id.clone(),
|
||||||
|
game_id: g.id.clone(),
|
||||||
|
})
|
||||||
|
.collect();
|
||||||
|
|
||||||
|
diesel::insert_into(gamenight_gamelist::table)
|
||||||
|
.values(entries)
|
||||||
|
.execute(c)?;
|
||||||
|
|
||||||
|
Ok(id)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
.await?)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn get_gamenight(conn: &DbConn, game_id: Uuid) -> Result<Gamenight, DatabaseError> {
|
||||||
|
Ok(conn
|
||||||
|
.run(move |c| gamenight::table.find(game_id).first(c))
|
||||||
|
.await?)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn delete_gamenight(conn: &DbConn, game_id: Uuid) -> Result<usize, DatabaseError> {
|
||||||
|
Ok(conn
|
||||||
|
.run(move |c| diesel::delete(gamenight::table.filter(gamenight::id.eq(game_id))).execute(c))
|
||||||
|
.await?)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn get_all_known_games(conn: &DbConn) -> Result<Vec<Game>, DatabaseError> {
|
||||||
|
Ok(conn.run(|c| known_games::table.load::<Game>(c)).await?)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn get_games_of_gamenight(
|
||||||
|
conn: &DbConn,
|
||||||
|
gamenight_id: Uuid,
|
||||||
|
) -> Result<Vec<Game>, DatabaseError> {
|
||||||
|
Ok(conn
|
||||||
|
.run::<_, Result<Vec<Game>, _>>(move |c| {
|
||||||
|
let linked_game_ids: Vec<GamenightGameListEntry> = gamenight_gamelist::table
|
||||||
|
.filter(gamenight_gamelist::gamenight_id.eq(gamenight_id))
|
||||||
|
.load::<GamenightGameListEntry>(c)?;
|
||||||
|
|
||||||
|
linked_game_ids
|
||||||
|
.iter()
|
||||||
|
.map(|l| {
|
||||||
|
known_games::table
|
||||||
|
.filter(known_games::id.eq(l.game_id))
|
||||||
|
.first::<Game>(c)
|
||||||
|
})
|
||||||
|
.collect()
|
||||||
|
})
|
||||||
|
.await?)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn add_game(conn: &DbConn, game: Game) -> Result<usize, DatabaseError> {
|
||||||
|
Ok(conn
|
||||||
|
.run(|c| {
|
||||||
|
diesel::insert_into(known_games::table)
|
||||||
|
.values(game)
|
||||||
|
.execute(c)
|
||||||
|
})
|
||||||
|
.await?)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn add_unknown_games(conn: &DbConn, games: &mut Vec<Game>) -> Result<(), DatabaseError> {
|
||||||
|
let all_games = get_all_known_games(conn).await?;
|
||||||
|
for game in games.iter_mut() {
|
||||||
|
if !all_games.iter().any(|g| g.name == game.name) {
|
||||||
|
game.id = Uuid::new_v4();
|
||||||
|
add_game(conn, game.clone()).await?;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn load_participants(
|
||||||
|
conn: &DbConn,
|
||||||
|
gamenight_id: Uuid,
|
||||||
|
) -> Result<Vec<User>, DatabaseError> {
|
||||||
|
Ok(conn
|
||||||
|
.run::<_, Result<Vec<User>, _>>(move |c| {
|
||||||
|
let linked_participants = gamenight_participants::table
|
||||||
|
.filter(gamenight_participants::gamenight_id.eq(gamenight_id))
|
||||||
|
.load::<GamenightParticipantsEntry>(c)?;
|
||||||
|
linked_participants
|
||||||
|
.iter()
|
||||||
|
.map(|l| {
|
||||||
|
users::table
|
||||||
|
.filter(users::id.eq(l.user_id))
|
||||||
|
.first::<User>(c)
|
||||||
|
})
|
||||||
|
.collect()
|
||||||
|
})
|
||||||
|
.await?)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn insert_participant(
|
||||||
|
conn: &DbConn,
|
||||||
|
participant: GamenightParticipantsEntry,
|
||||||
|
) -> Result<usize, DatabaseError> {
|
||||||
|
Ok(conn
|
||||||
|
.run(move |c| {
|
||||||
|
diesel::insert_into(gamenight_participants::table)
|
||||||
|
.values(&participant)
|
||||||
|
.execute(c)
|
||||||
|
})
|
||||||
|
.await?)
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<GamenightParticipantsEntry> for (Uuid, Uuid) {
|
||||||
|
fn from(entry: GamenightParticipantsEntry) -> Self {
|
||||||
|
(entry.gamenight_id, entry.user_id)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn remove_participant(
|
||||||
|
conn: &DbConn,
|
||||||
|
participant: GamenightParticipantsEntry,
|
||||||
|
) -> Result<usize, DatabaseError> {
|
||||||
|
Ok(conn
|
||||||
|
.run(move |c| diesel::delete(&participant).execute(c))
|
||||||
|
.await?)
|
||||||
|
}
|
57
backend/src/schema/mod.rs
Normal file
57
backend/src/schema/mod.rs
Normal file
@ -0,0 +1,57 @@
|
|||||||
|
pub mod gamenight;
|
||||||
|
pub mod users;
|
||||||
|
|
||||||
|
use rocket::{Build, Rocket};
|
||||||
|
use rocket_sync_db_pools::database;
|
||||||
|
use std::ops::Deref;
|
||||||
|
|
||||||
|
#[database("gamenight_database")]
|
||||||
|
pub struct DbConn(diesel::PgConnection);
|
||||||
|
|
||||||
|
impl Deref for DbConn {
|
||||||
|
type Target = rocket_sync_db_pools::Connection<DbConn, diesel::PgConnection>;
|
||||||
|
|
||||||
|
fn deref(&self) -> &Self::Target {
|
||||||
|
&self.0
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub enum DatabaseError {
|
||||||
|
Hash(password_hash::Error),
|
||||||
|
Query(String),
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn run_migrations(rocket: Rocket<Build>) -> Rocket<Build> {
|
||||||
|
// This macro from `diesel_migrations` defines an `embedded_migrations`
|
||||||
|
// module containing a function named `run`. This allows the example to be
|
||||||
|
// run and tested without any outside setup of the database.
|
||||||
|
embed_migrations!();
|
||||||
|
|
||||||
|
let conn = DbConn::get_one(&rocket).await.expect("database connection");
|
||||||
|
conn.run(|c| embedded_migrations::run(c))
|
||||||
|
.await
|
||||||
|
.expect("can run migrations");
|
||||||
|
|
||||||
|
rocket
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<diesel::result::Error> for DatabaseError {
|
||||||
|
fn from(error: diesel::result::Error) -> Self {
|
||||||
|
Self::Query(error.to_string())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<password_hash::Error> for DatabaseError {
|
||||||
|
fn from(error: password_hash::Error) -> Self {
|
||||||
|
Self::Hash(error)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl std::fmt::Display for DatabaseError {
|
||||||
|
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::result::Result<(), std::fmt::Error> {
|
||||||
|
match self {
|
||||||
|
DatabaseError::Hash(err) => write!(f, "{}", err),
|
||||||
|
DatabaseError::Query(err) => write!(f, "{}", err),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
191
backend/src/schema/users.rs
Normal file
191
backend/src/schema/users.rs
Normal file
@ -0,0 +1,191 @@
|
|||||||
|
use crate::schema::{DatabaseError, DbConn};
|
||||||
|
use argon2::password_hash::SaltString;
|
||||||
|
use argon2::PasswordHash;
|
||||||
|
use argon2::PasswordVerifier;
|
||||||
|
use argon2::{
|
||||||
|
password_hash::{rand_core::OsRng, PasswordHasher},
|
||||||
|
Argon2,
|
||||||
|
};
|
||||||
|
use diesel::{Connection, ExpressionMethods, QueryDsl, RunQueryDsl};
|
||||||
|
use diesel_derive_enum::DbEnum;
|
||||||
|
use serde::{Deserialize, Serialize};
|
||||||
|
use uuid::Uuid;
|
||||||
|
use validator::{Validate, ValidationError};
|
||||||
|
|
||||||
|
#[derive(Debug, Serialize, Deserialize, DbEnum, Clone, Copy, PartialEq)]
|
||||||
|
pub enum Role {
|
||||||
|
Admin,
|
||||||
|
User,
|
||||||
|
}
|
||||||
|
|
||||||
|
table! {
|
||||||
|
users(id) {
|
||||||
|
id -> diesel::sql_types::Uuid,
|
||||||
|
username -> VarChar,
|
||||||
|
email -> VarChar,
|
||||||
|
role -> crate::schema::users::RoleMapping,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
table! {
|
||||||
|
pwd(user_id) {
|
||||||
|
user_id -> diesel::sql_types::Uuid,
|
||||||
|
password -> VarChar,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize, Deserialize, Debug, Insertable, Queryable)]
|
||||||
|
#[table_name = "pwd"]
|
||||||
|
struct Pwd {
|
||||||
|
user_id: Uuid,
|
||||||
|
password: String,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize, Deserialize, Debug, Insertable, Queryable)]
|
||||||
|
#[table_name = "users"]
|
||||||
|
pub struct User {
|
||||||
|
pub id: Uuid,
|
||||||
|
pub username: String,
|
||||||
|
pub email: String,
|
||||||
|
pub role: Role,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Debug, Serialize, Deserialize)]
|
||||||
|
pub struct UserWithToken {
|
||||||
|
#[serde(flatten)]
|
||||||
|
pub user: User,
|
||||||
|
pub jwt: String,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize, Deserialize, Debug)]
|
||||||
|
pub struct Login {
|
||||||
|
pub username: String,
|
||||||
|
pub password: String,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize, Deserialize, Debug)]
|
||||||
|
pub struct LoginResult {
|
||||||
|
pub result: bool,
|
||||||
|
pub user: Option<User>,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize, Deserialize, Debug, Validate, Clone)]
|
||||||
|
pub struct Register {
|
||||||
|
#[validate(
|
||||||
|
length(min = 1),
|
||||||
|
custom(function = "unique_username", arg = "&'v_a diesel::PgConnection")
|
||||||
|
)]
|
||||||
|
pub username: String,
|
||||||
|
#[validate(
|
||||||
|
email,
|
||||||
|
custom(function = "unique_email", arg = "&'v_a diesel::PgConnection")
|
||||||
|
)]
|
||||||
|
pub email: String,
|
||||||
|
#[validate(length(min = 10), must_match = "password_repeat")]
|
||||||
|
pub password: String,
|
||||||
|
pub password_repeat: String,
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn insert_user(conn: DbConn, new_user: Register) -> Result<usize, DatabaseError> {
|
||||||
|
let salt = SaltString::generate(&mut OsRng);
|
||||||
|
|
||||||
|
let argon2 = Argon2::default();
|
||||||
|
|
||||||
|
let password_hash = argon2
|
||||||
|
.hash_password(new_user.password.as_bytes(), &salt)?
|
||||||
|
.to_string();
|
||||||
|
|
||||||
|
Ok(conn
|
||||||
|
.run(move |c| {
|
||||||
|
c.transaction(|| {
|
||||||
|
let id = Uuid::new_v4();
|
||||||
|
|
||||||
|
diesel::insert_into(users::table)
|
||||||
|
.values(User {
|
||||||
|
id: id.clone(),
|
||||||
|
username: new_user.username,
|
||||||
|
email: new_user.email,
|
||||||
|
role: Role::User,
|
||||||
|
})
|
||||||
|
.execute(c)?;
|
||||||
|
|
||||||
|
diesel::insert_into(pwd::table)
|
||||||
|
.values(Pwd {
|
||||||
|
user_id: id,
|
||||||
|
password: password_hash,
|
||||||
|
})
|
||||||
|
.execute(c)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
.await?)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn login(conn: DbConn, login: Login) -> Result<LoginResult, DatabaseError> {
|
||||||
|
conn.run(move |c| -> Result<LoginResult, DatabaseError> {
|
||||||
|
let id: Uuid = users::table
|
||||||
|
.filter(users::username.eq(&login.username))
|
||||||
|
.or_filter(users::email.eq(&login.username))
|
||||||
|
.select(users::id)
|
||||||
|
.first(c)?;
|
||||||
|
|
||||||
|
let pwd: String = pwd::table
|
||||||
|
.filter(pwd::user_id.eq(id))
|
||||||
|
.select(pwd::password)
|
||||||
|
.first(c)?;
|
||||||
|
|
||||||
|
let parsed_hash = PasswordHash::new(&pwd)?;
|
||||||
|
|
||||||
|
if Argon2::default()
|
||||||
|
.verify_password(&login.password.as_bytes(), &parsed_hash)
|
||||||
|
.is_ok()
|
||||||
|
{
|
||||||
|
let user: User = users::table.find(id).first(c)?;
|
||||||
|
|
||||||
|
Ok(LoginResult {
|
||||||
|
result: true,
|
||||||
|
user: Some(user),
|
||||||
|
})
|
||||||
|
} else {
|
||||||
|
Ok(LoginResult {
|
||||||
|
result: false,
|
||||||
|
user: None,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.await
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn get_user(conn: DbConn, id: Uuid) -> Result<User, DatabaseError> {
|
||||||
|
Ok(conn
|
||||||
|
.run(move |c| users::table.filter(users::id.eq(id)).first(c))
|
||||||
|
.await?)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn unique_username(
|
||||||
|
username: &String,
|
||||||
|
conn: &diesel::PgConnection,
|
||||||
|
) -> Result<(), ValidationError> {
|
||||||
|
match users::table
|
||||||
|
.count()
|
||||||
|
.filter(users::username.eq(username))
|
||||||
|
.get_result(conn)
|
||||||
|
{
|
||||||
|
Ok(0) => Ok(()),
|
||||||
|
Ok(_) => Err(ValidationError::new("User already exists")),
|
||||||
|
Err(_) => Err(ValidationError::new("Database error while validating user")),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn unique_email(email: &String, conn: &diesel::PgConnection) -> Result<(), ValidationError> {
|
||||||
|
match users::table
|
||||||
|
.count()
|
||||||
|
.filter(users::email.eq(email))
|
||||||
|
.get_result(conn)
|
||||||
|
{
|
||||||
|
Ok(0) => Ok(()),
|
||||||
|
Ok(_) => Err(ValidationError::new("email already exists")),
|
||||||
|
Err(_) => Err(ValidationError::new(
|
||||||
|
"Database error while validating email",
|
||||||
|
)),
|
||||||
|
}
|
||||||
|
}
|
@ -1,16 +1,15 @@
|
|||||||
|
use local_ip_address::local_ip;
|
||||||
use rocket::fs::NamedFile;
|
use rocket::fs::NamedFile;
|
||||||
use rocket::http::Method;
|
use rocket::http::Method;
|
||||||
use rocket_cors::{AllowedHeaders, AllowedOrigins, Cors, CorsOptions};
|
use rocket_cors::{AllowedHeaders, AllowedOrigins, Cors, CorsOptions};
|
||||||
use std::io;
|
use std::io;
|
||||||
use std::path::{Path, PathBuf};
|
use std::path::{Path, PathBuf};
|
||||||
use local_ip_address::local_ip;
|
|
||||||
|
|
||||||
|
|
||||||
pub fn make_cors() -> Cors {
|
pub fn make_cors() -> Cors {
|
||||||
let allowed_origins = AllowedOrigins::some_exact(&[
|
let allowed_origins = AllowedOrigins::some_exact(&[
|
||||||
"http://localhost:3000",
|
"http://localhost:3000",
|
||||||
"http://127.0.0.1:3000",
|
"http://127.0.0.1:3000",
|
||||||
&format!("http://{}:8000",local_ip().unwrap())[..],
|
&format!("http://{}:8000", local_ip().unwrap())[..],
|
||||||
"http://localhost:8000",
|
"http://localhost:8000",
|
||||||
"http://0.0.0.0:8000",
|
"http://0.0.0.0:8000",
|
||||||
]);
|
]);
|
||||||
|
@ -2,8 +2,9 @@ import './App.css';
|
|||||||
import React, { useState, useEffect } from 'react';
|
import React, { useState, useEffect } from 'react';
|
||||||
import MenuBar from './components/MenuBar';
|
import MenuBar from './components/MenuBar';
|
||||||
import Login from './components/Login';
|
import Login from './components/Login';
|
||||||
import Gamenights from './components/Gamenights'
|
import Gamenights from './components/Gamenights';
|
||||||
import AddGameNight from './components/AddGameNight'
|
import AddGameNight from './components/AddGameNight';
|
||||||
|
import Gamenight from './components/Gamenight';
|
||||||
|
|
||||||
const localStorageUserKey = 'user';
|
const localStorageUserKey = 'user';
|
||||||
|
|
||||||
@ -13,6 +14,7 @@ function App() {
|
|||||||
const [gamenights, setGamenights] = useState([]);
|
const [gamenights, setGamenights] = useState([]);
|
||||||
const [flashData, setFlashData] = useState({});
|
const [flashData, setFlashData] = useState({});
|
||||||
const [games, setGames] = useState([]);
|
const [games, setGames] = useState([]);
|
||||||
|
const [activeGamenight, setActiveGamenight] = useState(null);
|
||||||
|
|
||||||
const handleLogin = (input) => {
|
const handleLogin = (input) => {
|
||||||
const requestOptions = {
|
const requestOptions = {
|
||||||
@ -48,6 +50,10 @@ function App() {
|
|||||||
setUser({...user});
|
setUser({...user});
|
||||||
};
|
};
|
||||||
|
|
||||||
|
const dismissActiveGamenight = () => {
|
||||||
|
setActiveGamenight(null);
|
||||||
|
};
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (user !== null) {
|
if (user !== null) {
|
||||||
const requestOptions = {
|
const requestOptions = {
|
||||||
@ -101,11 +107,29 @@ function App() {
|
|||||||
</div>
|
</div>
|
||||||
);
|
);
|
||||||
} else {
|
} else {
|
||||||
|
|
||||||
|
let mainview;
|
||||||
|
if(activeGamenight === null) {
|
||||||
|
mainview = <>
|
||||||
|
<AddGameNight user={user} games={games} setFlash={setFlash} refetchGamenights={refetchGamenights} />
|
||||||
|
<Gamenights
|
||||||
|
user={user}
|
||||||
|
setFlash={setFlash}
|
||||||
|
refetchGamenights={refetchGamenights}
|
||||||
|
gamenights={gamenights}
|
||||||
|
onSelectGamenight={(g) => setActiveGamenight(g)}/>
|
||||||
|
</>
|
||||||
|
} else {
|
||||||
|
mainview = <Gamenight
|
||||||
|
gamenight={activeGamenight}
|
||||||
|
onDismis={dismissActiveGamenight}
|
||||||
|
/>
|
||||||
|
}
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<>
|
<>
|
||||||
<MenuBar user={user} onLogout={onLogout} />
|
<MenuBar user={user} onLogout={onLogout} />
|
||||||
<AddGameNight user={user} games={games} setFlash={setFlash} refetchGamenights={refetchGamenights} />
|
{mainview}
|
||||||
<Gamenights user={user} setFlash={setFlash} refetchGamenights={refetchGamenights} gamenights={gamenights} />
|
|
||||||
</>
|
</>
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
@ -2,8 +2,6 @@ import React, { useEffect, useState } from 'react';
|
|||||||
import DateTime from 'react-datetime';
|
import DateTime from 'react-datetime';
|
||||||
import GameAdder from './GameAdder';
|
import GameAdder from './GameAdder';
|
||||||
|
|
||||||
import Autocomplete from '@mui/material/Autocomplete';
|
|
||||||
|
|
||||||
import "react-datetime/css/react-datetime.css";
|
import "react-datetime/css/react-datetime.css";
|
||||||
|
|
||||||
function AddGameNight(props) {
|
function AddGameNight(props) {
|
||||||
@ -12,12 +10,6 @@ function AddGameNight(props) {
|
|||||||
const [date, setDate] = useState(Date.now());
|
const [date, setDate] = useState(Date.now());
|
||||||
const [gameList, setGameList] = useState([]);
|
const [gameList, setGameList] = useState([]);
|
||||||
|
|
||||||
const emptyUuid = "00000000-0000-0000-0000-000000000000";
|
|
||||||
|
|
||||||
//temp hack:
|
|
||||||
props.games = [{id: emptyUuid, name: "mystic vale"}, {id: emptyUuid, name: "Crew"}];
|
|
||||||
|
|
||||||
|
|
||||||
const handleNameChange = (event) => {
|
const handleNameChange = (event) => {
|
||||||
setGameName(event.target.value);
|
setGameName(event.target.value);
|
||||||
};
|
};
|
||||||
|
38
frontend/src/components/Gamenight.jsx
Normal file
38
frontend/src/components/Gamenight.jsx
Normal file
@ -0,0 +1,38 @@
|
|||||||
|
import * as React from 'react';
|
||||||
|
|
||||||
|
function Gamenight(props) {
|
||||||
|
|
||||||
|
let games = props.gamenight.game_list.map(g =>
|
||||||
|
(
|
||||||
|
<li>
|
||||||
|
<span>{g.name}</span>
|
||||||
|
</li>
|
||||||
|
)
|
||||||
|
);
|
||||||
|
|
||||||
|
let participants = props.gamenight.participants.map(p =>
|
||||||
|
(
|
||||||
|
<li>
|
||||||
|
<span>{p.username}</span>
|
||||||
|
</li>
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
|
return (
|
||||||
|
<div>
|
||||||
|
<h3>{props.gamenight.name}</h3>
|
||||||
|
<button onClick={(e) => props.onDismis()}>x</button>
|
||||||
|
<span>{props.gamenight.datetime}</span>
|
||||||
|
<h4>Games:</h4>
|
||||||
|
<ul>
|
||||||
|
{games}
|
||||||
|
</ul>
|
||||||
|
<h4>Participants:</h4>
|
||||||
|
<ul>
|
||||||
|
{participants}
|
||||||
|
</ul>
|
||||||
|
</div>
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
export default Gamenight
|
@ -33,12 +33,12 @@ function Gamenights(props) {
|
|||||||
|
|
||||||
let gamenights = props.gamenights.map(g =>
|
let gamenights = props.gamenights.map(g =>
|
||||||
(
|
(
|
||||||
<li>
|
<li onClick={(e) => props.onSelectGamenight(g)}>
|
||||||
<span>{g.name}</span>
|
<span>{g.name}</span>
|
||||||
{(props.user.id === g.owner_id || props.user.role === "Admin") &&
|
{(props.user.id === g.owner_id || props.user.role === "Admin") &&
|
||||||
<button onClick={() =>DeleteGameNight(g.id, g.owner)}>
|
<button onClick={(e) => {
|
||||||
x
|
e.stopPropagation();
|
||||||
</button>
|
DeleteGameNight(g.id, g.owner)}}>x</button>
|
||||||
}
|
}
|
||||||
</li>
|
</li>
|
||||||
)
|
)
|
||||||
|
Loading…
Reference in New Issue
Block a user