payload-automation/src/plugin/init-collection-hooks.ts

import type {Payload} from "payload"
import type {Logger} from "pino"

import type { WorkflowExecutor } from "../core/workflow-executor.js"
import type {CollectionTriggerConfigCrud, WorkflowsPluginConfig} from "./config-types.js"

export function initCollectionHooks<T extends string>(pluginOptions: WorkflowsPluginConfig<T>, payload: Payload, logger: Payload['logger'], executor: WorkflowExecutor) {
  
  if (!pluginOptions.collectionTriggers || Object.keys(pluginOptions.collectionTriggers).length === 0) {
    logger.warn('No collection triggers configured in plugin options')
    return
  }

  logger.info({
    configuredCollections: Object.keys(pluginOptions.collectionTriggers),
    availableCollections: Object.keys(payload.collections)
  }, 'Starting collection hook registration')

  // Add hooks to configured collections
  for (const [collectionSlug, triggerConfig] of Object.entries(pluginOptions.collectionTriggers)) {
    if (!triggerConfig) {
      logger.debug({collectionSlug}, 'Skipping collection with falsy trigger config')
      continue
    }

    const collection = payload.collections[collectionSlug as T]
    const crud: CollectionTriggerConfigCrud = triggerConfig === true ? {
      create: true,
      delete: true,
      read: true,
      update: true,
    } : triggerConfig

    if (!collection.config.hooks) {
      collection.config.hooks = {} as typeof collection.config.hooks
    }

    if (crud.update || crud.create) {
      collection.config.hooks.afterChange = collection.config.hooks.afterChange || []
      collection.config.hooks.afterChange.push(async (change) => {
        const operation = change.operation as 'create' | 'update'
        
        
        logger.info({
          slug: change.collection.slug,
          operation,
          docId: change.doc?.id,
          previousDocId: change.previousDoc?.id,
          hasExecutor: !!executor,
          executorType: typeof executor
        }, 'Collection automation hook triggered')

        try {
          
          // Execute workflows for this trigger
          await executor.executeTriggeredWorkflows(
            change.collection.slug,
            operation,
            change.doc,
            change.previousDoc,
            change.req
          )
          
          
          logger.info({
            slug: change.collection.slug,
            operation,
            docId: change.doc?.id
          }, 'Workflow execution completed successfully')
        } catch (error) {
          
          logger.error({
            slug: change.collection.slug,
            operation,
            docId: change.doc?.id,
            error: error instanceof Error ? error.message : 'Unknown error',
            stack: error instanceof Error ? error.stack : undefined
          }, 'AUTOMATION PLUGIN: executeTriggeredWorkflows failed')
          // Don't re-throw to avoid breaking other hooks
        }
      })
    }

    if (crud.read) {
      collection.config.hooks.afterRead = collection.config.hooks.afterRead || []
      collection.config.hooks.afterRead.push(async (change) => {
        logger.debug({
          slug: change.collection.slug,
          operation: 'read',
        }, 'Collection hook triggered')

        // Execute workflows for this trigger
        await executor.executeTriggeredWorkflows(
          change.collection.slug,
          'read',
          change.doc,
          undefined,
          change.req
        )
      })
    }

    if (crud.delete) {
      collection.config.hooks.afterDelete = collection.config.hooks.afterDelete || []
      collection.config.hooks.afterDelete.push(async (change) => {
        logger.debug({
          slug: change.collection.slug,
          operation: 'delete',
        }, 'Collection hook triggered')

        // Execute workflows for this trigger
        await executor.executeTriggeredWorkflows(
          change.collection.slug,
          'delete',
          change.doc,
          undefined,
          change.req
        )
      })
    }

    if (collection) {
      logger.info({
        collectionSlug,
        hooksRegistered: {
          afterChange: crud.update || crud.create,
          afterRead: crud.read,
          afterDelete: crud.delete
        }
      }, 'Collection hooks registered successfully')
    } else {
      logger.error({
        collectionSlug,
        availableCollections: Object.keys(payload.collections)
      }, 'Collection not found for trigger configuration - check collection slug spelling')
    }
  }
}