fix

geph-official · Jan 9, 2025 · cff19d4 · cff19d4
1 parent 4a82628
commit cff19d4
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 5 deletions.
diff --git a/binaries/geph5-broker/src/rpc_impl.rs b/binaries/geph5-broker/src/rpc_impl.rs
@@ -272,11 +272,8 @@ impl BrokerProtocol for BrokerImpl {
         )
         .await
         {
-            match route {
-                Ok(route) => routes.push(route),
-                Err(err) => {
-                    tracing::warn!(err = debug(err), "could not communicate")
-                }
+            if let Ok(route) = route {
+                routes.push(route)
             }
         }
 

diff --git a/binaries/geph5-broker/src/self_stat.rs b/binaries/geph5-broker/src/self_stat.rs
@@ -42,6 +42,12 @@ pub async fn self_stat_loop() -> anyhow::Result<()> {
             .fetch_one(&*POSTGRES)
             .await?;
             client.gauge("broker.daily_logins", daily_logins as f64)?;
+            let (weekly_logins,): (i64,) = sqlx::query_as(
+                "select count(id) from last_login where login_time > NOW() - INTERVAL '7 days'",
+            )
+            .fetch_one(&*POSTGRES)
+            .await?;
+            client.gauge("broker.weekly_logins", weekly_logins as f64)?;
         }
         async_io::Timer::after(Duration::from_secs(5)).await;
     }