diff options
| author | physcik <mynameisgennadiy@vk.com> | 2026-04-17 22:20:00 +0500 |
|---|---|---|
| committer | physcik <mynameisgennadiy@vk.com> | 2026-04-17 22:20:00 +0500 |
| commit | c03658c1b5a8dad87f4b11d1b48f2c057ac3a439 (patch) | |
| tree | 5e653b1396e4727f8c00b7b45991f9147b299f4e /backend/src/Redis/Connection.zig | |
| parent | ec8a21afd098f636cd1a3b1cffd62f0a4d98700f (diff) | |
small cleanup
Diffstat (limited to 'backend/src/Redis/Connection.zig')
| -rw-r--r-- | backend/src/Redis/Connection.zig | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/backend/src/Redis/Connection.zig b/backend/src/Redis/Connection.zig index b20903d..83adb2c 100644 --- a/backend/src/Redis/Connection.zig +++ b/backend/src/Redis/Connection.zig @@ -48,3 +48,19 @@ pub fn ReadFromTopic(topic: []const u8, Key: []const u8) ?[]const u8 { } return std.mem.span(resp.str); } + +test "Redis connection" { + try Connect(); + defer Disconnect(); + + try WriteToTopic("test", Message { + .Key = "key", + .Value = "value", + .SecondsToLive = 1, + }); + + try std.testing.expectEqualStrings("value", ReadFromTopic("test", "key") orelse "not found"); + std.Thread.sleep(1_500_000_000); + // KVP TTL check + try std.testing.expectEqualStrings("not found", ReadFromTopic("test", "key") orelse "not found"); +} |
