<?php
/**
 * Email automation repository.
 *
 * @package Bookingistic
 */

namespace Bookingistic\Database;

defined( 'ABSPATH' ) || exit;

class Email_Automation_Repository {

	public static function table(): string {
		return Tables::email_automations_table();
	}

	public static function all(): array {
		global $wpdb;
		$cache_key = Cache::key( 'automation_all', [], [ Cache::EMAIL_AUTOMATIONS ] );
		$rows = wp_cache_get( $cache_key, Cache::EMAIL_AUTOMATIONS, false, $cache_found );
		if ( ! $cache_found ) {
			// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery -- Plugin's own custom table; the result is object-cached (wp_cache_set below) and invalidated on every write.
			$rows = $wpdb->get_results( $wpdb->prepare( 'SELECT * FROM %i ORDER BY trigger_event ASC, name ASC', self::table() ), ARRAY_A );
			wp_cache_set( $cache_key, $rows, Cache::EMAIL_AUTOMATIONS );
		}
		return array_map( [ self::class, 'normalize' ], $rows ?: [] );
	}

	public static function find( int $id ): ?array {
		global $wpdb;
		$cache_key = Cache::key( 'automation_find', [ $id ], [ Cache::EMAIL_AUTOMATIONS ] );
		$row = wp_cache_get( $cache_key, Cache::EMAIL_AUTOMATIONS, false, $cache_found );
		if ( ! $cache_found ) {
			// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery -- Plugin's own custom table; the result is object-cached (wp_cache_set below) and invalidated on every write.
			$row = $wpdb->get_row(
				$wpdb->prepare( 'SELECT * FROM %i WHERE id = %d', self::table(), $id ),
				ARRAY_A
			);
			wp_cache_set( $cache_key, $row, Cache::EMAIL_AUTOMATIONS );
		}
		return $row ? self::normalize( $row ) : null;
	}

	public static function for_trigger( string $event, int $service_id = 0 ): array {
		global $wpdb;
		$cache_key = Cache::key( 'automation_for_trigger', [ $event, $service_id ], [ Cache::EMAIL_AUTOMATIONS ] );
		$rows = wp_cache_get( $cache_key, Cache::EMAIL_AUTOMATIONS, false, $cache_found );
		if ( ! $cache_found ) {
			// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery -- Plugin's own custom table; the result is object-cached (wp_cache_set below) and invalidated on every write.
			$rows = $wpdb->get_results(
				$wpdb->prepare(
					"SELECT * FROM %i
					WHERE status = 'active'
					AND trigger_event = %s
					AND (service_id = 0 OR service_id = %d)
					ORDER BY service_id DESC",
					self::table(),
					$event,
					$service_id
				),
				ARRAY_A
			);
			wp_cache_set( $cache_key, $rows, Cache::EMAIL_AUTOMATIONS );
		}
		return array_map( [ self::class, 'normalize' ], $rows ?: [] );
	}

	public static function create( array $data ) {
		global $wpdb;
		$now    = current_time( 'mysql', true );
		$insert = [
			'name'             => sanitize_text_field( $data['name'] ?? __( 'Untitled automation', 'bookingistic' ) ),
			'trigger_event'    => sanitize_key( $data['trigger_event'] ?? 'booking_confirmed' ),
			'recipient_type'   => sanitize_key( $data['recipient_type'] ?? 'customer' ),
			'recipient_custom' => sanitize_email( $data['recipient_custom'] ?? '' ),
			'delay_amount'     => max( 0, (int) ( $data['delay_amount'] ?? 0 ) ),
			'delay_unit'       => sanitize_key( $data['delay_unit'] ?? 'minutes' ),
			'subject'          => sanitize_text_field( $data['subject'] ?? '' ),
			'body'             => wp_kses_post( $data['body'] ?? '' ),
			'service_id'       => (int) ( $data['service_id'] ?? 0 ),
			'status'           => sanitize_key( $data['status'] ?? 'active' ),
			'created_at'       => $now,
			'updated_at'       => $now,
		];
		// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery -- Write to the plugin's own custom table; its cache group is invalidated right after.
		$ok = $wpdb->insert( self::table(), $insert );
		wp_cache_delete( 'last_changed', Cache::EMAIL_AUTOMATIONS );
		if ( false === $ok ) {
			return new \WP_Error( 'automation_insert_failed', __( 'Could not create automation.', 'bookingistic' ) );
		}
		return self::find( (int) $wpdb->insert_id );
	}

	public static function delete( int $id ): bool {
		global $wpdb;
		// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery -- Write to the plugin's own custom table; its cache group is invalidated right after.
		$result = (bool) $wpdb->delete( self::table(), [ 'id' => $id ], [ '%d' ] );
		wp_cache_delete( 'last_changed', Cache::EMAIL_AUTOMATIONS );
		return $result;
	}

	public static function update( int $id, array $data ) {
		global $wpdb;
		$now    = current_time( 'mysql', true );
		$update = [ 'updated_at' => $now ];

		$map = [
			'name'             => 'sanitize_text_field',
			'trigger_event'    => 'sanitize_key',
			'recipient_type'   => 'sanitize_key',
			'recipient_custom' => 'sanitize_email',
			'delay_unit'       => 'sanitize_key',
			'subject'          => 'sanitize_text_field',
			'status'           => 'sanitize_key',
		];
		foreach ( $map as $field => $cb ) {
			if ( array_key_exists( $field, $data ) ) {
				$update[ $field ] = call_user_func( $cb, $data[ $field ] );
			}
		}
		if ( array_key_exists( 'body', $data ) ) {
			$update['body'] = wp_kses_post( $data['body'] );
		}
		foreach ( [ 'delay_amount', 'service_id' ] as $int_field ) {
			if ( array_key_exists( $int_field, $data ) ) {
				$update[ $int_field ] = (int) $data[ $int_field ];
			}
		}
		// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery -- Write to the plugin's own custom table; its cache group is invalidated right after.
		$wpdb->update( self::table(), $update, [ 'id' => $id ] );
		wp_cache_delete( 'last_changed', Cache::EMAIL_AUTOMATIONS );
		return self::find( $id );
	}

	public static function normalize( array $row ): array {
		$row['id']           = (int) $row['id'];
		$row['delay_amount'] = (int) $row['delay_amount'];
		$row['service_id']   = (int) $row['service_id'];
		return $row;
	}
}