CLI: add support for Polling Endpoint Consumers

Adds support for using `v1.events-public.consumer` and
`v1.events-public.consumer-seek`, but gated behind a `svix_beta`
cargo feature.

Author: svix-onelson

svix-cli/Cargo.toml

@@ -52,6 +52,10 @@ tokio-tungstenite = { version = "0.26.0", features = ["rustls-tls-native-roots"]
 toml = "0.8.19"
 url = "2.5.4"
 
+[features]
+default = []
+svix_beta = ["svix/svix_beta"]
+
 # The profile that 'dist' will build with
 [profile.dist]
 inherits = "release"

svix-cli/src/cmds/api/events_public.rs

@@ -1,4 +1,3 @@
-use chrono::{DateTime, Utc};
 use clap::{Args, Subcommand};
 use svix::api::*;
 

svix-cli/src/cmds/api/mod.rs

@@ -3,6 +3,8 @@ pub mod authentication;
 pub mod endpoint;
 pub mod environment;
 pub mod event_type;
+#[cfg(feature = "svix_beta")]
+pub mod events_public;
 pub mod integration;
 pub mod message;
 pub mod message_attempt;

svix-cli/src/main.rs

@@ -5,6 +5,8 @@ use colored_json::{ColorMode, Output};
 use concolor_clap::{Color, ColorChoice};
 use svix::api::SvixOptions;
 
+#[cfg(feature = "svix_beta")]
+use crate::cmds::api::events_public::EventsPublicArgs;
 use crate::{
     cmds::{
         api::{
@@ -65,6 +67,9 @@ enum RootCommands {
     Endpoint(EndpointArgs),
     /// Import or export environments
     Environment(EnvironmentArgs),
+    #[cfg(feature = "svix_beta")]
+    /// Iterate over messages for a Polling Endpoint
+    EventsPublic(EventsPublicArgs),
     /// List, create & modify event types
     EventType(EventTypeArgs),
     /// List integrations by app id
@@ -109,6 +114,11 @@ async fn main() -> Result<()> {
             let client = get_client(&cfg)?;
             args.command.exec(&client, color_mode).await?;
         }
+        #[cfg(feature = "svix_beta")]
+        RootCommands::EventsPublic(args) => {
+            let client = get_client(&cfg?)?;
+            args.command.exec(&client, color_mode).await?;
+        }
         RootCommands::EventType(args) => {
             let client = get_client(&cfg?)?;
             args.command.exec(&client, color_mode).await?;