Function onCollectionDeleteExecute

core/collection_model.go:686–743

delete hook -------------------------------------------------------------------

(e *CollectionEvent)

// -------------------------------------------------------------------

func onCollectionDeleteExecute(e *CollectionEvent) error {
	if e.Collection.System {
		return fmt.Errorf("[%s] system collections cannot be deleted", e.Collection.Name)
	}

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

	if !e.Collection.disableIntegrityChecks {
		// ensure that there aren't any existing references.
		// note: the select is outside of the transaction to prevent SQLITE_LOCKED error when mixing read&write in a single transaction
		references, err := e.App.FindCollectionReferences(e.Collection, e.Collection.Id)
		if err != nil {
			return fmt.Errorf("[%s] failed to check collection references: %w", e.Collection.Name, err)
		}
		if total := len(references); total > 0 {
			names := make([]string, 0, len(references))
			for ref := range references {
				names = append(names, ref.Name)
			}
			return fmt.Errorf("[%s] failed to delete due to existing relation references: %s", e.Collection.Name, strings.Join(names, ", "))
		}
	}

	originalApp := e.App

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

		// delete the related view or records table
		if e.Collection.IsView() {
			if err := txApp.DeleteView(e.Collection.Name); err != nil {
				return err
			}
		} else {
			if err := txApp.DeleteTable(e.Collection.Name); err != nil {
				return err
			}
		}

		if !e.Collection.disableIntegrityChecks {
			// trigger views resave to check for dependencies
			if err := resaveViewsWithChangedFields(txApp, e.Collection.Id); err != nil {
				return fmt.Errorf("[%s] failed to delete due to existing view dependency: %w", e.Collection.Name, err)
			}
		}

		// delete
		return e.Next()
	})

	e.App = originalApp

	return txErr
}