From 2f0e4994e103570807c72ae10fcfda953b302644 Mon Sep 17 00:00:00 2001
From: NathanFlurry <git@nathanflurry.com>
Date: Fri, 31 May 2024 21:44:50 +0000
Subject: [PATCH] fix(user-presence): broken redis query (#802)

<!-- Please make sure there is an issue that this PR is correlated to. -->

## Changes

<!-- If there are frontend changes, please include screenshots. -->
---
 svc/pkg/user-presence/ops/get/src/lib.rs | 20 ++++++++++++--------
 1 file changed, 12 insertions(+), 8 deletions(-)

diff --git a/svc/pkg/user-presence/ops/get/src/lib.rs b/svc/pkg/user-presence/ops/get/src/lib.rs
index 2d6d84c04..e8ddd6bbe 100644
--- a/svc/pkg/user-presence/ops/get/src/lib.rs
+++ b/svc/pkg/user-presence/ops/get/src/lib.rs
@@ -38,15 +38,18 @@ async fn handle(
 			);
 		}
 
-		pipe.query_async::<_, Vec<(
-			Option<String>,
-			Option<String>,
-			Option<String>,
-			Option<String>,
-			Option<String>,
-		)>>(&mut redis)
+		pipe.query_async::<_, Vec<
+			Vec<(
+				Option<String>,
+				Option<String>,
+				Option<String>,
+				Option<String>,
+				Option<String>,
+			)>,
+		>>(&mut redis)
 			.await?
 			.into_iter()
+			.flatten()
 			.map(
 				|(user_id, game_id, message, public_metadata, friend_metadata)| {
 					if user_id.is_none() {
@@ -87,9 +90,10 @@ async fn handle(
 			);
 		}
 
-		pipe.query_async::<_, Vec<(Option<String>, Option<i64>, Option<i64>)>>(&mut redis)
+		pipe.query_async::<_, Vec<Vec<(Option<String>, Option<i64>, Option<i64>)>>>(&mut redis)
 			.await?
 			.into_iter()
+			.flatten()
 			.map(|(user_id, update_ts, status)| {
 				if user_id.is_none() {
 					return GlobalResult::Ok(None);