feat(server): Add FinalOdb websocket request

CHANGELOG.md

@@ -19,6 +19,7 @@ changes will be documented in this file.
  there are both `*.mid` and `*.mid.lz4` files in the data directory. The
  default pattern will match any `runXXXXXsubYYY.mid*` file. To, for example,
  match only `*.mid` files, add a `$` anchor to the end of the default pattern.
+- New websocket message to request the final ODB.
 
 ## [0.1.1] - 2024-08-24
 

src/communication.rs

@@ -28,6 +28,9 @@ pub enum ClientRequest {
  InitialOdb {
  run_number: u32,
  },
+ FinalOdb {
+ run_number: u32,
+ },
  SpillLog {
  run_number: u32,
  },
@@ -92,6 +95,9 @@ pub async fn handle_client_message(
  ClientRequest::InitialOdb { .. } => {
  handle_initial_odb(msg, tx, app_state).await;
  }
+ ClientRequest::FinalOdb { .. } => {
+ handle_final_odb(msg, tx, app_state).await;
+ }
  ClientRequest::SpillLog { .. } => {
  handle_spill_log(msg, tx, app_state).await;
  }
@@ -307,6 +313,24 @@ async fn handle_initial_odb(
  send_download_jwt(&msg.service, &msg.context, &tx, output);
 }
 
+async fn handle_final_odb(
+ msg: ClientMessage,
+ tx: mpsc::UnboundedSender<ServerMessage>,
+ app_state: Arc<AppState>,
+) {
+ let ClientRequest::FinalOdb { run_number } = msg.request else {
+ unreachable!();
+ };
+ let cmd = CoreCmd {
+ bin: CoreBin::FinalOdb,
+ run_number,
+ };
+ let Ok(output) = run_core_command(&msg.service, &msg.context, cmd, &tx, app_state).await else {
+ return;
+ };
+ send_download_jwt(&msg.service, &msg.context, &tx, output);
+}
+
 async fn handle_spill_log(
  msg: ClientMessage,
  tx: mpsc::UnboundedSender<ServerMessage>,