Function recordRefHooks

core/auth_origin_model.go:146–239

------------------------------------------------------------------- recordRefHooks registers common hooks that are usually used with record proxies that have polymorphic record relations (aka. "collectionRef" and "recordRef" fields).

(app App, collectionName string, optCollectionTypes ...string)

// recordRefHooks registers common hooks that are usually used with record proxies
// that have polymorphic record relations (aka. "collectionRef" and "recordRef" fields).
func recordRefHooks[T RecordProxy](app App, collectionName string, optCollectionTypes ...string) {
	app.OnRecordValidate(collectionName).Bind(&hook.Handler[*RecordEvent]{
		Func: func(e *RecordEvent) error {
			collectionId := e.Record.GetString("collectionRef")
			err := validation.Validate(collectionId, validation.Required, validation.By(validateCollectionId(e.App, optCollectionTypes...)))
			if err != nil {
				return validation.Errors{"collectionRef": err}
			}

			recordId := e.Record.GetString("recordRef")
			err = validation.Validate(recordId, validation.Required, validation.By(validateRecordId(e.App, collectionId)))
			if err != nil {
				return validation.Errors{"recordRef": err}
			}

			return e.Next()
		},
		Priority: 99,
	})

	// delete on collection ref delete
	app.OnCollectionDeleteExecute().Bind(&hook.Handler[*CollectionEvent]{
		Func: func(e *CollectionEvent) error {
			if e.Collection.Name == collectionName || (len(optCollectionTypes) > 0 && !slices.Contains(optCollectionTypes, e.Collection.Type)) {
				return e.Next()
			}

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

				if err := e.Next(); err != nil {
					return err
				}

				rels, err := txApp.FindAllRecords(collectionName, dbx.HashExp{"collectionRef": e.Collection.Id})
				if err != nil {
					return err
				}

				for _, mfa := range rels {
					if err := txApp.Delete(mfa); err != nil {
						return err
					}
				}

				return nil
			})
			e.App = originalApp

			return txErr
		},
		Priority: 99,
	})

	// delete on record ref delete
	app.OnRecordDeleteExecute().Bind(&hook.Handler[*RecordEvent]{
		Func: func(e *RecordEvent) error {