From 8139481ea7345b6dcfb6048cc19898a7e683469b Mon Sep 17 00:00:00 2001
From: Lykin <137850705+tiny-craft@users.noreply.github.com>
Date: Fri, 26 Apr 2024 16:20:00 +0800
Subject: [PATCH] fix: fail to open pub/sub in cluster mode #239

---
 backend/services/pubsub_service.go | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

diff --git a/backend/services/pubsub_service.go b/backend/services/pubsub_service.go
index c4e2c10..4929751 100644
--- a/backend/services/pubsub_service.go
+++ b/backend/services/pubsub_service.go
@@ -2,7 +2,6 @@ package services
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"github.com/redis/go-redis/v9"
 	"github.com/wailsapp/wails/v2/pkg/runtime"
@@ -13,7 +12,7 @@ import (
 )
 
 type pubsubItem struct {
-	client    *redis.Client
+	client    redis.UniversalClient
 	pubsub    *redis.PubSub
 	mutex     sync.Mutex
 	closeCh   chan struct{}
@@ -62,12 +61,8 @@ func (p *pubsubService) getItem(server string) (*pubsubItem, error) {
 		if uniClient, err = Connection().createRedisClient(conf.ConnectionConfig); err != nil {
 			return nil, err
 		}
-		var client *redis.Client
-		if client, ok = uniClient.(*redis.Client); !ok {
-			return nil, errors.New("create redis client fail")
-		}
 		item = &pubsubItem{
-			client: client,
+			client: uniClient,
 		}
 		p.items[server] = item
 	}