Edit File by line

<?php

[0] Fix | Delete

[1] Fix | Delete

namespace WPForms\Lite\Integrations\LiteConnect;

[2] Fix | Delete

[3] Fix | Delete

use WPForms\Integrations\LiteConnect\API;

[4] Fix | Delete

use WPForms\Tasks\Meta;

[5] Fix | Delete

[6] Fix | Delete

/**

[7] Fix | Delete

* Class SendEntryTask.

[8] Fix | Delete

[9] Fix | Delete

* @since 1.7.4

[10] Fix | Delete

[11] Fix | Delete

class SendEntryTask extends Integration {

[12] Fix | Delete

[13] Fix | Delete

/**

[14] Fix | Delete

* Task name.

[15] Fix | Delete

[16] Fix | Delete

* @since 1.7.4

[17] Fix | Delete

[18] Fix | Delete

* @var string

[19] Fix | Delete

[20] Fix | Delete

const LITE_CONNECT_TASK = 'wpforms_lite_connect_send_entry';

[21] Fix | Delete

[22] Fix | Delete

/**

[23] Fix | Delete

* SendEntryTask constructor.

[24] Fix | Delete

[25] Fix | Delete

* @since 1.7.4

[26] Fix | Delete

[27] Fix | Delete

public function __construct() {

[28] Fix | Delete

[29] Fix | Delete

parent::__construct();

[30] Fix | Delete

[31] Fix | Delete

$this->hooks();

[32] Fix | Delete

}

[33] Fix | Delete

[34] Fix | Delete

/**

[35] Fix | Delete

* Initialize the hooks.

[36] Fix | Delete

[37] Fix | Delete

* @since 1.7.4

[38] Fix | Delete

[39] Fix | Delete

private function hooks() {

[40] Fix | Delete

[41] Fix | Delete

// Process the tasks as needed.

[42] Fix | Delete

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

[43] Fix | Delete

}

[44] Fix | Delete

[45] Fix | Delete

/**

[46] Fix | Delete

* Creates a task to submit the lite entry to the Lite Connect API via

[47] Fix | Delete

* Action Scheduler.

[48] Fix | Delete

[49] Fix | Delete

* @since 1.7.4

[50] Fix | Delete

[51] Fix | Delete

* @param int $form_id The form ID.

[52] Fix | Delete

* @param string $entry_data The entry data.

[53] Fix | Delete

[54] Fix | Delete

public function create( $form_id, $entry_data ) {

[55] Fix | Delete

[56] Fix | Delete

$action_id = wpforms()->get( 'tasks' )

[57] Fix | Delete

->create( self::LITE_CONNECT_TASK )

[58] Fix | Delete

->params( $form_id, $entry_data )

[59] Fix | Delete

->once( time() + wp_rand( 10, 60 ) * MINUTE_IN_SECONDS )

[60] Fix | Delete

->register();

[61] Fix | Delete

[62] Fix | Delete

if ( $action_id === null ) {

[63] Fix | Delete

wpforms_log(

[64] Fix | Delete

'Lite Connect: error creating the AS task',

[65] Fix | Delete

[

[66] Fix | Delete

'task' => self::LITE_CONNECT_TASK,

[67] Fix | Delete

[68] Fix | Delete

[ 'type' => [ 'error' ] ]

[69] Fix | Delete

);

[70] Fix | Delete

}

[71] Fix | Delete

}

[72] Fix | Delete

[73] Fix | Delete

/**

[74] Fix | Delete

* Process the task to submit the entry to the Lite Connect API via

[75] Fix | Delete

* Action Scheduler.

[76] Fix | Delete

[77] Fix | Delete

* @since 1.7.4

[78] Fix | Delete

[79] Fix | Delete

* @param int $meta_id The meta ID.

[80] Fix | Delete

[81] Fix | Delete

public function process( $meta_id ) {

[82] Fix | Delete

[83] Fix | Delete

// Load task data.

[84] Fix | Delete

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

[85] Fix | Delete

[86] Fix | Delete

list( $form_id, $entry_data ) = $params->data;

[87] Fix | Delete

[88] Fix | Delete

// Grab current access token. If site key or access token is not available, then it recreates the task to run later.

[89] Fix | Delete

$access_token = $this->get_access_token( $this->get_site_key() );

[90] Fix | Delete

[91] Fix | Delete

if ( ! $access_token ) {

[92] Fix | Delete

$this->create( $form_id, $entry_data );

[93] Fix | Delete

[94] Fix | Delete

return;

[95] Fix | Delete

}

[96] Fix | Delete

[97] Fix | Delete

// Submit entry to the Lite Connect API.

[98] Fix | Delete

$response = ( new API() )->add_form_entry( $access_token, $form_id, $entry_data );

[99] Fix | Delete

[100] Fix | Delete

if ( $response ) {

[101] Fix | Delete

$response = json_decode( $response, true );

[102] Fix | Delete

}

[103] Fix | Delete

[104] Fix | Delete

if ( isset( $response['error'] ) && $response['error'] === 'Access token is invalid or expired.' ) {

[105] Fix | Delete

// Force to re-generate access token in case it is invalid.

[106] Fix | Delete

$this->get_access_token( $this->get_site_key(), true );

[107] Fix | Delete

}

[108] Fix | Delete

[109] Fix | Delete

if ( ! empty( $response['error'] ) ) {

[110] Fix | Delete

wpforms_log(

[111] Fix | Delete

'Lite Connect: error submitting form entry (AS task)',

[112] Fix | Delete

[

[113] Fix | Delete

'response' => $response,

[114] Fix | Delete

'entry_data' => $entry_data,

[115] Fix | Delete

[116] Fix | Delete

[

[117] Fix | Delete

'type' => [ 'error' ],

[118] Fix | Delete

'form_id' => $form_id,

[119] Fix | Delete

]

[120] Fix | Delete

);

[121] Fix | Delete

}

[122] Fix | Delete

[123] Fix | Delete

// Recreate the task if the request to the API fail for any reasons.

[124] Fix | Delete

if ( ! isset( $response['status'] ) || $response['status'] !== 'success' ) {

[125] Fix | Delete

$this->create( $form_id, $entry_data );

[126] Fix | Delete

[127] Fix | Delete

return;

[128] Fix | Delete

}

[129] Fix | Delete

[130] Fix | Delete

// Increase the entries count if the entry has been added successfully.

[131] Fix | Delete

$this->increase_entries_count( $form_id );

[132] Fix | Delete

}

[133] Fix | Delete

}

[134] Fix | Delete

[135] Fix | Delete