Skip to content

Commit 3d549da

Browse files
committed
Retain the taint status cross queue.
1 parent ad8b0b9 commit 3d549da

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

src/API/Backend/Webhooks.php

+1
Original file line numberDiff line numberDiff line change
@@ -199,6 +199,7 @@ private function process(string $name, iRequest $request): iResponse
199199
'unique' => true,
200200
EventsTable::COLUMN_REFERENCE => $itemId,
201201
EventsTable::COLUMN_OPTIONS => [
202+
'tainted' => $entity->isTainted(),
202203
Options::IMPORT_METADATA_ONLY => $metadataOnly,
203204
Options::REQUEST_ID => ag($request->getServerParams(), 'X_REQUEST_ID'),
204205
],

src/Listeners/ProcessRequestEvent.php

+2-1
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,8 @@ public function __invoke(DataEvent $e): DataEvent
3535
{
3636
$e->stopPropagation();
3737

38-
$entity = Container::get(iState::class)::fromArray($e->getData());
38+
$entity = Container::get(iState::class)::fromArray($e->getData())
39+
->setIsTainted((bool)ag($e->getOptions(), 'tainted', false));
3940

4041
if (null !== ($lastSync = ag(Config::get("servers.{$entity->via}", []), 'import.lastSync'))) {
4142
$lastSync = makeDate($lastSync);

0 commit comments

Comments
 (0)