diff --git a/binding/go/example/execution_management_simple_request/main.go b/binding/go/example/execution_management_simple_request/main.go index 149d30e8..5814db69 100644 --- a/binding/go/example/execution_management_simple_request/main.go +++ b/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() { diff --git a/binding/go/example/execution_management_simple_subscription/main.go b/binding/go/example/execution_management_simple_subscription/main.go index dddc2cc4..6f6b79b6 100644 --- a/binding/go/example/execution_management_simple_subscription/main.go +++ b/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)) } } diff --git a/binding/go/example/fix_simple/main.go b/binding/go/example/fix_simple/main.go index 96571d76..36bc3cbd 100644 --- a/binding/go/example/fix_simple/main.go +++ b/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)) } } diff --git a/binding/go/example/market_data_simple_request/main.go b/binding/go/example/market_data_simple_request/main.go index 29b70d0d..a65b8efc 100644 --- a/binding/go/example/market_data_simple_request/main.go +++ b/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() { diff --git a/binding/go/example/market_data_simple_subscription/main.go b/binding/go/example/market_data_simple_subscription/main.go index c9d15478..16e0d174 100644 --- a/binding/go/example/market_data_simple_subscription/main.go +++ b/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++ { diff --git a/binding/go/go.mod.in b/binding/go/go.mod.in index d0379da6..f9589939 100644 --- a/binding/go/go.mod.in +++ b/binding/go/go.mod.in @@ -1 +1,3 @@ module cryptochassis.com + +go 1.17 diff --git a/binding/go/go.mod.in_2 b/binding/go/go.mod.in_2 index b49f2dfb..7dbca1bc 100644 --- a/binding/go/go.mod.in_2 +++ b/binding/go/go.mod.in_2 @@ -1,5 +1,7 @@ module main +go 1.17 + require ( cryptochassis.com/ccapi v1.0.0 ) diff --git a/include/ccapi_cpp/service/ccapi_market_data_service_bitfinex.h b/include/ccapi_cpp/service/ccapi_market_data_service_bitfinex.h index 2a0d0cbc..4692b25a 100644 --- a/include/ccapi_cpp/service/ccapi_market_data_service_bitfinex.h +++ b/include/ccapi_cpp/service/ccapi_market_data_service_bitfinex.h @@ -246,7 +246,7 @@ class MarketDataServiceBitfinex : public MarketDataService { } else { MarketDataMessage::TypeForDataPoint dataPoint; dataPoint.emplace(MarketDataMessage::DataFieldType::PRICE, UtilString::normalizeDecimalStringView(x[0].GetString())); - std::string_view count = std::string(x[1].GetString()); + std::string_view count = x[1].GetString(); std::string_view amount = UtilString::normalizeDecimalStringView(x[2].GetString()); if (count != "0") { if (amount.at(0) == '-') { diff --git a/include/ccapi_cpp/service/ccapi_service.h b/include/ccapi_cpp/service/ccapi_service.h index 6edbdd76..36f23411 100644 --- a/include/ccapi_cpp/service/ccapi_service.h +++ b/include/ccapi_cpp/service/ccapi_service.h @@ -1,6 +1,15 @@ #ifndef INCLUDE_CCAPI_CPP_SERVICE_CCAPI_SERVICE_H_ #define INCLUDE_CCAPI_CPP_SERVICE_CCAPI_SERVICE_H_ +#if (defined(CCAPI_ENABLE_SERVICE_MARKET_DATA) && \ + (defined(CCAPI_ENABLE_EXCHANGE_HUOBI) || defined(CCAPI_ENABLE_EXCHANGE_HUOBI_USDT_SWAP) || defined(CCAPI_ENABLE_EXCHANGE_HUOBI_COIN_SWAP))) || \ + (defined(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT) && \ + (defined(CCAPI_ENABLE_EXCHANGE_HUOBI_USDT_SWAP) || defined(CCAPI_ENABLE_EXCHANGE_HUOBI_COIN_SWAP) || defined(CCAPI_ENABLE_EXCHANGE_BITMART))) +#define CCAPI_REQUIRES_INFLATE_STREAM 1 +#else +#define CCAPI_REQUIRES_INFLATE_STREAM 0 +#endif + #ifndef CCAPI_HTTP_RESPONSE_PARSER_BODY_LIMIT #define CCAPI_HTTP_RESPONSE_PARSER_BODY_LIMIT (8 * 1024 * 1024) #endif @@ -27,12 +36,6 @@ #define CCAPI_WEBSOCKET_WRITE_BUFFER_SIZE (1 << 20) #endif -#define CCAPI_REQUIRES_INFLATE_STREAM \ - ((defined(CCAPI_ENABLE_SERVICE_MARKET_DATA) && \ - (defined(CCAPI_ENABLE_EXCHANGE_HUOBI) || defined(CCAPI_ENABLE_EXCHANGE_HUOBI_USDT_SWAP) || defined(CCAPI_ENABLE_EXCHANGE_HUOBI_COIN_SWAP))) || \ - (defined(CCAPI_ENABLE_SERVICE_EXECUTION_MANAGEMENT) && \ - (defined(CCAPI_ENABLE_EXCHANGE_HUOBI_USDT_SWAP) || defined(CCAPI_ENABLE_EXCHANGE_HUOBI_COIN_SWAP) || defined(CCAPI_ENABLE_EXCHANGE_BITMART)))) - #include #include "boost/asio/strand.hpp"