Tiny File Manager

Back Back Up Advanced Editor

<?php

namespace WPForms\Tasks\Actions;

use WPForms\Integrations\Square\Api\Api;
use WPForms\Integrations\Square\Connection;
use WPForms\Tasks\Task;
use WPForms\Tasks\Meta;

/**
 * Class SquareSubscriptionTransactionIDTask.
 *
 * @since 1.9.5
 */
class SquareSubscriptionTransactionIDTask extends Task {

/**
	 * Action name.
	 *
	 * @since 1.9.5
	 */
	private const ACTION = 'wpforms_process_square_subscription_transaction_id';

/**
	 * Constructor.
	 *
	 * @since 1.9.5
	 */
	public function __construct() {

parent::__construct( self::ACTION );

$this->init();
	}

/**
	 * Initialize.
	 *
	 * @since 1.9.5
	 */
	private function init() {

$this->hooks();
	}

/**
	 * Register hooks.
	 *
	 * @since 1.9.5
	 */
	private function hooks() {

add_action( 'wpforms_process_payment_saved', [ $this, 'add_task' ], 999, 3 );
		add_action( self::ACTION, [ $this, 'process' ] );
	}

/**
	 * Add task to the queue.
	 *
	 * @since 1.9.5
	 *
	 * @param string $payment_id Payment ID.
	 * @param array  $fields     Final/sanitized submitted field data.
	 * @param array  $form_data  Form data and settings.
	 */
	public function add_task( $payment_id, array $fields, array $form_data ) {

$payment_obj = wpforms()->obj( 'payment' );

if ( ! $payment_obj ) {
			return;
		}

$payment = $payment_obj->get( (int) $payment_id );

if ( ! $payment ) {
			return;
		}

// Bail early if not Square subscription.
		if ( $payment->gateway !== 'square' || $payment->type !== 'subscription' ) {
			return;
		}

// Bail early if transaction_id is already set via webhooks.
		if ( ! empty( $payment->transaction_id ) ) {
			return;
		}

// Add task to the queue.
		wpforms()->obj( 'tasks' )
			->create( self::ACTION )
			->once( time() + MINUTE_IN_SECONDS )
			->params( (int) $payment_id )
			->register();
	}

/**
	 * Process the task.
	 *
	 * @since 1.9.5
	 *
	 * @param int $meta_id Meta ID.
	 */
	public function process( $meta_id ) {

$task_meta = new Meta();
		$meta      = $task_meta->get( (int) $meta_id );

if ( empty( $meta ) || empty( $meta->data ) ) {
			return;
		}

[ $payment_id ] = $meta->data;

$payment = wpforms()->obj( 'payment' )->get( (int) $payment_id );

// Bail early if transaction_id is already set via webhooks.
		if ( ! empty( $payment->transaction_id ) ) {
			return;
		}

if ( ! Connection::get() ) {
			return;
		}

$api = new Api( Connection::get() );

$subscription = $api->retrieve_subscription( $payment->subscription_id );

if ( $subscription === null ) {
			return;
		}

$invoice = $api->get_latest_subscription_invoice( $subscription );

if ( $invoice === null ) {
			return;
		}

$transaction_id = $api->get_latest_invoice_transaction_id( $invoice );

// Set transaction_id for the subscription in case it not received earlier.
		wpforms()->obj( 'payment' )->update(
			$payment_id,
			[ 'transaction_id' => $transaction_id ],
			'',
			'',
			[ 'cap' => false ]
		);

// Log.
		wpforms()->obj( 'payment_meta' )->add_log(
			$payment_id,
			sprintf(
				'Square subscription was created. (Invoice ID: %s)',
				$invoice->getId()
			)
		);
	}
}