fix(pegboard): fix migrations (#1230)

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

## Changes

<!-- If there are frontend changes, please include screenshots. -->

lib/migrate/src/migrate.rs

@@ -157,18 +157,20 @@ pub async fn up(services: &[SqlService]) -> Result<()> {
 	tokio::try_join!(
 		async {
 			if !crdb_pre_queries.is_empty() {
+				let mut conn = crdb.acquire().await.context("can't acquire crdb")?;
+
 				for query in crdb_pre_queries {
-					let mut conn = crdb.acquire().await?;
-					conn.execute(query.as_str()).await?;
+					conn.execute(query.as_str()).await.with_context(|| format!("failed executing crdb pre-migration:\n{query}"))?;
 				}
 			}
 			Ok(())
 		},
 		async {
 			if !clickhouse_pre_queries.is_empty() {
 				let clickhouse = clickhouse.as_ref().context("missing clickhouse")?;
+
 				for query in clickhouse_pre_queries {
-					clickhouse.query(&query).execute().await?;
+					clickhouse.query(&query).execute().await.with_context(|| format!("failed executing clickhouse pre-migration:\n{query}"))?;
 				}
 			}
 

svc/pkg/pegboard/src/protocol.rs

@@ -34,6 +34,7 @@ impl ToClient {
 
 #[signal("pegboard_forward_to_server")]
 #[serde(rename_all = "snake_case")]
+#[derive(Debug)]
 pub enum ToServer {
 	Init {
 		last_command_idx: i64,

svc/pkg/pegboard/standalone/ws/src/lib.rs

@@ -184,7 +184,7 @@ async fn handle_connection_inner(
 			Message::Close(_) => {
 				bail!("socket closed {client_id}");
 			}
-			_ => bail!("unexpected initial message: {msg:?}"),
+			msg => bail!("unexpected initial message: {msg:?}"),
 		}
 	}
 
@@ -207,9 +207,7 @@ async fn handle_connection_inner(
 			Message::Close(_) => {
 				bail!("socket closed {client_id}");
 			}
-			msg => {
-				tracing::warn!(?client_id, ?msg, "unexpected message");
-			}
+			msg => tracing::warn!(?client_id, ?msg, "unexpected message"),
 		}
 	}