Skip to content

Commit b2a86aa

Browse files
cryptochassiscryptochassis
committed
chore: revert examples
1 parent 1105eec commit b2a86aa

File tree

6 files changed

+57
-103
lines changed

6 files changed

+57
-103
lines changed

‎example/src/execution_management_simple_request/CMakeLists.txt

+1-3
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
11
set(NAME execution_management_simple_request)
22
project(${NAME})
3-
#add_compile_definitions(CCAPI_ENABLE_SERVICE_MARKET_DATA)
43
add_compile_definitions(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT)
5-
add_compile_definitions(CCAPI_ENABLE_LOG_TRACE)
6-
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BINANCE_USDS_FUTURES)
4+
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BINANCE)
75
add_executable(${NAME} main.cpp)
86
add_dependencies(${NAME} boost rapidjson)

‎example/src/execution_management_simple_request/main.cpp

+22-53
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,6 @@
11
#include "ccapi_cpp/ccapi_session.h"
22
namespace ccapi {
3-
class MyLogger final : public Logger {
4-
public:
5-
void logMessage(const std::string& severity, const std::string& threadId, const std::string& timeISO, const std::string& fileName,
6-
const std::string& lineNumber, const std::string& message) override {
7-
std::lock_guard<std::mutex> lock(m);
8-
std::cout << threadId << ": [" << timeISO << "] {" << fileName << ":" << lineNumber << "} " << severity << std::string(8, ' ') << message << std::endl;
9-
}
10-
11-
private:
12-
std::mutex m;
13-
};
14-
MyLogger myLogger;
15-
Logger* Logger::logger = &myLogger;
3+
Logger* Logger::logger = nullptr; // This line is needed.
164
class MyEventHandler : public EventHandler {
175
public:
186
bool processEvent(const Event& event, Session* session) override {
@@ -29,14 +17,14 @@ using ::ccapi::SessionOptions;
2917
using ::ccapi::toString;
3018
using ::ccapi::UtilSystem;
3119
int main(int argc, char** argv) {
32-
// if (UtilSystem::getEnvAsString("BINANCE_API_KEY").empty()) {
33-
// std::cerr << "Please set environment variable BINANCE_API_KEY" << std::endl;
34-
// return EXIT_FAILURE;
35-
// }
36-
// if (UtilSystem::getEnvAsString("BINANCE_API_SECRET").empty()) {
37-
// std::cerr << "Please set environment variable BINANCE_API_SECRET" << std::endl;
38-
// return EXIT_FAILURE;
39-
// }
20+
if (UtilSystem::getEnvAsString("BINANCE_API_KEY").empty()) {
21+
std::cerr << "Please set environment variable BINANCE_API_KEY" << std::endl;
22+
return EXIT_FAILURE;
23+
}
24+
if (UtilSystem::getEnvAsString("BINANCE_API_SECRET").empty()) {
25+
std::cerr << "Please set environment variable BINANCE_API_SECRET" << std::endl;
26+
return EXIT_FAILURE;
27+
}
4028
std::vector<std::string> modeList = {
4129
"create_order", "cancel_order", "get_order", "get_open_orders", "cancel_open_orders", "get_account_balances",
4230
};
@@ -57,7 +45,7 @@ int main(int argc, char** argv) {
5745
session.stop();
5846
return EXIT_FAILURE;
5947
}
60-
Request request(Request::Operation::CREATE_ORDER, "binance-usds-futures", argv[2]);
48+
Request request(Request::Operation::CREATE_ORDER, "binance", argv[2]);
6149
request.appendParam({
6250
{"SIDE", strcmp(argv[3], "buy") == 0 ? "BUY" : "SELL"},
6351
{"QUANTITY", argv[4]},
@@ -72,7 +60,7 @@ int main(int argc, char** argv) {
7260
session.stop();
7361
return EXIT_FAILURE;
7462
}
75-
Request request(Request::Operation::CANCEL_ORDER, "binance-usds-futures", argv[2]);
63+
Request request(Request::Operation::CANCEL_ORDER, "binance", argv[2]);
7664
request.appendParam({
7765
{"ORDER_ID", argv[3]},
7866
});
@@ -85,40 +73,21 @@ int main(int argc, char** argv) {
8573
session.stop();
8674
return EXIT_FAILURE;
8775
}
88-
Request request(Request::Operation::GET_ORDER, "binance-usds-futures", argv[2]);
76+
Request request(Request::Operation::GET_ORDER, "binance", argv[2]);
8977
request.appendParam({
9078
{"ORDER_ID", argv[3]},
9179
});
9280
session.sendRequest(request);
9381
} else if (mode == "get_open_orders") {
94-
// if (argc != 3) {
95-
// std::cerr << "Usage: " << argv[0] << " get_open_orders <symbol>\n"
96-
// << "Example:\n"
97-
// << " " << argv[0] << " get_open_orders BTCUSD" << std::endl;
98-
// session.stop();
99-
// return EXIT_FAILURE;
100-
// }
101-
std::string localIpAddress = argv[3];
102-
std::string baseUrl = argv[6];
103-
{
104-
Request request(Request::Operation::GET_OPEN_ORDERS, "binance-usds-futures", argv[2]);
105-
request.setLocalIpAddress(localIpAddress);
106-
request.setBaseUrl(baseUrl);
107-
session.sendRequest(request);
108-
}
109-
int numRequests = std::stoi(argv[4]);
110-
if (numRequests == 2) {
111-
int sleepSeconds = std::stoi(argv[5]);
112-
if (sleepSeconds > 0) {
113-
std::this_thread::sleep_for(std::chrono::seconds(sleepSeconds));
114-
}
115-
{
116-
Request request(Request::Operation::GET_OPEN_ORDERS, "binance-usds-futures", argv[2]);
117-
request.setLocalIpAddress(localIpAddress);
118-
request.setBaseUrl(baseUrl);
119-
session.sendRequest(request);
120-
}
82+
if (argc != 3) {
83+
std::cerr << "Usage: " << argv[0] << " get_open_orders <symbol>\n"
84+
<< "Example:\n"
85+
<< " " << argv[0] << " get_open_orders BTCUSD" << std::endl;
86+
session.stop();
87+
return EXIT_FAILURE;
12188
}
89+
Request request(Request::Operation::GET_OPEN_ORDERS, "binance", argv[2]);
90+
session.sendRequest(request);
12291
} else if (mode == "cancel_open_orders") {
12392
if (argc != 3) {
12493
std::cerr << "Usage: " << argv[0] << " cancel_open_orders <symbol>\n"
@@ -127,10 +96,10 @@ int main(int argc, char** argv) {
12796
session.stop();
12897
return EXIT_FAILURE;
12998
}
130-
Request request(Request::Operation::CANCEL_OPEN_ORDERS, "binance-usds-futures", argv[2]);
99+
Request request(Request::Operation::CANCEL_OPEN_ORDERS, "binance", argv[2]);
131100
session.sendRequest(request);
132101
} else if (mode == "get_account_balances") {
133-
Request request(Request::Operation::GET_ACCOUNT_BALANCES, "binance-usds-futures");
102+
Request request(Request::Operation::GET_ACCOUNT_BALANCES, "binance");
134103
session.sendRequest(request);
135104
}
136105
std::this_thread::sleep_for(std::chrono::seconds(10));

‎example/src/execution_management_simple_subscription/CMakeLists.txt

+1-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
set(NAME execution_management_simple_subscription)
22
project(${NAME})
33
add_compile_definitions(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT)
4-
add_compile_definitions(CCAPI_ENABLE_LOG_TRACE)
5-
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BINANCE_USDS_FUTURES)
4+
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_COINBASE)
65
add_executable(${NAME} main.cpp)
76
add_dependencies(${NAME} boost rapidjson)

‎example/src/execution_management_simple_subscription/main.cpp

+31-43
Original file line numberDiff line numberDiff line change
@@ -1,37 +1,25 @@
11
#include "ccapi_cpp/ccapi_session.h"
22
namespace ccapi {
3-
class MyLogger final : public Logger {
4-
public:
5-
void logMessage(const std::string& severity, const std::string& threadId, const std::string& timeISO, const std::string& fileName,
6-
const std::string& lineNumber, const std::string& message) override {
7-
std::lock_guard<std::mutex> lock(m);
8-
std::cout << threadId << ": [" << timeISO << "] {" << fileName << ":" << lineNumber << "} " << severity << std::string(8, ' ') << message << std::endl;
9-
}
10-
11-
private:
12-
std::mutex m;
13-
};
14-
MyLogger myLogger;
15-
Logger* Logger::logger = &myLogger;
3+
Logger* Logger::logger = nullptr; // This line is needed.
164
class MyEventHandler : public EventHandler {
175
public:
186
bool processEvent(const Event& event, Session* session) override {
19-
// if (event.getType() == Event::Type::SUBSCRIPTION_STATUS) {
20-
// std::cout << "Received an event of type SUBSCRIPTION_STATUS:\n" + event.toStringPretty(2, 2) << std::endl;
21-
// auto message = event.getMessageList().at(0);
22-
// if (message.getType() == Message::Type::SUBSCRIPTION_STARTED) {
23-
// Request request(Request::Operation::CREATE_ORDER, "coinbase", "BTC-USD");
24-
// request.appendParam({
25-
// {"SIDE", "BUY"},
26-
// {"LIMIT_PRICE", "20000"},
27-
// {"QUANTITY", "0.001"},
28-
// {"CLIENT_ORDER_ID", "6d4eb0fb-2229-469f-873e-557dd78ac11e"},
29-
// });
30-
// session->sendRequest(request);
31-
// }
32-
// } else if (event.getType() == Event::Type::SUBSCRIPTION_DATA) {
33-
// std::cout << "Received an event of type SUBSCRIPTION_DATA:\n" + event.toStringPretty(2, 2) << std::endl;
34-
// }
7+
if (event.getType() == Event::Type::SUBSCRIPTION_STATUS) {
8+
std::cout << "Received an event of type SUBSCRIPTION_STATUS:\n" + event.toStringPretty(2, 2) << std::endl;
9+
auto message = event.getMessageList().at(0);
10+
if (message.getType() == Message::Type::SUBSCRIPTION_STARTED) {
11+
Request request(Request::Operation::CREATE_ORDER, "coinbase", "BTC-USD");
12+
request.appendParam({
13+
{"SIDE", "BUY"},
14+
{"LIMIT_PRICE", "20000"},
15+
{"QUANTITY", "0.001"},
16+
{"CLIENT_ORDER_ID", "6d4eb0fb-2229-469f-873e-557dd78ac11e"},
17+
});
18+
session->sendRequest(request);
19+
}
20+
} else if (event.getType() == Event::Type::SUBSCRIPTION_DATA) {
21+
std::cout << "Received an event of type SUBSCRIPTION_DATA:\n" + event.toStringPretty(2, 2) << std::endl;
22+
}
3523
return true;
3624
}
3725
};
@@ -44,25 +32,25 @@ using ::ccapi::SessionOptions;
4432
using ::ccapi::Subscription;
4533
using ::ccapi::UtilSystem;
4634
int main(int argc, char** argv) {
47-
// if (UtilSystem::getEnvAsString("COINBASE_API_KEY").empty()) {
48-
// std::cerr << "Please set environment variable COINBASE_API_KEY" << std::endl;
49-
// return EXIT_FAILURE;
50-
// }
51-
// if (UtilSystem::getEnvAsString("COINBASE_API_SECRET").empty()) {
52-
// std::cerr << "Please set environment variable COINBASE_API_SECRET" << std::endl;
53-
// return EXIT_FAILURE;
54-
// }
55-
// if (UtilSystem::getEnvAsString("COINBASE_API_PASSPHRASE").empty()) {
56-
// std::cerr << "Please set environment variable COINBASE_API_PASSPHRASE" << std::endl;
57-
// return EXIT_FAILURE;
58-
// }
35+
if (UtilSystem::getEnvAsString("COINBASE_API_KEY").empty()) {
36+
std::cerr << "Please set environment variable COINBASE_API_KEY" << std::endl;
37+
return EXIT_FAILURE;
38+
}
39+
if (UtilSystem::getEnvAsString("COINBASE_API_SECRET").empty()) {
40+
std::cerr << "Please set environment variable COINBASE_API_SECRET" << std::endl;
41+
return EXIT_FAILURE;
42+
}
43+
if (UtilSystem::getEnvAsString("COINBASE_API_PASSPHRASE").empty()) {
44+
std::cerr << "Please set environment variable COINBASE_API_PASSPHRASE" << std::endl;
45+
return EXIT_FAILURE;
46+
}
5947
SessionOptions sessionOptions;
6048
SessionConfigs sessionConfigs;
6149
MyEventHandler eventHandler;
6250
Session session(sessionOptions, sessionConfigs, &eventHandler);
63-
Subscription subscription("binance-usds-futures", argv[1], argv[2]);
51+
Subscription subscription("coinbase", "BTC-USD", "ORDER_UPDATE");
6452
session.subscribe(subscription);
65-
std::this_thread::sleep_for(std::chrono::seconds(1000));
53+
std::this_thread::sleep_for(std::chrono::seconds(10));
6654
session.stop();
6755
std::cout << "Bye" << std::endl;
6856
return EXIT_SUCCESS;

‎example/src/market_data_simple_subscription/CMakeLists.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
set(NAME market_data_simple_subscription)
22
project(${NAME})
33
add_compile_definitions(CCAPI_ENABLE_SERVICE_MARKET_DATA)
4-
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_COINBASE)
4+
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_OKX)
55
add_executable(${NAME} main.cpp)
66
add_dependencies(${NAME} boost rapidjson)

‎example/src/market_data_simple_subscription/main.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ int main(int argc, char** argv) {
3030
SessionConfigs sessionConfigs;
3131
MyEventHandler eventHandler;
3232
Session session(sessionOptions, sessionConfigs, &eventHandler);
33-
Subscription subscription("coinbase", "BTC-USD", "MARKET_DEPTH");
33+
Subscription subscription("okx", "BTC-USDT", "MARKET_DEPTH");
3434
session.subscribe(subscription);
3535
std::this_thread::sleep_for(std::chrono::seconds(10));
3636
session.stop();

0 commit comments

Comments
 (0)