Fix: spread data parsing and re-subscribing to private channels

Author: aopoltorzhicky

websocket/data.go

@@ -157,7 +157,7 @@ type Spread struct {
 
 // UnmarshalJSON - unmarshal candle update
 func (s *Spread) UnmarshalJSON(data []byte) error {
-	raw := []interface{}{&s.Ask, &s.Bid, &s.Time, &s.AskVolume, &s.BidVolume, &s.Time}
+	raw := []interface{}{&s.Bid, &s.Ask, &s.Time, &s.AskVolume, &s.BidVolume, &s.Time}
 	return json.Unmarshal(data, &raw)
 }
 

websocket/kraken.go

@@ -124,12 +124,18 @@ func (k *Kraken) managerThread() {
 
 func (k *Kraken) resubscribe() error {
 	for _, sub := range k.subscriptions {
-		if err := k.send(SubscriptionRequest{
-			Event:        EventSubscribe,
-			Pairs:        []string{sub.Pair},
-			Subscription: sub.Subscription,
-		}); err != nil {
-			return err
+		switch sub.Subscription.Name {
+		// Private Channels
+		case ChanOwnTrades, ChanOpenOrders:
+			return k.subscribeToPrivate(sub.Subscription.Name)
+		default:
+			if err := k.send(SubscriptionRequest{
+				Event:        EventSubscribe,
+				Pairs:        []string{sub.Pair},
+				Subscription: sub.Subscription,
+			}); err != nil {
+				return err
+			}
 		}
 	}
 	return nil