summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/database.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/database.rs b/src/database.rs
index a5204a1..7b548de 100644
--- a/src/database.rs
+++ b/src/database.rs
@@ -156,9 +156,9 @@ pub async fn match_users(lobby: String, names: &[&str]) -> Result<String, Error>
JOIN suser USING (user_id)
JOIN track USING (track_id)
JOIN lobby USING (lobby_id)
- WHERE suser.user_name IN (SELECT user_name FROM users) AND token = $1
+ WHERE suser.user_name IN (SELECT * FROM users) AND token = $1
GROUP BY track_id
- ---HAVING COUNT(track_id) = (SELECT COUNT(*) FROM users)
+ HAVING COUNT(track_id) = (SELECT COUNT(*) FROM users)
ORDER BY SUM(score) DESC
) AS _ USING (track_id)
;
@@ -172,7 +172,7 @@ pub async fn match_users(lobby: String, names: &[&str]) -> Result<String, Error>
use futures::{pin_mut, TryStreamExt};
let mut it = client.query_raw(query.as_str(), values).await?;
pin_mut!(it);
- for row in it.try_next().await? {
+ while let Some(row) = it.try_next().await? {
let name: String = row.get(1);
let artist: String = row.get(2);
songs = format!("{}{} by {}\n", songs, name, artist);