Method proxy

authnode/http_server.go:147–173

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

}

func (m *Server) proxy(w http.ResponseWriter, r *http.Request) {
	if m.cluster.PKIKey.EnableHTTPS {
		var (
			plaintext []byte
			err       error
			res       []byte
			jobj      proto.HTTPAuthReply
		)
		target := "https://" + m.leaderInfo.addr + r.URL.Path
		if plaintext, err = m.extractClientReqInfo(r); err != nil {
			sendErrReply(w, r, &proto.HTTPAuthReply{Code: proto.ErrCodeParamError, Msg: err.Error()})
			return
		}
		res, err = proto.SendBytes(m.authProxy.client, target, plaintext)
		if err != nil {
			sendErrReply(w, r, &proto.HTTPAuthReply{Code: proto.ErrCodeAuthReqRedirectError, Msg: "[proxy] failed: " + err.Error()})
			return
		}
		if jobj, err = proto.ParseAuthReply(res); err != nil {
			sendErrReply(w, r, &proto.HTTPAuthReply{Code: proto.ErrCodeAuthReqRedirectError, Msg: "Target Server failed: " + err.Error()})
			return
		}
		sendOkReply(w, r, newSuccessHTTPAuthReply(jobj.Data))
	} else {
		m.authProxy.reverseProxy.ServeHTTP(w, r)
	}
}