chore: Upgrade SDK to 0.4.0

Signed-off-by: Vaibhav Rabber <[email protected]>

Cargo.toml

@@ -28,7 +28,7 @@ miette = { version = "7.2.0", features = ["fancy"] }
 rand = "0.8.5"
 serde = { version = "1.0.214", features = ["derive"] }
 serde_json = "1.0.132"
-streamstore = "0.3.1"
+streamstore = "0.4.0"
 thiserror = "2.0.6"
 tokio = { version = "1.41.1", features = ["full"] }
 tokio-stream = { version = "0.1.16", features = ["io-util"] }

src/account.rs

@@ -50,8 +50,11 @@ impl AccountService {
             stream_config = stream_config.with_retention_policy(retention_policy.into());
         }
 
-        let create_basin_req = CreateBasinRequest::new(basin)
-            .with_config(BasinConfig::with_default_stream_config(stream_config));
+        let basin_config = BasinConfig {
+            default_stream_config: Some(stream_config),
+        };
+
+        let create_basin_req = CreateBasinRequest::new(basin).with_config(basin_config);
 
         self.client
             .create_basin(create_basin_req)

src/basin.rs

@@ -41,7 +41,7 @@ impl BasinService {
         &self,
         stream: String,
         config: Option<StreamConfig>,
-    ) -> Result<(), ServiceError> {
+    ) -> Result<StreamInfo, ServiceError> {
         let mut create_stream_req = CreateStreamRequest::new(stream);
 
         if let Some(config) = config {

src/types.rs

@@ -168,10 +168,11 @@ impl From<&str> for RetentionPolicy {
 
 impl From<BasinConfig> for streamstore::types::BasinConfig {
     fn from(config: BasinConfig) -> Self {
-        if let Some(default_stream_config) = config.default_stream_config.map(|c| c.into()) {
-            streamstore::types::BasinConfig::with_default_stream_config(default_stream_config)
-        } else {
-            streamstore::types::BasinConfig::default()
+        let BasinConfig {
+            default_stream_config,
+        } = config;
+        streamstore::types::BasinConfig {
+            default_stream_config: default_stream_config.map(Into::into),
         }
     }
 }