lobby.h

Go to the documentation of this file.

/*
 * PokerUnicorn Server
 * This project uses test network, NO real coin or NO real money involved.
 * Copyright (C) 2023, Oğuzhan Eroğlu <meowingcate@gmail.com> (https://meowingcat.io)
 * Licensed under GPLv3 License
 * See LICENSE for more info
 */
 
#pragma once


 
#include <stdint.h>
#include <stdbool.h>
#include <pthread.h>
 
#include <libpq-fe.h>
 
#include "ref.h"
#include "sugar.h"
#include "table.h"
#include "account.h"
#include "poker.h"
#include "server.h"
#include "eventloop.h"
#include "trie.h"
#include "auth.h"
#include "../include/mime.h"

#define PKRSRV_LOBBY_DISCONNECTION_TOLERANCE 20000
 
typedef struct pkrsrv_lobby pkrsrv_lobby_t;
typedef struct pkrsrv_lobby_sessions pkrsrv_lobby_sessions_t;
typedef struct pkrsrv_lobby_session pkrsrv_lobby_session_t;
typedef struct pkrsrv_lobby_session_clients pkrsrv_lobby_session_clients_t;
typedef struct pkrsrv_lobby_session_client pkrsrv_lobby_session_client_t;
typedef struct pkrsrv_lobby_client pkrsrv_lobby_client_t;
typedef struct pkrsrv_lobby_client_sessions pkrsrv_lobby_client_sessions_t;
typedef struct pkrsrv_lobby_client_session pkrsrv_lobby_client_session_t;

struct pkrsrv_lobby {
    PKRSRV_REF_COUNTEDIFY();
    pkrsrv_server_t* server;
    pthread_mutex_t mutex;
    int process_latency;
    pkrsrv_lobby_sessions_t* sessions;
    pkrsrv_eventloop_t* eventloop;
    pkrsrv_trie__ascii_t* authorized_clients;
};

struct pkrsrv_lobby_sessions {
    PKRSRV_REF_COUNTEDIFY();
    LISTIFY(pkrsrv_lobby_session_t*);
};

pkrsrv_lobby_sessions_t* pkrsrv_lobby_sessions_new();
void pkrsrv_lobby_sessions_free(pkrsrv_lobby_sessions_t* sessions);

struct pkrsrv_lobby_session {
    PKRSRV_REF_COUNTEDIFY();
    ITEMIFY(pkrsrv_lobby_session_t*);
    PGconn* pg_conn;
    pkrsrv_lobby_t* lobby;
    pkrsrv_uniqid_uuid_t id;
    int process_latency;
    pkrsrv_poker_t* poker;
    pthread_mutex_t mutex;
    bool is_running;
    pkrsrv_eventloop_task_t* proceed_task;
    pkrsrv_eventloop_task_t* poker_start_task;
    pkrsrv_eventloop_task_t* poker_restart_task;
    pkrsrv_lobby_session_clients_t* clients;
    int joined_clients_count;
};

struct pkrsrv_lobby_session_clients {
    LISTIFY(pkrsrv_lobby_session_client_t*);
};

struct pkrsrv_lobby_session_client {
    ITEMIFY(pkrsrv_lobby_session_client_t*);
    pkrsrv_lobby_client_t* client;
    bool is_joined;
    PKRSRV_REF_COUNTEDIFY();
};

struct pkrsrv_lobby_client_session {
    ITEMIFY(pkrsrv_lobby_client_session_t*);
    pkrsrv_lobby_session_t* session;
    bool is_joined;
    PKRSRV_REF_COUNTEDIFY();
};

struct pkrsrv_lobby_client_sessions {
    LISTIFY(pkrsrv_lobby_client_session_t*);
    PKRSRV_REF_COUNTEDIFY();
};
 
pkrsrv_lobby_client_sessions_t *pkrsrv_lobby_client_sessions_new();
void pkrsrv_lobby_client_sessions_free(pkrsrv_lobby_client_sessions_t *sessions);

struct pkrsrv_lobby_client {
    PKRSRV_REF_COUNTEDIFY();
    pkrsrv_lobby_t* lobby;
    pkrsrv_server_client_t* client;
    pkrsrv_lobby_client_sessions_t* sessions;
    pkrsrv_account_t* account;
    pkrsrv_auth_session_t* auth_session;
    bool is_tolerant_disconnected;
    bool is_disconnected;
    bool is_connected;
    bool is_revived;
    pkrsrv_eventloop_task_t* tolerated_disconnected_task;
};

struct on_account_updated_params {
    pkrsrv_account_t* account;
    pkrsrv_lobby_client_t* lobby_client;
};
typedef struct on_account_updated_params on_account_updated_params_t;
void on_account_updated__async(pkrsrv_eventloop_task_t* task);

struct pkrsrv_lobby_new_params {
    int port;
    char* bind_address;
    int process_latency;
    int max_clients;
};
typedef struct pkrsrv_lobby_new_params pkrsrv_lobby_new_params_t;
pkrsrv_lobby_t* pkrsrv_lobby_new(pkrsrv_lobby_new_params_t params);
void pkrsrv_lobby_free(pkrsrv_lobby_t* lobby);
void pkrsrv_lobby_run(pkrsrv_lobby_t* lobby);

pkrsrv_lobby_client_t* pkrsrv_lobby_client_new(pkrsrv_lobby_t* lobby, pkrsrv_server_client_t* client);
void pkrsrv_lobby_client_set_account(pkrsrv_lobby_client_t* lobby_client, pkrsrv_account_t* account);
void pkrsrv_lobby_client_free(pkrsrv_lobby_client_t* lobby_client);

struct pkrsrv_lobby_session_new_params {
    pkrsrv_auth_session_t* auth_session;
    pkrsrv_lobby_t* lobby;
    pkrsrv_table_t* table;
};
typedef struct pkrsrv_lobby_session_new_params pkrsrv_lobby_session_new_params_t;
pkrsrv_lobby_session_t* pkrsrv_lobby_session_new(pkrsrv_lobby_session_new_params_t params);
void pkrsrv_lobby_session_free(pkrsrv_lobby_session_t* session);

void pkrsrv_lobby_sessions_add(pkrsrv_lobby_sessions_t* sessions, pkrsrv_lobby_session_t* session);
void pkrsrv_lobby_sessions_remove(pkrsrv_lobby_sessions_t* sessions, pkrsrv_lobby_session_t* session);

void pkrsrv_lobby_session_start(pkrsrv_lobby_session_t* session);
void pkrsrv_lobby_session_stop(pkrsrv_lobby_session_t* session);
void pkrsrv_lobby_session_free(pkrsrv_lobby_session_t* p_session);
pkrsrv_lobby_session_t* pkrsrv_lobby_session_getby_id(pkrsrv_lobby_t* lobby, uint64_t id);
pkrsrv_lobby_session_t* pkrsrv_lobby_session_getby_table_id(pkrsrv_lobby_t* lobby, uint64_t id);

struct pkrsrv_lobby_session_proceed__async_params {
    pkrsrv_lobby_session_t* session;
};
typedef struct pkrsrv_lobby_session_proceed__async_params pkrsrv_lobby_session_proceed__async_params_t;
void pkrsrv_lobby_session_proceed__async(pkrsrv_eventloop_task_t* task);

struct pkrsrv_lobby_session_poker_start__async_params {
    pkrsrv_lobby_session_t* session;
};
typedef struct pkrsrv_lobby_session_poker_start__async_params pkrsrv_lobby_session_poker_start__async_params_t;
void pkrsrv_lobby_session_poker_start__async(pkrsrv_eventloop_task_t* task);

struct pkrsrv_lobby_session_poker_restart__async_params {
    pkrsrv_lobby_session_t* session;
};
typedef struct pkrsrv_lobby_session_poker_restart__async_params pkrsrv_lobby_session_poker_restart__async_params_t;
void pkrsrv_lobby_session_poker_restart__async(pkrsrv_eventloop_task_t* task);

pkrsrv_lobby_session_client_t* pkrsrv_lobby_session_client_new(pkrsrv_lobby_client_t* lobby_client);
void pkrsrv_lobby_session_client_free(pkrsrv_lobby_session_client_t* session_client);
void pkrsrv_lobby_session_clients_add(pkrsrv_lobby_session_clients_t* session_clients, pkrsrv_lobby_session_client_t* session_client);
void pkrsrv_lobby_session_clients_remove(pkrsrv_lobby_session_clients_t* session_clients, pkrsrv_lobby_session_client_t* session_client);

pkrsrv_lobby_client_session_t* pkrsrv_lobby_client_session_new(pkrsrv_lobby_session_t* session);
void pkrsrv_lobby_client_session_free(pkrsrv_lobby_client_session_t* joined_session);
void pkrsrv_lobby_client_sessions_add(pkrsrv_lobby_client_sessions_t* client_sessions, pkrsrv_lobby_client_session_t* client_session);
void pkrsrv_lobby_client_sessions_remove(pkrsrv_lobby_client_sessions_t* client_sessions, pkrsrv_lobby_client_session_t* client_session);

bool pkrsrv_lobby_client_enter_session(pkrsrv_lobby_client_t* client, pkrsrv_lobby_session_t* session);
bool pkrsrv_lobby_client_leave_session(pkrsrv_lobby_client_t* client, pkrsrv_lobby_client_session_t* client_session);
bool pkrsrv_lobby_client_join_session(pkrsrv_lobby_client_t* client, pkrsrv_lobby_session_t* session, uint64_t enterance_amount, int position);
bool pkrsrv_lobby_client_unjoin_session(pkrsrv_lobby_client_t* client, pkrsrv_lobby_session_t* session);

pkrsrv_lobby_client_session_t* pkrsrv_lobby_client_get_session_by_id(pkrsrv_lobby_client_t* client, uint64_t id);
pkrsrv_lobby_client_session_t* pkrsrv_lobby_client_session_getby_table_id(pkrsrv_lobby_client_t* client, uint64_t id);
pkrsrv_lobby_session_client_t* pkrsrv_lobby_session_client_getby_socket(pkrsrv_lobby_session_t* session, int socket);
pkrsrv_lobby_session_client_t* pkrsrv_lobby_session_client_getby_account_id(pkrsrv_lobby_session_t* session, uint64_t account_id);
pkrsrv_lobby_client_session_t* pkrsrv_lobby_client_session_getby_session_id(pkrsrv_lobby_client_t* lobby_client, uint64_t session_id);
 
static void on_client_connected(pkrsrv_eventloop_task_t* task);
static void on_client_disconnected(pkrsrv_eventloop_task_t* task);
static void on_client_disconnected__tolerated(pkrsrv_eventloop_task_t* task);
static void on_client_meowed(pkrsrv_eventloop_task_t* task);
static void on_client_login(pkrsrv_eventloop_task_t* task);
static void on_client_signup(pkrsrv_eventloop_task_t* task);
static void on_client_auth_session(pkrsrv_eventloop_task_t* task);
static void on_client_get_account(pkrsrv_eventloop_task_t* task);
static void on_client_enter(pkrsrv_eventloop_task_t* task);
static void on_client_leave(pkrsrv_eventloop_task_t* task);
static void on_client_join(pkrsrv_eventloop_task_t* task);
static void on_client_unjoin(pkrsrv_eventloop_task_t* task);
static void on_client_action(pkrsrv_eventloop_task_t* task);
static void on_client_get_tables(pkrsrv_eventloop_task_t* task);
static void on_client_get_sessions(pkrsrv_eventloop_task_t* task);
static void on_client_update_account(pkrsrv_eventloop_task_t* task);
static void on_client_json(pkrsrv_eventloop_task_t* task);
 
static void on_poker_action(pkrsrv_eventloop_task_t* task);

bool reorder_updated_session(pkrsrv_lobby_session_t* updated, int old_length);

void pkrsrv_lobby_broadcast_sessions(pkrsrv_lobby_t* lobby);