Skip to content

Commit

Permalink
HitBTC: Add subscription configuration
Browse files Browse the repository at this point in the history
  • Loading branch information
gbjk committed Sep 18, 2024
1 parent b4f94b4 commit 0e80320
Show file tree
Hide file tree
Showing 10 changed files with 215 additions and 119 deletions.
8 changes: 4 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -141,12 +141,12 @@ Binaries will be published once the codebase reaches a stable condition.

|User|Contribution Amount|
|--|--|
| [thrasher-](https://github.com/thrasher-) | 692 |
| [shazbert](https://github.com/shazbert) | 333 |
| [dependabot[bot]](https://github.com/apps/dependabot) | 293 |
| [thrasher-](https://github.com/thrasher-) | 696 |
| [shazbert](https://github.com/shazbert) | 338 |
| [dependabot[bot]](https://github.com/apps/dependabot) | 301 |
| [gloriousCode](https://github.com/gloriousCode) | 234 |
| [dependabot-preview[bot]](https://github.com/apps/dependabot-preview) | 88 |
| [gbjk](https://github.com/gbjk) | 80 |
| [gbjk](https://github.com/gbjk) | 82 |
| [xtda](https://github.com/xtda) | 47 |
| [lrascao](https://github.com/lrascao) | 27 |
| [Beadko](https://github.com/Beadko) | 17 |
Expand Down
22 changes: 17 additions & 5 deletions cmd/documentation/exchanges_templates/hitbtc.tmpl
Original file line number Diff line number Diff line change
Expand Up @@ -93,12 +93,24 @@ if err != nil {
}
```

### How to do Websocket public/private calls
### Subscriptions

```go
// Exchanges will be abstracted out in further updates and examples will be
// supplied then
```
Subscriptions are for [v2 api](https://hitbtc-com.github.io/hitbtc-api/#socket-api-reference)

All subscriptions are for spot.

Default Public Subscriptions:
- Ticker
- Orderbook
- Candles ( Interval: 30 minutes, History: 100 )
- All Trades ( History: 100 )

Default Authenticated Subscriptions:
- My Account events

Subscriptions are subject to enabled assets and pairs.

Configure Levels for number of history entries to return for applicable APIs.

### Please click GoDocs chevron above to view current GoDoc information for this package
{{template "contributions"}}
Expand Down
22 changes: 17 additions & 5 deletions exchanges/hitbtc/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -111,12 +111,24 @@ if err != nil {
}
```

### How to do Websocket public/private calls
### Subscriptions

```go
// Exchanges will be abstracted out in further updates and examples will be
// supplied then
```
Subscriptions are for [v2 api](https://hitbtc-com.github.io/hitbtc-api/#socket-api-reference)

All subscriptions are for spot.

Default Public Subscriptions:
- Ticker
- Orderbook
- Candles ( Interval: 30 minutes, History: 100 )
- All Trades ( History: 100 )

Default Authenticated Subscriptions:
- My Account events

Subscriptions are subject to enabled assets and pairs.

Configure Levels for number of history entries to return for applicable APIs.

### Please click GoDocs chevron above to view current GoDoc information for this package

Expand Down
38 changes: 37 additions & 1 deletion exchanges/hitbtc/hitbtc_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,9 @@ import (
"github.com/thrasher-corp/gocryptotrader/exchanges/order"
"github.com/thrasher-corp/gocryptotrader/exchanges/sharedtestvalues"
"github.com/thrasher-corp/gocryptotrader/exchanges/stream"
"github.com/thrasher-corp/gocryptotrader/exchanges/subscription"
testexch "github.com/thrasher-corp/gocryptotrader/internal/testing/exchange"
testsubs "github.com/thrasher-corp/gocryptotrader/internal/testing/subscriptions"
"github.com/thrasher-corp/gocryptotrader/portfolio/withdraw"
)

Expand Down Expand Up @@ -1007,7 +1009,7 @@ func Test_FormatExchangeKlineInterval(t *testing.T) {
test := testCases[x]
t.Run(test.name, func(t *testing.T) {
t.Parallel()
ret, err := h.FormatExchangeKlineInterval(test.interval)
ret, err := formatExchangeKlineInterval(test.interval)
if err != nil {
t.Fatal(err)
}
Expand Down Expand Up @@ -1090,3 +1092,37 @@ func TestGetCurrencyTradeURL(t *testing.T) {
assert.NotEmpty(t, resp)
}
}

func TestGenerateSubscriptions(t *testing.T) {
t.Parallel()

h := new(HitBTC)
require.NoError(t, testexch.Setup(h), "Test instance Setup must not error")

h.Websocket.SetCanUseAuthenticatedEndpoints(true)
require.True(t, h.Websocket.CanUseAuthenticatedEndpoints(), "CanUseAuthenticatedEndpoints must return true")
subs, err := h.generateSubscriptions()
require.NoError(t, err, "generateSubscriptions should not error")
exp := subscription.List{}
pairs, err := h.GetEnabledPairs(asset.Spot)
require.NoErrorf(t, err, "GetEnabledPairs must not error")
for _, s := range h.Features.Subscriptions {
for _, p := range pairs.Format(currency.PairFormat{Uppercase: true}) {
s = s.Clone()
s.Pairs = currency.Pairs{p}
n := subscriptionNames[s.Channel]
switch s.Channel {
case subscription.MyAccountChannel:
s.QualifiedChannel = `{"method":"` + n + `"}`
case subscription.CandlesChannel:
s.QualifiedChannel = `{"method":"` + n + `","params":{"symbol":"` + p.String() + `","period":"M30","limit":100}}`
case subscription.AllTradesChannel:
s.QualifiedChannel = `{"method":"` + n + `","params":{"symbol":"` + p.String() + `","limit":100}}`
default:
s.QualifiedChannel = `{"method":"` + n + `","params":{"symbol":"` + p.String() + `"}}`
}
exp = append(exp, s)
}
}
testsubs.EqualLists(t, exp, subs)
}
17 changes: 5 additions & 12 deletions exchanges/hitbtc/hitbtc_types.go
Original file line number Diff line number Diff line change
Expand Up @@ -294,24 +294,17 @@ type ResponseError struct {

// WsRequest defines a request obj for the JSON-RPC and gets a websocket response
type WsRequest struct {
Method string `json:"method"`
Params WsParams `json:"params,omitempty"`
ID int64 `json:"id"`
}

// WsNotification defines a notification obj for the JSON-RPC this does not get
// a websocket response
type WsNotification struct {
JSONRPCVersion string `json:"jsonrpc,omitempty"`
Method string `json:"method"`
Params WsParams `json:"params"`
JSONRPCVersion string `json:"jsonrpc,omitempty"`
Method string `json:"method"`
Params *WsParams `json:"params,omitempty"`
ID int64 `json:"id,omitempty"`
}

// WsParams are websocket params for a request
type WsParams struct {
Symbol string `json:"symbol,omitempty"`
Period string `json:"period,omitempty"`
Limit int64 `json:"limit,omitempty"`
Limit int `json:"limit,omitempty"`
Symbols []string `json:"symbols,omitempty"`
}

Expand Down
184 changes: 100 additions & 84 deletions exchanges/hitbtc/hitbtc_websocket.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,13 +8,16 @@ import (
"net/http"
"strconv"
"strings"
"text/template"
"time"

"github.com/Masterminds/sprig/v3"
"github.com/gorilla/websocket"
"github.com/thrasher-corp/gocryptotrader/common"
"github.com/thrasher-corp/gocryptotrader/common/crypto"
"github.com/thrasher-corp/gocryptotrader/currency"
"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/orderbook"
"github.com/thrasher-corp/gocryptotrader/exchanges/request"
Expand All @@ -31,6 +34,22 @@ const (
errAuthFailed = 1002
)

var subscriptionNames = map[string]string{
subscription.TickerChannel: "Ticker",
subscription.OrderbookChannel: "Orderbook",
subscription.CandlesChannel: "Candles",
subscription.AllTradesChannel: "Trades",
subscription.MyAccountChannel: "Reports",
}

var defaultSubscriptions = subscription.List{
{Enabled: true, Asset: asset.Spot, Channel: subscription.TickerChannel},
{Enabled: true, Asset: asset.Spot, Channel: subscription.OrderbookChannel},
{Enabled: true, Asset: asset.Spot, Channel: subscription.CandlesChannel, Interval: kline.ThirtyMin, Levels: 100},
{Enabled: true, Asset: asset.Spot, Channel: subscription.AllTradesChannel, Levels: 100},
{Enabled: true, Asset: asset.Spot, Channel: subscription.MyAccountChannel, Authenticated: true},
}

// WsConnect starts a new connection with the websocket API
func (h *HitBTC) WsConnect() error {
if !h.Websocket.IsEnabled() || !h.IsEnabled() {
Expand Down Expand Up @@ -465,104 +484,54 @@ func (h *HitBTC) WsProcessOrderbookUpdate(update *WsOrderbook) error {
})
}

// GenerateDefaultSubscriptions Adds default subscriptions to websocket to be handled by ManageSubscriptions()
func (h *HitBTC) GenerateDefaultSubscriptions() (subscription.List, error) {
var channels = []string{
"Ticker",
"Orderbook",
"Trades",
"Candles",
}

var subscriptions subscription.List
if h.Websocket.CanUseAuthenticatedEndpoints() {
subscriptions = append(subscriptions, &subscription.Subscription{Channel: "Reports"})
}
pairs, err := h.GetEnabledPairs(asset.Spot)
if err != nil {
return nil, err
}
pairFmt, err := h.GetPairFormat(asset.Spot, true)
if err != nil {
return nil, err
}
pairFmt.Delimiter = ""
pairs = pairs.Format(pairFmt)
for i := range channels {
for j := range pairs {
subscriptions = append(subscriptions, &subscription.Subscription{
Channel: channels[i],
Pairs: currency.Pairs{pairs[j]},
Asset: asset.Spot,
})
}
}
return subscriptions, nil
// generateSubscriptions returns a list of subscriptions from the configured subscriptions feature
func (h *HitBTC) generateSubscriptions() (subscription.List, error) {
return h.Features.Subscriptions.ExpandTemplates(h)
}

// Subscribe sends a websocket message to receive data from the channel
func (h *HitBTC) Subscribe(channelsToSubscribe subscription.List) error {
var errs error
for _, s := range channelsToSubscribe {
if len(s.Pairs) != 1 {
return subscription.ErrNotSinglePair
}
pair := s.Pairs[0]
// GetSubscriptionTemplate returns a subscription channel template
func (h *HitBTC) GetSubscriptionTemplate(_ *subscription.Subscription) (*template.Template, error) {
return template.New("master.tmpl").Funcs(sprig.FuncMap()).Funcs(template.FuncMap{
"subToReq": subToReq,
"isSymbolChannel": isSymbolChannel,
}).Parse(subTplText)
}

r := WsRequest{
Method: "subscribe" + s.Channel,
ID: h.Websocket.Conn.GenerateMessageID(false),
Params: WsParams{
Symbol: pair.String(),
},
}
switch s.Channel {
case "Trades":
r.Params.Limit = 100
case "Candles":
r.Params.Period = "M30"
r.Params.Limit = 100
}
const (
subscribeOp = "subscribe"
unsubscribeOp = "unsubscribe"
)

err := h.Websocket.Conn.SendJSONMessage(context.TODO(), request.Unset, r)
if err == nil {
err = h.Websocket.AddSuccessfulSubscriptions(s)
}
if err != nil {
errs = common.AppendError(errs, err)
}
}
return errs
// Subscribe sends a websocket message to receive data from the channel
func (h *HitBTC) Subscribe(subs subscription.List) error {
return h.ParallelChanOp(subs, func(subs subscription.List) error { return h.manageSubs(subscribeOp, subs) }, 1)
}

// Unsubscribe sends a websocket message to stop receiving data from the channel
func (h *HitBTC) Unsubscribe(subs subscription.List) error {
return h.ParallelChanOp(subs, func(subs subscription.List) error { return h.manageSubs(unsubscribeOp, subs) }, 1)
}

func (h *HitBTC) manageSubs(op string, subs subscription.List) error {
var errs error
subs, errs = subs.ExpandTemplates(h)
for _, s := range subs {
if len(s.Pairs) != 1 {
return subscription.ErrNotSinglePair
}
pair := s.Pairs[0]

r := WsNotification{
r := WsRequest{
JSONRPCVersion: rpcVersion,
Method: "unsubscribe" + s.Channel,
Params: WsParams{
Symbol: pair.String(),
},
ID: h.Websocket.Conn.GenerateMessageID(false),
}

switch s.Channel {
case "Trades":
r.Params.Limit = 100
case "Candles":
r.Params.Period = "M30"
r.Params.Limit = 100
if err := json.Unmarshal([]byte(s.QualifiedChannel), &r); err != nil {
errs = common.AppendError(errs, err)
continue
}

err := h.Websocket.Conn.SendJSONMessage(context.TODO(), request.Unset, r)
r.Method = op + r.Method
err := h.Websocket.Conn.SendJSONMessage(context.TODO(), request.Unset, r) // v2 api does not return an ID with errors, so we don't use ReturnResponse
if err == nil {
err = h.Websocket.RemoveSubscriptions(s)
if op == subscribeOp {
err = h.Websocket.AddSuccessfulSubscriptions(s)
} else {
err = h.Websocket.RemoveSubscriptions(s)
}
}
if err != nil {
errs = common.AppendError(errs, err)
Expand Down Expand Up @@ -838,3 +807,50 @@ func (h *HitBTC) wsGetTrades(c currency.Pair, limit int64, sort, by string) (*Ws
}
return &response, nil
}

// subToReq returns the subscription as a map to populate WsRequest
func subToReq(s *subscription.Subscription, maybePair ...currency.Pair) *WsRequest {
name, ok := subscriptionNames[s.Channel]
if !ok {
panic(fmt.Errorf("%w: %s", subscription.ErrNotSupported, s.Channel))
}
r := &WsRequest{
Method: name,
}
if len(maybePair) != 0 {
r.Params = &WsParams{
Symbol: maybePair[0].String(),
Limit: s.Levels,
}
if s.Interval != 0 {
var err error
if r.Params.Period, err = formatExchangeKlineInterval(s.Interval); err != nil {
panic(err)
}
}
} else if s.Levels != 0 {
r.Params = &WsParams{
Limit: s.Levels,
}
}
return r
}

// isSymbolChannel returns if the channel expects receive a symbol
func isSymbolChannel(s *subscription.Subscription) bool {
return s.Channel != subscription.MyAccountChannel
}

const subTplText = `
{{- if isSymbolChannel $.S }}
{{ range $asset, $pairs := $.AssetPairs }}
{{- range $p := $pairs -}}
{{- subToReq $.S $p | mustToJson }}
{{ $.PairSeparator }}
{{- end }}
{{ $.AssetSeparator }}
{{- end }}
{{- else }}
{{- subToReq $.S | mustToJson }}
{{- end }}
`
Loading

0 comments on commit 0e80320

Please sign in to comment.