db.h

Go to the documentation of this file.

 
 
#ifndef DB_H
#define DB_H
 
#include "errstatus.h"
#include "tchatator413/cfg.h"
#include "types.h"
 
typedef void db_t;
 
typedef struct {
    void *memory_owner_db;
    serial_t id;
    user_kind_t kind;
    char const *email, *last_name, *first_name, *display_name;
} user_t;
 
typedef struct {
    void *memory_owner_db;
    msg_t *msgs;
    size_t n_msgs;
} msg_list_t;
 
db_t *db_connect(cfg_t *cfg, int verbosity, char const *host, char const *port, char const *database, char const *username, char const *password);
 
void db_destroy(db_t *db);
 
void db_collect(void *memory_owner);
 
errstatus_t db_verify_user_api_key(db_t *db, cfg_t *cfg, user_identity_t *out_user, api_key_t api_key);
 
serial_t db_get_user_id_by_email(db_t *db, cfg_t *cfg, char const *email);
 
serial_t db_get_user_id_by_name(db_t *db, cfg_t *cfg, char const *name);
 
errstatus_t db_get_user(db_t *db, cfg_t *cfg, user_t *user);
 
errstatus_t db_get_msg(db_t *db, cfg_t *cfg, msg_t *msg, void **out_memory_owner_db);
 
errstatus_t db_check_password(db_t *db, cfg_t *cfg, serial_t user_id, char const *password);
 
int db_get_user_role(db_t *db, cfg_t *cfg, serial_t user_id);
 
int db_count_msg(db_t *db, cfg_t *cfg, serial_t sender_id, serial_t recipient_id);
 
serial_t db_send_msg(db_t *db, cfg_t *cfg, serial_t sender_id, serial_t recipient_id, char const *content);
 
msg_list_t db_get_inbox(db_t *db, cfg_t *cfg,
    int32_t limit,
    int32_t offset,
    serial_t recipient_id);
 
errstatus_t db_rm_msg(db_t *db, cfg_t *cfg, serial_t msg_id);
 
typedef errstatus_t (*fn_transaction_t)(db_t *db, cfg_t *cfg, void *ctx);
 
errstatus_t db_transaction(db_t *db, cfg_t *cfg, fn_transaction_t body, void *ctx);
 
#endif // DB_H