proto.h

Go to the documentation of this file.

 
#pragma once
 
#include "proto/c/proto/xroad_proto_reader.h"
#include "proto/xroad_proto_builder.h"
#include <common/xroad_common_types.h>
#include <common/xroad_string.h>
#include <cache/xroad_objects_types.h>
#include <cache/xroad_objects.h>
#include <node/xroad_node.h>
#include <mdata/engine/mdata_proto.h>
 
#ifdef __cplusplus
extern "C"
{
#endif
 
typedef struct proto_s proto_t;
 
typedef struct
{
   char* data;
   size_t len;
} proto_encoded_data_t;
 
proto_t* proto_create();
 
void proto_destroy(proto_t* proto);
 
xroad_str_t proto_to_json(proto_t* p, const char* buf, size_t len);
 
proto_encoded_data_t proto_encode_request_failed(proto_t* proto, uint32_t req_id, xroad_str_t reason);
 
proto_encoded_data_t proto_encode_instr(proto_t* proto, uint32_t req_id, xroad_instr_t* instr, bool is_last);
 
proto_encoded_data_t proto_encode_order_rejected(
      proto_t* p, int64_t clord_id, xroad_rej_reason_t reason, xroad_str_t text);
 
proto_encoded_data_t proto_encode_cancel_rejected(
      proto_t* p, int64_t clord_id, xroad_rej_reason_t reason, xroad_str_t text);
 
proto_encoded_data_t proto_encode_replace_rejected(
      proto_t* p, int64_t clord_id, xroad_rej_reason_t reason, xroad_str_t text);
 
proto_encoded_data_t proto_encode_pong(proto_t* p, xroad_proto_Ping_table_t tbl);
 
proto_encoded_data_t proto_encode_order_accepted(proto_t* p, int64_t clord_id, xroad_accepted_t* msg);
 
proto_encoded_data_t proto_encode_order_canceled(proto_t* p, int64_t clord_id, xroad_canceled_t* msg);
 
proto_encoded_data_t proto_encode_trade(proto_t* p, xroad_order_rabbit_t* rorder, xroad_trade_t* msg);
 
proto_encoded_data_t proto_encode_trd_capt(proto_t* p, xroad_trd_capt_t* msg);
 
proto_encoded_data_t proto_encode_order_replaced(proto_t* p, xroad_order_rabbit_t* rorder, xroad_replaced_t* replaced);
 
proto_encoded_data_t proto_encode_acc_positions(proto_t* p, const xroad_acc_pos_t* acc_pos);
 
proto_encoded_data_t proto_encode_acc_pos_subs_result(
      proto_t* p, int32_t req_id, xroad_proto_SubsResult_enum_t subs_res);
 
proto_encoded_data_t proto_encode_ping(proto_t* p, int32_t req_id, uint64_t ts);
 
proto_encoded_data_t proto_encode_heartbeat(proto_t* p, uint64_t ts);
 
proto_encoded_data_t proto_encode_acc_balances(proto_t* p, const xroad_acc_balance_t* acc_bal);
 
proto_encoded_data_t proto_encode_acc_bal_subs_result(
      proto_t* p, int32_t req_id, xroad_proto_SubsResult_enum_t subs_res);
 
proto_encoded_data_t proto_encode_order_status(proto_t* p, int64_t clord_id, xroad_proto_OrdStatus_enum_t ord_status,
      double qty, double fill_qty, double avg_px, xroad_str_t reason);
 
proto_encoded_data_t proto_encode_prop_update_time(proto_t* p, int32_t req_id, const xroad_node_data_t* ndata,
      xroad_str_t field_name, xroad_time_t value);
 
proto_encoded_data_t proto_encode_prop_update_int(proto_t* p, int32_t req_id, const xroad_node_data_t* ndata,
      xroad_str_t field_name, int64_t value);
 
proto_encoded_data_t proto_encode_prop_update_str(proto_t* p, int32_t req_id, const xroad_node_data_t* ndata,
      xroad_str_t field_name, xroad_str_t value);
 
proto_encoded_data_t proto_encode_prop_update_double(proto_t* p, int32_t req_id, const xroad_node_data_t* ndata,
      xroad_str_t field_name, double value);
 
#define proto_encode_prop_update(p, req_id, node, field_name, value) _Generic((value), \
      int8_t:       proto_encode_prop_update_int,   \
      int16_t:      proto_encode_prop_update_int,   \
      int32_t:      proto_encode_prop_update_int,   \
      int64_t:      proto_encode_prop_update_int,   \
      xroad_str_t:  proto_encode_prop_update_str,   \
      double:       proto_encode_prop_update_double \
      )(p, req_id, node, field_name, value)
 
proto_encoded_data_t proto_encode_prop_error(proto_t* p, int32_t req_id, const xroad_node_data_t* ndata,
      xroad_str_t field_name, xroad_str_t reason);
 
proto_encoded_data_t proto_encode_action_response(proto_t* p, int32_t req_id, bool result, xroad_str_t reason);
 
proto_encoded_data_t proto_encode_md_subs_result(proto_t* p, uint32_t req_id, xroad_str_t alias,
      xroad_proto_MdType_enum_t type, xroad_proto_FieldId_enum_t field_id, xroad_str_t indicator,
      xroad_proto_SubsResult_enum_t result);
 
proto_encoded_data_t proto_encode_md_trade(proto_t* p, xroad_instr_t* instr, mdata_trade_t* trade, xroad_str_t source);
 
proto_encoded_data_t proto_encode_md_quote(proto_t* p, xroad_instr_t* instr, mdata_quote_t* quote, xroad_str_t source);
 
proto_encoded_data_t proto_encode_md_book(proto_t* p, xroad_instr_t* instr, mdata_book_20_t* book, xroad_str_t source);
 
proto_encoded_data_t proto_encode_md_field(proto_t* p, xroad_instr_t* instr, mdata_common_info_t* cinfo,
      xroad_proto_FieldId_enum_t field, xroad_str_t source);
 
proto_encoded_data_t proto_encode_md_indicator(proto_t* p, xroad_instr_t* instr, mdata_indicator_t* indicator,
      xroad_str_t type, xroad_str_t source);
 
proto_encoded_data_t proto_encode_sw_subs_result(
      proto_t* p, int32_t req_id, xroad_proto_SubsResult_enum_t subs_res);
 
proto_encoded_data_t proto_encode_sw_message(proto_t* p, mdata_speedway_t* speedway);
 
#ifdef __cplusplus
}
#endif