Function TestIsCfgChanged

db/sg_replicate_cfg_test.go:547–669

(t *testing.T)

}

func TestIsCfgChanged(t *testing.T) {

	getInitialCfg := func() *ReplicationCfg {
		return &ReplicationCfg{
			ReplicationConfig: ReplicationConfig{
				ID:                     "foo",
				Remote:                 "a",
				Direction:              ActiveReplicatorTypePull,
				ConflictResolutionType: ConflictResolverCustom,
				ConflictResolutionFn:   "a",
				PurgeOnRemoval:         true,
				DeltaSyncEnabled:       true,
				MaxBackoff:             5,
				InitialState:           "a",
				Continuous:             true,
				Filter:                 "a",
				QueryParams:            []interface{}{"ABC"},
				Username:               "alice",
				Password:               "password",
				CollectionsLocal:       []string{"foo.bar"},
			},
		}
	}

	type cfgChangedTest struct {
		name            string                   // Test name
		updatedConfig   *ReplicationUpsertConfig // Updated replication config
		expectedChanged bool
	}
	testCases := []cfgChangedTest{
		{
			name: "remoteChanged",
			updatedConfig: &ReplicationUpsertConfig{
				Remote: base.Ptr("b"),
			},
			expectedChanged: true,
		},
		{
			name: "directionChanged",
			updatedConfig: &ReplicationUpsertConfig{
				Direction: base.Ptr(string(ActiveReplicatorTypePushAndPull)),
			},
			expectedChanged: true,
		},
		{
			name: "conflictResolverChanged",
			updatedConfig: &ReplicationUpsertConfig{
				ConflictResolutionType: base.Ptr(string(ConflictResolverDefault)),
			},
			expectedChanged: true,
		},
		{
			name: "conflictResolverFnChange",
			updatedConfig: &ReplicationUpsertConfig{
				ConflictResolutionFn: base.Ptr("b"),
			},
			expectedChanged: true,
		},