Skip to content

Commit

Permalink
Fix UserID not getting through Snowflake (#26)
Browse files Browse the repository at this point in the history
  • Loading branch information
streamer45 authored Mar 11, 2022
1 parent 9adb3f2 commit a74a92b
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions server/websocket.go
Original file line number Diff line number Diff line change
Expand Up @@ -289,10 +289,10 @@ func (p *Plugin) handleJoin(userID, connID, channelID string) error {
p.mut.Unlock()

p.track(evCallStarted, map[string]interface{}{
"UserID": userID,
"CallID": state.Call.ID,
"ChannelID": channelID,
"ChannelType": channel.Type,
"ParticipantID": userID,
"CallID": state.Call.ID,
"ChannelID": channelID,
"ChannelType": channel.Type,
})

// new call has started
Expand Down Expand Up @@ -321,9 +321,9 @@ func (p *Plugin) handleJoin(userID, connID, channelID string) error {
p.metrics.WebSocketConnections.With(prometheus.Labels{"channelID": channelID}).Inc()
defer p.metrics.WebSocketConnections.With(prometheus.Labels{"channelID": channelID}).Dec()
p.track(evCallUserJoined, map[string]interface{}{
"UserID": userID,
"ChannelID": channelID,
"CallID": state.Call.ID,
"ParticipantID": userID,
"ChannelID": channelID,
"CallID": state.Call.ID,
})

handlerID := state.NodeID
Expand Down Expand Up @@ -397,9 +397,9 @@ func (p *Plugin) handleJoin(userID, connID, channelID string) error {
"userID": userID,
}, &model.WebsocketBroadcast{ChannelId: channelID})
p.track(evCallUserLeft, map[string]interface{}{
"UserID": userID,
"ChannelID": channelID,
"CallID": state.Call.ID,
"ParticipantID": userID,
"ChannelID": channelID,
"CallID": state.Call.ID,
})

p.LogDebug("removing session from state", "userID", userID)
Expand Down

0 comments on commit a74a92b

Please sign in to comment.