Elementor #2722 - Door of Clubs

File Manager

Current Directory: wp-content/plugins/wpforms/src/Pro/Tasks/Actions

Linux appserver-0d5e4f1e-php-cc8da225320a42ba9b7d66cba40b1f03 6.6.123+ #1 SMP PREEMPT_DYNAMIC Wed Mar 11 09:04:28 UTC 2026 x86_64

Edit File: EntryEmailCSVCleanupTask.php

<?php

namespace WPForms\Pro\Tasks\Actions;

use WPForms\Pro\Admin\Builder\Notifications\Advanced\EntryCsvAttachment;
use WPForms\Tasks\Meta;
use WPForms\Tasks\Task;

/**
 * Class EntryEmailCSVCleanupTask.
 *
 * @since 1.7.7
 */
class EntryEmailCSVCleanupTask extends Task {

/**
	 * Chunk size to use when processing CSV files to delete.
	 *
	 * @since 1.7.7
	 *
	 * @var int
	 */
	const CHUNK_SIZE = 50;

/**
	 * Scan action name for this task.
	 *
	 * @since 1.7.7
	 *
	 * @var string
	 */
	const SCAN_ACTION = 'wpforms_process_entry_emails_csv_scan';

/**
	 * Cleanup action name for this task.
	 *
	 * @since 1.7.7
	 *
	 * @var string
	 */
	const CLEANUP_ACTION = 'wpforms_process_entry_emails_csv_cleanup';

/**
	 * Cleanup status option name.
	 *
	 * @since 1.7.7
	 *
	 * @var string
	 */
	const CLEANUP_STATUS = 'wpforms_process_entry_emails_csv_cleanup_status';

/**
	 * Cleanup status "In Progress".
	 *
	 * @since 1.7.7
	 *
	 * @var string
	 */
	const CLEANUP_STATUS_IN_PROGRESS = 'in progress';

/**
	 * Cleanup status "Completed".
	 *
	 * @since 1.7.7
	 *
	 * @var string
	 */
	const CLEANUP_STATUS_COMPLETED = 'completed';

/**
	 * CSV File TTL value.
	 *
	 * @since 1.7.7
	 *
	 * @var int
	 */
	const ENTRY_CSV_DEFAULT_TTL = DAY_IN_SECONDS;

/**
	 * Class constructor.
	 *
	 * @since 1.7.7
	 */
	public function __construct() {

parent::__construct( self::SCAN_ACTION );

$this->init();
	}

/**
	 * Initialize.
	 *
	 * @since 1.7.7
	 */
	private function init() {

$this->hooks();
	}

/**
	 * Add hooks.
	 *
	 * @since 1.7.7
	 */
	private function hooks() {

add_action( self::SCAN_ACTION, [ $this, 'scan' ] );
		add_action( self::CLEANUP_ACTION, [ $this, 'cleanup' ] );
		add_action( 'action_scheduler_after_process_queue', [ $this, 'after_process_queue' ] );
		add_action( 'wpforms_attach_entry_csv_in_email_complete', [ $this, 'create_cleanup_task' ] );
	}

/**
	 * Scan the Entry Attachment CSV parent folder for CSV files.
	 *
	 * @since 1.7.7
	 */
	public function scan() {

$tasks = wpforms()->obj( 'tasks' );

if ( ! $tasks ) {
			return;
		}

// Bail out if cleanup is already in progress.
		if ( self::CLEANUP_STATUS_IN_PROGRESS === (string) get_option( self::CLEANUP_STATUS ) ) {
			return;
		}

$upload_dir = wpforms_upload_dir();

if ( ! empty( $upload_dir['error'] ) ) {
			// Log here.
			return;
		}

// First we want to scan the directory.
		$directory = $upload_dir['path'] . '/' . EntryCsvAttachment::FOLDER_NAME;

$files = glob( "$directory/*/*.csv" );

if ( empty( $files ) ) {
			return;
		}

// Mark the cleanup is in progress.
		update_option( self::CLEANUP_STATUS, self::CLEANUP_STATUS_IN_PROGRESS );

/**
		 * We chunk the cleanup tasks to account for potential memory/resource issue.
		 */
		$file_chunks = array_chunk( $files, self::CHUNK_SIZE, true );
		$count       = count( $file_chunks );

foreach ( $file_chunks as $index => $file_chunk ) {
			$tasks->create( self::CLEANUP_ACTION )->async()->params( $file_chunk, $index, $count )->register();
		}

$this->log( 'Cleanup task(s) created.' );
	}

/**
	 * Cleanup action.
	 *
	 * Delete CSV files that expired there TTL.
	 *
	 * @since 1.7.7
	 *
	 * @param int $meta_id Action meta id.
	 */
	public function cleanup( $meta_id ) {

$params = ( new Meta() )->get( $meta_id );

if ( ! $params ) {
			return;
		}

list( $file_chunk, $index, $count ) = $params->data;

if ( empty( $file_chunk ) ) {
			return;
		}

/**
		 * Give developers an ability to modify CSV TTL.
		 *
		 * @since 1.7.7
		 *
		 * @param int $ttl TTL of CSV files.
		 */
		$ttl = (int) apply_filters( 'wpforms_pro_tasks_actions_entry_email_csv_cleanup_task_ttl', self::ENTRY_CSV_DEFAULT_TTL );

$now = time();

foreach ( $file_chunk as $file ) {
			$this->attempt_to_delete_csv( $file, $now, $ttl );
		}

$this->log(
			sprintf(
				'Cleanup action %1$d/%2$d is done.',
				$index + 1,
				$count
			)
		);
	}

/**
	 * Attempt to delete a CSV file and it's directory.
	 *
	 * @since 1.7.7
	 *
	 * @param string $file     File path to delete.
	 * @param int    $time_now Current Unix timestamp.
	 * @param int    $ttl      TTL of the file.
	 */
	private function attempt_to_delete_csv( $file, $time_now, $ttl ) {

clearstatcache( true, $file );

if ( ! is_file( $file ) ) {
			return;
		}

$path_info = pathinfo( $file );

if (
			strtolower( $path_info['extension'] ) !== 'csv' ||
			( $time_now - filemtime( $file ) ) < $ttl
		) {
			return;
		}

// We want to hide the first part of the path in the logs for security purposes.
		$wpforms_upload_dir = wpforms_upload_dir();
		$remove_path_string = wp_normalize_path( WP_CONTENT_DIR );

if ( empty( $wpforms_upload_dir['error'] ) ) {
			$remove_path_string = $wpforms_upload_dir['path'];
		}

// Delete the file.
		// phpcs:ignore WordPress.WP.AlternativeFunctions.unlink_unlink
		if ( ! unlink( $file ) ) {
			$this->log(
				sprintf(
					'Cleanup action unable to delete the file: %s.',
					str_replace( $remove_path_string, '', $file )
				)
			);

return;
		}

// phpcs:ignore WordPress.WP.AlternativeFunctions.file_system_operations_rmdir
		if ( ! rmdir( $path_info['dirname'] ) ) {
			$this->log(
				sprintf(
					'Cleanup action unable to delete the directory: %s.',
					str_replace( $remove_path_string, '', $path_info['dirname'] )
				)
			);
		}
	}

/**
	 * After process queue action.
	 *
	 * @since 1.7.7
	 */
	public function after_process_queue() {

if ( wpforms()->obj( 'tasks' )->is_scheduled( self::CLEANUP_ACTION ) ) {
			return;
		}

// Mark that cleanup is finished.
		if ( (string) get_option( self::CLEANUP_STATUS ) === self::CLEANUP_STATUS_IN_PROGRESS ) {
			update_option( self::CLEANUP_STATUS, self::CLEANUP_STATUS_COMPLETED );
			$this->log( 'Cleanup task(s) completed.' );
		}
	}

/**
	 * Log message to WPForms logger and standard debug.log file.
	 *
	 * @since 1.7.7
	 *
	 * @param string $message The error message that should be logged.
	 */
	protected function log( $message ) {

if ( defined( 'WPFORMS_DEBUG' ) && WPFORMS_DEBUG ) {
			// phpcs:ignore WordPress.PHP.DevelopmentFunctions.error_log_error_log
			error_log( sprintf( 'Entry CSV Attachment: %s', $message ) );
			wpforms_log( 'Entry CSV Attachment', $message, [ 'type' => 'log' ] );
		}
	}

/**
	 * Create cleanup task.
	 *
	 * @since 1.7.7
	 *
	 * @param array $email_data Email data used on the email sent.
	 */
	public function create_cleanup_task( $email_data ) {

$tasks = wpforms()->obj( 'tasks' );

if ( $tasks->is_scheduled( self::SCAN_ACTION ) ) {
			return;
		}

/**
		 * Filters the Entry CSV Attachment cleanup interval.
		 *
		 * @since 1.7.7
		 *
		 * @param int $interval Interval in seconds.
		 */
		$interval = (int) apply_filters( 'wpforms_pro_tasks_actions_entry_email_csv_cleanup_task_interval', DAY_IN_SECONDS );

$tasks->create( self::SCAN_ACTION )
			->recurring( time() + 60, $interval )
			->params()
			->register();
	}
}

Upload File

Directory Listing

Name	Type	Size	Actions
.. (Parent Directory)	Dir
EntryEmailCSVCleanupTask.php	File	6.79 KB	Rename \| Delete \| Edit
Migration176Task.php	File	5.69 KB	Rename \| Delete \| Edit
Migration190Task.php	File	5.51 KB	Rename \| Delete \| Edit
MigrationPaymentEntriesTask.php	File	14.45 KB	Rename \| Delete \| Edit
PurgeTemplateEntryTask.php	File	3.42 KB	Rename \| Delete \| Edit

File Manager

Edit File: EntryEmailCSVCleanupTask.php

Upload File

Directory Listing

Resources

Company

Office