@@ -10,25 +10,28 @@ import (
10
10
"github.com/graphql-go/graphql/language/kinds"
11
11
)
12
12
13
+ type SubscriptionIDByConnectionID map [string ]string
14
+ type QueryArgsMap map [string ]string
15
+
13
16
type SubscribeFilter interface {
14
17
RegisterConnectionIDFromDocument (connID string , subID string , doc * ast.Document , variables map [string ]interface {})
15
18
RemoveSubscriptionIDFromConnectionID (connID , subID string )
16
19
RemoveConnectionIDFromChannels (connID string )
17
- GetChannelRegisteredConnectionIDs (channel string ) map [ string ] string
20
+ GetChannelRegisteredConnectionIDs (channel string ) SubscriptionIDByConnectionID
18
21
}
19
22
20
23
type ChannelSerializer interface {
21
- Serialize (field string , args map [ string ] string ) string
24
+ Serialize (field string , args QueryArgsMap ) string
22
25
}
23
26
24
- type channelSerializerFunc func (field string , args map [ string ] string ) string
27
+ type channelSerializerFunc func (field string , args QueryArgsMap ) string
25
28
26
- func (f channelSerializerFunc ) Serialize (field string , args map [ string ] string ) string {
29
+ func (f channelSerializerFunc ) Serialize (field string , args QueryArgsMap ) string {
27
30
return f (field , args )
28
31
}
29
32
30
33
func getNewChannelSerializerFunc () channelSerializerFunc {
31
- return func (field string , args map [ string ] string ) string {
34
+ return func (field string , args QueryArgsMap ) string {
32
35
sargs := []string {}
33
36
for k := range args {
34
37
sargs = append (sargs , k )
@@ -203,8 +206,8 @@ func (f *subscribeFilter) RemoveSubscriptionIDFromConnectionID(connID, subID str
203
206
}
204
207
}
205
208
206
- func (f * subscribeFilter ) GetChannelRegisteredConnectionIDs (channel string ) map [ string ] string {
207
- founds := map [ string ] string {}
209
+ func (f * subscribeFilter ) GetChannelRegisteredConnectionIDs (channel string ) SubscriptionIDByConnectionID {
210
+ founds := SubscriptionIDByConnectionID {}
208
211
if m , ok := f .connectionIDByChannel [channel ]; ok {
209
212
m .Range (func (k , v interface {}) bool {
210
213
founds [k .(string )] = v .(string )
0 commit comments