Function onCollectionSaveExecute

core/collection_model.go:846–932

(e *CollectionEvent)

}

func onCollectionSaveExecute(e *CollectionEvent) error {
	defer func() {
		if err := e.App.ReloadCachedCollections(); err != nil {
			e.App.Logger().Warn("Failed to reload collections cache", "error", err)
		}
	}()

	var oldCollection *Collection
	if !e.Collection.IsNew() {
		var err error
		oldCollection, err = e.App.FindCachedCollectionByNameOrId(e.Collection.Id)
		if err != nil {
			return err
		}

		// invalidate previously issued auth tokens on auth rule change
		if oldCollection.AuthRule != e.Collection.AuthRule &&
			cast.ToString(oldCollection.AuthRule) != cast.ToString(e.Collection.AuthRule) {
			e.Collection.AuthToken.Secret = security.RandomString(50)
		}
	}

	originalApp := e.App
	txErr := e.App.RunInTransaction(func(txApp App) error {
		e.App = txApp

		isView := e.Collection.IsView()

		// ensures that the view collection shema is properly loaded
		if isView {
			query := e.Collection.ViewQuery

			// generate collection fields list from the query
			viewFields, err := e.App.CreateViewFields(query)
			if err != nil {
				return err
			}

			// delete old renamed view
			if oldCollection != nil {
				if err := e.App.DeleteView(oldCollection.Name); err != nil {
					return err
				}
			}

			// wrap view query if necessary
			query, err = normalizeViewQueryId(e.App, query)
			if err != nil {
				return fmt.Errorf("failed to normalize view query id: %w", err)
			}

			// (re)create the view
			if err := e.App.SaveView(e.Collection.Name, query); err != nil {
				return err
			}

			// updates newCollection.Fields based on the generated view table info and query
			e.Collection.Fields = viewFields