FileMaster

Edit File: IncomingWebhooksController.php

<?php

namespace SureCart\Controllers\Rest;

use SureCart\Models\IncomingWebhook;

/**
 * Handle Price requests through the REST API
 */
class IncomingWebhooksController {
	/**
	 * Create a product integration.
	 *
	 * @param \WP_REST_Request $request Rest Request.
	 *
	 * @return \WP_REST_Response|\WP_Error
	 */
	public function create( \WP_REST_Request $request ) {
		return IncomingWebhook::create( $request->get_params() );
	}

/**
	 * Retry the incoming webhook.
	 *
	 * @param \WP_REST_Request $request Rest Request.
	 *
	 * @return void
	 */
	public function retry( \WP_REST_Request $request ) {
		try {
			$webhook = \SureCart::async()->handle( $request['id'] );
		} catch ( \Exception $e ) {
			return new \WP_Error( 'webhook_retry_failed', $e->getMessage() );
		}

if ( is_wp_error( $webhook ) ) {
			return $webhook;
		}

if ( empty( $webhook ) ) {
			return new \WP_Error( 'webhook_retry_failed', 'Webhook retry failed.' );
		}

return $webhook->toArray();
	}

/**
	 * List all product integrations.
	 *
	 * @param \WP_REST_Request $request Rest Request.
	 *
	 * @return \WP_REST_Response|\WP_Error
	 */
	public function index( \WP_REST_Request $request ) {
		$webhook = new IncomingWebhook();

// processed is false.
		if ( false === $request->get_param( 'processed' ) ) {
			$webhook = $webhook->whereNull( 'processed_at' );
		} elseif ( ! empty( $request->get_param( 'processed' ) ) ) {
			$webhook = $webhook->whereNotNull( 'processed_at' );
		}

// webhook ids.
		if ( $request->get_param( 'webhook_ids' ) ) {
			$webhook = $webhook->whereIn( 'webhook_ids', $request->get_param( 'webhook_ids' ) );
		}

$total    = $webhook->count();
		$page     = $request->get_param( 'page' ) ? $request->get_param( 'page' ) : 1;
		$per_page = $request->get_param( 'per_page' ) ? $request->get_param( 'per_page' ) : 10;

// handle pagination.
		$items = $webhook->paginate(
			[
				'page'     => $page,
				'per_page' => $per_page,
			]
		);

$response = rest_ensure_response( $items );
		$response->header( 'X-WP-Total', (int) $total );
		$response->header( 'X-WP-TotalPages', (int) ceil( $total / (int) $per_page ) );

return $response;
	}

/**
	 * Find a specific product integration.
	 *
	 * @param \WP_REST_Request $request Rest Request.
	 *
	 * @return \WP_REST_Response|\WP_Error
	 */
	public function find( \WP_REST_Request $request ) {
		$webhook = new IncomingWebhook();

// processed is false.
		if ( false === $request->get_param( 'processed' ) ) {
			$webhook = $webhook->whereNull( 'processed' );
		} elseif ( ! empty( $request->get_param( 'processed' ) ) ) {
			$webhook = $webhook->whereNotNull( 'processed' );
		}

if ( $request->get_param( 'webhook_id' ) ) {
			$webhook = $webhook->where( 'webhook_id', $request->get_param( 'webhook_id' ) );
		}

return $webhook->find( $request['id'] );
	}

/**
	 * Edit model.
	 *
	 * @param \WP_REST_Request $request Rest Request.
	 *
	 * @return \WP_REST_Response|\WP_Error
	 */
	public function edit( \WP_REST_Request $request ) {
		return IncomingWebhook::where( $request->get_query_params() )->update( array_diff_assoc( $request->get_params(), $request->get_query_params() ) );
	}

/**
	 * Delete model.
	 *
	 * @param \WP_REST_Request $request Rest Request.
	 *
	 * @return \WP_REST_Response|\WP_Error
	 */
	public function delete( \WP_REST_Request $request ) {
		return IncomingWebhook::delete( $request['id'] );
	}
}

Back