MUL-1794: EOS support

.gitignore

@@ -12,4 +12,6 @@ cmd/state.json
 rpc.cert
 data-db
 
-.env
+.env
+
+.idea

btc/btc.go

@@ -126,7 +126,7 @@ func InitHandlers(dbConf *store.Conf, coinTypes []store.CoinType, nsqAddr string
 func initGrpcClient(url string) (pb.NodeCommuunicationsClient, error) {
 	conn, err := grpc.Dial(url, grpc.WithInsecure())
 	if err != nil {
-		log.Errorf("initGrpcClient: grpc.Dial: %s", err.Error())
+		//log.Errorf("initGrpcClient: grpc.Dial: %s", err.Error())
 		return nil, err
 	}
 

btc/handlers.go

@@ -80,7 +80,7 @@ func setGRPCHandlers(cli pb.NodeCommuunicationsClient, nsqProducer *nsq.Producer
 	go func() {
 		stream, err := cli.EventNewBlock(context.Background(), &pb.Empty{})
 		if err != nil {
-			log.Errorf("setGRPCHandlers: cli.EventNewBlock: %s", err.Error())
+			// log.Errorf("setGRPCHandlers: cli.EventNewBlock: %s", err.Error())
 			// return nil, err
 		}
 

client/bitfinex.go

@@ -47,7 +47,7 @@ func round(val float64) int {
 func (eChart *exchangeChart) newBitfinexAPI(log slf.StructuredLogger) (*BitfinexAPI, error) {
 	bitfinexAPI := &BitfinexAPI{rates: eChart.rates.exchangeBitfinex, log: log.WithField("api", "bitfinex")}
 
-	c, err := newWebSocketConn(bitfinexAPIAddr)
+	c, err := newWebSocketConn(bitfinexAPIAddr, log)
 	if err != nil {
 		eChart.log.Errorf("new Bitfinex connection: %s", err.Error())
 		c, err = reconnectWebSocketConn(gdaxAPIAddr, log)

client/exchange-api.go

@@ -1,8 +1,8 @@
 /*
-Copyright 2018 Idealnaya rabota LLC
-Licensed under Multy.io license.
-See LICENSE for details
-*/
+ * Copyright 2018 Idealnaya rabota LLC
+ * Licensed under Multy.io license.
+ * See LICENSE for details
+ */
 package client
 
 import (
@@ -46,7 +46,7 @@ type GDAXSocketEvent struct {
 func (eChart *exchangeChart) newGdaxAPI(log slf.StructuredLogger) (*GdaxAPI, error) {
 	gdaxAPI := &GdaxAPI{rates: eChart.rates.exchangeGdax, log: log.WithField("api", "gdax")}
 
-	c, err := newWebSocketConn(gdaxAPIAddr)
+	c, err := newWebSocketConn(gdaxAPIAddr, log)
 	if err != nil {
 		eChart.log.Errorf("new gdax connection: %s", err.Error())
 		c, err = reconnectWebSocketConn(gdaxAPIAddr, log)
@@ -139,7 +139,7 @@ type PoloniexSocketEvent struct {
 func (eChart *exchangeChart) newPoloniexAPI(log slf.StructuredLogger) (*PoloniexAPI, error) {
 	poloniexAPI := &PoloniexAPI{rates: eChart.rates.exchangePoloniex, log: log.WithField("api", "poloniex")}
 
-	c, err := newWebSocketConn(poloniexAPIAddr)
+	c, err := newWebSocketConn(poloniexAPIAddr, log)
 	if err != nil {
 		eChart.log.Errorf("new poloniex connection: %s", err.Error())
 		c, err = reconnectWebSocketConn(gdaxAPIAddr, log)