Function TestAutomaticConfigUpgradeError

rest/persistent_config_test.go:118–169

(t *testing.T)

}

func TestAutomaticConfigUpgradeError(t *testing.T) {
	if base.UnitTestUrlIsWalrus() {
		t.Skip("CBS required")
	}

	testCases := []struct {
		Name   string
		Config string
	}{
		{
			"Multiple DBs different servers",
			`
				{
					"server_tls_skip_verify": %t,
					"databases": {
						"db": {
							"server": "%s",
							"username": "%s",
							"password": "%s",
							"bucket": "%s"
						},
						"db2": {
							"server": "rand",
							"username": "",
							"password": "",
							"bucket": ""
						}
					}
				}`,
		},
	}

	for _, testCase := range testCases {
		// Create tempdir here to avoid slash operator in t.Name()
		tmpDir := t.TempDir()

		t.Run(testCase.Name, func(t *testing.T) {
			ctx := base.TestCtx(t)
			tb := base.GetTestBucket(t)
			defer tb.Close(ctx)

			config := fmt.Sprintf(testCase.Config, base.TestTLSSkipVerify(), base.UnitTestUrl(), base.TestClusterUsername(), base.TestClusterPassword(), tb.GetName())

			configPath := filepath.Join(tmpDir, "config.json")
			err := os.WriteFile(configPath, []byte(config), os.FileMode(0644))
			require.NoError(t, err)

			_, _, _, _, err = automaticConfigUpgrade(base.TestCtx(t), configPath)
			assert.Error(t, err)
		})
	}
}

func TestUnmarshalBrokenConfig(t *testing.T) {
	t.Skip("Disabled, CBG-2420")