Implements leaving on the client side

Reviewed-on: Roflin/gamenight#9

.gitignore

@@ -1,4 +1,4 @@
-/target
+/target/
+**/*.rs.bk
+Cargo.lock
 .vscode
-Rocket.toml
-*.sqlite

Cargo.toml

@@ -1,18 +0,0 @@
-[package]
-name = "gamenight"
-version = "0.1.0"
-authors = ["Dennis Brentjes <d.brentjes@gmail.com>"]
-edition = "2018"
-
-# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
-
-[dependencies]
-rocket = { version = "0.5.0-rc.1", features = ["default", "json"] }
-libsqlite3-sys = { version = ">=0.8.0, <0.19.0", features = ["bundled"] }
-rocket_sync_db_pools = { version = "0.1.0-rc.1", features =  ["diesel_sqlite_pool"] }
-diesel = { version = "1.4.8", features = ["sqlite"] }
-diesel_migrations = "1.4.0"
-rocket_dyn_templates = { version = "0.1.0-rc.1", features = ["handlebars"] }
-chrono = "0.4.19"
-serde = "1.0.136"
-

Rocket.toml.example

@@ -1,4 +0,0 @@
-#Copy this file over to Rocket.toml after changing all relevant values.
-
-[global.databases]
-gamenight_database = { url = "gamenight.sqlite" }

backend-actix/.gitignore

@@ -0,0 +1,3 @@
+target
+src/models/
+docs/

backend-actix/Cargo.toml

@@ -0,0 +1,20 @@
+[package]
+name = "backend-actix"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+gamenight-database = { path = "../gamenight-database"}
+actix-web = "4"
+actix-cors = "0.7"
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"
+uuid = { version = "1.3.0", features = ["serde", "v4"] }
+chrono = { version = "0.4", features = ["serde"] }
+jsonwebtoken = "9.3"
+validator = { version = "0.20", features = ["derive"] }
+rand_core = { version = "0.9" }
+env_logger = "0.11"
+tracing-actix-web = "0.7"

backend-actix/build.rs

@@ -0,0 +1,29 @@
+use std::{fs::{exists, read_dir, remove_dir_all, File}, io::Write, process::Command};
+
+
+fn main() {
+
+    if exists("src/models").unwrap() {
+        remove_dir_all("src/models").unwrap();
+    }
+ 
+    let _ = 
+        Command::new("openapi-generator")
+            .args(["generate", "-i", "gamenight-api.yaml", "-g", "rust", "--global-property", "models"])
+            .output()
+            .expect("Failed to generate models sources for the gamenight API");
+
+    let mut file = File::create("src/models/mod.rs").unwrap();
+    let paths = read_dir("./src/models").unwrap();
+    for path in paths {
+        let path = path.unwrap();
+        let path = path.path();
+        let stem = path.file_stem().unwrap();
+        if stem == "mod" {
+            continue
+        }
+    
+        let line = format!("pub mod {};\n", stem.to_str().unwrap());
+        let _ = file.write(line.as_bytes()).unwrap();
+    }
+}

backend-actix/gamenight-api.yaml

@@ -0,0 +1,346 @@
+openapi: 3.0.0
+info:
+  title: Gamenight
+  version: '1.0'
+  contact:
+    name: Dennis Brentjes
+    email: dennis@brentj.es
+    url: 'https://brentj.es'
+  description: Api specifaction for a Gamenight server
+  license:
+    name: MIT
+servers:
+  - url: 'http://localhost:8080'
+    description: Gamenight
+paths:
+  /token:
+    get:
+      summary: ''
+      operationId: get-token
+      responses:
+        '200':
+          $ref: '#/components/responses/TokenResponse'
+        '401':
+          $ref: '#/components/responses/FailureResponse'
+      requestBody:
+        $ref: '#/components/requestBodies/LoginRequest'
+      description: Submit your credentials to get a JWT-token to use with the rest of the api.
+      parameters: []
+  /user:
+    post:
+      summary: ''
+      operationId: post-register
+      requestBody:
+        $ref: '#/components/requestBodies/RegisterRequest'
+      responses:
+        '200':
+          description: ''
+        '422':
+          $ref: '#/components/responses/FailureResponse'
+      description: 'Create a new user given a registration token and user information, username and email must be unique, and password and password_repeat must match.'
+      parameters: []
+      security:
+        - JWT-Auth: []
+    get:
+      description: 'Get a user from primary id'
+      requestBody:
+        $ref: '#/components/requestBodies/GetUserRequest'
+      parameters: []
+      responses:
+        '200':
+          $ref: '#/components/responses/UserResponse'
+        '401': 
+          $ref: '#/components/responses/FailureResponse'
+        '404':
+          $ref: '#/components/responses/FailureResponse'
+        '422':
+          $ref: '#/components/responses/FailureResponse'
+      security:
+        - JWT-Auth: []
+  /gamenights:
+    get:
+      summary: Get a all gamenights
+      responses:
+        '200':
+          $ref: '#/components/responses/GamenightsResponse'
+        '400':
+          $ref: '#/components/responses/FailureResponse'
+        '401':
+          $ref: '#/components/responses/FailureResponse'
+      operationId: get-gamenights
+      security:
+        - JWT-Auth: []
+      description: Retrieve the list of gamenights on this gamenight server. Requires authorization.
+  /participants:
+    get:
+      summary: Get all participants for a gamenight
+      responses:
+        '200':
+          $ref: '#/components/responses/ParticipantsResponse'
+        '400':
+          $ref: '#/components/responses/FailureResponse'
+        '401':
+          $ref: '#/components/responses/FailureResponse'
+      requestBody:
+        $ref: '#/components/requestBodies/GetParticipants'
+      security:
+        - JWT-Auth: []
+      description: Retrieve the participants of a single gamenight by id.
+  /gamenight:
+    post:
+      summary: ''
+      operationId: post-gamenight
+      responses:
+        '200':
+          description: OK
+        '401':
+          $ref: '#/components/responses/FailureResponse'
+        '422':
+          $ref: '#/components/responses/FailureResponse'
+      security:
+        - JWT-Auth: []
+      requestBody:
+        $ref: '#/components/requestBodies/AddGamenight'
+      description: 'Add a gamenight by providing a name and a date, only available when providing an JWT token.'
+    get:
+      summary: ''
+      operationId: get-gamenight
+      responses:
+        '200':
+          $ref: '#/components/responses/GamenightResponse'
+        '401':
+          $ref: '#/components/responses/FailureResponse'
+        '422':
+          $ref: '#/components/responses/FailureResponse'
+      requestBody:
+        $ref: '#/components/requestBodies/GetGamenight'
+      security:
+        - JWT-Auth: []
+  /join:
+    post:
+      responses:
+        '200':
+          description: OK
+        '401':
+          $ref: '#/components/responses/FailureResponse'
+        '422':
+          $ref: '#/components/responses/FailureResponse'
+      requestBody:
+        $ref: '#/components/requestBodies/JoinGamenight'
+      security:
+        - JWT-Auth: []
+  /leave:
+    post:
+      responses:
+        '200':
+          description: OK
+        '401':
+          $ref: '#/components/responses/FailureResponse'
+        '422':
+          $ref: '#/components/responses/FailureResponse'
+      requestBody:
+        $ref: '#/components/requestBodies/LeaveGamenight'
+      security:
+        - JWT-Auth: []
+      
+components:
+  schemas:
+    Gamenight:
+      title: Gamenight
+      type: object
+      properties:
+        id:
+          type: string
+        name:
+          type: string
+        datetime:
+          type: string
+        owner_id:
+          type: string
+      required:
+        - id
+        - name
+        - datetime
+        - owner_id
+    Participants:
+      title: participants
+      type: object
+      properties:
+        participants:
+          type: array
+          items:
+            type: string
+      required:
+        - participants
+    Failure:
+      title: Failure
+      type: object
+      properties:
+        message:
+          type: string
+      description: 'Failure Reason'
+    Token:
+      title: Token
+      type: object
+      properties:
+        jwt_token:
+          type: string
+    Login:
+      title: Login
+      type: object
+      properties:
+        username:
+          type: string
+        password:
+          type: string
+      required:
+        - username
+        - password
+    Registration:
+      title: Registration
+      type: object
+      properties:
+        username:
+          type: string
+        email:
+          type: string
+        password:
+          type: string
+        password_repeat:
+          type: string
+        registration_token:
+          type: string
+      required:
+        - username
+        - email
+        - password
+        - password_repeat
+        - registration_token
+    UserId:
+      title: UserId
+      type: object
+      properties:
+        user_id:
+          type: string
+      required:
+        - user_id
+    AddGamenightRequestBody:
+      title: AddGamenightRequestBody
+      type: object
+      properties:
+        name:
+          type: string
+        datetime:
+          type: string
+    GamenightId:
+      title: GamenightId
+      type: object
+      properties: 
+        gamenight_id:
+          type: string
+      required:
+        - gamenight_id
+    GetGamenightRequestBody:
+      type: object
+      properties:
+        id:
+          type: string
+    User:
+      type: object
+      properties:
+        id:
+          type: string
+        username:
+          type: string
+        email:
+          type: string
+      required:
+        - id
+        - username
+  requestBodies:
+    LoginRequest:
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/Login'
+    RegisterRequest:
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/Registration'
+    GetUserRequest:
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/UserId'
+    AddGamenight:
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/AddGamenightRequestBody'
+    GetGamenight:
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/GetGamenightRequestBody'
+    GetParticipants:
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/GamenightId'
+    JoinGamenight:
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/GamenightId'
+    LeaveGamenight:
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/GamenightId'
+  responses:
+    TokenResponse:
+      description: Example response
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/Token'
+    FailureResponse:
+      description: Example response
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/Failure'
+    ParticipantsResponse:
+      description: Response with a list of participant uuids
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/Participants'
+    GamenightsResponse:
+      description: Example response
+      content:
+        application/json:
+          schema:
+            type: array
+            items:
+              $ref: '#/components/schemas/Gamenight'
+    GamenightResponse:
+      description: A gamenight being hosted
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/Gamenight'
+    UserResponse:
+      description: A user in the gamenight system
+      content:
+        application/json:
+          schema:
+            $ref: '#/components/schemas/User'
+  securitySchemes:
+    JWT-Auth:
+      type: http
+      scheme: bearer
+      bearerFormat: JWT
+      description: ''
+

backend-actix/src/main.rs

@@ -0,0 +1,53 @@
+#[allow(unused_imports)]
+pub mod models;
+pub mod request;
+
+use actix_cors::Cors;
+use actix_web::middleware::Logger;
+use actix_web::HttpServer;
+use actix_web::App;
+use actix_web::http;
+use actix_web::web;
+use request::{*, login, register, gamenights};
+use tracing_actix_web::TracingLogger;
+use gamenight_database::*;
+
+#[actix_web::main]
+async fn main() -> std::io::Result<()> {
+    let url = "postgres://root:root@127.0.0.1/gamenight";
+    
+    let pool = get_connection_pool(url);
+
+    let mut conn = pool.get_conn();
+    run_migration(&mut conn);
+
+    env_logger::init_from_env(env_logger::Env::new().default_filter_or("info"));
+
+    HttpServer::new(move || {
+        let cors = Cors::default()
+            .allowed_origin("0.0.0.0")
+            .allowed_origin_fn(|_origin, _req_head| { true })
+        .allowed_methods(vec!["GET", "POST"])
+        .allowed_headers(vec![http::header::AUTHORIZATION, http::header::ACCEPT])
+        .allowed_header(http::header::CONTENT_TYPE)
+        .max_age(3600);
+
+        App::new()
+            .wrap(cors)
+            .wrap(Logger::default())
+            .wrap(TracingLogger::default())
+            .app_data(web::Data::new(pool.clone()))
+            .service(login)
+            .service(register)
+            .service(gamenights)
+            .service(gamenight_post)
+            .service(gamenight_get)
+            .service(get_user)
+            .service(get_user_unauthenticated)
+            .service(post_join_gamenight)
+            .service(get_get_participants)
+    })
+    .bind(("::1", 8080))?
+    .run()
+    .await
+}

backend-actix/src/request/authorization.rs

@@ -0,0 +1,80 @@
+use std::future::{Ready, ready};
+
+use actix_web::{FromRequest, http, HttpRequest, dev::Payload, web::Data};
+use chrono::Utc;
+use jsonwebtoken::{encode, Header, EncodingKey, decode, DecodingKey, Validation};
+use serde::{Serialize, Deserialize};
+use uuid::Uuid;
+
+use gamenight_database::{user::{get_user, Role, User}, DbPool};
+
+use super::error::ApiError;
+
+#[derive(Debug, Serialize, Deserialize)]
+pub struct Claims {
+    exp: i64,
+    uid: Uuid
+}
+
+pub struct AuthUser {
+    pub id: Uuid,
+    pub username: String,
+    pub email: String,
+    pub role: Role,
+}
+
+impl From<User> for AuthUser  {
+    fn from(value: User) -> Self {
+        Self{
+            id: value.id,
+            username: value.username,
+            email: value.email,
+            role: value.role,
+        }
+    }
+}
+
+fn get_claims(req: &HttpRequest) -> Result<Claims, ApiError>  {
+    let token = req.headers()
+        .get(http::header::AUTHORIZATION)
+        .map(|h| h.to_str().unwrap().split_at(7).1.to_string());
+
+    let token = token.ok_or(ApiError{
+        status: 400,
+        message: "JWT-token was not specified in the Authorization header as Bearer: token".to_string()
+    })?;
+
+    let secret = "secret";
+    Ok(decode::<Claims>(token.as_str(), &DecodingKey::from_secret(secret.as_bytes()), &Validation::default())?.claims)
+}
+
+pub fn get_token(user: &User) -> Result<String, ApiError> {
+    let claims = Claims {
+        exp: Utc::now().timestamp() + chrono::Duration::days(7).num_seconds(),
+        uid: user.id,
+    };
+
+    let secret = "secret";
+    Ok(encode(
+        &Header::default(),
+        &claims,
+        &EncodingKey::from_secret(secret.as_bytes()))?)
+}
+
+impl FromRequest for AuthUser {
+    type Error = ApiError;
+    type Future = Ready<Result<Self, Self::Error>>;
+
+    fn from_request(req: &HttpRequest, _payload: &mut Payload) -> Self::Future {
+        ready(
+            (|| -> Result<AuthUser, ApiError>{
+                let pool = req.app_data::<Data<DbPool>>().expect("No database configured");
+                let mut conn = pool.get().expect("couldn't get db connection from pool");
+                let uid = get_claims(req)?.uid;
+                let user = get_user(&mut conn, uid)?;
+                
+                Ok(user.into())
+            })()
+        )
+    }
+}

backend-actix/src/request/error.rs

@@ -0,0 +1,91 @@
+use std::fmt::{Display, Formatter, Result};
+use actix_web::{ResponseError, error::BlockingError, HttpResponse, http::{header::ContentType, StatusCode}};
+use serde::{Serialize, Deserialize};
+use validator::ValidationErrors;
+
+use gamenight_database::error::DatabaseError;
+
+#[derive(Serialize, Deserialize, Debug)]
+pub struct ApiError {
+    #[serde(skip_serializing)]
+    pub status: u16,
+    pub message: String
+}
+
+impl Display for ApiError {
+    fn fmt(&self, f: &mut Formatter) -> Result {
+        write!(f, "{}", self.message)
+    }
+}
+
+impl ResponseError for ApiError {
+    fn error_response(&self) -> HttpResponse {
+        HttpResponse::build(StatusCode::from_u16(self.status).unwrap())
+        .content_type(ContentType::json())
+        .body(serde_json::to_string(&self).unwrap())
+    }    
+}
+
+impl From<DatabaseError> for ApiError {
+    fn from(value: DatabaseError) -> Self {
+        ApiError {
+            //Todo, split this in unrecoverable and schema error
+            status: 500,
+            message: value.0
+        }
+    }
+}
+
+impl From<BlockingError> for ApiError {
+    fn from(value: BlockingError) -> Self {
+        ApiError {
+            status: 500,
+            message: value.to_string()
+        }
+    }
+}
+
+impl From<serde_json::Error> for ApiError {
+    fn from(value: serde_json::Error) -> Self {
+        ApiError {
+            status: 500,
+            message: value.to_string()
+        }
+    }
+}
+
+impl From<jsonwebtoken::errors::Error> for ApiError {
+    fn from(value: jsonwebtoken::errors::Error) -> Self {
+        ApiError {
+            status: 500,
+            message: value.to_string() 
+        }
+    }
+}
+
+impl From<ValidationErrors> for ApiError {
+    fn from(value: ValidationErrors) -> Self {
+        ApiError {
+            status: 422,
+            message: value.to_string()
+        }
+    }
+}
+
+impl From<chrono::ParseError> for ApiError {
+    fn from(value: chrono::ParseError) -> Self {
+        ApiError {
+            status: 422,
+            message: value.to_string()
+        }
+    }
+}
+
+impl From<uuid::Error> for ApiError {
+    fn from(value: uuid::Error) -> Self {
+        ApiError {
+            status: 422,
+            message: value.to_string()
+        }
+    }
+}

backend-actix/src/request/gamenight_handlers.rs

@@ -0,0 +1,70 @@
+use actix_web::{get, web, Responder, http::header::ContentType, HttpResponse, post};
+use chrono::{DateTime, ParseError};
+use uuid::Uuid;
+
+use gamenight_database::{gamenight, DbPool, GetConnection};
+
+use crate::{models::{add_gamenight_request_body::AddGamenightRequestBody, gamenight::Gamenight, get_gamenight_request_body::GetGamenightRequestBody}, request::authorization::AuthUser};
+use crate::request::error::ApiError;
+
+
+impl AddGamenightRequestBody {
+    pub fn into_with_user(&self, user: AuthUser) -> Result<gamenight::Gamenight, ParseError> {
+        Ok(gamenight::Gamenight {
+            datetime: DateTime::parse_from_rfc3339(&self.clone().datetime.unwrap())?.with_timezone(&chrono::Utc),
+            id: Uuid::new_v4(),
+            name: self.clone().name.unwrap().clone(),
+            owner_id: user.id
+        })
+    }
+}
+
+impl From<GetGamenightRequestBody> for Uuid {
+    fn from(value: GetGamenightRequestBody) -> Self {
+        Uuid::parse_str(value.id.unwrap().as_str()).unwrap()
+    }
+}
+
+#[get("/gamenights")]
+pub async fn gamenights(pool: web::Data<DbPool>, _user: AuthUser) -> Result<impl Responder, ApiError> {
+    let mut conn = pool.get_conn();
+    let gamenights: Vec<gamenight::Gamenight> = gamenight_database::gamenights(&mut conn)?;
+    let model: Vec<Gamenight> = gamenights.iter().map(|x| {
+        Gamenight {
+            id: x.id.to_string(),
+            name: x.name.clone(),
+            datetime: x.datetime.to_rfc3339(),
+            owner_id: x.owner_id.to_string() 
+        }}
+    ).collect();
+
+    Ok(HttpResponse::Ok()
+        .content_type(ContentType::json())
+        .body(serde_json::to_string(&model)?)
+    )
+}
+
+#[post("/gamenight")]
+pub async fn gamenight_post(pool: web::Data<DbPool>, user: AuthUser, gamenight_data: web::Json<AddGamenightRequestBody>) -> Result<impl Responder, ApiError> {
+    let mut conn = pool.get_conn();
+    
+    gamenight::add_gamenight(&mut conn, gamenight_data.into_with_user(user)?)?;
+    
+    Ok(HttpResponse::Ok())
+}
+
+#[get("/gamenight")]
+pub async fn gamenight_get(pool: web::Data<DbPool>, _user: AuthUser, gamenight_data: web::Json<GetGamenightRequestBody>) -> Result<impl Responder, ApiError> {
+    let mut conn = pool.get_conn();
+    let gamenight = gamenight::get_gamenight(&mut conn, gamenight_data.into_inner().into())?;
+    let model = Gamenight{
+        id: gamenight.id.to_string(),
+        datetime: gamenight.datetime.to_rfc3339(),
+        name: gamenight.name,
+        owner_id: gamenight.owner_id.to_string(),
+    };
+
+    Ok(HttpResponse::Ok()
+        .content_type(ContentType::json())
+        .body(serde_json::to_string(&model)?))
+}

backend-actix/src/request/join_gamenight.rs

@@ -0,0 +1,31 @@
+use actix_web::{post, web, HttpResponse, Responder};
+use gamenight_database::{gamenight_participants::{delete_gamenight_participant, insert_gamenight_participant, GamenightParticipant}, DbPool, GetConnection};
+use uuid::Uuid;
+
+use crate::{models::gamenight_id::GamenightId, request::{authorization::AuthUser, error::ApiError}};
+
+#[post("/join")]
+pub async fn post_join_gamenight(pool: web::Data<DbPool>, user: AuthUser, gamenight_id: web::Json<GamenightId>) -> Result<impl Responder, ApiError> {
+    web::block(move || -> Result<usize, ApiError> {
+        let mut conn = pool.get_conn();
+        Ok(insert_gamenight_participant(&mut conn, GamenightParticipant {
+            gamenight_id: Uuid::parse_str(&gamenight_id.gamenight_id)?,
+            user_id: user.id
+        })?)
+    }).await??;
+
+    Ok(HttpResponse::Ok())
+}
+
+#[post("/leave")]
+pub async fn post_leave_gamenight(pool: web::Data<DbPool>, user: AuthUser, gamenight_id: web::Json<GamenightId>) -> Result<impl Responder, ApiError> {
+    web::block(move || -> Result<usize, ApiError> {
+        let mut conn = pool.get_conn();
+        Ok(delete_gamenight_participant(&mut conn, GamenightParticipant {
+            gamenight_id: Uuid::parse_str(&gamenight_id.gamenight_id)?,
+            user_id: user.id
+        })?)
+    }).await??;
+
+    Ok(HttpResponse::Ok())
+}

backend-actix/src/request/mod.rs

@@ -0,0 +1,17 @@
+
+mod user_handlers;
+mod gamenight_handlers;
+mod error;
+mod authorization;
+mod join_gamenight;
+mod participant_handlers;
+
+pub use user_handlers::login;
+pub use user_handlers::register;
+pub use gamenight_handlers::gamenights;
+pub use gamenight_handlers::gamenight_post;
+pub use gamenight_handlers::gamenight_get;
+pub use user_handlers::get_user;
+pub use user_handlers::get_user_unauthenticated;
+pub use join_gamenight::post_join_gamenight;
+pub use participant_handlers::get_get_participants;

backend-actix/src/request/participant_handlers.rs

@@ -0,0 +1,17 @@
+use actix_web::{get, http::header::ContentType, web, HttpResponse, Responder};
+use gamenight_database::{DbPool, GetConnection};
+use uuid::Uuid;
+
+use crate::{models::{gamenight_id::GamenightId, participants::Participants}, request::{authorization::AuthUser, error::ApiError}};
+
+#[get("/participants")]
+pub async fn get_get_participants(pool: web::Data<DbPool>, _user: AuthUser, gamenight_info: web::Json<GamenightId>) -> Result<impl Responder, ApiError> {
+    let mut conn = pool.get_conn();
+    
+    let users = gamenight_database::get_participants(&mut conn, &Uuid::parse_str(&gamenight_info.into_inner().gamenight_id)?)?
+        .iter().map(|x| x.to_string()).collect();
+    
+    Ok(HttpResponse::Ok()
+        .content_type(ContentType::json())
+        .body(serde_json::to_string(&Participants{participants: users})?))
+}

backend-actix/src/request/user_handlers.rs

@@ -0,0 +1,157 @@
+
+use actix_web::http::header::ContentType;
+use actix_web::{get, post, web, HttpResponse, Responder};
+use gamenight_database::user::{count_users_with_email, count_users_with_username};
+use serde::{Deserialize, Serialize};
+use uuid::Uuid;
+use validator::{Validate, ValidateArgs, ValidationError};
+use crate::models::login::Login;
+use crate::models::registration::Registration;
+use crate::models::token::Token;
+use crate::models::user::User;
+use crate::models::user_id::UserId;
+use crate::request::error::ApiError;
+use crate::request::authorization::get_token;
+use serde_json;
+use gamenight_database::{DbPool, GetConnection};
+
+use super::authorization::AuthUser;
+
+impl From<Login> for gamenight_database::user::LoginUser {
+    fn from(val: Login) -> Self {
+        gamenight_database::user::LoginUser {
+            username: val.username,
+            password: val.password
+        }
+    }
+}
+
+impl From<Registration> for gamenight_database::user::Register {
+    fn from(val: Registration) -> Self {
+        gamenight_database::user::Register {
+            email: val.email,
+            username: val.username,
+            password: val.password
+        }
+    }
+}
+
+pub struct RegisterContext<'v_a> {
+    pub pool: &'v_a DbPool
+}
+
+pub fn unique_username(username: &String, context: &RegisterContext) -> Result<(), ValidationError> {
+    let mut conn = context.pool.get_conn();
+
+    match count_users_with_username(&mut conn, username)
+    {
+        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, context: &RegisterContext) -> Result<(), ValidationError> {
+    let mut conn = context.pool.get_conn();
+
+    match count_users_with_email(&mut conn, email)
+    {
+        Ok(0) => Ok(()),
+        Ok(_) => Err(ValidationError::new("email already exists")),
+        Err(_) => Err(ValidationError::new("Database error while validating email"))
+    }
+}
+
+#[derive(Serialize, Deserialize, Clone, Validate)]
+#[validate(context = RegisterContext::<'v_a>)]
+pub struct ValidatableRegistration {
+    #[validate(
+        length(min = 1),
+        custom(function = "unique_username", use_context)
+    )]
+    pub username: String,
+    #[validate(
+        email,
+        custom(function = "unique_email", use_context)
+    )]
+    pub email: String,
+    #[validate(length(min = 10), must_match(other = "password_repeat", ))]
+    pub password: String,
+    pub password_repeat: String,
+}
+
+impl From<Registration> for ValidatableRegistration {
+    fn from(value: Registration) -> Self {
+        Self {
+            username: value.username,
+            email: value.email,
+            password: value.password,
+            password_repeat: value.password_repeat
+        }
+    }
+}
+
+#[get("/token")]
+pub async fn login(pool: web::Data<DbPool>, login_data: web::Json<Login>) -> Result<impl Responder, ApiError> {
+    let data = login_data.into_inner();
+
+    if let Ok(Some(user)) = web::block(move || {
+        let mut conn = pool.get_conn();
+        gamenight_database::login(&mut conn, data.into())
+    })
+    .await?
+    {
+        let token = get_token(&user)?;
+        let response = Token{ jwt_token: Some(token) };
+        Ok(HttpResponse::Ok()
+            .content_type(ContentType::json())
+            .body(serde_json::to_string(&response)?)
+        )
+    }
+    else {
+        Err(ApiError{status: 401, message: "User doesn't exist or password doesn't match".to_string()})
+    }
+}
+
+#[post("/user")]
+pub async fn register(pool: web::Data<DbPool>, register_data: web::Json<Registration>) -> Result<impl Responder, ApiError> {
+    web::block(move || -> Result<(), ApiError> {
+        let validatable_registration: ValidatableRegistration = register_data.clone().into();
+        validatable_registration.validate_with_args(&RegisterContext{pool: &pool})?;
+        let register_request = register_data.into_inner().into();
+        let mut conn = pool.get_conn();
+        gamenight_database::register(&mut conn, register_request)?;
+        Ok(())
+    }).await??;
+
+    Ok(HttpResponse::Ok())
+}
+
+impl From<gamenight_database::user::User> for User {
+    fn from(value: gamenight_database::user::User) -> Self {
+        Self {
+            id: value.id.to_string(),
+            username: value.username,
+            email: None,
+        }
+    }
+}
+
+#[get("/user")]
+pub async fn get_user(pool: web::Data<DbPool>, _user: AuthUser, user_info: web::Json<UserId>) -> Result<impl Responder, ApiError> {
+    let mut conn = pool.get_conn();
+    
+    let user = gamenight_database::user::get_user(&mut conn, Uuid::parse_str(&user_info.into_inner().user_id)?)?;
+    
+    Ok(HttpResponse::Ok()
+        .content_type(ContentType::json())
+        .body(serde_json::to_string(&user)?))
+}
+
+#[get("/user")]
+pub async fn get_user_unauthenticated(_path: web::Path<UserId>) -> Result<impl Responder, ApiError> {
+    Ok(HttpResponse::Forbidden())
+}
+
+
+

docker-compose.yml

@@ -0,0 +1,18 @@
+services:
+  db:
+    container_name: pg_container
+    image: postgres
+    environment:
+      POSTGRES_USER: root
+      POSTGRES_PASSWORD: root
+      POSTGRES_DB: gamenight
+    ports:
+      - "5432:5432"
+  pgadmin:
+    container_name: pgadmin4_container
+    image: dpage/pgadmin4
+    environment:
+      PGADMIN_DEFAULT_EMAIL: admin@admin.com
+      PGADMIN_DEFAULT_PASSWORD: root
+    ports:
+      - "5050:80"

gamenight-api-client-rs/.gitignore

@@ -0,0 +1,3 @@
+/target/
+**/*.rs.bk
+Cargo.lock

gamenight-api-client-rs/.openapi-generator-ignore

@@ -0,0 +1,23 @@
+# OpenAPI Generator Ignore
+# Generated by openapi-generator https://github.com/openapitools/openapi-generator
+
+# Use this file to prevent files from being overwritten by the generator.
+# The patterns follow closely to .gitignore or .dockerignore.
+
+# As an example, the C# client generator defines ApiClient.cs.
+# You can make changes and tell OpenAPI Generator to ignore just this file by uncommenting the following line:
+#ApiClient.cs
+
+# You can match any string of characters against a directory, file or extension with a single asterisk (*):
+#foo/*/qux
+# The above matches foo/bar/qux and foo/baz/qux, but not foo/bar/baz/qux
+
+# You can recursively match patterns against a directory, file or extension with a double asterisk (**):
+#foo/**/qux
+# This matches foo/bar/qux, foo/baz/qux, and foo/bar/baz/qux
+
+# You can also negate patterns with an exclamation (!).
+# For example, you can ignore all files in a docs folder with the file extension .md:
+#docs/*.md
+# Then explicitly reverse the ignore rule for a single file:
+#!docs/README.md

gamenight-api-client-rs/.openapi-generator/FILES

@@ -0,0 +1,33 @@
+.gitignore
+.travis.yml
+Cargo.toml
+README.md
+docs/AddGamenightRequestBody.md
+docs/DefaultApi.md
+docs/Failure.md
+docs/Gamenight.md
+docs/GamenightId.md
+docs/GetGamenightRequestBody.md
+docs/Login.md
+docs/Participants.md
+docs/Registration.md
+docs/Token.md
+docs/User.md
+docs/UserId.md
+git_push.sh
+src/apis/configuration.rs
+src/apis/default_api.rs
+src/apis/mod.rs
+src/lib.rs
+src/models/add_gamenight_request_body.rs
+src/models/failure.rs
+src/models/gamenight.rs
+src/models/gamenight_id.rs
+src/models/get_gamenight_request_body.rs
+src/models/login.rs
+src/models/mod.rs
+src/models/participants.rs
+src/models/registration.rs
+src/models/token.rs
+src/models/user.rs
+src/models/user_id.rs

gamenight-api-client-rs/.openapi-generator/VERSION

@@ -0,0 +1 @@
+7.13.0

gamenight-api-client-rs/.travis.yml

@@ -0,0 +1 @@
+language: rust

gamenight-api-client-rs/Cargo.toml

@@ -0,0 +1,14 @@
+[package]
+name = "gamenight-api-client-rs"
+version = "0.1.0"
+authors = ["dennis@brentj.es"]
+description = "Api specifaction for a Gamenight server"
+license = "MIT"
+edition = "2021"
+
+[dependencies]
+serde = { version = "^1.0", features = ["derive"] }
+serde_json = "^1.0"
+serde_repr = "^0.1"
+url = "^2.5"
+reqwest = { version = "^0.12", default-features = false, features = ["json", "multipart"] }

gamenight-api-client-rs/README.md

@@ -0,0 +1,65 @@
+# Rust API client for gamenight-api-client-rs
+
+Api specifaction for a Gamenight server
+
+For more information, please visit [https://brentj.es](https://brentj.es)
+
+## Overview
+
+This API client was generated by the [OpenAPI Generator](https://openapi-generator.tech) project.  By using the [openapi-spec](https://openapis.org) from a remote server, you can easily generate an API client.
+
+- API version: 1.0
+- Package version: 0.1.0
+- Generator version: 7.13.0
+- Build package: `org.openapitools.codegen.languages.RustClientCodegen`
+
+## Installation
+
+Put the package under your project folder in a directory named `gamenight-api-client-rs` and add the following to `Cargo.toml` under `[dependencies]`:
+
+```
+gamenight-api-client-rs = { path = "./gamenight-api-client-rs" }
+```
+
+## Documentation for API Endpoints
+
+All URIs are relative to *http://localhost:8080*
+
+Class | Method | HTTP request | Description
+------------ | ------------- | ------------- | -------------
+*DefaultApi* | [**get_gamenight**](docs/DefaultApi.md#get_gamenight) | **GET** /gamenight | 
+*DefaultApi* | [**get_gamenights**](docs/DefaultApi.md#get_gamenights) | **GET** /gamenights | Get a all gamenights
+*DefaultApi* | [**get_token**](docs/DefaultApi.md#get_token) | **GET** /token | 
+*DefaultApi* | [**join_post**](docs/DefaultApi.md#join_post) | **POST** /join | 
+*DefaultApi* | [**leave_post**](docs/DefaultApi.md#leave_post) | **POST** /leave | 
+*DefaultApi* | [**participants_get**](docs/DefaultApi.md#participants_get) | **GET** /participants | Get all participants for a gamenight
+*DefaultApi* | [**post_gamenight**](docs/DefaultApi.md#post_gamenight) | **POST** /gamenight | 
+*DefaultApi* | [**post_register**](docs/DefaultApi.md#post_register) | **POST** /user | 
+*DefaultApi* | [**user_get**](docs/DefaultApi.md#user_get) | **GET** /user | 
+
+
+## Documentation For Models
+
+ - [AddGamenightRequestBody](docs/AddGamenightRequestBody.md)
+ - [Failure](docs/Failure.md)
+ - [Gamenight](docs/Gamenight.md)
+ - [GamenightId](docs/GamenightId.md)
+ - [GetGamenightRequestBody](docs/GetGamenightRequestBody.md)
+ - [Login](docs/Login.md)
+ - [Participants](docs/Participants.md)
+ - [Registration](docs/Registration.md)
+ - [Token](docs/Token.md)
+ - [User](docs/User.md)
+ - [UserId](docs/UserId.md)
+
+
+To get access to the crate's generated documentation, use:
+
+```
+cargo doc --open
+```
+
+## Author
+
+dennis@brentj.es
+

gamenight-api-client-rs/build.rs

@@ -0,0 +1,9 @@
+use std::process::Command;
+
+fn main() {
+    let _ = 
+        Command::new("openapi-generator")
+            .args(["generate", "-i", "../backend-actix/gamenight-api.yaml", "-g", "rust", "--additional-properties=withSeparateModelsAndApi=true,modelPackage=gamenight_model,apiPackage=gamenight_api,packageName=gamenight-api-client-rs,packageVersion=0.1.0"])
+            .output()
+            .expect("Failed to generate models sources for the gamenight API");
+}

gamenight-api-client-rs/docs/AddGamenightRequestBody.md

@@ -0,0 +1,12 @@
+# AddGamenightRequestBody
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**name** | Option<**String**> |  | [optional]
+**datetime** | Option<**String**> |  | [optional]
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/DefaultApi.md

@@ -0,0 +1,278 @@
+# \DefaultApi
+
+All URIs are relative to *http://localhost:8080*
+
+Method | HTTP request | Description
+------------- | ------------- | -------------
+[**get_gamenight**](DefaultApi.md#get_gamenight) | **GET** /gamenight | 
+[**get_gamenights**](DefaultApi.md#get_gamenights) | **GET** /gamenights | Get a all gamenights
+[**get_token**](DefaultApi.md#get_token) | **GET** /token | 
+[**join_post**](DefaultApi.md#join_post) | **POST** /join | 
+[**leave_post**](DefaultApi.md#leave_post) | **POST** /leave | 
+[**participants_get**](DefaultApi.md#participants_get) | **GET** /participants | Get all participants for a gamenight
+[**post_gamenight**](DefaultApi.md#post_gamenight) | **POST** /gamenight | 
+[**post_register**](DefaultApi.md#post_register) | **POST** /user | 
+[**user_get**](DefaultApi.md#user_get) | **GET** /user | 
+
+
+
+## get_gamenight
+
+> models::Gamenight get_gamenight(get_gamenight_request_body)
+
+
+### Parameters
+
+
+Name | Type | Description  | Required | Notes
+------------- | ------------- | ------------- | ------------- | -------------
+**get_gamenight_request_body** | Option<[**GetGamenightRequestBody**](GetGamenightRequestBody.md)> |  |  |
+
+### Return type
+
+[**models::Gamenight**](Gamenight.md)
+
+### Authorization
+
+[JWT-Auth](../README.md#JWT-Auth)
+
+### HTTP request headers
+
+- **Content-Type**: application/json
+- **Accept**: application/json
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md)
+
+
+## get_gamenights
+
+> Vec<models::Gamenight> get_gamenights()
+Get a all gamenights
+
+Retrieve the list of gamenights on this gamenight server. Requires authorization.
+
+### Parameters
+
+This endpoint does not need any parameter.
+
+### Return type
+
+[**Vec<models::Gamenight>**](Gamenight.md)
+
+### Authorization
+
+[JWT-Auth](../README.md#JWT-Auth)
+
+### HTTP request headers
+
+- **Content-Type**: Not defined
+- **Accept**: application/json
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md)
+
+
+## get_token
+
+> models::Token get_token(login)
+
+
+Submit your credentials to get a JWT-token to use with the rest of the api.
+
+### Parameters
+
+
+Name | Type | Description  | Required | Notes
+------------- | ------------- | ------------- | ------------- | -------------
+**login** | Option<[**Login**](Login.md)> |  |  |
+
+### Return type
+
+[**models::Token**](Token.md)
+
+### Authorization
+
+No authorization required
+
+### HTTP request headers
+
+- **Content-Type**: application/json
+- **Accept**: application/json
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md)
+
+
+## join_post
+
+> join_post(gamenight_id)
+
+
+### Parameters
+
+
+Name | Type | Description  | Required | Notes
+------------- | ------------- | ------------- | ------------- | -------------
+**gamenight_id** | Option<[**GamenightId**](GamenightId.md)> |  |  |
+
+### Return type
+
+ (empty response body)
+
+### Authorization
+
+[JWT-Auth](../README.md#JWT-Auth)
+
+### HTTP request headers
+
+- **Content-Type**: application/json
+- **Accept**: application/json
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md)
+
+
+## leave_post
+
+> leave_post(gamenight_id)
+
+
+### Parameters
+
+
+Name | Type | Description  | Required | Notes
+------------- | ------------- | ------------- | ------------- | -------------
+**gamenight_id** | Option<[**GamenightId**](GamenightId.md)> |  |  |
+
+### Return type
+
+ (empty response body)
+
+### Authorization
+
+[JWT-Auth](../README.md#JWT-Auth)
+
+### HTTP request headers
+
+- **Content-Type**: application/json
+- **Accept**: application/json
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md)
+
+
+## participants_get
+
+> models::Participants participants_get(gamenight_id)
+Get all participants for a gamenight
+
+Retrieve the participants of a single gamenight by id.
+
+### Parameters
+
+
+Name | Type | Description  | Required | Notes
+------------- | ------------- | ------------- | ------------- | -------------
+**gamenight_id** | Option<[**GamenightId**](GamenightId.md)> |  |  |
+
+### Return type
+
+[**models::Participants**](Participants.md)
+
+### Authorization
+
+[JWT-Auth](../README.md#JWT-Auth)
+
+### HTTP request headers
+
+- **Content-Type**: application/json
+- **Accept**: application/json
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md)
+
+
+## post_gamenight
+
+> post_gamenight(add_gamenight_request_body)
+
+
+Add a gamenight by providing a name and a date, only available when providing an JWT token.
+
+### Parameters
+
+
+Name | Type | Description  | Required | Notes
+------------- | ------------- | ------------- | ------------- | -------------
+**add_gamenight_request_body** | Option<[**AddGamenightRequestBody**](AddGamenightRequestBody.md)> |  |  |
+
+### Return type
+
+ (empty response body)
+
+### Authorization
+
+[JWT-Auth](../README.md#JWT-Auth)
+
+### HTTP request headers
+
+- **Content-Type**: application/json
+- **Accept**: application/json
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md)
+
+
+## post_register
+
+> post_register(registration)
+
+
+Create a new user given a registration token and user information, username and email must be unique, and password and password_repeat must match.
+
+### Parameters
+
+
+Name | Type | Description  | Required | Notes
+------------- | ------------- | ------------- | ------------- | -------------
+**registration** | Option<[**Registration**](Registration.md)> |  |  |
+
+### Return type
+
+ (empty response body)
+
+### Authorization
+
+[JWT-Auth](../README.md#JWT-Auth)
+
+### HTTP request headers
+
+- **Content-Type**: application/json
+- **Accept**: application/json
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md)
+
+
+## user_get
+
+> models::User user_get(user_id)
+
+
+Get a user from primary id
+
+### Parameters
+
+
+Name | Type | Description  | Required | Notes
+------------- | ------------- | ------------- | ------------- | -------------
+**user_id** | Option<[**UserId**](UserId.md)> |  |  |
+
+### Return type
+
+[**models::User**](User.md)
+
+### Authorization
+
+[JWT-Auth](../README.md#JWT-Auth)
+
+### HTTP request headers
+
+- **Content-Type**: application/json
+- **Accept**: application/json
+
+[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md)
+

gamenight-api-client-rs/docs/Failure.md

@@ -0,0 +1,11 @@
+# Failure
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**message** | Option<**String**> |  | [optional]
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/Gamenight.md

@@ -0,0 +1,14 @@
+# Gamenight
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**id** | **String** |  | 
+**name** | **String** |  | 
+**datetime** | **String** |  | 
+**owner_id** | **String** |  | 
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/GamenightId.md

@@ -0,0 +1,11 @@
+# GamenightId
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**gamenight_id** | **String** |  | 
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/GetGamenightRequest.md

@@ -0,0 +1,11 @@
+# GetGamenightRequest
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**id** | Option<**String**> |  | [optional]
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/GetGamenightRequestBody.md

@@ -0,0 +1,11 @@
+# GetGamenightRequestBody
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**id** | Option<**String**> |  | [optional]
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/GetToken401Response.md

@@ -0,0 +1,11 @@
+# GetToken401Response
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**message** | **String** |  | 
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/Login.md

@@ -0,0 +1,12 @@
+# Login
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**username** | **String** |  | 
+**password** | **String** |  | 
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/Participants.md

@@ -0,0 +1,11 @@
+# Participants
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**participants** | **Vec<String>** |  | 
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/Registration.md

@@ -0,0 +1,15 @@
+# Registration
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**username** | **String** |  | 
+**email** | **String** |  | 
+**password** | **String** |  | 
+**password_repeat** | **String** |  | 
+**registration_token** | **String** |  | 
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/Token.md

@@ -0,0 +1,11 @@
+# Token
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**jwt_token** | Option<**String**> |  | [optional]
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/User.md

@@ -0,0 +1,13 @@
+# User
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**id** | **String** |  | 
+**username** | **String** |  | 
+**email** | Option<**String**> |  | [optional]
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/docs/UserId.md

@@ -0,0 +1,11 @@
+# UserId
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**user_id** | **String** |  | 
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+

gamenight-api-client-rs/git_push.sh

@@ -0,0 +1,57 @@
+#!/bin/sh
+# ref: https://help.github.com/articles/adding-an-existing-project-to-github-using-the-command-line/
+#
+# Usage example: /bin/sh ./git_push.sh wing328 openapi-petstore-perl "minor update" "gitlab.com"
+
+git_user_id=$1
+git_repo_id=$2
+release_note=$3
+git_host=$4
+
+if [ "$git_host" = "" ]; then
+    git_host="github.com"
+    echo "[INFO] No command line input provided. Set \$git_host to $git_host"
+fi
+
+if [ "$git_user_id" = "" ]; then
+    git_user_id="GIT_USER_ID"
+    echo "[INFO] No command line input provided. Set \$git_user_id to $git_user_id"
+fi
+
+if [ "$git_repo_id" = "" ]; then
+    git_repo_id="GIT_REPO_ID"
+    echo "[INFO] No command line input provided. Set \$git_repo_id to $git_repo_id"
+fi
+
+if [ "$release_note" = "" ]; then
+    release_note="Minor update"
+    echo "[INFO] No command line input provided. Set \$release_note to $release_note"
+fi
+
+# Initialize the local directory as a Git repository
+git init
+
+# Adds the files in the local repository and stages them for commit.
+git add .
+
+# Commits the tracked changes and prepares them to be pushed to a remote repository.
+git commit -m "$release_note"
+
+# Sets the new remote
+git_remote=$(git remote)
+if [ "$git_remote" = "" ]; then # git remote not defined
+
+    if [ "$GIT_TOKEN" = "" ]; then
+        echo "[INFO] \$GIT_TOKEN (environment variable) is not set. Using the git credential in your environment."
+        git remote add origin https://${git_host}/${git_user_id}/${git_repo_id}.git
+    else
+        git remote add origin https://${git_user_id}:"${GIT_TOKEN}"@${git_host}/${git_user_id}/${git_repo_id}.git
+    fi
+
+fi
+
+git pull origin master
+
+# Pushes (Forces) the changes in the local repository up to the remote repository
+echo "Git pushing to https://${git_host}/${git_user_id}/${git_repo_id}.git"
+git push origin master 2>&1 | grep -v 'To https'

gamenight-api-client-rs/src/apis/configuration.rs

@@ -0,0 +1,51 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+
+
+#[derive(Debug, Clone)]
+pub struct Configuration {
+    pub base_path: String,
+    pub user_agent: Option<String>,
+    pub client: reqwest::Client,
+    pub basic_auth: Option<BasicAuth>,
+    pub oauth_access_token: Option<String>,
+    pub bearer_access_token: Option<String>,
+    pub api_key: Option<ApiKey>,
+}
+
+pub type BasicAuth = (String, Option<String>);
+
+#[derive(Debug, Clone)]
+pub struct ApiKey {
+    pub prefix: Option<String>,
+    pub key: String,
+}
+
+
+impl Configuration {
+    pub fn new() -> Configuration {
+        Configuration::default()
+    }
+}
+
+impl Default for Configuration {
+    fn default() -> Self {
+        Configuration {
+            base_path: "http://localhost:8080".to_owned(),
+            user_agent: Some("OpenAPI-Generator/1.0/rust".to_owned()),
+            client: reqwest::Client::new(),
+            basic_auth: None,
+            oauth_access_token: None,
+            bearer_access_token: None,
+            api_key: None,
+        }
+    }
+}

gamenight-api-client-rs/src/apis/default_api.rs

@@ -0,0 +1,414 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+
+use reqwest;
+use serde::{Deserialize, Serialize, de::Error as _};
+use crate::{apis::ResponseContent, models};
+use super::{Error, configuration, ContentType};
+
+
+/// struct for typed errors of method [`get_gamenight`]
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[serde(untagged)]
+pub enum GetGamenightError {
+    Status401(models::Failure),
+    Status422(models::Failure),
+    UnknownValue(serde_json::Value),
+}
+
+/// struct for typed errors of method [`get_gamenights`]
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[serde(untagged)]
+pub enum GetGamenightsError {
+    Status400(models::Failure),
+    Status401(models::Failure),
+    UnknownValue(serde_json::Value),
+}
+
+/// struct for typed errors of method [`get_token`]
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[serde(untagged)]
+pub enum GetTokenError {
+    Status401(models::Failure),
+    UnknownValue(serde_json::Value),
+}
+
+/// struct for typed errors of method [`join_post`]
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[serde(untagged)]
+pub enum JoinPostError {
+    Status401(models::Failure),
+    Status422(models::Failure),
+    UnknownValue(serde_json::Value),
+}
+
+/// struct for typed errors of method [`leave_post`]
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[serde(untagged)]
+pub enum LeavePostError {
+    Status401(models::Failure),
+    Status422(models::Failure),
+    UnknownValue(serde_json::Value),
+}
+
+/// struct for typed errors of method [`participants_get`]
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[serde(untagged)]
+pub enum ParticipantsGetError {
+    Status400(models::Failure),
+    Status401(models::Failure),
+    UnknownValue(serde_json::Value),
+}
+
+/// struct for typed errors of method [`post_gamenight`]
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[serde(untagged)]
+pub enum PostGamenightError {
+    Status401(models::Failure),
+    Status422(models::Failure),
+    UnknownValue(serde_json::Value),
+}
+
+/// struct for typed errors of method [`post_register`]
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[serde(untagged)]
+pub enum PostRegisterError {
+    Status422(models::Failure),
+    UnknownValue(serde_json::Value),
+}
+
+/// struct for typed errors of method [`user_get`]
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[serde(untagged)]
+pub enum UserGetError {
+    Status401(models::Failure),
+    Status404(models::Failure),
+    Status422(models::Failure),
+    UnknownValue(serde_json::Value),
+}
+
+
+pub async fn get_gamenight(configuration: &configuration::Configuration, get_gamenight_request_body: Option<models::GetGamenightRequestBody>) -> Result<models::Gamenight, Error<GetGamenightError>> {
+    // add a prefix to parameters to efficiently prevent name collisions
+    let p_get_gamenight_request_body = get_gamenight_request_body;
+
+    let uri_str = format!("{}/gamenight", configuration.base_path);
+    let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
+
+    if let Some(ref user_agent) = configuration.user_agent {
+        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
+    }
+    if let Some(ref token) = configuration.bearer_access_token {
+        req_builder = req_builder.bearer_auth(token.to_owned());
+    };
+    req_builder = req_builder.json(&p_get_gamenight_request_body);
+
+    let req = req_builder.build()?;
+    let resp = configuration.client.execute(req).await?;
+
+    let status = resp.status();
+    let content_type = resp
+        .headers()
+        .get("content-type")
+        .and_then(|v| v.to_str().ok())
+        .unwrap_or("application/octet-stream");
+    let content_type = super::ContentType::from(content_type);
+
+    if !status.is_client_error() && !status.is_server_error() {
+        let content = resp.text().await?;
+        match content_type {
+            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
+            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::Gamenight`"))),
+            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::Gamenight`")))),
+        }
+    } else {
+        let content = resp.text().await?;
+        let entity: Option<GetGamenightError> = serde_json::from_str(&content).ok();
+        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+    }
+}
+
+/// Retrieve the list of gamenights on this gamenight server. Requires authorization.
+pub async fn get_gamenights(configuration: &configuration::Configuration, ) -> Result<Vec<models::Gamenight>, Error<GetGamenightsError>> {
+
+    let uri_str = format!("{}/gamenights", configuration.base_path);
+    let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
+
+    if let Some(ref user_agent) = configuration.user_agent {
+        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
+    }
+    if let Some(ref token) = configuration.bearer_access_token {
+        req_builder = req_builder.bearer_auth(token.to_owned());
+    };
+
+    let req = req_builder.build()?;
+    let resp = configuration.client.execute(req).await?;
+
+    let status = resp.status();
+    let content_type = resp
+        .headers()
+        .get("content-type")
+        .and_then(|v| v.to_str().ok())
+        .unwrap_or("application/octet-stream");
+    let content_type = super::ContentType::from(content_type);
+
+    if !status.is_client_error() && !status.is_server_error() {
+        let content = resp.text().await?;
+        match content_type {
+            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
+            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `Vec&lt;models::Gamenight&gt;`"))),
+            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `Vec&lt;models::Gamenight&gt;`")))),
+        }
+    } else {
+        let content = resp.text().await?;
+        let entity: Option<GetGamenightsError> = serde_json::from_str(&content).ok();
+        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+    }
+}
+
+/// Submit your credentials to get a JWT-token to use with the rest of the api.
+pub async fn get_token(configuration: &configuration::Configuration, login: Option<models::Login>) -> Result<models::Token, Error<GetTokenError>> {
+    // add a prefix to parameters to efficiently prevent name collisions
+    let p_login = login;
+
+    let uri_str = format!("{}/token", configuration.base_path);
+    let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
+
+    if let Some(ref user_agent) = configuration.user_agent {
+        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
+    }
+    req_builder = req_builder.json(&p_login);
+
+    let req = req_builder.build()?;
+    let resp = configuration.client.execute(req).await?;
+
+    let status = resp.status();
+    let content_type = resp
+        .headers()
+        .get("content-type")
+        .and_then(|v| v.to_str().ok())
+        .unwrap_or("application/octet-stream");
+    let content_type = super::ContentType::from(content_type);
+
+    if !status.is_client_error() && !status.is_server_error() {
+        let content = resp.text().await?;
+        match content_type {
+            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
+            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::Token`"))),
+            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::Token`")))),
+        }
+    } else {
+        let content = resp.text().await?;
+        let entity: Option<GetTokenError> = serde_json::from_str(&content).ok();
+        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+    }
+}
+
+pub async fn join_post(configuration: &configuration::Configuration, gamenight_id: Option<models::GamenightId>) -> Result<(), Error<JoinPostError>> {
+    // add a prefix to parameters to efficiently prevent name collisions
+    let p_gamenight_id = gamenight_id;
+
+    let uri_str = format!("{}/join", configuration.base_path);
+    let mut req_builder = configuration.client.request(reqwest::Method::POST, &uri_str);
+
+    if let Some(ref user_agent) = configuration.user_agent {
+        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
+    }
+    if let Some(ref token) = configuration.bearer_access_token {
+        req_builder = req_builder.bearer_auth(token.to_owned());
+    };
+    req_builder = req_builder.json(&p_gamenight_id);
+
+    let req = req_builder.build()?;
+    let resp = configuration.client.execute(req).await?;
+
+    let status = resp.status();
+
+    if !status.is_client_error() && !status.is_server_error() {
+        Ok(())
+    } else {
+        let content = resp.text().await?;
+        let entity: Option<JoinPostError> = serde_json::from_str(&content).ok();
+        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+    }
+}
+
+pub async fn leave_post(configuration: &configuration::Configuration, gamenight_id: Option<models::GamenightId>) -> Result<(), Error<LeavePostError>> {
+    // add a prefix to parameters to efficiently prevent name collisions
+    let p_gamenight_id = gamenight_id;
+
+    let uri_str = format!("{}/leave", configuration.base_path);
+    let mut req_builder = configuration.client.request(reqwest::Method::POST, &uri_str);
+
+    if let Some(ref user_agent) = configuration.user_agent {
+        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
+    }
+    if let Some(ref token) = configuration.bearer_access_token {
+        req_builder = req_builder.bearer_auth(token.to_owned());
+    };
+    req_builder = req_builder.json(&p_gamenight_id);
+
+    let req = req_builder.build()?;
+    let resp = configuration.client.execute(req).await?;
+
+    let status = resp.status();
+
+    if !status.is_client_error() && !status.is_server_error() {
+        Ok(())
+    } else {
+        let content = resp.text().await?;
+        let entity: Option<LeavePostError> = serde_json::from_str(&content).ok();
+        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+    }
+}
+
+/// Retrieve the participants of a single gamenight by id.
+pub async fn participants_get(configuration: &configuration::Configuration, gamenight_id: Option<models::GamenightId>) -> Result<models::Participants, Error<ParticipantsGetError>> {
+    // add a prefix to parameters to efficiently prevent name collisions
+    let p_gamenight_id = gamenight_id;
+
+    let uri_str = format!("{}/participants", configuration.base_path);
+    let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
+
+    if let Some(ref user_agent) = configuration.user_agent {
+        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
+    }
+    if let Some(ref token) = configuration.bearer_access_token {
+        req_builder = req_builder.bearer_auth(token.to_owned());
+    };
+    req_builder = req_builder.json(&p_gamenight_id);
+
+    let req = req_builder.build()?;
+    let resp = configuration.client.execute(req).await?;
+
+    let status = resp.status();
+    let content_type = resp
+        .headers()
+        .get("content-type")
+        .and_then(|v| v.to_str().ok())
+        .unwrap_or("application/octet-stream");
+    let content_type = super::ContentType::from(content_type);
+
+    if !status.is_client_error() && !status.is_server_error() {
+        let content = resp.text().await?;
+        match content_type {
+            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
+            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::Participants`"))),
+            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::Participants`")))),
+        }
+    } else {
+        let content = resp.text().await?;
+        let entity: Option<ParticipantsGetError> = serde_json::from_str(&content).ok();
+        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+    }
+}
+
+/// Add a gamenight by providing a name and a date, only available when providing an JWT token.
+pub async fn post_gamenight(configuration: &configuration::Configuration, add_gamenight_request_body: Option<models::AddGamenightRequestBody>) -> Result<(), Error<PostGamenightError>> {
+    // add a prefix to parameters to efficiently prevent name collisions
+    let p_add_gamenight_request_body = add_gamenight_request_body;
+
+    let uri_str = format!("{}/gamenight", configuration.base_path);
+    let mut req_builder = configuration.client.request(reqwest::Method::POST, &uri_str);
+
+    if let Some(ref user_agent) = configuration.user_agent {
+        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
+    }
+    if let Some(ref token) = configuration.bearer_access_token {
+        req_builder = req_builder.bearer_auth(token.to_owned());
+    };
+    req_builder = req_builder.json(&p_add_gamenight_request_body);
+
+    let req = req_builder.build()?;
+    let resp = configuration.client.execute(req).await?;
+
+    let status = resp.status();
+
+    if !status.is_client_error() && !status.is_server_error() {
+        Ok(())
+    } else {
+        let content = resp.text().await?;
+        let entity: Option<PostGamenightError> = serde_json::from_str(&content).ok();
+        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+    }
+}
+
+/// Create a new user given a registration token and user information, username and email must be unique, and password and password_repeat must match.
+pub async fn post_register(configuration: &configuration::Configuration, registration: Option<models::Registration>) -> Result<(), Error<PostRegisterError>> {
+    // add a prefix to parameters to efficiently prevent name collisions
+    let p_registration = registration;
+
+    let uri_str = format!("{}/user", configuration.base_path);
+    let mut req_builder = configuration.client.request(reqwest::Method::POST, &uri_str);
+
+    if let Some(ref user_agent) = configuration.user_agent {
+        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
+    }
+    if let Some(ref token) = configuration.bearer_access_token {
+        req_builder = req_builder.bearer_auth(token.to_owned());
+    };
+    req_builder = req_builder.json(&p_registration);
+
+    let req = req_builder.build()?;
+    let resp = configuration.client.execute(req).await?;
+
+    let status = resp.status();
+
+    if !status.is_client_error() && !status.is_server_error() {
+        Ok(())
+    } else {
+        let content = resp.text().await?;
+        let entity: Option<PostRegisterError> = serde_json::from_str(&content).ok();
+        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+    }
+}
+
+/// Get a user from primary id
+pub async fn user_get(configuration: &configuration::Configuration, user_id: Option<models::UserId>) -> Result<models::User, Error<UserGetError>> {
+    // add a prefix to parameters to efficiently prevent name collisions
+    let p_user_id = user_id;
+
+    let uri_str = format!("{}/user", configuration.base_path);
+    let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
+
+    if let Some(ref user_agent) = configuration.user_agent {
+        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
+    }
+    if let Some(ref token) = configuration.bearer_access_token {
+        req_builder = req_builder.bearer_auth(token.to_owned());
+    };
+    req_builder = req_builder.json(&p_user_id);
+
+    let req = req_builder.build()?;
+    let resp = configuration.client.execute(req).await?;
+
+    let status = resp.status();
+    let content_type = resp
+        .headers()
+        .get("content-type")
+        .and_then(|v| v.to_str().ok())
+        .unwrap_or("application/octet-stream");
+    let content_type = super::ContentType::from(content_type);
+
+    if !status.is_client_error() && !status.is_server_error() {
+        let content = resp.text().await?;
+        match content_type {
+            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
+            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::User`"))),
+            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::User`")))),
+        }
+    } else {
+        let content = resp.text().await?;
+        let entity: Option<UserGetError> = serde_json::from_str(&content).ok();
+        Err(Error::ResponseError(ResponseContent { status, content, entity }))
+    }
+}
+

gamenight-api-client-rs/src/apis/mod.rs

@@ -0,0 +1,116 @@
+use std::error;
+use std::fmt;
+
+#[derive(Debug, Clone)]
+pub struct ResponseContent<T> {
+    pub status: reqwest::StatusCode,
+    pub content: String,
+    pub entity: Option<T>,
+}
+
+#[derive(Debug)]
+pub enum Error<T> {
+    Reqwest(reqwest::Error),
+    Serde(serde_json::Error),
+    Io(std::io::Error),
+    ResponseError(ResponseContent<T>),
+}
+
+impl <T> fmt::Display for Error<T> {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        let (module, e) = match self {
+            Error::Reqwest(e) => ("reqwest", e.to_string()),
+            Error::Serde(e) => ("serde", e.to_string()),
+            Error::Io(e) => ("IO", e.to_string()),
+            Error::ResponseError(e) => ("response", format!("status code {}", e.status)),
+        };
+        write!(f, "error in {}: {}", module, e)
+    }
+}
+
+impl <T: fmt::Debug> error::Error for Error<T> {
+    fn source(&self) -> Option<&(dyn error::Error + 'static)> {
+        Some(match self {
+            Error::Reqwest(e) => e,
+            Error::Serde(e) => e,
+            Error::Io(e) => e,
+            Error::ResponseError(_) => return None,
+        })
+    }
+}
+
+impl <T> From<reqwest::Error> for Error<T> {
+    fn from(e: reqwest::Error) -> Self {
+        Error::Reqwest(e)
+    }
+}
+
+impl <T> From<serde_json::Error> for Error<T> {
+    fn from(e: serde_json::Error) -> Self {
+        Error::Serde(e)
+    }
+}
+
+impl <T> From<std::io::Error> for Error<T> {
+    fn from(e: std::io::Error) -> Self {
+        Error::Io(e)
+    }
+}
+
+pub fn urlencode<T: AsRef<str>>(s: T) -> String {
+    ::url::form_urlencoded::byte_serialize(s.as_ref().as_bytes()).collect()
+}
+
+pub fn parse_deep_object(prefix: &str, value: &serde_json::Value) -> Vec<(String, String)> {
+    if let serde_json::Value::Object(object) = value {
+        let mut params = vec![];
+
+        for (key, value) in object {
+            match value {
+                serde_json::Value::Object(_) => params.append(&mut parse_deep_object(
+                    &format!("{}[{}]", prefix, key),
+                    value,
+                )),
+                serde_json::Value::Array(array) => {
+                    for (i, value) in array.iter().enumerate() {
+                        params.append(&mut parse_deep_object(
+                            &format!("{}[{}][{}]", prefix, key, i),
+                            value,
+                        ));
+                    }
+                },
+                serde_json::Value::String(s) => params.push((format!("{}[{}]", prefix, key), s.clone())),
+                _ => params.push((format!("{}[{}]", prefix, key), value.to_string())),
+            }
+        }
+
+        return params;
+    }
+
+    unimplemented!("Only objects are supported with style=deepObject")
+}
+
+/// Internal use only
+/// A content type supported by this client.
+#[allow(dead_code)]
+enum ContentType {
+    Json,
+    Text,
+    Unsupported(String)
+}
+
+impl From<&str> for ContentType {
+    fn from(content_type: &str) -> Self {
+        if content_type.starts_with("application") && content_type.contains("json") {
+            return Self::Json;
+        } else if content_type.starts_with("text/plain") {
+            return Self::Text;
+        } else {
+            return Self::Unsupported(content_type.to_string());
+        }
+    }
+}
+
+pub mod default_api;
+
+pub mod configuration;

gamenight-api-client-rs/src/lib.rs

@@ -0,0 +1,11 @@
+#![allow(unused_imports)]
+#![allow(clippy::too_many_arguments)]
+
+extern crate serde_repr;
+extern crate serde;
+extern crate serde_json;
+extern crate url;
+extern crate reqwest;
+
+pub mod apis;
+pub mod models;

gamenight-api-client-rs/src/models/add_gamenight_request_body.rs

@@ -0,0 +1,30 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct AddGamenightRequestBody {
+    #[serde(rename = "name", skip_serializing_if = "Option::is_none")]
+    pub name: Option<String>,
+    #[serde(rename = "datetime", skip_serializing_if = "Option::is_none")]
+    pub datetime: Option<String>,
+}
+
+impl AddGamenightRequestBody {
+    pub fn new() -> AddGamenightRequestBody {
+        AddGamenightRequestBody {
+            name: None,
+            datetime: None,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/failure.rs

@@ -0,0 +1,29 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+/// Failure : Failure Reason
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct Failure {
+    #[serde(rename = "message", skip_serializing_if = "Option::is_none")]
+    pub message: Option<String>,
+}
+
+impl Failure {
+    /// Failure Reason
+    pub fn new() -> Failure {
+        Failure {
+            message: None,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/gamenight.rs

@@ -0,0 +1,36 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct Gamenight {
+    #[serde(rename = "id")]
+    pub id: String,
+    #[serde(rename = "name")]
+    pub name: String,
+    #[serde(rename = "datetime")]
+    pub datetime: String,
+    #[serde(rename = "owner_id")]
+    pub owner_id: String,
+}
+
+impl Gamenight {
+    pub fn new(id: String, name: String, datetime: String, owner_id: String) -> Gamenight {
+        Gamenight {
+            id,
+            name,
+            datetime,
+            owner_id,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/gamenight_id.rs

@@ -0,0 +1,27 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct GamenightId {
+    #[serde(rename = "gamenight_id")]
+    pub gamenight_id: String,
+}
+
+impl GamenightId {
+    pub fn new(gamenight_id: String) -> GamenightId {
+        GamenightId {
+            gamenight_id,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/get_gamenight_request.rs

@@ -0,0 +1,27 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct GetGamenightRequest {
+    #[serde(rename = "id", skip_serializing_if = "Option::is_none")]
+    pub id: Option<String>,
+}
+
+impl GetGamenightRequest {
+    pub fn new() -> GetGamenightRequest {
+        GetGamenightRequest {
+            id: None,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/get_gamenight_request_body.rs

@@ -0,0 +1,27 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct GetGamenightRequestBody {
+    #[serde(rename = "id", skip_serializing_if = "Option::is_none")]
+    pub id: Option<String>,
+}
+
+impl GetGamenightRequestBody {
+    pub fn new() -> GetGamenightRequestBody {
+        GetGamenightRequestBody {
+            id: None,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/get_token_401_response.rs

@@ -0,0 +1,27 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct GetToken401Response {
+    #[serde(rename = "message")]
+    pub message: String,
+}
+
+impl GetToken401Response {
+    pub fn new(message: String) -> GetToken401Response {
+        GetToken401Response {
+            message,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/login.rs

@@ -0,0 +1,30 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct Login {
+    #[serde(rename = "username")]
+    pub username: String,
+    #[serde(rename = "password")]
+    pub password: String,
+}
+
+impl Login {
+    pub fn new(username: String, password: String) -> Login {
+        Login {
+            username,
+            password,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/mod.rs

@@ -0,0 +1,22 @@
+pub mod add_gamenight_request_body;
+pub use self::add_gamenight_request_body::AddGamenightRequestBody;
+pub mod failure;
+pub use self::failure::Failure;
+pub mod gamenight;
+pub use self::gamenight::Gamenight;
+pub mod gamenight_id;
+pub use self::gamenight_id::GamenightId;
+pub mod get_gamenight_request_body;
+pub use self::get_gamenight_request_body::GetGamenightRequestBody;
+pub mod login;
+pub use self::login::Login;
+pub mod participants;
+pub use self::participants::Participants;
+pub mod registration;
+pub use self::registration::Registration;
+pub mod token;
+pub use self::token::Token;
+pub mod user;
+pub use self::user::User;
+pub mod user_id;
+pub use self::user_id::UserId;

gamenight-api-client-rs/src/models/participants.rs

@@ -0,0 +1,27 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct Participants {
+    #[serde(rename = "participants")]
+    pub participants: Vec<String>,
+}
+
+impl Participants {
+    pub fn new(participants: Vec<String>) -> Participants {
+        Participants {
+            participants,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/registration.rs

@@ -0,0 +1,39 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct Registration {
+    #[serde(rename = "username")]
+    pub username: String,
+    #[serde(rename = "email")]
+    pub email: String,
+    #[serde(rename = "password")]
+    pub password: String,
+    #[serde(rename = "password_repeat")]
+    pub password_repeat: String,
+    #[serde(rename = "registration_token")]
+    pub registration_token: String,
+}
+
+impl Registration {
+    pub fn new(username: String, email: String, password: String, password_repeat: String, registration_token: String) -> Registration {
+        Registration {
+            username,
+            email,
+            password,
+            password_repeat,
+            registration_token,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/token.rs

@@ -0,0 +1,27 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct Token {
+    #[serde(rename = "jwt_token", skip_serializing_if = "Option::is_none")]
+    pub jwt_token: Option<String>,
+}
+
+impl Token {
+    pub fn new() -> Token {
+        Token {
+            jwt_token: None,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/user.rs

@@ -0,0 +1,33 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct User {
+    #[serde(rename = "id")]
+    pub id: String,
+    #[serde(rename = "username")]
+    pub username: String,
+    #[serde(rename = "email", skip_serializing_if = "Option::is_none")]
+    pub email: Option<String>,
+}
+
+impl User {
+    pub fn new(id: String, username: String) -> User {
+        User {
+            id,
+            username,
+            email: None,
+        }
+    }
+}
+

gamenight-api-client-rs/src/models/user_id.rs

@@ -0,0 +1,27 @@
+/*
+ * Gamenight
+ *
+ * Api specifaction for a Gamenight server
+ *
+ * The version of the OpenAPI document: 1.0
+ * Contact: dennis@brentj.es
+ * Generated by: https://openapi-generator.tech
+ */
+
+use crate::models;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
+pub struct UserId {
+    #[serde(rename = "user_id")]
+    pub user_id: String,
+}
+
+impl UserId {
+    pub fn new(user_id: String) -> UserId {
+        UserId {
+            user_id,
+        }
+    }
+}
+

gamenight-cli/.gitignore

@@ -0,0 +1 @@
+target

gamenight-cli/Cargo.toml

@@ -0,0 +1,16 @@
+[package]
+name = "gamenight-cli"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+gamenight-api-client-rs = { path = "../gamenight-api-client-rs" }
+tokio = { version = "1", features = ["full"] }
+inquire = { version = "0.7.5", features = ["date"] }
+async-trait = "0.1"
+dyn-clone = "1.0"
+chrono = "0.4"
+uuid = { version = "1.3.0", features = ["serde", "v4"] }
+jsonwebtoken = "9.3"
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"

gamenight-cli/src/domain/gamenight.rs

@@ -0,0 +1,20 @@
+use std::fmt::Display;
+
+use chrono::{DateTime, Local};
+use uuid::Uuid;
+
+#[derive(Clone)]
+pub struct Gamenight {
+    pub id: Uuid,
+    pub name: String,
+    pub start_time: DateTime<Local>,
+    pub owner_id: Uuid,
+}
+
+impl Display for Gamenight {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, r#"
+Name: {}
+When: {}"#, self.name, self.start_time.format("%d-%m-%Y %H:%M"))
+    }
+}

gamenight-cli/src/domain/mod.rs

@@ -0,0 +1,2 @@
+pub mod gamenight;
+pub mod user;

gamenight-cli/src/domain/user.rs

@@ -0,0 +1,16 @@
+use std::fmt::Display;
+
+use uuid::Uuid;
+
+#[derive(Clone)]
+pub struct User {
+    pub id: Uuid,
+    pub username: String
+}
+
+impl Display for User {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "{}", self.username)
+        
+    }
+}

gamenight-cli/src/flows/add_gamenight.rs

@@ -0,0 +1,49 @@
+
+use gamenight_api_client_rs::{apis::default_api::post_gamenight, models};
+use inquire::{CustomType, DateSelect, Text};
+use chrono::{self, Local, NaiveTime};
+
+use super::*;
+
+#[derive(Clone)]
+pub struct AddGamenight {
+
+}
+
+impl AddGamenight {
+    pub fn new() -> Self {
+        Self {}
+    }
+}
+
+#[async_trait]
+impl<'a> Flow<'a> for AddGamenight {
+    async fn run(&self, state: &'a mut GamenightState) -> FlowResult<'a> {
+        let mut add_gamenight = models::AddGamenightRequestBody::new();
+
+        add_gamenight.name = Some(Text::new("What should we call your gamenight")
+            .prompt()?);
+        let naive_date = DateSelect::new("When is your gamenight")
+            .prompt()?;
+        let naive_time = CustomType::<NaiveTime>::new("At What time")
+            .prompt()?;
+        add_gamenight.datetime = Some(naive_date
+            .and_time(naive_time)
+            .and_local_timezone(Local)
+            .earliest()
+            .unwrap()
+            .to_utc()
+            .to_rfc3339());
+
+        post_gamenight(&state.configuration, Some(add_gamenight)).await?;
+        
+        Ok((FlowOutcome::Successful, state))
+    }
+}
+
+impl Display for AddGamenight {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "Add Gamenight.")
+    }
+}
+

gamenight-cli/src/flows/exit.rs

@@ -0,0 +1,25 @@
+use super::*;
+
+#[derive(Clone)]
+pub struct Exit {
+
+}
+
+impl Exit {
+    pub fn new() -> Self {
+        Self{}
+    }
+}
+
+#[async_trait]
+impl<'a> Flow<'a> for Exit {
+    async fn run(&self, state: &'a mut GamenightState) -> FlowResult<'a> {
+        Ok((FlowOutcome::Abort, state))
+    }
+}
+
+impl Display for Exit {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "Exit")
+    }
+}

gamenight-cli/src/flows/join.rs

@@ -0,0 +1,34 @@
+use std::fmt::Display;
+
+use async_trait::async_trait;
+use gamenight_api_client_rs::{apis::default_api::join_post, models::GamenightId};
+use uuid::Uuid;
+
+use super::{Flow, FlowOutcome, FlowResult, GamenightState};
+
+#[derive(Clone)]
+pub struct Join {
+    gamenight_id: Uuid
+}
+
+impl Join {
+    pub fn new(gamenight_id: Uuid) -> Self {
+        Self {
+            gamenight_id
+        }
+    }
+}
+
+#[async_trait]
+impl<'a> Flow<'a> for Join {
+    async fn run(&self, state: &'a mut GamenightState) -> FlowResult<'a> {
+        let _ = join_post(&state.configuration, Some(GamenightId{gamenight_id: self.gamenight_id.to_string()})).await?;
+        Ok((FlowOutcome::Successful, state))
+    }
+}
+
+impl Display for Join {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "Join")
+    }
+}

gamenight-cli/src/flows/leave.rs

@@ -0,0 +1,34 @@
+use std::fmt::Display;
+
+use async_trait::async_trait;
+use gamenight_api_client_rs::{apis::default_api::leave_post, models::GamenightId};
+use uuid::Uuid;
+
+use super::{Flow, FlowOutcome, FlowResult, GamenightState};
+
+#[derive(Clone)]
+pub struct Leave {
+    gamenight_id: Uuid
+}
+
+impl Leave {
+    pub fn new(gamenight_id: Uuid) -> Self {
+        Self {
+            gamenight_id
+        }
+    }
+}
+
+#[async_trait]
+impl<'a> Flow<'a> for Leave {
+    async fn run(&self, state: &'a mut GamenightState) -> FlowResult<'a> {
+        let _ = leave_post(&state.configuration, Some(GamenightId{gamenight_id: self.gamenight_id.to_string()})).await?;
+        Ok((FlowOutcome::Successful, state))
+    }
+}
+
+impl Display for Leave {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "Leave")
+    }
+}

gamenight-cli/src/flows/list_gamenights.rs

@@ -0,0 +1,52 @@
+
+use chrono::DateTime;
+use gamenight_api_client_rs::apis::default_api::get_gamenights;
+use inquire::Select;
+use uuid::Uuid;
+
+use crate::{domain::{gamenight::Gamenight}, flows::view_gamenight::ViewGamenight};
+
+use super::{exit::Exit, *};
+
+#[derive(Clone)]
+pub struct ListGamenights {
+
+}
+
+impl ListGamenights {
+    pub fn new() -> Self {
+        Self {}
+    }
+}
+
+#[async_trait]
+impl<'a> Flow<'a> for ListGamenights {
+    async fn run(&self, state: &'a mut GamenightState) -> FlowResult<'a> {
+        let response = get_gamenights(&state.configuration).await?;
+
+        let mut view_flows: Vec<Box<dyn Flow<'_> + Send>> = vec![];
+
+        for response in response.iter() {
+            let gamenight = Gamenight {
+                id: Uuid::parse_str(&response.id)?,
+                name: response.name.clone(),
+                start_time:DateTime::parse_from_rfc3339(&response.datetime)?.into(),
+                owner_id: Uuid::parse_str(&response.owner_id)?
+            };
+            view_flows.push(Box::new(ViewGamenight::new(gamenight)));
+        }
+
+        view_flows.push(Box::new(Exit::new()));
+
+        let choice = Select::new("What gamenight would you like to view?", view_flows)
+            .prompt_skippable()?;
+
+        handle_choice_option(&choice, self, state).await
+    }
+}
+
+impl Display for ListGamenights {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "List all gamenights")
+    }
+}

gamenight-cli/src/flows/login.rs

@@ -0,0 +1,44 @@
+use async_trait::async_trait;
+use gamenight_api_client_rs::{apis::{configuration::Configuration, default_api::get_token}, models};
+use inquire::{Password, Text};
+
+use super::*;
+
+#[derive(Clone)]
+pub struct Login {
+
+}
+
+impl Login {
+    pub fn new() -> Self {
+        Self {}
+    }
+}
+
+#[async_trait]
+impl<'a> Flow<'a> for Login {
+    async fn run(&self, state: &'a mut GamenightState) -> FlowResult<'a> {
+        let configuration = Configuration::new();
+
+        let username = Text::new("What is your login?").prompt()?;
+        let password = Password::new("what is your password?")
+            .without_confirmation()
+            .prompt()?;
+   
+        let login = models::Login::new(username, password);
+   
+        let result = get_token(&configuration, Some(login)).await?;
+        if let Some(token) = result.jwt_token {
+            state.configuration.bearer_access_token = Some(token);
+            Ok((FlowOutcome::Successful, state))
+        } else {
+            Err(FlowError{error: "Unexpected response".to_string()})
+        }
+    }
+}
+
+impl Display for Login {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "Login")
+    }
+}

gamenight-cli/src/flows/main.rs

@@ -0,0 +1,42 @@
+
+use super::{exit::Exit, add_gamenight::AddGamenight, list_gamenights::ListGamenights, login::Login, main_menu::MainMenu, *};
+
+#[derive(Clone)]
+pub struct Main {
+    login: Box<dyn for<'a> Flow<'a>>,
+    main_menu: MainMenu
+}
+
+impl Main {
+    pub fn new() -> Self {
+        let mut main_menu = MainMenu::new();
+        main_menu.menu.push(Box::new(ListGamenights::new()));
+        main_menu.menu.push(Box::new(AddGamenight::new()));
+        main_menu.menu.push(Box::new(Exit::new()));
+        Self {
+            login: Box::new(Login::new()),
+            main_menu
+        }
+    }
+}
+
+impl Default for Main {
+    fn default() -> Self {
+        Self::new()
+    }
+}
+
+#[async_trait]
+impl<'a> Flow<'a> for Main {
+    async fn run(&self, state: &'a mut GamenightState) -> FlowResult<'a> {
+        let (_outcome, state) = self.login.run(state).await?;
+        let (_outcome, state) = self.main_menu.run(state).await?;
+        Ok((FlowOutcome::Successful, state))
+    }
+}
+
+impl Display for Main {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "main")
+    }
+}

gamenight-cli/src/flows/main_menu.rs

@@ -0,0 +1,42 @@
+
+use inquire::{ui::RenderConfig, Select};
+
+use super::*;
+
+#[derive(Clone)]
+pub struct MainMenu {
+    pub menu: Vec<Box<dyn for<'a> Flow<'a> + Send>>
+}
+
+impl MainMenu {
+    pub fn new() -> Self {
+        MainMenu { 
+            menu: vec![]
+        }
+    }
+}
+
+unsafe impl Send for MainMenu {
+
+}
+
+#[async_trait]
+impl<'a> Flow<'a> for MainMenu {
+    async fn run(&self, state: &'a mut GamenightState) -> FlowResult<'a> {
+        let choice = Select::new("What would you like to do?", self.menu.clone())
+            .with_help_message("Select the action you want to take or quit the program")
+            .with_render_config(RenderConfig {
+                option_index_prefix: inquire::ui::IndexPrefix::Simple,
+                ..Default::default()
+            })
+            .prompt_skippable()?;
+
+            handle_choice_option(&choice, self, state).await
+    }
+}
+
+impl Display for MainMenu {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "Main menu")
+    }
+}

gamenight-cli/src/flows/mod.rs

@@ -0,0 +1,109 @@
+use std::fmt::Display;
+
+use async_trait::async_trait;
+use chrono::ParseError;
+use gamenight_api_client_rs::apis::{configuration::Configuration, Error};
+use inquire::InquireError;
+use dyn_clone::DynClone;
+
+pub mod main;
+mod login;
+mod main_menu;
+mod exit;
+mod list_gamenights;
+mod add_gamenight;
+mod view_gamenight;
+mod join;
+mod leave;
+
+pub struct GamenightState {
+    configuration: Configuration,
+}
+
+impl GamenightState {
+    pub fn new() -> Self{
+        Self {
+            configuration: Configuration::new()
+        }
+    }
+}
+
+impl Default for GamenightState {
+    fn default() -> Self {
+        Self::new()
+    }
+}
+
+#[derive(Debug)]
+pub struct FlowError {
+    pub error: String
+}
+
+impl From<InquireError> for FlowError {
+    fn from(value: InquireError) -> Self {
+        Self {
+            error: value.to_string()
+        }
+    }
+}
+
+impl From<ParseError> for FlowError {
+    fn from(value: ParseError) -> Self {
+        Self {
+            error: value.to_string()
+        }
+    }
+}
+
+impl<T> From<Error<T>> for FlowError {
+    fn from(value: Error<T>) -> Self {
+        Self {
+            error: value.to_string()
+        }
+    }
+}
+
+impl From<uuid::Error> for FlowError {
+    fn from(value: uuid::Error) -> Self {
+        Self {
+            error: value.to_string()
+        }
+    }
+}
+
+#[derive(PartialEq)]
+pub enum FlowOutcome {
+    Successful,
+    Bool(bool),
+    String(String),
+    Abort
+}
+
+type FlowResult<'a> = Result<(FlowOutcome, &'a mut GamenightState), FlowError>;
+
+dyn_clone::clone_trait_object!(for<'a> Flow<'a>);
+
+#[async_trait]
+pub trait Flow<'a>: Sync + DynClone + Send + Display {
+    async fn run(&self, state: &'a mut GamenightState) -> FlowResult<'a>;
+}
+
+async fn handle_choice<'a>(choice: &Box<dyn Flow<'a> + Send>, flow: &dyn Flow<'a>, state: &'a mut GamenightState) -> FlowResult<'a> {
+    let (outcome, new_state) = choice.run(state).await?;
+        
+    if outcome == FlowOutcome::Abort {
+        Ok((FlowOutcome::Successful, new_state))
+    }
+    else {
+        flow.run(new_state).await
+    }       
+}
+
+async fn handle_choice_option<'a>(choice: &Option<Box<dyn Flow<'a> + Send>>, flow: &dyn Flow<'a>, state: &'a mut GamenightState) -> FlowResult<'a> {
+    if let Some(choice) = choice {
+        handle_choice(choice, flow, state).await
+    }
+    else {
+        Ok((FlowOutcome::Abort, state))
+    }
+}

gamenight-cli/src/flows/view_gamenight.rs

@@ -0,0 +1,93 @@
+
+use gamenight_api_client_rs::{apis::default_api::{participants_get, user_get}, models::{GamenightId, UserId}};
+use inquire::Select;
+use jsonwebtoken::{decode, DecodingKey, Validation};
+use serde::{Deserialize, Serialize};
+use uuid::Uuid;
+
+use crate::{domain::{gamenight::Gamenight, user::User}, flows::{exit::Exit, join::Join, leave::Leave}};
+
+use super::*;
+
+#[derive(Clone)]
+pub struct ViewGamenight {
+    gamenight: Gamenight
+}
+
+impl ViewGamenight {
+    pub fn new(gamenight: Gamenight) -> Self {
+        Self {
+            gamenight
+        }
+    }
+}
+
+
+fn vec_user_to_usernames_string(users: &Vec<User>) -> String {
+    
+    let string_list: Vec<String> = users.iter().map(|x| {format!("{}", x)}).collect();
+    string_list.join(", ")
+}
+
+#[derive(Debug, Serialize, Deserialize)]
+pub struct Claims {
+    exp: i64,
+    uid: Uuid
+}
+
+impl From<jsonwebtoken::errors::Error> for FlowError {
+    fn from(value: jsonwebtoken::errors::Error) -> Self {
+        Self {
+            error: value.to_string()
+        }
+    }
+}
+
+#[async_trait]
+impl<'a> Flow<'a> for ViewGamenight {
+    async fn run(&self, state: &'a mut GamenightState) -> FlowResult<'a> {
+        
+        let participants = participants_get(&state.configuration, Some(GamenightId{gamenight_id: self.gamenight.id.to_string()})).await?;
+        let mut users = vec![];
+        for participant in participants.participants.iter() {
+            let user = user_get(&state.configuration, Some(UserId{user_id: participant.clone()})).await?;
+            users.push(User {
+                id: Uuid::parse_str(&user.id)?,
+                username: user.username
+            });
+        }
+
+        println!("{}\nwho: {}", self.gamenight, vec_user_to_usernames_string(&users));
+        let decoding_key = DecodingKey::from_secret(b"");
+        let mut validation = Validation::default();
+        validation.insecure_disable_signature_validation();
+        let claims = decode::<Claims>(
+            &state.configuration.bearer_access_token.as_ref().unwrap(),
+            &decoding_key,
+            &validation)?.claims;
+            
+        let join_or_leave: Box<dyn Flow<'a> + Send> =
+        if users.iter().map(|x| {x.id}).find(|x| *x == claims.uid) != None {
+            Box::new(Leave::new(claims.uid))
+        }
+        else { 
+            Box::new(Join::new(claims.uid))
+        };
+
+        let options: Vec<Box<dyn Flow<'a> + Send>> = vec![
+            join_or_leave,
+            Box::new(Exit::new())
+        ];
+        let choice = Select::new("What do you want to do:", options)
+            .prompt_skippable()?;
+
+        handle_choice_option(&choice, self, state).await
+    }
+}
+
+impl Display for ViewGamenight {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "{} {}", self.gamenight.name, self.gamenight.start_time.format("%d-%m-%Y %H:%M"))
+    }
+}
+

gamenight-cli/src/main.rs

@@ -0,0 +1,15 @@
+pub mod flows;
+pub mod domain;
+
+use flows::{main::Main, Flow, GamenightState};
+
+#[tokio::main]
+async fn main() {
+    let mut state = GamenightState::new();
+    let mainflow = Main::new();
+    if let Err(x) = mainflow.run(&mut state).await {
+        println!("{}", x.error);
+    }
+}
+    
+

gamenight-database/.gitignore

@@ -0,0 +1 @@
+target

gamenight-database/Cargo.toml

@@ -0,0 +1,15 @@
+[package]
+name = "gamenight-database"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+diesel = { version = "2.0", features = ["postgres", "r2d2", "uuid", "chrono"] }
+diesel-derive-enum = { version = "2.0", features = ["postgres"] }
+diesel_migrations = "2.0"
+argon2 = { version = "0.5", features = ["std"] }
+uuid = { version = "1.17.0", features = ["serde", "v4"] }
+serde = { version = "1.0", features = ["derive"] }
+chrono = { version = "0.4", features = ["serde"] }
+rand_core = "0.9"
+

gamenight-database/diesel.toml

@@ -0,0 +1,2 @@
+[print_schema]
+file = "src/schema/schema.rs"

gamenight-database/migrations/2022-03-19-191822_initial/up.sql

@@ -0,0 +1,12 @@
+-- Your SQL goes here
+
+CREATE TABLE gamenight (
+    id UUID NOT NULL PRIMARY KEY,
+    name VARCHAR NOT NULL,
+    datetime VARCHAR NOT NULL
+);
+
+CREATE TABLE known_games (
+    id UUID NOT NULL PRIMARY KEY,
+    name VARCHAR UNIQUE NOT NULL
+);

gamenight-database/migrations/2022-04-17-175115_user-system/down.sql

@@ -0,0 +1,6 @@
+-- This file should undo anything in `up.sql`
+
+drop table pwd;
+drop table users;
+
+drop type Role;

gamenight-database/migrations/2022-04-17-175115_user-system/up.sql

@@ -0,0 +1,28 @@
+CREATE TYPE Role AS ENUM ('user', 'admin');
+
+CREATE TABLE users (
+    id UUID NOT NULL PRIMARY KEY,
+    username VARCHAR UNIQUE NOT NULL,
+    email VARCHAR UNIQUE NOT NULL,
+    role Role NOT NULL
+);
+
+CREATE TABLE pwd (
+    user_id UUID NOT NULL PRIMARY KEY,
+    password VARCHAR NOT NULL,
+    CONSTRAINT FK_UserId FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
+);
+
+--Initialize default admin user, with password "gamenight!"
+CREATE EXTENSION IF NOT EXISTS "uuid-ossp";
+DO $$
+DECLARE 
+    admin_uuid uuid = uuid_generate_v4();
+BEGIN
+    INSERT INTO users (id, username, email, role)
+    values(admin_uuid, 'admin', '', 'admin');
+
+    insert INTO pwd (user_id, password)
+    values(admin_uuid, '$argon2id$v=19$m=4096,t=3,p=1$zEdUjCAnZqd8DziYWzlFHw$YBLQhKvYIZBY43B8zM6hyBvLKuqTeh0EM5pKOfbWQSI');
+END $$;
+

gamenight-database/migrations/2022-05-14-104118_gamenight_owners/down.sql

@@ -0,0 +1,4 @@
+-- This file should undo anything in `up.sql`
+
+ALTER TABLE gamenight
+DROP COLUMN owner_id;

gamenight-database/migrations/2022-05-14-104118_gamenight_owners/up.sql

@@ -0,0 +1,19 @@
+ALTER TABLE gamenight RENAME TO _gamenight_old;
+
+CREATE TABLE gamenight (
+    id UUID NOT NULL PRIMARY KEY,
+    name VARCHAR NOT NULL,
+    datetime VARCHAR NOT NULL,
+    owner_id UUID NOT NULL,
+    CONSTRAINT FK_OwnerId FOREIGN KEY (owner_id) REFERENCES users(id) ON DELETE CASCADE
+);
+
+SET session_replication_role = 'replica';
+
+INSERT INTO gamenight (id, name, datetime, owner_id)
+select id, name, datetime, '00000000-0000-0000-0000-000000000000'
+FROM _gamenight_old;
+
+drop table _gamenight_old;
+
+SET session_replication_role = 'origin';

gamenight-database/migrations/2022-05-27-183310_gamenight_gamelist/down.sql

@@ -0,0 +1,3 @@
+-- This file should undo anything in `up.sql`
+
+drop table gamenight_gamelist;

gamenight-database/migrations/2022-05-27-183310_gamenight_gamelist/up.sql

@@ -0,0 +1,9 @@
+-- Your SQL goes here
+
+create table gamenight_gamelist (
+    gamenight_id UUID NOT NULL,
+    game_id UUID NOT NULL,
+    CONSTRAINT FK_gamenight_id FOREIGN KEY (gamenight_id) REFERENCES gamenight(id) ON DELETE CASCADE,
+    CONSTRAINT FK_game_id FOREIGN KEY (game_id) REFERENCES known_games(id) ON DELETE CASCADE,
+    PRIMARY KEY(gamenight_id, game_id)
+);

gamenight-database/migrations/2022-05-28-142526_gamenight participant/down.sql

@@ -0,0 +1,3 @@
+-- This file should undo anything in `up.sql`
+
+drop table gamenight_participant;

gamenight-database/migrations/2022-05-28-142526_gamenight participant/up.sql

@@ -0,0 +1,9 @@
+-- Your SQL goes here
+
+create table gamenight_participant (
+    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)
+)

gamenight-database/migrations/2022-06-04-141858_registration_tokens/down.sql

@@ -0,0 +1,6 @@
+-- This file should undo anything in `up.sql`
+
+drop table registration_tokens;
+
+ALTER TABLE gamenight
+ALTER datetime TYPE VARCHAR;

gamenight-database/migrations/2022-06-04-141858_registration_tokens/up.sql

@@ -0,0 +1,11 @@
+-- Your SQL goes here
+
+create table registration_tokens (
+    id UUID PRIMARY KEY,
+    token CHARACTER(32) NOT NULL,
+    single_use BOOLEAN NOT NULL,
+    expires TIMESTAMPTZ
+);
+
+ALTER TABLE gamenight
+ALTER datetime TYPE TIMESTAMPTZ using datetime::timestamp;

gamenight-database/src/error.rs

@@ -0,0 +1,13 @@
+pub struct DatabaseError(pub String);
+
+impl From<diesel::result::Error> for DatabaseError {
+    fn from(value: diesel::result::Error) -> Self {
+        DatabaseError(value.to_string())
+    }
+}
+
+impl From<argon2::password_hash::Error> for DatabaseError {
+    fn from(value: argon2::password_hash::Error) -> Self {
+        DatabaseError(value.to_string())
+    }
+}

gamenight-database/src/gamenight.rs

@@ -0,0 +1,28 @@
+use chrono::{DateTime, Utc};
+use diesel::{Insertable, Queryable, PgConnection, RunQueryDsl, insert_into, QueryDsl};
+use serde::{Serialize, Deserialize};
+use uuid::Uuid;
+use crate::schema::gamenight;
+
+use super::error::DatabaseError;
+
+#[derive(Serialize, Deserialize, Debug, Insertable, Queryable)]
+#[diesel(table_name = gamenight)]
+pub struct Gamenight {
+    pub id: Uuid,
+    pub name: String,
+    pub datetime: DateTime<Utc>,
+    pub owner_id: Uuid,
+}
+
+pub fn gamenights(conn: &mut PgConnection) -> Result<Vec::<Gamenight>, DatabaseError> {
+    Ok(gamenight::table.load::<Gamenight>(conn)?)
+}
+
+pub fn add_gamenight(conn: &mut PgConnection, gamenight: Gamenight) -> Result<usize, DatabaseError> {
+    Ok(insert_into(gamenight::table).values(&gamenight).execute(conn)?)
+}
+
+pub fn get_gamenight(conn: &mut PgConnection, id: Uuid) -> Result<Gamenight, DatabaseError> {
+    Ok(gamenight::table.find(id).first(conn)?)
+}

gamenight-database/src/gamenight_participants.rs

@@ -0,0 +1,34 @@
+use diesel::{BoolExpressionMethods, ExpressionMethods, Insertable, QueryDsl, Queryable, RunQueryDsl};
+use serde::{Serialize, Deserialize};
+use uuid::Uuid;
+
+use crate::schema::gamenight_participant;
+
+use super::error::DatabaseError;
+use super::DbConnection;
+
+#[derive(Serialize, Deserialize, Debug, Insertable, Queryable)]
+#[diesel(belongs_to(Gamenight))]
+#[diesel(belongs_to(User))]
+#[diesel(table_name = gamenight_participant)]
+pub struct GamenightParticipant {
+    pub gamenight_id: Uuid,
+    pub user_id: Uuid,
+}
+
+pub fn get_participants(conn: &mut DbConnection, id: &Uuid) -> Result<Vec<Uuid>, DatabaseError> {
+    Ok(gamenight_participant::table
+        .filter(gamenight_participant::gamenight_id.eq(&id))
+        .select(gamenight_participant::user_id)
+        .get_results(conn)?)
+}
+
+pub fn insert_gamenight_participant(conn: &mut DbConnection, gp: GamenightParticipant) -> Result<usize, DatabaseError> {
+    Ok(gp.insert_into(gamenight_participant::table).execute(conn)?)
+}
+
+pub fn delete_gamenight_participant(conn: &mut DbConnection, gp: GamenightParticipant) -> Result<usize, DatabaseError> {
+    Ok(gamenight_participant::table
+        .filter(gamenight_participant::gamenight_id.eq(&gp.gamenight_id).and(gamenight_participant::user_id.eq(gp.user_id)))
+        .execute(conn)?)
+}

gamenight-database/src/lib.rs

@@ -0,0 +1,46 @@
+pub mod user;
+pub mod error;
+pub mod schema;
+pub mod gamenight;
+pub mod gamenight_participants;
+
+use diesel::r2d2::ConnectionManager;
+use diesel::r2d2::ManageConnection;
+use diesel::r2d2::Pool;
+use diesel::r2d2::PooledConnection;
+use diesel::PgConnection;
+use diesel_migrations::embed_migrations;
+use diesel_migrations::EmbeddedMigrations;
+
+use diesel_migrations::MigrationHarness;
+pub use user::login;
+pub use user::register;
+pub use gamenight::gamenights;
+pub use gamenight_participants::get_participants;
+
+pub const MIGRATIONS: EmbeddedMigrations = embed_migrations!();
+pub type DbConnection = PgConnection;
+pub type DbPool = Pool<ConnectionManager<DbConnection>>;
+
+pub fn run_migration(conn: &mut DbConnection) {
+    conn.run_pending_migrations(MIGRATIONS).unwrap();
+}
+
+pub fn get_connection_pool(url: &str) -> DbPool {
+    let manager = ConnectionManager::<PgConnection>::new(url);
+    // Refer to the `r2d2` documentation for more methods to use
+    // when building a connection pool
+    Pool::builder()
+        .test_on_check_out(true)
+        .build(manager)
+        .expect("Could not build connection pool")
+}
+pub trait GetConnection<T> where T: ManageConnection {
+    fn get_conn(&self) -> PooledConnection<T>;
+}
+
+impl<T: ManageConnection> GetConnection<T> for Pool<T> {
+    fn get_conn(&self) -> PooledConnection<T> {
+        self.get().expect("Couldn't get db connection from pool")
+    }
+}

gamenight-database/src/schema.rs

@@ -0,0 +1,83 @@
+// @generated automatically by Diesel CLI.
+
+pub mod sql_types {
+    #[derive(diesel::sql_types::SqlType)]
+    #[diesel(postgres_type(name = "role"))]
+    pub struct Role;
+}
+
+diesel::table! {
+    gamenight (id) {
+        id -> Uuid,
+        name -> Varchar,
+        datetime -> Timestamptz,
+        owner_id -> Uuid,
+    }
+}
+
+diesel::table! {
+    gamenight_gamelist (gamenight_id, game_id) {
+        gamenight_id -> Uuid,
+        game_id -> Uuid,
+    }
+}
+
+diesel::table! {
+    gamenight_participant (gamenight_id, user_id) {
+        gamenight_id -> Uuid,
+        user_id -> Uuid,
+    }
+}
+
+diesel::table! {
+    known_games (id) {
+        id -> Uuid,
+        name -> Varchar,
+    }
+}
+
+diesel::table! {
+    pwd (user_id) {
+        user_id -> Uuid,
+        password -> Varchar,
+    }
+}
+
+diesel::table! {
+    registration_tokens (id) {
+        id -> Uuid,
+        #[max_length = 32]
+        token -> Bpchar,
+        single_use -> Bool,
+        expires -> Nullable<Timestamptz>,
+    }
+}
+
+diesel::table! {
+    use diesel::sql_types::*;
+    use super::sql_types::Role;
+
+    users (id) {
+        id -> Uuid,
+        username -> Varchar,
+        email -> Varchar,
+        role -> Role,
+    }
+}
+
+diesel::joinable!(gamenight -> users (owner_id));
+diesel::joinable!(gamenight_gamelist -> gamenight (gamenight_id));
+diesel::joinable!(gamenight_gamelist -> known_games (game_id));
+diesel::joinable!(gamenight_participant -> gamenight (gamenight_id));
+diesel::joinable!(gamenight_participant -> users (user_id));
+diesel::joinable!(pwd -> users (user_id));
+
+diesel::allow_tables_to_appear_in_same_query!(
+    gamenight,
+    gamenight_gamelist,
+    gamenight_participant,
+    known_games,
+    pwd,
+    registration_tokens,
+    users,
+);

gamenight-database/src/schema/schema.rs

@@ -0,0 +1,83 @@
+// @generated automatically by Diesel CLI.
+
+pub mod sql_types {
+    #[derive(diesel::sql_types::SqlType)]
+    #[diesel(postgres_type(name = "role"))]
+    pub struct Role;
+}
+
+diesel::table! {
+    gamenight (id) {
+        id -> Uuid,
+        name -> Varchar,
+        datetime -> Timestamptz,
+        owner_id -> Uuid,
+    }
+}
+
+diesel::table! {
+    gamenight_gamelist (gamenight_id, game_id) {
+        gamenight_id -> Uuid,
+        game_id -> Uuid,
+    }
+}
+
+diesel::table! {
+    gamenight_participant (gamenight_id, user_id) {
+        gamenight_id -> Uuid,
+        user_id -> Uuid,
+    }
+}
+
+diesel::table! {
+    known_games (id) {
+        id -> Uuid,
+        name -> Varchar,
+    }
+}
+
+diesel::table! {
+    pwd (user_id) {
+        user_id -> Uuid,
+        password -> Varchar,
+    }
+}
+
+diesel::table! {
+    registration_tokens (id) {
+        id -> Uuid,
+        #[max_length = 32]
+        token -> Bpchar,
+        single_use -> Bool,
+        expires -> Nullable<Timestamptz>,
+    }
+}
+
+diesel::table! {
+    use diesel::sql_types::*;
+    use super::sql_types::Role;
+
+    users (id) {
+        id -> Uuid,
+        username -> Varchar,
+        email -> Varchar,
+        role -> Role,
+    }
+}
+
+diesel::joinable!(gamenight -> users (owner_id));
+diesel::joinable!(gamenight_gamelist -> gamenight (gamenight_id));
+diesel::joinable!(gamenight_gamelist -> known_games (game_id));
+diesel::joinable!(gamenight_participant -> gamenight (gamenight_id));
+diesel::joinable!(gamenight_participant -> users (user_id));
+diesel::joinable!(pwd -> users (user_id));
+
+diesel::allow_tables_to_appear_in_same_query!(
+    gamenight,
+    gamenight_gamelist,
+    gamenight_participant,
+    known_games,
+    pwd,
+    registration_tokens,
+    users,
+);

gamenight-database/src/user.rs

@@ -0,0 +1,140 @@
+use argon2::password_hash::Salt;
+use diesel::Connection;
+use serde::{Serialize, Deserialize};
+use uuid::Uuid;
+use diesel::{ExpressionMethods, QueryDsl, RunQueryDsl, Insertable, Queryable};
+use diesel_derive_enum::DbEnum;
+use argon2::password_hash::SaltString;
+use argon2::PasswordHash;
+use argon2::PasswordVerifier;
+use argon2::Argon2;
+use argon2::password_hash::PasswordHasher;
+use argon2::password_hash::rand_core::OsRng;
+use argon2::password_hash::rand_core::RngCore;
+use crate::DbConnection;
+
+use super::schema::{pwd, users};
+pub use super::error::DatabaseError;
+
+
+
+#[derive(Serialize, Deserialize, Debug, Insertable, Queryable)]
+#[diesel(table_name = pwd)]
+struct Pwd {
+    user_id: Uuid,
+    password: String,
+}
+
+#[derive(Serialize, Deserialize, Debug, Insertable, Queryable)]
+#[diesel(table_name = users)]
+pub struct User {
+    pub id: Uuid,
+    pub username: String,
+    pub email: String,
+    pub role: Role,
+}
+
+#[derive(DbEnum, Debug, Serialize, Deserialize, Clone, Copy, PartialEq)]
+#[ExistingTypePath = "crate::schema::sql_types::Role"]
+pub enum Role {
+    Admin,
+    User
+}
+
+pub struct LoginUser {
+    pub username: String,
+    pub password: String
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct LoginResult {
+    pub result: bool,
+    pub user: Option<User>,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct RegisterResult {
+    pub result: bool,
+}
+
+#[derive(Serialize, Deserialize)]
+pub struct Register {
+    pub username: String,
+    pub email: String,
+    pub password: String
+}
+
+pub fn login(conn: &mut DbConnection, user: LoginUser) -> Result<Option<User>, DatabaseError> {
+    let id: Uuid = users::table
+        .filter(users::username.eq(&user.username))
+        .or_filter(users::email.eq(&user.username))
+        .select(users::id)
+        .first(conn)?;
+
+    let pwd: String = pwd::table
+        .filter(pwd::user_id.eq(id))
+        .select(pwd::password)
+        .first(conn)?;
+
+    let parsed_hash = PasswordHash::new(&pwd)?;
+
+    if Argon2::default()
+        .verify_password(user.password.as_bytes(), &parsed_hash)
+        .is_ok()
+    {
+        Ok(Some(users::table.find(id).first(conn)?))
+    } else {
+        Ok(None)
+    } 
+}
+
+pub fn get_user(conn: &mut DbConnection, id: Uuid) -> Result<User, DatabaseError> {
+    Ok(users::table.find(id).first(conn)?)
+}
+
+pub fn register(conn: &mut DbConnection, register: Register) -> Result<(), DatabaseError> {
+    let mut bytes = [0u8; Salt::RECOMMENDED_LENGTH];
+    OsRng.try_fill_bytes(&mut bytes).unwrap();
+    let salt = SaltString::encode_b64(&bytes).unwrap();
+    let argon2 = Argon2::default();
+
+    let password_hash = argon2
+        .hash_password(register.password.as_bytes(), &salt)?
+        .to_string();
+
+    conn.transaction(|c| {
+        let id = Uuid::new_v4();
+
+        diesel::insert_into(users::table)
+            .values(User {
+                id,
+                username: register.username,
+                email: register.email,
+                role: Role::User,
+            })
+            .execute(c)?;
+
+        diesel::insert_into(pwd::table)
+            .values(Pwd {
+                user_id: id,
+                password: password_hash,
+            })
+            .execute(c)?;
+
+        Ok(())
+    })
+}
+
+pub fn count_users_with_username(conn: &mut DbConnection, username: &String) -> Result<i64, DatabaseError> {
+    Ok(users::table
+        .count()
+        .filter(users::username.eq(username))
+        .get_result::<i64>(conn)?)
+}
+
+pub fn count_users_with_email(conn: &mut DbConnection, email: &String) -> Result<i64, DatabaseError> {
+    Ok(users::table
+        .count()
+        .filter(users::email.eq(email))
+        .get_result::<i64>(conn)?)
+}

migrations/2022-03-19-191822_initial/up.sql

@@ -1,12 +0,0 @@
--- Your SQL goes here
-
-CREATE TABLE gamenight (
-    id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
-    game text TEXT NOT NULL,
-    datetime TEXT NOT NULL
-);
-
-CREATE TABLE known_games (
-    id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
-    game TEXT UNIQUE NOT NULL
-);

src/api.rs

@@ -1,58 +0,0 @@
-use crate::schema;
-use rocket::form::Form;
-use rocket::serde::json::{Json, json, Value};
-use rocket::http::Status;
-use rocket::request::{self, Request, FromRequest};
-use rocket::outcome::Outcome::{Success, Failure};
-use rocket::response::{Redirect, Flash};
-
-pub struct Referer(String);
-
-#[derive(Debug)]
-pub enum ReferrerError {
-    Missing,
-    MoreThanOne
-}
-
-#[derive(Debug, Responder)]
-pub enum ApiResponse {
-    Status(Status),
-    Redirect(Redirect),
-    Value(Value),
-    Flash(Flash<Redirect>)
-}
-
-#[rocket::async_trait]
-impl<'r> FromRequest<'r> for Referer {
-    type Error = ReferrerError;
-
-    async fn from_request(req: &'r Request<'_>) -> request::Outcome<Self, Self::Error> {
-        let referers : Vec<_> = req.headers().get("Referer").collect();
-        match referers.len() {
-            0 => Failure((Status::BadRequest, ReferrerError::Missing)),
-            1 => Success(Referer(referers[0].to_string())),
-            _ => Failure((Status::BadRequest, ReferrerError::MoreThanOne)),
-        }
-    }
-}
-
-#[get("/gamenights")]
-pub async fn gamenights(conn: schema::DbConn) -> ApiResponse {
-    let gamenights = schema::get_all_gamenights(conn).await;
-    ApiResponse::Value(json!(gamenights))
-}
-
-#[post("/gamenight", format = "application/json", data = "<gamenight_json>")]
-pub async fn gamenight_post_json(conn: schema::DbConn, gamenight_json: Json<schema::GameNightNoId>) -> ApiResponse  {
-    schema::insert_gamenight(conn, gamenight_json.into_inner()).await;
-    ApiResponse::Status(Status::Accepted)
-}
-
-#[post("/gamenight", format = "application/x-www-form-urlencoded", data = "<gamenight_form>")]
-pub async fn gamenight_post_form(referer: Option<Referer>, conn: schema::DbConn, gamenight_form: Form<schema::GameNightNoId>) -> ApiResponse {
-    schema::insert_gamenight(conn, gamenight_form.into_inner()).await;
-    match referer {
-        None => ApiResponse::Status(Status::Accepted),
-        Some(referer) => ApiResponse::Flash(Flash::success(Redirect::to(referer.0), "Added Gamenight."))
-    }
-}