diff --git a/cloud/src/Repository/AuditRepository.php b/cloud/src/Repository/AuditRepository.php new file mode 100644 index 0000000..5f3a18a --- /dev/null +++ b/cloud/src/Repository/AuditRepository.php @@ -0,0 +1,8 @@ +assertFalse($r->seen('n1')); + $r->remember('n1', 999); + $this->assertTrue($r->seen('n1')); + } + public function testEventInsertAndRecent(): void + { + $r = new InMemoryEventRepository(); + $id = $r->insert(['severity' => 'high', 'event_type' => 'fall']); + $this->assertSame(1, $id); + $this->assertCount(1, $r->recent(10, null)); + $this->assertCount(0, $r->recent(10, 'critical')); + } + public function testRateLimiterIncrements(): void + { + $r = new InMemoryRateLimiter(); + $this->assertSame(1, $r->hit('dev', 100)); + $this->assertSame(2, $r->hit('dev', 100)); + $this->assertSame(1, $r->hit('dev', 160)); + } +} diff --git a/cloud/tests/Support/InMemoryRepositories.php b/cloud/tests/Support/InMemoryRepositories.php new file mode 100644 index 0000000..669e16d --- /dev/null +++ b/cloud/tests/Support/InMemoryRepositories.php @@ -0,0 +1,61 @@ +secrets[$d] ?? null; } + public function touchHeartbeat(string $d, array $m): void { $this->heartbeats[$d] = $m; } + public function configVersion(string $d): int { return $this->versions[$d] ?? 1; } +} +final class InMemoryNonceRepository implements NonceRepository { + public array $store = []; + public function seen(string $n): bool { return isset($this->store[$n]); } + public function remember(string $n, int $exp): void { $this->store[$n] = $exp; } +} +final class InMemoryRateLimiter implements RateLimiterRepository { + public array $counts = []; + public function hit(string $k, int $w): int { $key = "$k:$w"; return $this->counts[$key] = ($this->counts[$key] ?? 0) + 1; } +} +final class InMemoryEventRepository implements EventRepository { + public array $rows = []; private int $seq = 0; + public function insert(array $e): int { $id = ++$this->seq; $this->rows[$id] = $e + ['event_id' => $id, 'acknowledged_by' => null]; return $id; } + public function recent(int $limit, ?string $sev): array { + $r = array_reverse($this->rows, true); + if ($sev !== null) $r = array_filter($r, fn($x) => $x['severity'] === $sev); + return array_slice(array_values($r), 0, $limit); + } + public function find(int $id): ?array { return $this->rows[$id] ?? null; } + public function acknowledge(int $id, string $u): bool { if (!isset($this->rows[$id])) return false; $this->rows[$id]['acknowledged_by'] = $u; return true; } +} +final class InMemorySnapshotRepository implements SnapshotRepository { + public array $rows = []; public array $paths = []; + public function add(int $e, string $uuid, string $hash): void { $this->rows[$e][] = ['file_uuid' => $uuid, 'content_hash' => $hash]; $this->paths[$uuid] = "/tmp/$uuid.jpg"; } + public function forEvent(int $e): array { return $this->rows[$e] ?? []; } + public function pathByUuid(string $u): ?string { return $this->paths[$u] ?? null; } +} +final class InMemoryUserRepository implements UserRepository { + public function __construct(public array $users = []) {} + public function byUsername(string $u): ?array { return $this->users[$u] ?? null; } + public function recordFailure(int $id, int $lock): void { foreach ($this->users as &$row) if ($row['id'] === $id) { $row['failed_attempts'] = ($row['failed_attempts'] ?? 0) + 1; $row['locked_until'] = $lock; } } + public function clearFailures(int $id): void { foreach ($this->users as &$row) if ($row['id'] === $id) { $row['failed_attempts'] = 0; $row['locked_until'] = 0; } } +} +final class InMemoryZoneRepository implements ZoneRepository { + public array $zones = []; private int $seq = 0; + public function forDevice(string $d): array { return array_values(array_filter($this->zones, fn($z) => ($z['device_id'] ?? '') === $d)); } + public function forCamera(string $c): array { return array_values(array_filter($this->zones, fn($z) => $z['camera_id'] === $c)); } + public function save(array $z): string { $id = $z['zone_id'] ?? ('z' . (++$this->seq)); $this->zones[$id] = $z + ['zone_id' => $id]; return $id; } + public function delete(string $id): bool { if (!isset($this->zones[$id])) return false; unset($this->zones[$id]); return true; } +} +final class InMemoryThresholdRepository implements ThresholdRepository { + public function __construct(private array $data = []) {} + public function forDevice(string $d): array { return $this->data[$d] ?? []; } +} +final class InMemoryAuditRepository implements AuditRepository { + public array $log = []; + public function append(string $a, string $act, string $t, array $b, array $af): void { $this->log[] = compact('a', 'act', 't', 'b', 'af'); } +}