Skip to content

Commit 43d0c6f

Browse files
cryptochassiscryptochassis
authored
Merge pull request #562 from crypto-chassis/update-example
update examples
2 parents 2f91852 + f3106ca commit 43d0c6f

File tree

44 files changed

+158
-181
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

44 files changed

+158
-181
lines changed

‎README.md‎

Lines changed: 52 additions & 59 deletions
Large diffs are not rendered by default.

‎example/CMakeLists.txt‎

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -68,23 +68,23 @@ if(WIN32)
6868
endif()
6969
link_libraries(OpenSSL::Crypto OpenSSL::SSL ${ADDITIONAL_LINK_LIBRARIES})
7070
add_compile_options(-Wno-deprecated -Wno-nonnull -Wno-deprecated-declarations)
71-
add_subdirectory(src/market_data_simple_request)
72-
add_subdirectory(src/market_data_simple_subscription)
73-
add_subdirectory(src/market_data_advanced_request)
74-
add_subdirectory(src/market_data_advanced_subscription)
75-
add_subdirectory(src/generic_public_request)
76-
add_subdirectory(src/generic_private_request)
77-
add_subdirectory(src/execution_management_simple_request)
78-
add_subdirectory(src/execution_management_simple_subscription)
79-
add_subdirectory(src/execution_management_advanced_request)
80-
add_subdirectory(src/execution_management_advanced_subscription)
81-
add_subdirectory(src/fix_simple)
82-
add_subdirectory(src/fix_advanced)
83-
add_subdirectory(src/enable_library_logging)
84-
add_subdirectory(src/set_timer)
85-
add_subdirectory(src/heartbeat)
86-
add_subdirectory(src/override_exchange_url_at_runtime)
87-
add_subdirectory(src/test_order_latency)
88-
add_subdirectory(src/test_cpu_usage)
89-
add_subdirectory(src/use_multiple_sessions)
90-
add_subdirectory(src/reduce_build_time)
71+
add_subdirectory(market_data_simple_request)
72+
add_subdirectory(market_data_simple_subscription)
73+
add_subdirectory(market_data_advanced_request)
74+
add_subdirectory(market_data_advanced_subscription)
75+
add_subdirectory(generic_public_request)
76+
add_subdirectory(generic_private_request)
77+
add_subdirectory(execution_management_simple_request)
78+
add_subdirectory(execution_management_simple_subscription)
79+
add_subdirectory(execution_management_advanced_request)
80+
add_subdirectory(execution_management_advanced_subscription)
81+
add_subdirectory(fix_simple)
82+
add_subdirectory(fix_advanced)
83+
add_subdirectory(enable_library_logging)
84+
add_subdirectory(set_timer)
85+
add_subdirectory(heartbeat)
86+
add_subdirectory(override_exchange_url_at_runtime)
87+
add_subdirectory(test_order_latency)
88+
add_subdirectory(test_cpu_usage)
89+
add_subdirectory(use_multiple_sessions)
90+
add_subdirectory(reduce_build_time)

example/src/enable_library_logging/CMakeLists.txt renamed to example/enable_library_logging/CMakeLists.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,6 @@ set(NAME enable_library_logging)
22
project(${NAME})
33
add_compile_definitions(CCAPI_ENABLE_LOG_TRACE)
44
add_compile_definitions(CCAPI_ENABLE_SERVICE_MARKET_DATA)
5-
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_OKX)
5+
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BYBIT)
66
add_executable(${NAME} main.cpp)
77
add_dependencies(${NAME} boost rapidjson)

example/src/enable_library_logging/main.cpp renamed to example/enable_library_logging/main.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ using ::ccapi::Subscription;
2424

2525
int main(int argc, char** argv) {
2626
Session session;
27-
Subscription subscription("okx", "BTC-USDT", "MARKET_DEPTH");
27+
Subscription subscription("bybit", "BTCUSDT", "MARKET_DEPTH");
2828
session.subscribe(subscription);
2929
std::this_thread::sleep_for(std::chrono::seconds(10));
3030
session.stop();

example/src/execution_management_advanced_request/CMakeLists.txt renamed to example/execution_management_advanced_request/CMakeLists.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
set(NAME execution_management_advanced_request)
22
project(${NAME})
33
add_compile_definitions(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT)
4-
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_OKX)
4+
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BYBIT)
55
add_executable(${NAME} main.cpp)
66
add_dependencies(${NAME} boost rapidjson)

example/src/execution_management_advanced_request/main.cpp renamed to example/execution_management_advanced_request/main.cpp

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -19,23 +19,20 @@ using ::ccapi::SessionOptions;
1919
using ::ccapi::UtilSystem;
2020

2121
int main(int argc, char** argv) {
22-
if (UtilSystem::getEnvAsString("OKX_API_KEY").empty()) {
23-
std::cerr << "Please set environment variable OKX_API_KEY" << std::endl;
22+
if (UtilSystem::getEnvAsString("BYBIT_API_KEY").empty()) {
23+
std::cerr << "Please set environment variable BYBIT_API_KEY" << std::endl;
2424
return EXIT_FAILURE;
2525
}
26-
if (UtilSystem::getEnvAsString("OKX_API_SECRET").empty()) {
27-
std::cerr << "Please set environment variable OKX_API_SECRET" << std::endl;
28-
return EXIT_FAILURE;
29-
}
30-
if (UtilSystem::getEnvAsString("OKX_API_PASSPHRASE").empty()) {
31-
std::cerr << "Please set environment variable OKX_API_PASSPHRASE" << std::endl;
26+
if (UtilSystem::getEnvAsString("BYBIT_API_SECRET").empty()) {
27+
std::cerr << "Please set environment variable BYBIT_API_SECRET" << std::endl;
3228
return EXIT_FAILURE;
3329
}
30+
3431
SessionOptions sessionOptions;
3532
SessionConfigs sessionConfigs;
3633
MyEventHandler eventHandler;
3734
Session session(sessionOptions, sessionConfigs, &eventHandler);
38-
Request request(Request::Operation::CREATE_ORDER, "okx", "BTC-USDT");
35+
Request request(Request::Operation::CREATE_ORDER, "bybit", "BTCUSDT");
3936
request.appendParam({
4037
{"tdMode", "cross"},
4138
{"ccy", "USDT"},

example/src/execution_management_advanced_subscription/CMakeLists.txt renamed to example/execution_management_advanced_subscription/CMakeLists.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
set(NAME execution_management_advanced_subscription)
22
project(${NAME})
33
add_compile_definitions(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT)
4-
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_OKX)
4+
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BYBIT)
55
add_executable(${NAME} main.cpp)
66
add_dependencies(${NAME} boost rapidjson)

example/src/execution_management_advanced_subscription/main.cpp renamed to example/execution_management_advanced_subscription/main.cpp

Lines changed: 10 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ class MyEventHandler : public EventHandler {
1313
std::cout << "Received an event:\n" + event.toPrettyString(2, 2) << std::endl;
1414
if (!willSendRequest) {
1515
sessionPtr->setTimer("id", 1000, nullptr, [this, sessionPtr]() {
16-
Request request(Request::Operation::CREATE_ORDER, "okx", "BTC-USDT");
16+
Request request(Request::Operation::CREATE_ORDER, "bybit", "BTCUSDT");
1717
request.appendParam({
1818
{"SIDE", "BUY"},
1919
{"LIMIT_PRICE", "20000"},
@@ -43,25 +43,24 @@ using ::ccapi::Subscription;
4343
using ::ccapi::UtilSystem;
4444

4545
int main(int argc, char** argv) {
46-
if (UtilSystem::getEnvAsString("OKX_API_KEY").empty()) {
47-
std::cerr << "Please set environment variable OKX_API_KEY" << std::endl;
46+
if (UtilSystem::getEnvAsString("BYBIT_API_KEY").empty()) {
47+
std::cerr << "Please set environment variable BYBIT_API_KEY" << std::endl;
4848
return EXIT_FAILURE;
4949
}
50-
if (UtilSystem::getEnvAsString("OKX_API_SECRET").empty()) {
51-
std::cerr << "Please set environment variable OKX_API_SECRET" << std::endl;
52-
return EXIT_FAILURE;
53-
}
54-
if (UtilSystem::getEnvAsString("OKX_API_PASSPHRASE").empty()) {
55-
std::cerr << "Please set environment variable OKX_API_PASSPHRASE" << std::endl;
50+
if (UtilSystem::getEnvAsString("BYBIT_API_SECRET").empty()) {
51+
std::cerr << "Please set environment variable BYBIT_API_SECRET" << std::endl;
5652
return EXIT_FAILURE;
5753
}
54+
5855
SessionOptions sessionOptions;
5956
SessionConfigs sessionConfigs;
6057
std::string websocketOrderEntrySubscriptionCorrelationId("any");
6158
MyEventHandler eventHandler(websocketOrderEntrySubscriptionCorrelationId);
6259
Session session(sessionOptions, sessionConfigs, &eventHandler);
63-
Subscription subscription("okx", "", "ORDER_UPDATE", "", websocketOrderEntrySubscriptionCorrelationId);
64-
session.subscribe(subscription);
60+
Subscription subscription_1("bybit", "", "ORDER_UPDATE");
61+
Subscription subscription_2("bybit", "", "WEBSOCKET_ORDER_ENTRY", "", websocketOrderEntrySubscriptionCorrelationId);
62+
std::vector<ccapi::Subscription> subscriptions = {subscription_1, subscription_2};
63+
session.subscribe(subscriptions);
6564
std::this_thread::sleep_for(std::chrono::seconds(10));
6665
session.stop();
6766
std::cout << "Bye" << std::endl;

example/src/execution_management_simple_request/CMakeLists.txt renamed to example/execution_management_simple_request/CMakeLists.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
set(NAME execution_management_simple_request)
22
project(${NAME})
33
add_compile_definitions(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT)
4-
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_OKX)
4+
add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BYBIT)
55
add_executable(${NAME} main.cpp)
66
add_dependencies(${NAME} boost rapidjson)

example/src/execution_management_simple_request/main.cpp renamed to example/execution_management_simple_request/main.cpp

Lines changed: 11 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -20,18 +20,15 @@ using ::ccapi::toString;
2020
using ::ccapi::UtilSystem;
2121

2222
int main(int argc, char** argv) {
23-
if (UtilSystem::getEnvAsString("OKX_API_KEY").empty()) {
24-
std::cerr << "Please set environment variable OKX_API_KEY" << std::endl;
23+
if (UtilSystem::getEnvAsString("BYBIT_API_KEY").empty()) {
24+
std::cerr << "Please set environment variable BYBIT_API_KEY" << std::endl;
2525
return EXIT_FAILURE;
2626
}
27-
if (UtilSystem::getEnvAsString("OKX_API_SECRET").empty()) {
28-
std::cerr << "Please set environment variable OKX_API_SECRET" << std::endl;
29-
return EXIT_FAILURE;
30-
}
31-
if (UtilSystem::getEnvAsString("OKX_API_PASSPHRASE").empty()) {
32-
std::cerr << "Please set environment variable OKX_API_PASSPHRASE" << std::endl;
27+
if (UtilSystem::getEnvAsString("BYBIT_API_SECRET").empty()) {
28+
std::cerr << "Please set environment variable BYBIT_API_SECRET" << std::endl;
3329
return EXIT_FAILURE;
3430
}
31+
3532
std::vector<std::string> modeList = {
3633
"create_order", "cancel_order", "get_order", "get_open_orders", "cancel_open_orders", "get_account_balances",
3734
};
@@ -52,7 +49,7 @@ int main(int argc, char** argv) {
5249
session.stop();
5350
return EXIT_FAILURE;
5451
}
55-
Request request(Request::Operation::CREATE_ORDER, "okx", argv[2]);
52+
Request request(Request::Operation::CREATE_ORDER, "bybit", argv[2]);
5653
request.appendParam({
5754
{"SIDE", strcmp(argv[3], "buy") == 0 ? "BUY" : "SELL"},
5855
{"QUANTITY", argv[4]},
@@ -67,7 +64,7 @@ int main(int argc, char** argv) {
6764
session.stop();
6865
return EXIT_FAILURE;
6966
}
70-
Request request(Request::Operation::CANCEL_ORDER, "okx", argv[2]);
67+
Request request(Request::Operation::CANCEL_ORDER, "bybit", argv[2]);
7168
request.appendParam({
7269
{"ORDER_ID", argv[3]},
7370
});
@@ -80,7 +77,7 @@ int main(int argc, char** argv) {
8077
session.stop();
8178
return EXIT_FAILURE;
8279
}
83-
Request request(Request::Operation::GET_ORDER, "okx", argv[2]);
80+
Request request(Request::Operation::GET_ORDER, "bybit", argv[2]);
8481
request.appendParam({
8582
{"ORDER_ID", argv[3]},
8683
});
@@ -93,7 +90,7 @@ int main(int argc, char** argv) {
9390
session.stop();
9491
return EXIT_FAILURE;
9592
}
96-
Request request(Request::Operation::GET_OPEN_ORDERS, "okx", argv[2]);
93+
Request request(Request::Operation::GET_OPEN_ORDERS, "bybit", argv[2]);
9794
session.sendRequest(request);
9895
} else if (mode == "cancel_open_orders") {
9996
if (argc != 3) {
@@ -103,10 +100,10 @@ int main(int argc, char** argv) {
103100
session.stop();
104101
return EXIT_FAILURE;
105102
}
106-
Request request(Request::Operation::CANCEL_OPEN_ORDERS, "okx", argv[2]);
103+
Request request(Request::Operation::CANCEL_OPEN_ORDERS, "bybit", argv[2]);
107104
session.sendRequest(request);
108105
} else if (mode == "get_account_balances") {
109-
Request request(Request::Operation::GET_ACCOUNT_BALANCES, "okx");
106+
Request request(Request::Operation::GET_ACCOUNT_BALANCES, "bybit");
110107
session.sendRequest(request);
111108
}
112109
std::this_thread::sleep_for(std::chrono::seconds(10));

0 commit comments

Comments
 (0)