-
Notifications
You must be signed in to change notification settings - Fork 2
/
example_lastTrades.cpp
92 lines (60 loc) · 2.02 KB
/
example_lastTrades.cpp
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
#include <map>
#include <vector>
#include <string>
#include "bthmcpp.h"
#include "bthmcpp_websocket.h"
#include <json/json.h>
using namespace std;
map < long, map <string,double> > aggTradeCache;
#define API_KEY ""
#define SECRET_KEY ""
//---------------
void print_lastTradeCache() {
map < long, map<string,double> >::iterator it_i;
cout << "==================================" << endl;
for ( it_i = aggTradeCache.begin() ; it_i != aggTradeCache.end() ; it_i++ ) {
long aggTradeId = (*it_i).first;
map <string,double> aggtrade_obj = (*it_i).second;
cout << "AggtradeId:" << aggTradeId << ", ";
printf("p: %.08f, ", aggtrade_obj["p"] );
printf("q: %.08f " , aggtrade_obj["q"] );
cout << " " << endl;
}
}
//-----------
int ws_lastTrade_OnData( Json::Value &json_result ) {
int code = atoi(json_result["code"].asString().c_str());
if (code == 7)
{
long long ver = atol(json_result["data"]["ver"].asString().c_str());
aggTradeCache[ver]["p"] = atof( json_result["data"]["p"].asString().c_str() );
aggTradeCache[ver]["q"] = atof( json_result["data"]["v"].asString().c_str() );
print_lastTradeCache();
}
}
//---------------------------
/*
To compile, type
make example_lastTrades
*/
//--------------------------
int main() {
string api_key = API_KEY;
string secret_key = SECRET_KEY;
BthmCPP::init( api_key , secret_key );
Json::Value result;
// Last 100 Trades
BthmCPP::get_lastTrades( "RNT-USDT", result );
int code = atoi(result["code"].asString().c_str());
Json::Value data = result["data"];
for ( int i = 0 ; i < data.size() ; i++ ) {
long long ver = atol(data[i]["ver"].asString().c_str());
aggTradeCache[ver]["p"] = atof( data[i]["v"].asString().c_str() );
aggTradeCache[ver]["q"] = atof( data[i]["v"].asString().c_str() );
}
print_lastTradeCache();
BthmCPP_websocket::init( "{'cmd':'subscribe','args':['TRADE:RNT-USDT']}" );
BthmCPP_websocket::connect_endpoint( ws_lastTrade_OnData ,"/message/realtime" );
BthmCPP_websocket::enter_event_loop();
return 0;
}