diff --git a/composer.json b/composer.json index 32e809b..66c05a6 100644 --- a/composer.json +++ b/composer.json @@ -3,15 +3,15 @@ "description": "Data enrichment library based on DataEnrichmentKit. A suitable components for micro services written using laravel framework.", "type": "library", "license": "MIT", - "version": "1.0.0", + "version": "1.0.1", "keywords": [ "laravel", "data enrichment", "facade", "psr7", "http", - "pipeline", "message processing", "middleware", "microservice" + "pipeline", "message processing", "middleware", "microservice", + "data processing", "data transformation" ], "autoload": { "psr-4": { - "Diffhead\\PHP\\LaravelDataEnrichment\\": "src/", - "Diffhead\\PHP\\LaravelDataEnrichment\\Tests\\": "tests/" + "Diffhead\\PHP\\LaravelDataEnrichment\\": "src/" } }, "extra": { diff --git a/src/Manager/HttpManager.php b/src/Manager/HttpManager.php index cc36317..cc874ae 100644 --- a/src/Manager/HttpManager.php +++ b/src/Manager/HttpManager.php @@ -37,9 +37,13 @@ class HttpManager extends AbstractManager public function enrichMessage(MessageInterface $message): MessageInterface { $requests = $this->message->getRequests($message, $this->requestsHeader); - $payload = $this->message->getPayload($message); - $enriched = $this->enricher->enrich($payload, $requests); - return $this->message->setPayload($message, $enriched); + if ($requests->count()) { + $payload = $this->message->getPayload($message); + $enriched = $this->enricher->enrich($payload, $requests); + $message = $this->message->setPayload($message, $enriched); + } + + return $message; } }