ssb.ebt.h

#pragma once
 
#include "ssb.h"
 
#include "quickjs.h"
 
typedef struct _tf_ssb_connection_t tf_ssb_connection_t;
 
typedef struct _tf_ssb_ebt_t tf_ssb_ebt_t;
 
typedef struct _tf_ssb_ebt_clock_entry_t
{
    char id[k_id_base64_len];
    int32_t value;
} tf_ssb_ebt_clock_entry_t;
 
typedef struct _tf_ssb_ebt_clock_t
{
    int count;
    tf_ssb_ebt_clock_entry_t entries[];
} tf_ssb_ebt_clock_t;
 
typedef void(tf_ssb_ebt_clock_callback_t)(const tf_ssb_ebt_clock_t* clock, int32_t request_number, void* user_data);
 
tf_ssb_ebt_t* tf_ssb_ebt_create(tf_ssb_connection_t* connection);
 
void tf_ssb_ebt_receive_clock(tf_ssb_ebt_t* ebt, JSContext* context, JSValue clock);
 
void tf_ssb_ebt_get_send_clock(tf_ssb_ebt_t* ebt, int32_t request_number, tf_ssb_ebt_clock_callback_t* callback, void* user_data);
 
tf_ssb_ebt_clock_t* tf_ssb_ebt_get_messages_to_send(tf_ssb_ebt_t* ebt);
 
void tf_ssb_ebt_set_messages_sent(tf_ssb_ebt_t* ebt, const char* id, int32_t sequence);
 
void tf_ssb_ebt_set_messages_received(tf_ssb_ebt_t* ebt, const char* id, int32_t sequence);
 
void tf_ssb_ebt_destroy(tf_ssb_ebt_t* ebt);
 
int tf_ssb_ebt_get_send_clock_pending(tf_ssb_ebt_t* ebt);
 
void tf_ssb_ebt_set_send_clock_pending(tf_ssb_ebt_t* ebt, int pending);
 
void tf_ssb_ebt_get_progress(tf_ssb_ebt_t* ebt, int* in_pending, int* in_total, int* out_pending, int* out_total);