From 04054ca07f67eb48f28750dc6e7c43f0ddf1ba5d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Toma=C5=BE=20Jerman?= Date: Tue, 29 Dec 2020 11:34:17 +0100 Subject: [PATCH] Fix sink error handling --- system/service/sink.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/system/service/sink.go b/system/service/sink.go index 317b9b2c8..c460189f8 100644 --- a/system/service/sink.go +++ b/system/service/sink.go @@ -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{}