Skip to content

Instantly share code, notes, and snippets.

@leoantony72
Created October 19, 2022 15:11
Show Gist options
  • Save leoantony72/1ad26339065a86fca0d907aa5d6dd5ee to your computer and use it in GitHub Desktop.
Save leoantony72/1ad26339065a86fca0d907aa5d6dd5ee to your computer and use it in GitHub Desktop.
Go webscoket - receive messages
type Message struct {
Id string
Message string `json:"msg"`
Sender string
Receiver string `json:"receiver,omitempty"`
Group bool `json:"group"`
GroupName string `json:"group_name,omitempty"`
}
func ReceiveMessage(conn *websocket.Conn) {
for {
_, msg, errCon := conn.ReadMessage()
if errCon != nil {
log.Println("Read Error:", errCon)
conn.Close()
break
}
var r Message
if err := json.Unmarshal(msg, &r); err != nil {
log.Println("Error: " + err.Error())
return
}
r.Id = utils.GenerateKsuid()
r.Sender = userID
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment