'.var_export($resp, true)), 'error'); return; } $json = json_decode($resp['body'], true); if(empty($json['license'])){ gosmtp_notify(__('The license key is invalid'), 'error'); return; } $json['last_update'] = time(); update_option('gosmtp_license', $json); gosmtp_notify(__('Successfully updated the license key')); gosmtp_pro_load_license(); } function gosmtp_notify($message, $type = 'updated', $dismissible = true){ $is_dismissible = ''; if(!empty($dismissible)){ $is_dismissible = 'is-dismissible'; } if(!empty($message)){ echo '
'.$message.'
|
license['license'])){
$expires = $gosmtp->license['expires'];
$expires = substr($expires, 0, 4).'/'.substr($expires, 4, 2).'/'.substr($expires, 6);
echo ' License Status : '.(empty($gosmtp->license['status_txt']) ? 'N.A.' : wp_kses_post($gosmtp->license['status_txt'])).'
License Expires : '.($gosmtp->license['expires'] <= date('Ymd') ? ''.esc_attr($expires).'' : esc_attr($expires)).'
';
}?>
|
|
| URL | |
| Path | |
| .htaccess | Yes' : 'No');?> |
"';
$email = '
GOSMTP Weekly Email Summary
';
if($send_email || isset($_GET['test_reports'])){
$headers = array( 'Content-Type: text/html; charset=UTF-8' );
$admin_email = get_option('admin_email');
if(!empty($admin_email)){
$title = 'Weekly Report';
if(wp_mail($admin_email, $title, $email, $headers)){
echo '
';
}else{
echo '
';
}
}else{
echo "";
}
}
// Update Timestamp
if($send_email){
$gosmtp->options['weekly_reports']['timestamp'] = strtotime("next ".$gosmtp->options['weekly_reports']['weekday']);
update_option( 'gosmtp_options', $gosmtp->options );
return;
}
$email.= '
';
echo $email;
}
?>
main/gosmtp-init.php 0000644 00000012167 15171073004 0010460 0 ustar 00 addQueryArgFilter('gosmtp_pro_updater_filter_args');
// Show the text to install the license key
add_filter('puc_manual_final_check_link-gosmtp-pro', 'gosmtp_pro_updater_check_link', 10, 1);
// Nag informing the user to install the free version.
if(current_user_can('activate_plugins')){
add_action('admin_notices', 'gosmtp_pro_free_version_nag', 9);
add_action('admin_menu', 'gosmtp_pro_add_menu', 9);
}
$is_network_wide = gosmtp_pro_is_network_active('gosmtp-pro');
$_do_version = get_option('gosmtp_version');
$req_free_update = !empty($_do_version) && version_compare($_do_version, '1.0.7', '<');
if($is_network_wide){
$free_installed = get_site_option('gosmtp_free_installed');
}else{
$free_installed = get_option('gosmtp_free_installed');
}
if(!empty($free_installed)){
return;
}
// Include the necessary stuff
include_once(ABSPATH . 'wp-admin/includes/plugin-install.php');
include_once(ABSPATH . 'wp-admin/includes/plugin.php');
include_once(ABSPATH . 'wp-admin/includes/file.php');
if(file_exists(WP_PLUGIN_DIR . '/gosmtp/gosmtp.php') && is_plugin_inactive('/gosmtp/gosmtp.php') && empty($req_free_update)) {
if($is_network_wide){
update_site_option('gosmtp_free_installed', time());
}else{
update_option('gosmtp_free_installed', time());
}
activate_plugin('/gosmtp/gosmtp.php', '', $is_network_wide);
remove_action('admin_notices', 'gosmtp_pro_free_version_nag', 9);
remove_action('admin_menu', 'gosmtp_pro_add_menu', 9);
return;
}
// Includes necessary for Plugin_Upgrader and Plugin_Installer_Skin
include_once(ABSPATH . 'wp-admin/includes/misc.php');
include_once(ABSPATH . 'wp-admin/includes/class-wp-upgrader.php');
// Filter to prevent the activate text
add_filter('install_plugin_complete_actions', 'gosmtp_pro_prevent_activation_text', 10, 3);
$upgrader = new Plugin_Upgrader(new WP_Ajax_Upgrader_Skin());
// Upgrade the plugin to the latest version of free already installed.
if(!empty($req_free_update)){
$installed = $upgrader->upgrade('gosmtp/gosmtp.php');
}else{
$installed = $upgrader->install('https://downloads.wordpress.org/plugin/gosmtp.zip');
}
if(!is_wp_error($installed) && $installed){
if($is_network_wide){
update_site_option('gosmtp_free_installed', time());
}else{
update_option('gosmtp_free_installed', time());
}
activate_plugin('gosmtp/gosmtp.php', '', $is_network_wide);
remove_action('admin_notices', 'gosmtp_pro_free_version_nag', 9);
remove_action('admin_menu', 'gosmtp_pro_add_menu', 9);
}
}
// Do not shows the activation text if
function gosmtp_pro_prevent_activation_text($install_actions, $api, $plugin_file){
if($plugin_file == 'gosmtp/gosmtp.php'){
return array();
}
return $install_actions;
}
function gosmtp_pro_free_version_nag(){
$go_version = get_option('gosmtp_version');
$lower_version = __('You have not installed the free version of GoSMTP. GoSMTP Pro depends on the free version, so you must install it first in order to use GoSMTP Pro.');
if(!empty($go_version) && version_compare($go_version, '1.0.7', '<')){
$lower_version = __('You are using an older version of the free version of GoSMTP, please update GoSMTP to work without any issues');
}
echo ' | ||||||||||||||||||||||||
| ||||||||||||||||||||||||
'.__('Email Sent successfully to ').' '.$admin_email.'.
'.__('Weekly email reports were sent from: '.$start.' to: '.$end.'').'
'.__('Failed to send email to ').' '.__($admin_email).''.__('. Plesae check ').''. __(' Email logs ').''.__('for more info.').'
'.esc_html($lower_version).' Install/Update Now
GoSMTP Free version is not installed / outdated!
GoSMTP Pro depends on the free version of GoSMTP, so you need to install / update the free version first.
Install/Update NowEmail report is disabled
'.__('To view email reports, please enable email logs from GoSMTP').' '.__('settings').'.
| '.$mail_array[$ck].' | '; } echo '||||||||
- ';
foreach ( $pages as $page ) {
echo '
- '.$page.' '; } echo '
%s
new $class(...).
*/
class Gosmtp_PucFactory {
protected static $classVersions = array();
protected static $sorted = false;
/**
* Create a new instance of GosmtpUpdateChecker.
*
* @see GosmtpUpdateChecker::__construct()
*
* @param $metadataUrl
* @param $pluginFile
* @param string $slug
* @param int $checkPeriod
* @param string $optionName
* @param string $muPluginFile
* @return GosmtpUpdateChecker_3_2
*/
public static function buildUpdateChecker($metadataUrl, $pluginFile, $slug = '', $checkPeriod = 12, $optionName = '', $muPluginFile = '') {
$class = self::getLatestClassVersion('GosmtpUpdateChecker');
return new $class($metadataUrl, $pluginFile, $slug, $checkPeriod, $optionName, $muPluginFile);
}
/**
* Get the specific class name for the latest available version of a class.
*
* @param string $class
* @return string|null
*/
public static function getLatestClassVersion($class) {
if ( !self::$sorted ) {
self::sortVersions();
}
if ( isset(self::$classVersions[$class]) ) {
return reset(self::$classVersions[$class]);
} else {
return null;
}
}
/**
* Sort available class versions in descending order (i.e. newest first).
*/
protected static function sortVersions() {
foreach ( self::$classVersions as $class => $versions ) {
uksort($versions, array(__CLASS__, 'compareVersions'));
self::$classVersions[$class] = $versions;
}
self::$sorted = true;
}
protected static function compareVersions($a, $b) {
return -version_compare($a, $b);
}
/**
* Register a version of a class.
*
* @access private This method is only for internal use by the library.
*
* @param string $generalClass Class name without version numbers, e.g. 'GosmtpUpdateChecker'.
* @param string $versionedClass Actual class name, e.g. 'GosmtpUpdateChecker_1_2'.
* @param string $version Version number, e.g. '1.2'.
*/
public static function addVersion($generalClass, $versionedClass, $version) {
if ( !isset(self::$classVersions[$generalClass]) ) {
self::$classVersions[$generalClass] = array();
}
self::$classVersions[$generalClass][$version] = $versionedClass;
self::$sorted = false;
}
}
endif;
//Register classes defined in this file with the factory.
Gosmtp_PucFactory::addVersion('GosmtpUpdateChecker', 'GosmtpUpdateChecker_3_2', '3.2');
Gosmtp_PucFactory::addVersion('GosmtpUpdate', 'GosmtpUpdate_3_2', '3.2');
Gosmtp_PucFactory::addVersion('GosmtpInfo', 'GosmtpInfo_3_2', '3.2');
Gosmtp_PucFactory::addVersion('Gosmtp_PucGitHubChecker', 'Gosmtp_PucGitHubChecker_3_2', '3.2');
main/logger.php 0000644 00000011173 15171073004 0007461 0 ustar 00 table = $wpdb->prefix . GOSMTP_DB_PREFIX .'email_logs';
}
public function create_table(){
global $wpdb;
$charsetCollate = $wpdb->get_charset_collate();
if($wpdb->get_var("SHOW TABLES LIKE '$this->table'") == $this->table){
return;
}
$sql = "CREATE TABLE $this->table (
`id` INT UNSIGNED NOT NULL PRIMARY KEY AUTO_INCREMENT,
`site_id` INT UNSIGNED NULL,
`message_id` VARCHAR(255) NULL,
`to` VARCHAR(255),
`from` VARCHAR(255),
`subject` VARCHAR(255),
`body` LONGTEXT NULL,
`headers` LONGTEXT NULL,
`attachments` LONGTEXT NULL,
`status` VARCHAR(20) DEFAULT 'pending',
`response` TEXT NULL,
`extra` TEXT NULL,
`retries` INT UNSIGNED NULL DEFAULT 0,
`resent_count` INT UNSIGNED NULL DEFAULT 0,
`provider` TEXT NULL,
`source` VARCHAR(255) NULL,
`created_at` TIMESTAMP NULL,
`updated_at` TIMESTAMP NULL,
`parent_id` INT UNSIGNED NULL DEFAULT 0
) $charsetCollate;";
// Make Sitepad compatible
$upgrade = ABSPATH . 'site-admin/includes/upgrade.php';
$upgrade = file_exists($upgrade) ? $upgrade : ABSPATH . 'wp-admin/includes/upgrade.php';
require_once( $upgrade );
dbDelta($sql);
}
public function add_logs($data){
global $wpdb;
if(empty($data)){
return false;
}
$result = $wpdb->insert($this->table, $data);
if($result){
return $wpdb->insert_id;
}
return false;
}
public function update_logs($data, $id){
global $wpdb;
if(empty($data) || empty($id)){
return false;
}
$result = $wpdb->update( $this->table, $data, array( 'id' => $id ) );
if($result){
return true;
}
return false;
}
public function delete_log($id){
global $wpdb;
$data['id'] = $id;
$result = $wpdb->delete($this->table, $data);
if(!empty($result)){
return true;
}
return false;
}
public function get_logs($for = 'records', $id = '', $args = array()){
global $wpdb;
$defaults = array(
'interval' => array(),
'limit' => 10,
'offset' => 0,
'pagination' => true,
'multiselect' => array(),
);
$args = wp_parse_args( $args, $defaults );
$query = '';
$start = '';
$end = date('y-m-d').' 23:59:59';
if(!empty($args['filter'])){
$query .= 'status="'.$args['filter'].'"';
}
if(!empty($args['interval']) && !empty($args['interval']['start'])){
$start = $args['interval']['start'].' 00:00:00';
if(!empty($args['interval']['end'])){
$end = $args['interval']['end'].' 23:59:59';
}
$query .= (!empty($query) ? ' and (' : '').'`created_at` between "'.$start.'" and "'.$end.'" '.(!empty($query) ? ') ' : ' ');
}
if(!empty($args['search']) && empty($args['multiselect'])){
$query .= (!empty($query) ? ' and ' : '').' (
`from` like "%'. $args['search'] .'%" or
`subject` like "%'. $args['search'] .'%" or
`to` like "%'. $args['search'] .'%" or
`body` like "%'. $args['search'] .'%" )';
}else if(!empty($args['search'])){
$search_qry ='';
foreach($args['multiselect'] as $key => $value){
$search_qry .= '`'.$value.'` like "%'.$args['search'].'%"';
if(count($args['multiselect']) - 1 > $key){
$search_qry .= ' or ';
}
}
$query .= (!empty($query) ? ' and ' : '').' ('.$search_qry.')';
}
if(!empty($query)){
$query = ' where '.$query;
}
if(!empty($id)){
$query = ' where id='.$id;
}else if(!empty($args['pagination'])){
$query .= $for != 'count' ? ' order by id desc LIMIT '.$args['limit'].' OFFSET '.$args['offset'] : ' ';
}
// echo "SELECT * FROM ".$this->table. $query;
try{
if($for == 'count'){
$result = $wpdb->get_results("SELECT count(*) as records FROM ".$this->table. $query)[0];
}else{
$result = $wpdb->get_results("SELECT * FROM ".$this->table. $query);
if( count($result) == 0 ){
return false;
}
}
return $result;
}catch(\Exception $e){}
return false;
}
public function clear_records( $period = 0 ){
if( empty($period) || $period == 0 ) return;
global $wpdb;
$date = ( new \DateTime( '-'.$period.' seconds' ))->format('Y-m-d H:i:s');
$query = 'DELETE FROM `'.$this->table.'` WHERE created_at < %s';
if( $period == -1 ){
$query = 'TRUNCATE TABLE '.$this->table;
$date = '';
}
$wpdb->query(
$wpdb->prepare( $query , $date)
);
}
public static function retention_logs(){
global $gosmtp;
if(empty($gosmtp->options['logs']['retention_period'])){
return;
}
$logger = new Logger();
// Clear logs
$logger->clear_records($gosmtp->options['logs']['retention_period']);
}
} main/smtp-logs.php 0000644 00000035147 15171073004 0010136 0 ustar 00 options['logs']['enable_logs']) ){
echo ''.__('Email logs is disabled').'
'.__('To store and view email logs, please enable email logs from GoSMTP').' '.__('settings').'.
If you are operating under EU laws, you may be required to use EU region. More information on aws.amazon.com.' ), ) ); return $fields; } } main/mailer/amazonses/emailservice.php 0000644 00000056721 15171073004 0014133 0 ustar 00 setAuth($accessKey, $secretKey); } $this->__host = $host; $this->__trigger_errors = $trigger_errors; $this->__requestSignatureVersion = $requestSignatureVersion; } /** * Set the request signature version * * @param string $requestSignatureVersion * @return EmailService $this */ public function setRequestSignatureVersion($requestSignatureVersion) { $this->__requestSignatureVersion = $requestSignatureVersion; return $this; } /** * @return string */ public function getRequestSignatureVersion() { return $this->__requestSignatureVersion; } /** * Set AWS access key and secret key * * @param string $accessKey Access key * @param string $secretKey Secret key * @return EmailService $this */ public function setAuth($accessKey, $secretKey) { $this->__accessKey = $accessKey; $this->__secretKey = $secretKey; return $this; } /** * Set AWS Host * @param string $host AWS Host */ public function setHost($host = self::AWS_US_EAST_1) { $this->__host = $host; return $this; } /** * @deprecated */ public function enableVerifyHost($enable = true) { $this->__verifyHost = (bool)$enable; return $this; } /** * @deprecated */ public function enableVerifyPeer($enable = true) { $this->__verifyPeer = (bool)$enable; return $this; } /** * @deprecated */ public function verifyHost() { return $this->__verifyHost; } /** * @deprecated */ public function verifyPeer() { return $this->__verifyPeer; } /** * Get AWS target host * @return boolean */ public function getHost() { return $this->__host; } /** * Get AWS SES auth access key * @return string */ public function getAccessKey() { return $this->__accessKey; } /** * Get AWS SES auth secret key * @return string */ public function getSecretKey() { return $this->__secretKey; } /** * Get the verify peer CURL mode * @return boolean */ public function getVerifyPeer() { return $this->__verifyPeer; } /** * Get the verify host CURL mode * @return boolean */ public function getVerifyHost() { return $this->__verifyHost; } /** * Get bulk email sending mode * @return boolean * @deprecated */ public function getBulkMode() { return $this->__bulk_sending_mode; } /** * Enable/disable CURLOPT_SSL_VERIFYHOST for EmailServiceRequest's curl handler * verifyHost and verifyPeer determine whether curl verifies ssl certificates. * It may be necessary to disable these checks on certain systems. * These only have an effect if SSL is enabled. * * @param boolean $enable New status for the mode * @return EmailService $this */ public function setVerifyHost($enable = true) { $this->__verifyHost = (bool)$enable; return $this; } /** * Enable/disable CURLOPT_SSL_VERIFYPEER for EmailServiceRequest's curl handler * verifyHost and verifyPeer determine whether curl verifies ssl certificates. * It may be necessary to disable these checks on certain systems. * These only have an effect if SSL is enabled. * * @param boolean $enable New status for the mode * @return EmailService $this */ public function setVerifyPeer($enable = true) { $this->__verifyPeer = (bool)$enable; return $this; } /** * Enable/disable bulk email sending mode * * @param boolean $enable New status for the mode * @return EmailService $this * @deprecated */ public function setBulkMode($enable = true) { $this->__bulk_sending_mode = (bool)$enable; return $this; } /** * Lists the email addresses that have been verified and can be used as the 'From' address * * @return array An array containing two items: a list of verified email addresses, and the request id. */ public function listVerifiedEmailAddresses() { $ses_request = $this->getRequestHandler('GET'); $ses_request->setParameter('Action', 'ListIdentities'); $ses_response = $ses_request->getResponse(); if ($ses_response->error === false && $ses_response->code !== 200) { $ses_response->error = array('code' => $ses_response->code, 'message' => 'Unexpected HTTP status'); } if ($ses_response->error !== false) { $this->__triggerError('ListIdentities', $ses_response->error); return []; } $response = array(); if (!isset($ses_response->body)) { return $response; } $addresses = array(); foreach ($ses_response->body->ListIdentitiesResult->Identities->member as $address) { if(is_email($address)) { $addresses[] = (string)$address; } } $response['Addresses'] = $addresses; $response['RequestId'] = (string)$ses_response->body->ResponseMetadata->RequestId; return $response; } /** * Requests verification of the provided email address, so it can be used * as the 'From' address when sending emails through EmailService. * * After submitting this request, you should receive a verification email * from Amazon at the specified address containing instructions to follow. * * @param string $email The email address to get verified * @return array The request id for this request. */ public function verifyEmailAddress($email) { $ses_request = $this->getRequestHandler('POST'); $ses_request->setParameter('Action', 'VerifyEmailAddress'); $ses_request->setParameter('EmailAddress', $email); $ses_response = $ses_request->getResponse(); if ($ses_response->error === false && $ses_response->code !== 200) { $ses_response->error = array('code' => $ses_response->code, 'message' => 'Unexpected HTTP status'); } if ($ses_response->error !== false) { $this->__triggerError('verifyEmailAddress', $ses_response->error); return false; } $response['RequestId'] = (string)$ses_response->body->ResponseMetadata->RequestId; return $response; } /** * Removes the specified email address from the list of verified addresses. * * @param string $email The email address to remove * @return array The request id for this request. */ public function deleteVerifiedEmailAddress($email) { $ses_request = $this->getRequestHandler('DELETE'); $ses_request->setParameter('Action', 'DeleteVerifiedEmailAddress'); $ses_request->setParameter('EmailAddress', $email); $ses_response = $ses_request->getResponse(); if ($ses_response->error === false && $ses_response->code !== 200) { $ses_response->error = array('code' => $ses_response->code, 'message' => 'Unexpected HTTP status'); } if ($ses_response->error !== false) { $this->__triggerError('deleteVerifiedEmailAddress', $ses_response->error); return false; } $response['RequestId'] = (string)$ses_response->body->ResponseMetadata->RequestId; return $response; } /** * Retrieves information on the current activity limits for this account. * See http://docs.amazonwebservices.com/ses/latest/APIReference/API_GetSendQuota.html * * @return array An array containing information on this account's activity limits. */ public function getSendQuota() { $ses_request = $this->getRequestHandler('GET'); $ses_request->setParameter('Action', 'GetSendQuota'); $ses_response = $ses_request->getResponse(); if ($ses_response->error === false && $ses_response->code !== 200) { $ses_response->error = array('code' => $ses_response->code, 'message' => 'Unexpected HTTP status'); } if ($ses_response->error !== false) { $this->__triggerError('getSendQuota', $ses_response->error); return false; } $response = array(); if (!isset($ses_response->body)) { return $response; } $response['Max24HourSend'] = (string)$ses_response->body->GetSendQuotaResult->Max24HourSend; $response['MaxSendRate'] = (string)$ses_response->body->GetSendQuotaResult->MaxSendRate; $response['SentLast24Hours'] = (string)$ses_response->body->GetSendQuotaResult->SentLast24Hours; $response['RequestId'] = (string)$ses_response->body->ResponseMetadata->RequestId; return $response; } /** * Retrieves statistics for the last two weeks of activity on this account. * See http://docs.amazonwebservices.com/ses/latest/APIReference/API_GetSendStatistics.html * * @return array An array of activity statistics. Each array item covers a 15-minute period. */ public function getSendStatistics() { $ses_request = $this->getRequestHandler('GET'); $ses_request->setParameter('Action', 'GetSendStatistics'); $ses_response = $ses_request->getResponse(); if ($ses_response->error === false && $ses_response->code !== 200) { $ses_response->error = array('code' => $ses_response->code, 'message' => 'Unexpected HTTP status'); } if ($ses_response->error !== false) { $this->__triggerError('getSendStatistics', $ses_response->error); return false; } $response = array(); if (!isset($ses_response->body)) { return $response; } $datapoints = array(); foreach ($ses_response->body->GetSendStatisticsResult->SendDataPoints->member as $datapoint) { $p = array(); $p['Bounces'] = (string)$datapoint->Bounces; $p['Complaints'] = (string)$datapoint->Complaints; $p['DeliveryAttempts'] = (string)$datapoint->DeliveryAttempts; $p['Rejects'] = (string)$datapoint->Rejects; $p['Timestamp'] = (string)$datapoint->Timestamp; $datapoints[] = $p; } $response['SendDataPoints'] = $datapoints; $response['RequestId'] = (string)$ses_response->body->ResponseMetadata->RequestId; return $response; } /** * Given a EmailServiceMessage object, submits the message to the service for sending. * * @param EmailServiceMessage $sesMessage An instance of the message class * @param boolean $use_raw_request If this is true or there are attachments to the email `SendRawEmail` call will be used * @param boolean $trigger_error Optionally overwrite the class setting for triggering an error (with type check to true/false) * @return array An array containing the unique identifier for this message and a separate request id. * Returns false if the provided message is missing any required fields. * @link(AWS SES Response formats, http://docs.aws.amazon.com/ses/latest/DeveloperGuide/query-interface-responses.html) */ public function sendEmail($sesMessage, $use_raw_request = false, $trigger_error = null) { if (!$sesMessage->validate()) { $this->__triggerError('sendEmail', 'Message failed validation.'); return false; } $ses_request = $this->getRequestHandler('POST'); $action = !empty($sesMessage->attachments) || $use_raw_request ? 'SendRawEmail' : 'SendEmail'; $ses_request->setParameter('Action', $action); // Works with both calls if (!is_null($sesMessage->configuration_set)) { $ses_request->setParameter('ConfigurationSetName', $sesMessage->configuration_set); } if ($action == 'SendRawEmail') { // https://docs.aws.amazon.com/ses/latest/APIReference/API_SendRawEmail.html $ses_request->setParameter('RawMessage.Data', $sesMessage->mime); } else { $i = 1; foreach ($sesMessage->to as $to) { $ses_request->setParameter('Destination.ToAddresses.member.' . $i, $sesMessage->encodeRecipients($to)); $i++; } if (is_array($sesMessage->cc)) { $i = 1; foreach ($sesMessage->cc as $cc) { $ses_request->setParameter('Destination.CcAddresses.member.' . $i, $sesMessage->encodeRecipients($cc)); $i++; } } if (is_array($sesMessage->bcc)) { $i = 1; foreach ($sesMessage->bcc as $bcc) { $ses_request->setParameter('Destination.BccAddresses.member.' . $i, $sesMessage->encodeRecipients($bcc)); $i++; } } if (is_array($sesMessage->replyto)) { $i = 1; foreach ($sesMessage->replyto as $replyto) { $ses_request->setParameter('ReplyToAddresses.member.' . $i, $sesMessage->encodeRecipients($replyto)); $i++; } } $ses_request->setParameter('Source', $sesMessage->encodeRecipients($sesMessage->from)); if ($sesMessage->returnpath != null) { $ses_request->setParameter('ReturnPath', $sesMessage->returnpath); } if ($sesMessage->subject != null && strlen($sesMessage->subject) > 0) { $ses_request->setParameter('Message.Subject.Data', $sesMessage->subject); if ($sesMessage->subjectCharset != null && strlen($sesMessage->subjectCharset) > 0) { $ses_request->setParameter('Message.Subject.Charset', $sesMessage->subjectCharset); } } if ($sesMessage->messagetext != null && strlen($sesMessage->messagetext) > 0) { $ses_request->setParameter('Message.Body.Text.Data', $sesMessage->messagetext); if ($sesMessage->messageTextCharset != null && strlen($sesMessage->messageTextCharset) > 0) { $ses_request->setParameter('Message.Body.Text.Charset', $sesMessage->messageTextCharset); } } if ($sesMessage->messagehtml != null && strlen($sesMessage->messagehtml) > 0) { $ses_request->setParameter('Message.Body.Html.Data', $sesMessage->messagehtml); if ($sesMessage->messageHtmlCharset != null && strlen($sesMessage->messageHtmlCharset) > 0) { $ses_request->setParameter('Message.Body.Html.Charset', $sesMessage->messageHtmlCharset); } } $i = 1; foreach ($sesMessage->message_tags as $key => $value) { $ses_request->setParameter('Tags.member.' . $i . '.Name', $key); $ses_request->setParameter('Tags.member.' . $i . '.Value', $value); $i++; } } $ses_response = $ses_request->getResponse(); if ($ses_response->error === false && $ses_response->code !== 200) { $response = array( 'code' => $ses_response->code, 'error' => array('Error' => array('message' => 'Unexpected HTTP status')), ); return $response; } if ($ses_response->error !== false) { if (($this->__trigger_errors && ($trigger_error !== false)) || $trigger_error === true) { $this->__triggerError('sendEmail', $ses_response->error); return false; } return $ses_response; } $response = array( 'MessageId' => (string)$ses_response->body->{"{$action}Result"}->MessageId, 'RequestId' => (string)$ses_response->body->ResponseMetadata->RequestId, ); return $response; } public function sendRawEmail($sesMessage) { $ses_request = $this->getRequestHandler('POST'); $ses_request->setParameter('Action', 'SendRawEmail'); // https://docs.aws.amazon.com/ses/latest/APIReference/API_SendRawEmail.html $ses_request->setParameter('RawMessage.Data', $sesMessage); $ses_response = $ses_request->getResponse(); if (($ses_response->error === false && $ses_response->code !== 200) || $ses_response->error !== false) { return new \WP_Error($ses_response->code, $this->getErrorMessage('sendRawEmail', $ses_response->error), $ses_response->error); } return array( 'MessageId' => (string)$ses_response->body->SendRawEmailResult->MessageId, 'RequestId' => (string)$ses_response->body->ResponseMetadata->RequestId, ); } /** * Trigger an error message * * {@internal Used by member functions to output errors} * @param string $functionname The name of the function that failed * @param array $error Array containing error information * @return void */ public function __triggerError($functionname, $error) { trigger_error($this->getErrorMessage($functionname, $error), E_USER_WARNING); } public function getErrorMessage($functionname, $error) { if ($error == false) { return sprintf("EmailService::%s(): Encountered an error, but no description given", $functionname); } else if (isset($error['curl']) && $error['curl']) { return sprintf("EmailService::%s(): %s %s", $functionname, $error['code'], $error['message']); } else if (isset($error['Error'])) { $e = $error['Error']; return sprintf("EmailService::%s(): %s - %s: %s\nRequest Id: %s\n", $functionname, $e['Type'], $e['Code'], $e['Message'], $error['RequestId']); } return sprintf("EmailService::%s(): Encountered an error: %s", $functionname, $error); } /** * Set SES Request * * @param EmailServiceRequest $ses_request description * @return EmailService $this */ public function setRequestHandler(EmailServiceRequest $ses_request = null) { if (!is_null($ses_request)) { $ses_request->setSES($this); } $this->__ses_request = $ses_request; return $this; } /** * Get SES Request * * @param string $verb HTTP Verb: GET, POST, DELETE * @return EmailServiceRequest SES Request */ public function getRequestHandler($verb) { if (empty($this->__ses_request)) { $this->__ses_request = new EmailServiceRequest($this, $verb); } else { $this->__ses_request->setVerb($verb); } return $this->__ses_request; } } main/mailer/amazonses/emailservicerequest.php 0000644 00000025556 15171073004 0015546 0 ustar 00 ses = $ses; $this->verb = $verb; $this->response = (object) array('body' => '', 'code' => 0, 'error' => false); } /** * Set SES class * * @param EmailService $ses * @return EmailServiceRequest $this */ public function setSES(EmailService $ses) { $this->ses = $ses; return $this; } /** * Set HTTP method * * @param string $verb * @return EmailServiceRequest $this */ public function setVerb($verb) { $this->verb = $verb; return $this; } /** * Set request parameter * * @param string $key Key * @param string $value Value * @param boolean $replace Whether to replace the key if it already exists (default true) * @return EmailServiceRequest $this */ public function setParameter($key, $value, $replace = true) { if(!$replace && isset($this->parameters[$key])) { $temp = (array)($this->parameters[$key]); $temp[] = $value; $this->parameters[$key] = $temp; } else { $this->parameters[$key] = $value; } return $this; } /** * Get the params for the request * * @return array $params */ public function getParametersEncoded() { $params = array(); foreach ($this->parameters as $var => $value) { if(is_array($value)) { foreach($value as $v) { $params[] = $var.'='.$this->__customUrlEncode($v); } } else { $params[] = $var.'='.$this->__customUrlEncode($value); } } sort($params, SORT_STRING); return $params; } /** * Clear the request parameters * @return EmailServiceRequest $this */ public function clearParameters() { $this->parameters = array(); return $this; } /** * Instantiate and setup CURL handler for sending requests. * Instance is cashed in `$this->curl_handler` * * @return resource $curl_handler */ protected function getCurlHandler() { if (!empty($this->curl_handler)) return $this->curl_handler; $curl = curl_init(); curl_setopt($curl, CURLOPT_USERAGENT, 'EmailService/php'); curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, ($this->ses->verifyHost() ? 2 : 0)); curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, ($this->ses->verifyPeer() ? 1 : 0)); curl_setopt($curl, CURLOPT_HEADER, false); curl_setopt($curl, CURLOPT_RETURNTRANSFER, false); curl_setopt($curl, CURLOPT_WRITEFUNCTION, array(&$this, '__responseWriteCallback')); curl_setopt($curl, CURLOPT_FOLLOWLOCATION, true); foreach(self::$curlOptions as $option => $value) { curl_setopt($curl, $option, $value); } $this->curl_handler = $curl; return $this->curl_handler; } /** * Get the response * * @return object | false */ public function getResponse() { $url = 'https://'.$this->ses->getHost().'/'; $query = implode('&', $this->getParametersEncoded()); $headers = $this->getHeaders($query); $curl_handler = $this->getCurlHandler(); curl_setopt($curl_handler, CURLOPT_CUSTOMREQUEST, $this->verb); // Request types switch ($this->verb) { case 'GET': case 'DELETE': $url .= '?'.$query; break; case 'POST': curl_setopt($curl_handler, CURLOPT_POSTFIELDS, $query); $headers[] = 'Content-Type: application/x-www-form-urlencoded'; break; } curl_setopt($curl_handler, CURLOPT_HTTPHEADER, $headers); curl_setopt($curl_handler, CURLOPT_URL, $url); // Execute, grab errors if (curl_exec($curl_handler)) { $this->response->code = curl_getinfo($curl_handler, CURLINFO_HTTP_CODE); } else { $this->response->error = array( 'curl' => true, 'code' => curl_errno($curl_handler), 'message' => curl_error($curl_handler), ); } // cleanup for reusing the current instance for multiple requests curl_setopt($curl_handler, CURLOPT_POSTFIELDS, ''); $this->parameters = array(); // Parse body into XML if ($this->response->error === false && !empty($this->response->body)) { $this->response->body = simplexml_load_string($this->response->body); // Grab SES errors if (!in_array($this->response->code, array(200, 201, 202, 204)) && isset($this->response->body->Error)) { $error = $this->response->body->Error; $output = array(); $output['curl'] = false; $output['Error'] = array(); $output['Error']['Type'] = (string)$error->Type; $output['Error']['Code'] = (string)$error->Code; $output['Error']['Message'] = (string)$error->Message; $output['RequestId'] = (string)$this->response->body->RequestId; $this->response->error = $output; unset($this->response->body); } } $response = $this->response; $this->response = (object) array('body' => '', 'code' => 0, 'error' => false); return $response; } /** * Get request headers * @param string $query * @return array */ protected function getHeaders($query) { $headers = array(); if ($this->ses->getRequestSignatureVersion() == EmailService::REQUEST_SIGNATURE_V4) { $date = (new \DateTime('now', new \DateTimeZone('UTC')))->format('Ymd\THis\Z'); $headers[] = 'X-Amz-Date: ' . $date; $headers[] = 'Host: ' . $this->ses->getHost(); $headers[] = 'Authorization: ' . $this->__getAuthHeaderV4($date, $query); } else { // must be in format 'Sun, 06 Nov 1994 08:49:37 GMT' $date = gmdate('D, d M Y H:i:s e'); $auth = 'AWS3-HTTPS AWSAccessKeyId='.$this->ses->getAccessKey(); $auth .= ',Algorithm=HmacSHA256,Signature='.$this->__getSignature($date); $headers[] = 'Date: ' . $date; $headers[] = 'Host: ' . $this->ses->getHost(); $headers[] = 'X-Amzn-Authorization: ' . $auth; } return $headers; } /** * Destroy any leftover handlers */ public function __destruct() { if (!empty($this->curl_handler)) @curl_close($this->curl_handler); } /** * CURL write callback * * @param resource $curl CURL resource * @param string $data Data * @return integer */ private function __responseWriteCallback($curl, $data) { if (!isset($this->response->body)) { $this->response->body = $data; } else { $this->response->body .= $data; } return strlen($data); } /** * Contributed by afx114 * URL encode the parameters as per http://docs.amazonwebservices.com/AWSECommerceService/latest/DG/index.html?Query_QueryAuth.html * PHP's rawurlencode() follows RFC 1738, not RFC 3986 as required by Amazon. The only difference is the tilde (~), so convert it back after rawurlencode * See: http://www.morganney.com/blog/API/AWS-Product-Advertising-API-Requires-a-Signed-Request.php * * @param string $var String to encode * @return string */ private function __customUrlEncode($var) { return str_replace('%7E', '~', rawurlencode($var)); } /** * Generate the auth string using Hmac-SHA256 * * @internal Used by EmailServiceRequest::getResponse() * @param string $string String to sign * @return string */ private function __getSignature($string) { return base64_encode(hash_hmac('sha256', $string, $this->ses->getSecretKey(), true)); } /** * @param string $key * @param string $dateStamp * @param string $regionName * @param string $serviceName * @param string $algo * @return string */ private function __getSigningKey($key, $dateStamp, $regionName, $serviceName, $algo) { $kDate = hash_hmac($algo, $dateStamp, 'AWS4' . $key, true); $kRegion = hash_hmac($algo, $regionName, $kDate, true); $kService = hash_hmac($algo, $serviceName, $kRegion, true); return hash_hmac($algo,'aws4_request', $kService, true); } /** * Implementation of AWS Signature Version 4 * @see https://docs.aws.amazon.com/general/latest/gr/sigv4_signing.html * @param string $amz_datetime * @param string $query * @return string */ private function __getAuthHeaderV4($amz_datetime, $query) { $amz_date = substr($amz_datetime, 0, 8); $algo = 'sha256'; $aws_algo = 'AWS4-HMAC-' . strtoupper($algo); $host_parts = explode('.', $this->ses->getHost()); $service = $host_parts[0]; $region = $host_parts[1]; $canonical_uri = '/'; if($this->verb === 'POST') { $canonical_querystring = ''; $payload_data = $query; } else { $canonical_querystring = $query; $payload_data = ''; } // ************* TASK 1: CREATE A CANONICAL REQUEST ************* $canonical_headers_list = [ 'host:' . $this->ses->getHost(), 'x-amz-date:' . $amz_datetime ]; $canonical_headers = implode("\n", $canonical_headers_list) . "\n"; $signed_headers = 'host;x-amz-date'; $payload_hash = hash($algo, $payload_data, false); $canonical_request = implode("\n", array( $this->verb, $canonical_uri, $canonical_querystring, $canonical_headers, $signed_headers, $payload_hash )); // ************* TASK 2: CREATE THE STRING TO SIGN************* $credential_scope = $amz_date. '/' . $region . '/' . $service . '/' . 'aws4_request'; $string_to_sign = implode("\n", array( $aws_algo, $amz_datetime, $credential_scope, hash($algo, $canonical_request, false) )); // ************* TASK 3: CALCULATE THE SIGNATURE ************* // Create the signing key using the function defined above. $signing_key = $this->__getSigningKey($this->ses->getSecretKey(), $amz_date, $region, $service, $algo); // Sign the string_to_sign using the signing_key $signature = hash_hmac($algo, $string_to_sign, $signing_key, false); // ************* TASK 4: ADD SIGNING INFORMATION TO THE REQUEST ************* return $aws_algo . ' ' . implode(', ', array( 'Credential=' . $this->ses->getAccessKey() . '/' . $credential_scope, 'SignedHeaders=' . $signed_headers , 'Signature=' . $signature )); } } main/mailer/gmail/auth.php 0000644 00000013040 15171073004 0011500 0 ustar 00 client_id = $client_id; $this->client_secret = $client_secret; $this->redirect_uri = $redirect_uri; $this->state = $state; $this->options = $this->getConfig(); } private function getConfig(){ return array( 'client_id' => $this->client_id, 'client_secret' => $this->client_secret, 'redirect_uri' => $this->redirect_uri, 'urlAuthorize' => 'https://accounts.google.com/o/oauth2/auth', 'urlAccessToken' => 'https://www.googleapis.com/oauth2/v4/token', 'urlResourceOwnerDetails' => '', 'scopes' => 'https://www.googleapis.com/auth/gmail.compose', 'access_type' => 'offline', 'include_granted_scopes' => 'true', 'approval_prompt' => 'force', 'state' => $this->state, ); } public function setClientId($client_id){ $this->client_id= $client_id; return true; } public function setClientSecret($client_secret){ $this->client_secret = $client_secret; return true; } public function add_scope($scope){ if(is_array($scope)){ $separator = ','; $this->options['scope'] = implode($separator, $scope); return true; } $this->options['scope'] = $scope; return true; } public function set_access_type($access_type){ $this->options['access_type'] = $access_type; return true; } public function set_approval_prompt($approval_prompt){ $this->options['approval_prompt'] = $approval_prompt; return true; } public function getAuthUrl(){ return $this->getAuthorizationUrl(); } public function getAuthorizationUrl($options = []){ $base = $this->options['urlAuthorize']; $params = $this->getAuthorizationParameters($options); $query = http_build_query($params, null, '&', \PHP_QUERY_RFC3986); return $this->appendQuery($base, $query); } private function getAuthorizationParameters($options){ if(empty($options['scope'])){ $options['scope'] = $this->options['scopes']; } $options += [ 'access_type' => $this->options['access_type'], 'include_granted_scopes' => $this->options['include_granted_scopes'], 'response_type' => 'code', 'state' => $this->getRandomState().$this->options['state'], 'approval_prompt' => $this->options['approval_prompt'], ]; if(is_array($options['scope'])){ $separator = ','; $options['scope'] = implode($separator, $options['scope']); } // Store the state as it may need to be accessed later on. $this->options['state'] = $options['state']; // Business code layer might set a different redirect_uri parameter // depending on the context, leave it as-is if(!isset($options['redirect_uri'])){ $options['redirect_uri'] = $this->options['redirect_uri']; } $options['client_id'] = $this->options['client_id']; return $options; } protected function getRandomState($length = 32){ // Converting bytes to hex will always double length. Hence, we can reduce // the amount of bytes by half to produce the correct length. $state = bin2hex(random_bytes($length / 2)); update_option('_gosmtp_last_generated_state', $state); return $state; } protected function appendQuery($url, $query){ $query = trim($query, '?&'); if($query){ $glue = strstr($url, '?') === false ? '?' : '&'; return $url . $glue . $query; } return $url; } public function sendTokenRequest($type, $params){ try { $tokens = $this->getAccessToken($type, $params); return $tokens; } catch (\Exception $exception) { return new \WP_Error(423, $exception->getMessage()); } } /** * Requests an access token using a specified grant and option set. * * @param mixed $grant * @param array $options * @throws \Exception * @return array tokens */ public function getAccessToken($grant, array $options = []){ $params = [ 'client_id' => $this->options['client_id'], 'client_secret' => $this->options['client_secret'], 'redirect_uri' => $this->options['redirect_uri'], 'grant_type' => $grant, ]; $params += $options; $requestData = $this->getAccessTokenRequestDetails($params); $response = wp_remote_request($requestData['url'], $requestData['params']); if(is_wp_error($response)) { throw new \Exception( $response->get_error_message() ); return $response; } $responseBody = wp_remote_retrieve_body($response); if(false === is_array($response)){ throw new \Exception( 'Invalid response received from Authorization Server. Expected JSON.' ); } if(empty(['access_token'])){ throw new \Exception( 'Invalid response received from Authorization Server.' ); } return \json_decode($responseBody, true); } /** * Returns a prepared request for requesting an access token. * * @param array $params Query string parameters * @return array $requestDetails */ protected function getAccessTokenRequestDetails($params){ $method = $this->accessTokenMethod; $url = $this->options['urlAccessToken']; $options = http_build_query($params, null, '&', \PHP_QUERY_RFC3986); return [ 'url' => $url, 'params' => [ 'method' => $method, 'body' => $options, 'headers' => [ 'content-type' => 'application/x-www-form-urlencoded' ] ] ]; } } main/mailer/gmail/gmail.php 0000644 00000025746 15171073004 0011650 0 ustar 00 preSend()){ $response = $this->postSend(); return $this->handle_response( $response ); } return $this->handle_response(new \WP_Error(400, 'Unable to send mail for some reason!', [])); } protected function postSend(){ global $phpmailer; try{ $access_token = $this->getAccessToken($this->getMailerOption()); if(is_wp_error($access_token)){ return $access_token->get_error_message(); } $mime = base64_encode($phpmailer->getSentMIMEMessage()); $body = array( "raw" =>$mime, ); $params = array( 'method' => 'POST', 'headers' => [ 'Authorization' => 'Bearer '. $access_token, 'Content-Type' => 'application/json', 'Accept' => 'application/json', ], 'body' => wp_json_encode($body) ); $response = wp_remote_request($this->url, $params); if(is_wp_error($response)){ $return_response = new \WP_Error($response->get_error_code(), $response->get_error_message(), $response->get_error_messages()); }else{ $resp_body = wp_remote_retrieve_body($response); $resp_code = wp_remote_retrieve_response_code($response); $resp_body = \json_decode($resp_body, true); if($this->isOk == $resp_code){ $msgId = isset( $resp_body['id'] ) ? $resp_body['id'] : ''; $status = 'Email sent successfully'; $return_response = [ 'status' => true, 'code' => $resp_code, 'messageId' => $msgId, 'message' => $status ]; }else{ $err_code = $resp_code; $error_text = ['']; if( ! empty( $resp_body['error'] ) && is_array( $resp_body['error'] ) ){ $message = $resp_body['error']['message']; $code = !empty( $resp_body['error']['code'] ) ? $resp_body['error']['code'] : ''; $error_text[] = $this->message_formatting( $message, $code ); }else{ $error_text[] = $this->get_response_error_message($response); } $error_msg = implode( '\r\n', array_map( 'esc_textarea', array_filter( $error_text ) ) ); $return_response = new \WP_Error($err_code, $error_msg, $resp_body); } } }catch(\Exception $e){ $return_Response = new \WP_Error(423, $e->getMessage(), []); } return $return_response; } // get access token private function getAccessToken($options){ $accessToken = $options['access_token']; // check if expired or will be expired in 300 seconds if( ($options['expire_stamp'] - 300) < time()){ $state = ($this->conn_id === 0 ? '' : '-'.$this->conn_id); $client_id = $this->getOption('client_id', $this->mailer); $client_secret = $this->getOption('client_secret', $this->mailer); $redirect_url = $this->getRedirectUrl('&auth=gmail'); $google_client = new \GOSMTP\mailer\gmail\Auth($client_id, $client_secret, $redirect_url, $state); $tokens = $google_client->sendTokenRequest('refresh_token', [ 'refresh_token' => $options['refresh_token'] ]); if(is_wp_error($tokens)) { return $tokens->get_error_message(); } $this->saveNewTokens($tokens); $accessToken = $tokens['access_token']; } return $accessToken; } //save new token when expire time exeed private function saveNewTokens($tokens){ $tokens['refresh_token'] = empty($tokens['refresh_token']) ? $this->getOption('refresh_token', $this->mailer) : $tokens['refresh_token']; if(empty($tokens['access_token']) || empty($tokens['refresh_token'])){ return false; } $this->update_option('access_token', $tokens['access_token'], $this->mailer); $this->update_option('refresh_token', $tokens['refresh_token'], $this->mailer); $this->update_option('expire_stamp', $tokens['expires_in'] + time(), $this->mailer); $this->update_option('expires_in', $tokens['expires_in'], $this->mailer); return true; } //generate access token and refresh token and update in data base. public function set_token(){ $errors = []; $clientId = $this->getOption('client_id', $this->mailer); $clientSecret = $this->getOption('client_secret', $this->mailer); $accessToken = $this->getOption('access_token', $this->mailer); $authToken = $this->getOption('auth_token', $this->mailer); if(!$accessToken && $authToken ){ $body = [ 'code' => $authToken, 'grant_type' => 'authorization_code', 'redirect_uri' => $this->getRedirectUrl('&auth=gmail'), 'client_id' => $clientId, 'client_secret' => $clientSecret ]; $tokens = $this->makeRequest('https://accounts.google.com/o/oauth2/token', $body, 'POST'); if(is_wp_error($tokens)){ return new \WP_Error(423, $tokens->get_error_message()); }else{ $this->update_option('access_token', $tokens['access_token'], $this->mailer); $this->update_option('refresh_token', $tokens['refresh_token'], $this->mailer); $this->update_option('auth_token', '', $this->mailer); $this->update_option('expire_stamp', time() + $tokens['expires_in'], $this->mailer); $this->update_option('expires_in', $tokens['expires_in'], $this->mailer); $this->update_option('version', 2, $this->mailer); } }elseif(!$authToken && !$accessToken){ return new \WP_Error(423, __('Please Provide Auth Token.', 'GOSMTP')); } return true; } private function makeRequest($url, $bodyArgs, $type = 'GET', $headers = false){ if(!$headers){ $headers = array( 'Content-Type' => 'application/http', 'Content-Transfer-Encoding' => 'binary', 'MIME-Version' => '1.0', ); } $args = array( 'headers' => $headers ); if($bodyArgs){ $args['body'] = json_encode($bodyArgs); } $args['method'] = $type; $request = wp_remote_request($url, $args); if(is_wp_error($request)){ $message = $request->get_error_message(); return new \WP_Error(423, $message); } $body = json_decode(wp_remote_retrieve_body($request), true); if(!empty($body['error'])){ $error = 'Unknown Error'; if(isset($body['error_description'])){ $error = $body['error_description']; }elseif(!empty($body['error']['message'])){ $error = $body['error']['message']; } return new \WP_Error(423, $error); } return $body; } public function get_auth_url() { $state = ($this->conn_id === 0 ? '' : '-'.$this->conn_id); $client_id = $this->getOption('client_id', $this->mailer); $client_secret = $this->getOption('client_secret', $this->mailer); $redirect_url = $this->getRedirectUrl('&auth=gmail'); $google_client = new \GOSMTP\mailer\gmail\Auth($client_id, $client_secret, $redirect_url, $state); if($google_client->getAuthUrl()){ return $google_client->getAuthUrl(); } } public function load_field(){ $this->gmail_init(); $access_token = $this->getOption('access_token', $this->mailer); $client_id = $this->getOption('client_id', $this->mailer); $client_secret = $this->getOption('client_secret', $this->mailer); $refresh_token = $this->getOption('refresh_token', $this->mailer); $mail_type = $this->getOption('mail_type', $this->mailer); $deactivate = !empty($refresh_token) && !empty($access_token) && $this->mailer == $mail_type; $activate = !empty($client_id) && !empty($client_secret) && empty($access_token) && empty($refresh_token); $readonly = $deactivate ? 'readonly' : ''; $fields = array( 'client_id' => array( 'title' => __('Client ID'), 'type' => 'text', 'desc' => '', 'attr'=> $readonly, ), 'client_secret' => array( 'title' => __('Client Secret'), 'type' => 'password', 'desc' => '', 'attr'=> $readonly, ), 'authorized_redirect_uri' => array( 'title' => __('Authorized redirect URI'), 'type' => 'copy', 'id' => 'gmail_redirect_uri', 'attr'=>'readonly', 'default' => $this->getRedirectUrl('&auth=gmail'), 'desc' => __('Please copy this URL into the "Authorized redirect URIs" field of your Google web application.') ), ); if($activate){ $fields['get_acces_token'] = array( 'title' => __('Get Access Token'), 'type' => 'button', 'class'=>'access_token', 'default' => 'Get Access Token', 'href' => $this->get_auth_url(), 'attr' => 'data-field=auth', ); }elseif($deactivate){ $fields['get_acces_token'] = array( 'title' => __('Deactivate Access Token'), 'type' => 'button', 'class'=>'deactivate_token', 'default' => 'Deactivate Access Token', 'href' => $this->getRedirectUrl().($this->conn_id !== 0 ? '&type=edit&conn_id='.$this->conn_id.'&act=deactivate_token#gosmtp-connections-settings' : '&act=deactivate_token'), 'attr' => 'data-field=auth', ); }else{ $fields['get_acces_token'] = array( 'title' => __('Get Access Token'), 'type' => 'notice', 'default' => __('You need to save settings with Client ID and Client Secret before you can proceed.'), ); } return $fields; } public function gmail_init(){ $options = $this->getMailerOption(); // Update auth URl when user succesfull regirect our page if( empty($options['access_token']) && empty($options['refresh_token']) && isset( $_GET['auth_code'] ) && isset( $_GET['auth'] ) && $this->mailer == $_GET['auth'] && strlen($this->conn_id) > 0 ){ if( !empty(gosmtp_optget('conn_id')) && $this->conn_id === 0 ){ return; } $auth_code = gosmtp_optget('auth_code'); $this->update_option('auth_token', $auth_code, $this->mailer); $resp = ''; if($this->set_token()){ $resp = __('Token Updated Sucessfully'); }elseif(is_wp_error($this->set_token())){ $resp = $this->set_token()->get_error_message(); }; $query = ''; if( !is_numeric($this->conn_id) ){ $query = '&type=edit&conn_id='.$this->conn_id.$query.'#gosmtp-connections-settings'; } echo ''; } // Delete all the tokens or expire stamp when user click deactivate access token if(isset($_GET['act']) && $_GET['act'] == 'deactivate_token'){ if(!empty(gosmtp_optget('conn_id')) && $this->conn_id === 0){ return; } $this->delete_option('refresh_token', $this->mailer); $this->delete_option('expire_stamp', $this->mailer); $this->delete_option('expires_in', $this->mailer); $this->delete_option('version', $this->mailer); $this->delete_option('access_token', $this->mailer); $query = ''; if(!is_numeric($this->conn_id)){ $query = '&type=edit&conn_id='.$this->conn_id.$query.'#gosmtp-connections-settings'; } if(isset($_GET['conn_id'])){ echo ''; } } } } main/mailer/outlook/outlook.php 0000644 00000022316 15171073004 0012644 0 ustar 00 isMail(); $phpmailer->Encoding = 'base64'; if ($phpmailer->preSend()) { $response = $this->postSend(); return $this->handle_response( $response ); } return $this->handle_response(new \WP_Error(400, 'Unable to send mail for some reason!', [])); } public function postSend(){ global $phpmailer; try{ $access_token = $this->getAccessToken($this->getMailerOption()); if(is_wp_error($access_token)){ return $access_token->get_error_message(); } $mime = chunk_split(base64_encode($phpmailer->getSentMIMEMessage()), 76, "\n"); $params = array( 'method' => 'POST', 'headers' => [ 'Authorization' => 'Bearer '. $access_token, 'Content-Type' => 'text/plain' ], 'body' => $mime ); $response = wp_remote_request($this->url, $params); if(is_wp_error($response)){ $return_response = new \WP_Error($response->get_error_code(), $response->get_error_message(), $response->get_error_messages()); }else{ $resp_body = wp_remote_retrieve_body($response); $resp_code = wp_remote_retrieve_response_code($response); $resp_body = \json_decode($resp_body, true); if(202 == $resp_code){ $msgId = isset( $response['headers']['request-id'] ) ? $response['headers']['request-id'] : ''; $status = __('Email sent successfully'); $return_response = [ 'status' => true, 'code' => $resp_code, 'messageId' => $msgId, 'message' => $status ]; }else{ $err_code = $resp_code; $error_text = ['']; if(!empty( $resp_body['error']) && is_array($resp_body['error'])){ $message = $resp_body['error']['message']; $code = !empty( $resp_body['error']['code'] ) ? $resp_body['error']['code'] : ''; $desc = ''; if($code === 'ErrorAccessDenied'){ $desc = esc_html__( 'Note: This issue can also be caused by exceeding the total message size limit. If you are using large attachments, please remove the existing Outlook Mailer OAuth connection in WP Mail SMTP settings and reconnect it. We recently added support for large attachments, but oAuth re-connection is required.'); } $error_text[] = $this->message_formatting( $message, $code, $desc ); }else{ $error_text[] = $this->get_response_error_message($response); } $error_msg = implode( '\r\n', array_map( 'esc_textarea', array_filter( $error_text ) ) ); $return_response = new \WP_Error($err_code, $error_msg, $resp_body); } } }catch(\Exception $e){ $return_response = new \WP_Error(423, $e->getMessage(), []); } return $return_response; } public function getRedirectUrl($query = ''){ // TODO check and change this return admin_url().'admin.php?page=gosmtp'.$query; } private function getAccessToken($options){ $accessToken = $options['access_token']; // check if expired or will be expired in 300 seconds if( ($options['expire_stamp'] - 300) < time()){ $api = new \GOSMTP\mailer\outlook\Auth($options['client_id'], $options['client_secret']); $tokens = $api->sendTokenRequest('refresh_token', [ 'refresh_token' => $options['refresh_token'] ]); if(is_wp_error($tokens)) { return false; } $this->saveNewTokens($options, $tokens); $accessToken = $tokens['access_token']; } return $accessToken; } private function saveNewTokens($data, $tokens){ if (empty($tokens['access_token']) || empty($tokens['refresh_token'])) { return false; } $this->update_option('access_token', $tokens['access_token'], $this->mailer); $this->update_option('refresh_token', $tokens['refresh_token'], $this->mailer); $this->update_option('expire_stamp', $tokens['expires_in'] + time(), $this->mailer); } public function load_field(){ $this->outlook_init(); $client_id = $this->getOption('client_id', $this->mailer); $client_secret = $this->getOption('client_secret', $this->mailer); $access_token = $this->getOption('access_token', $this->mailer); $refresh_token = $this->getOption('refresh_token', $this->mailer); $mail_type = $this->getOption('mail_type', $this->mailer); $activate = !empty($client_id) && !empty($client_secret) && empty($access_token) && empty($refresh_token); $deactivate = !empty($refresh_token) && !empty($access_token) && $this->mailer == $mail_type; $readonly = $deactivate ? 'readonly' : ''; $state = ($this->conn_id === 0 ? '' : '-'.$this->conn_id); $api = new \GOSMTP\mailer\outlook\Auth($client_id, $client_secret, $state); $fields = array( 'client_id' => array( 'title' => __('Application Client ID'), 'type' => 'text', 'attr' => $readonly, ), 'client_secret' => array( 'title' => __('Application Client Secret'), 'type' => 'password', 'attr' => $readonly, 'desc' => __( 'Follow this link to get a Application Client Secret from Outlook: Application Client Secret.' ), ), 'redirect_uri' => array( 'title' => __('Outlook Callback URL'), 'type' => 'copy', 'id' => 'outlook_redirect_uri', 'attr'=>'readonly', 'default' => $api->getRedirectUrl(), 'desc' => __('Use this URL to your APP as Redirect URI.') ) ); if($activate){ $fields['get_access_token'] = array( 'title' => __('Get Access Token'), 'type' => 'button', 'class'=>'access_token', 'default' => __('Authenticate with outlook/Office365 & Get Access Token'), 'href' => $api->getAuthUrl(), 'attr' => 'data-field=auth', ); }elseif($deactivate){ $fields['get_access_token'] = array( 'title' => __('Deactivate Access Token'), 'type' => 'button', 'class'=>'deactivate_token', 'default' => 'Deactivate Access Token', 'href' => $this->getRedirectUrl().($this->conn_id !== 0 ? '&type=edit&conn_id='.$this->conn_id.'&act=deactivate_token#gosmtp-connections-settings' : '&act=deactivate_token'), 'attr' => 'data-field=auth', ); }else{ $fields['get_access_token'] = array( 'title' => __('Get Access Token'), 'type' => 'notice', 'default' => __('You need to save settings with Client ID and Client Secret before you can proceed.'), ); } return $fields; } // Generate access token and refresh token and update in data base. public function set_token(){ $errors = []; $options = $this->getMailerOption(); if(empty($options['access_token']) && !empty($options['auth_token'])){ $api = new \GOSMTP\mailer\outlook\Auth($options['client_id'], $options['client_secret']); $tokens = $api->generateToken($options['auth_token']); if(is_wp_error($tokens) || (is_array($tokens) && isset($tokens['error']))) { $err = is_wp_error($tokens) ? $tokens->get_error_message() : __('Mailer Authentication failed!'); return new \WP_Error(423, $err); } $this->saveNewTokens($options, $tokens); }elseif(!$authToken && !$accessToken){ return new \WP_Error(423, __('Please Provide Auth Token.', 'GOSMTP')); } return true; } public function outlook_init(){ $options = $this->getMailerOption(); // Update auth URl when user succesfull regirect our page if( empty($options['access_token']) && empty($options['refresh_token']) && isset( $_GET['auth_code'] ) && isset( $_GET['auth'] ) && $this->mailer == $_GET['auth'] && strlen($this->conn_id) > 0 ){ if( !empty(gosmtp_optget('conn_id')) && $this->conn_id === 0 ){ return; } $auth_code = gosmtp_optget('auth_code'); $this->update_option('auth_token', $auth_code, $this->mailer); $resp = ''; $set_token = $this->set_token(); if(is_wp_error($set_token)){ $resp = $set_token->get_error_message(); }else{ $resp = __('Mailer successfully configured!'); } $query = ''; if( !is_numeric($this->conn_id) ){ $query = '&type=edit&conn_id='.$this->conn_id.$query.'#gosmtp-connections-settings'; } echo ''; } // Delete all the tokens or expire stamp when user click deactivate access token if(isset($_GET['act']) && $_GET['act'] == 'deactivate_token'){ if(!empty(gosmtp_optget('conn_id')) && $this->conn_id === 0){ return; } $this->delete_option('refresh_token', $this->mailer); $this->delete_option('expire_stamp', $this->mailer); $this->delete_option('expires_in', $this->mailer); $this->delete_option('version', $this->mailer); $this->delete_option('access_token', $this->mailer); $query = ''; if(!is_numeric($this->conn_id)){ $query = '&type=edit&conn_id='.$this->conn_id.$query.'#gosmtp-connections-settings'; } if(isset($_GET['conn_id'])){ echo ''; } } } } main/mailer/outlook/auth.php 0000644 00000015056 15171073004 0012114 0 ustar 00 clientId = $clientId; $this->clientSecret = $clientSecret; $this->state = $state; //$this->assertRequiredOptions($this->getConfig()); $this->options = $this->getConfig(); } public function getAuthUrl(){ return $this->getAuthorizationUrl(); } public function generateToken($authCode){ return $this->sendTokenRequest('authorization_code', [ 'code' => $authCode ]); } public function sendTokenRequest($type, $params){ try { $tokens = $this->getAccessToken($type, $params); return $tokens; } catch (\Exception $exception) { return new \WP_Error(423, $exception->getMessage()); } } public function getRedirectUrl(){ return rest_url('gosmtp-smtp/outlook_callback'); } private function getConfig(){ return array( 'clientId' => $this->clientId, 'clientSecret' => $this->clientSecret, 'redirectUri' => $this->getRedirectUrl(), 'urlAuthorize' => 'https://login.microsoftonline.com/common/oauth2/v2.0/authorize', 'urlAccessToken' => 'https://login.microsoftonline.com/common/oauth2/v2.0/token', 'urlResourceOwnerDetails' => '', 'scopes' => 'offline_access user.read Mail.Send' ); } public function getAuthorizationUrl($options = []){ $base = $this->options['urlAuthorize']; $params = $this->getAuthorizationParameters($options); $query = $this->getAuthorizationQuery($params); return $this->appendQuery($base, $query); } private function getAuthorizationParameters($options){ if(empty($options['state'])){ $options['state'] = $this->getRandomState().$this->state; update_option('_gosmtp_last_generated_state', $options['state']); } if(empty($options['scope'])){ $options['scope'] = $this->options['scopes']; } $options += [ 'response_type' => 'code', 'approval_prompt' => 'auto' ]; if(is_array($options['scope'])){ $separator = ','; $options['scope'] = implode($separator, $options['scope']); } // Store the state as it may need to be accessed later on. $this->options['state'] = $options['state']; // Business code layer might set a different redirect_uri parameter // depending on the context, leave it as-is if(!isset($options['redirect_uri'])){ $options['redirect_uri'] = $this->options['redirectUri']; } $options['client_id'] = $this->options['clientId']; return $options; } /** * Appends a query string to a URL. * * @param string $url The URL to append the query to * @param string $query The HTTP query string * @return string The resulting URL */ protected function appendQuery($url, $query){ $query = trim($query, '?&'); if($query){ $glue = strstr($url, '?') === false ? '?' : '&'; return $url . $glue . $query; } return $url; } /** * Builds the authorization URL's query string. * * @param array $params Query parameters * @return string Query string */ protected function getAuthorizationQuery(array $params){ return $this->buildQueryString($params); } /** * Build a query string from an array. * * @param array $params * * @return string */ protected function buildQueryString(array $params){ return http_build_query($params, null, '&', \PHP_QUERY_RFC3986); } /** * Verifies that all required options have been passed. * * @param array $options * @return void * @throws \InvalidArgumentException */ private function assertRequiredOptions(array $options){ $missing = array_diff_key(array_flip($this->getRequiredOptions()), $options); if (!empty($missing)) { throw new \InvalidArgumentException( 'Required options not defined: ' . implode(', ', array_keys($missing)) ); } } /** * Returns all options that are required. * * @return array */ protected function getRequiredOptions(){ return [ 'urlAuthorize', 'urlAccessToken', 'urlResourceOwnerDetails', ]; } /** * Returns a new random string to use as the state parameter in an * authorization flow. * * @param int $length Length of the random string to be generated. * @return string */ protected function getRandomState($length = 32){ // Converting bytes to hex will always double length. Hence, we can reduce // the amount of bytes by half to produce the correct length. $state = bin2hex(random_bytes($length / 2)); update_option('_gosmtp_last_generated_state', $state); return $state; } /** * Requests an access token using a specified grant and option set. * * @param mixed $grant * @param array $options * @throws \Exception * @return array tokens */ public function getAccessToken($grant, array $options = []){ $params = [ 'client_id' => $this->options['clientId'], 'client_secret' => $this->options['clientSecret'], 'redirect_uri' => $this->options['redirectUri'], 'grant_type' => $grant, ]; $params += $options; $requestData = $this->getAccessTokenRequestDetails($params); $response = wp_remote_request($requestData['url'], $requestData['params']); if(is_wp_error($response)) { throw new \Exception( $response->get_error_message() ); } $responseBody = wp_remote_retrieve_body($response); if(false === is_array($response)){ throw new \Exception( 'Invalid response received from Authorization Server. Expected JSON.' ); } if(empty(['access_token'])){ throw new \Exception( 'Invalid response received from Authorization Server.' ); } return \json_decode($responseBody, true); } /** * Returns a prepared request for requesting an access token. * * @param array $params Query string parameters * @return array $requestDetails */ protected function getAccessTokenRequestDetails($params){ $method = $this->accessTokenMethod; $url = $this->getAccessTokenUrl($params); $options = $this->buildQueryString($params); return [ 'url' => $url, 'params' => [ 'method' => $method, 'body' => $options, 'headers' => [ 'content-type' => 'application/x-www-form-urlencoded' ] ] ]; } /** * Returns the full URL to use when requesting an access token. * * @param array $params Query parameters * @return string */ protected function getAccessTokenUrl($params){ $url = $this->options['urlAccessToken']; if($this->accessTokenMethod === 'GET'){ $query = $this->getAccessTokenQuery($params); return $this->appendQuery($url, $query); } return $url; } protected function getAccessTokenQuery(array $params){ return $this->buildQueryString($params); } } main/export.php 0000644 00000025120 15171073005 0007521 0 ustar 00 $val){ // Skip attachment explode for first row if( $kk != 0 && $attachment_key !== false && !empty($val[$attachment_key]) ){ $attachment = explode(',', $val[$attachment_key]); $attach = ''; foreach($attachment as $attach_val){ $attach .= explode('*', $attach_val)[2].', '; } $val[$attachment_key] = rtrim($attach, ', '); } fputcsv($file, array_values($val)); } fclose($file); wp_die(); } // Export XML files function gosmtp_export_xls($data){ $filename = "gosmtp_export_".date('Ymd') . ".xls"; header("Content-Type: application/vnd.ms-excel"); header("Content-Disposition: attachment; filename=\"$filename\""); // We have all the field sequences in the first line // Get the key of attachments form the sequences $attachment_key = array_search('attachments', $data[0], true); foreach($data as $kk => $val) { array_walk($val, 'gosmtp_filterData'); // Skip attachment explode for first row if( $kk != 0 && $attachment_key !== false && !empty($val[$attachment_key]) ){ $attachment = explode(',', $val[$attachment_key]); $attach =""; foreach($attachment as $attach_val){ $attach .= explode('*', $attach_val)[2].', '; } $val[$attachment_key] = rtrim($attach, ", "); } echo esc_html(implode("\t", array_values($val)) . "\n"); } wp_die(); } // Export EML files function gosmtp_export_eml($data){ $files = array(); $first_row = $data[0]; // Replace key with value $fields = array_flip($data[0]); $attachment_key = $fields['attachments']; foreach($data as $key => $value){ // Skip for first row if($key == 0){ continue; } $files[$key] = "gosmtp_export_".$key."_".date('Ymd') . ".eml"; header("Content-Type: application/application/eml"); header("Content-Disposition: attachment; filename=\"$files[$key]\""); $output_buffer = fopen('php://output', 'w'); $boundary = md5(uniqid(mt_rand())); $output_buffer = 'MIME-Version: 1.0 Date: '.date_format( date_create( $value[$fields['created_at']] ), 'd-m-y H:i:s').' +0100 From: '.$value[$fields['from']].' To: '.$value[$fields['to']].' Cc: '.$value[$fields['cc']].' Ccc: '.$value[$fields['bcc']].' Subject: '.$value[$fields['subject']].' Content-Type: multipart/mixed; boundary="'.$boundary.'" This is a message with multiple parts in MIME format. --'.$boundary.' Content-Type: '.$value[$fields['content-type']].' '.$value[$fields['body']]; // Added attachment if any if(isset($value[$attachment_key]) && !empty($value[$attachment_key])){ $attachment = explode(',', $value[$attachment_key]); foreach($attachment as $attach){ $all_attach = explode('*', $attach); $attachment_file = file_get_contents(trim($all_attach[0])); if(empty($attachment_file)){ continue; } $encoded_attach = base64_encode($attachment_file); $type = $all_attach[4]; $base_name = $all_attach[2]; $output_buffer .= ' --'.$boundary.' Content-Type: '.$type.';name="'.$base_name.'" Content-Transfer-Encoding: base64 Content-Disposition: attachment;filename="'.$base_name.'" '.$encoded_attach; } } file_put_contents($files[$key], $output_buffer); } $zipname = "gosmtp_export_".date('Ymd') . ".zip"; $zip = new ZipArchive; $zip->open($zipname, ZipArchive::CREATE); foreach($files as $file){ $zip->addFile($file); } $zip->close(); header('Content-Type: application/zip'); header('Content-disposition: attachment; filename='.$zipname); header('Content-Length: ' . filesize($zipname)); readfile($zipname); unlink($zipname); wp_die(); } // Export page HTML function gosmtp_export_page(){ // Styles and Scripts wp_enqueue_style( 'gosmtp-admin' ); wp_enqueue_script( 'gosmtp-admin' ); $common_field = array( 'to' => __('To Address'), 'from' => __('From Address'), 'subject' => __('Subject'), 'body' => __('Body'), 'created_at' => __('Created At'), 'attachments' => __('Attachments'), ); $addtition_field = array( 'status' => __('Status'), 'reply-to' => __('Reply To'), 'cc' => __('Carbon Copy (CC)'), 'bcc' => __('Blind Carbon Copy (BCC)'), 'provider' => __('Provider'), 'response' => __('Response'), 'source' => __('Source'), 'content-type' => __('Content Type') ); $search_field = array( 'from' => __('from'), 'to' => __('To'), 'subject' => __('Subject'), 'body' => __('Body'), ); $all_field = array_merge(array_keys($common_field), array_keys($addtition_field)); ?>
'.esc_html__('You are using an older version of GoSMTP Pro. We recommend updating to the latest version to ensure seamless and uninterrupted use of the application.', 'gosmtp').'
'.esc_html__('You are using an older version of GoSMTP. We recommend updating to the latest free version to ensure smooth and uninterrupted use of the application.', 'gosmtp').'