diff --git a/src/core/workflow-executor.ts b/src/core/workflow-executor.ts index 566b4bd..5286224 100644 --- a/src/core/workflow-executor.ts +++ b/src/core/workflow-executor.ts @@ -990,12 +990,6 @@ export class WorkflowExecutor { previousDoc: unknown, req: PayloadRequest ): Promise { - console.log('🚨 EXECUTOR: executeTriggeredWorkflows called!') - console.log('🚨 EXECUTOR: Collection =', collection) - console.log('🚨 EXECUTOR: Operation =', operation) - console.log('🚨 EXECUTOR: Doc ID =', (doc as any)?.id) - console.log('🚨 EXECUTOR: Has payload?', !!this.payload) - console.log('🚨 EXECUTOR: Has logger?', !!this.logger) this.logger.info({ collection, @@ -1029,24 +1023,11 @@ export class WorkflowExecutor { } }> - this.logger.info({ + this.logger.debug({ workflowId: workflow.id, workflowName: workflow.name, - triggerCount: triggers?.length || 0, - triggers: triggers?.map(t => ({ - type: t.type, - parameters: t.parameters, - collection: t.parameters?.collection, - collectionSlug: t.parameters?.collectionSlug, - operation: t.parameters?.operation, - // Debug matching criteria - typeMatch: t.type === 'collection-trigger', - collectionMatch: (t.parameters?.collection === collection || t.parameters?.collectionSlug === collection), - operationMatch: t.parameters?.operation === operation - })), - targetCollection: collection, - targetOperation: operation - }, 'Checking workflow triggers with detailed matching info') + triggerCount: triggers?.length || 0 + }, 'Checking workflow triggers') const matchingTriggers = triggers?.filter(trigger => trigger.type === 'collection-trigger' && @@ -1090,18 +1071,13 @@ export class WorkflowExecutor { // Check trigger condition if present if (trigger.condition) { - this.logger.info({ + this.logger.debug({ collection, operation, condition: trigger.condition, - docId: (doc as any)?.id, - docFields: doc ? Object.keys(doc) : [], - previousDocId: (previousDoc as any)?.id, workflowId: workflow.id, - workflowName: workflow.name, - docStatus: (doc as any)?.status, - previousDocStatus: (previousDoc as any)?.status - }, 'Evaluating trigger condition before execution') + workflowName: workflow.name + }, 'Evaluating trigger condition') const conditionMet = this.evaluateCondition(trigger.condition, context) diff --git a/src/plugin/index.ts b/src/plugin/index.ts index c1dab34..caf380b 100644 --- a/src/plugin/index.ts +++ b/src/plugin/index.ts @@ -145,7 +145,7 @@ export const workflowsPlugin = // CRITICAL: Modify existing collection configs BEFORE PayloadCMS processes them // This is the ONLY time we can add hooks that will actually work const logger = getConfigLogger() - logger.info('Attempting to modify collection configs before PayloadCMS initialization...') + logger.debug('Modifying collection configs...') if (config.collections && pluginOptions.collectionTriggers) { for (const [triggerSlug, triggerConfig] of Object.entries(pluginOptions.collectionTriggers)) { @@ -311,10 +311,8 @@ export const workflowsPlugin = logger.info(`Plugin configuration: ${Object.keys(pluginOptions.collectionTriggers || {}).length} collection triggers, ${pluginOptions.steps?.length || 0} steps`) // Create workflow executor instance - console.log('🚨 CREATING WORKFLOW EXECUTOR INSTANCE') + logger.debug('Creating workflow executor instance') const executor = new WorkflowExecutor(payload, logger) - console.log('🚨 EXECUTOR CREATED:', typeof executor) - console.log('🚨 EXECUTOR METHODS:', Object.getOwnPropertyNames(Object.getPrototypeOf(executor))) // Register executor with proper dependency injection setWorkflowExecutor(executor, logger) diff --git a/src/plugin/init-collection-hooks.ts b/src/plugin/init-collection-hooks.ts index 56d4462..f2b37fe 100644 --- a/src/plugin/init-collection-hooks.ts +++ b/src/plugin/init-collection-hooks.ts @@ -40,13 +40,6 @@ export function initCollectionHooks(pluginOptions: WorkflowsPl collection.config.hooks.afterChange.push(async (change) => { const operation = change.operation as 'create' | 'update' - // AGGRESSIVE LOGGING - this should ALWAYS appear - console.log('🚨 AUTOMATION PLUGIN HOOK CALLED! 🚨') - console.log('Collection:', change.collection.slug) - console.log('Operation:', operation) - console.log('Doc ID:', change.doc?.id) - console.log('Has executor?', !!executor) - console.log('Executor type:', typeof executor) logger.info({ slug: change.collection.slug, @@ -55,10 +48,9 @@ export function initCollectionHooks(pluginOptions: WorkflowsPl previousDocId: change.previousDoc?.id, hasExecutor: !!executor, executorType: typeof executor - }, 'AUTOMATION PLUGIN: Collection hook triggered') + }, 'Collection automation hook triggered') try { - console.log('🚨 About to call executeTriggeredWorkflows') // Execute workflows for this trigger await executor.executeTriggeredWorkflows( @@ -69,15 +61,13 @@ export function initCollectionHooks(pluginOptions: WorkflowsPl change.req ) - console.log('🚨 executeTriggeredWorkflows completed without error') logger.info({ slug: change.collection.slug, operation, docId: change.doc?.id - }, 'AUTOMATION PLUGIN: executeTriggeredWorkflows completed successfully') + }, 'Workflow execution completed successfully') } catch (error) { - console.log('🚨 AUTOMATION PLUGIN ERROR:', error) logger.error({ slug: change.collection.slug, diff --git a/src/plugin/init-webhook.ts b/src/plugin/init-webhook.ts index f47fa27..3ffc1df 100644 --- a/src/plugin/init-webhook.ts +++ b/src/plugin/init-webhook.ts @@ -7,8 +7,7 @@ export function initWebhookEndpoint(config: Config, webhookPrefix = 'webhook'): const logger = getConfigLogger() // Ensure the prefix starts with a slash const normalizedPrefix = webhookPrefix.startsWith('/') ? webhookPrefix : `/${webhookPrefix}` - logger.debug(`Adding webhook endpoint to config with prefix: ${normalizedPrefix}`) - logger.debug('Current config.endpoints length:', config.endpoints?.length || 0) + logger.debug(`Adding webhook endpoint: ${normalizedPrefix}`) // Define webhook endpoint const webhookEndpoint = { @@ -172,7 +171,7 @@ export function initWebhookEndpoint(config: Config, webhookPrefix = 'webhook'): // Combine existing endpoints with the webhook endpoint config.endpoints = [...(config.endpoints || []), webhookEndpoint] logger.debug(`Webhook endpoint added at path: ${webhookEndpoint.path}`) - logger.debug('New config.endpoints length:', config.endpoints.length) + logger.debug('Webhook endpoint added') } else { logger.debug(`Webhook endpoint already exists at path: ${webhookEndpoint.path}`) }