PHP/LaravelDataEnrichment
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- Version 1.0.1

Browse Source 
* Dont enrich if requests is empty
This commit is contained in:
Viktor Smagin
2025-11-27 18:19:26 +04:00
parent 3f19a38412
commit 267fe7433f
2 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
composer.json
View File

@@ -3,15 +3,15 @@
"description": "Data enrichment library based on DataEnrichmentKit. A suitable components for micro services written using laravel framework.", "description": "Data enrichment library based on DataEnrichmentKit. A suitable components for micro services written using laravel framework.",
"type": "library", "type": "library",
"license": "MIT", "license": "MIT",
"version": "1.0.0", "version": "1.0.1",
"keywords": [ "keywords": [
"laravel", "data enrichment", "facade", "psr7", "http", "laravel", "data enrichment", "facade", "psr7", "http",
"pipeline", "message processing", "middleware", "microservice" "pipeline", "message processing", "middleware", "microservice",
"data processing", "data transformation"
], ],
"autoload": { "autoload": {
"psr-4": { "psr-4": {
"Diffhead\\PHP\\LaravelDataEnrichment\\": "src/", "Diffhead\\PHP\\LaravelDataEnrichment\\": "src/"
"Diffhead\\PHP\\LaravelDataEnrichment\\Tests\\": "tests/"
} }
}, },
"extra": { "extra": {

6
src/Manager/HttpManager.php
View File

@@ -37,9 +37,13 @@ class HttpManager extends AbstractManager
public function enrichMessage(MessageInterface $message): MessageInterface public function enrichMessage(MessageInterface $message): MessageInterface
{ {
$requests = $this->message->getRequests($message, $this->requestsHeader); $requests = $this->message->getRequests($message, $this->requestsHeader);
if ($requests->count()) {
$payload = $this->message->getPayload($message); $payload = $this->message->getPayload($message);
$enriched = $this->enricher->enrich($payload, $requests); $enriched = $this->enricher->enrich($payload, $requests);
$message = $this->message->setPayload($message, $enriched);
}
return $this->message->setPayload($message, $enriched); return $message;
} }
} }