encodingHelper = new EncodingHelper();
$this->editorHelper = new EditorHelper();
$this->userClass = new UserClass();
$this->mailClass = new MailClass();
$this->mailArchiveClass = new MailArchiveClass();
$this->config = acym_config();
$this->setFrom($this->getSendSettings('from_email'), $this->getSendSettings('from_name'));
$this->Sender = $this->cleanText($this->config->get('bounce_email'));
if (empty($this->Sender)) {
$this->Sender = '';
}
$maxLineLength = $this->config->get('mailer_wordwrap', 0);
if (!empty($maxLineLength) && self::MAX_LINE_LENGTH > $maxLineLength) {
$this->WordWrap = $maxLineLength;
}
$this->setSendingMethodSetting();
if ($this->config->get('dkim', 0) && $this->Mailer != 'elasticemail') {
$this->DKIM_domain = $this->config->get('dkim_domain');
$this->DKIM_selector = $this->config->get('dkim_selector', 'acy');
if (empty($this->DKIM_selector)) $this->DKIM_selector = 'acy';
$this->DKIM_passphrase = $this->config->get('dkim_passphrase');
$this->DKIM_identity = $this->config->get('dkim_identity');
$this->DKIM_private = trim($this->config->get('dkim_private'));
$this->DKIM_private_string = trim($this->config->get('dkim_private'));
}
$this->CharSet = strtolower($this->config->get('charset'));
if (empty($this->CharSet)) {
$this->CharSet = 'utf-8';
}
$this->clearAll();
$this->Encoding = $this->config->get('encoding_format');
if (empty($this->Encoding)) {
$this->Encoding = '8bit';
}
@ini_set('pcre.backtrack_limit', 1000000);
$this->SMTPOptions = ['ssl' => ['verify_peer' => false, 'verify_peer_name' => false, 'allow_self_signed' => true]];
$this->addParamInfo();
}
private function getSendingMethodSettings($settingName, $default = ''): string
{
if (empty($this->currentMethodSetting)) {
return $this->config->get($settingName, $default);
}
return $this->currentMethodSetting[$settingName] ?? $default;
}
private function getSendingMethod(): string
{
$this->currentMethodSetting = [];
$sendingMethods = $this->config->get('sending_method_list', '{}');
$sendingMethods = json_decode($sendingMethods, true);
$sendingMethodsByList = $this->config->get('sending_method_list_by_list', '{}');
$sendingMethodsByList = json_decode($sendingMethodsByList, true);
if (empty($this->listsIds) || empty($sendingMethods) || empty($sendingMethodsByList) || empty($sendingMethodsByList[$this->listsIds[0]])) {
return $this->config->get('mailer_method', 'phpmail');
}
$sendingMethodIds = [];
foreach ($this->listsIds as $listId) {
if (!empty($sendingMethodsByList[$listId])) {
$sendingMethodIds[] = $sendingMethodsByList[$listId];
}
}
if (count($sendingMethodIds) !== count($this->listsIds) || count(array_unique($sendingMethodIds)) !== 1) {
return $this->config->get('mailer_method', 'phpmail');
}
$sendingMethodId = $sendingMethodIds[0];
if (empty($sendingMethods[$sendingMethodId])) {
return $this->config->get('mailer_method', 'phpmail');
}
$this->currentMethodSetting = $sendingMethods[$sendingMethodId];
return $sendingMethods[$sendingMethodId]['mailer_method'];
}
public function setSendingMethodSetting(): void
{
$externalSendingMethod = [];
acym_trigger('onAcymGetSendingMethods', [&$externalSendingMethod, true]);
$externalSendingMethod = array_keys($externalSendingMethod['sendingMethods']);
$mailerMethodConfig = $this->getSendingMethod();
$this->currentSendingMethod = $mailerMethodConfig;
if ($mailerMethodConfig === 'smtp') {
$this->isSMTP();
$this->Host = trim($this->getSendingMethodSettings('smtp_host'));
$port = $this->getSendingMethodSettings('smtp_port');
if (empty($port) && $this->getSendingMethodSettings('smtp_secured') === 'ssl') {
$port = 465;
}
if (!empty($port)) {
$this->Host .= ':'.$port;
}
$this->SMTPAuth = (bool)$this->getSendingMethodSettings('smtp_auth', true);
$this->Username = trim($this->getSendingMethodSettings('smtp_username'));
$connectionType = $this->getSendingMethodSettings('smtp_type');
$hostName = explode(':', $this->Host)[0];
if (OAuth::hostRequireOauth($hostName, $connectionType)) {
$this->AuthType = 'XOAUTH2';
$this->clientSecret = trim($this->getSendingMethodSettings('smtp_secret'));
$this->clientId = trim($this->getSendingMethodSettings('smtp_clientId'));
$this->refreshToken = trim($this->getSendingMethodSettings('smtp_refresh_token'));
$this->oauthToken = trim($this->getSendingMethodSettings('smtp_token'));
$this->expiredIn = trim($this->getSendingMethodSettings('smtp_token_expireIn'));
$oauth = new OAuth(
[
'userName' => $this->Username,
'clientSecret' => $this->clientSecret,
'oauthToken' => $this->oauthToken,
'clientId' => $this->clientId,
'refreshToken' => $this->refreshToken,
'expiredIn' => $this->expiredIn,
'host' => $hostName,
]
);
$this->setOAuth($oauth);
} else {
$authMethod = $this->getSendingMethodSettings('smtp_method');
if (in_array($authMethod, ['CRAM-MD5', 'LOGIN', 'PLAIN', 'XOAUTH2'])) {
$this->AuthType = $authMethod;
}
if ($this->SMTPAuth) {
$this->Password = trim($this->getSendingMethodSettings('smtp_password'));
}
}
$this->SMTPSecure = trim((string)$this->getSendingMethodSettings('smtp_secured'));
if (empty($this->Sender)) {
$this->Sender = strpos($this->Username, '@') ? $this->Username : $this->getSendingMethodSettings('from_email');
}
} elseif ($mailerMethodConfig === 'sendmail') {
$this->isSendmail();
$this->Sendmail = trim($this->getSendingMethodSettings('sendmail_path'));
if (empty($this->Sendmail)) {
$this->Sendmail = '/usr/sbin/sendmail';
}
} elseif ($mailerMethodConfig === 'qmail') {
$this->isQmail();
} elseif ($mailerMethodConfig === 'amazon') {
$this->isSMTP();
$amazonCredentials = [];
acym_trigger('onAcymGetCredentialsSendingMethod', [&$amazonCredentials, 'amazon', $this->currentMethodSetting], 'plgAcymAmazon');
$this->Host = trim($amazonCredentials['amazon_host']).':587';
$this->Username = trim($amazonCredentials['amazon_username']);
$this->Password = trim($amazonCredentials['amazon_password']);
$this->SMTPAuth = true;
$this->SMTPSecure = 'tls';
} elseif ($mailerMethodConfig === 'brevo-smtp') {
$this->isSMTP();
$brevoSmtpCredentials = [];
acym_trigger('onAcymGetCredentialsSendingMethod', [&$brevoSmtpCredentials, 'brevo-smtp', $this->currentMethodSetting], 'plgAcymBrevo');
$this->Host = trim($brevoSmtpCredentials['brevo-smtp_host']).':587';
$this->Username = trim($brevoSmtpCredentials['brevo-smtp_username']);
$this->Password = trim($brevoSmtpCredentials['brevo-smtp_password']);
$this->SMTPAuth = true;
$this->SMTPSecure = 'tls';
} elseif (in_array($mailerMethodConfig, $externalSendingMethod)) {
$this->isExternal($mailerMethodConfig);
} else {
$this->isMail();
}
}
public function isExternal($method)
{
$this->Mailer = 'external';
$this->externalMailer = $method;
}
protected function externalSend($MIMEHeader, $MIMEBody)
{
$fromName = empty($this->FromName) ? $this->config->get('from_name') : $this->FromName;
$reply_to = array_shift($this->ReplyTo);
$attachments = [];
if (!empty($this->attachment) && $this->config->get('embed_files')) {
foreach ($this->attachment as $i => $oneAttach) {
$encodedContent = $this->encodeFile($oneAttach[0], $oneAttach[3]);
$this->attachment[$i]['contentEncoded'] = $encodedContent;
}
$attachments = $this->attachment;
}
$response = [];
$data = [
&$response,
$this,
['email' => $this->to[0][0], 'name' => $this->to[0][1]],
['email' => $this->From, 'name' => $fromName],
['email' => $reply_to[0], 'name' => $reply_to[1]],
!empty($this->bcc) ? $this->bcc : [],
$attachments,
$this->currentMethodSetting,
];
acym_trigger('onAcymSendEmail', $data);
if (!empty($response['error'])) {
$this->setError($response['message']);
return false;
}
return true;
}
public function send()
{
if (!file_exists(ACYM_LIBRARIES.'Mailer'.DS.'Mailer.php')) {
$this->reportMessage = acym_translationSprintf('ACYM_X_FILE_MISSING', 'Mailer', ACYM_LIBRARIES.'Mailer'.DS);
if ($this->report) {
acym_enqueueMessage($this->reportMessage, 'error');
}
return false;
}
if (empty($this->Subject) || empty($this->Body)) {
if ($this->isTest && empty($this->Subject)) {
$this->Subject = acym_translation('ACYM_EMAIL_SUBJECT');
} else {
$this->reportMessage = acym_translation('ACYM_SEND_EMPTY');
$this->errorNumber = 8;
if ($this->report) {
acym_enqueueMessage($this->reportMessage, 'error');
}
return false;
}
}
if (empty($this->ReplyTo) && empty($this->ReplyToQueue)) {
if (!empty($this->replyemail)) {
$replyToEmail = $this->replyemail;
} elseif ($this->config->get('from_as_replyto', 1) == 1) {
$replyToEmail = $this->getSendSettings('from_email');
} else {
$replyToEmail = $this->getSendSettings('replyto_email');
}
if (!empty($this->replyname)) {
$replyToName = $this->replyname;
} elseif ($this->config->get('from_as_replyto', 1) == 1) {
$replyToName = $this->getSendSettings('from_name');
} else {
$replyToName = $this->getSendSettings('replyto_name');
}
$this->_addReplyTo($replyToEmail, $replyToName);
}
$shouldEmbed = $this->config->get('embed_images', 0);
if (intval($shouldEmbed) === 1 && $this->Mailer !== 'elasticemail') {
$this->embedImages();
}
if (!$this->alreadyCheckedAddresses) {
$this->alreadyCheckedAddresses = true;
$replyToTmp = '';
if (!empty($this->ReplyTo)) {
$replyToTmp = reset($this->ReplyTo);
$replyToTmp = $replyToTmp[0];
} elseif (!empty($this->ReplyToQueue)) {
$replyToTmp = reset($this->ReplyToQueue);
$replyToTmp = $replyToTmp[1];
}
if (empty($replyToTmp) || !acym_isValidEmail($replyToTmp)) {
$this->reportMessage = acym_translation('ACYM_VALID_EMAIL').' ( '.acym_translation('ACYM_REPLYTO_EMAIL').' : '.(empty($this->ReplyTo) ? '' : $replyToTmp).' ) ';
$this->errorNumber = 9;
if ($this->report) {
acym_enqueueMessage($this->reportMessage, 'error');
}
return false;
}
if (empty($this->From) || !acym_isValidEmail($this->From)) {
$this->reportMessage = acym_translation('ACYM_VALID_EMAIL').' ( '.acym_translation('ACYM_FROM_EMAIL').' : '.$this->From.' ) ';
$this->errorNumber = 9;
if ($this->report) {
acym_enqueueMessage($this->reportMessage, 'error');
}
return false;
}
if (!empty($this->Sender) && !acym_isValidEmail($this->Sender)) {
$this->reportMessage = acym_translation('ACYM_VALID_EMAIL').' ( '.acym_translation('ACYM_BOUNCE_EMAIL').' : '.$this->Sender.' ) ';
$this->errorNumber = 9;
if ($this->report) {
acym_enqueueMessage($this->reportMessage, 'error');
}
return false;
}
}
if ($this->config->get('save_body') === '1') {
@file_put_contents(ACYM_ROOT.'acydebug_mail.html', $this->Body);
}
$this->Body = htmlentities($this->Body);
$this->Body = htmlspecialchars_decode($this->Body);
$this->Body = str_replace(['&', 'ς'], ['&', 'ς'], $this->Body);
if ($this->CharSet !== 'utf-8') {
$this->Body = $this->encodingHelper->change($this->Body, 'UTF-8', $this->CharSet);
$this->Subject = $this->encodingHelper->change($this->Subject, 'UTF-8', $this->CharSet);
}
$this->Subject = str_replace(
['’', '“', '”', '–'],
["'", '"', '"', '-'],
$this->Subject
);
$this->Body = str_replace(" ", ' ', $this->Body);
$externalSending = false;
$this->isOneTimeMail = $this->isTransactional = $this->isForward || $this->isTest || $this->isSpamTest;
if (!empty($this->mailId) && !empty($this->defaultMail[$this->mailId])) {
if ($this->mailClass->isTransactionalMail($this->defaultMail[$this->mailId])) {
$this->isTransactional = true;
}
if ($this->mailClass->isOneTimeMail($this->defaultMail[$this->mailId])) {
$this->isOneTimeMail = true;
}
}
acym_trigger('onAcymProcessQueueExternalSendingCampaign', [&$externalSending, $this->isTransactional]);
$warnings = '';
if (ACYM_PRODUCTION) {
if ($externalSending) {
$result = false;
acym_trigger('onAcymRegisterReceiverContentAndList', [&$result, $this->Subject, $this->Body, $this->receiverEmail, $this->mailId, &$warnings]);
} else {
acym_trigger('onAcymBeforeEmailSend', [&$this]);
ob_start();
$result = parent::send();
$warnings = ob_get_clean();
}
}
if (!empty($warnings) && strpos($warnings, 'bloque')) {
$result = false;
}
$this->mailHeader = '';
$receivers = [];
foreach ($this->to as $oneReceiver) {
$receivers[] = $oneReceiver[0];
}
if (!$result) {
$this->reportMessage = acym_translationSprintf('ACYM_SEND_ERROR', ''.$this->Subject.'', ''.implode(' , ', $receivers).'');
if (!empty($this->ErrorInfo)) {
$this->reportMessage .= " \n\n ".$this->ErrorInfo;
}
if (!empty($warnings)) {
$this->reportMessage .= " \n\n ".$warnings;
}
$this->errorNumber = 1;
if ($this->report) {
$this->reportMessage = str_replace(
'Could not instantiate mail function',
''.acym_translation('ACYM_COUND_NOT_INSTANCIATE_MAIL_FUCNTION').'',
$this->reportMessage
);
acym_enqueueMessage(nl2br($this->reportMessage), 'error');
}
} else {
if ($this->isSendingMethodByListActive) {
$this->reportMessage = acym_translationSprintf(
'ACYM_SEND_SUCCESS_WITH_SENDING_METHOD',
''.$this->Subject.'',
''.implode(' , ', $receivers).'',
''.$this->currentSendingMethod.''
);
} else {
$this->reportMessage = acym_translationSprintf('ACYM_SEND_SUCCESS', ''.$this->Subject.'', ''.implode(' , ', $receivers).'');
}
if (!empty($warnings)) {
$this->reportMessage .= " \n\n ".$warnings;
}
if ($this->report) {
if (acym_isAdmin()) {
acym_enqueueMessage(preg_replace('#(){2}#', '
', nl2br($this->reportMessage)), 'info');
}
}
}
return $result;
}
public function clearAll()
{
$this->Subject = '';
$this->Body = '';
$this->AltBody = '';
$this->ClearAllRecipients();
$this->ClearAttachments();
$this->ClearCustomHeaders();
$this->ClearReplyTos();
$this->errorNumber = 0;
$this->MessageID = '';
$this->ErrorInfo = '';
$this->setFrom($this->getSendSettings('from_email'), $this->getSendSettings('from_name'));
}
public function load(int $mailId, $user = null)
{
if (isset($this->defaultMail[$mailId])) {
return $this->defaultMail[$mailId];
}
if (!empty($this->overrideEmailToSend)) {
$this->defaultMail[$mailId] = $this->overrideEmailToSend;
} else {
$this->defaultMail[$mailId] = $this->mailClass->getOneById($mailId, true);
}
global $acymLanguages;
if (!$this->isAbTest && empty($this->overrideEmailToSend) && acym_isMultilingual()) {
$defaultLanguage = $this->config->get('multilingual_default', ACYM_DEFAULT_LANGUAGE);
$mails = $this->mailClass->getMultilingualMails($mailId);
$this->userLanguage = $user != null && !empty($user->language) ? $user->language : $defaultLanguage;
if (!empty($mails)) {
$languages = array_keys($mails);
if (count($languages) == 1) {
$key = $languages[0];
} elseif (empty($mails[$this->userLanguage])) {
$key = $defaultLanguage;
} else {
$key = $this->userLanguage;
}
if (isset($mails[$key])) {
$this->defaultMail[$mailId] = $mails[$key];
}
} else {
unset($this->defaultMail[$mailId]);
return false;
}
$acymLanguages['userLanguage'] = $this->userLanguage;
$this->setFrom($this->getSendSettings('from_email'), $this->getSendSettings('from_name'));
}
if (empty($this->defaultMail[$mailId]->id)) {
unset($this->defaultMail[$mailId]);
return false;
}
if (!empty($this->defaultMail[$mailId]->attachments)) {
$this->defaultMail[$mailId]->attach = [];
$attachments = json_decode($this->defaultMail[$mailId]->attachments);
foreach ($attachments as $oneAttach) {
$attach = new \stdClass();
$attach->name = basename($oneAttach->filename);
$attach->filename = str_replace(['/', '\\'], DS, ACYM_ROOT).$oneAttach->filename;
$attach->url = ACYM_LIVE.$oneAttach->filename;
$this->defaultMail[$mailId]->attach[] = $attach;
}
}
$this->mailId = $mailId;
$this->id = $this->mailId;
$this->mail = clone $this->defaultMail[$mailId];
acym_trigger('replaceContent', [&$this->defaultMail[$mailId], true]);
$this->prepareEmailContent($mailId);
if (!$this->isTest) {
$this->storeArchiveVersion($mailId);
}
return $this->defaultMail[$mailId];
}
private function storeArchiveVersion($mailId)
{
$mailId = intval($mailId);
if (empty($mailId) || $this->defaultMail[$mailId]->type !== MailClass::TYPE_STANDARD) {
return;
}
$mailArchive = new \stdClass();
$alreadyExisting = $this->mailArchiveClass->getOneByMailId($mailId);
if (!empty($alreadyExisting)) {
$mailArchive->id = $alreadyExisting->id;
}
$mailArchive->mail_id = $mailId;
$mailArchive->date = time();
$mailArchive->body = $this->defaultMail[$mailId]->body;
$mailArchive->subject = $this->defaultMail[$mailId]->subject;
$mailArchive->settings = $this->defaultMail[$mailId]->settings;
$mailArchive->stylesheet = $this->defaultMail[$mailId]->stylesheet;
$mailArchive->attachments = $this->defaultMail[$mailId]->attachments;
$this->mailArchiveClass->save($mailArchive);
}
private function canTrack(int $mailId, object $user): bool
{
if ($this->isTest || empty($mailId) || empty($user) || !isset($user->tracking) || $user->tracking != 1) {
return false;
}
$mail = $this->mailClass->getOneById($mailId);
if (!empty($mail) && $mail->tracking != 1) {
return false;
}
$lists = $this->mailClass->getAllListsByMailIdAndUserId($mailId, $user->id);
foreach ($lists as $list) {
if ($list->tracking != 1) {
return false;
}
}
return true;
}
private function loadUser($user)
{
if (is_string($user) && strpos($user, '@')) {
$receiver = $this->userClass->getOneByEmail($user);
if (empty($receiver) && $this->autoAddUser && acym_isValidEmail($user)) {
$newUser = new \stdClass();
$newUser->email = $user;
$this->userClass->checkVisitor = false;
$this->userClass->sendConf = false;
acym_setVar('acy_source', 'When sending a test');
$this->userClass->triggers = $this->userCreationTriggers;
$userId = $this->userClass->save($newUser);
$receiver = $this->userClass->getOneById($userId);
}
} elseif (is_object($user)) {
$receiver = $user;
} else {
$receiver = $this->userClass->getOneById($user);
}
$this->userLanguage = empty($receiver->language) ? acym_getLanguageTag() : $receiver->language;
$this->receiverEmail = $receiver->email;
return $receiver;
}
public function sendOne($mailId, $user, array $options = []): bool
{
$this->clearAll();
$receiver = $this->loadUser($user);
$this->isTest = !empty($options['isTest']);
$this->dtextsFailed = false;
if (empty($receiver->email)) {
$this->errorNumber = 4;
$this->reportMessage = acym_translationSprintf('ACYM_SEND_ERROR_USER', ''.acym_escape($user).'');
if ($this->report) {
acym_enqueueMessage($this->reportMessage, 'error');
}
return false;
}
$mailId = intval($mailId);
$receiver->id = intval($receiver->id);
if (!$this->load($mailId, $receiver)) {
$this->reportMessage = 'Can not load the email with ID n°'.$mailId;
$this->errorNumber = 2;
if ($this->report) {
acym_enqueueMessage($this->reportMessage, 'error');
}
return false;
}
$this->prepareContent($mailId, $options);
$this->prepareHeaders($mailId, $receiver->id, $options);
$this->prepareAddresses($mailId, $receiver);
$this->prepareBcc($mailId, $options);
$this->prepareAttachments($mailId, $options);
$this->replaceDynamicContent($mailId);
$this->prepareTracking($mailId, $receiver);
if (!$this->handleDtexts($receiver)) {
$this->dtextsFailed = true;
return false;
}
$status = (bool)$this->send();
$this->initStatistics($status, $receiver->id);
return $status;
}
public function triggerFollowUpAgain(string $mailId, string $userId): void
{
if ($this->defaultMail[$mailId]->type !== MailClass::TYPE_FOLLOWUP) {
return;
}
$followUpClass = new FollowupClass();
$followUp = $followUpClass->getOneByMailId(intval($mailId));
if (empty($followUp)) {
return;
}
if (empty($followUp->loop)) {
return;
}
$lastEmail = $followUpClass->getLastEmail(intval($followUp->id));
if (empty($lastEmail) || $lastEmail->id != $mailId) {
return;
}
$delay = 0;
if (!empty($followUp->loop_delay)) {
$delay = $followUp->loop_delay;
}
$mailToSkip = [];
if (!empty($followUp->loop_mail_skip)) {
$mailToSkip = json_decode($followUp->loop_mail_skip);
}
$followUpClass->triggerFollowUp(intval($followUp->id), intval($userId), $delay, $mailToSkip);
}
private function prepareContent(int $mailId, array $options): void
{
$this->isHTML();
if (!empty($this->defaultMail[$mailId]->stylesheet)) {
$this->stylesheet = $this->defaultMail[$mailId]->stylesheet;
}
$this->settings = empty($this->defaultMail[$mailId]->settings) ? [] : json_decode($this->defaultMail[$mailId]->settings, true);
$this->Subject = $this->defaultMail[$mailId]->subject;
$this->Body = $this->defaultMail[$mailId]->body;
if ($this->isTest && !empty($options['testNote'])) {
$this->Body = ''.$options['testNote'].'
'.$this->Body;
}
if (!empty($this->introtext)) {
$this->Body = $this->introtext.$this->Body;
}
if (!empty($this->defaultMail[$mailId]->preheader)) {
$preHeader = '';
$preHeader .= $this->defaultMail[$mailId]->preheader.str_repeat(' ', 100);
$preHeader .= '
';
preg_match('#(<(.*))#Uis', $this->Body, $matches);
if (empty($matches) || empty($matches[1])) {
$this->Body = $preHeader.$this->Body;
} else {
$this->Body = $matches[1].$preHeader.str_replace($matches[1], '', $this->Body);
}
}
if (ACYM_CMS === 'wordpress') {
ob_start();
$this->Body = do_shortcode($this->Body);
ob_end_clean();
}
}
private function prepareHeaders(int $mailId, int $receiverId, array $options): void
{
$subject = base64_encode(rand(0, 9999999)).'AC'.$receiverId.'Y'.$this->defaultMail[$mailId]->id.'BA'.base64_encode(time().rand(0, 99999));
$this->MessageID = '<'.preg_replace('|[^a-z0-9+_]|i', '', $subject).'@'.$this->serverHostname().'>';
$this->addCustomHeader('Feedback-ID', $this->defaultMail[$mailId]->id.':'.$receiverId.':'.$this->defaultMail[$mailId]->type.':'.base64_encode(ACYM_ROOT));
if (!empty($this->defaultMail[$mailId]->headers)) {
$this->mailHeader = $this->defaultMail[$mailId]->headers;
}
if (!empty($options['headers'])) {
foreach ($options['headers'] as $headerName => $headerValue) {
$this->addCustomHeader(trim($headerName), trim($headerValue));
}
}
}
private function prepareAddresses(int $mailId, object $receiver): void
{
$receiverName = '';
if ($this->config->get('add_names', true)) {
$receiverName = $this->cleanText($receiver->name);
if ($receiverName == $this->cleanText($receiver->email)) {
$receiverName = '';
}
}
$this->addAddress($this->cleanText($receiver->email), $receiverName);
$this->setFrom($this->getSendSettings('from_email', $mailId), $this->getSendSettings('from_name', $mailId));
$this->_addReplyTo($this->defaultMail[$mailId]->reply_to_email, $this->defaultMail[$mailId]->reply_to_name);
if (!empty($this->defaultMail[$mailId]->bounce_email)) {
$this->Sender = $this->cleanText($this->defaultMail[$mailId]->bounce_email);
} else {
$this->Sender = $this->cleanText($this->config->get('bounce_email'));
}
}
private function prepareBcc(int $mailId, array $options): void
{
$bccAddresses = [];
if (!empty($options['bcc'])) {
$bccAddresses = $options['bcc'];
}
if (!empty($this->defaultMail[$mailId]->bcc)) {
$emailBccAddresses = explode(';', trim(str_replace([',', ' '], ';', $this->defaultMail[$mailId]->bcc)));
$bccAddresses = array_unique(array_merge($bccAddresses, $emailBccAddresses));
}
if (!empty($bccAddresses)) {
$bccAddresses = array_filter($bccAddresses);
foreach ($bccAddresses as $oneBccAddress) {
$this->loadUser($oneBccAddress);
$this->addBCC($oneBccAddress);
}
}
}
private function prepareAttachments(int $mailId, array $options): void
{
$attachments = [];
if (!empty($this->defaultMail[$mailId]->attach)) {
$attachments = $this->defaultMail[$mailId]->attach;
}
if (!empty($options['attachments'])) {
$attachments = array_merge($attachments, $options['attachments']);
}
if (empty($attachments)) {
return;
}
if ($this->config->get('embed_files')) {
foreach ($attachments as $attachment) {
$this->addAttachment($attachment->filename, $attachment->name);
}
} else {
$attachStringHTML = '';
if ($this->config->get('attachments_position', 'bottom') === 'top') {
$this->Body = $attachStringHTML.'
'.$this->Body;
} else {
$this->Body .= '
'.$attachStringHTML;
}
}
}
private function replaceDynamicContent(int $mailId): void
{
$this->replaceParams();
$this->body = &$this->Body;
$this->altbody = &$this->AltBody;
$this->subject = &$this->Subject;
$this->from = &$this->From;
$this->fromName = &$this->FromName;
$this->replyto = &$this->ReplyTo;
$this->replyname = $this->defaultMail[$mailId]->reply_to_name;
$this->replyemail = $this->defaultMail[$mailId]->reply_to_email;
$this->mailId = $this->defaultMail[$mailId]->id;
$this->id = $this->mailId;
$this->creator_id = $this->defaultMail[$mailId]->creator_id;
$this->type = $this->defaultMail[$mailId]->type;
$this->stylesheet = &$this->stylesheet;
$this->links_language = $this->defaultMail[$mailId]->links_language;
}
private function prepareTracking(int $mailId, object $receiver): void
{
if ($this->canTrack($mailId, $receiver)) {
$this->statPicture($this->mailId, $receiver->id);
$this->body = acym_absoluteURL($this->body);
$this->statClick($this->mailId, $receiver->id);
if (acym_isTrackingSalesActive()) {
$this->trackingSales($this->mailId, $receiver->id);
}
}
}
private function handleDtexts(object $receiver): bool
{
$this->replaceParams();
if (strpos($receiver->email, '@mt.acyba.com') !== false) {
$currentUser = $this->userClass->getOneByEmail(acym_currentUserEmail());
if (empty($currentUser)) {
$currentUser = $receiver;
}
$result = acym_trigger('replaceUserInformation', [&$this, &$currentUser, true]);
} else {
$result = acym_trigger('replaceUserInformation', [&$this, &$receiver, true]);
if (!empty($result)) {
foreach ($result as $oneResult) {
if (!empty($oneResult) && !$oneResult['send']) {
$this->reportMessage = $oneResult['message'];
return false;
}
}
}
}
global $acymLanguages;
if (!empty($acymLanguages['userLanguage'])) {
unset($acymLanguages['userLanguage']);
}
foreach ($result as $oneResult) {
if (!empty($oneResult['emogrifier'])) {
$this->prepareEmailContent();
break;
}
}
if ($this->config->get('multiple_part', false)) {
$this->altbody = $this->textVersion($this->Body);
}
$this->replaceParams();
return true;
}
private function initStatistics(bool $status, int $receiverId): void
{
if ($this->trackEmail) {
$statsAdd = [];
$statsAdd[$this->mailId][intval($status)][] = $receiverId;
$queueHelper = new QueueHelper();
$queueHelper->statsAdd($statsAdd);
$this->trackEmail = false;
}
}
private function trackingSales($mailId, $userId)
{
preg_match_all('#href[ ]*=[ ]*"(?!mailto:|\#|ymsgr:|callto:|file:|ftp:|webcal:|skype:|tel:)([^"]+)"#Ui', $this->body, $results);
if (empty($results)) return;
foreach ($results[1] as $key => $url) {
$simplifiedUrl = str_replace(['https://', 'http://', 'www.'], '', $url);
$simplifiedWebsite = str_replace(['https://', 'http://', 'www.'], '', ACYM_LIVE);
if (strpos($simplifiedUrl, rtrim($simplifiedWebsite, '/')) === false || strpos($url, 'task=unsub')) continue;
$toAddUrl = (strpos($url, '?') === false ? '?' : '&').'linkReferal='.$mailId.'-'.$userId;
$posHash = strpos($url, '#');
if ($posHash !== false) {
$newURL = substr($url, 0, $posHash).$toAddUrl.substr($url, $posHash);
} else {
$newURL = $url.$toAddUrl;
}
$this->body = preg_replace('#href="('.preg_quote($url, '#').')"#Uis', 'href="'.$newURL.'"', $this->body);
}
}
public function statPicture($mailId, $userId)
{
$pictureLink = acym_frontendLink('frontstats&task=openStats&id='.$mailId.'&userid='.$userId, true, false);
$widthsize = 50;
$heightsize = 1;
$width = empty($widthsize) ? '' : ' width="'.$widthsize.'" ';
$height = empty($heightsize) ? '' : ' height="'.$heightsize.'" ';
$statPicture = '
';
if (strpos($this->body, ' ')) {
$this->body = str_replace('', $statPicture.'', $this->body);
} else {
$this->body .= $statPicture;
}
}
public function statClick($mailId, $userid, $fromStat = false)
{
if (!$fromStat && !in_array($this->type, MailClass::TYPES_WITH_STATS)) {
return;
}
$urlClass = new UrlClass();
$urls = [];
$trackingSystemExternalWebsite = $this->config->get('trackingsystemexternalwebsite', 1);
$trackingSystem = $this->config->get('trackingsystem', 'acymailing');
if (false === strpos($trackingSystem, 'acymailing') && false === strpos($trackingSystem, 'google')) {
return;
}
if (strpos($trackingSystem, 'google') !== false) {
$mail = $this->mailClass->getOneById($mailId);
$campaignClass = new CampaignClass();
$campaign = $campaignClass->getOneCampaignByMailId($mailId);
$utmCampaign = acym_getAlias($mail->subject);
}
preg_match_all('#<[^>]* href[ ]*=[ ]*"(?!mailto:|\#|ymsgr:|callto:|file:|ftp:|webcal:|skype:|tel:)([^"]+)"#Ui', $this->body, $results);
if (empty($results)) {
return;
}
$countLinks = array_count_values($results[1]);
if (array_product($countLinks) != 1) {
$previousLinkHandled = '';
foreach ($results[1] as $key => $url) {
if ($countLinks[$url] === 1) {
continue;
}
$previousIsOutlook = false;
if (strpos($results[0][$key], '