Added user management (no api yet)
This commit is contained in:
37
src/users.rs
Normal file
37
src/users.rs
Normal file
@@ -0,0 +1,37 @@
|
||||
use std::error::Error;
|
||||
|
||||
use axum::routing::{post, get};
|
||||
use sqlx::{PgPool, query, query_as, types::Uuid};
|
||||
|
||||
struct User {
|
||||
id: Uuid,
|
||||
steamid: String,
|
||||
name: String,
|
||||
avatar: String
|
||||
}
|
||||
|
||||
impl User {
|
||||
fn new(steamid: String, name: String, avatar: String) -> User {
|
||||
User {
|
||||
id: Uuid::nil(),
|
||||
steamid,
|
||||
name,
|
||||
avatar
|
||||
}
|
||||
}
|
||||
|
||||
async fn create(self, pool: PgPool) -> Result<(), Box<dyn Error>>{
|
||||
query!("INSERT INTO users (steamid, name, avatar) VALUES ($1, $2, $3)", self.steamid, self.name, self.avatar).execute(&pool).await?;
|
||||
Ok(())
|
||||
}
|
||||
|
||||
async fn delete(self, pool: PgPool) -> Result<(), Box<dyn Error>>{
|
||||
query!("DELETE FROM users WHERE id=$1", self.id).execute(&pool).await?;
|
||||
Ok(())
|
||||
}
|
||||
|
||||
async fn update(self, pool: PgPool) -> Result<(), Box<dyn Error>>{
|
||||
query!("UPDATE users SET steamid=$1, name=$2, avatar=$3 WHERE id=$4", self.steamid, self.name, self.avatar, self.id).execute(&pool).await?;
|
||||
Ok(())
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user