Bridge: bump rust sdk (path dep)

This gives access to the needed beta `events_subscription` API, pending a libs release.
svix · Jul 10, 2024 · 6f4f67c · 6f4f67c
1 parent c3654d1
commit 6f4f67c
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 6 deletions.
diff --git a/bridge/Cargo.lock b/bridge/Cargo.lock
diff --git a/bridge/svix-bridge-types/Cargo.toml b/bridge/svix-bridge-types/Cargo.toml
@@ -9,4 +9,4 @@ async-trait = "0.1"
 tokio.workspace = true
 serde.workspace = true
 serde_json.workspace = true
-svix = { version = "1.24.0", features = ["svix_beta"] }
+svix = { path = "../../rust", features = ["svix_beta"] }
diff --git a/bridge/svix-bridge/src/webhook_receiver/mod.rs b/bridge/svix-bridge/src/webhook_receiver/mod.rs
@@ -8,7 +8,7 @@ use axum::{
 };
 use svix_bridge_types::{
     async_trait,
-    svix::api::{Svix, V1MessageStreamParams},
+    svix::api::{Svix, V1MessageEventsSubscriptionParams},
     ForwardRequest, PollerInput, ReceiverOutput, TransformationConfig, TransformerInput,
     TransformerInputFormat, TransformerJob, TransformerOutput, TransformerTx,
 };
@@ -274,9 +274,10 @@ async fn run_inner(poller: &SvixEventsPoller) -> ! {
         match poller
             .svix_client
             .message()
-            .events(V1MessageStreamParams {
+            .events_subscription(V1MessageEventsSubscriptionParams {
                 // FIXME: expose more params as poller input cfg
                 app_id: app_id.clone(),
+                subscription_id: subscription_id.clone(),
                 limit: None,
                 iterator: iterator.clone(),
                 event_types: None,