fix: fixed handling of new beacons

sparse-beacon/src/lib.rs

@@ -66,8 +66,6 @@ where
     let mut config: messages::BeaconConfig = {
         let client = callback::obtain_https_client(&host_adapter, &params).await?;
 
-        dbg!(&params.beacon_identifier);
-
         make_request(
             &client,
             format!("https://{}/checkin", params::domain_name::<A>(&params)?).parse()?,

sparse-handler/src/router.rs

@@ -94,15 +94,18 @@ pub async fn handle_checkin(
                 .fetch_optional(&state.db)
                 .await?;
 
-            if let Some(category_id) = template_category.map(|r| r.default_category) {
-                sqlx::query!(
+            if let Some(category_id) = template_category.map(|r| r.default_category).flatten() {
+                if let Err(e) = sqlx::query!(
                     "INSERT INTO beacon_category_assignment (category_id, beacon_id)
                     VALUES (?, ?)",
                     category_id,
                     reg.beacon_id
                 )
                     .execute(&state.db)
-                    .await?;
+                    .await {
+                    tracing::warn!("Could not assign beacon to default category: {e:?}");
+                    return Err(e.into());
+                };
             }
 
             sqlx::query!(
@@ -138,6 +141,7 @@ pub async fn handle_checkin(
         }
     };
 
+        tracing::debug!("Here 5");
     let now = chrono::Utc::now();
     sqlx::query!(
         r"INSERT INTO beacon_checkin (beacon_id, checkin_date) VALUES (?, ?)"r,

sparse-server/src/webserver.rs

@@ -469,7 +469,8 @@ async fn handle_listener_events(
                     category_ids: category_ids.iter().map(|r| r.category_id).collect()
                 };
 
-                socket.send(ws::Message::Text(serde_json::to_string(&beacon)?)).await?;
+                let json = serde_json::to_string(&SidebarEvents::NewBeacon(beacon))?;
+                socket.send(ws::Message::Text(json)).await?;
             }
             Err(e) => {
                 tracing::warn!("Unable to handle general event: {e:?}");