<?php

namespace RainLoop\Providers\AddressBook;

use SnappyMail\DAV\Client as DAVClient;

trait CardDAV
{
	private $aDAVConfig = ['Mode' => 0];

	public function setDAVClientConfig(?array $aConfig)
	{
		if (isset($aConfig['User'], $aConfig['Password'], $aConfig['Url']) && !empty($aConfig['Mode'])) {
			$this->aDAVConfig = $aConfig;
		} else {
			$this->aDAVConfig = ['Mode' => 0];
		}
	}

	protected function isDAVReadWrite()
	{
		return 1 == $this->aDAVConfig['Mode'];
	}

	protected function prepareDavSyncData(DAVClient $oClient, string $sPath)
	{
		$mResult = false;
		$aResponse = null;
		try
		{
			$aResponse = $oClient->propFind($sPath, array(
				'{DAV:}getlastmodified',
				'{DAV:}resourcetype',
				'{DAV:}getetag'
			), 1);
		}
		catch (\Throwable $oException)
		{
			$this->logException($oException);
		}

		/**
		 * find every <response><href>*.vcf</href> with empty <resourcetype/>
		 */
		if (\is_array($aResponse)) {
			$mResult = array();
			foreach ($aResponse as $sKey => $aItem) {
				$sKey = \rtrim(\trim($sKey), '\\/');
				if (!empty($sKey) && is_array($aItem)) {
					if (isset($aItem['{DAV:}getetag'])) {
						$aMatch = array();
						if (\preg_match('/\/([^\/?]+)$/', $sKey, $aMatch) && !empty($aMatch[1])
						 && !static::hasDAVCollection($aItem))
						{
							$sVcfFileName = \urldecode(\urldecode($aMatch[1]));
							$sKeyID = \preg_replace('/\.vcf$/i', '', $sVcfFileName);

							$mResult[$sKeyID] = array(
								'deleted' => false,
								'uid' => $sKeyID,
								'vcf' => $sVcfFileName,
								'etag' => \trim(\trim($aItem['{DAV:}getetag']), '"\''),
								'lastmodified' => '',
								'changed' => 0
							);

							if (isset($aItem['{DAV:}getlastmodified'])) {
								$mResult[$sKeyID]['lastmodified'] = $aItem['{DAV:}getlastmodified'];
								$mResult[$sKeyID]['changed'] = \MailSo\Base\DateTimeHelper::ParseRFC2822DateString(
									$aItem['{DAV:}getlastmodified']);
							} else {
								$mResult[$sKeyID]['changed'] = \MailSo\Base\DateTimeHelper::TryToParseSpecEtagFormat($mResult[$sKeyID]['etag']);
								$mResult[$sKeyID]['lastmodified'] = 0 < $mResult[$sKeyID]['changed'] ?
									\gmdate('c', $mResult[$sKeyID]['changed']) : '';
							}

							$mResult[$sKeyID]['changed_'] = \gmdate('c', $mResult[$sKeyID]['changed']);
						}
					}
				}
			}
		}

		return $mResult;
	}

	protected function davClientRequest(DAVClient $oClient, string $sCmd, string $sUrl, $mData = null) : ?\SnappyMail\HTTP\Response
	{
		\MailSo\Base\Utils::ResetTimeLimit();

		$this->logWrite($sCmd.' '.$sUrl.(('PUT' === $sCmd || 'POST' === $sCmd) && null !== $mData ? ' ('.\strlen($mData).')' : ''),
			\LOG_INFO, 'DAV');

		try
		{
			if (('PUT' === $sCmd || 'POST' === $sCmd) && null !== $mData) {
				return $oClient->request($sCmd, $sUrl, $mData, array(
					'Content-Type' => 'text/vcard; charset=utf-8'
				));
			}
			return $oClient->request($sCmd, $sUrl);
//			if ('GET' === $sCmd) {
//				$this->oLogger->WriteDump($aResponse, \LOG_INFO, 'DAV');
//			}
		}
		catch (\Throwable $oException)
		{
			$this->logException($oException);
		}

		return null;
	}

	private function detectionPropFind(DAVClient $oClient, string $sPath) : ?array
	{
		try
		{
			return $oClient->propFind($sPath, array(
				'{DAV:}current-user-principal',
				'{DAV:}resourcetype',
				'{DAV:}displayname',
				'{urn:ietf:params:xml:ns:carddav}addressbook-home-set'
			), 1);
		}
		catch (\Throwable $oException)
		{
			$this->logException($oException);
		}

		return null;
	}

	private function getContactsPaths(DAVClient $oClient, string $sPath, string $sUser,
		#[\SensitiveParameter]
		string $sPassword,
		string $sProxy = '') : array
	{
		$aContactsPaths = array();

		$sCurrentUserPrincipal = '';
		$sAddressbookHomeSet = '';

		$aResponse = $this->detectionPropFind($oClient, '/.well-known/carddav')
			?: $this->detectionPropFind($oClient, $sPath);

		$sNextPath = '';
		$sFirstNextPath = '';
		if (\is_array($aResponse)) {
			foreach ($aResponse as $sPropPath => $aItem) {
				if (empty($sAddressbookHomeSet) && !empty($aItem['{urn:ietf:params:xml:ns:carddav}addressbook-home-set']['{DAV:}href'])
				 && false === \strpos($aItem['{urn:ietf:params:xml:ns:carddav}addressbook-home-set']['{DAV:}href'], '/calendar-proxy'))
				{
					$sAddressbookHomeSet = $aItem['{urn:ietf:params:xml:ns:carddav}addressbook-home-set']['{DAV:}href'];
					continue;
				}

				if (empty($sCurrentUserPrincipal) && !empty($aItem['{DAV:}current-user-principal']['{DAV:}href'])) {
					$sCurrentUserPrincipal = $aItem['{DAV:}current-user-principal']['{DAV:}href'];
					continue;
				}

				if (!empty($sPropPath)) {
					if (empty($sFirstNextPath)) {
						$sFirstNextPath = $sPropPath;
					}

					if (empty($sNextPath)) {
						if (static::hasDAVCollection($aItem)) {
							$sNextPath = $sPropPath;
							continue;
						}
					}
				}
			}

			if (empty($sNextPath) && empty($sCurrentUserPrincipal) && empty($sAddressbookHomeSet) && !empty($sFirstNextPath)) {
				$sNextPath = $sFirstNextPath;
			}
		}

		if (empty($sCurrentUserPrincipal) && empty($sAddressbookHomeSet)) {
			if (empty($sNextPath)) {
				return $aContactsPaths;
			}
			if (\preg_match('/^http[s]?:\/\//i', $sNextPath)) {
				$oClient = $this->getDavClientFromUrl($sNextPath, $sUser, $sPassword, $sProxy);
				if (!$oClient) {
					return $aContactsPaths;
				}
				$sNextPath = $oClient->urlPath;
			}

			if ($sPath != $sNextPath) {
				$aResponse = $this->detectionPropFind($oClient, $sNextPath);
				if (\is_array($aResponse)) {
					foreach ($aResponse as $aItem) {
						if (empty($sAddressbookHomeSet) && !empty($aItem['{urn:ietf:params:xml:ns:carddav}addressbook-home-set']['{DAV:}href']) &&
							false === \strpos($aItem['{urn:ietf:params:xml:ns:carddav}addressbook-home-set']['{DAV:}href'], '/calendar-proxy'))
						{
							$sAddressbookHomeSet = $aItem['{urn:ietf:params:xml:ns:carddav}addressbook-home-set']['{DAV:}href'];
							continue;
						}

						if (empty($sCurrentUserPrincipal) && !empty($aItem['{DAV:}current-user-principal']['{DAV:}href'])) {
							$sCurrentUserPrincipal = $aItem['{DAV:}current-user-principal']['{DAV:}href'];
							continue;
						}
					}
				}
			}
		}

		if (empty($sAddressbookHomeSet)) {
			if (empty($sCurrentUserPrincipal)) {
				return $aContactsPaths;
			}
			if (\preg_match('/^http[s]?:\/\//i', $sCurrentUserPrincipal)) {
				$oClient = $this->getDavClientFromUrl($sCurrentUserPrincipal, $sUser, $sPassword, $sProxy);
				if (!$oClient) {
					return $aContactsPaths;
				}
				$sCurrentUserPrincipal = $oClient->urlPath;
			}

			$aResponse = $this->detectionPropFind($oClient, $sCurrentUserPrincipal);
			if (\is_array($aResponse)) {
				foreach ($aResponse as $aItem) {
					if (empty($sAddressbookHomeSet) && !empty($aItem['{urn:ietf:params:xml:ns:carddav}addressbook-home-set']['{DAV:}href']) &&
						false === \strpos($aItem['{urn:ietf:params:xml:ns:carddav}addressbook-home-set']['{DAV:}href'], '/calendar-proxy'))
					{
						$sAddressbookHomeSet = $aItem['{urn:ietf:params:xml:ns:carddav}addressbook-home-set']['{DAV:}href'];
						continue;
					}
				}
			}
		}

		if (empty($sAddressbookHomeSet)) {
			return $aContactsPaths;
		}
		if (\preg_match('/^http[s]?:\/\//i', $sAddressbookHomeSet)) {
			$oClient = $this->getDavClientFromUrl($sAddressbookHomeSet, $sUser, $sPassword, $sProxy);
			if (!$oClient) {
				return $aContactsPaths;
			}
			$sAddressbookHomeSet = $oClient->urlPath;
		}

		$aResponse = $this->detectionPropFind($oClient, $sAddressbookHomeSet);
		if (\is_array($aResponse)) {
			foreach ($aResponse as $sPropPath => $aItem) {
				if (!empty($sPropPath) && static::hasDAVCollection($aItem)
				 && \in_array('{urn:ietf:params:xml:ns:carddav}addressbook', $aItem['{DAV:}resourcetype']))
				{
					$aContactsPaths[$sPropPath] = isset($aItem['{DAV:}displayname']) ? \trim($aItem['{DAV:}displayname']) : '';
				}
			}
		}

		return $aContactsPaths;
	}

	/**
	 * Checks if remote path resourcetype is an addressbook
	 */
	private function checkContactsPath(DAVClient $oClient, string $sPath) : bool
	{
		$aResponse = null;
		try
		{
			$aResponse = $oClient->propFind($sPath, array(
				'{DAV:}resourcetype'
			), 1);
		}
		catch (\Throwable $oException)
		{
			$this->logException($oException);
		}

		$bGood = false;
		if (\is_array($aResponse)) {
			foreach ($aResponse as $sKey => $aItem) {
				if (!empty($sKey) && static::hasDAVCollection($aItem)
				 && \in_array('{urn:ietf:params:xml:ns:carddav}addressbook', $aItem['{DAV:}resourcetype']))
				{
					$bGood = true;
				}
			}
			if ($bGood) {
				$oClient->urlPath = $sPath;
			}
		}

		return $bGood;
	}

	private function getDavClientFromUrl(string $sUrl, string $sUser,
		#[\SensitiveParameter]
		string $sPassword,
		string $sProxy = ''
	) : DAVClient
	{
		if (!\preg_match('/^http[s]?:\/\//i', $sUrl)) {
			$sUrl = \preg_replace('/^fruux\.com/i', 'dav.fruux.com', $sUrl);
			$sUrl = \preg_replace('/^icloud\.com/i', 'contacts.icloud.com', $sUrl);
			$sUrl = \preg_replace('/^gmail\.com/i', 'google.com', $sUrl);
			$sUrl = 'https://'.$sUrl;
		}

		$aUrl = \parse_url($sUrl);
		if (!\is_array($aUrl)) {
			$aUrl = array();
		}

		$aUrl['scheme'] = $aUrl['scheme'] ?? 'http';
		$aUrl['host'] = $aUrl['host'] ?? 'localhost';
		$aUrl['port'] = $aUrl['port'] ?? 0;
		$aUrl['path'] = isset($aUrl['path']) ? \rtrim($aUrl['path'], '\\/').'/' : '/';

		$aSettings = array(
			'baseUri' => $aUrl['scheme'].'://'.$aUrl['host'].($aUrl['port'] ? ':'.$aUrl['port'] : ''),
			'userName' => $sUser,
			'password' => $sPassword
		);

		$this->logMask($sPassword);

		if (!empty($sProxy)) {
			$aSettings['proxy'] = $sProxy;
		}

		$oClient = new DAVClient($aSettings);
		$oClient->setVerifyPeer(false);

		$oClient->urlPath = $aUrl['path'];

		$this->logWrite('DavClient: User: '.$aSettings['userName'].', Url: '.$sUrl, \LOG_INFO, 'DAV');

		return $oClient;
	}

	protected function getDavClient() : ?DAVClient
	{
		if (!$this->aDAVConfig['Mode']) {
			return null;
		}
		$sUrl = $this->aDAVConfig['Url'];
		$sUser = $this->aDAVConfig['User'];
		$sPassword = $this->aDAVConfig['Password'];
		$sProxy = '';

		$aMatch = array();
		$sUserAddressBookNameName = '';

		if (\preg_match('/\|(.+)$/', $sUrl, $aMatch) && !empty($aMatch[1])) {
			$sUserAddressBookNameName = \trim($aMatch[1]);
			$sUserAddressBookNameName = \mb_strtolower($sUserAddressBookNameName);

			$sUrl = \preg_replace('/\|(.+)$/', '', $sUrl);
		}

		$oClient = $this->getDavClientFromUrl($sUrl, $sUser, $sPassword, $sProxy);

		$sPath = $oClient->urlPath;

		$bGood = true;
		if ('' === $sPath || '/' === $sPath || !$this->checkContactsPath($oClient, $sPath)) {
			/**
			 * Path is not an addressbook, try to find it
			 */
			$aPaths = $this->getContactsPaths($oClient, $sPath, $sUser, $sPassword, $sProxy);
			$this->oLogger->WriteDump($aPaths);

			$sNewPath = '';
			if (\is_array($aPaths)) {
				if (1 < \count($aPaths)) {
					if ('' !== $sUserAddressBookNameName) {
						foreach ($aPaths as $sKey => $sValue) {
							$sValue = \mb_strtolower(\trim($sValue));
							if ($sValue === $sUserAddressBookNameName) {
								$sNewPath = $sKey;
								break;
							}
						}
					}

					if (empty($sNewPath)) {
						foreach ($aPaths as $sKey => $sValue) {
							$sValue = \mb_strtolower($sValue);
							if (\in_array($sValue, array('contacts', 'default', 'addressbook', 'address book'))) {
								$sNewPath = $sKey;
								break;
							}
						}
					}
				}

				if (empty($sNewPath)) {
					foreach ($aPaths as $sKey => $sValue) {
						$sNewPath = $sKey;
						break;
					}
				}
			}

			$bGood = $sNewPath && $this->checkContactsPath($oClient, $sNewPath);
			if (!$bGood) {
				$this->logWrite('Contacts path not found at: '.$sPath, \LOG_INFO, 'DAV');
			}
		}

		return $bGood ? $oClient : null;
	}

	private static function hasDAVCollection($aItem)
	{
		return !empty($aItem['{DAV:}resourcetype'])
			&& \is_array($aItem['{DAV:}resourcetype'])
			&& \in_array('{DAV:}collection', $aItem['{DAV:}resourcetype']);
	}

}