Add check for failed states

lambdaclass · Dec 11, 2024 · d237792 · d237792
1 parent d6fde33
commit d237792
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/core/node/da_clients/src/eigen/sdk.rs b/core/node/da_clients/src/eigen/sdk.rs
@@ -114,7 +114,9 @@ impl<T: GetBlobData> RawEigenClient<T> {
             .into_inner();
 
         match disperser::BlobStatus::try_from(disperse_reply.result)? {
-            disperser::BlobStatus::Failed => Err(anyhow::anyhow!("Blob dispatch failed")),
+            disperser::BlobStatus::Failed
+            | disperser::BlobStatus::InsufficientSignatures
+            | disperser::BlobStatus::Unknown => Err(anyhow::anyhow!("Blob dispatch failed")),
 
             _ => Ok(hex::encode(disperse_reply.request_id)),
         }
@@ -157,7 +159,9 @@ impl<T: GetBlobData> RawEigenClient<T> {
         };
 
         match disperser::BlobStatus::try_from(disperse_reply.result)? {
-            disperser::BlobStatus::Failed => Err(anyhow::anyhow!("Blob dispatch failed")),
+            disperser::BlobStatus::Failed
+            | disperser::BlobStatus::InsufficientSignatures
+            | disperser::BlobStatus::Unknown => Err(anyhow::anyhow!("Blob dispatch failed")),
 
             _ => Ok(hex::encode(disperse_reply.request_id)),
         }