github/natpass
4
0
Fork 0
mirror of https://github.com/lwch/natpass.git synced 2024-04-21 12:41:54 +00:00
Code Issues Projects Releases Wiki Activity

增加错误处理逻辑

Browse Source
This commit is contained in:
lwch
2022-07-28 15:42:07 +08:00
parent 2c268de3dd
commit 856d237f88
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
code/client/rule/code/workspace_remote_response.go
+8 -2
View File
@@ -17,8 +17,11 @@ func (ws *Workspace) handleRequest(msg *network.Msg) {
req := msg.GetCsreq()
request, err := http.NewRequest(req.GetMethod(), "http://unix"+req.GetUri(), bytes.NewReader(req.GetBody()))
if err != nil {
// TODO: response error
logging.Error("build request [%s] [%s]: %v", ws.id, ws.name, err)
ws.remote.SendCodeResponseHeader(ws.target, ws.id, req.GetRequestId(),
http.StatusInternalServerError, nil)
ws.remote.SendCodeResponseBody(ws.target, ws.id, req.GetRequestId(),
0, false, true, []byte(err.Error()))
return
}
for key, values := range req.GetHeader() {
@@ -28,8 +31,11 @@ func (ws *Workspace) handleRequest(msg *network.Msg) {
}
response, err := ws.cli.Do(request)
if err != nil {
// TODO: response error
logging.Error("call request [%s] [%s] [%s]: %v", ws.id, ws.name, req.GetUri(), err)
ws.remote.SendCodeResponseHeader(ws.target, ws.id, req.GetRequestId(),
http.StatusInternalServerError, nil)
ws.remote.SendCodeResponseBody(ws.target, ws.id, req.GetRequestId(),
0, false, true, []byte(err.Error()))
return
}
defer response.Body.Close()