(t *testing.T)
| 225 | } |
| 226 | |
| 227 | func TestConfigValidationImport(t *testing.T) { |
| 228 | jsonConfig := `{"databases": {"db": {"enable_shared_bucket_access":true, "import_docs": true, "import_partitions": 32}}}` |
| 229 | ctx := base.TestCtx(t) |
| 230 | buf := bytes.NewBufferString(jsonConfig) |
| 231 | config, err := readLegacyServerConfig(ctx, buf) |
| 232 | assert.NoError(t, err) |
| 233 | |
| 234 | errorMessages := config.setupAndValidateDatabases(ctx) |
| 235 | require.NoError(t, errorMessages) |
| 236 | require.NotNil(t, config.Databases["db"]) |
| 237 | |
| 238 | if base.IsEnterpriseEdition() { |
| 239 | require.NotNil(t, config.Databases["db"].ImportPartitions) |
| 240 | assert.Equal(t, uint16(32), *config.Databases["db"].ImportPartitions) |
| 241 | } else { |
| 242 | // CE disallowed - should be nil |
| 243 | assert.Nil(t, config.Databases["db"].ImportPartitions) |
| 244 | } |
| 245 | } |
| 246 | |
| 247 | func TestConfigValidationImportPartitions(t *testing.T) { |
| 248 |
nothing calls this directly
no test coverage detected