jong/spacetimedb/src/lib.rs

use spacetimedb::{rand::seq::SliceRandom, reducer, table, Identity, ReducerContext, Table};

use jong_types::*;

#[table(name = player)]
pub struct Player {
    #[primary_key]
    identity: Identity,

    name: Option<String>,
    lobby_id: u32,
}

#[table(name = lobby, public)]
pub struct Lobby {
    #[primary_key]
    #[auto_inc]
    id: u32,

    host: Identity,
}

#[table(name = wall)]
pub struct Wall {
    #[primary_key]
    #[auto_inc]
    id: u32,

    tiles: Vec<Tile>,
}

#[table(name = hand)]
pub struct Hand {
    #[primary_key]
    player_ident: Identity,

    tiles: Vec<Tile>,
}

#[table(name = pond, public)]
pub struct Pond {
    tiles: Vec<Tile>,
}

#[reducer]
pub fn add_player(ctx: &ReducerContext, name: Option<String>) {
    let identity = ctx.identity();
    ctx.db.player().insert(Player {
        identity,
        name,
        lobby_id: 0,
    });
}

#[reducer]
pub fn set_name(ctx: &ReducerContext, name: String) -> Result<(), String> {
    if name.is_empty() {
        return Err("names must not be empty".into());
    }
    if let Some(player) = ctx.db.player().identity().find(ctx.sender) {
        ctx.db.player().identity().update(Player {
            name: Some(name),
            ..player
        });
        Ok(())
    } else {
        Err("Cannot set name for unknown user".into())
    }
}

#[reducer]
pub fn join_or_create_lobby(ctx: &ReducerContext, lobby: Option<u32>) -> Result<(), String> {
    let player = ctx.db.player().identity().find(ctx.sender).unwrap();

    todo!()
}

#[reducer]
pub fn insert_wall(ctx: &ReducerContext, player_ids: Vec<u32>) {
    let tiles: Vec<Tile> = tiles();
    ctx.db.wall().insert(Wall { id: 0, tiles });
}

#[reducer]
pub fn shuffle_wall(ctx: &ReducerContext) {
    todo!()
}

#[reducer]
pub fn deal_hands(ctx: &ReducerContext) {
    todo!()
}

#[reducer]
pub fn sort_hand(ctx: &ReducerContext) {
    todo!()
}

// #[reducer(init)]
// pub fn init(_ctx: &ReducerContext) {
//     // Called when the module is initially published
// }

// #[reducer(client_connected)]
// pub fn identity_connected(_ctx: &ReducerContext) {
//     // Called everytime a new client connects
// }

// #[reducer(client_disconnected)]
// pub fn identity_disconnected(_ctx: &ReducerContext) {
//     // Called everytime a client disconnects
// }

// #[reducer]
// pub fn add(ctx: &ReducerContext, name: String) {
// ctx.db.player().insert(Player { name });
// }

// #[reducer]
// pub fn say_hello(ctx: &ReducerContext) {
//     for person in ctx.db.person().iter() {
//         log::info!("Hello, {}!", person.name);
//     }
//     log::info!("Hello, World!");
// }