forked from f0cii/deribit-api
-
Notifications
You must be signed in to change notification settings - Fork 0
/
subscriptions.go
138 lines (136 loc) · 4.14 KB
/
subscriptions.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
package deribit
import (
jsoniter "github.com/json-iterator/go"
"github.com/alunir/deribit-api/models"
"log"
"strings"
)
func (c *Client) subscriptionsProcess(event *Event) {
if event.Channel == "announcements" {
var notification models.AnnouncementsNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "book") {
var notification models.OrderBookNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "deribit_price_index") {
var notification models.DeribitPriceIndexNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "deribit_price_ranking") {
var notification models.DeribitPriceRankingNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "estimated_expiration_price") {
var notification models.EstimatedExpirationPriceNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "markprice.options") {
var notification models.MarkpriceOptionsNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "perpetual") {
var notification models.PerpetualNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "quote") {
var notification models.QuoteNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "ticker") {
var notification models.TickerNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "trades") {
var notification models.TradesNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "user.changes") {
var notification models.UserChangesNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "user.orders") {
if string(event.Data)[0] == '{' {
var notification models.UserOrderNotification
var order models.Order
err := jsoniter.Unmarshal(event.Data, &order)
if err != nil {
log.Printf("%v", err)
return
}
notification = append(notification, order)
c.Emit(event.Channel, ¬ification)
} else {
var notification models.UserOrderNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
}
} else if strings.HasPrefix(event.Channel, "user.portfolio") {
var notification models.PortfolioNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else if strings.HasPrefix(event.Channel, "user.trades") {
var notification models.UserTradesNotification
err := jsoniter.Unmarshal(event.Data, ¬ification)
if err != nil {
log.Printf("%v", err)
return
}
c.Emit(event.Channel, ¬ification)
} else {
log.Printf("%v", string(event.Data))
}
}