From c01b3d1ac536fdbc2c46ab6ae2797877a2f8bfde Mon Sep 17 00:00:00 2001 From: Peter Grlica Date: Mon, 16 Nov 2020 16:58:07 +0100 Subject: [PATCH] Added label to federated record --- federation/service/sync_worker_data.go | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/federation/service/sync_worker_data.go b/federation/service/sync_worker_data.go index 92afe0e3c..147425759 100644 --- a/federation/service/sync_worker_data.go +++ b/federation/service/sync_worker_data.go @@ -9,7 +9,6 @@ import ( ct "github.com/cortezaproject/corteza-server/compose/types" "github.com/cortezaproject/corteza-server/federation/types" "github.com/cortezaproject/corteza-server/pkg/decoder" - "github.com/davecgh/go-spew/spew" "go.uber.org/zap" ) @@ -43,10 +42,6 @@ func WorkerData(sync *Sync, logger *zap.Logger) *syncWorkerData { } func (w *syncWorkerData) queueUrl(url *types.SyncerURI, urls chan Url, meta Processer) { - // s, _ := url.String() - - // w.logger.Debug(fmt.Sprintf("adding %s to queue", s)) - t := Url{ Url: *url, Meta: meta, @@ -170,14 +165,12 @@ func (w *syncWorkerData) Watch(ctx context.Context, delay time.Duration, limit i s, err := url.Url.String() if err != nil { - spew.Dump("ERR", err) continue } responseBody, err := w.syncService.FetchUrl(ctx, s) if err != nil { - spew.Dump("ERR", err) continue } @@ -265,6 +258,8 @@ func (dp *dataProcesser) Process(ctx context.Context, payload []byte) (int, erro Values: *dp.ModuleMappingValues, } + AddFederationLabel(rec, dp.NodeBaseURL) + _, err := dp.SyncService.CreateRecord(ctx, rec) if err != nil {