Changeset 3789172 for subtleforms/trunk/src/Async/AsyncDispatcher.php

Timestamp:

11/07/2026 08:16:35 AM (10 hours ago)

Author:

subtleforms

Message:

SubtleForms 2.8.0

File:

• subtleforms/trunk/src/Async/AsyncDispatcher.php (modified) (1 diff)

subtleforms/trunk/src/Async/AsyncDispatcher.php

@@ -145 +145 @@
 
                 return true;
+        }
+
+        /**
+         * Queue an email marketing job for an entry and one service.
+         *
+         * The job carries the entry ID, never the answers: they are read back
+         * from the entry when the job runs.
+         *
+         * @param array $job   { service, submission_id, form_id, retry_count, feeds }.
+         * @param int   $delay Seconds until it runs.
+         * @return bool True if the job was scheduled.
+         */
+        public static function dispatchEmailMarketing( array $job, int $delay = 0 ): bool {
+                if ( empty( $job['submission_id'] ) || empty( $job['service'] ) ) {
+                        self::log( 'Email marketing dispatch failed: missing entry or service' );
+                        return false;
+                }
+                $job['dispatch_id'] = self::dispatchId();
+                $scheduled          = wp_schedule_single_event( time() + max( 0, $delay ), 'subtleforms_async_email_marketing', array( $job ) );
+                if ( false === $scheduled ) {
+                        self::log( 'Failed to schedule email marketing job', array( 'submission_id' => $job['submission_id'], 'service' => $job['service'] ) );
+                        return false;
+                }
+                return true;
+        }
+
+        /**
+         * Execute an email marketing job (called by WP Cron).
+         *
+         * @param array $job Job from dispatchEmailMarketing().
+         * @return void
+         */
+        public static function executeEmailMarketing( array $job ): void {
+                \SubtleForms\Integrations\EmailMarketing\Sender::run( $job );
         }