diff --git a/main.go b/main.go index 1e6d04e..bf1143d 100644 --- a/main.go +++ b/main.go @@ -427,6 +427,7 @@ func (that *GlobalBackfeedManager) Handle(res http.ResponseWriter, req *http.Req var err error statusCode := http.StatusNoContent + n := 0 for scanner.Scan() { b := scanner.Bytes() if len(b) == 0 { @@ -443,6 +444,7 @@ func (that *GlobalBackfeedManager) Handle(res http.ResponseWriter, req *http.Req statusCode = http.StatusServiceUnavailable break } + n++ } if err == nil { err = scanner.Err() @@ -450,7 +452,11 @@ func (that *GlobalBackfeedManager) Handle(res http.ResponseWriter, req *http.Req statusCode = http.StatusBadRequest } } - WriteResponse(res, statusCode, err) + if err != nil { + WriteResponse(res, statusCode, err) + } else { + WriteResponse(res, http.StatusOK, fmt.Sprintf("%d items queued", n)) + } return }