Fix: parse message type

benlad · Jun 5, 2019 · f8cd526 · f8cd526
1 parent f420fbe
commit f8cd526
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/websocket/client.go b/websocket/client.go
@@ -6,6 +6,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"log"
+	"strings"
 	"sync"
 	"time"
 	"unicode"
@@ -377,7 +378,8 @@ func (c *Client) handleChannel(msg []byte) error {
 		return err
 	}
 
-	factory, ok := c.factories[data.ChannelName]
+	channel := strings.Split(data.ChannelName, "-")[0]
+	factory, ok := c.factories[channel]
 	if !ok {
 		return fmt.Errorf("Unknown message type: %s", data.ChannelName)
 	}