ctp-rs 0.3.2+ctp.6.7.11.darwin.6.7.7

Safe & idiomatic Rust bindings for CTP; cross-platform (Windows/Linux/macOS) with built-in LocalCTP support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139

#include "ctp-rs/wrapper/include/MdApi.h"
#include "ctp-rs/wrapper/include/Converter.h"

#ifdef __APPLE__
// Both implemented in MdApiDarwinShim.cpp. CreateFtdcMdApi takes only three
// booleans on darwin (is_production_mode is silently dropped); GetApiVersion
// is a static class method that we resolve via dlsym at runtime since the
// dylib is loaded dynamically rather than linked.
extern "C" void* CtpRsDarwinCreateFtdcMdApi(const char*, bool, bool);
extern "C" const char* CtpRsDarwinGetMdApiVersion();
#endif

MdApi::MdApi(rust::Box<MdSpi> gateway, rust::String flow_path, bool is_using_udp, bool is_multicast, bool is_production_mode) {
    spi = new CMdSpi(std::move(gateway));
#ifdef __APPLE__
    (void)is_production_mode;
    api = static_cast<CThostFtdcMdApi*>(
        CtpRsDarwinCreateFtdcMdApi(flow_path.c_str(), is_using_udp, is_multicast));
#else
    api = CThostFtdcMdApi::CreateFtdcMdApi(flow_path.c_str(), is_using_udp, is_multicast, is_production_mode);
#endif
    api->RegisterSpi(spi);
}

MdApi::~MdApi() {
    if (api) {
        api->Release();
        api = nullptr;
    }
    delete spi;
    spi = nullptr;
}

std::unique_ptr<MdApi> CreateMdApi(rust::Box<MdSpi> gateway, rust::String flow_path, bool is_using_udp, bool is_multicast, bool is_production_mode) {
    return std::make_unique<MdApi>(std::move(gateway), flow_path, is_using_udp, is_multicast, is_production_mode);
}

rust::String MdApi::GetApiVersion() const {
#ifdef __APPLE__
    return CtpRsDarwinGetMdApiVersion();
#else
    return api->GetApiVersion(
    );
#endif
}

void MdApi::Init() const {
    return api->Init(
    );
}

int32_t MdApi::Join() const {
    return api->Join(
    );
}

rust::String MdApi::GetTradingDay() const {
    return api->GetTradingDay(
    );
}

void MdApi::RegisterFront(rust::String pszFrontAddress) const {
    return api->RegisterFront(
        const_cast<char *>(pszFrontAddress.c_str())
    );
}

void MdApi::RegisterNameServer(rust::String pszNsAddress) const {
    return api->RegisterNameServer(
        const_cast<char *>(pszNsAddress.c_str())
    );
}

void MdApi::RegisterFensUserInfo(FensUserInfoField pFensUserInfo) const {
    CThostFtdcFensUserInfoField req(Converter::FensUserInfoFieldToCpp(pFensUserInfo));
    return api->RegisterFensUserInfo(
        &req
    );
}

int32_t MdApi::SubscribeMarketData(rust::Vec<rust::String> ppInstrumentID) const {
    char **ppInstrumentID_raw = new char *[ppInstrumentID.size()];
    for (int i = 0; i < ppInstrumentID.size(); i++)
        ppInstrumentID_raw[i] = (char *)ppInstrumentID[i].c_str();
    int ret = api->SubscribeMarketData(ppInstrumentID_raw, ppInstrumentID.size());
    delete[] ppInstrumentID_raw;
    return ret;
}

int32_t MdApi::UnSubscribeMarketData(rust::Vec<rust::String> ppInstrumentID) const {
    char **ppInstrumentID_raw = new char *[ppInstrumentID.size()];
    for (int i = 0; i < ppInstrumentID.size(); i++)
        ppInstrumentID_raw[i] = (char *)ppInstrumentID[i].c_str();
    int ret = api->UnSubscribeMarketData(ppInstrumentID_raw, ppInstrumentID.size());
    delete[] ppInstrumentID_raw;
    return ret;
}

int32_t MdApi::SubscribeForQuoteRsp(rust::Vec<rust::String> ppInstrumentID) const {
    char **ppInstrumentID_raw = new char *[ppInstrumentID.size()];
    for (int i = 0; i < ppInstrumentID.size(); i++)
        ppInstrumentID_raw[i] = (char *)ppInstrumentID[i].c_str();
    int ret = api->SubscribeForQuoteRsp(ppInstrumentID_raw, ppInstrumentID.size());
    delete[] ppInstrumentID_raw;
    return ret;
}

int32_t MdApi::UnSubscribeForQuoteRsp(rust::Vec<rust::String> ppInstrumentID) const {
    char **ppInstrumentID_raw = new char *[ppInstrumentID.size()];
    for (int i = 0; i < ppInstrumentID.size(); i++)
        ppInstrumentID_raw[i] = (char *)ppInstrumentID[i].c_str();
    int ret = api->UnSubscribeForQuoteRsp(ppInstrumentID_raw, ppInstrumentID.size());
    delete[] ppInstrumentID_raw;
    return ret;
}

int32_t MdApi::ReqUserLogin(ReqUserLoginField pReqUserLoginField, int32_t nRequestID) const {
    CThostFtdcReqUserLoginField req(Converter::ReqUserLoginFieldToCpp(pReqUserLoginField));
    return api->ReqUserLogin(
        &req,
        nRequestID
    );
}

int32_t MdApi::ReqUserLogout(UserLogoutField pUserLogout, int32_t nRequestID) const {
    CThostFtdcUserLogoutField req(Converter::UserLogoutFieldToCpp(pUserLogout));
    return api->ReqUserLogout(
        &req,
        nRequestID
    );
}

int32_t MdApi::ReqQryMulticastInstrument(QryMulticastInstrumentField pQryMulticastInstrument, int32_t nRequestID) const {
    CThostFtdcQryMulticastInstrumentField req(Converter::QryMulticastInstrumentFieldToCpp(pQryMulticastInstrument));
    return api->ReqQryMulticastInstrument(
        &req,
        nRequestID
    );
}