Method Handler

cmd/sigsvr/httpsvr.go:79–140

(w http.ResponseWriter, r *http.Request)

}

func (this *CliRpcServer) Handler(w http.ResponseWriter, r *http.Request) {
	resp := &common.CliRpcResponse{}
	defer func() {
		w.Header().Add("Access-Control-Allow-Headers", "Content-Type")
		w.Header().Set("content-type", "application/json;charset=utf-8")
		w.Header().Set("Access-Control-Allow-Origin", "*")
		w.WriteHeader(http.StatusOK)

		if resp.ErrorInfo == "" {
			resp.ErrorInfo = common.GetCLIErrorDesc(resp.ErrorCode)
		}
		data, err := json.Marshal(resp)
		if err != nil {
			log.Error("CliRpcServer json.Marshal JsonRpcResponse:%+v error:%s", resp, err)
			return
		}
		_, err = w.Write(data)
		if err != nil {
			log.Error("CliRpcServer Write:%s error %s", data, err)
			return
		}
		log.Infof("[CliRpcResponse]%s", data)
	}()

	if r.Method != http.MethodPost {
		resp.ErrorCode = common.CLIERR_HTTP_METHOD_INVALID
		return
	}
	data, err := ioutil.ReadAll(r.Body)
	if err != nil {
		log.Error("CliRpcServer read body error:%s", err)
		resp.ErrorCode = common.CLIERR_INVALID_REQUEST
		resp.ErrorInfo = "invalid body"
		return
	}
	defer r.Body.Close()

	req := &common.CliRpcRequest{}
	err = json.Unmarshal(data, req)
	if err != nil {
		log.Errorf("CliRpcServer json.Unmarshal JsonRpcRequest error:%s", err)
		resp.ErrorCode = common.CLIERR_INVALID_PARAMS
		return
	}

	pwd := req.Pwd
	req.Pwd = "*"
	logData, _ := json.Marshal(req)
	log.Infof("[CliRpcRequest]%s", logData)

	req.Pwd = pwd
	resp.Method = req.Method
	resp.Qid = req.Qid

	handler := this.GetHandler(req.Method)
	if handler == nil {
		resp.ErrorCode = common.CLIERR_UNSUPPORT_METHOD
		return