From 97d34f9ad6512c27ee0b60dcdee7590dd4358b33 Mon Sep 17 00:00:00 2001 From: Juan Pablo Vial Date: Tue, 13 May 2025 20:18:09 -0400 Subject: [PATCH] Uso de request original --- app/src/Service/Worker/Request.php | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/app/src/Service/Worker/Request.php b/app/src/Service/Worker/Request.php index 0b1c791..e1dabcf 100644 --- a/app/src/Service/Worker/Request.php +++ b/app/src/Service/Worker/Request.php @@ -5,6 +5,7 @@ use Incoviba\Common\Implement\Exception\EmptyResponse; use Incoviba\Service\Worker; use Psr\Http\Client\ClientExceptionInterface; use Psr\Http\Client\ClientInterface; +use Psr\Http\Message\RequestInterface; use Psr\Log\LoggerInterface; use Incoviba\Common\Ideal; use Incoviba\Model; @@ -16,6 +17,13 @@ class Request extends Ideal\Service implements Worker parent::__construct($logger); } + protected RequestInterface $request; + public function setRequest(RequestInterface $request): self + { + $this->request = $request; + return $this; + } + /** * @param Model\Job $job * @return bool @@ -23,13 +31,16 @@ class Request extends Ideal\Service implements Worker */ public function execute(Model\Job $job): bool { - $url = $job->configuration['url']; - $method = strtolower($job->configuration['method']); + $url = $job->configuration['url'] ?? $job->configuration['action']; + $method = strtolower($job->configuration['method']) ?? 'get'; $body = $job->configuration['body']; try { $response = $this->client->{$method}($url, [ 'json' => $body, + 'headers' => [ + 'Authorization' => $this->request->getHeaderLine('Authorization') + ] ]); } catch (ClientExceptionInterface $exception) { throw new EmptyResponse($url, $exception);