coba websocket ke nats

coba_websocket_ke_nats.go

func (h *Handler) dksocket(c *gin.Context) {
     token := h.extractClaim(c)
     conn, err := wsupgrader.Upgrade(c.Writer, c.Request, nil)
     nc, _ := nats.Connect(nats.DefaultURL)
     nc.Subscribe(token.UserID, func(m *nats.Msg) {
       conn.WriteMessage(1, m.Data)      // meneruskan subcribe ke websocket. potensi panic ga??
     })
     nc.Subscribe("pengumuman", func(m *nats.Msg) {
      conn.WriteMessage(1, m.Data)      // meneruskan subcribe ke websocket. potensi panic ga??
     })
     for {
       t, msg, err := conn.ReadMessage()
       fmt.Println(t, msg, err)
       conn.WriteMessage(t, msg)
     }
}