cosmopolite/clients/c/cosmopolite.h

#ifndef _COSMOPOLITE_H
#define _COSMOPOLITE_H

#include <jansson.h>

#include "promise.h"

#define COSMO_UUID_SIZE 37

typedef struct {
  void (*client_id_change)(void *, const char *);
  void (*connect)(void *);
  void (*disconnect)(void *);
  void (*login)(void *);
  void (*logout)(void *);
  void (*message)(const json_t *, void *);
} cosmo_callbacks;

typedef struct {
  int placeholder;
} cosmo_options;

typedef struct cosmo cosmo;

void cosmo_uuid(char *uuid);

cosmo *cosmo_create(const char *base_url, const char *client_id, const cosmo_callbacks *callbacks, const cosmo_options *options, void *passthrough);
void cosmo_shutdown(cosmo *instance);

void cosmo_get_profile(cosmo *instance, promise *promise_obj);
json_t *cosmo_current_profile(cosmo *instance);

json_t *cosmo_subject(const char *name, const char *readable_only_by, const char *writeable_only_by);
void cosmo_subscribe(cosmo *instance, json_t *subjects, const json_int_t messages, const json_int_t last_id, promise *promise_obj);
void cosmo_unsubscribe(cosmo *instance, json_t *subject, promise *promise_obj);
void cosmo_send_message(cosmo *instance, json_t *subject, json_t *message, promise *promise_obj);

json_t *cosmo_get_messages(cosmo *instance, json_t *subject);
json_t *cosmo_get_last_message(cosmo *instance, json_t *subject);

// TODO
json_t *cosmo_get_pins(cosmo *instance, json_t *subject, promise *promise_obj);
void cosmo_pin(cosmo *instance, json_t *subject, json_t *message, promise *promise_obj);
void cosmo_unpin(cosmo *instance, json_t *subject, json_t *message, promise *promise_obj);

#endif