change

Author: NullpointerW

httphandler/commn.go

@@ -16,22 +16,22 @@ const (
 	ServerError      statusCode = 500
 )
 
-func respOk(w http.ResponseWriter, t any) {
+func RespOk(w http.ResponseWriter, t any) {
 	resp(OK, w, t)
 }
-func respSrvErr(w http.ResponseWriter, t any) {
+func RespSrvErr(w http.ResponseWriter, t any) {
 	resp(ServerError, w, t)
 }
-func respBadReq(w http.ResponseWriter, t any) {
+func RespBadReq(w http.ResponseWriter, t any) {
 	resp(BadRequest, w, t)
 }
-func respMethodNA(w http.ResponseWriter, t any) {
+func RespMethodNA(w http.ResponseWriter, t any) {
 	resp(MethodNotAllowed, w, t)
 }
-func respUnAuth(w http.ResponseWriter, t any) {
+func RespUnAuth(w http.ResponseWriter, t any) {
 	resp(Unauthorized, w, t)
 }
-func respForbid(w http.ResponseWriter, t any) {
+func RespForbid(w http.ResponseWriter, t any) {
 	resp(Forbidden, w, t)
 }
 

httphandler/handler.go

@@ -25,47 +25,47 @@ func (h Handler) Push(w http.ResponseWriter, req *http.Request) {
 	uid, _ := strconv.ParseUint(idStr, 10, 64)
 	err := h.Adapter.Push(uid, utils.Bcs(_msg))
 	if err != nil {
-		respSrvErr(w, err)
+		RespSrvErr(w, err)
 		return
 	}
-	respOk(w, "ok")
+	RespOk(w, "ok")
 }
 
 func (h Handler) Broadcast(w http.ResponseWriter, req *http.Request) {
 	_msg, _ := ioutil.ReadAll(req.Body)
 	//t := time.Now()
 	err := h.Adapter.Broadcast(utils.Bcs(_msg))
 	if err != nil {
-		respSrvErr(w, err)
+		RespSrvErr(w, err)
 		return
 	}
-	respOk(w, "ok")
+	RespOk(w, "ok")
 }
 
 func (h Handler) MultiPush(w http.ResponseWriter, req *http.Request) {
 	if req.Method != "POST" {
-		respMethodNA(w, "non-post method not allowed")
+		RespMethodNA(w, "non-post method not allowed")
 		return
 	}
 	jsBody, _ := ioutil.ReadAll(req.Body)
 	cts := &golwpush.Contents{}
 	err := json.Unmarshal(jsBody, cts)
 	if err != nil {
-		respBadReq(w, "json unmarshal error")
+		RespBadReq(w, "json unmarshal error")
 		return
 	}
 	cts.Res = make(chan uint64, 1)
 	err, ok := h.Adapter.MultiPush(cts)
 	if err != nil {
-		respSrvErr(w, err)
+		RespSrvErr(w, err)
 		return
 	}
-	respOk(w, ok)
+	RespOk(w, ok)
 }
 
 func (h Handler) Count(w http.ResponseWriter, req *http.Request) {
 	c := h.Adapter.Count()
-	respOk(w, c)
+	RespOk(w, c)
 }
 
 func (h Handler) Info(w http.ResponseWriter, req *http.Request) {
@@ -74,14 +74,14 @@ func (h Handler) Info(w http.ResponseWriter, req *http.Request) {
 	res := make(chan any, 1)
 	i, err := h.Adapter.Info(golwpush.BizReq{Res: res, Uid: uid, Typ: golwpush.Info})
 	if err != nil {
-		respSrvErr(w, err)
+		RespSrvErr(w, err)
 		return
 	}
 	if i == nil {
-		respOk(w, fmt.Sprintf("uid :%d offline [%s]", uid, time.Now().Format(utils.TimeParseLayout)))
+		RespOk(w, fmt.Sprintf("uid :%d offline [%s]", uid, time.Now().Format(utils.TimeParseLayout)))
 		return
 	}
 	w.Header().Add("Content-Type", "application/json")
 	j, _ := json.Marshal(i)
-	respOk(w, utils.Bcs(j))
+	RespOk(w, utils.Bcs(j))
 }