2 files changed, 25 insertions, 19 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");
+}
diff --git a/backend/src/main.zig b/backend/src/main.zig
index 9c4351f..6f9b21b 100644
--- a/backend/src/main.zig
+++ b/backend/src/main.zig
@@ -8,6 +8,13 @@ const redis = @import("Redis/Connection.zig");
 pub fn main() !void {
     var gpa = std.heap.GeneralPurposeAllocator(.{}){};
     const allocator = gpa.allocator();
+   
+    // PSQL connection
+    try db.Connect(allocator);
+    defer db.Disconnect();
+
+    try redis.Connect();
+    defer redis.Disconnect();
 
     var httpHandler = handler.Handler {
     };
@@ -20,30 +27,12 @@ pub fn main() !void {
         server.stop();
         server.deinit();
     }
-
-    try redis.Connect();
-    defer redis.Disconnect();
-
-    try redis.WriteToTopic("test", redis.Message {
-        .Key = "xdd",
-        .Value = "ddx",
-        .SecondsToLive = 10,
-    });
-
-    std.debug.print("redis response: {s}\n", .{redis.ReadFromTopic("test", "xdd") orelse "not found"});
-
+   
     var router = try server.router(.{});
     router.get("/", index, .{});
 
     @import("API/WeaponsAPI.zig").RegisterEndpoints(router);
     @import("API/AuthenticationAPI.zig").RegisterEndpoints(router);
-    
-    // PSQL connection
-    try db.Connect(allocator);
-    defer db.Disconnect();
-
-    var outp = try db.RangedWeapons.GetAll(allocator);
-    outp.deinit(allocator);
 
     try server.listen();
 }
@@ -57,4 +46,5 @@ test "TestRunner" {
     _ = @import("Models/RangedWeapon.zig");
     _ = @import("Models/User.zig");
     _ = @import("Authentication/Password.zig");
+    _ = redis;
 }