Update APIs

Signed-off-by: Xuanwo <[email protected]>

src/storage/drivers/local.rs

@@ -11,17 +11,13 @@ use crate::storage::{drivers::opendal_adapter::OpendalAdapter, StorageResult};
 /// let file_system_driver = local::new();
 /// ```
 ///
-/// # Panics
+/// # Errors
 ///
-/// Panics if the filesystem service built failed.
-#[must_use]
-pub fn new() -> Box<dyn StoreDriver> {
+/// Errors if the filesystem service built failed.
+pub fn new() -> StorageResult<Box<dyn StoreDriver>> {
     let fs = Fs::default().root("/");
-    Box::new(OpendalAdapter::new(
-        Operator::new(fs)
-            .expect("fs service should build with success")
-            .finish(),
-    ))
+    let store = Box::new(OpendalAdapter::new(Operator::new(fs)?.finish()));
+    Ok(store)
 }
 
 /// Create new filesystem storage with `prefix` applied to all paths

src/storage/drivers/mem.rs

@@ -2,6 +2,7 @@ use opendal::{services::Memory, Operator};
 
 use super::StoreDriver;
 use crate::storage::drivers::opendal_adapter::OpendalAdapter;
+use crate::storage::StorageResult;
 
 /// Create new in-memory storage.
 ///
@@ -11,14 +12,12 @@ use crate::storage::drivers::opendal_adapter::OpendalAdapter;
 /// let mem_storage = mem::new();
 /// ```
 ///
-/// # Panics
+/// # Errors
 ///
-/// Panics if the memory service built failed.
-#[must_use]
-pub fn new() -> Box<dyn StoreDriver> {
-    Box::new(OpendalAdapter::new(
-        Operator::new(Memory::default())
-            .expect("memory service must build with success")
-            .finish(),
-    ))
+/// Errors if the memory service built failed.
+pub fn new() -> StorageResult<Box<dyn StoreDriver>> {
+    let store = Box::new(OpendalAdapter::new(
+        Operator::new(Memory::default())?.finish(),
+    ));
+    Ok(store)
 }

src/storage/mod.rs

@@ -56,7 +56,7 @@ impl Storage {
     ///```
     /// use loco_rs::storage;
     ///
-    /// let storage = storage::Storage::single(storage::drivers::mem::new());
+    /// let storage = storage::Storage::single(storage::drivers::mem::new().unwrap());
     /// ```
     #[must_use]
     pub fn single(store: Box<dyn StoreDriver>) -> Self {
@@ -86,7 +86,7 @@ impl Storage {
     /// use std::path::Path;
     /// use bytes::Bytes;
     /// pub async fn upload() {
-    ///     let storage = storage::Storage::single(storage::drivers::mem::new());
+    ///     let storage = storage::Storage::single(storage::drivers::mem::new().unwrap());
     ///     let path = Path::new("example.txt");
     ///     let content = "Loco!";
     ///     let result = storage.upload(path, &Bytes::from(content)).await;

src/tests_cfg/app.rs

@@ -6,6 +6,11 @@ use crate::{
     tests_cfg::config::test_config,
 };
 
+/// Create a new `AppContext` for testing purposes.
+///
+/// # Panics
+///
+/// Panics if the storage drivers failed to initiate.
 pub async fn get_app_context() -> AppContext {
     AppContext {
         environment: Environment::Test,
@@ -14,7 +19,7 @@ pub async fn get_app_context() -> AppContext {
         queue_provider: None,
         config: test_config(),
         mailer: None,
-        storage: Storage::single(storage::drivers::mem::new()).into(),
+        storage: Storage::single(storage::drivers::mem::new().unwrap()).into(),
         #[cfg(feature = "cache_inmem")]
         cache: cache::Cache::new(cache::drivers::inmem::new()).into(),
         #[cfg(not(feature = "cache_inmem"))]