account.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 <pthread.h>
#include <stdbool.h>
 
#include <libpq-fe.h>
 
#include "sugar.h"
#include "ref.h"
#include "string.h"
 
#define PKRSRV_ACCOUNT_SELECT_COLUMNS " id, id_token, name, avatar, balance, xmr_deposit_address, locked_balance, total_deposited, xmr_deposit_address_index, xmr_height "
#define PKRSRV_ACCOUNT_SELECT_COLUMNS_COUNT 11
#define PKRSRV_ACCOUNT_SELECT_COLUMNS_ARRAY { "id", "id_token", "name", "avatar", "balance", "xmr_deposit_address", "locked_balance", "total_deposited", "xmr_deposit_address_index", "xmr_height", NULL }
 
typedef struct pkrsrv_account pkrsrv_account_t;
 
struct pkrsrv_account {
    PKRSRV_REF_COUNTEDIFY();
    uint64_t id;
    pkrsrv_string_t* id_token;
    pkrsrv_string_t* name;
    pkrsrv_string_t* avatar;
    pkrsrv_string_t* xmr_deposit_address;
    uint64_t xmr_deposit_address_index;
    uint64_t balance;
    uint64_t locked_balance;
    uint64_t total_deposited;
    uint64_t xmr_height;
    void* owner;
    void (*on_updated)(pkrsrv_account_t* account, void* param);
    void* on_updated_param;
};
 
typedef struct pkrsrv_account_new_params {
    uint64_t id;
    pkrsrv_string_t* id_token;
    pkrsrv_string_t* name;
    pkrsrv_string_t* avatar;
    pkrsrv_string_t* xmr_deposit_address;
    uint64_t xmr_deposit_address_index;
    uint64_t balance;
    uint64_t locked_balance;
    uint64_t total_deposited;
    uint64_t xmr_height;
} pkrsrv_account_new_params_t;
 
pkrsrv_account_t* pkrsrv_account_new(pkrsrv_account_new_params_t params);
void pkrsrv_account_free(pkrsrv_account_t* player);
 
bool pkrsrv_account_set_balance(pkrsrv_account_t* account, uint64_t balance);
 
void pkrsrv_account_get_balance(pkrsrv_account_t* account, uint64_t balance);
 
typedef struct pkrsrv_account_create_params {
    pkrsrv_string_t* id_token;
    pkrsrv_string_t* name;
    pkrsrv_string_t* avatar;
    pkrsrv_string_t* password;
    pkrsrv_string_t* xmr_deposit_address;
    uint64_t xmr_deposit_address_index;
    uint64_t balance;
    uint64_t locked_balance;
    uint64_t total_deposited;
    uint64_t xmr_height;
} pkrsrv_account_create_params_t;
typedef struct pkrsrv_account_create_result {
    pkrsrv_account_t* account;
    bool is_already_exists;
} pkrsrv_account_create_result_t;
pkrsrv_account_create_result_t pkrsrv_account_create(PGconn* pg_conn, pkrsrv_account_create_params_t params);
 
typedef struct pkrsrv_account_update_params {
    uint64_t id;
    pkrsrv_string_t* name;
    pkrsrv_string_t* avatar;
} pkrsrv_account_update_params_t;
typedef struct pkrsrv_account_update_result {
    bool is_ok;
    bool is_avatar_too_big;
} pkrsrv_account_update_result_t;
pkrsrv_account_update_result_t pkrsrv_account_update(PGconn* pg_conn, pkrsrv_account_update_params_t params);
bool pkrsrv_account_update_balance(PGconn* pg_conn, pkrsrv_account_t* account, uint64_t balance);
bool pkrsrv_account_add_balance(PGconn* pg_conn, pkrsrv_account_t* account, uint64_t amount);
bool pkrsrv_account_update_locked_balance(PGconn* pg_conn, pkrsrv_account_t* account, uint64_t locked_balance);
bool pkrsrv_account_remove_locked_balance(PGconn* pg_conn, pkrsrv_account_t* account, uint64_t amount);
bool pkrsrv_account_lock_balance(PGconn* pg_conn, pkrsrv_account_t* account, uint64_t amount);
bool pkrsrv_account_unlock_balance(PGconn* pg_conn, pkrsrv_account_t* account, uint64_t amount);
bool pkrsrv_account_revert_locked_balanes(PGconn* pg_conn);
 
bool pkrsrv_account_update_xmr_height(PGconn* pg_conn, pkrsrv_account_t* account, uint64_t xmr_height);
 
typedef struct pkrsrv_account_getby_credentials_params {
    pkrsrv_string_t* id_token;
    pkrsrv_string_t* password;
} pkrsrv_account_getby_credentials_params_t;
pkrsrv_account_t* pkrsrv_account_getby_credentials(PGconn* pg_conn, pkrsrv_account_getby_credentials_params_t params);
 
pkrsrv_account_t* pkrsrv_account_getby_id(PGconn* pg_conn, uint64_t p_id);
 
void pkrsrv_account_fetch(PGconn* pg_conn, pkrsrv_account_t* p_account);
 
typedef struct pkrsrv_account_iterator {
    PKRSRV_REF_COUNTEDIFY() 
    pkrsrv_account_t* current; 
    int index; 
    int count; 
    PGresult* query_result; 
} pkrsrv_account_iterator_t;
 
pkrsrv_account_iterator_t* pkrsrv_account_iterator_new();
 
void pkrsrv_account_iterator_free(pkrsrv_account_iterator_t* iterator);
 
pkrsrv_account_iterator_t* pkrsrv_account_iterator_query(PGconn* pg_conn, pkrsrv_string_t* query, char** params, int params_length);
 
bool pkrsrv_account_iterator_next(pkrsrv_account_iterator_t* iterator);