diff --git a/backtester/btrpc/btrpc.proto b/backtester/btrpc/btrpc.proto index 5ad2ba1a..467ec4b9 100644 --- a/backtester/btrpc/btrpc.proto +++ b/backtester/btrpc/btrpc.proto @@ -250,48 +250,30 @@ message ClearAllRunsResponse { service BacktesterService { rpc ExecuteStrategyFromFile(ExecuteStrategyFromFileRequest) returns (ExecuteStrategyResponse) { - option (google.api.http) = { - post: "/v1/executestrategyfromfile" - }; + option (google.api.http) = {post: "/v1/executestrategyfromfile"}; } rpc ExecuteStrategyFromConfig(ExecuteStrategyFromConfigRequest) returns (ExecuteStrategyResponse) { - option (google.api.http) = { - post: "/v1/executestrategyfromconfig" - }; + option (google.api.http) = {post: "/v1/executestrategyfromconfig"}; } rpc ListAllRuns(ListAllRunsRequest) returns (ListAllRunsResponse) { - option (google.api.http) = { - get: "/v1/listallruns" - }; + option (google.api.http) = {get: "/v1/listallruns"}; } rpc StartRun(StartRunRequest) returns (StartRunResponse) { - option (google.api.http) = { - post: "/v1/startrun" - }; + option (google.api.http) = {post: "/v1/startrun"}; } rpc StartAllRuns(StartAllRunsRequest) returns (StartAllRunsResponse) { - option (google.api.http) = { - post: "/v1/startallruns" - }; + option (google.api.http) = {post: "/v1/startallruns"}; } rpc StopRun(StopRunRequest) returns (StopRunResponse) { - option (google.api.http) = { - post: "/v1/stoprun" - }; + option (google.api.http) = {post: "/v1/stoprun"}; } rpc StopAllRuns(StopAllRunsRequest) returns (StopAllRunsResponse) { - option (google.api.http) = { - post: "/v1/stopallruns" - }; + option (google.api.http) = {post: "/v1/stopallruns"}; } rpc ClearRun(ClearRunRequest) returns (ClearRunResponse) { - option (google.api.http) = { - delete: "/v1/clearrun" - }; + option (google.api.http) = {delete: "/v1/clearrun"}; } rpc ClearAllRuns(ClearAllRunsRequest) returns (ClearAllRunsResponse) { - option (google.api.http) = { - delete: "/v1/clearallruns" - }; + option (google.api.http) = {delete: "/v1/clearallruns"}; } } diff --git a/exchanges/bybit/bybit.go b/exchanges/bybit/bybit.go index 0458ccbd..7f36a211 100644 --- a/exchanges/bybit/bybit.go +++ b/exchanges/bybit/bybit.go @@ -299,24 +299,12 @@ func (by *Bybit) GetKlines(ctx context.Context, symbol, period string, limit int } kline.TradesCount = int64(tradesCount) - takerBaseVolume, ok := resp.Data[x][9].(string) - if !ok { + if kline.TakerBaseVolume, ok = resp.Data[x][9].(float64); !ok { return klines, fmt.Errorf("%v GetKlines: %w for TakerBaseVolume", by.Name, errTypeAssert) } - kline.TakerBaseVolume, err = strconv.ParseFloat(takerBaseVolume, 64) - if err != nil { - return klines, fmt.Errorf("%v GetKlines: %w for TakerBaseVolume", by.Name, errStrParsing) - } - - takerQuoteVolume, ok := resp.Data[x][10].(string) - if !ok { + if kline.TakerQuoteVolume, ok = resp.Data[x][10].(float64); !ok { return klines, fmt.Errorf("%v GetKlines: %w for TakerQuoteVolume", by.Name, errTypeAssert) } - kline.TakerQuoteVolume, err = strconv.ParseFloat(takerQuoteVolume, 64) - if err != nil { - return klines, fmt.Errorf("%v GetKlines: %w for TakerQuoteVolume", by.Name, errStrParsing) - } - klines[x] = kline } return klines, nil diff --git a/exchanges/bybit/bybit_test.go b/exchanges/bybit/bybit_test.go index aa3de2f0..4fe03ffe 100644 --- a/exchanges/bybit/bybit_test.go +++ b/exchanges/bybit/bybit_test.go @@ -17,6 +17,7 @@ import ( "github.com/thrasher-corp/gocryptotrader/exchanges/asset" "github.com/thrasher-corp/gocryptotrader/exchanges/kline" "github.com/thrasher-corp/gocryptotrader/exchanges/order" + "github.com/thrasher-corp/gocryptotrader/exchanges/request" "github.com/thrasher-corp/gocryptotrader/exchanges/sharedtestvalues" "github.com/thrasher-corp/gocryptotrader/portfolio/withdraw" ) @@ -48,6 +49,7 @@ func TestMain(m *testing.M) { exchCfg.API.Credentials.Key = apiKey exchCfg.API.Credentials.Secret = apiSecret b.Websocket = sharedtestvalues.NewTestWebsocket() + request.MaxRequestJobs = 100 err = b.Setup(exchCfg) if err != nil { log.Fatal(err) diff --git a/exchanges/bybit/bybit_types.go b/exchanges/bybit/bybit_types.go index 48a028ee..1d0604b8 100644 --- a/exchanges/bybit/bybit_types.go +++ b/exchanges/bybit/bybit_types.go @@ -149,6 +149,34 @@ func (b bybitTimeNanoSec) Time() time.Time { return time.Time(b) } +// bybitNumericalValue is a type used for when the API returns an empty or +// numerical string +type bybitNumericalValue float64 + +// UnmarshalJSON is custom type json unmarshaller for bybitNumericalValue +func (b *bybitNumericalValue) UnmarshalJSON(data []byte) error { + var num string + err := json.Unmarshal(data, &num) + if err != nil { + return err + } + + if num == "" { + return nil + } + + v, err := strconv.ParseFloat(num, 64) + if err != nil { + return err + } + + *b = bybitNumericalValue(v) + return nil +} + +// Float64 returns a float64 value for bybitNumericalValue +func (b *bybitNumericalValue) Float64() float64 { return float64(*b) } + // UnmarshalTo acts as interface to exchange API response type UnmarshalTo interface { GetError() error diff --git a/exchanges/bybit/bybit_wrapper.go b/exchanges/bybit/bybit_wrapper.go index afe5b572..85eb55e9 100644 --- a/exchanges/bybit/bybit_wrapper.go +++ b/exchanges/bybit/bybit_wrapper.go @@ -464,7 +464,7 @@ func (by *Bybit) UpdateTickers(ctx context.Context, assetType asset.Item) error Bid: tick[y].BidPrice, Ask: tick[y].AskPrice, Volume: tick[y].Volume24h, - Open: tick[y].OpenValue, + Open: tick[y].OpenValue.Float64(), Pair: cp, ExchangeName: by.Name, AssetType: assetType}) @@ -567,7 +567,7 @@ func (by *Bybit) UpdateTicker(ctx context.Context, p currency.Pair, assetType as Bid: tick[y].BidPrice, Ask: tick[y].AskPrice, Volume: tick[y].Volume24h, - Open: tick[y].OpenValue, + Open: tick[y].OpenValue.Float64(), Pair: cp, ExchangeName: by.Name, AssetType: assetType}) diff --git a/exchanges/bybit/futures_type.go b/exchanges/bybit/futures_type.go index 3f3292b7..2f365671 100644 --- a/exchanges/bybit/futures_type.go +++ b/exchanges/bybit/futures_type.go @@ -51,32 +51,32 @@ type FuturesCandleStickWithStringParam struct { // SymbolPriceTicker stores ticker price stats type SymbolPriceTicker struct { - Symbol string `json:"symbol"` - BidPrice float64 `json:"bid_price,string"` - AskPrice float64 `json:"ask_price,string"` - LastPrice float64 `json:"last_price,string"` - LastTickDirection string `json:"last_tick_direction"` - Price24hAgo float64 `json:"prev_price_24h,string"` - PricePcntChange24h float64 `json:"price_24h_pcnt,string"` - HighPrice24h float64 `json:"high_price_24h,string"` - LowPrice24h float64 `json:"low_price_24h,string"` - Price1hAgo float64 `json:"prev_price_1h,string"` - PricePcntChange1h float64 `json:"price_1h_pcnt,string"` - MarkPrice float64 `json:"mark_price,string"` - IndexPrice float64 `json:"index_price,string"` - OpenInterest float64 `json:"open_interest"` - OpenValue float64 `json:"open_value,string"` - TotalTurnover float64 `json:"total_turnover,string"` - Turnover24h float64 `json:"turnover_24h,string"` - TotalVolume float64 `json:"total_volume"` - Volume24h float64 `json:"volume_24h"` - FundingRate float64 `json:"funding_rate,string"` - PredictedFundingRate float64 `json:"predicted_funding_rate,string"` - NextFundingTime string `json:"next_funding_time"` - CountdownHour int64 `json:"countdown_hour"` - DeliveryFeeRate string `json:"delivery_fee_rate"` // type is string because it comes as empty string in API response sometime - PredictedDeliveryPrice string `json:"predicted_delivery_price"` // type is string because it comes as empty string in API response sometime - DeliveryTime string `json:"delivery_time"` + Symbol string `json:"symbol"` + BidPrice float64 `json:"bid_price,string"` + AskPrice float64 `json:"ask_price,string"` + LastPrice float64 `json:"last_price,string"` + LastTickDirection string `json:"last_tick_direction"` + Price24hAgo float64 `json:"prev_price_24h,string"` + PricePcntChange24h float64 `json:"price_24h_pcnt,string"` + HighPrice24h float64 `json:"high_price_24h,string"` + LowPrice24h float64 `json:"low_price_24h,string"` + Price1hAgo float64 `json:"prev_price_1h,string"` + PricePcntChange1h bybitNumericalValue `json:"price_1h_pcnt"` + MarkPrice float64 `json:"mark_price,string"` + IndexPrice float64 `json:"index_price,string"` + OpenInterest float64 `json:"open_interest"` + OpenValue bybitNumericalValue `json:"open_value"` + TotalTurnover bybitNumericalValue `json:"total_turnover"` + Turnover24h float64 `json:"turnover_24h,string"` + TotalVolume float64 `json:"total_volume"` + Volume24h float64 `json:"volume_24h"` + FundingRate float64 `json:"funding_rate,string"` + PredictedFundingRate bybitNumericalValue `json:"predicted_funding_rate"` + NextFundingTime string `json:"next_funding_time"` + CountdownHour int64 `json:"countdown_hour"` + DeliveryFeeRate bybitNumericalValue `json:"delivery_fee_rate"` + PredictedDeliveryPrice bybitNumericalValue `json:"predicted_delivery_price"` + DeliveryTime string `json:"delivery_time"` } // FuturesPublicTradesData stores recent public trades for futures @@ -149,10 +149,11 @@ type OpenInterestData struct { // BigDealData stores big deal data type BigDealData struct { - Symbol string `json:"symbol"` - Side string `json:"side"` - Time int64 `json:"timestamp"` - Value int64 `json:"value"` + ID int64 `json:"id"` + Symbol string `json:"symbol"` + Side string `json:"side"` + Time int64 `json:"timestamp"` + Value float64 `json:"value"` } // AccountRatioData stores user accounts long short ratio diff --git a/gctrpc/rpc.proto b/gctrpc/rpc.proto index ff39aa43..da5ec013 100644 --- a/gctrpc/rpc.proto +++ b/gctrpc/rpc.proto @@ -1355,45 +1355,31 @@ message GetOrderbookAmountByImpactResponse { service GoCryptoTraderService { rpc GetInfo(GetInfoRequest) returns (GetInfoResponse) { - option (google.api.http) = { - get: "/v1/getinfo" - }; + option (google.api.http) = {get: "/v1/getinfo"}; } rpc GetSubsystems(GetSubsystemsRequest) returns (GetSusbsytemsResponse) { - option (google.api.http) = { - get: "/v1/getsubsystems" - }; + option (google.api.http) = {get: "/v1/getsubsystems"}; } rpc EnableSubsystem(GenericSubsystemRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/enablesubsystem" - }; + option (google.api.http) = {get: "/v1/enablesubsystem"}; } rpc DisableSubsystem(GenericSubsystemRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/disablesubsystem" - }; + option (google.api.http) = {get: "/v1/disablesubsystem"}; } rpc GetRPCEndpoints(GetRPCEndpointsRequest) returns (GetRPCEndpointsResponse) { - option (google.api.http) = { - get: "/v1/getrpcendpoints" - }; + option (google.api.http) = {get: "/v1/getrpcendpoints"}; } rpc GetCommunicationRelayers(GetCommunicationRelayersRequest) returns (GetCommunicationRelayersResponse) { - option (google.api.http) = { - get: "/v1/getcommunicationrelayers" - }; + option (google.api.http) = {get: "/v1/getcommunicationrelayers"}; } rpc GetExchanges(GetExchangesRequest) returns (GetExchangesResponse) { - option (google.api.http) = { - get: "/v1/getexchanges" - }; + option (google.api.http) = {get: "/v1/getexchanges"}; } rpc DisableExchange(GenericExchangeNameRequest) returns (GenericResponse) { @@ -1404,21 +1390,15 @@ service GoCryptoTraderService { } rpc GetExchangeInfo(GenericExchangeNameRequest) returns (GetExchangeInfoResponse) { - option (google.api.http) = { - get: "/v1/getexchangeinfo" - }; + option (google.api.http) = {get: "/v1/getexchangeinfo"}; } rpc GetExchangeOTPCode(GenericExchangeNameRequest) returns (GetExchangeOTPResponse) { - option (google.api.http) = { - get: "/v1/getexchangeotp" - }; + option (google.api.http) = {get: "/v1/getexchangeotp"}; } rpc GetExchangeOTPCodes(GetExchangeOTPsRequest) returns (GetExchangeOTPsResponse) { - option (google.api.http) = { - get: "/v1/getexchangeotps" - }; + option (google.api.http) = {get: "/v1/getexchangeotps"}; } rpc EnableExchange(GenericExchangeNameRequest) returns (GenericResponse) { @@ -1436,9 +1416,7 @@ service GoCryptoTraderService { } rpc GetTickers(GetTickersRequest) returns (GetTickersResponse) { - option (google.api.http) = { - get: "/v1/gettickers" - }; + option (google.api.http) = {get: "/v1/gettickers"}; } rpc GetOrderbook(GetOrderbookRequest) returns (OrderbookResponse) { @@ -1449,45 +1427,31 @@ service GoCryptoTraderService { } rpc GetOrderbooks(GetOrderbooksRequest) returns (GetOrderbooksResponse) { - option (google.api.http) = { - get: "/v1/getorderbooks" - }; + option (google.api.http) = {get: "/v1/getorderbooks"}; } rpc GetAccountInfo(GetAccountInfoRequest) returns (GetAccountInfoResponse) { - option (google.api.http) = { - get: "/v1/getaccountinfo" - }; + option (google.api.http) = {get: "/v1/getaccountinfo"}; } rpc UpdateAccountInfo(GetAccountInfoRequest) returns (GetAccountInfoResponse) { - option (google.api.http) = { - get: "/v1/updateaccountinfo" - }; + option (google.api.http) = {get: "/v1/updateaccountinfo"}; } rpc GetAccountInfoStream(GetAccountInfoRequest) returns (stream GetAccountInfoResponse) { - option (google.api.http) = { - get: "/v1/getaccountinfostream" - }; + option (google.api.http) = {get: "/v1/getaccountinfostream"}; } rpc GetConfig(GetConfigRequest) returns (GetConfigResponse) { - option (google.api.http) = { - get: "/v1/getconfig" - }; + option (google.api.http) = {get: "/v1/getconfig"}; } rpc GetPortfolio(GetPortfolioRequest) returns (GetPortfolioResponse) { - option (google.api.http) = { - get: "/v1/getportfolio" - }; + option (google.api.http) = {get: "/v1/getportfolio"}; } rpc GetPortfolioSummary(GetPortfolioSummaryRequest) returns (GetPortfolioSummaryResponse) { - option (google.api.http) = { - get: "/v1/getportfoliosummary" - }; + option (google.api.http) = {get: "/v1/getportfoliosummary"}; } rpc AddPortfolioAddress(AddPortfolioAddressRequest) returns (GenericResponse) { @@ -1505,15 +1469,11 @@ service GoCryptoTraderService { } rpc GetForexProviders(GetForexProvidersRequest) returns (GetForexProvidersResponse) { - option (google.api.http) = { - get: "/v1/getforexproviders" - }; + option (google.api.http) = {get: "/v1/getforexproviders"}; } rpc GetForexRates(GetForexRatesRequest) returns (GetForexRatesResponse) { - option (google.api.http) = { - get: "/v1/getforexrates" - }; + option (google.api.http) = {get: "/v1/getforexrates"}; } rpc GetOrders(GetOrdersRequest) returns (GetOrdersResponse) { @@ -1573,9 +1533,7 @@ service GoCryptoTraderService { } rpc GetEvents(GetEventsRequest) returns (GetEventsResponse) { - option (google.api.http) = { - get: "/v1/getevents" - }; + option (google.api.http) = {get: "/v1/getevents"}; } rpc AddEvent(AddEventRequest) returns (AddEventResponse) { @@ -1649,9 +1607,7 @@ service GoCryptoTraderService { } rpc GetLoggerDetails(GetLoggerDetailsRequest) returns (GetLoggerDetailsResponse) { - option (google.api.http) = { - get: "/v1/getloggerdetails" - }; + option (google.api.http) = {get: "/v1/getloggerdetails"}; } rpc SetLoggerDetails(SetLoggerDetailsRequest) returns (GetLoggerDetailsResponse) { @@ -1676,39 +1632,27 @@ service GoCryptoTraderService { } rpc GetOrderbookStream(GetOrderbookStreamRequest) returns (stream OrderbookResponse) { - option (google.api.http) = { - get: "/v1/getorderbookstream" - }; + option (google.api.http) = {get: "/v1/getorderbookstream"}; } rpc GetExchangeOrderbookStream(GetExchangeOrderbookStreamRequest) returns (stream OrderbookResponse) { - option (google.api.http) = { - get: "/v1/getexchangeorderbookstream" - }; + option (google.api.http) = {get: "/v1/getexchangeorderbookstream"}; } rpc GetTickerStream(GetTickerStreamRequest) returns (stream TickerResponse) { - option (google.api.http) = { - get: "/v1/gettickerstream" - }; + option (google.api.http) = {get: "/v1/gettickerstream"}; } rpc GetExchangeTickerStream(GetExchangeTickerStreamRequest) returns (stream TickerResponse) { - option (google.api.http) = { - get: "/v1/getexchangetickerstream", - }; + option (google.api.http) = {get: "/v1/getexchangetickerstream"}; } rpc GetAuditEvent(GetAuditEventRequest) returns (GetAuditEventResponse) { - option (google.api.http) = { - get: "/v1/getauditevent", - }; + option (google.api.http) = {get: "/v1/getauditevent"}; } rpc GCTScriptExecute(GCTScriptExecuteRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/gctscript/execute", - }; + option (google.api.http) = {get: "/v1/gctscript/execute"}; } rpc GCTScriptUpload(GCTScriptUploadRequest) returns (GenericResponse) { @@ -1726,15 +1670,11 @@ service GoCryptoTraderService { } rpc GCTScriptStatus(GCTScriptStatusRequest) returns (GCTScriptStatusResponse) { - option (google.api.http) = { - get: "/v1/gctscript/status", - }; + option (google.api.http) = {get: "/v1/gctscript/status"}; } rpc GCTScriptQuery(GCTScriptQueryRequest) returns (GCTScriptQueryResponse) { - option (google.api.http) = { - get: "/v1/gctscript/query", - }; + option (google.api.http) = {get: "/v1/gctscript/query"}; } rpc GCTScriptStop(GCTScriptStopRequest) returns (GenericResponse) { @@ -1765,104 +1705,70 @@ service GoCryptoTraderService { } rpc GetHistoricCandles(GetHistoricCandlesRequest) returns (GetHistoricCandlesResponse) { - option (google.api.http) = { - get: "/v1/gethistoriccandles" - }; + option (google.api.http) = {get: "/v1/gethistoriccandles"}; } rpc SetExchangeAsset(SetExchangeAssetRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/setexchangeasset" - }; + option (google.api.http) = {get: "/v1/setexchangeasset"}; } rpc SetAllExchangePairs(SetExchangeAllPairsRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/setallexchangepairs" - }; + option (google.api.http) = {get: "/v1/setallexchangepairs"}; } rpc UpdateExchangeSupportedPairs(UpdateExchangeSupportedPairsRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/updateexchangesupportedpairs" - }; + option (google.api.http) = {get: "/v1/updateexchangesupportedpairs"}; } rpc GetExchangeAssets(GetExchangeAssetsRequest) returns (GetExchangeAssetsResponse) { - option (google.api.http) = { - get: "/v1/getexchangeassets" - }; + option (google.api.http) = {get: "/v1/getexchangeassets"}; } rpc WebsocketGetInfo(WebsocketGetInfoRequest) returns (WebsocketGetInfoResponse) { - option (google.api.http) = { - get: "/v1/websocketgetinfo" - }; + option (google.api.http) = {get: "/v1/websocketgetinfo"}; } rpc WebsocketSetEnabled(WebsocketSetEnabledRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/websocketsetenabled" - }; + option (google.api.http) = {get: "/v1/websocketsetenabled"}; } rpc WebsocketGetSubscriptions(WebsocketGetSubscriptionsRequest) returns (WebsocketGetSubscriptionsResponse) { - option (google.api.http) = { - get: "/v1/websocketgetsubscriptions" - }; + option (google.api.http) = {get: "/v1/websocketgetsubscriptions"}; } rpc WebsocketSetProxy(WebsocketSetProxyRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/websocketsetproxy" - }; + option (google.api.http) = {get: "/v1/websocketsetproxy"}; } rpc WebsocketSetURL(WebsocketSetURLRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/websocketseturl" - }; + option (google.api.http) = {get: "/v1/websocketseturl"}; } rpc GetRecentTrades(GetSavedTradesRequest) returns (SavedTradesResponse) { - option (google.api.http) = { - get: "/v1/getrecenttrades" - }; + option (google.api.http) = {get: "/v1/getrecenttrades"}; } rpc GetHistoricTrades(GetSavedTradesRequest) returns (stream SavedTradesResponse) { - option (google.api.http) = { - get: "/v1/gethistorictrades" - }; + option (google.api.http) = {get: "/v1/gethistorictrades"}; } rpc GetSavedTrades(GetSavedTradesRequest) returns (SavedTradesResponse) { - option (google.api.http) = { - get: "/v1/getsavedtrades" - }; + option (google.api.http) = {get: "/v1/getsavedtrades"}; } rpc ConvertTradesToCandles(ConvertTradesToCandlesRequest) returns (GetHistoricCandlesResponse) { - option (google.api.http) = { - get: "/v1/converttradestocandles" - }; + option (google.api.http) = {get: "/v1/converttradestocandles"}; } rpc FindMissingSavedCandleIntervals(FindMissingCandlePeriodsRequest) returns (FindMissingIntervalsResponse) { - option (google.api.http) = { - get: "/v1/findmissingsavedcandleintervals" - }; + option (google.api.http) = {get: "/v1/findmissingsavedcandleintervals"}; } rpc FindMissingSavedTradeIntervals(FindMissingTradePeriodsRequest) returns (FindMissingIntervalsResponse) { - option (google.api.http) = { - get: "/v1/findmissingsavedtradeintervals" - }; + option (google.api.http) = {get: "/v1/findmissingsavedtradeintervals"}; } rpc SetExchangeTradeProcessing(SetExchangeTradeProcessingRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/setexchangetradeprocessing" - }; + option (google.api.http) = {get: "/v1/setexchangetradeprocessing"}; } rpc UpsertDataHistoryJob(UpsertDataHistoryJobRequest) returns (UpsertDataHistoryJobResponse) { @@ -1873,24 +1779,16 @@ service GoCryptoTraderService { } rpc GetDataHistoryJobDetails(GetDataHistoryJobDetailsRequest) returns (DataHistoryJob) { - option (google.api.http) = { - get: "/v1/getdatahistoryjobdetails" - }; + option (google.api.http) = {get: "/v1/getdatahistoryjobdetails"}; } rpc GetActiveDataHistoryJobs(GetInfoRequest) returns (DataHistoryJobs) { - option (google.api.http) = { - get: "/v1/getactivedatahistoryjobs" - }; + option (google.api.http) = {get: "/v1/getactivedatahistoryjobs"}; } rpc GetDataHistoryJobsBetween(GetDataHistoryJobsBetweenRequest) returns (DataHistoryJobs) { - option (google.api.http) = { - get: "/v1/getdatahistoryjobsbetween" - }; + option (google.api.http) = {get: "/v1/getdatahistoryjobsbetween"}; } rpc GetDataHistoryJobSummary(GetDataHistoryJobDetailsRequest) returns (DataHistoryJob) { - option (google.api.http) = { - get: "/v1/getdatahistoryjobsummary" - }; + option (google.api.http) = {get: "/v1/getdatahistoryjobsummary"}; } rpc SetDataHistoryJobStatus(SetDataHistoryJobStatusRequest) returns (GenericResponse) { option (google.api.http) = { @@ -1911,89 +1809,55 @@ service GoCryptoTraderService { }; } rpc ModifyOrder(ModifyOrderRequest) returns (ModifyOrderResponse) { - option (google.api.http) = { - get: "/v1/modifyorder" - }; + option (google.api.http) = {get: "/v1/modifyorder"}; } rpc CurrencyStateGetAll(CurrencyStateGetAllRequest) returns (CurrencyStateResponse) { - option (google.api.http) = { - get: "/v1/currencystategetall" - }; + option (google.api.http) = {get: "/v1/currencystategetall"}; } rpc CurrencyStateTrading(CurrencyStateTradingRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/currencystatetrading" - }; + option (google.api.http) = {get: "/v1/currencystatetrading"}; } rpc CurrencyStateDeposit(CurrencyStateDepositRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/currencystatedeposit" - }; + option (google.api.http) = {get: "/v1/currencystatedeposit"}; } rpc CurrencyStateWithdraw(CurrencyStateWithdrawRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/currencystatewithdraw" - }; + option (google.api.http) = {get: "/v1/currencystatewithdraw"}; } rpc CurrencyStateTradingPair(CurrencyStateTradingPairRequest) returns (GenericResponse) { - option (google.api.http) = { - get: "/v1/currencystatetradingpair" - }; + option (google.api.http) = {get: "/v1/currencystatetradingpair"}; } rpc GetFuturesPositions(GetFuturesPositionsRequest) returns (GetFuturesPositionsResponse) { - option (google.api.http) = { - get: "/v1/getfuturespositions" - }; + option (google.api.http) = {get: "/v1/getfuturespositions"}; } rpc GetCollateral(GetCollateralRequest) returns (GetCollateralResponse) { - option (google.api.http) = { - get: "/v1/getcollateral" - }; + option (google.api.http) = {get: "/v1/getcollateral"}; } rpc Shutdown(ShutdownRequest) returns (ShutdownResponse) { - option (google.api.http) = { - get: "/v1/shutdown" - }; + option (google.api.http) = {get: "/v1/shutdown"}; } rpc GetTechnicalAnalysis(GetTechnicalAnalysisRequest) returns (GetTechnicalAnalysisResponse) { - option (google.api.http) = { - get: "/v1/gettechnicalanalysis" - }; + option (google.api.http) = {get: "/v1/gettechnicalanalysis"}; } rpc GetMarginRatesHistory(GetMarginRatesHistoryRequest) returns (GetMarginRatesHistoryResponse) { - option (google.api.http) = { - get: "/v1/getmarginrateshistory" - }; + option (google.api.http) = {get: "/v1/getmarginrateshistory"}; } rpc GetManagedPosition(GetManagedPositionRequest) returns (GetManagedPositionsResponse) { - option (google.api.http) = { - get: "/v1/getmanagedposition" - }; + option (google.api.http) = {get: "/v1/getmanagedposition"}; } rpc GetAllManagedPositions(GetAllManagedPositionsRequest) returns (GetManagedPositionsResponse) { - option (google.api.http) = { - get: "/v1/getallmanagedpositions" - }; + option (google.api.http) = {get: "/v1/getallmanagedpositions"}; } rpc GetFundingRates(GetFundingRatesRequest) returns (GetFundingRatesResponse) { - option (google.api.http) = { - get: "/v1/getfundingrates" - }; + option (google.api.http) = {get: "/v1/getfundingrates"}; } rpc GetOrderbookMovement(GetOrderbookMovementRequest) returns (GetOrderbookMovementResponse) { - option (google.api.http) = { - get: "/v1/getorderbookmovement" - }; + option (google.api.http) = {get: "/v1/getorderbookmovement"}; } rpc GetOrderbookAmountByNominal(GetOrderbookAmountByNominalRequest) returns (GetOrderbookAmountByNominalResponse) { - option (google.api.http) = { - get: "/v1/getorderbookamountbynominal" - }; + option (google.api.http) = {get: "/v1/getorderbookamountbynominal"}; } rpc GetOrderbookAmountByImpact(GetOrderbookAmountByImpactRequest) returns (GetOrderbookAmountByImpactResponse) { - option (google.api.http) = { - get: "/v1/getorderbookamountbyimpact" - }; + option (google.api.http) = {get: "/v1/getorderbookamountbyimpact"}; } }