Tiny File Manager | SquareSubscriptionTransactionIDTask.php

File: SquareSubscriptionTransactionIDTask.php
Full Path: /home/mata8712/public_html/on-me-trouve/wp-content/plugins/wpforms-lite/src/Tasks/Actions/SquareSubscriptionTransactionIDTask.php
File size: 3.04 KB
MIME-type: text/x-php
Charset: utf-8

Delete Open Edit Advanced Editor Back

<?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()
			)
		);
	}
}