<?php
namespace JVBase\integrations;

use JVBase\meta\Meta;
use JVBase\meta\Sanitizer;
use JVBase\registrar\Registrar;

if (!defined('ABSPATH')) {
	exit;
}

trait SyncToUser
{
	use SyncTo, SyncHelpers, UserConnection;

	public function addSaveUser():void
	{
		if (empty($this->syncUsers)) {
			return;
		}
		if (!has_action('profile_update', [$this, 'handleUpdateUser'])) {
			add_action('profile_update', [$this, 'handleUpdateUser'], 20, 1);
		}
		if (!has_action('user_register', [$this, 'handleUpdateUser'])) {
			add_action('user_register', [$this, 'handleUpdateUser'], 20, 1);
		}
	}
	public function removeSaveUser():void
	{
		if (empty($this->syncUsers)) {
			return;
		}
		remove_action('profile_update', [$this, 'handleUpdateUser'], 20);
		remove_action('user_register', [$this, 'handleUpdateUser'], 20);
	}
	protected function handleUpdateUser(int $userID):void
	{
		$user = $this->getOrCreateUser($userID);
		if (!$user) {
			return;
		}

		$fields = $this->getSyncFields($userID, 'user');
		if (!empty($fields["_{$this->service_name}_item_id"])) {
			return;
		}

		$this->removeSaveUser();
		$this->handleTheSaveUser($userID);
		$this->addSaveUser();
	}

	protected function getOrCreateUser(int $userID):string|false
	{
		$user = get_userdata($userID);
		if (!$user || is_wp_error($user)) {
			return false;
		}
		$role = jvbUserRole($userID);
		if (!in_array(jvbNoBase($role), $this->syncUsers)) {
			return false;
		}
		$fields = $this->getSyncFields($userID, 'user');
		if (!empty($fields["_{$this->service_name}_item_id"])) {
			return $fields["_{$this->service_name}_item_id"];
		}

		$meta = Meta::forUser($userID);
		$serviceUserID = $this->searchServiceForUser($user->user_email??'');
		if ($serviceUserID) {
			$meta->set("{$this->service_name}_item_id", $serviceUserID);
			return $serviceUserID;
		}

		$created = $this->createServiceUser($userID, $fields);
		if ($created) {
			return $created;
		}
		return false;
	}
	public function searchServiceForUser(string $email):string|false
	{
		if (!filter_var($email, FILTER_VALIDATE_EMAIL)) {
			return false;
		}
		return $this->handleEmailSearch($email);
	}

	/**
	 * Searches for existing user from sanitized email
	 * @param string $email
	 * @return string|false The found service's User ID or false on failure
	 */
	abstract public function handleEmailSearch(string $email):string|false;

	public function createServiceUser(int $userID, array $fields):string|false
	{
		$checked = $this->validateUserFields($userID, $fields);
		$response = $this->handleCreateUser($checked);
		if ($response['success'] && !empty($response['data'])) {
			$meta = Meta::forUser($userID);
			$meta->set("{$this->service_name}_item_id", $response['data']['id']);
		}
		return $response['success'] ? $response['data']['id']??false : false;
	}

	protected function validateUserFields(int $userID, array $fields):array|false
	{
		foreach ($fields as $f => $v) {
			$v = match ($f) {
				'email' => filter_var($v, FILTER_SANITIZE_EMAIL),
				'phone' => Sanitizer::sanitizePhone($v),
				default => sanitize_text_field($v),
			};
			if (empty($v) && in_array($f, $this->requiredUserFields())) {
				return false;
			}
			$fields[$f] = $v;
		}
		return $fields;
	}
	protected function requiredUserFields():array
	{
		return [];
	}

	/**
	 * @param array $data User Data
	 * @return array The created user ID or false on failure
	 */
	abstract protected function handleCreateUser(array $data):array;

	/**
	 * @param int $userID
	 * @return void
	 */
	protected function handleTheSaveUser(int $userID):void
	{
		error_log('==== ['.$this->title.']::handleTheSaveUser ====');
		//TODO: This is likely only for stuff like customers.
		//If we have multiple stores connected, we may have to queue operations to update every connection's customer account if they made an order with that store
		$role = jvbUserRole($userID);
		$registrar = Registrar::getInstance($role);
		if (!$registrar || !$registrar->hasIntegration($this->service_name)) {
			return;
		}

		$this->queueOperation(self::$syncTo, [
			'users'	=> [$userID],
		]);
	}

	public function addDeleteUser():void
	{
		if (!has_action('delete_user', [$this, 'handleDeleteTerm'])) {
			add_action('delete_user', [$this, 'handleDeleteTerm']);
		}
	}
	public function removeDeleteUser():void
	{
		remove_action('delete_user', [$this, 'handleDeleteTerm']);
	}
	public function handleDeleteUser(int $userID):void
	{
		if (!$this->canSync['delete']) {
			return;
		}

		$fields = $this->getSyncFields($userID, 'user');
		if (empty($fields["_{$this->service_name}_item_id"])) {
			return;
		}
		JVB()->queue()->add(
			self::$deleteFrom,
			0,
			[
				'fields'	=> [$userID => $fields],
				'service'	=> $this->service_name,
				'type'		=> 'user'
			]
		);
	}
}