change how celestia blob are fetch to test

protocol-units/da/movement/protocol/da/src/lib.rs

@@ -107,7 +107,6 @@ pub trait DaOperations: Send + Sync {
 		&self,
 		start_height: u64,
 	) -> Pin<Box<dyn Future<Output = Result<DaBlobStream, DaError>> + Send + '_>> {
-		tracing::info!("TEST Da lib DaOperations stream_da_blobs_from_height start");
 		let fut = async move {
 			let certificate_stream = self.stream_certificates().await?;
 			let stream = try_stream! {
@@ -120,13 +119,12 @@ pub trait DaOperations: Send + Sync {
 
 					match certificate {
 						Ok(Certificate::Height(height)) if height > last_height => {
-							let blob_stream = self
-								.stream_da_blobs_between_heights(last_height, height)
-								.await?;
-							tokio::pin!(blob_stream);
-
-							while let Some(blob) = blob_stream.next().await {
-								yield blob?;
+							for height in last_height..height {
+								info!("getting certified blobs at height {}", height);
+								let blobs = self.get_da_blobs_at_height_for_stream(height).await?;
+								for blob in blobs {
+									yield (DaHeight(height), blob);
+								}
 							}
 
 							last_height = height;