deribit: fix subscriptions

thrasher-corp · Jan 15, 2025 · dc72434 · dc72434
1 parent 457cba1
commit dc72434
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/exchanges/deribit/deribit_websocket.go b/exchanges/deribit/deribit_websocket.go
@@ -1176,9 +1176,14 @@ func (d *Deribit) handleSubscription(operation string, channels subscription.Lis
 			return fmt.Errorf("%v %v", d.Name, err)
 		}
 		if payloads[x].ID == response.ID && len(response.Result) == 0 {
-			log.Errorf(log.ExchangeSys, "subscription to channel %s was not successful", payloads[x].Params["channels"][0])
+			return fmt.Errorf("subscription to channel %s was not successful", payloads[x].Params["channels"][0])
 		}
 	}
+	if operation == "unsubscribe" {
+		d.Websocket.RemoveSubscriptions(d.Websocket.Conn, channels...)
+	} else {
+		d.Websocket.AddSubscriptions(d.Websocket.Conn, channels...)
+	}
 	return nil
 }