feat(extensions): При установке расширения больше не перезаписывают...

feat(extensions): При установке расширения больше не перезаписывают конфликтные схемы коллекций. (Удален временный флаг _alwaysSetSchema в Setup)

Close #PRXS-1472

pkg/setup/collection.go

@@ -19,11 +19,6 @@ var (
 	ErrUninstallCollections = errors.New("failed to uninstall collections")
 )
 
-// todo добавлено в релизе v0.0.16: временный флаг для установки метадаты во все коллекции расширений
-const (
-	_alwaysSetSchema = true
-)
-
 type CollectionsOption func(c *CollectionConfig)
 type UpdateCollectionFn func(s *Setup, exist, new *collections.Collection) (coll *collections.Collection, upd bool, setSchema bool, err error)
 type DeleteCollectionFn func(s *Setup, col *collections.Collection) (bool, error)
@@ -90,7 +85,7 @@ func isMetadataExtensionEqual(s1, s2 *schema.Schema) bool {
 func DefaultUpdateCollectionStrategy() CollectionsOption {
 	return func(c *CollectionConfig) {
 		c.UpdateFn = func(s *Setup, exist, collection *collections.Collection) (*collections.Collection, bool, bool, error) {
-			if !_alwaysSetSchema && !s.IsForce() && !collection.IsView() && !exist.IsView() && !isMetadataExtensionEqual(collection.Schema, exist.Schema) {
+			if !s.IsForce() && !collection.IsView() && !exist.IsView() && !isMetadataExtensionEqual(collection.Schema, exist.Schema) {
 				return nil, false, false, errors.WithDetailf(collections.ErrAlreadyExists, "Коллекция с идентификатором '%s' "+
 					"уже существует. Удалите ее или вызовите установку расширения с флагом Force", collection.ID)
 			}
@@ -107,7 +102,7 @@ func DefaultUpdateCollectionStrategy() CollectionsOption {
 				update = update && *exist.View == *collection.View
 			}
 
-			setSchema = !collection.IsView() && (_alwaysSetSchema || !reflect.DeepEqual(exist.Schema, collection.Schema))
+			setSchema = !collection.IsView() && !reflect.DeepEqual(exist.Schema, collection.Schema)
 
 			return collection, update, setSchema, nil
 		}

pkg/setup/collection_test.go

@@ -122,18 +122,17 @@ func TestSetup_InstallCollections(t *testing.T) {
 				assert.NoError(t, err)
 			},
 		},
-		//todo после удаления флага _alwaysSetSchema данный тест будет работать, сейчас он будет всегда падать, поэтому пока закомментирован
-		//{
-		//name:        "Fail to update user collection with same id as in extensions collection",
-		//collections: []*collections.Collection{{ID: "1", SpaceID: "sp", EnvID: "env", Schema: schema.New("name", field.String()).WithMetadata(extension.ExtensionMetadataKey, "test-extension")}},
-		//collectionsCall: func(svc *mockscollections.Collections) {
-		//	svc.On("Get", mock.Anything, "sp", "env", "1").Return(&collections.Collection{ID: "1", SpaceID: "sp", EnvID: "env", Schema: schema.New("name", field.String())}, nil).Once()
-		//},
-		//wantErr: func(t *testing.T, err error) {
-		//	assert.Error(t, err)
-		//	assert.ErrorIs(t, err, collections.ErrAlreadyExists)
-		//},
-		//},
+		{
+			name:        "Fail to update user collection with same id as in extensions collection",
+			collections: []*collections.Collection{{ID: "1", SpaceID: "sp", EnvID: "env", Schema: schema.New("name", field.String()).WithMetadata(extension.ExtensionMetadataKey, "test-extension")}},
+			collectionsCall: func(svc *mockscollections.Collections) {
+				svc.On("Get", mock.Anything, "sp", "env", "1").Return(&collections.Collection{ID: "1", SpaceID: "sp", EnvID: "env", Schema: schema.New("name", field.String())}, nil).Once()
+			},
+			wantErr: func(t *testing.T, err error) {
+				assert.Error(t, err)
+				assert.ErrorIs(t, err, collections.ErrAlreadyExists)
+			},
+		},
 		{
 			name:        "Update user collection with same id as in extensions collection with force",
 			collections: []*collections.Collection{{ID: "1", SpaceID: "sp", EnvID: "env", Schema: schema.New("name", field.String()).WithMetadata(extension.ExtensionMetadataKey, "test-extension")}},

pkg/setup/setup_test.go

@@ -178,16 +178,10 @@ func TestSetupInstall(t *testing.T) {
 
 	t.Run("Success, update existing records", func(t *testing.T) {
 		envMocks := &environmentMock.Environments{}
-		//todo после удаления флага _alwaysSetSchema убрать лишний вызов
-		envMocks.On("Migrate", mock.Anything, spaceID, envID).
-			Return(nil).Once()
-
 		collsMock := &collectionMock.Collections{}
 		collsMock.On("Get", mock.Anything, spaceID, envID, "coll1").
 			Return(&collections.Collection{ID: "coll1", SpaceID: spaceID, EnvID: envID, Schema: schema.New(), Name: "Коллекция старая"}, nil).Once()
 		collsMock.On("Update", mock.Anything, &collections.Collection{ID: "coll1", SpaceID: spaceID, EnvID: envID, Schema: schema.New(), Name: "Коллекция"}).Return(nil).Once()
-		//todo после удаления флага _alwaysSetSchema убрать лишний вызов
-		collsMock.On("SetSchema", mock.Anything, "sp", "env", "coll1", schema.New()).Return(nil).Once()
 
 		rMock := &rolesMock.Roles{}
 		for _, role := range getRoles() {
@@ -244,17 +238,10 @@ func TestSetupInstall(t *testing.T) {
 	})
 
 	t.Run("Success, with force", func(t *testing.T) {
-		//todo после удаления флага _alwaysSetSchema убрать лишний вызов
-		envMocks := &environmentMock.Environments{}
-		envMocks.On("Migrate", mock.Anything, spaceID, envID).
-			Return(nil).Once()
-
 		collsMock := &collectionMock.Collections{}
 		collsMock.On("Get", mock.Anything, spaceID, envID, "coll1").
 			Return(&collections.Collection{ID: "coll1", SpaceID: spaceID, EnvID: envID, Schema: schema.New(), Name: "Коллекция старая"}, nil).Once()
 		collsMock.On("Update", mock.Anything, &collections.Collection{ID: "coll1", SpaceID: spaceID, EnvID: envID, Schema: schema.New(), Name: "Коллекция"}).Return(nil).Once()
-		//todo после удаления флага _alwaysSetSchema убрать лишний вызов
-		collsMock.On("SetSchema", mock.Anything, "sp", "env", "coll1", schema.New()).Return(nil).Once()
 
 		rMock := &rolesMock.Roles{}
 		for _, role := range getRoles() {
@@ -289,8 +276,6 @@ func TestSetupInstall(t *testing.T) {
 			Clients:     clMock,
 			Roles:       rMock,
 			Items:       itmMock,
-			//todo после удаления флага _alwaysSetSchema убрать
-			Environments: envMocks,
 		}, t)
 		setup = setup.WithForce(true)