OSSMailScanner_Record_Model::isConnection() - Code Metrics - YetiForceCompany/YetiForceCRM - Measure and Improve Code Quality continuously with Scrutinizer

OSSMailScanner_Record_Model::isConnection() A
last analyzed 2024-09-13 12:00 UTC

↳ Parent: OSSMailScanner_Record_Model
Complexity

Conditions	2
Paths	2
Size

Total Lines	8
Code Lines	5
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	0
CRAP Score	6
Importance

Changes
Metric	Value
eloc	5
c	0
b	0
f	0
dl	0
loc	8
ccs	0
cts	0
cp	0
rs	10
cc	2
nc	2
nop	1
crap	6
<?php

/**
 * OSSMailScanner Record model class.
 *
 * @copyright YetiForce S.A.
 * @license   YetiForce Public License 6.5 (licenses/LicenseEN.txt or yetiforce.com)
 * @author    Mariusz Krzaczkowski <[email protected]>
 * @author    Radosław Skrzypczak <[email protected]>
 */
class OSSMailScanner_Record_Model extends Vtiger_Record_Model
{
	/**
	 * Main folders array.
	 *
	 * @var array
	 */
	public static $mainFolders = ['Received', 'Sent', 'Spam', 'Trash', 'All'];

	/**
	 * Returns array list of actions.
	 *
	 * @return array
	 */
	public static function getActionsList()
	{
		$accountsPriority = ['CreatedEmail', 'CreatedHelpDesk', 'BindAccounts', 'BindContacts', 'BindLeads', 'BindHelpDesk', 'BindSSalesProcesses'];
		$moduleModel = Vtiger_Module_Model::getInstance('OSSMailScanner');
		$iterator = new DirectoryIterator($moduleModel->actionsDir);
		$actions = [];
		foreach ($iterator as $i => $fileInfo) {
			if (!$fileInfo->isDot() && 'php' === $fileInfo->getExtension()) {
				$action = trim($fileInfo->getBasename('.php'));
				$key = array_search($action, $accountsPriority);
				if (false === $key) {
					$key = $i + 100;
				}
				$actions[$key] = $action;
			}
		}
		ksort($actions);

		return $actions;
	}

	/**
	 * Return user identities.
	 *
	 * @param int $id
	 *
	 * @return array
	 */
	public static function getIdentities($id = 0)
	{
		if (App\Cache::staticHas('OSSMailScanner_Record_Model::getIdentities', $id)) {
			return App\Cache::staticGet('OSSMailScanner_Record_Model::getIdentities', $id);
		}
		$query = (new \App\Db\Query())->select(['name', 'email', 'identity_id'])->from('roundcube_identities');
		if ($id) {
			$query = $query->where(['user_id' => $id]);
		}
		$rows = $query->all();
		App\Cache::staticSave('OSSMailScanner_Record_Model::getIdentities', $id, $rows);
		return $rows;
	}

	/**
	 * Delete identity by id.
	 *
	 * @param int $id
	 */
	public function deleteIdentities($id)
	{
		\App\Db::getInstance()->createCommand()->delete('roundcube_identities', ['identity_id' => $id])->execute();
	}

	/**
	 * Return email  actions name list.
	 *
	 * @param array $data
	 *
	 * @return array
	 */
	public static function getEmailActionsListName($data)
	{
		$return = [];
		foreach ($data as $row) {
			if ('files' == $row[0]) {
				$return[] = [$row[1], $row[1]];
			} else {
				foreach ($row[2] as $row_dir) {
					$return[] = [$row_dir[1], $row[1] . '|' . $row_dir[1]];
				}
			}
		}
		return $return;
	}

	/**
	 * Update user actions.
	 *
	 * @param int    $userid
	 * @param string $value
	 */
	public static function setActions($userid, $value)
	{
		\App\Db::getInstance()->createCommand()
			->update('roundcube_users', [
				'actions' => $value,
			], ['user_id' => $userid])
			->execute();
	}

	/**
	 * Update folder list for user.
	 *
	 * @param int   $user
	 * @param array $foldersByType
	 */
	public static function setFolderList($user, $foldersByType)
	{
		$dbCommand = \App\Db::getInstance()->createCommand();
		$oldFoldersByType = (new \App\Db\Query())->select(['type', 'folder'])->from('vtiger_ossmailscanner_folders_uid')->where(['user_id' => $user])->createCommand()->queryAllByGroup(2);
		foreach (self::$mainFolders as $type) {
			$toRemove = $toAdd = $oldFolders = $folders = [];

			if (isset($oldFoldersByType[$type])) {
				$oldFolders = $oldFoldersByType[$type];
			}
			if (isset($foldersByType[$type])) {
				$folders = $foldersByType[$type];
			}

			$toAdd = array_diff_assoc($folders, $oldFolders);
			$toRemove = array_diff_assoc($oldFolders, $folders);
			foreach ($toRemove as $folder) {
				$dbCommand->delete('vtiger_ossmailscanner_folders_uid', ['user_id' => $user, 'type' => $type, 'folder' => html_entity_decode($folder)])->execute();
			}
			foreach ($toAdd as $folder) {
				$dbCommand->insert('vtiger_ossmailscanner_folders_uid', [
					'user_id' => $user,
					'type' => $type,
					'folder' => html_entity_decode($folder),
				])->execute();
			}
		}
	}

	/**
	 * Return folders config.
	 *
	 * @param bool|string $folder
	 *
	 * @return array|string
	 */
	public static function getConfigFolderList($folder = false)
	{
		if ($folder) {
			return (new \App\Db\Query())->select(['parameter'])->from('vtiger_ossmailscanner_config')->where(['and', ['conf_type' => 'folders'], ['like', 'value', $folder]])->orderBy('parameter')->scalar();

		}
		return (new \App\Db\Query())->select(['parameter', 'value'])->from('vtiger_ossmailscanner_config')->where(['conf_type' => 'folders'])->orderBy(['parameter' => SORT_DESC])->createCommand()->queryAllByGroup(0);
	}

	/**
	 * Return mailscanner config.
	 *
	 * @param bool|string $confType
	 *
	 * @return array
	 */
	public static function getConfig($confType)
	{
		$query = (new \App\Db\Query())->from('vtiger_ossmailscanner_config');
		if (false !== $confType) {
			$query->where(['conf_type' => $confType]);
		}
		$query->orderBy(['parameter' => SORT_DESC]);
		$dataReader = $query->createCommand()->query();
		$return = [];
		while ($row = $dataReader->read()) {
			if (false !== $confType) {
				$return[$row['parameter']] = $row['value'];
			} else {
				$return[$row['conf_type']][$row['parameter']] = $row['value'];
			}
		}
		$dataReader->close();

		return $return;
	}

	/**
	 * Update config widget param.
	 *
	 * @param string $confType
	 * @param string $type
	 * @param string $value
	 *
	 * @return string
	 */
	public function setConfigWidget($confType, $type, $value)
	{
		if (null === $value || 'null' === $value) {
			$value = null;
		}
		App\Db::getInstance()->createCommand()->update('vtiger_ossmailscanner_config', ['value' => $value], ['conf_type' => $confType, 'parameter' => $type])->execute();

		return App\Language::translate('LBL_SAVE', 'OSSMailScanner');
	}

	/**
	 * Returns folder type.
	 *
	 * @param string $folder
	 *
	 * @return int
	 */
	public static function getTypeFolder($folder)
	{
		switch ($folder) {
			case 'Received':
				$return = 0;
				break;
			case 'Sent':
				$return = 1;
				break;
			case 'Spam':
				$return = 2;
				break;
			case 'Trash':
				$return = 3;
				break;
			case 'All':
				$return = 4;
				break;
			default:
				break;
		}
		return $return;

	}

	/**
	 * Return folder UID.
	 *
	 * @param int    $accountId
	 * @param string $folder
	 *
	 * @return int
	 */
	public static function getUidFolder($accountId, $folder)
	{
		$rows = (new \App\Db\Query())->select(['uid', 'folder'])->from('vtiger_ossmailscanner_folders_uid')->where(['user_id' => $accountId, 'folder' => $folder])->createCommand()->query();
		while ($row = $rows->read()) {
			if ($folder === $row['folder']) {
				return $row['uid'];
			}
		}
		return 0;
	}

	/**
	 * Return user folders.
	 *
	 * @param int $accountId
	 *
	 * @return array
	 */
	public function getFolders($accountId)
	{
		return (new \App\Db\Query())->from('vtiger_ossmailscanner_folders_uid')->where(['user_id' => $accountId])->createCommand()->queryAll();
	}

	/**
	 * @param int                $account
	 * @param OSSMail_Mail_Model $mail
	 * @param string             $folder
	 * @param array              $params
	 *
	 * @return array
	 */
	public static function executeActions($account, OSSMail_Mail_Model $mail, $folder, $params = false)
	{
		\App\Log::trace('Start execute actions: ' . $account['username'], 'MailScanner');

		$actions = [];
		if ($params && \array_key_exists('actions', $params)) {
			$actions = $params['actions'];
		} elseif (\is_string($account['actions'])) {
			$actions = explode(',', $account['actions']);
		} else {
			$actions = $account['actions'];
		}
		$mail->setAccount($account);
		$mail->setAccount(/** @scrutinizer ignore-type */ $account);
		$mail->setFolder($folder);
		foreach ($actions as &$action) {
			$handlerClass = Vtiger_Loader::getComponentClassName('ScannerAction', $action, 'OSSMailScanner');
			$handler = new $handlerClass();
			if ($handler) {
				\App\Log::trace('Start action: ' . $action, 'MailScanner');
				try {
					$mail->addActionResult($action, $handler->process($mail));
				} catch (Exception $e) {
					App\Log::error("Action: $action  Folder: $folder ID:" . $mail->get('id') . PHP_EOL . $e->__toString(), 'MailScanner');
				}
				\App\Log::trace('End action', 'MailScanner');
			}
		}
		$mail->postProcess();
		\App\Log::trace('End execute actions', 'MailScanner');

		return $mail->getActionResult();
	}

	/**
	 * Manually scan mail.
	 *
	 * @param int    $uid
	 * @param string $folder
	 * @param array  $account
	 *
	 * @throws \App\Exceptions\AppException
	 *
	 * @return array
	 */
	public function manualScanMail(int $uid, string $folder, array $account)
	{
		$imapFolder = \App\Utils::convertCharacterEncoding($folder, 'UTF-8', 'UTF7-IMAP');
		$mbox = \OSSMail_Record_Model::imapConnect($account['username'], \App\Encryption::getInstance()->decrypt($account['password']), $account['mail_host'], $imapFolder);
		$mail = OSSMail_Record_Model::getMail($mbox, $uid);
		$mail = OSSMail_Record_Model::getMail(/** @scrutinizer ignore-type */ $mbox, $uid);
		if (!$mail) {
			return [];
		}
		$params = [];
		if (empty($account['actions'])) {
			$params['actions'] = ['CreatedEmail', 'BindAccounts', 'BindContacts', 'BindLeads'];
		} else {
			if (\is_string($account['actions'])) {
				$actions = explode(',', $account['actions']);
			} else {
				$actions = $account['actions'];
			}
			if (!\in_array('CreatedEmail', $actions)) {
				array_unshift($actions, 'CreatedEmail', );
			}
			$params['actions'] = $actions;
		}
		$return = self::executeActions($account, $mail, $folder, $params);
		unset($mail);
		return $return;
	}

	/**
	 * Scan mailbox for emails.
	 *
	 * @param resource $mbox
	 * @param array    $account
	 * @param string   $folder      Character encoding UTF-8
	 * @param int      $scan_id
	 * @param int      $countEmails
	 *
	 * @throws \ReflectionException
	 * @throws \yii\db\Exception
	 *
	 * @return array
	 */
	public static function mailScan($mbox, array $account, string $folder, int $scan_id, int $countEmails)
	{
		$break = false;
		$lastScanUid = self::getUidFolder($account['user_id'], $folder);
		\App\Log::beginProfile(__METHOD__ . '|imap_msgno', 'Mail|IMAP');
		$msgno = $lastScanUid ? imap_msgno($mbox, $lastScanUid) : 0;
		\App\Log::endProfile(__METHOD__ . '|imap_msgno', 'Mail|IMAP');
		\App\Log::beginProfile(__METHOD__ . '|imap_num_msg', 'Mail|IMAP');
		$numMsg = imap_num_msg($mbox);
		\App\Log::endProfile(__METHOD__ . '|imap_num_msg', 'Mail|IMAP');
		$getEmails = false;
		if (0 === $msgno && 0 !== $numMsg) {
			if (0 === $lastScanUid) {
				$msgno = 1;
				$getEmails = true;
			} elseif (imap_uid($mbox, $numMsg) > $lastScanUid) {
				foreach (imap_search($mbox, 'ALL', SE_UID) as $uid) {
					if ($uid > $lastScanUid) {
						\App\Log::beginProfile(__METHOD__ . '|imap_msgno', 'Mail|IMAP');
						$msgno = imap_msgno($mbox, $uid);
						\App\Log::endProfile(__METHOD__ . '|imap_msgno', 'Mail|IMAP');
						$getEmails = true;
						break;
					}
				}
			}
		} elseif ($msgno < $numMsg) {
			++$msgno;
			$getEmails = true;
		}
		if ($getEmails) {
			$dbCommand = \App\Db::getInstance()->createCommand();
			for ($i = $msgno; $i <= $numMsg; ++$i) {
				\App\Log::beginProfile(__METHOD__ . '|imap_uid', 'Mail|IMAP');
				$uid = imap_uid($mbox, $i);
				\App\Log::endProfile(__METHOD__ . '|imap_uid', 'Mail|IMAP');
				$mail = OSSMail_Record_Model::getMail($mbox, $uid, $i);

				self::executeActions($account, $mail, $folder);
				self::executeActions(/** @scrutinizer ignore-type */ $account, $mail, $folder);
				unset($mail);
				$dbCommand->update('vtiger_ossmailscanner_folders_uid', ['uid' => $uid], ['user_id' => $account['user_id'], 'folder' => $folder])->execute();
				++$countEmails;
				if (!self::updateScanHistory($scan_id, ['status' => '1', 'count' => $countEmails, 'action' => 'Action_CronMailScanner'])
					|| $countEmails >= \App\Config::performance('NUMBERS_EMAILS_DOWNLOADED_DURING_ONE_SCANNING')) {
					$break = true;
					break;
				}
			}
		}
		return ['count' => $countEmails, 'break' => $break];
	}

	/**
	 * Return email search results.
	 *
	 * @param string $module
	 * @param mixed  $onlyMailUitype
	 *
	 * @return array
	 */
	public static function getEmailSearch($module = false, $onlyMailUitype = true)
	{
		$return = [];
		$query = (new App\Db\Query())->from('vtiger_field')
			->leftJoin('vtiger_tab', 'vtiger_tab.tabid = vtiger_field.tabid')
			->where(['and', ['uitype' => ($onlyMailUitype ? 13 : [13, 319])], ['<>', 'vtiger_field.presence', 1], ['<>', 'vtiger_tab.name', 'Users']]);
		if ($module) {
			$query->andWhere(['vtiger_tab.name' => $module]);
		}
		$query->orderBy('name');
		$dataReader = $query->createCommand()->query();
		while ($row = $dataReader->read()) {
			$return[] = [
				'key' => "{$row['fieldname']}={$row['name']}={$row['uitype']}",
				'value' => "{$row['fieldname']}={$row['name']}", // item to delete in next version
				'fieldlabel' => $row['fieldlabel'],
				'tablename' => $row['tablename'],
				'columnname' => $row['columnname'],
				'name' => $row['name'],
				'tabid' => $row['tabid'],
				'fieldname' => $row['fieldname'],
			];
		}
		$dataReader->close();
		return $return;
	}

	/**
	 * Return email search list.
	 *
	 * @return array
	 */
	public static function getEmailSearchList()
	{
		$cacheKey = 'Mail';
		$cacheValue = 'EmailSearchList';
		if (\App\Cache::staticHas($cacheKey, $cacheValue)) {
			return \App\Cache::staticGet($cacheKey, $cacheValue);
		}
		$return = [];
		$value = (new \App\Db\Query())->select(['value'])->from('vtiger_ossmailscanner_config')
			->where(['conf_type' => 'emailsearch', 'parameter' => 'fields'])
			->scalar();
		if (!empty($value)) {
			$return = explode(',', $value);
		}
		\App\Cache::staticSave($cacheKey, $cacheValue, $return);
		return $return;
	}

	/**
	 * Set email search list.
	 *
	 * @param string $value
	 */
	public static function setEmailSearchList($value)
	{
		$dbCommand = App\Db::getInstance()->createCommand();
		if (null === $value || 'null' == $value) {
			$dbCommand->update('vtiger_ossmailscanner_config', ['value' => ''], ['conf_type' => 'emailsearch', 'parameter' => 'fields'])->execute();
		} else {
			$isExists = (new App\Db\Query())->from('vtiger_ossmailscanner_config')->where(['conf_type' => 'emailsearch', 'parameter' => 'fields'])->exists();
			if (!$isExists) {
				$dbCommand->insert('vtiger_ossmailscanner_config', [
					'conf_type' => 'emailsearch',
					'parameter' => 'fields',
					'value' => $value,
				])->execute();
			} else {
				$dbCommand->update('vtiger_ossmailscanner_config', ['value' => $value], ['conf_type' => 'emailsearch', 'parameter' => 'fields'])->execute();
			}
		}
	}

	/**
	 * Merge arrays.
	 *
	 * @param array $tab1
	 * @param array $tab2
	 *
	 * @return array
	 */
	public static function mergeArray($tab1, $tab2)
	{
		$return = [];
		if (0 != \count($tab1) && 0 != \count($tab2)) {
			$return = array_unique(array_merge($tab1, $tab2));
		} elseif (0 != \count($tab1)) {
			$return = $tab1;
		} elseif (0 != \count($tab2)) {
			$return = $tab2;
		}
		return $return;
	}

	/**
	 * The function returns information about OSSMailScanner Crons.
	 *
	 * @return array
	 */
	public static function getCron()
	{
		return (new App\Db\Query())->select(['name', 'status', 'frequency'])->from('vtiger_cron_task')->where(['module' => 'OSSMailScanner'])->createCommand()->queryAll();
	}

	/**
	 * Execute cron task.
	 *
	 * @param int $whoTrigger
	 *
	 * @return bool|string
	 */
	public function executeCron($whoTrigger)
	{
		\App\Log::trace('Start executeCron');
		if (!self::isPermissionToScan($whoTrigger)) {
			\App\Log::warning(\App\Language::translate('ERROR_ACTIVE_CRON', 'OSSMailScanner'));
			return \App\Language::translate('ERROR_ACTIVE_CRON', 'OSSMailScanner');
		}
		$accounts = OSSMail_Record_Model::getAccountsList();
		if (!$accounts) {
			\App\Log::info('There are no accounts to be scanned');
			return false;
		}
		$scannerModel = Vtiger_Record_Model::getCleanInstance('OSSMailScanner');
		$countEmails = 0;
		$scanId = $scannerModel->addScanHistory(['user' => $whoTrigger]);
  $scanId = $scannerModel->addScanHistory(['user' => $whoTrigger]);
		foreach ($accounts as $account) {
			\App\Log::trace('Start checking account: ' . $account['username']);
			if (empty($account['actions']) || !$this->isConnection($account) || empty($folders = $scannerModel->getFolders($account['user_id']))) {
			if (empty($account['actions']) || !$this->isConnection($account) || empty($folders = $scannerModel->/** @scrutinizer ignore-call */ getFolders($account['user_id']))) {
				continue;
			}
			foreach ($folders as $folderRow) {
				$folder = \App\Utils::convertCharacterEncoding($folderRow['folder'], 'UTF-8', 'UTF7-IMAP');
				\App\Log::trace('Start checking folder: ' . $folder);
				$mbox = \OSSMail_Record_Model::imapConnect($account['username'], \App\Encryption::getInstance()->decrypt($account['password']), $account['mail_host'], $folder, false, [], $account);
				if (\is_resource($mbox)) {
					$scanSummary = $scannerModel->mailScan($mbox, $account, $folderRow['folder'], $scanId, $countEmails);
     $scanSummary = $scannerModel->mailScan($mbox, $account, $folderRow['folder'], $scanId, $countEmails);
					$countEmails = $scanSummary['count'];
					if ($scanSummary['break']) {
						\App\Log::info('Reached the maximum number of scanned mails');
						break 2;
					}
				} else {
					\App\Log::error("Incorrect mail access data, username: {$account['username']} , folder: $folder , type: {$folderRow['type']} ,  Error: " . imap_last_error());
				}
			}
		}
		self::updateScanHistory($scanId, ['status' => '0', 'count' => $countEmails, 'action' => 'Action_CronMailScanner']);
		\App\Log::trace('End executeCron');
		return 'ok';
	}

	/**
	 * Function checks connection to mailbox.
	 *
	 * @param array $account
	 *
	 * @return bool
	 */
	public function isConnection(array $account)
	{
		$result = false;
		$mbox = \OSSMail_Record_Model::imapConnect($account['username'], \App\Encryption::getInstance()->decrypt($account['password']), $account['mail_host'], '', false, [], $account);
		if (\is_resource($mbox)) {

			$result = true;
		}
		return $result;
	}

	/**
	 * Return history status label.
	 *
	 * @param int $id
	 *
	 * @return string
	 */
	public function getHistoryStatus($id)
	{
		switch ($id) {
			case 0:
				$return = 'OK';
				break;
			case 1:
				$return = 'In progress';
				break;
			case 2:
				$return = 'Manually stopped';
				break;
			default:
				break;
		}
		return $return;

	}

	/**
	 * Return scan history.
	 *
	 * @param int $startNumber
	 *
	 * @return array
	 */
	public function getScanHistory($startNumber = 0)
	{
		$limit = 30;
		$endNumber = $startNumber + $limit;
		$dataReader = (new App\Db\Query())->from('vtiger_ossmails_logs')->orderBy(['id' => SORT_DESC])->limit($endNumber)->offset($startNumber)->createCommand()->query();
		$output = [];
		while ($row = $dataReader->read()) {
			$startTime = new DateTimeField($row['start_time']);
			$endTime = new DateTimeField($row['end_time']);
			$output[] = [
				'id' => $row['id'],
				'start_time' => $startTime->getDisplayDateTimeValue(),
				'end_time' => $endTime->getDisplayDateTimeValue(),
				'status' => self::getHistoryStatus($row['status']),
				'status' => self::/** @scrutinizer ignore-call */ getHistoryStatus($row['status']),
				'user' => $row['user'],
				'stop_user' => $row['stop_user'],
				'count' => $row['count'],
				'action' => $row['count'],
				'info' => $row['info'],
			];
		}
		$dataReader->close();

		return $output;
	}

	/**
	 * Insert new scan history row.
	 *
	 * @param array $array
	 *
	 * @throws \yii\db\Exception
	 *
	 * @return int
	 */
	public function addScanHistory($array): int
	{
		$db = \App\Db::getInstance();
		$db->createCommand()->insert('vtiger_ossmails_logs', ['status' => 1, 'user' => $array['user'], 'start_time' => date('Y-m-d H:i:s')])->execute();

		return $db->getLastInsertID('vtiger_ossmails_logs_id_seq');

	}

	/**
	 * Update scan history row.
	 *
	 * @param int   $id
	 * @param array $array
	 */
	public static function updateScanHistory($id, $array): bool
	{
		$dbCommand = \App\Db::getInstance()->createCommand();
		$result = $dbCommand->update('vtiger_ossmails_logs', ['end_time' => date('Y-m-d H:i:s'), 'status' => $array['status'], 'count' => $array['count'], 'action' => $array['action']],
			['and', ['id' => $id], ['<>', 'status', 2]])->execute();
		if (!$result) {
			$dbCommand->update('vtiger_ossmails_logs', ['count' => $array['count']], ['id' => $id])->execute();
		}
		return (bool) $result;
	}

	/**
	 * State of scan action.
	 *
	 * @param mixed $whoTrigger
	 *
	 * @return bool
	 */
	public static function isPermissionToScan($whoTrigger = ''): bool
	{
		$result = self::isActiveScan();
		if ($result && self::getCronTask()->hadTimeout()) {
			$result = static::setActiveScan($whoTrigger);
		}
		return !$result;
	}

	/**
	 * State of scan action.
	 *
	 * @param int|null $scanId
	 *
	 * @return bool
	 */
	public static function isActiveScan(?int $scanId = null): bool
	{
		$where = ['status' => 1];
		if ($scanId) {
0   == false // true
0   == null  // true
123 == false // false
123 == null  // false

// It is often better to use strict comparison
0 === false // false
0 === null  // false
			$where['id'] = $scanId;
		}
		return (new App\Db\Query())->select(['id'])->from('vtiger_ossmails_logs')->where($where)->exists();
	}

	/**
	 * Activate scan.
	 *
	 * @param string   $whoTrigger
	 * @param int|null $scanId
	 *
	 * @return bool
	 */
	public static function setActiveScan(string $whoTrigger, ?int $scanId = null): bool
	{
		$where = ['status' => 1];
		if ($scanId) {
0   == false // true
0   == null  // true
123 == false // false
123 == null  // false

// It is often better to use strict comparison
0 === false // false
0 === null  // false
			$where['id'] = $scanId;
		}
		return (bool) \App\Db::getInstance()->createCommand()
			->update('vtiger_ossmails_logs', ['status' => 2, 'stop_user' => $whoTrigger, 'end_time' => date('Y-m-d H:i:s')], $where)->execute();
	}

	/**
	 * Cron data.
	 *
	 * @return \vtlib\Cron
	 */
	public static function getCronTask()
	{
		return \vtlib\Cron::getInstance('LBL_MAIL_SCANNER_ACTION')->refreshData();
	}

	/**
	 * Restart cron.
	 *
	 * @param int $scanId
	 */
	public static function runRestartCron(int $scanId)
	{
		if (self::isActiveScan($scanId)) {
			if (self::getCronTask()->hadTimeout()) {
				\App\Cron::updateStatus(\App\Cron::STATUS_ENABLED, 'LBL_MAIL_SCANNER_ACTION');
			}
			self::setActiveScan(\App\User::getCurrentUserModel()->getDetail('user_name'), $scanId);
		}
	}

	/**
	 * Active users list.
	 *
	 * @var array|bool
	 */
	protected $user = false;

	/**
	 * Return active users list.
	 *
	 * @return array
	 */
	public function getUserList()
	{
		if ($this->user) {
			return $this->user;

		}

		$this->user = (new \App\Db\Query())->select(['id', 'user_name', 'first_name', 'last_name'])->from('vtiger_users')->where(['status' => 'Active'])->createCommand()->queryAll();

		return $this->user;
	}

	/**
	 * Groups list.
	 *
	 * @var array
	 */
	protected $group = false;

	/**
	 * Return groups list.
	 *
	 * @return array
	 */
	public function getGroupList()
	{
		if ($this->group) {

			return $this->group;
		}
		return $this->group = (new \App\Db\Query())->select(['groupid', 'groupname'])->from('vtiger_groups')->all();
	}

	/**
	 * Assign data to model.
	 *
	 * @param array $row
	 *
	 * @return bool
	 */
	public function bindMail($row)
	{
		if (empty($row['actions'])) {
			return false;
		}
		$actions = array_diff(explode(',', $row['actions']), ['CreatedEmail', 'CreatedHelpDesk']);
		if (empty($actions)) {
			return false;
		}

		$mail = new OSSMail_Mail_Model();
		$mail->setMailCrmId($row['ossmailviewid']);
		$mail->setFolder($row['mbox']);
		$mail->set('message_id', $row['uid']);
		$mail->set('to_email', $row['to_email']);
		$mail->set('from_email', $row['from_email']);
		$mail->set('reply_to_email', $row['reply_to_email']);
		$mail->set('cc_email', $row['cc_email']);
		$mail->set('bcc_email', $row['bcc_email']);
		$mail->set('subject', $row['subject']);
		$mail->set('date', $row['date']);
		$mail->set('body', $row['content']);

		foreach ($actions as $action) {
			$handlerClass = Vtiger_Loader::getComponentClassName('ScannerAction', $action, 'OSSMailScanner');
			$handler = new $handlerClass();
			if ($handler) {
				$handler->process($mail);
			}
		}
		return true;
	}

	/**
	 * Delete user email accounts.
	 *
	 * @param int $id
	 */
	public static function accountDelete($id)
	{
		$db = App\Db::getInstance();
		$db->createCommand()->delete('roundcube_users', ['user_id' => $id])->execute();
		$db->createCommand()->delete('vtiger_ossmailscanner_folders_uid', ['user_id' => $id])->execute();
	}
}

YetiForceCompany / YetiForceCRM

OSSMailScanner_Record_Model::isConnection() A last analyzed 2024-09-13 12:00 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

OSSMailScanner_Record_Model::isConnection() A
last analyzed 2024-09-13 12:00 UTC
