@@ -44,7 +44,7 @@ func mockStarData() (a redisocket.Auth, d []byte) {
44
44
}
45
45
func TestSubscribeCommand (t * testing.T ) {
46
46
a , d := mockNoStarData ()
47
- m , err := SubscribeCommand ("TEST" , a , d , false )
47
+ m , err := SubscribeCommand ("TEST" , a , d , "socket_id" , false )
48
48
if err != nil {
49
49
t .Errorf ("%s err:%v" , "nostar" , err )
50
50
return
@@ -54,7 +54,7 @@ func TestSubscribeCommand(t *testing.T) {
54
54
return
55
55
}
56
56
a , d = mockNoMatchData ()
57
- m , err = SubscribeCommand ("TEST" , a , d , false )
57
+ m , err = SubscribeCommand ("TEST" , a , d , "socket_id" , false )
58
58
if err != nil {
59
59
t .Errorf ("%s err:%v" , "nostar" , err )
60
60
return
@@ -64,7 +64,7 @@ func TestSubscribeCommand(t *testing.T) {
64
64
return
65
65
}
66
66
a , d = mockAdminData ()
67
- m , err = SubscribeCommand ("TEST" , a , d , false )
67
+ m , err = SubscribeCommand ("TEST" , a , d , "socket_id" , false )
68
68
if err != nil {
69
69
t .Errorf ("%s err:%v" , "admin" , err )
70
70
return
@@ -74,7 +74,7 @@ func TestSubscribeCommand(t *testing.T) {
74
74
return
75
75
}
76
76
a , d = mockStarData ()
77
- m , err = SubscribeCommand ("TEST" , a , d , false )
77
+ m , err = SubscribeCommand ("TEST" , a , d , "socket_id" , false )
78
78
if m .data != "@^WTFDD" {
79
79
t .Error ("subscribe @^WTFDD error" )
80
80
return
0 commit comments