gistfile1.php

<?php

function rcp_process_paypal($subscription_data) {

	global $rcp_options;

	$paypal_redirect = '';
	$paypal_email = $rcp_options['paypal_email'];
	$listener_url = home_url('/') . '?listener=IPN';
	
	if( isset($rcp_options['sandbox'])) {
		$paypal_redirect = 'https://www.sandbox.paypal.com/cgi-bin/webscr/?';
	} else {
		$paypal_redirect = 'https://www.paypal.com/cgi-bin/webscr/?';
	}	
	
	// recurring paypal payment
	if($subscription_data['auto_renew']) {
		// recurring paypal payment
		$paypal_redirect .= 'cmd=_xclick-subscriptions&src=1&sra=1';
		$paypal_redirect .= '&a3=' . $subscription_data['price'];
		$paypal_redirect .= '&p3=' . $subscription_data['length'];
		switch ($subscription_data['length_unit']) :
			case "day" :
				$paypal_redirect .= '&t3=D';
			break;
			case "month" :
				$paypal_redirect .= '&t3=M';
			break;
			case "year" :
				$paypal_redirect .= '&t3=Y';
			break;
		endswitch;
	} else {
		// one time payment
		$paypal_redirect .= 'cmd=_xclick&amount=' . $subscription_data['price'];
	}
	
	$paypal_redirect .= '&business=' . $paypal_email;
	$paypal_redirect .= '&item_name=' . $subscription_data['subscription_name'];
	$paypal_redirect .= '&email=' . $subscription_data['user_email'];
	$paypal_redirect .= '&no_shipping=1&no_note=1&item_number=' . $subscription_data['key'];
	$paypal_redirect .= '&currency_code=' . $subscription_data['currency'];
	$paypal_redirect .= '&charset=UTF-8&return=' . urlencode($subscription_data['return_url']);
	$paypal_redirect .= '&notify_url=' . urlencode($listener_url);
	$paypal_redirect .= '&rm=2&custom=' . $subscription_data['user_id'];
	$paypal_redirect .= '&tax=0';
		
	// Redirect to paypal
	header('Location: ' . $paypal_redirect);
	exit;
	
}
add_action('rcp_gateway_paypal', 'rcp_process_paypal');

function rcp_check_ipn() {


	global $rcp_options, $rcp_base_dir;

	if( !class_exists('IpnListener') ) {
		// instantiate the IpnListener class
		include($rcp_base_dir . '/includes/gateways/paypal/ipnlistener.php');
	}

	$listener = new IpnListener();

	if(isset($rcp_options['sandbox']) && $rcp_options['sandbox'])
		$listener->use_sandbox = true;

	if(isset($rcp_options['ssl']) && $rcp_options['ssl']) {
		$listener->use_ssl = true;
	} else {
		$listener->use_ssl = false;
	}
	
	//To post using the fsockopen() function rather than cURL, use:
	if(isset($rcp_options['disable_curl']))
		$listener->use_curl = false;

	try {
		$listener->requirePostMethod();
		$verified = $listener->processIpn();
	} catch (Exception $e) {
		//exit(0);
	}

	/*
	The processIpn() method returned true if the IPN was "VERIFIED" and false if it
	was "INVALID".
	*/
	if ($verified || isset( $_POST['verification_override'] ) || isset( $rcp_options['sandbox'] ) )  {
		
		$posted = apply_filters('rcp_ipn_post', $_POST); // allow $_POST to be modified

		$user_id 			= $posted['custom'];
		$subscription_key 	= $posted['item_number'];
		$amount 			= number_format((float)$posted['mc_gross'], 2);
		$amount2 			= number_format((float)$posted['mc_amount3'], 2);
		$payment_status 	= $posted['payment_status'];
		$currency_code		= $posted['mc_currency'];
		$subscription_price = number_format((float) rcp_get_subscription_price( rcp_get_subscription_id($user_id) ), 2) ;
		
		// setup the payment info in an array for storage
		$payment_data = array(
			'date' => date('Y-m-d g:i:s', strtotime($posted['payment_date'])),
			'subscription' => $posted['item_name'],
			'payment_type' => $posted['txn_type'],
			'payer_email' => $posted['payer_email'],
			'subscription_key' => $subscription_key,
			'amount' => $amount,
			'amount2' => $amount2,
			'user_id' => $user_id
		);

		do_action('rcp_valid_ipn', $payment_data, $user_id, $posted);
		
		if($posted['txn_type'] == 'web_accept' || $posted['txn_type'] == 'subscr_payment') {
			// only check for an existing payment if this is a payment IPD request
			if(rcp_check_for_existing_payment($posted['txn_type'], $posted['payment_date'], $subscription_key)) {
				return; // this IPN request has already been processed
			}
		}

		if(isset($rcp_options['email_ipn_reports'])) {
			wp_mail(get_bloginfo('admin_email'), __('IPN report', 'rcp'), $listener->getTextReport());
		}
	
		/* do some quick checks to make sure all necessary data validates */
		
		if ( $amount != $subscription_price && $amount2 != $subscription_price ) {	
			// the subscription price doesn't match, so lets check to see if it matches with a discount code
			if(!rcp_check_paypal_return_price_after_discount($subscription_price, $amount, $amount2, $user_id)) {
				return;
			}
		}
		if(rcp_get_subscription_key($user_id) != $subscription_key) {
			// the subscription key is invalid
			return;
		}
		if($currency_code != $rcp_options['currency']) {
			// the currency code is invalid
			return;
		}
		
		update_user_meta( $user_id, 'rcp_paypal_subscriber', 'yes');

		/* now process the kind of subscription/payment */
		
		// Subscriptions
		switch ($posted['txn_type']) :
			
			case "subscr_signup" :
				// when a new user signs up
				
				// set the user's status to active
				rcp_set_status($user_id, 'active');
				
				if( ! isset( $rcp_options['disable_new_user_notices'] ) ) {

					wp_new_user_notification($user_id);
	
				}

				// send welcome email
				rcp_email_subscription_status($user_id, 'active');

				update_user_meta( $user_id, 'rcp_recurring', 'yes');

				do_action('rcp_ipn_subscr_signup', $payment_data, $user_id );

			break;
			case "subscr_payment" :

				// when a user makes a recurring payment

				// record this payment in the database
				rcp_insert_payment($payment_data);
				
				$subscription = rcp_get_subscription_details_by_name($payment_data['subscription']);
				
				// update the user's expiration to correspond with the new payment
				$member_new_expiration = date('Y-m-d', strtotime('+' . $subscription->duration . ' ' . $subscription->duration_unit));
				
				update_user_meta( $user_id, 'rcp_expiration', $member_new_expiration );
				
				// make sure the user's status is active
				rcp_set_status($user_id, 'active');

				update_user_meta( $user_id, 'rcp_recurring', 'yes');

				do_action('rcp_ipn_subscr_payment', $payment_data, $user_id );
				
			break;
			case "subscr_cancel" :

				// user is not canceled until end of term
				
				// set the use to no longer be recurring
				delete_user_meta( $user_id, 'rcp_recurring');
				
				// send sub cancelled email
				rcp_email_subscription_status($user_id, 'cancelled');

				do_action('rcp_ipn_subscr_cancel', $payment_data, $user_id );

			break;
			case "subscr_failed" :
				do_action('rcp_ipn_subscr_failed');
				break;

			case "subscr_eot" :

				// user's subscription has reach the end of its term
				
				// set the use to no longer be recurring
				update_user_meta( $user_id, 'rcp_recurring', 'no');

				rcp_set_status($user_id, 'expired');

				// send expired email
				rcp_email_subscription_status($user_id, 'expired');

				do_action('rcp_ipn_subscr_eot', $payment_data, $user_id );

			break;
			default;
			break;
		endswitch;
		
		// Single Payments
		switch ($posted['txn_type']) :
			
			case "cart" :
			case "express_checkout" :
			case "web_accept" :
				
				switch (strtolower($payment_status)) :
		            case 'completed' :
		            
		            	if( isset( $_POST['verification_override'] ) ) {

		            		// this signup is coming from amember, so add the expiration

			            	$subscription = rcp_get_subscription_details_by_name($payment_data['subscription']);

			            	// update the user's expiration to correspond with the new payment
							$member_new_expiration = date('Y-m-d', strtotime('+' . $subscription->duration . ' ' . $subscription->duration_unit));
					
							update_user_meta( $user_id, 'rcp_expiration', $member_new_expiration );

						}

						// set this user to active
						rcp_set_status($user_id, 'active');
						
						rcp_insert_payment($payment_data);
						
						rcp_email_subscription_status($user_id, 'active');


						if( ! isset( $rcp_options['disable_new_user_notices'] ) ) {
							// send welcome email here
							wp_new_user_notification($user_id);

						}

						do_action('rcp_ipn_web_accept', $payment_data, $user_id );
						
		            break;
		            case 'denied' :
		            case 'expired' :
		            case 'failed' :
		            case 'voided' :
						rcp_set_status($user_id, 'cancelled');
						// send cancelled email here
						do_action('rcp_ipn_voided', $payment_data, $user_id );
		            break;
		        endswitch;
				
			break;
			default :
			break;
			
		endswitch;

	} else {
		if(isset($rcp_options['email_ipn_reports'])) {
			// an invalid IPN attempt was made. Send an email to the admin account to investigate
			wp_mail(get_bloginfo('admin_email'), __('Invalid IPN', 'rcp'), $listener->getTextReport());
		}
	}
}
add_action('verify-paypal-ipn', 'rcp_check_ipn');

function rcp_listen_for_paypal_ipn() {
	if(isset($_GET['listener']) && $_GET['listener'] == 'IPN') {
		do_action('verify-paypal-ipn');
	}
}
add_action('init', 'rcp_listen_for_paypal_ipn');