Release

.github/workflows/test.yml

@@ -14,6 +14,10 @@ on:
       - '**/README.md'
       - '**.example'
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.event.pull_request.number || github.ref }}
+  cancel-in-progress: true
+
 env:
   CMAKE_VERSION: 3.17.5
   NINJA_VERSION: 1.9.0
@@ -53,7 +57,7 @@ jobs:
       #   }
 
     steps:
-    - uses: actions/checkout@v5
+    - uses: actions/checkout@v6
 
     - name: Download Ninja and CMake
       id: cmake_and_ninja

binding/go/CMakeLists.txt

@@ -121,6 +121,7 @@ foreach(ZLIB_LIBRARY IN LISTS ZLIB_LIBRARIES)
   get_filename_component(ZLIB_LIBRARY_DIR ${ZLIB_LIBRARY} DIRECTORY)
   list(APPEND CGO_LDFLAGS_LIST -L${ZLIB_LIBRARY_DIR} -lz)
 endforeach()
+list(REMOVE_DUPLICATES CGO_LDFLAGS_LIST)
 list(JOIN CGO_LDFLAGS_LIST " " CGO_LDFLAGS)
 message(STATUS "CGO_LDFLAGS: ${CGO_LDFLAGS}")
 file(APPEND ${COMPILER_OPTIONS_FILE_PATH}

binding/go/example/execution_management_simple_request/main.go

@@ -12,7 +12,7 @@ type MyEventHandler struct {
 }
 
 func (*MyEventHandler) ProcessEvent(event ccapi.Event, session ccapi.Session)  {
-	fmt.Printf("Received an event:\n%s\n", event.ToStringPretty(2, 2))
+	fmt.Printf("Received an event:\n%s\n", event.ToPrettyString(2, 2))
 	}
 
 func main() {

binding/go/example/execution_management_simple_subscription/main.go

@@ -13,7 +13,7 @@ type MyEventHandler struct {
 
 func (*MyEventHandler) ProcessEvent(event ccapi.Event, session ccapi.Session)  {
 	if event.GetType() == ccapi.EventType_SUBSCRIPTION_STATUS {
-		fmt.Printf("Received an event of type SUBSCRIPTION_STATUS:\n%s\n", event.ToStringPretty(2, 2))
+		fmt.Printf("Received an event of type SUBSCRIPTION_STATUS:\n%s\n", event.ToPrettyString(2, 2))
 		message := event.GetMessageList().Get(0)
 		if message.GetType() == ccapi.MessageType_SUBSCRIPTION_STARTED {
 			request := ccapi.NewRequest(ccapi.RequestOperation_CREATE_ORDER, "okx", "BTC-USDT")
@@ -27,7 +27,7 @@ func (*MyEventHandler) ProcessEvent(event ccapi.Event, session ccapi.Session)  {
 			session.SendRequest(request)
 		}
 	} else if event.GetType() == ccapi.EventType_SUBSCRIPTION_DATA {
-		fmt.Printf("Received an event of type SUBSCRIPTION_DATA:\n%s\n", event.ToStringPretty(2, 2))
+		fmt.Printf("Received an event of type SUBSCRIPTION_DATA:\n%s\n", event.ToPrettyString(2, 2))
 	}
 	}
 

binding/go/example/fix_simple/main.go

@@ -13,7 +13,7 @@ type MyEventHandler struct {
 
 func (*MyEventHandler) ProcessEvent(event ccapi.Event, session ccapi.Session)  {
 	if event.GetType() == ccapi.EventType_AUTHORIZATION_STATUS {
-		fmt.Printf("Received an event of type AUTHORIZATION_STATUS:\n%s\n", event.ToStringPretty(2, 2))
+		fmt.Printf("Received an event of type AUTHORIZATION_STATUS:\n%s\n", event.ToPrettyString(2, 2))
 		message := event.GetMessageList().Get(0)
 		if message.GetType() == ccapi.MessageType_AUTHORIZATION_SUCCESS {
 			request := ccapi.NewRequest(ccapi.RequestOperation_FIX, "coinbase", "", "same correlation id for subscription and request")
@@ -44,7 +44,7 @@ func (*MyEventHandler) ProcessEvent(event ccapi.Event, session ccapi.Session)  {
 			session.SendRequestByFix(request)
 		}
 	} else if event.GetType() == ccapi.EventType_FIX {
-		fmt.Printf("Received an event of type FIX:\n%s\n", event.ToStringPretty(2, 2))
+		fmt.Printf("Received an event of type FIX:\n%s\n", event.ToPrettyString(2, 2))
 	}
 	}
 

binding/go/example/market_data_simple_request/main.go

@@ -11,7 +11,7 @@ type MyEventHandler struct {
 }
 
 func (*MyEventHandler) ProcessEvent(event ccapi.Event, session ccapi.Session)  {
-	fmt.Printf("Received an event:\n%s\n", event.ToStringPretty(2, 2))
+	fmt.Printf("Received an event:\n%s\n", event.ToPrettyString(2, 2))
 	}
 
 func main() {

binding/go/example/market_data_simple_subscription/main.go

@@ -12,7 +12,7 @@ type MyEventHandler struct {
 
 func (*MyEventHandler) ProcessEvent(event ccapi.Event, session ccapi.Session)  {
 	if event.GetType() == ccapi.EventType_SUBSCRIPTION_STATUS {
-		fmt.Printf("Received an event of type SUBSCRIPTION_STATUS:\n%s\n", event.ToStringPretty(2, 2))
+		fmt.Printf("Received an event of type SUBSCRIPTION_STATUS:\n%s\n", event.ToPrettyString(2, 2))
 	} else if event.GetType() == ccapi.EventType_SUBSCRIPTION_DATA {
 		messageList := event.GetMessageList()
 		for i := 0; i < int(messageList.Size()); i++ {

binding/go/go.mod.in

@@ -1 +1,3 @@
 module cryptochassis.com
+
+go 1.17

binding/go/go.mod.in_2

@@ -1,5 +1,7 @@
 module main
 
+go 1.17
+
 require (
     cryptochassis.com/ccapi v1.0.0
 )

example/CMakeLists.txt

@@ -68,23 +68,23 @@ if(WIN32)
 endif()
 link_libraries(OpenSSL::Crypto OpenSSL::SSL ${ADDITIONAL_LINK_LIBRARIES})
 add_compile_options(-Wno-deprecated -Wno-nonnull -Wno-deprecated-declarations)
-add_subdirectory(src/market_data_simple_request)
-add_subdirectory(src/market_data_simple_subscription)
-add_subdirectory(src/market_data_advanced_request)
-add_subdirectory(src/market_data_advanced_subscription)
-add_subdirectory(src/generic_public_request)
-add_subdirectory(src/generic_private_request)
-add_subdirectory(src/execution_management_simple_request)
-add_subdirectory(src/execution_management_simple_subscription)
-add_subdirectory(src/execution_management_advanced_request)
-add_subdirectory(src/execution_management_advanced_subscription)
-add_subdirectory(src/fix_simple)
-add_subdirectory(src/fix_advanced)
-add_subdirectory(src/enable_library_logging)
-add_subdirectory(src/set_timer)
-add_subdirectory(src/heartbeat)
-add_subdirectory(src/override_exchange_url_at_runtime)
-add_subdirectory(src/test_order_latency)
-add_subdirectory(src/test_cpu_usage)
-add_subdirectory(src/use_multiple_sessions)
-add_subdirectory(src/reduce_build_time)
+add_subdirectory(market_data_simple_request)
+add_subdirectory(market_data_simple_subscription)
+add_subdirectory(market_data_advanced_request)
+add_subdirectory(market_data_advanced_subscription)
+add_subdirectory(generic_public_request)
+add_subdirectory(generic_private_request)
+add_subdirectory(execution_management_simple_request)
+add_subdirectory(execution_management_simple_subscription)
+add_subdirectory(execution_management_advanced_request)
+add_subdirectory(execution_management_advanced_subscription)
+add_subdirectory(fix_simple)
+add_subdirectory(fix_advanced)
+add_subdirectory(enable_library_logging)
+add_subdirectory(set_timer)
+add_subdirectory(heartbeat)
+add_subdirectory(override_exchange_url_at_runtime)
+add_subdirectory(test_order_latency)
+add_subdirectory(test_cpu_usage)
+add_subdirectory(use_multiple_sessions)
+add_subdirectory(reduce_build_time)

example/src/enable_library_logging/CMakeLists.txt → example/enable_library_logging/CMakeLists.txt

@@ -2,6 +2,6 @@ set(NAME enable_library_logging)
 project(${NAME})
 add_compile_definitions(CCAPI_ENABLE_LOG_TRACE)
 add_compile_definitions(CCAPI_ENABLE_SERVICE_MARKET_DATA)
-add_compile_definitions(CCAPI_ENABLE_EXCHANGE_OKX)
+add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BYBIT)
 add_executable(${NAME} main.cpp)
 add_dependencies(${NAME} boost rapidjson)

example/src/enable_library_logging/main.cpp → example/enable_library_logging/main.cpp

@@ -24,7 +24,7 @@ using ::ccapi::Subscription;
 
 int main(int argc, char** argv) {
   Session session;
-  Subscription subscription("okx", "BTC-USDT", "MARKET_DEPTH");
+  Subscription subscription("bybit", "BTCUSDT", "MARKET_DEPTH");
   session.subscribe(subscription);
   std::this_thread::sleep_for(std::chrono::seconds(10));
   session.stop();

example/src/execution_management_advanced_request/CMakeLists.txt → example/execution_management_advanced_request/CMakeLists.txt

@@ -1,6 +1,6 @@
 set(NAME execution_management_advanced_request)
 project(${NAME})
 add_compile_definitions(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT)
-add_compile_definitions(CCAPI_ENABLE_EXCHANGE_OKX)
+add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BYBIT)
 add_executable(${NAME} main.cpp)
 add_dependencies(${NAME} boost rapidjson)

example/src/execution_management_advanced_request/main.cpp → example/execution_management_advanced_request/main.cpp

@@ -19,23 +19,20 @@ using ::ccapi::SessionOptions;
 using ::ccapi::UtilSystem;
 
 int main(int argc, char** argv) {
-  if (UtilSystem::getEnvAsString("OKX_API_KEY").empty()) {
-    std::cerr << "Please set environment variable OKX_API_KEY" << std::endl;
+  if (UtilSystem::getEnvAsString("BYBIT_API_KEY").empty()) {
+    std::cerr << "Please set environment variable BYBIT_API_KEY" << std::endl;
     return EXIT_FAILURE;
   }
-  if (UtilSystem::getEnvAsString("OKX_API_SECRET").empty()) {
-    std::cerr << "Please set environment variable OKX_API_SECRET" << std::endl;
-    return EXIT_FAILURE;
-  }
-  if (UtilSystem::getEnvAsString("OKX_API_PASSPHRASE").empty()) {
-    std::cerr << "Please set environment variable OKX_API_PASSPHRASE" << std::endl;
+  if (UtilSystem::getEnvAsString("BYBIT_API_SECRET").empty()) {
+    std::cerr << "Please set environment variable BYBIT_API_SECRET" << std::endl;
     return EXIT_FAILURE;
   }
+
   SessionOptions sessionOptions;
   SessionConfigs sessionConfigs;
   MyEventHandler eventHandler;
   Session session(sessionOptions, sessionConfigs, &eventHandler);
-  Request request(Request::Operation::CREATE_ORDER, "okx", "BTC-USDT");
+  Request request(Request::Operation::CREATE_ORDER, "bybit", "BTCUSDT");
   request.appendParam({
       {"tdMode", "cross"},
       {"ccy", "USDT"},

example/src/execution_management_advanced_subscription/CMakeLists.txt → example/execution_management_advanced_subscription/CMakeLists.txt

@@ -1,6 +1,6 @@
 set(NAME execution_management_advanced_subscription)
 project(${NAME})
 add_compile_definitions(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT)
-add_compile_definitions(CCAPI_ENABLE_EXCHANGE_OKX)
+add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BYBIT)
 add_executable(${NAME} main.cpp)
 add_dependencies(${NAME} boost rapidjson)

example/src/execution_management_advanced_subscription/main.cpp → example/execution_management_advanced_subscription/main.cpp

@@ -13,7 +13,7 @@ class MyEventHandler : public EventHandler {
     std::cout << "Received an event:\n" + event.toPrettyString(2, 2) << std::endl;
     if (!willSendRequest) {
       sessionPtr->setTimer("id", 1000, nullptr, [this, sessionPtr]() {
-        Request request(Request::Operation::CREATE_ORDER, "okx", "BTC-USDT");
+        Request request(Request::Operation::CREATE_ORDER, "bybit", "BTCUSDT");
         request.appendParam({
             {"SIDE", "BUY"},
             {"LIMIT_PRICE", "20000"},
@@ -43,25 +43,24 @@ using ::ccapi::Subscription;
 using ::ccapi::UtilSystem;
 
 int main(int argc, char** argv) {
-  if (UtilSystem::getEnvAsString("OKX_API_KEY").empty()) {
-    std::cerr << "Please set environment variable OKX_API_KEY" << std::endl;
+  if (UtilSystem::getEnvAsString("BYBIT_API_KEY").empty()) {
+    std::cerr << "Please set environment variable BYBIT_API_KEY" << std::endl;
     return EXIT_FAILURE;
   }
-  if (UtilSystem::getEnvAsString("OKX_API_SECRET").empty()) {
-    std::cerr << "Please set environment variable OKX_API_SECRET" << std::endl;
-    return EXIT_FAILURE;
-  }
-  if (UtilSystem::getEnvAsString("OKX_API_PASSPHRASE").empty()) {
-    std::cerr << "Please set environment variable OKX_API_PASSPHRASE" << std::endl;
+  if (UtilSystem::getEnvAsString("BYBIT_API_SECRET").empty()) {
+    std::cerr << "Please set environment variable BYBIT_API_SECRET" << std::endl;
     return EXIT_FAILURE;
   }
+
   SessionOptions sessionOptions;
   SessionConfigs sessionConfigs;
   std::string websocketOrderEntrySubscriptionCorrelationId("any");
   MyEventHandler eventHandler(websocketOrderEntrySubscriptionCorrelationId);
   Session session(sessionOptions, sessionConfigs, &eventHandler);
-  Subscription subscription("okx", "", "ORDER_UPDATE", "", websocketOrderEntrySubscriptionCorrelationId);
-  session.subscribe(subscription);
+  Subscription subscription_1("bybit", "", "ORDER_UPDATE");
+  Subscription subscription_2("bybit", "", "WEBSOCKET_ORDER_ENTRY", "", websocketOrderEntrySubscriptionCorrelationId);
+  std::vector<ccapi::Subscription> subscriptions = {subscription_1, subscription_2};
+  session.subscribe(subscriptions);
   std::this_thread::sleep_for(std::chrono::seconds(10));
   session.stop();
   std::cout << "Bye" << std::endl;

example/src/execution_management_simple_request/CMakeLists.txt → example/execution_management_simple_request/CMakeLists.txt

@@ -1,6 +1,6 @@
 set(NAME execution_management_simple_request)
 project(${NAME})
 add_compile_definitions(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT)
-add_compile_definitions(CCAPI_ENABLE_EXCHANGE_OKX)
+add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BYBIT)
 add_executable(${NAME} main.cpp)
 add_dependencies(${NAME} boost rapidjson)

example/src/execution_management_simple_request/main.cpp → example/execution_management_simple_request/main.cpp

@@ -20,18 +20,15 @@ using ::ccapi::toString;
 using ::ccapi::UtilSystem;
 
 int main(int argc, char** argv) {
-  if (UtilSystem::getEnvAsString("OKX_API_KEY").empty()) {
-    std::cerr << "Please set environment variable OKX_API_KEY" << std::endl;
+  if (UtilSystem::getEnvAsString("BYBIT_API_KEY").empty()) {
+    std::cerr << "Please set environment variable BYBIT_API_KEY" << std::endl;
     return EXIT_FAILURE;
   }
-  if (UtilSystem::getEnvAsString("OKX_API_SECRET").empty()) {
-    std::cerr << "Please set environment variable OKX_API_SECRET" << std::endl;
-    return EXIT_FAILURE;
-  }
-  if (UtilSystem::getEnvAsString("OKX_API_PASSPHRASE").empty()) {
-    std::cerr << "Please set environment variable OKX_API_PASSPHRASE" << std::endl;
+  if (UtilSystem::getEnvAsString("BYBIT_API_SECRET").empty()) {
+    std::cerr << "Please set environment variable BYBIT_API_SECRET" << std::endl;
     return EXIT_FAILURE;
   }
+
   std::vector<std::string> modeList = {
       "create_order", "cancel_order", "get_order", "get_open_orders", "cancel_open_orders", "get_account_balances",
   };
@@ -52,7 +49,7 @@ int main(int argc, char** argv) {
       session.stop();
       return EXIT_FAILURE;
     }
-    Request request(Request::Operation::CREATE_ORDER, "okx", argv[2]);
+    Request request(Request::Operation::CREATE_ORDER, "bybit", argv[2]);
     request.appendParam({
         {"SIDE", strcmp(argv[3], "buy") == 0 ? "BUY" : "SELL"},
         {"QUANTITY", argv[4]},
@@ -67,7 +64,7 @@ int main(int argc, char** argv) {
       session.stop();
       return EXIT_FAILURE;
     }
-    Request request(Request::Operation::CANCEL_ORDER, "okx", argv[2]);
+    Request request(Request::Operation::CANCEL_ORDER, "bybit", argv[2]);
     request.appendParam({
         {"ORDER_ID", argv[3]},
     });
@@ -80,7 +77,7 @@ int main(int argc, char** argv) {
       session.stop();
       return EXIT_FAILURE;
     }
-    Request request(Request::Operation::GET_ORDER, "okx", argv[2]);
+    Request request(Request::Operation::GET_ORDER, "bybit", argv[2]);
     request.appendParam({
         {"ORDER_ID", argv[3]},
     });
@@ -93,7 +90,7 @@ int main(int argc, char** argv) {
       session.stop();
       return EXIT_FAILURE;
     }
-    Request request(Request::Operation::GET_OPEN_ORDERS, "okx", argv[2]);
+    Request request(Request::Operation::GET_OPEN_ORDERS, "bybit", argv[2]);
     session.sendRequest(request);
   } else if (mode == "cancel_open_orders") {
     if (argc != 3) {
@@ -103,10 +100,10 @@ int main(int argc, char** argv) {
       session.stop();
       return EXIT_FAILURE;
     }
-    Request request(Request::Operation::CANCEL_OPEN_ORDERS, "okx", argv[2]);
+    Request request(Request::Operation::CANCEL_OPEN_ORDERS, "bybit", argv[2]);
     session.sendRequest(request);
   } else if (mode == "get_account_balances") {
-    Request request(Request::Operation::GET_ACCOUNT_BALANCES, "okx");
+    Request request(Request::Operation::GET_ACCOUNT_BALANCES, "bybit");
     session.sendRequest(request);
   }
   std::this_thread::sleep_for(std::chrono::seconds(10));

example/src/execution_management_simple_subscription/CMakeLists.txt → example/execution_management_simple_subscription/CMakeLists.txt

@@ -1,6 +1,6 @@
 set(NAME execution_management_simple_subscription)
 project(${NAME})
 add_compile_definitions(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT)
-add_compile_definitions(CCAPI_ENABLE_EXCHANGE_OKX)
+add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BYBIT)
 add_executable(${NAME} main.cpp)
 add_dependencies(${NAME} boost rapidjson)

example/src/execution_management_simple_subscription/main.cpp → example/execution_management_simple_subscription/main.cpp

@@ -10,7 +10,7 @@ class MyEventHandler : public EventHandler {
     std::cout << "Received an event:\n" + event.toPrettyString(2, 2) << std::endl;
     if (!willSendRequest) {
       sessionPtr->setTimer("id", 1000, nullptr, [this, sessionPtr]() {
-        Request request(Request::Operation::CREATE_ORDER, "okx", "BTC-USDT");
+        Request request(Request::Operation::CREATE_ORDER, "bybit", "BTCUSDT");
         request.appendParam({
             {"SIDE", "BUY"},
             {"LIMIT_PRICE", "20000"},
@@ -39,23 +39,20 @@ using ::ccapi::Subscription;
 using ::ccapi::UtilSystem;
 
 int main(int argc, char** argv) {
-  if (UtilSystem::getEnvAsString("OKX_API_KEY").empty()) {
-    std::cerr << "Please set environment variable OKX_API_KEY" << std::endl;
+  if (UtilSystem::getEnvAsString("BYBIT_API_KEY").empty()) {
+    std::cerr << "Please set environment variable BYBIT_API_KEY" << std::endl;
     return EXIT_FAILURE;
   }
-  if (UtilSystem::getEnvAsString("OKX_API_SECRET").empty()) {
-    std::cerr << "Please set environment variable OKX_API_SECRET" << std::endl;
-    return EXIT_FAILURE;
-  }
-  if (UtilSystem::getEnvAsString("OKX_API_PASSPHRASE").empty()) {
-    std::cerr << "Please set environment variable OKX_API_PASSPHRASE" << std::endl;
+  if (UtilSystem::getEnvAsString("BYBIT_API_SECRET").empty()) {
+    std::cerr << "Please set environment variable BYBIT_API_SECRET" << std::endl;
     return EXIT_FAILURE;
   }
+
   SessionOptions sessionOptions;
   SessionConfigs sessionConfigs;
   MyEventHandler eventHandler;
   Session session(sessionOptions, sessionConfigs, &eventHandler);
-  Subscription subscription("okx", "BTC-USDT", "ORDER_UPDATE");
+  Subscription subscription("bybit", "BTCUSDT", "ORDER_UPDATE");
   session.subscribe(subscription);
   std::this_thread::sleep_for(std::chrono::seconds(10));
   session.stop();

example/src/generic_private_request/CMakeLists.txt → example/generic_private_request/CMakeLists.txt

@@ -1,6 +1,6 @@
 set(NAME generic_private_request)
 project(${NAME})
 add_compile_definitions(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT)
-add_compile_definitions(CCAPI_ENABLE_EXCHANGE_OKX)
+add_compile_definitions(CCAPI_ENABLE_EXCHANGE_BYBIT)
 add_executable(${NAME} main.cpp)
 add_dependencies(${NAME} boost rapidjson)