stream.h

Go to the documentation of this file.

#ifndef JABBERWERX_STREAM_H
#define JABBERWERX_STREAM_H

#include <event2/bufferevent.h>
#include "util/htable.h"
#include "eventing.h"
#include "dom.h"


#define JW_STREAM_CONFIG_NAMESPACE "namespace"

#define JW_STREAM_CONFIG_DOMAIN "domain"

#define JW_STREAM_CONFIG_HOST "host"

#define JW_STREAM_CONFIG_PORT "port"

#define JW_STREAM_CONFIG_SELECTOR JW_WORKQ_CONFIG_SELECTOR

#define JW_STREAM_CONFIG_URI "uri"

#define JW_STREAM_CONFIG_LOG_LABEL "loglabel"

#define JW_STREAM_CONFIG_QUEUE_SIZE "queuesize"

#define JW_STREAM_CONFIG_KEEPALIVE_SECONDS "keepalive_seconds"

#define JW_STREAM_CONFIG_TLS_CERTIFICATE_CHAIN_FILENAME "stream_cert_chain_file"

#define JW_STREAM_CONFIG_TLS_PRIVATE_KEY_FILENAME "stream_private_key_file"

#define JW_STREAM_CONFIG_BUFFEREVENT "socket_bufferevent"

#define JW_STREAM_EVENT_OPENED "streamOpened"

#define JW_STREAM_EVENT_CLOSED "streamClosed"

#define JW_STREAM_EVENT_ELEMRECV "streamElementsReceived"

#define JW_STREAM_EVENT_ELEMSENT "streamElementsSent"

#define JW_STREAM_EVENT_DESTROYED "streamDestroyed"


typedef struct _jw_stream jw_stream;


#ifdef __cplusplus
extern "C"
{
#endif

JABBERWERX_API bool jw_stream_bosh_create(jw_workq   *workq,
                                          jw_stream **stream,
                                          jw_err    *err);

JABBERWERX_API bool jw_stream_socket_create(jw_workq   *workq,
                                            jw_stream **stream,
                                            jw_err    *err);

JABBERWERX_API void jw_stream_destroy(jw_stream *stream);

JABBERWERX_API bool jw_stream_open(jw_stream *stream,
                                   jw_htable *config,
                                   jw_err    *err);

JABBERWERX_API bool jw_stream_reopen(jw_stream *stream,
                                     jw_err    *err);

JABBERWERX_API bool jw_stream_send(jw_stream   *stream,
                                   jw_dom_node *dom,
                                   jw_err      *err);

JABBERWERX_API void jw_stream_close(jw_stream *stream,
                                    jw_errcode close_reason);

JABBERWERX_API const char* jw_stream_get_stream_id(jw_stream *stream);

JABBERWERX_API const char* jw_stream_get_namespace(jw_stream *stream);

JABBERWERX_API const char* jw_stream_get_domain(jw_stream *stream);

JABBERWERX_API struct event_base* jw_stream_get_selector(jw_stream *stream);

JABBERWERX_API jw_workq* jw_stream_get_workq(jw_stream *stream);

JABBERWERX_API jw_htable *jw_stream_get_config(jw_stream *stream);

JABBERWERX_API bool jw_stream_is_open(jw_stream *stream);

JABBERWERX_API jw_event *jw_stream_event(jw_stream *stream,
                                        const char *name);

JABBERWERX_API struct bufferevent *jw_stream_get_bufferevent(jw_stream *stream);

JABBERWERX_API bool jw_stream_set_bufferevent(jw_stream          *stream,
                                              struct bufferevent *bev,
                                              jw_err             *err);

JABBERWERX_API struct bufferevent *
    jw_stream_add_filter(jw_stream            *stream,
                         bufferevent_filter_cb input,
                         bufferevent_filter_cb output,
                         int                   options,
                         jw_data_free_func     free_filter_ctx,
                         void                 *ctx,
                         jw_err               *err);

#ifdef __cplusplus
}
#endif

#endif  /* JABBERWERX_STREAM_H */