DeforaNetworks/corteza
3
0
Fork 0
Code Activity

Fix sink error handling

Browse Source
This commit is contained in:
Tomaž Jerman
2020-12-29 11:34:17 +01:00
parent 2bfe81b9db
commit 04054ca07f
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
system/service/sink.go
+2 -3
View File
@@ -8,7 +8,6 @@ import (
"github.com/cortezaproject/corteza-server/pkg/actionlog"
"github.com/cortezaproject/corteza-server/pkg/api"
internalAuth "github.com/cortezaproject/corteza-server/pkg/auth"
"github.com/cortezaproject/corteza-server/pkg/errors"
"github.com/cortezaproject/corteza-server/pkg/eventbus"
"github.com/cortezaproject/corteza-server/system/service/event"
"github.com/cortezaproject/corteza-server/system/types"
@@ -149,7 +148,7 @@ func (svc *sink) ProcessRequest(w http.ResponseWriter, r *http.Request) {
)
// capture error from request handling and process functions
err := func() *errors.Error {
err := func() error {
defer r.Body.Close()
srup, err := svc.handleRequest(r)
if err != nil {
@@ -179,7 +178,7 @@ func (svc *sink) ProcessRequest(w http.ResponseWriter, r *http.Request) {
}
// Verifies and extracts sink request params
func (svc sink) handleRequest(r *http.Request) (*SinkRequestUrlParams, *errors.Error) {
func (svc sink) handleRequest(r *http.Request) (*SinkRequestUrlParams, error) {
var (
srup = &SinkRequestUrlParams{}
sap = &sinkActionProps{}