<?php

[0] Fix | Delete

[1] Fix | Delete

namespace WPForms\Tasks\Actions;

[2] Fix | Delete

[3] Fix | Delete

use WPForms\Integrations\Square\Api\Api;

[4] Fix | Delete

use WPForms\Integrations\Square\Connection;

[5] Fix | Delete

use WPForms\Tasks\Task;

[6] Fix | Delete

use WPForms\Tasks\Meta;

[7] Fix | Delete

[8] Fix | Delete

/**

[9] Fix | Delete

* Class SquareSubscriptionTransactionIDTask.

[10] Fix | Delete

*

[11] Fix | Delete

* @since 1.9.5

[12] Fix | Delete

*/

[13] Fix | Delete

class SquareSubscriptionTransactionIDTask extends Task {

[14] Fix | Delete

[15] Fix | Delete

/**

[16] Fix | Delete

* Action name.

[17] Fix | Delete

*

[18] Fix | Delete

* @since 1.9.5

[19] Fix | Delete

*/

[20] Fix | Delete

private const ACTION = 'wpforms_process_square_subscription_transaction_id';

[21] Fix | Delete

[22] Fix | Delete

/**

[23] Fix | Delete

* Constructor.

[24] Fix | Delete

*

[25] Fix | Delete

* @since 1.9.5

[26] Fix | Delete

*/

[27] Fix | Delete

public function __construct() {

[28] Fix | Delete

[29] Fix | Delete

parent::__construct( self::ACTION );

[30] Fix | Delete

[31] Fix | Delete

$this->init();

[32] Fix | Delete

}

[33] Fix | Delete

[34] Fix | Delete

/**

[35] Fix | Delete

* Initialize.

[36] Fix | Delete

*

[37] Fix | Delete

* @since 1.9.5

[38] Fix | Delete

*/

[39] Fix | Delete

private function init() {

[40] Fix | Delete

[41] Fix | Delete

$this->hooks();

[42] Fix | Delete

}

[43] Fix | Delete

[44] Fix | Delete

/**

[45] Fix | Delete

* Register hooks.

[46] Fix | Delete

*

[47] Fix | Delete

* @since 1.9.5

[48] Fix | Delete

*/

[49] Fix | Delete

private function hooks() {

[50] Fix | Delete

[51] Fix | Delete

add_action( 'wpforms_process_payment_saved', [ $this, 'add_task' ], 999, 3 );

[52] Fix | Delete

add_action( self::ACTION, [ $this, 'process' ] );

[53] Fix | Delete

}

[54] Fix | Delete

[55] Fix | Delete

/**

[56] Fix | Delete

* Add task to the queue.

[57] Fix | Delete

*

[58] Fix | Delete

* @since 1.9.5

[59] Fix | Delete

*

[60] Fix | Delete

* @param string $payment_id Payment ID.

[61] Fix | Delete

* @param array $fields Final/sanitized submitted field data.

[62] Fix | Delete

* @param array $form_data Form data and settings.

[63] Fix | Delete

*/

[64] Fix | Delete

public function add_task( $payment_id, array $fields, array $form_data ) {

[65] Fix | Delete

[66] Fix | Delete

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

[67] Fix | Delete

[68] Fix | Delete

if ( ! $payment_obj ) {

[69] Fix | Delete

return;

[70] Fix | Delete

}

[71] Fix | Delete

[72] Fix | Delete

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

[73] Fix | Delete

[74] Fix | Delete

if ( ! $payment ) {

[75] Fix | Delete

return;

[76] Fix | Delete

}

[77] Fix | Delete

[78] Fix | Delete

// Bail early if not Square subscription.

[79] Fix | Delete

if ( $payment->gateway !== 'square' || $payment->type !== 'subscription' ) {

[80] Fix | Delete

return;

[81] Fix | Delete

}

[82] Fix | Delete

[83] Fix | Delete

// Bail early if transaction_id is already set via webhooks.

[84] Fix | Delete

if ( ! empty( $payment->transaction_id ) ) {

[85] Fix | Delete

return;

[86] Fix | Delete

}

[87] Fix | Delete

[88] Fix | Delete

// Add task to the queue.

[89] Fix | Delete

wpforms()->obj( 'tasks' )

[90] Fix | Delete

->create( self::ACTION )

[91] Fix | Delete

->once( time() + MINUTE_IN_SECONDS )

[92] Fix | Delete

->params( (int) $payment_id )

[93] Fix | Delete

->register();

[94] Fix | Delete

}

[95] Fix | Delete

[96] Fix | Delete

/**

[97] Fix | Delete

* Process the task.

[98] Fix | Delete

*

[99] Fix | Delete

* @since 1.9.5

[100] Fix | Delete

*

[101] Fix | Delete

* @param int $meta_id Meta ID.

[102] Fix | Delete

*/

[103] Fix | Delete

public function process( $meta_id ) {

[104] Fix | Delete

[105] Fix | Delete

$task_meta = new Meta();

[106] Fix | Delete

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

[107] Fix | Delete

[108] Fix | Delete

if ( empty( $meta ) || empty( $meta->data ) ) {

[109] Fix | Delete

return;

[110] Fix | Delete

}

[111] Fix | Delete

[112] Fix | Delete

[ $payment_id ] = $meta->data;

[113] Fix | Delete

[114] Fix | Delete

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

[115] Fix | Delete

[116] Fix | Delete

// Bail early if transaction_id is already set via webhooks.

[117] Fix | Delete

if ( ! empty( $payment->transaction_id ) ) {

[118] Fix | Delete

return;

[119] Fix | Delete

}

[120] Fix | Delete

[121] Fix | Delete

if ( ! Connection::get() ) {

[122] Fix | Delete

return;

[123] Fix | Delete

}

[124] Fix | Delete

[125] Fix | Delete

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

[126] Fix | Delete

[127] Fix | Delete

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

[128] Fix | Delete

[129] Fix | Delete

if ( $subscription === null ) {

[130] Fix | Delete

return;

[131] Fix | Delete

}

[132] Fix | Delete

[133] Fix | Delete

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

[134] Fix | Delete

[135] Fix | Delete

if ( $invoice === null ) {

[136] Fix | Delete

return;

[137] Fix | Delete

}

[138] Fix | Delete

[139] Fix | Delete

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

[140] Fix | Delete

[141] Fix | Delete

// Set transaction_id for the subscription in case it not received earlier.

[142] Fix | Delete

wpforms()->obj( 'payment' )->update(

[143] Fix | Delete

$payment_id,

[144] Fix | Delete

[ 'transaction_id' => $transaction_id ],

[145] Fix | Delete

'',

[146] Fix | Delete

'',

[147] Fix | Delete

[ 'cap' => false ]

[148] Fix | Delete

);

[149] Fix | Delete

[150] Fix | Delete

// Log.

[151] Fix | Delete

wpforms()->obj( 'payment_meta' )->add_log(

[152] Fix | Delete

$payment_id,

[153] Fix | Delete

sprintf(

[154] Fix | Delete

'Square subscription was created. (Invoice ID: %s)',

[155] Fix | Delete

$invoice->getId()

[156] Fix | Delete

)

[157] Fix | Delete

);

[158] Fix | Delete

}

[159] Fix | Delete

}

[160] Fix | Delete

[161] Fix | Delete