discord-internal.h

Go to the documentation of this file.

 
#ifndef DISCORD_INTERNAL_H
#define DISCORD_INTERNAL_H
 
#include <inttypes.h>
#include <pthread.h>
#include "uthash.h"
 
#include "json-scanf.h"
#include "json-actor.h"
#include "json-actor-boxed.h"
 
#include "logconf.h" /* struct logconf */
#include "user-agent.h"
#include "websockets.h"
#include "cee-utils.h"
#include "discord-voice-connections.h"
 
struct discord_adapter {
  struct user_agent *ua; 
  struct { /* RATELIMITING STRUCTURE */
    struct discord_bucket *buckets; 
    pthread_mutex_t lock; 
  } ratelimit;
  struct discord *p_client; 
};
 
void discord_adapter_init(struct discord_adapter *adapter, struct logconf *config, struct sized_buffer *token);
 
void discord_adapter_cleanup(struct discord_adapter *adapter);
 
ORCAcode discord_adapter_run(
  struct discord_adapter *adapter, 
  struct ua_resp_handle *resp_handle,
  struct sized_buffer *req_body,
  enum http_method http_method,
  char endpoint[], ...);
 
struct discord_bucket {
  char route[256]; 
  char hash[128]; 
  int busy; 
  int remaining; 
  int64_t reset_after_ms; 
  u64_unix_ms_t reset_tstamp; 
  u64_unix_ms_t update_tstamp; 
  
  pthread_mutex_t lock; 
  pthread_cond_t cond;
  UT_hash_handle hh; 
};
 
void discord_buckets_cleanup(struct discord_adapter *adapter);
 
void discord_bucket_try_cooldown(struct discord_bucket *bucket);
 
struct discord_bucket* discord_bucket_try_get(struct discord_adapter *adapter, const char route[]);
 
void discord_bucket_build(struct discord_adapter *adapter, struct discord_bucket *bucket, const char route[], struct ua_info *info);
 
struct discord_gateway_cmd_cbs {
  char *start;
  size_t size;
  message_cb cb;
};
 
struct discord_gateway {
  struct websockets *ws; 
  struct { /* RECONNECT STRUCTURE */
    bool enable; 
    int attempt; 
    int threshold; 
  } reconnect;
  bool is_resumable; 
  bool is_ready; 
  bool shutdown; 
 
  struct discord_gateway_identify *id; 
  char session_id[512]; 
  
 // https://discord.com/developers/docs/topics/gateway#payloads-gateway-payload-structure
  struct { /* GATEWAY PAYLOAD STRUCTURE */
    enum discord_gateway_opcodes opcode; 
    int seq_number;                      
    char event_name[64];                 
    struct sized_buffer event_data;      
  } payload;
 
  // Discord expects a proccess called heartbeating in order to keep the client-server connection alive
  // https://discord.com/developers/docs/topics/gateway#heartbeating
  struct { /* HEARTBEAT STRUCTURE */
    u64_unix_ms_t interval_ms; 
    u64_unix_ms_t tstamp; 
  } hbeat;
 
  struct discord_session session; 
 
  struct sized_buffer prefix; 
  struct discord_gateway_cmd_cbs on_default_cmd, *on_cmd; 
  size_t num_cmd; 
 
  struct { /* CALLBACKS STRUCTURE */
    idle_cb on_idle; 
    event_raw_cb on_event_raw; 
    idle_cb on_ready; 
    guild_role_cb on_guild_role_create; 
    guild_role_cb on_guild_role_update; 
    guild_role_delete_cb on_guild_role_delete; 
    guild_member_cb on_guild_member_add; 
    guild_member_remove_cb on_guild_member_remove; 
    guild_member_cb on_guild_member_update; 
    guild_ban_cb on_guild_ban_add; 
    guild_ban_cb on_guild_ban_remove; 
    channel_cb on_channel_create; 
    channel_cb on_channel_update; 
    channel_cb on_channel_delete; 
    channel_pins_update_cb on_channel_pins_update; 
    message_cb on_message_create; 
    sb_message_cb sb_on_message_create; 
    message_cb on_message_update; 
    sb_message_cb sb_on_message_update; 
    message_delete_cb on_message_delete; 
    message_delete_bulk_cb on_message_delete_bulk; 
    message_reaction_add_cb on_message_reaction_add; 
    message_reaction_remove_cb on_message_reaction_remove; 
    message_reaction_remove_all_cb on_message_reaction_remove_all; 
    message_reaction_remove_emoji_cb on_message_reaction_remove_emoji; 
    voice_state_update_cb on_voice_state_update; 
    voice_server_update_cb on_voice_server_update; 
  } cbs;
 
  enum discord_event_handling_mode (*blocking_event_handler)(void *cxt);
  
  int ping_ms; 
 
  pthread_mutex_t lock;
  
  struct discord_user *bot; 
  struct sized_buffer sb_bot; 
 
  struct discord *p_client; 
};
 
void discord_gateway_init(struct discord_gateway *gw, struct logconf *config, struct sized_buffer *token);
 
void discord_gateway_cleanup(struct discord_gateway *gw);
 
void discord_gateway_run(struct discord_gateway *gw);
 
void discord_gateway_shutdown(struct discord_gateway *gw);
 
void discord_gateway_reconnect(struct discord_gateway *gw, bool resume);
 
 
struct discord {
  struct sized_buffer token; 
  struct discord_adapter adapter; 
  struct discord_gateway gw; 
  
  struct logconf config; 
 
#define NUM_VCS 512
  struct discord_voice vcs[NUM_VCS];
  struct discord_voice_cbs voice_cbs;
 
  void *data; 
};
 
struct discord_event_cxt {
  char event_name[64];
  pthread_t tid; 
  struct sized_buffer data; 
  struct discord_gateway *p_gw; 
  enum discord_gateway_events event;
  void (*on_event)(
    struct discord_gateway *gw,
    struct sized_buffer *data);
  bool is_main_thread;
};
 
#endif // DISCORD_INTERNAL_H