<?php

namespace XF\Repository;

use XF\ChangeLog\AbstractHandler;
use XF\Entity\ChangeLog;
use XF\Finder\ChangeLogFinder;
use XF\Mvc\Entity\AbstractCollection;
use XF\Mvc\Entity\Repository;
use XF\PrintableException;

use function strval;

class ChangeLogRepository extends Repository
{
	/**
	 * @param string $contentType
	 * @param int $contentId
	 *
	 * @return ChangeLogFinder
	 */
	public function findChangeLogsByContent($contentType, $contentId)
	{
		return $this->finder(ChangeLogFinder::class)
			->where(['content_type' => $contentType, 'content_id' => $contentId])
			->with('EditUser')
			->setDefaultOrder('edit_date', 'DESC');
	}

	/**
	 * @param string $contentType
	 *
	 * @return ChangeLogFinder
	 */
	public function findChangeLogsByContentType($contentType)
	{
		return $this->finder(ChangeLogFinder::class)
			->where('content_type', $contentType)
			->with('EditUser')
			->setDefaultOrder('edit_date', 'DESC');
	}

	public function countChangeLogsSince($contentType, $contentId, $field, $cutOff)
	{
		return $this->db()->fetchOne("
			SELECT COUNT(*)
			FROM xf_change_log
			WHERE content_type = ?
				AND content_id = ?
				AND field = ?
				AND edit_date >= ?
		", [$contentType, $contentId, $field, $cutOff]);
	}

	public function groupChangeLogs($changes)
	{
		$grouped = [];

		/** @var ChangeLog $change */
		foreach ($changes AS $key => $change)
		{
			$groupKey = "{$change->content_type}-{$change->content_id}-{$change->edit_user_id}-{$change->edit_date}";
			if (!isset($grouped[$groupKey]))
			{
				$grouped[$groupKey] = [
					'content_type' => $change->content_type,
					'content_id' => $change->content_id,
					'date' => $change->edit_date,
					'content' => $change->Content,
					'editUser' => $change->EditUser,
					'changes' => [],
					'changesRaw' => [],
				];
			}

			$grouped[$groupKey]['changes'][$key] = $change->DisplayEntry;
			$grouped[$groupKey]['changesRaw'][$key] = $change;
		}

		return $grouped;
	}

	public function logChange($contentType, $contentId, $column, $oldValue, $newValue, $editByUserId)
	{
		return $this->logHistoricalChange($contentType, $contentId, $column, $oldValue, $newValue, $editByUserId);
	}

	public function logHistoricalChange($contentType, $contentId, $column, $oldValue, $newValue, $editByUserId, $editDate = null)
	{
		$inserts = $this->logChanges($contentType, $contentId, [$column => [$oldValue, $newValue, $editDate]], $editByUserId);
		return $inserts ? null : reset($inserts);
	}

	/**
	 * @param       $contentType
	 * @param       $contentId
	 * @param array $changes Should be of the form [column => [old, new, (optional)edit_date]
	 * @param       $editByUserId
	 *
	 * @return array
	 * @throws PrintableException
	 */
	public function logChanges($contentType, $contentId, array $changes, $editByUserId)
	{
		$em = \XF::em();
		$inserted = [];

		\XF::db()->beginTransaction();

		foreach ($changes AS $field => $change)
		{
			[$old, $new] = $change;
			$old = strval($old);
			$new = strval($new);
			if ($old === $new)
			{
				continue;
			}

			$date = empty($change[2]) ? \XF::$time : $change[2];

			/** @var ChangeLog $entry */
			$entry = $em->create(ChangeLog::class);
			$entry->bulkSet([
				'content_type' => $contentType,
				'content_id' => $contentId,
				'edit_user_id' => $editByUserId,
				'edit_date' => $date,
				'field' => $field,
				'old_value' => $old,
				'new_value' => $new,
			]);

			$handler = $entry->getHandler();
			if ($handler)
			{
				$entry->protected = $handler->isFieldProtected($field);
			}

			if ($entry->save(true, false))
			{
				$inserted[] = $entry;
			}
		}

		\XF::db()->commit();

		return $inserted;
	}

	public function pruneChangeLogs($cutOff = null)
	{
		if ($cutOff === null)
		{
			$length = $this->options()->changeLogLength;
			if (!$length)
			{
				return 0;
			}

			$cutOff = \XF::$time - 86400 * $length;
		}

		return $this->db()->delete('xf_change_log', 'edit_date < ? AND protected = 0', $cutOff);
	}

	/**
	 * @return AbstractHandler[]
	 */
	public function getChangeLogHandlers()
	{
		$handlers = [];

		foreach (\XF::app()->getContentTypeField('change_log_handler_class') AS $contentType => $handlerClass)
		{
			if (class_exists($handlerClass))
			{
				$handlerClass = \XF::extendClass($handlerClass);
				$handlers[$contentType] = new $handlerClass($contentType);
			}
		}

		return $handlers;
	}

	/**
	 * @param string $type
	 * @param bool $throw
	 *
	 * @return AbstractHandler|null
	 */
	public function getChangeLogHandler($type, $throw = false)
	{
		$handlerClass = \XF::app()->getContentTypeFieldValue($type, 'change_log_handler_class');
		if (!$handlerClass)
		{
			if ($throw)
			{
				throw new \InvalidArgumentException("No change log handler for '$type'");
			}
			return null;
		}

		if (!class_exists($handlerClass))
		{
			if ($throw)
			{
				throw new \InvalidArgumentException("Change log handler for '$type' does not exist: $handlerClass");
			}
			return null;
		}

		$handlerClass = \XF::extendClass($handlerClass);
		return new $handlerClass($type);
	}

	/**
	 * @param AbstractCollection<ChangeLog>|array<int, ChangeLog> $logs
	 */
	public function addDataToLogs($logs)
	{
		$contentMap = [];
		$displayMap = [];
		foreach ($logs AS $key => $log)
		{
			$contentType = $log->content_type;
			if (!isset($contentMap[$contentType]))
			{
				$contentMap[$contentType] = [];
				$displayMap[$contentType] = [];
			}
			$contentMap[$contentType][$key] = $log->content_id;
			$displayMap[$contentType][] = $key;
		}

		foreach ($contentMap AS $contentType => $contentIds)
		{
			$handler = $this->getChangeLogHandler($contentType);
			if (!$handler)
			{
				continue;
			}
			$data = $handler->getContent($contentIds);
			foreach ($contentIds AS $alertId => $contentId)
			{
				$content = $data[$contentId] ?? null;
				$logs[$alertId]->setContent($content);
			}

			foreach ($displayMap[$contentType] AS $changeId)
			{
				$log = $logs[$changeId];
				$display = $handler->getDisplayEntry($log);
				$log->setDisplayEntry($display);
			}
		}
	}
}
