deposit.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 <pthread.h>
#include <stdbool.h>
 
#include <libpq-fe.h>
 
#include "sugar.h"
#include "string.h"
#include "ref.h"
 
#include "../include/account.h"
 
#define PKRSRV_DEPOSIT_SERVICE_DELAY 10000
#define PKRSRV_DEPOSIT_MONERO_MIN_CONFIRMATIONS 1
 
typedef struct pkrsrv_deposit_service pkrsrv_deposit_service_t;
typedef struct pkrsrv_deposit_monero_address pkrsrv_deposit_monero_address_t;
typedef struct pkrsrv_deposit_monero_tx pkrsrv_deposit_monero_tx_t;
typedef struct pkrsrv_deposit_monero_tx_list pkrsrv_deposit_monero_tx_list_t;
typedef struct pkrsrv_deposit_monero_deposit pkrsrv_deposit_monero_deposit_t;
typedef struct pkrsrv_deposit_monero_deposit_list pkrsrv_deposit_monero_deposit_list_t;
 
typedef enum pkrsrv_deposit_monero_deposit_status {
    PKRSRV_DEPOSIT_MONERO_DEPOSIT_STATUS_NONE = 0,
    PKRSRV_DEPOSIT_MONERO_DEPOSIT_STATUS_PENDING,
    PKRSRV_DEPOSIT_MONERO_DEPOSIT_STATUS_CONFIRMED,
    PKRSRV_DEPOSIT_MONERO_DEPOSIT_STATUS_FAILED
} pkrsrv_deposit_monero_deposit_status_t;
 
struct pkrsrv_deposit_service {
    PKRSRV_REF_COUNTEDIFY();
    pthread_t thread;
    bool is_running;
    PGconn* pg_conn;
};
 
struct pkrsrv_deposit_monero_address {
    PKRSRV_REF_COUNTEDIFY();
    pkrsrv_string_t* address;
    int account_index;
    int index;
    int payment_id;
};
 
pkrsrv_deposit_monero_address_t* pkrsrv_deposit_monero_address_new(pkrsrv_string_t* address, int account_index, int index, int payment_id);
void pkrsrv_deposit_monero_address_free(pkrsrv_deposit_monero_address_t* address);
pkrsrv_deposit_monero_address_t* pkrsrv_deposit_monero_create_address(int account_index, int index);
 
pkrsrv_deposit_service_t* pkrsrv_deposit_service_new();
void pkrsrv_deposit_service_free(pkrsrv_deposit_service_t* service);
void pkrsrv_deposit_service_start(pkrsrv_deposit_service_t* service);
void pkrsrv_deposit_service_stop(pkrsrv_deposit_service_t* service);
void pkrsrv_deposit_service_thread_f(pkrsrv_deposit_service_t* service);
 
pkrsrv_string_t* pkrsrv_deposit_monero_wallet_rpc_call(char* method, char* params);
 
bool pkrsrv_deposit_monero_wallet_open(char* wallet_name, char* password);
bool pkrsrv_deposit_monero_wallet_close();
bool pkrsrv_deposit_monero_wallet_create(char* wallet_name, char* password);
pkrsrv_string_t* pkrsrv_deposit_monero_get_main_address();
bool pkrsrv_deposit_monero_get_balance(uint64_t* balance, uint64_t* unlocked_balance);
bool pkrsrv_deposit_monero_get_address_balance(char* address, uint64_t* balance, uint64_t* unlocked_balance);
 
struct pkrsrv_deposit_monero_tx {
    PKRSRV_REF_COUNTEDIFY();
    ITEMIFY(pkrsrv_deposit_monero_tx_t*);
    pkrsrv_string_t* txid;
    pkrsrv_string_t* address;
    uint64_t amount;
    uint64_t fee;
    uint64_t unlock_time;
    uint64_t timestamp;
    uint64_t height;
    bool is_confirmed;
};
 
struct pkrsrv_deposit_monero_tx_list {
    PKRSRV_REF_COUNTEDIFY();
    LISTIFY(pkrsrv_deposit_monero_tx_t*);
};
 
struct pkrsrv_deposit_monero_tx_new_params {
    pkrsrv_string_t* txid;
    pkrsrv_string_t* address;
    uint64_t amount;
    uint64_t fee;
    uint64_t unlock_time;
    uint64_t timestamp;
    uint64_t height;
    bool is_confirmed;
};
typedef struct pkrsrv_deposit_monero_tx_new_params pkrsrv_deposit_monero_tx_new_params_t;
 
pkrsrv_deposit_monero_tx_t* pkrsrv_deposit_monero_tx_new(pkrsrv_deposit_monero_tx_new_params_t params);
void pkrsrv_deposit_monero_tx_free(pkrsrv_deposit_monero_tx_t* tx);
 
pkrsrv_deposit_monero_tx_list_t* pkrsrv_deposit_monero_tx_list_new();
void pkrsrv_deposit_monero_tx_list_free(pkrsrv_deposit_monero_tx_list_t* list);
void pkrsrv_deposit_monero_tx_list_add(pkrsrv_deposit_monero_tx_list_t* list, pkrsrv_deposit_monero_tx_t* tx);
void pkrsrv_deposit_monero_tx_list_remove(pkrsrv_deposit_monero_tx_list_t* list, pkrsrv_deposit_monero_tx_t* tx);
pkrsrv_deposit_monero_tx_t* pkrsrv_deposit_monero_tx_list_get_by_txid(pkrsrv_deposit_monero_tx_list_t* list, pkrsrv_string_t* txid);
 
uint64_t pkrsrv_deposit_monero_get_height();
pkrsrv_deposit_monero_tx_list_t* pkrsrv_deposit_monero_get_txs(int account_index, int address_index, int min_height);
 
struct pkrsrv_deposit_monero_deposit {
    PKRSRV_REF_COUNTEDIFY();
    ITEMIFY(pkrsrv_deposit_monero_deposit_t*);
    uint64_t id;
    pkrsrv_account_t* account;
    pkrsrv_string_t* txid;
    uint64_t timestamp;
    uint64_t amount;
    pkrsrv_string_t* to_address;
    pkrsrv_deposit_monero_deposit_status_t status;
};
 
typedef struct pkrsrv_deposit_monero_deposit_new_params {
    uint64_t id;
    pkrsrv_account_t* account;
    pkrsrv_string_t* txid;
    uint64_t timestamp;
    uint64_t amount;
    pkrsrv_string_t* to_address;
    pkrsrv_deposit_monero_deposit_status_t status;
} pkrsrv_deposit_monero_deposit_new_params_t;
pkrsrv_deposit_monero_deposit_t* pkrsrv_deposit_monero_deposit_new(pkrsrv_deposit_monero_deposit_new_params_t params);
void pkrsrv_deposit_monero_deposit_free(pkrsrv_deposit_monero_deposit_t* deposit);
pkrsrv_deposit_monero_deposit_t* pkrsrv_deposit_monero_deposit_getby_txid(PGconn* pg_conn, pkrsrv_string_t* p_txid);
 
struct pkrsrv_deposit_monero_deposit_list {
    PKRSRV_REF_COUNTEDIFY();
    LISTIFY(pkrsrv_deposit_monero_deposit_t*);
};
 
pkrsrv_deposit_monero_deposit_list_t* pkrsrv_deposit_monero_deposit_list_new();
void pkrsrv_deposit_monero_deposit_list_free(pkrsrv_deposit_monero_deposit_list_t* list);
void pkrsrv_deposit_monero_deposit_list_add(pkrsrv_deposit_monero_deposit_list_t* list, pkrsrv_deposit_monero_deposit_t* deposit);
void pkrsrv_deposit_monero_deposit_list_remove(pkrsrv_deposit_monero_deposit_list_t* list, pkrsrv_deposit_monero_deposit_t* deposit);
 
struct pkrsrv_deposit_monero_get_deposits_param {
    pkrsrv_account_t* account;
    pkrsrv_deposit_monero_deposit_status_t status;
    int min_height;
    int max_height;
    int offset;
    int limit;
};
typedef struct pkrsrv_deposit_monero_get_deposits_param pkrsrv_deposit_monero_get_deposits_params_t;
 
pkrsrv_deposit_monero_deposit_list_t* pkrsrv_deposit_monero_get_deposits(PGconn* pg_conn, pkrsrv_deposit_monero_get_deposits_params_t params);
 
struct pkrsrv_deposit_monero_deposit_create_params {
    pkrsrv_account_t* account;
    pkrsrv_string_t* txid;
    uint64_t timestamp;
    uint64_t amount;
    pkrsrv_string_t* to_address;
    pkrsrv_deposit_monero_deposit_status_t status;
};
typedef struct pkrsrv_deposit_monero_deposit_create_params pkrsrv_deposit_monero_deposit_create_params_t;
pkrsrv_deposit_monero_deposit_t* pkrsrv_deposit_monero_deposit_create(PGconn* pg_conn, pkrsrv_deposit_monero_deposit_create_params_t params);
 
bool pkrsrv_deposit_monero_deposit_update_status(PGconn* pg_conn, pkrsrv_deposit_monero_deposit_t* deposit, pkrsrv_deposit_monero_deposit_status_t status);