/
deprecated.go
58 lines (47 loc) · 1.28 KB
/
deprecated.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
package operator
//TODO what do we do if we don't pick up the event
// case event := <-tradeEvents:
// fmt.Println("TRADE_SUCCESS_EVENT")
// txh := event.Raw.TxHash
// go func() {
// _, err := op.EthereumProvider.WaitMined(txh)
// if err != nil {
// logger.Error(err)
// }
// takerOrderHash := event.TakerOrderHashes[0]
// makerOrderHashes := []common.Hash{}
// for _, h := range event.MakerOrderHashes {
// makerOrderHashes = append(makerOrderHashes, common.BytesToHash(h[:]))
// }
// trades, err := op.TradeService.GetByTakerOrderHash(takerOrderHash)
// if err != nil {
// logger.Error(err)
// }
// to, err := op.OrderService.GetByHash(takerOrderHash)
// if err != nil {
// logger.Error(err)
// }
// makerOrders, err := op.OrderService.GetByHashes(makerOrderHashes)
// if err != nil {
// logger.Error(err)
// }
// matches := types.Matches{
// MakerOrders: makerOrders,
// TakerOrder: to,
// Trades: trades,
// }
// err = op.Broker.PublishTradeSuccessMessage(&matches)
// if err != nil {
// logger.Error(err)
// }
// }()
// tradeEvents, err := op.Exchange.ListenToTrades()
// if err != nil {
// logger.Error(err)
// return err
// }
// tradeEvents, err := op.Exchange.ListenToBatchTrades()
// if err != nil {
// logger.Error(err)
// return err
// }