feat(application): export_diary::execute returns BoxStream<Bytes>

crates/application/Cargo.toml

@@ -15,6 +15,7 @@ sha2 = { workspace = true }
 rand = { workspace = true }
 hex = { workspace = true }
 serde_json = { workspace = true }
+bytes = { workspace = true }
 
 [features]
 xlsx = []

crates/application/src/diary/export_diary.rs

@@ -1,22 +1,21 @@
 use std::sync::Arc;
 
+use bytes::Bytes;
 use domain::{
     errors::DomainError,
     ports::{DiaryExporter, DiaryRepository},
     value_objects::UserId,
 };
+use futures::stream::BoxStream;
 
 use crate::diary::queries::ExportQuery;
 
-pub async fn execute(
+pub fn execute(
     diary: &Arc<dyn DiaryRepository>,
     diary_exporter: &Arc<dyn DiaryExporter>,
     query: ExportQuery,
-) -> Result<Vec<u8>, DomainError> {
+) -> BoxStream<'static, Result<Bytes, DomainError>> {
-    let entries = diary
+    let user_id = UserId::from_uuid(query.user_id);
-        .get_user_history(&UserId::from_uuid(query.user_id))
+    let entry_stream = diary.stream_user_history(user_id);
-        .await?;
+    diary_exporter.stream_entries(entry_stream, query.format)
-    diary_exporter
-        .serialize_entries(&entries, query.format)
-        .await
 }