Function TestReportSync

sync/sync_test.go:25–88

(t *testing.T)

)

func TestReportSync(t *testing.T) {
	f, err := os.CreateTemp("", t.Name())
	assert.NoError(t, err)
	assert.NotNil(t, f)
	fmt.Println("-->tempfile", f.Name())

	sto, err := store.NewBoltHold(f.Name())
	assert.NoError(t, err)
	assert.NotNil(t, sto)

	nod, err := node.NewNode(sto)
	assert.NoError(t, err)
	assert.NotNil(t, nod)

	var sc config.Config
	err = utils.UnmarshalYAML(nil, &sc)
	assert.NoError(t, err)

	mockCtl := gomock.NewController(t)
	link := plugin.NewMockLink(mockCtl)
	assert.NoError(t, err)
	pb := plugin.NewMockPubsub(mockCtl)
	syn := &sync{
		link:  link,
		cfg:   sc,
		store: sto,
		nod:   nod,
		pb:    pb,
		log:   log.With(log.Any("test", "sync")),
	}
	link.EXPECT().IsAsyncSupported().Return(false).Times(1)
	delta := specv1.Delta{"apps": map[string]interface{}{"app1": "123"}}

	msg := &specv1.Message{Content: specv1.LazyValue{Value: delta}, Kind: specv1.MessageReport}
	dt, err := json.Marshal(msg)
	assert.NoError(t, err)
	m := &specv1.Message{}
	err = json.Unmarshal(dt, m)
	assert.NoError(t, err)

	link.EXPECT().Request(gomock.Any()).Return(m, nil).Times(1)
	err = syn.reportAndDesire()
	assert.NoError(t, err)
	no, _ := syn.nod.Get()
	var desire specv1.Desire = map[string]interface{}{}
	desire, err = desire.Patch(delta)
	assert.NoError(t, err)
	assert.Equal(t, desire, no.Desire)

	link.EXPECT().IsAsyncSupported().Return(true).Times(1)
	link.EXPECT().Send(gomock.Any()).Return(nil).Times(1)
	err = syn.reportAndDesire()
	assert.NoError(t, err)

	link.EXPECT().IsAsyncSupported().Return(false).Times(1)
	link.EXPECT().Request(gomock.Any()).Return(nil, errors.New("failed to report"))
	err = syn.reportAndDesire()
	assert.Error(t, err)