WIP

Author: cicnavi

src/Federation/EntityCollection/CacheEntityCollectionStore.php

@@ -11,7 +11,9 @@
 
 class CacheEntityCollectionStore implements EntityCollectionStoreInterface
 {
-    protected const PREFIX = 'federation_entities';
+    protected const KEY_FEDERATED_ENTITIES = 'federation_entities';
+
+    protected const KEY_LAST_UPDATED = 'last_updated';
 
 
     public function __construct(
@@ -22,13 +24,16 @@ public function __construct(
     }
 
 
+    /**
+     * @inheritDoc
+     */
     public function store(string $trustAnchorId, array $entities, int $ttl): void
     {
         try {
             $this->cacheDecorator->set(
                 $this->helpers->json()->encode($entities),
                 $ttl,
-                self::PREFIX,
+                self::KEY_FEDERATED_ENTITIES,
                 $trustAnchorId,
             );
         } catch (Throwable $throwable) {
@@ -41,11 +46,14 @@ public function store(string $trustAnchorId, array $entities, int $ttl): void
     }
 
 
+    /**
+     * @inheritDoc
+     */
     public function get(string $trustAnchorId): ?array
     {
         try {
             /** @var ?string $cached */
-            $cached = $this->cacheDecorator->get(null, self::PREFIX, $trustAnchorId);
+            $cached = $this->cacheDecorator->get(null, self::KEY_FEDERATED_ENTITIES, $trustAnchorId);
 
             if (is_null($cached)) {
                 return null;
@@ -69,15 +77,79 @@ public function get(string $trustAnchorId): ?array
     }
 
 
+    /**
+     * @inheritDoc
+     */
     public function clear(string $trustAnchorId): void
     {
         try {
-            $this->cacheDecorator->delete(self::PREFIX, $trustAnchorId);
+            $this->cacheDecorator->delete(self::KEY_FEDERATED_ENTITIES, $trustAnchorId);
         } catch (Throwable $throwable) {
             $this->logger?->error('Unable to clear entities from cache.', [
                 'trustAnchorId' => $trustAnchorId,
                 'exception_message' => $throwable->getMessage(),
             ]);
         }
     }
+
+
+    /**
+     * @inheritDoc
+     */
+    public function storeLastUpdated(string $trustAnchorId, int $timestamp, int $ttl): void
+    {
+        try {
+            $this->cacheDecorator->set(
+                (string)$timestamp,
+                $ttl,
+                self::KEY_LAST_UPDATED,
+                $trustAnchorId,
+            );
+        } catch (Throwable $throwable) {
+            $this->logger?->error('Unable to store last updated timestamp in cache.', [
+                'trustAnchorId' => $trustAnchorId,
+                'timestamp' => $timestamp,
+                'exception_message' => $throwable->getMessage(),
+            ]);
+        }
+    }
+
+
+    /**
+     * @inheritDoc
+     */
+    public function getLastUpdated(string $trustAnchorId): ?int
+    {
+        try {
+            $lastUpdated = $this->cacheDecorator->get(null, self::KEY_LAST_UPDATED, $trustAnchorId);
+        } catch (Throwable $throwable) {
+            $this->logger?->error('Unable to retrieve last updated timestamp from cache.', [
+                'trustAnchorId' => $trustAnchorId,
+                'exception_message' => $throwable->getMessage(),
+            ]);
+            return null;
+        }
+
+        if (is_int($lastUpdated)) {
+            return $lastUpdated;
+        }
+
+        return null;
+    }
+
+
+    /**
+     * @inheritDoc
+     */
+    public function clearLastUpdated(string $trustAnchorId): void
+    {
+        try {
+            $this->cacheDecorator->delete(self::KEY_LAST_UPDATED, $trustAnchorId);
+        } catch (Throwable $throwable) {
+            $this->logger?->error('Unable to clear last updated timestamp from cache.', [
+                'trustAnchorId' => $trustAnchorId,
+                'exception_message' => $throwable->getMessage(),
+            ]);
+        }
+    }
 }

src/Federation/EntityCollection/EntityCollectionStoreInterface.php

@@ -30,4 +30,25 @@ public function get(string $trustAnchorId): ?array;
      * @param non-empty-string $trustAnchorId
      */
     public function clear(string $trustAnchorId): void;
+
+
+    /**
+     * Set the last update timestamp for a given trust anchor.
+     *
+     * @param non-empty-string $trustAnchorId
+     */
+    public function storeLastUpdated(string $trustAnchorId, int $timestamp, int $ttl): void;
+
+
+    /**
+     * Get the last update timestamp for a given trust anchor.
+     * @param non-empty-string $trustAnchorId
+     */
+    public function getLastUpdated(string $trustAnchorId): ?int;
+
+
+    /**
+     * Clear the last update timestamp for a given trust anchor.
+     */
+    public function clearLastUpdated(string $trustAnchorId): void;
 }

src/Federation/EntityCollection/InMemoryEntityCollectionStore.php

@@ -7,7 +7,10 @@
 class InMemoryEntityCollectionStore implements EntityCollectionStoreInterface
 {
     /** @var array<string, array{entities: array<string, array<string, mixed>>, expires: int}> */
-    private array $store = [];
+    protected array $store = [];
+
+    /** @var array<string, int> */
+    protected array $lastUpdatedStore = [];
 
 
     public function store(string $trustAnchorId, array $entities, int $ttl): void
@@ -38,4 +41,22 @@ public function clear(string $trustAnchorId): void
     {
         unset($this->store[$trustAnchorId]);
     }
+
+
+    public function storeLastUpdated(string $trustAnchorId, int $timestamp, int $ttl): void
+    {
+        $this->lastUpdatedStore[$trustAnchorId] = $timestamp;
+    }
+
+
+    public function getLastUpdated(string $trustAnchorId): ?int
+    {
+        return $this->lastUpdatedStore[$trustAnchorId] ?? null;
+    }
+
+
+    public function clearLastUpdated(string $trustAnchorId): void
+    {
+        unset($this->lastUpdatedStore[$trustAnchorId]);
+    }
 }