AsyncRequest.php
1 year ago
AsyncWebhookService.php
1 year ago
BackgroundProcess.php
1 year ago
BackgroundServiceProvider.php
1 year ago
BulkActionService.php
1 year ago
QueueService.php
1 year ago
AsyncWebhookService.php
121 lines
| 1 | <?php |
| 2 | |
| 3 | namespace SureCart\Background; |
| 4 | |
| 5 | use SureCart\Models\IncomingWebhook; |
| 6 | |
| 7 | /** |
| 8 | * SureCart Queue |
| 9 | * |
| 10 | * A job queue using WordPress actions. |
| 11 | */ |
| 12 | class AsyncWebhookService extends AsyncRequest { |
| 13 | /** |
| 14 | * Map object names to their models. |
| 15 | * |
| 16 | * @var array |
| 17 | */ |
| 18 | protected $models = [ |
| 19 | 'charge' => \SureCart\Models\Charge::class, |
| 20 | 'coupon' => \SureCart\Models\Coupon::class, |
| 21 | 'customer' => \SureCart\Models\Customer::class, |
| 22 | 'purchase' => \SureCart\Models\Purchase::class, |
| 23 | 'price' => \SureCart\Models\Price::class, |
| 24 | 'product' => \SureCart\Models\Product::class, |
| 25 | 'period' => \SureCart\Models\Period::class, |
| 26 | 'order' => \SureCart\Models\Order::class, |
| 27 | 'refund' => \SureCart\Models\Refund::class, |
| 28 | 'subscription' => \SureCart\Models\Subscription::class, |
| 29 | 'invoice' => \SureCart\Models\Invoice::class, |
| 30 | 'account' => \SureCart\Models\Account::class, |
| 31 | 'webhook_endpoint' => \SureCart\Models\Webhook::class, |
| 32 | ]; |
| 33 | |
| 34 | /** |
| 35 | * Bootstrap the service. |
| 36 | * |
| 37 | * @return void |
| 38 | */ |
| 39 | public function bootstrap() { |
| 40 | // nothing to bootstrap. |
| 41 | } |
| 42 | |
| 43 | /** |
| 44 | * Enqueue an action to run one time, as soon as possible |
| 45 | * |
| 46 | * @var string |
| 47 | */ |
| 48 | protected $prefix = 'surecart'; |
| 49 | |
| 50 | /** |
| 51 | * Action for ajax hooks. |
| 52 | * |
| 53 | * @var string |
| 54 | */ |
| 55 | protected $action = 'async_webhook'; |
| 56 | |
| 57 | /** |
| 58 | * Handle a dispatched request. |
| 59 | * |
| 60 | * @param integer $id The webhook process id. |
| 61 | * @return void |
| 62 | * @throws \Exception If no id is specified. |
| 63 | */ |
| 64 | public function handle( $id = 0 ) { |
| 65 | // get the webhook. |
| 66 | $id = (int) ( $id ? $id : $_POST['id'] ); // phpcs:ignore WordPress.Security.NonceVerification.Missing |
| 67 | |
| 68 | // get the event name. |
| 69 | if ( empty( $id ) ) { |
| 70 | error_log( 'No id specified for webhook' ); |
| 71 | throw new \Exception( 'No id specified for webhook' ); |
| 72 | } |
| 73 | |
| 74 | // find the webhook. |
| 75 | $webhook = IncomingWebhook::find( $id ); |
| 76 | |
| 77 | // get WP error and throw exception. |
| 78 | if ( is_wp_error( $webhook ) ) { |
| 79 | error_log( 'SureCart Webhook Processing Error (' . esc_html( $id ) . ') ' . $webhook->get_error_message() ); |
| 80 | throw new \Exception( $webhook->get_error_message() ); |
| 81 | } |
| 82 | |
| 83 | // get the event name. |
| 84 | if ( empty( $webhook->data->type ) ) { |
| 85 | error_log( 'No event specified for webhook' ); |
| 86 | throw new \Exception( 'No event specified for webhook' ); |
| 87 | } |
| 88 | |
| 89 | $object_name = $webhook->data->data->object->object ?? ''; |
| 90 | |
| 91 | // get model. |
| 92 | $class = $this->models[ $object_name ] ?? null; |
| 93 | |
| 94 | // We don't have a model. That's okay since we only subscribe to specific items. |
| 95 | if ( empty( $class ) ) { |
| 96 | $webhook->update( [ 'processed_at' => current_time( 'mysql' ) ] ); |
| 97 | return; |
| 98 | } |
| 99 | |
| 100 | // do the action. |
| 101 | do_action( $this->createEventName( $webhook->data->type ), new $class( $webhook->data->data->object ), $webhook->data ); // phpcs:ignore WordPress.Security.NonceVerification.Missing |
| 102 | |
| 103 | // update as processed. |
| 104 | $webhook->update( [ 'processed_at' => current_time( 'mysql' ) ] ); |
| 105 | |
| 106 | // update. |
| 107 | return $webhook; |
| 108 | } |
| 109 | |
| 110 | /** |
| 111 | * Replace our dot notation webhook with underscore. |
| 112 | * |
| 113 | * @param string $type The event type. |
| 114 | * @return string |
| 115 | */ |
| 116 | public function createEventName( $type = '' ) { |
| 117 | $type = str_replace( '.', '_', $type ); |
| 118 | return "surecart/$type"; |
| 119 | } |
| 120 | } |
| 121 |