fix: purge project cache after updates

This commit is contained in:
Jake Barnby
2026-05-26 19:46:13 +12:00
parent 76411aeca8
commit afb956a18c
21 changed files with 24 additions and 1 deletions
@@ -82,6 +82,7 @@ class Update extends Action
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), new Document([
'auths' => $auths,
])));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents->setParam('methodId', $methodId);
@@ -71,6 +71,7 @@ class Update extends Action
$labels = (array) \array_values(\array_unique($labels));
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), new Document(['labels' => $labels])));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$response->dynamic($project, Response::MODEL_PROJECT);
}
@@ -101,6 +101,7 @@ class Create extends Action
]);
$authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents->setParam('number', $number);
@@ -95,6 +95,7 @@ class Delete extends Action
]);
$authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents->setParam('number', $number);
@@ -97,6 +97,7 @@ class Update extends Action
]);
$authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents->setParam('number', $number);
@@ -425,7 +425,10 @@ abstract class Base extends Action
'oAuthProviders' => $oAuthProviders
]);
return $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
return $project;
}
public function action(
@@ -98,6 +98,7 @@ class Update extends Action
]);
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents
->setParam('projectId', $project->getId())
@@ -75,6 +75,7 @@ class Update extends Action
]);
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents
->setParam('projectId', $project->getId())
@@ -83,6 +83,7 @@ class Update extends Action
]);
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents
->setParam('projectId', $project->getId())
@@ -76,6 +76,7 @@ class Update extends Action
]);
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents
->setParam('projectId', $project->getId())
@@ -75,6 +75,7 @@ class Update extends Action
]);
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents
->setParam('projectId', $project->getId())
@@ -75,6 +75,7 @@ class Update extends Action
]);
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents
->setParam('projectId', $project->getId())
@@ -75,6 +75,7 @@ class Update extends Action
]);
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents
->setParam('projectId', $project->getId())
@@ -81,6 +81,7 @@ class Update extends Action
]);
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents
->setParam('projectId', $project->getId())
@@ -81,6 +81,7 @@ class Update extends Action
]);
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents
->setParam('projectId', $project->getId())
@@ -79,6 +79,7 @@ class Update extends Action
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), new Document([
'apis' => $protocols,
])));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents->setParam('protocolId', $protocolId);
@@ -169,6 +169,7 @@ class Update extends Action
]);
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$response->dynamic($project, Response::MODEL_PROJECT);
}
@@ -79,6 +79,7 @@ class Update extends Action
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), new Document([
'services' => $services,
])));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents->setParam('serviceId', $serviceId);
@@ -129,6 +129,7 @@ class Update extends Action
]);
$project = $authorization->skip(fn () => $dbForPlatform->updateDocument('projects', $project->getId(), $updates));
$authorization->skip(fn () => $dbForPlatform->purgeCachedDocument('projects', $project->getId()));
$queueForEvents->setParam('templateId', $templateId);
@@ -78,6 +78,7 @@ class Update extends Action
'teamInternalId' => $team->getSequence(),
'$permissions' => $permissions,
]));
$dbForPlatform->purgeCachedDocument('projects', $project->getId());
$installations = $dbForPlatform->find('installations', [
Query::equal('projectInternalId', [$project->getSequence()]),
@@ -72,6 +72,7 @@ class Update extends Action
->setAttribute('legalAddress', $legalAddress)
->setAttribute('legalTaxId', $legalTaxId)
->setAttribute('search', implode(' ', [$projectId, $name])));
$dbForPlatform->purgeCachedDocument('projects', $project->getId());
$response->dynamic($project, Response::MODEL_PROJECT);
}