feat(BUX-181): move SocketHandler to interfaces

BuxOrg · Sep 19, 2023 · e3b5539 · e3b5539
1 parent 496e498
commit e3b5539
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 19 deletions.
diff --git a/chainstate/interface.go b/chainstate/interface.go
@@ -119,3 +119,22 @@ type MonitorService interface {
 	Start(ctx context.Context, handler MonitorHandler, onStop func()) error
 	Stop(ctx context.Context) error
 }
+
+// SocketHandler is composite interface of centrifuge handlers interfaces
+type SocketHandler interface {
+	OnConnect(*centrifuge.Client, centrifuge.ConnectEvent)
+	OnDisconnect(*centrifuge.Client, centrifuge.DisconnectEvent)
+	OnError(*centrifuge.Client, centrifuge.ErrorEvent)
+	OnJoin(*centrifuge.Subscription, centrifuge.JoinEvent)
+	OnLeave(*centrifuge.Subscription, centrifuge.LeaveEvent)
+	OnMessage(*centrifuge.Client, centrifuge.MessageEvent)
+	OnPublish(*centrifuge.Subscription, centrifuge.PublishEvent)
+	OnServerJoin(*centrifuge.Client, centrifuge.ServerJoinEvent)
+	OnServerLeave(*centrifuge.Client, centrifuge.ServerLeaveEvent)
+	OnServerPublish(*centrifuge.Client, centrifuge.ServerPublishEvent)
+	OnServerSubscribe(*centrifuge.Client, centrifuge.ServerSubscribeEvent)
+	OnServerUnsubscribe(*centrifuge.Client, centrifuge.ServerUnsubscribeEvent)
+	OnSubscribeError(*centrifuge.Subscription, centrifuge.SubscribeErrorEvent)
+	OnSubscribeSuccess(*centrifuge.Subscription, centrifuge.SubscribeSuccessEvent)
+	OnUnsubscribe(*centrifuge.Subscription, centrifuge.UnsubscribeEvent)
+}
diff --git a/chainstate/monitor_client.go b/chainstate/monitor_client.go
@@ -98,22 +98,3 @@ func newCentrifugeClient(wsURL string, handler SocketHandler) MonitorClient {
 
 	return &AgentClient{Client: c}
 }
-
-// SocketHandler is composite interface of centrifuge handlers interfaces
-type SocketHandler interface {
-	OnConnect(*centrifuge.Client, centrifuge.ConnectEvent)
-	OnDisconnect(*centrifuge.Client, centrifuge.DisconnectEvent)
-	OnError(*centrifuge.Client, centrifuge.ErrorEvent)
-	OnJoin(*centrifuge.Subscription, centrifuge.JoinEvent)
-	OnLeave(*centrifuge.Subscription, centrifuge.LeaveEvent)
-	OnMessage(*centrifuge.Client, centrifuge.MessageEvent)
-	OnPublish(*centrifuge.Subscription, centrifuge.PublishEvent)
-	OnServerJoin(*centrifuge.Client, centrifuge.ServerJoinEvent)
-	OnServerLeave(*centrifuge.Client, centrifuge.ServerLeaveEvent)
-	OnServerPublish(*centrifuge.Client, centrifuge.ServerPublishEvent)
-	OnServerSubscribe(*centrifuge.Client, centrifuge.ServerSubscribeEvent)
-	OnServerUnsubscribe(*centrifuge.Client, centrifuge.ServerUnsubscribeEvent)
-	OnSubscribeError(*centrifuge.Subscription, centrifuge.SubscribeErrorEvent)
-	OnSubscribeSuccess(*centrifuge.Subscription, centrifuge.SubscribeSuccessEvent)
-	OnUnsubscribe(*centrifuge.Subscription, centrifuge.UnsubscribeEvent)
-}