ctl.h

Go to the documentation of this file.

/*
 *
 *    Copyright CAPLIN Systems Ltd 2000-2015
 *
 *
 *    $Author: andys $
 *    $DateTime: 2016/12/29 13:36:44 $
 *    $Change: 308038 $
 *    $Id: //CDev/V-7_0/trading/include/ctl.h#2 $
 *
 *
 */

#ifndef CTL_H
#define CTL_H

#ifndef CTL_EXPORT
#ifdef WIN32
#define CTL_EXPORT __declspec(dllimport)
#else
#define CTL_EXPORT extern
#endif
#endif

#ifdef HAVE_STREAMLINK
#define HAVE_CLIENT_API
#endif


#ifdef HAVE_DSDK
#define HAVE_SERVER_API
#define HAVE_CLIENT_API
#endif

#ifdef HAVE_TRANSFORMER
#define HAVE_CLIENT_API
#define HAVE_SERVER_API
#endif


#include <stdarg.h>
#include <sys/types.h>


typedef struct ctl_trade_s ctl_trade;
typedef struct ctl_tradeevent_s ctl_tradeevent;
typedef struct ctl_channel_s   ctl_channel;
typedef struct ctl_provider_s  ctl_provider;





#define FIELD_REQUESTID "RequestID"
#define FIELD_PROTOCOL  "TradingProtocol"
#define FIELD_MSGTYPE   "MsgType"

typedef enum {
    ctl_error_OK,                  
    ctl_error_FAILED_SOURCE_GUARD, 
    ctl_error_INVALID_TRANSITION,  
    ctl_error_UNKNOWN_CHANNEL,     
    ctl_error_UNKNOWN_TRADE,       
    ctl_error_INVALID_PARAMETERS,  
    ctl_error_MISSING_REQUIRED_FIELD, 
} ctl_error;

typedef struct {
    void (*on_event)(void *context, ctl_provider *provider, ctl_channel *channel, ctl_trade *trade, ctl_tradeevent *ev);

    void (*on_invalid_event)(void *context, ctl_provider *provider, ctl_channel *channel, ctl_trade *trade, ctl_tradeevent *ev, ctl_error reason);
} ctl_trade_listener;

typedef struct {
    void  (*trade_created)(void *context, ctl_provider *provider, ctl_channel *channel, ctl_trade *trade);
    void  (*trade_closed)(void *context, ctl_provider *provider, ctl_channel *channel, ctl_trade *trade);


    void (*channel_closed)(void *context, ctl_provider *provider, ctl_channel *channel);

} ctl_channel_listener;



#ifdef HAVE_STREAMLINK
#ifdef WIN32
#include <time.h>
#endif
#include "sl4c.h"
CTL_EXPORT ctl_provider    *ctl_create_sl_provider(streamlink *sl, int num_models, const char  * const *models);
#endif

#ifdef HAVE_CLIENT_API
CTL_EXPORT ctl_channel     *ctl_provider_create_channel(ctl_provider *provider, const char *subject, ctl_channel_listener *listener, void *context);
CTL_EXPORT ctl_trade       *ctl_channel_create_trade(ctl_provider *provider, ctl_channel *channel, const char *model);
CTL_EXPORT ctl_trade       *ctl_channel_create_trade_with_requestid(ctl_provider *provider, ctl_channel *channel, const char *model, const char *requestid);
#endif


#ifdef HAVE_SERVER_API
/* DataSource API */
typedef struct {
    void (*channel_created)(void *context, ctl_provider *provider, ctl_channel *channel);

    void (*channel_closed)(void *context, ctl_provider *provider, ctl_channel *channel);
} ctl_app_listener;

typedef void (*ctl_audit_log_cb)(void *ctx, ctl_provider *provider, const char *id, ctl_trade *trade, ctl_tradeevent *ev);
#endif

#ifdef HAVE_TRANSFORMER
CTL_EXPORT ctl_provider    *ctl_create_tf_server_provider(ctl_app_listener *listener, void *context, int num_models, const char * const *models, const char *namespacePattern);
CTL_EXPORT ctl_provider    *ctl_create_tf_client_provider(int num_models, const char * const *models);
CTL_EXPORT void             ctl_provider_set_use_generic_messages(ctl_provider *provider, int use_generic_messages);

#else

#ifdef HAVE_DSDK
#include "datasrc.h"
CTL_EXPORT ctl_provider    *ctl_create_ds_provider(ctl_app_listener *listener, void *context, int num_models, const char * const *models, const char *namespacePattern);
CTL_EXPORT ctl_provider    *ctl_create_ds_client_provider(int num_models, const char * const *models);
CTL_EXPORT void             ctl_provider_set_audit_dslog(ctl_provider *provider, ds_log_t *log);
CTL_EXPORT void             ctl_provider_set_audit_logger(ctl_provider *provider, ctl_audit_log_cb callback, void *ctx);
CTL_EXPORT void             ctl_provider_set_application_listener(ctl_provider *provider, ctl_app_listener *listener, void *context);
CTL_EXPORT void             ctl_provider_set_use_generic_messages(ctl_provider *provider, int use_generic_messages);
#endif

#endif


CTL_EXPORT void             ctl_provider_set_name(ctl_provider *provider, const char *name);
CTL_EXPORT void             ctl_provider_dealloc(ctl_provider *provider);
CTL_EXPORT void             ctl_channel_set_listener(ctl_provider *provider, ctl_channel *channel, ctl_channel_listener *listener, void *context);
CTL_EXPORT const char      *ctl_channel_get_username(ctl_provider *provider, ctl_channel *channel);
CTL_EXPORT const char      *ctl_channel_get_subject(ctl_provider *provider, ctl_channel *channel);
CTL_EXPORT void            *ctl_channel_get_user_pointer(ctl_provider *provider, ctl_channel *channel);
CTL_EXPORT void             ctl_channel_set_user_pointer(ctl_provider *provider, ctl_channel *channel, void *ptr);
CTL_EXPORT void             ctl_channel_close(ctl_provider *provider, ctl_channel *channel);


CTL_EXPORT void             ctl_trade_set_listener(ctl_provider *provider, ctl_channel *channel, ctl_trade *trade, ctl_trade_listener *listener, void *context);
CTL_EXPORT ctl_error        ctl_trade_process_event(ctl_provider *provider,  ctl_channel *channel, ctl_trade *trade, ctl_tradeevent *tradeevent); /* Deallocates tradeevent */
CTL_EXPORT const char      *ctl_trade_get_field(ctl_provider *provider, ctl_channel *channel, ctl_trade *trade, const char *fieldname);
CTL_EXPORT const char      *ctl_trade_get_protocol(ctl_provider *provider, ctl_channel *channel, ctl_trade *trade);
CTL_EXPORT const char      *ctl_trade_get_requestid(ctl_provider *provider, ctl_channel *channel, ctl_trade *trade);
CTL_EXPORT const char      *ctl_trade_get_state(ctl_provider *provider, ctl_channel *channel, ctl_trade *trade);
CTL_EXPORT void            *ctl_trade_get_user_pointer(ctl_provider *provider, ctl_channel *channel, ctl_trade *trade);
CTL_EXPORT void             ctl_trade_set_user_pointer(ctl_provider *provider, ctl_channel *channel, ctl_trade *trade, void *ptr);


CTL_EXPORT ctl_tradeevent  *ctl_trade_create_tradeevent(ctl_provider *provider, ctl_channel *channel, ctl_trade *trade, const char *type);
CTL_EXPORT void             ctl_tradeevent_add_field(ctl_tradeevent *ev, const char *name, const char *value);
CTL_EXPORT const char      *ctl_tradeevent_get_type(ctl_tradeevent *ev);
CTL_EXPORT const char      *ctl_tradeevent_get_field(ctl_tradeevent *ev, const char *name);
CTL_EXPORT char const     **ctl_tradeevent_get_fields(ctl_tradeevent *ev, int *num_ptr); // User to free returned ptr
CTL_EXPORT void             ctl_tradeevent_dealloc(ctl_tradeevent *ev);
CTL_EXPORT ctl_tradeevent  *ctl_tradeevent_clone(ctl_tradeevent *ev);

typedef enum {
    ctl_LOG_FINEST = 1,   
    ctl_LOG_FINER,        
    ctl_LOG_DEBUG,        
    ctl_LOG_INFO,         
    ctl_LOG_NOTIFY,       
    ctl_LOG_WARN,         
    ctl_LOG_ERROR,        
    ctl_LOG_CRITICAL,     
    ctl_LOG_CONFIG        
} ctl_loglevel;

typedef void (*ctl_log_cb)(void *ctx, ctl_loglevel level, const char *fmt, va_list ap);

CTL_EXPORT void             ctl_set_log_callback(ctl_provider *provider, ctl_log_cb callback, void *ctx);
CTL_EXPORT void             ctl_free(void *ptr);
CTL_EXPORT void             ctl_log(ctl_provider *provider, ctl_loglevel level, const char *fmt, ...);
CTL_EXPORT void             ctl_set_allocator(void *(*realloc_func)(void *ctx, void *orig, size_t size), void (*free_func)(void *ctx, void *), void *ctx);
CTL_EXPORT void            *ctl_malloc(size_t size);
CTL_EXPORT void            *ctl_realloc(void *orig, size_t size);
CTL_EXPORT void             ctl_free(void *);
CTL_EXPORT char            *ctl_strdup(const char *orig);
CTL_EXPORT void            *ctl_calloc(size_t nmemb, size_t size);
CTL_EXPORT const char      *ctl_loglevel_tostring(ctl_loglevel level);
CTL_EXPORT const char      *ctl_error_tostring(ctl_error error);
CTL_EXPORT char            *ctl_tradeevent_tostring(ctl_tradeevent *trade, char *buf, size_t buflen);
CTL_EXPORT char            *ctl_trade_tostring(ctl_trade *trade, char *buf, size_t buflen);
CTL_EXPORT char            *ctl_channel_tostring(ctl_channel *channel, char *buf, size_t buflen);


#endif