mirror of
https://github.com/invoiceninja/invoiceninja.git
synced 2024-09-21 17:01:33 +02:00
123 lines
3.2 KiB
PHP
123 lines
3.2 KiB
PHP
<?php
|
|
/**
|
|
* Invoice Ninja (https://invoiceninja.com).
|
|
*
|
|
* @link https://github.com/invoiceninja/invoiceninja source repository
|
|
*
|
|
* @copyright Copyright (c) 2020. Invoice Ninja LLC (https://invoiceninja.com)
|
|
*
|
|
* @license https://opensource.org/licenses/AAL
|
|
*/
|
|
namespace App\Jobs\Util;
|
|
|
|
use App\Libraries\MultiDB;
|
|
use App\Models\Webhook;
|
|
use App\Transformers\ArraySerializer;
|
|
use GuzzleHttp\Client;
|
|
use GuzzleHttp\RequestOptions;
|
|
use Illuminate\Bus\Queueable;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|
use Illuminate\Queue\InteractsWithQueue;
|
|
use Illuminate\Queue\SerializesModels;
|
|
use League\Fractal\Manager;
|
|
use League\Fractal\Resource\Item;
|
|
|
|
class WebhookHandler implements ShouldQueue
|
|
{
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
|
|
|
private $entity;
|
|
|
|
private $event_id;
|
|
|
|
private $company;
|
|
|
|
public $tries = 5; //number of retries
|
|
|
|
public $backoff = 5; //seconds to wait until retry
|
|
|
|
public $deleteWhenMissingModels = true;
|
|
|
|
|
|
/**
|
|
* Create a new job instance.
|
|
*
|
|
* @param $event_id
|
|
* @param $entity
|
|
*/
|
|
public function __construct($event_id, $entity, $company)
|
|
{
|
|
$this->event_id = $event_id;
|
|
$this->entity = $entity;
|
|
$this->company = $company;
|
|
}
|
|
|
|
/**
|
|
* Execute the job.
|
|
*
|
|
* @return bool
|
|
*/
|
|
public function handle()
|
|
{//todo set multidb here
|
|
|
|
MultiDB::setDb($this->company->db);
|
|
|
|
if (! $this->company || $this->company->is_disabled) {
|
|
return true;
|
|
}
|
|
|
|
|
|
$subscriptions = Webhook::where('company_id', $this->company->id)
|
|
->where('event_id', $this->event_id)
|
|
->get();
|
|
|
|
if (! $subscriptions || $subscriptions->count() == 0) {
|
|
return;
|
|
}
|
|
|
|
$subscriptions->each(function ($subscription) {
|
|
$this->process($subscription);
|
|
});
|
|
}
|
|
|
|
private function process($subscription)
|
|
{
|
|
// generate JSON data
|
|
$manager = new Manager();
|
|
$manager->setSerializer(new ArraySerializer());
|
|
|
|
$class = sprintf('App\\Transformers\\%sTransformer', class_basename($this->entity));
|
|
|
|
$transformer = new $class();
|
|
|
|
$resource = new Item($this->entity, $transformer, $this->entity->getEntityType());
|
|
$data = $manager->createData($resource)->toArray();
|
|
|
|
$this->postData($subscription, $data, []);
|
|
}
|
|
|
|
private function postData($subscription, $data, $headers = [])
|
|
{
|
|
$base_headers = [
|
|
'Content-Length' => strlen(json_encode($data)),
|
|
'Accept' => 'application/json',
|
|
];
|
|
|
|
$client = new Client(['headers' => array_merge($base_headers, $headers)]);
|
|
|
|
$response = $client->post($subscription->target_url, [
|
|
RequestOptions::JSON => $data, // or 'json' => [...]
|
|
]);
|
|
|
|
if ($response->getStatusCode() == 410 || $response->getStatusCode() == 200) {
|
|
$subscription->delete();
|
|
}
|
|
}
|
|
|
|
public function failed($exception)
|
|
{
|
|
info(print_r($exception->getMessage(), 1));
|
|
}
|
|
}
|