<?php
/**
 * Journal retention.
 *
 * @package Recast\WCS
 */

namespace Recast\WCS\Journal;

use Recast\WCS\Admin\Settings;
use Recast\WCS\Install\Schema;
use Recast\WCS\Run\RunRepository;
use Recast\WCS\Run\RunStatus;

defined( 'ABSPATH' ) || exit;

/**
 * Purges items and events of old applied runs (the run row and its summary are kept). Runs on recast_cleanup.
 */
final class Retention {

	/**
	 * Hooks.
	 *
	 * @return void
	 */
	public static function register() {
		add_action(
			'recast_cleanup',
			static function () {
				self::run();
			}
		);
	}

	/**
	 * One pass.
	 *
	 * @return int Runs purged.
	 */
	public static function run() {
		global $wpdb;
		$days = (int) Settings::get( 'recast_journal_retention_days' );
		if ( $days <= 0 ) {
			return 0;
		}
		$runs   = Schema::table( 'runs' );
		$cutoff = gmdate( 'Y-m-d H:i:s', time() - $days * DAY_IN_SECONDS );
		$in     = "'" . implode( "','", array_map( 'esc_sql', RunStatus::applied() ) ) . "'";
		$ids    = $wpdb->get_col( $wpdb->prepare( "SELECT id FROM %i WHERE status IN ({$in}) AND finished_at IS NOT NULL AND finished_at < %s AND (summary NOT LIKE %s) LIMIT 50", $runs, $cutoff, '%items_purged_at%' ) ); // phpcs:ignore WordPress.DB, PluginCheck.Security.DirectDB -- Recast-owned table, prepared query.
		$repo   = new RunRepository();
		$count  = 0;
		foreach ( $ids as $id ) {
			$wpdb->delete( Schema::table( 'run_items' ), array( 'run_id' => (int) $id ) ); // phpcs:ignore WordPress.DB, PluginCheck.Security.DirectDB -- Recast-owned table, prepared query.
			$wpdb->delete( Schema::table( 'run_events' ), array( 'run_id' => (int) $id ) ); // phpcs:ignore WordPress.DB, PluginCheck.Security.DirectDB -- Recast-owned table, prepared query.
			$repo->patch_summary( (int) $id, array( 'items_purged_at' => current_time( 'mysql', true ) ) );
			++$count;
		}
		return $count;
	}
}