diff --git a/federation/service/syncer.go b/federation/service/syncer.go index 80fa9f520..aa08cac49 100644 --- a/federation/service/syncer.go +++ b/federation/service/syncer.go @@ -70,7 +70,6 @@ func (h *Syncer) Process(ctx context.Context, payload []byte, out chan Url, url aux, err := h.ParseHeader(ctx, payload) if err != nil { - spew.Dump("ERR", err) return 0, err } diff --git a/federation/service/syncer_test.go b/federation/service/syncer_test.go new file mode 100644 index 000000000..d65860e19 --- /dev/null +++ b/federation/service/syncer_test.go @@ -0,0 +1,62 @@ +package service + +import ( + "context" + "testing" + + "github.com/cortezaproject/corteza-server/federation/types" + "github.com/stretchr/testify/require" +) + +type ( + testProcesser struct{} +) + +func (p *testProcesser) Process(ctx context.Context, payload []byte) (int, error) { + return 0, nil +} + +func TestSyncer_process(t *testing.T) { + var ( + req = require.New(t) + syncer = &Syncer{} + + ctx = context.Background() + ) + + c := make(chan Url, 2) + u := types.SyncerURI{ + Limit: 10, + NextPage: "123", + } + tp := &testProcesser{} + + go syncer.Process(ctx, []byte(`{"response":{"filter":{"limit":1, "nextPage":"456"}}}`), c, u, tp) + + select { + case url := <-c: + req.Equal(url.Url.NextPage, "456") + break + } +} + +func TestSyncer_parseHeader(t *testing.T) { + var ( + req = require.New(t) + syncer = &Syncer{} + + ctx = context.Background() + ) + + c := make(chan Url, 2) + u := types.SyncerURI{ + Limit: 10, + NextPage: "123", + } + tp := &testProcesser{} + + n, err := syncer.Process(ctx, []byte(`{"response":{"filt`), c, u, tp) + + req.EqualError(err, "unexpected end of JSON input") + req.Equal(n, 0) +}