fix: use ceramic url

3box · Feb 6, 2024 · 7b1bcce · 7b1bcce
1 parent b4b6292
commit 7b1bcce
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/checkpointer/src/batcher.rs b/checkpointer/src/batcher.rs
@@ -48,7 +48,7 @@ pub struct Batcher {
 
 impl Batcher {
     pub fn new() -> Result<Self, Error> {
-        let u = std::env::var("CERAMIC_URL")?;
+        let u = std::env::var("CERAMIC_URL").expect("CERAMIC_URL not set in environment");
         let u = Url::parse(&u)?;
         let u = u.join("/api/v0/feed/aggregation/documents")?;
         Ok(Self::new_with_url(u))
@@ -251,7 +251,7 @@ mod tests {
         });
         JwkSigner::new(
             DidDocument::new(&s),
-            &std::env::var("DID_PRIVATE_KEY").unwrap(),
+            &std::env::var("DID_PRIVATE_KEY").expect("DID_PRIVATE_KEY not set in environment"),
         )
         .await
         .unwrap()
@@ -266,7 +266,8 @@ mod tests {
     async fn should_receive_create_and_update_events() {
         let _ = util::init_tracing();
 
-        let batcher = Batcher::new().unwrap();
+        let ceramic_url = ceramic_url();
+        let batcher = Batcher::new_with_url(ceramic_url.clone()).unwrap();
         let client_id = "test";
         batcher
             .create_batcher(BatchCreationParameters {
@@ -275,7 +276,7 @@ mod tests {
             .await
             .unwrap();
 
-        let ceramic = remote::CeramicRemoteHttpClient::new(signer().await, ceramic_url());
+        let ceramic = remote::CeramicRemoteHttpClient::new(signer().await, ceramic_url);
         let model = create_model(&ceramic).await;
         let stream_id = ceramic
             .create_list_instance(