');
}
function __construct($add_action=true)
{
$this->id = self::$_id;
$this->method_title = __(self::$_method_title, 'monero_gateway');
$this->method_description = __(self::$_method_description, 'monero_gateway');
$this->has_fields = false;
$this->supports = array(
'products',
'subscriptions',
'subscription_cancellation',
'subscription_suspension',
'subscription_reactivation',
'subscription_amount_changes',
'subscription_date_changes',
'subscription_payment_method_change'
);
$this->enabled = $this->get_option('enabled') == 'yes';
$this->init_form_fields();
$this->init_settings();
self::$_title = $this->settings['title'];
$this->title = $this->settings['title'];
$this->description = $this->settings['description'];
self::$discount = $this->settings['discount'];
self::$valid_time = $this->settings['valid_time'];
self::$confirms = $this->settings['confirms'];
self::$confirm_type = $this->settings['confirm_type'];
self::$address = $this->settings['monero_address'];
self::$viewkey = $this->settings['viewkey'];
self::$host = $this->settings['daemon_host'];
self::$port = $this->settings['daemon_port'];
self::$testnet = $this->settings['testnet'] == 'yes';
self::$onion_service = $this->settings['onion_service'] == 'yes';
self::$show_qr = $this->settings['show_qr'] == 'yes';
self::$use_monero_price = $this->settings['use_monero_price'] == 'yes';
self::$use_monero_price_decimals = $this->settings['use_monero_price_decimals'];
$explorer_url = self::$testnet ? MONERO_GATEWAY_TESTNET_EXPLORER_URL : MONERO_GATEWAY_MAINNET_EXPLORER_URL;
defined('MONERO_GATEWAY_EXPLORER_URL') || define('MONERO_GATEWAY_EXPLORER_URL', $explorer_url);
if($add_action)
add_action('woocommerce_update_options_payment_gateways_'.$this->id, array($this, 'process_admin_options'));
// Initialize helper classes
self::$cryptonote = new Monero_Cryptonote();
if(self::$confirm_type == 'monero-wallet-rpc') {
require_once('class-monero-wallet-rpc.php');
self::$monero_wallet_rpc = new Monero_Wallet_Rpc(self::$host, self::$port);
} else {
require_once('class-monero-explorer-tools.php');
self::$monero_explorer_tools = new Monero_Explorer_Tools(self::$testnet);
}
self::$log = new WC_Logger();
}
public function init_form_fields()
{
$this->form_fields = include 'admin/monero-gateway-admin-settings.php';
}
public function validate_monero_address_field($key,$address)
{
if($this->settings['confirm_type'] == 'viewkey') {
if (strlen($address) == 95 && substr($address, 0, 1) == '4')
if(self::$cryptonote->verify_checksum($address))
return $address;
self::$_errors[] = 'Monero address is invalid';
}
return $address;
}
public function validate_viewkey_field($key,$viewkey)
{
if($this->settings['confirm_type'] == 'viewkey') {
if(preg_match('/^[a-z0-9]{64}$/i', $viewkey)) {
return $viewkey;
} else {
self::$_errors[] = 'Viewkey is invalid';
return '';
}
}
return $viewkey;
}
public function validate_confirms_field($key,$confirms)
{
if($confirms >= 0 && $confirms <= 60)
return $confirms;
self::$_errors[] = 'Number of confirms must be between 0 and 60';
}
public function validate_valid_time_field($key,$valid_time)
{
if($valid_time >= 600 && $valid_time < 86400*7)
return $valid_time;
self::$_errors[] = 'Order valid time must be between 600 (10 minutes) and 604800 (1 week)';
}
public function admin_options()
{
$confirm_type = self::$confirm_type;
if($confirm_type === 'monero-wallet-rpc')
$balance = self::admin_balance_info();
$settings_html = $this->generate_settings_html(array(), false);
$errors = array_merge(self::$_errors, $this->admin_php_module_check(), $this->admin_ssl_check());
include MONERO_GATEWAY_PLUGIN_DIR . '/templates/monero-gateway/admin/settings-page.php';
}
public static function admin_balance_info()
{
if(!is_admin()) {
return array(
'height' => 'Not Available',
'balance' => 'Not Available',
'unlocked_balance' => 'Not Available',
);
}
$wallet_amount = self::$monero_wallet_rpc->getbalance();
$height = self::$monero_wallet_rpc->getheight();
if (!isset($wallet_amount)) {
self::$_errors[] = 'Cannot connect to monero-wallet-rpc';
self::$log->add('Monero_Payments', '[ERROR] Cannot connect to monero-wallet-rpc');
return array(
'height' => 'Not Available',
'balance' => 'Not Available',
'unlocked_balance' => 'Not Available',
);
} else {
return array(
'height' => $height,
'balance' => self::format_monero($wallet_amount['balance']).' Monero',
'unlocked_balance' => self::format_monero($wallet_amount['unlocked_balance']).' Monero'
);
}
}
protected function admin_ssl_check()
{
$errors = array();
if ($this->enabled && !self::$onion_service)
if (get_option('woocommerce_force_ssl_checkout') == 'no')
$errors[] = sprintf('%s is enabled and WooCommerce is not forcing the SSL certificate on your checkout page. Please ensure that you have a valid SSL certificate and that you are forcing the checkout pages to be secured.', self::$_method_title, admin_url('admin.php?page=wc-settings&tab=checkout'));
return $errors;
}
protected function admin_php_module_check()
{
$errors = array();
if(!extension_loaded('bcmath'))
$errors[] = 'PHP extension bcmath must be installed';
return $errors;
}
public function process_payment($order_id)
{
global $wpdb;
$table_name = $wpdb->prefix.'monero_gateway_quotes';
$order = wc_get_order($order_id);
// Generate a unique payment id
do {
$payment_id = bin2hex(openssl_random_pseudo_bytes(8));
$query = $wpdb->prepare("SELECT COUNT(*) FROM $table_name WHERE payment_id=%s", array($payment_id));
$payment_id_used = $wpdb->get_var($query);
} while ($payment_id_used);
$currency = $order->get_currency();
$rate = self::get_live_rate($currency);
$fiat_amount = $order->get_total('');
$monero_amount = 1e8 * $fiat_amount / $rate;
if(self::$discount)
$monero_amount = $monero_amount - $monero_amount * self::$discount / 100;
$monero_amount = intval($monero_amount * MONERO_GATEWAY_ATOMIC_UNITS_POW);
$query = $wpdb->prepare("INSERT INTO $table_name (order_id, payment_id, currency, rate, amount) VALUES (%d, %s, %s, %d, %d)", array($order_id, $payment_id, $currency, $rate, $monero_amount));
$wpdb->query($query);
$order->update_status('on-hold', __('Awaiting offline payment', 'monero_gateway'));
$order->reduce_order_stock(); // Reduce stock levels
WC()->cart->empty_cart(); // Remove cart
return array(
'result' => 'success',
'redirect' => $this->get_return_url($order)
);
}
/*
* function for verifying payments
* This cron runs every 30 seconds
*/
public static function do_update_event()
{
global $wpdb;
// Get Live Price
$currencies = implode(',', self::$currencies);
$api_link = 'https://min-api.cryptocompare.com/data/price?fsym=XMR&tsyms='.$currencies.'&extraParams=monero_woocommerce';
$curl = curl_init();
curl_setopt_array($curl, array(
CURLOPT_RETURNTRANSFER => 1,
CURLOPT_URL => $api_link,
));
$resp = curl_exec($curl);
curl_close($curl);
$price = json_decode($resp, true);
if(!isset($price['Response']) || $price['Response'] != 'Error') {
$table_name = $wpdb->prefix.'monero_gateway_live_rates';
foreach($price as $currency=>$rate) {
// shift decimal eight places for precise int storage
$rate = intval($rate * 1e8);
$query = $wpdb->prepare("INSERT INTO $table_name (currency, rate, updated) VALUES (%s, %d, NOW()) ON DUPLICATE KEY UPDATE rate=%d, updated=NOW()", array($currency, $rate, $rate));
$wpdb->query($query);
}
}
// Get current network/wallet height
if(self::$confirm_type == 'monero-wallet-rpc')
$height = self::$monero_wallet_rpc->getheight();
else
$height = self::$monero_explorer_tools->getheight();
set_transient('monero_gateway_network_height', $height);
// Get pending payments
$table_name_1 = $wpdb->prefix.'monero_gateway_quotes';
$table_name_2 = $wpdb->prefix.'monero_gateway_quotes_txids';
$query = $wpdb->prepare("SELECT *, $table_name_1.payment_id AS payment_id, $table_name_1.amount AS amount_total, $table_name_2.amount AS amount_paid, NOW() as now FROM $table_name_1 LEFT JOIN $table_name_2 ON $table_name_1.payment_id = $table_name_2.payment_id WHERE pending=1", array());
$rows = $wpdb->get_results($query);
$pending_payments = array();
// Group the query into distinct orders by payment_id
foreach($rows as $row) {
if(!isset($pending_payments[$row->payment_id]))
$pending_payments[$row->payment_id] = array(
'quote' => null,
'txs' => array()
);
$pending_payments[$row->payment_id]['quote'] = $row;
if($row->txid)
$pending_payments[$row->payment_id]['txs'][] = $row;
}
// Loop through each pending payment and check status
foreach($pending_payments as $pending) {
$quote = $pending['quote'];
$old_txs = $pending['txs'];
$order_id = $quote->order_id;
$order = wc_get_order($order_id);
$payment_id = self::sanatize_id($quote->payment_id);
$amount_monero = $quote->amount_total;
if(self::$confirm_type == 'monero-wallet-rpc')
$new_txs = self::check_payment_rpc($payment_id);
else
$new_txs = self::check_payment_explorer($payment_id);
foreach($new_txs as $new_tx) {
$is_new_tx = true;
foreach($old_txs as $old_tx) {
if($new_tx['txid'] == $old_tx->txid && $new_tx['amount'] == $old_tx->amount_paid) {
$is_new_tx = false;
break;
}
}
if($is_new_tx) {
$old_txs[] = (object) $new_tx;
}
$query = $wpdb->prepare("INSERT INTO $table_name_2 (payment_id, txid, amount, height) VALUES (%s, %s, %d, %d) ON DUPLICATE KEY UPDATE height=%d", array($payment_id, $new_tx['txid'], $new_tx['amount'], $new_tx['height'], $new_tx['height']));
$wpdb->query($query);
}
$txs = $old_txs;
$heights = array();
$amount_paid = 0;
foreach($txs as $tx) {
$amount_paid += $tx->amount;
$heights[] = $tx->height;
}
$paid = $amount_paid > $amount_monero - MONERO_GATEWAY_ATOMIC_UNIT_THRESHOLD;
if($paid) {
if(self::$confirms == 0) {
$confirmed = true;
} else {
$highest_block = max($heights);
if($height - $highest_block >= self::$confirms && !in_array(0, $heights)) {
$confirmed = true;
} else {
$confirmed = false;
}
}
} else {
$confirmed = false;
}
if($paid && $confirmed) {
self::$log->add('Monero_Payments', "[SUCCESS] Payment has been confirmed for order id $order_id and payment id $payment_id");
$query = $wpdb->prepare("UPDATE $table_name_1 SET confirmed=1,paid=1,pending=0 WHERE payment_id=%s", array($payment_id));
$wpdb->query($query);
unset(self::$payment_details[$order_id]);
if(self::is_virtual_in_cart($order_id) == true){
$order->update_status('completed', __('Payment has been received.', 'monero_gateway'));
} else {
$order->update_status('processing', __('Payment has been received.', 'monero_gateway'));
}
} else if($paid) {
self::$log->add('Monero_Payments', "[SUCCESS] Payment has been received for order id $order_id and payment id $payment_id");
$query = $wpdb->prepare("UPDATE $table_name_1 SET paid=1 WHERE payment_id=%s", array($payment_id));
$wpdb->query($query);
unset(self::$payment_details[$order_id]);
} else {
$timestamp_created = new DateTime($quote->created);
$timestamp_now = new DateTime($quote->now);
$order_age_seconds = $timestamp_now->getTimestamp() - $timestamp_created->getTimestamp();
if($order_age_seconds > self::$valid_time) {
self::$log->add('Monero_Payments', "[FAILED] Payment has expired for order id $order_id and payment id $payment_id");
$query = $wpdb->prepare("UPDATE $table_name_1 SET pending=0 WHERE payment_id=%s", array($payment_id));
$wpdb->query($query);
unset(self::$payment_details[$order_id]);
$order->update_status('cancelled', __('Payment has expired.', 'monero_gateway'));
}
}
}
}
protected static function check_payment_rpc($payment_id)
{
$txs = array();
$payments = self::$monero_wallet_rpc->get_all_payments($payment_id);
foreach($payments as $payment) {
$txs[] = array(
'amount' => $payment['amount'],
'txid' => $payment['tx_hash'],
'height' => $payment['block_height']
);
}
return $txs;
}
public static function check_payment_explorer($payment_id)
{
$txs = array();
$outputs = self::$monero_explorer_tools->get_outputs(self::$address, self::$viewkey);
foreach($outputs as $payment) {
if($payment['payment_id'] == $payment_id) {
$txs[] = array(
'amount' => $payment['amount'],
'txid' => $payment['tx_hash'],
'height' => $payment['block_no']
);
}
}
return $txs;
}
protected static function get_payment_details($order_id)
{
if(!is_integer($order_id))
$order_id = $order_id->get_id();
if(isset(self::$payment_details[$order_id]))
return self::$payment_details[$order_id];
global $wpdb;
$table_name_1 = $wpdb->prefix.'monero_gateway_quotes';
$table_name_2 = $wpdb->prefix.'monero_gateway_quotes_txids';
$query = $wpdb->prepare("SELECT *, $table_name_1.payment_id AS payment_id, $table_name_1.amount AS amount_total, $table_name_2.amount AS amount_paid, NOW() as now FROM $table_name_1 LEFT JOIN $table_name_2 ON $table_name_1.payment_id = $table_name_2.payment_id WHERE order_id=%d", array($order_id));
$details = $wpdb->get_results($query);
if (count($details)) {
$txs = array();
$heights = array();
$amount_paid = 0;
foreach($details as $tx) {
if(!isset($tx->txid))
continue;
$txs[] = array(
'txid' => $tx->txid,
'height' => $tx->height,
'amount' => $tx->amount_paid,
'amount_formatted' => self::format_monero($tx->amount_paid)
);
$amount_paid += $tx->amount_paid;
$heights[] = $tx->height;
}
usort($txs, function($a, $b) {
if($a['height'] == 0) return -1;
return $b['height'] - $a['height'];
});
if(count($heights) && !in_array(0, $heights)) {
$height = get_transient('monero_gateway_network_height');
$highest_block = max($heights);
$confirms = $height - $highest_block;
$blocks_to_confirm = self::$confirms - $confirms;
} else {
$blocks_to_confirm = self::$confirms;
}
$time_to_confirm = self::format_seconds_to_time($blocks_to_confirm * MONERO_GATEWAY_DIFFICULTY_TARGET);
$amount_total = $details[0]->amount_total;
$amount_due = max(0, $amount_total - $amount_paid);
$timestamp_created = new DateTime($details[0]->created);
$timestamp_now = new DateTime($details[0]->now);
$order_age_seconds = $timestamp_now->getTimestamp() - $timestamp_created->getTimestamp();
$order_expires_seconds = self::$valid_time - $order_age_seconds;
$address = self::$address;
$payment_id = self::sanatize_id($details[0]->payment_id);
if(self::$confirm_type == 'monero-wallet-rpc') {
$array_integrated_address = self::$monero_wallet_rpc->make_integrated_address($payment_id);
if (isset($array_integrated_address['integrated_address'])) {
$integrated_addr = $array_integrated_address['integrated_address'];
} else {
self::$log->add('Monero_Gateway', '[ERROR] Unable get integrated address');
return '[ERROR] Unable get integrated address';
}
} else {
if ($address) {
$decoded_address = self::$cryptonote->decode_address($address);
$pub_spendkey = $decoded_address['spendkey'];
$pub_viewkey = $decoded_address['viewkey'];
$integrated_addr = self::$cryptonote->integrated_addr_from_keys($pub_spendkey, $pub_viewkey, $payment_id);
} else {
self::$log->add('Monero_Gateway', '[ERROR] Merchant has not set Monero address');
return '[ERROR] Merchant has not set Monero address';
}
}
$status = '';
$paid = $details[0]->paid == 1;
$confirmed = $details[0]->confirmed == 1;
$pending = $details[0]->pending == 1;
if($confirmed) {
$status = 'confirmed';
} else if($paid) {
$status = 'paid';
} else if($pending && $order_expires_seconds > 0) {
if(count($txs)) {
$status = 'partial';
} else {
$status = 'unpaid';
}
} else {
if(count($txs)) {
$status = 'expired_partial';
} else {
$status = 'expired';
}
}
$qrcode_uri = 'monero:'.$address.'?tx_amount='.$amount_due.'&tx_payment_id='.$payment_id;
$my_order_url = wc_get_endpoint_url('view-order', $order_id, wc_get_page_permalink('myaccount'));
$payment_details = array(
'order_id' => $order_id,
'payment_id' => $payment_id,
'integrated_address' => $integrated_addr,
'qrcode_uri' => $qrcode_uri,
'my_order_url' => $my_order_url,
'rate' => $details[0]->rate,
'rate_formatted' => sprintf('%.8f', $details[0]->rate / 1e8),
'currency' => $details[0]->currency,
'amount_total' => $amount_total,
'amount_paid' => $amount_paid,
'amount_due' => $amount_due,
'amount_total_formatted' => self::format_monero($amount_total),
'amount_paid_formatted' => self::format_monero($amount_paid),
'amount_due_formatted' => self::format_monero($amount_due),
'status' => $status,
'created' => $details[0]->created,
'order_age' => $order_age_seconds,
'order_expires' => self::format_seconds_to_time($order_expires_seconds),
'blocks_to_confirm' => $blocks_to_confirm,
'time_to_confirm' => $time_to_confirm,
'txs' => $txs
);
self::$payment_details[$order_id] = $payment_details;
return $payment_details;
} else {
return '[ERROR] Quote not found';
}
}
public static function get_payment_details_ajax() {
$user = wp_get_current_user();
if($user === 0)
self::ajax_output(array('error' => '[ERROR] User not logged in'));
$order_id = preg_replace("/[^0-9]+/", "", $_GET['order_id']);
$order = wc_get_order( $order_id );
if($order->user_id != $user->ID)
self::ajax_output(array('error' => '[ERROR] Order does not belong to this user'));
if($order->get_payment_method() != self::$_id)
self::ajax_output(array('error' => '[ERROR] Order not paid for with Monero'));
$details = self::get_payment_details($order);
if(!is_array($details))
self::ajax_output(array('error' => $details));
self::ajax_output($details);
}
public static function ajax_output($response) {
ob_clean();
header('Content-type: application/json');
echo json_encode($response);
wp_die();
}
public static function admin_order_page($post)
{
$order = wc_get_order($post->ID);
if($order->get_payment_method() != self::$_id)
return;
$method_title = self::$_title;
$details = self::get_payment_details($order);
if(!is_array($details)) {
$error = $details;
include MONERO_GATEWAY_PLUGIN_DIR . '/templates/monero-gateway/admin/order-history-error-page.php';
return;
}
include MONERO_GATEWAY_PLUGIN_DIR . '/templates/monero-gateway/admin/order-history-page.php';
}
public static function customer_order_page($order)
{
if(is_integer($order)) {
$order_id = $order;
$order = wc_get_order($order_id);
} else {
$order_id = $order->get_id();
}
if($order->get_payment_method() != self::$_id)
return;
$method_title = self::$_title;
$details = self::get_payment_details($order_id);
if(!is_array($details)) {
$error = $details;
include MONERO_GATEWAY_PLUGIN_DIR . '/templates/monero-gateway/customer/order-error-page.php';
return;
}
$show_qr = self::$show_qr;
$details_json = json_encode($details);
$ajax_url = WC_AJAX::get_endpoint('monero_gateway_payment_details');
include MONERO_GATEWAY_PLUGIN_DIR . '/templates/monero-gateway/customer/order-page.php';
}
public static function customer_order_email($order)
{
if(is_integer($order)) {
$order_id = $order;
$order = wc_get_order($order_id);
} else {
$order_id = $order->get_id();
}
if($order->get_payment_method() != self::$_id)
return;
$method_title = self::$_title;
$details = self::get_payment_details($order_id);
if(!is_array($details)) {
include MONERO_GATEWAY_PLUGIN_DIR . '/templates/monero-gateway/customer/order-email-error-block.php';
return;
}
include MONERO_GATEWAY_PLUGIN_DIR . '/templates/monero-gateway/customer/order-email-block.php';
}
public static function get_id()
{
return self::$_id;
}
public static function get_confirm_type()
{
return self::$confirm_type;
}
public static function use_qr_code()
{
return self::$show_qr;
}
public static function use_monero_price()
{
return self::$use_monero_price;
}
public static function convert_wc_price($price, $currency)
{
$rate = self::get_live_rate($currency);
$monero_amount = intval(MONERO_GATEWAY_ATOMIC_UNITS_POW * 1e8 * $price / $rate) / MONERO_GATEWAY_ATOMIC_UNITS_POW;
$monero_amount_formatted = sprintf('%.'.self::$use_monero_price_decimals.'f', $monero_amount);
return <<
$monero_amount_formatted
XMR
HTML;
}
public static function convert_wc_price_order($price_html, $order)
{
if($order->get_payment_method() != self::$_id)
return $price_html;
$order_id = $order->get_id();
$payment_details = self::get_payment_details($order_id);
if(!is_array($payment_details))
return $price_html;
// Experimental regex, may fail with other custom price formatters
$match_ok = preg_match('/data-price="([^"]*)"/', $price_html, $matches);
if($match_ok !== 1) // regex failed
return $price_html;
$price = array_pop($matches);
$currency = $payment_details['currency'];
$rate = $payment_details['rate'];
$monero_amount = intval(MONERO_GATEWAY_ATOMIC_UNITS_POW * 1e8 * $price / $rate) / MONERO_GATEWAY_ATOMIC_UNITS_POW;
$monero_amount_formatted = sprintf('%.'.MONERO_GATEWAY_ATOMIC_UNITS.'f', $monero_amount);
return <<
$monero_amount_formatted
XMR
HTML;
}
public static function get_live_rate($currency)
{
if(isset(self::$rates[$currency]))
return self::$rates[$currency];
global $wpdb;
$table_name = $wpdb->prefix.'monero_gateway_live_rates';
$query = $wpdb->prepare("SELECT rate FROM $table_name WHERE currency=%s", array($currency));
$rate = $wpdb->get_row($query)->rate;
self::$rates[$currency] = $rate;
return $rate;
}
protected static function sanatize_id($payment_id)
{
// Limit payment id to alphanumeric characters
$sanatized_id = preg_replace("/[^a-zA-Z0-9]+/", "", $payment_id);
return $sanatized_id;
}
protected static function is_virtual_in_cart($order_id)
{
$order = wc_get_order($order_id);
$items = $order->get_items();
$cart_size = count($items);
$virtual_items = 0;
foreach ( $items as $item ) {
$product = new WC_Product( $item['product_id'] );
if ($product->is_virtual()) {
$virtual_items += 1;
}
}
return $virtual_items == $cart_size;
}
public static function format_monero($atomic_units) {
return sprintf(MONERO_GATEWAY_ATOMIC_UNITS_SPRINTF, $atomic_units / MONERO_GATEWAY_ATOMIC_UNITS_POW);
}
public static function format_seconds_to_time($seconds)
{
$units = array();
$dtF = new \DateTime('@0');
$dtT = new \DateTime("@$seconds");
$diff = $dtF->diff($dtT);
$d = $diff->format('%a');
$h = $diff->format('%h');
$m = $diff->format('%i');
if($d == 1)
$units[] = "$d day";
else if($d > 1)
$units[] = "$d days";
if($h == 0 && $d != 0)
$units[] = "$h hours";
else if($h == 1)
$units[] = "$h hour";
else if($h > 0)
$units[] = "$h hours";
if($m == 1)
$units[] = "$m minute";
else
$units[] = "$m minutes";
return implode(', ', $units) . ($seconds < 0 ? ' ago' : '');
}
}