<?php

//define('NO_KEEP_STATISTIC', 'Y');
//define('NO_AGENT_STATISTIC','Y');
//define('NO_AGENT_CHECK', true);
//define('DisableEventsCheck', true);

define('NOT_CHECK_PERMISSIONS', true);
//define('BX_SECURITY_SESSION_READONLY', true);

require $_SERVER['DOCUMENT_ROOT'].'/bitrix/modules/main/include/prolog_before.php';

$context = Bitrix\Main\Application::getInstance()->getContext();

$request  = $context->getRequest();
$response = $context->getResponse();

CModule::includeModule('mail');

function handleError($rcpt,$rcptErrors)
{
	if (count($rcptErrors) >= count($rcpt))
	{
		throw new Bitrix\Mail\ReceiverException(join('; ', $rcptErrors));
	}

	throw new Bitrix\Main\SystemException(sprintf('Message processing failed (rcpt: %s)', join(', ', $rcpt)));
}

try
{
	$hostname = $request->getPostList()->getRaw('hostname');
	if (empty($hostname))
		throw new Bitrix\Mail\ReceiverException('Empty \'hostname\' request parameter');

	$message = $request->getPostList()->getRaw('message');
	if (empty($message))
		throw new Bitrix\Mail\ReceiverException('Empty \'message\' request parameter');

	try
	{
		$message = Bitrix\Main\Web\Json::decode($message);
	}
	catch (Exception $e)
	{
		throw new Bitrix\Mail\ReceiverException('Invalid \'message\' request parameter');
	}

	if (empty($message['rcpt_to']))
		throw new Bitrix\Mail\ReceiverException('Empty recipients list');

	$rcpt = array();
	foreach ($message['rcpt_to'] as $to)
	{
		if (empty($to['user']) || empty($to['host']))
			continue;
		if (mb_strtolower($hostname) != mb_strtolower($to['host']))
			continue;
		if (preg_match('/^no-?reply$/i', $to['user']))
			continue;

		$rcpt[] = sprintf('%s@%s', $to['user'], $to['host']);
	}

	if (empty($rcpt))
		throw new Bitrix\Mail\ReceiverException('Invalid recipients list');

	$preSuccess = false;
	$success = false;
	$rcptErrors = [];

	$emails = [];

	foreach ($rcpt as $to)
	{
		$emailRecipient = null;
		$emailRelation = null;

		$emailRecipient = Bitrix\Mail\User::parseEmailRecipient($to);

		$token = $emailRecipient['token'];

		if($emailRecipient === false)
		{
			$rcptErrors[$to] = sprintf('Invalid recipient (%s)', $to);
			break;
		}

		$emailRelation = Bitrix\Mail\User::getUserRelation($token);

		if ($emailRelation === false)
		{
			$rcptErrors[$to] = sprintf('Unknown recipient (%s)', $to);
			break;
		}

		$preSuccess = true;
		$emails[$to] = [];
		$emails[$to]['recipient'] = $emailRecipient;
		$emails[$to]['relation'] = $emailRelation;
	}

	if (!$preSuccess)
	{
		handleError($rcpt,$rcptErrors);
	}

	$message['files'] = array();
	if (!empty($message['attachments']) && is_array($message['attachments']))
	{
		$emptyFile = array(
			'name'     => '',
			'type'     => '',
			'tmp_name' => '',
			'error'    => UPLOAD_ERR_NO_FILE,
			'size'     => 0
		);

		$imageExts = array(
			'image/bmp'  => array('.bmp'),
			'image/gif'  => array('.gif'),
			'image/jpeg' => array('.jpeg', '.jpg', '.jpe'),
			'image/png'  => array('.png')
		);
		$jpegTypes = array('image/pjpeg', 'image/jpeg', 'image/jpg', 'image/jpe');

		$tmpDir = \CTempFile::getDirectoryName(6);
		checkDirPath($tmpDir);

		foreach ($message['attachments'] as &$item)
		{
			$itemId = $item['uniqueId'];
			$fileId = $item['uniqueId'] = md5($item['checksum'].$item['length']);

			$item['fileName'] = trim(trim(trim($item['fileName']), '.'));
			if (empty($item['fileName']))
			{
				$item['fileName'] = $fileId;

				if (mb_strpos($item['contentType'], 'message/') === 0)
					$item['fileName'] .= '.eml';
			}

			if ($item['contentType'])
			{
				if (in_array($item['contentType'], $jpegTypes))
					$item['contentType'] = 'image/jpeg';

				if (is_set($imageExts, $item['contentType']))
				{
					$extPos = mb_strrpos($item['fileName'], '.');
					$ext = mb_substr($item['fileName'], $extPos);

					if ($extPos === false || !in_array($ext, $imageExts[$item['contentType']]))
						$item['fileName'] .= $imageExts[$item['contentType']][0];
				}
			}

			$file = array_merge(
				empty($_FILES[$itemId]) ? $emptyFile : $_FILES[$itemId],
				array(
					'name' => $item['fileName'],
					'type' => $item['contentType'],
				)
			);

			if (is_uploaded_file($file['tmp_name']) && $file['size'] > 0)
			{
				$uploadFile = $tmpDir . md5(mt_rand().$file['name']);
				move_uploaded_file($file['tmp_name'], $uploadFile);

				$file['tmp_name'] = $uploadFile;
			}

			$message['files'][$fileId] = $file;
		}
		unset($item);
	}

	foreach ($rcpt as $to)
	{
		if(!isset($emails[$to]))
		{
			continue;
		}

		$error  = null;
		$result = Bitrix\Mail\User::onEmailReceived(
			$to,
			$message,
			$emails[$to]['recipient'],
			$emails[$to]['relation'],
			$error
		);

		if ($result)
			$success = true;
		elseif ($error)
			$rcptErrors[$to] = $error;
	}

	if (!$success)
	{
		handleError($rcpt,$rcptErrors);
	}

	$response->setStatus('204 No Content');
}
catch (Bitrix\Mail\ReceiverException $e)
{
	addMessage2Log(sprintf('Mail entry: %s', $e->getMessage()), 'mail', 0, false);
	$response->setStatus('400 Bad Request');
}
catch (Exception $e)
{
	addMessage2Log(sprintf('Mail entry: %s', $e->getMessage()), 'mail', 0, false);
	$response->setStatus('500 Internal Server Error');
}

require $_SERVER['DOCUMENT_ROOT'].'/bitrix/modules/main/include/epilog_after.php';