diff --git a/api/helper.go b/api/helper.go index 5f94386..f3be0da 100644 --- a/api/helper.go +++ b/api/helper.go @@ -20,6 +20,10 @@ func (r *Request) OkJson(object JsonResponse) { handleErr(err, r) } +func (r *Request) Ok() { + r.Ctx.Response.SetStatusCode(204) +} + func (r *Request) Json(object JsonResponse, code int) { resp, err := json.Marshal(object) diff --git a/api/log.go b/api/log.go index 341e898..c7d032e 100644 --- a/api/log.go +++ b/api/log.go @@ -70,6 +70,8 @@ func (api *WebAPI) LogTrace(r *Request) { "scope": entry.Scope, "worker": entry.worker.Id, }).WithTime(entry.Time()).Trace(entry.Message) + + r.Ok() } func (api *WebAPI) LogInfo(r *Request) { @@ -87,6 +89,8 @@ func (api *WebAPI) LogInfo(r *Request) { "scope": entry.Scope, "worker": entry.worker.Id, }).WithTime(entry.Time()).Info(entry.Message) + + r.Ok() } func (api *WebAPI) LogWarn(r *Request) { @@ -104,6 +108,8 @@ func (api *WebAPI) LogWarn(r *Request) { "scope": entry.Scope, "worker": entry.worker.Id, }).WithTime(entry.Time()).Warn(entry.Message) + + r.Ok() } func (api *WebAPI) LogError(r *Request) { @@ -121,6 +127,8 @@ func (api *WebAPI) LogError(r *Request) { "scope": entry.Scope, "worker": entry.worker.Id, }).WithTime(entry.Time()).Error(entry.Message) + + r.Ok() } func (api *WebAPI) GetLog(r *Request) { diff --git a/client/client.go b/client/client.go index 6655295..69999b6 100644 --- a/client/client.go +++ b/client/client.go @@ -176,7 +176,7 @@ func (c TaskTrackerClient) Log(level storage.LogLevel, message string) error { case storage.WARN: levelString = "warn" case storage.INFO: - levelString = "panic" + levelString = "info" case storage.TRACE: levelString = "trace" default: @@ -184,6 +184,10 @@ func (c TaskTrackerClient) Log(level storage.LogLevel, message string) error { } httpResp := c.post("/log/"+levelString, req) + if httpResp.StatusCode == http.StatusNoContent { + return nil + } + var jsonResp api.JsonResponse err := unmarshalResponse(httpResp, &jsonResp)