Function TestImportCollectionsUpdateRules

core/collection_import_test.go:322–432

(t *testing.T)

}

func TestImportCollectionsUpdateRules(t *testing.T) {
	t.Parallel()

	scenarios := []struct {
		name          string
		data          map[string]any
		deleteMissing bool
	}{
		{
			"extend existing by name (without deleteMissing)",
			map[string]any{"name": "clients", "authToken": map[string]any{"duration": 100}, "fields": []map[string]any{{"name": "test", "type": "text"}}},
			false,
		},
		{
			"extend existing by id (without deleteMissing)",
			map[string]any{"id": "v851q4r790rhknl", "authToken": map[string]any{"duration": 100}, "fields": []map[string]any{{"name": "test", "type": "text"}}},
			false,
		},
		{
			"extend with delete missing",
			map[string]any{
				"id":           "v851q4r790rhknl",
				"authToken":    map[string]any{"duration": 100},
				"fields":       []map[string]any{{"name": "test", "type": "text"}},
				"passwordAuth": map[string]any{"identityFields": []string{"email"}},
				"indexes": []string{
					// min required system fields indexes
					"CREATE UNIQUE INDEX `_v851q4r790rhknl_email_idx` ON `clients` (email) WHERE email != ''",
					"CREATE UNIQUE INDEX `_v851q4r790rhknl_tokenKey_idx` ON `clients` (tokenKey)",
				},
			},
			true,
		},
	}

	for _, s := range scenarios {
		t.Run(s.name, func(t *testing.T) {
			testApp, _ := tests.NewTestApp()
			defer testApp.Cleanup()

			beforeCollection, err := testApp.FindCollectionByNameOrId("clients")
			if err != nil {
				t.Fatal(err)
			}

			err = testApp.ImportCollections([]map[string]any{s.data}, s.deleteMissing)
			if err != nil {
				t.Fatal(err)
			}

			afterCollection, err := testApp.FindCollectionByNameOrId("clients")
			if err != nil {
				t.Fatal(err)
			}

			if afterCollection.AuthToken.Duration != 100 {
				t.Fatalf("Expected AuthToken duration to be %d, got %d", 100, afterCollection.AuthToken.Duration)
			}