main.go

	router.HandleFunc("/ws/{rname}", func(w http.ResponseWriter, r *http.Request) {

		defer r.Body.Close()

		/*
			Authenticate user with custom-headers
			After authentication , Get the action from client

		*/

		if r.Method != "GET" {
			http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
			return
		}
		vars := mux.Vars(r)

		ws, err := upgrader.Upgrade(w, r, nil)

		if err != nil {
			m := "Unable to upgrade to websockets"

			http.Error(w, m, http.StatusBadRequest)
			return
		}

		vars["rname"] = string(vars["rname"])

		if err != nil {
			log.Println(err)
			return
		}
		c := &connection{send: make(chan []byte, 256), ws: ws}

		/*the subscription struct will hold the ws pointer , associate rooms*/

		s := subscription{c, vars["rname"]}
		go h.run(db)
		h.register <- s
		go s.writePump()
		s.readPump()
	})