feat: add empty auth interceptor

cli/src/activate.rs

@@ -1,8 +1,7 @@
 use crate::Debug;
 use clap::{Args, Subcommand};
 use color_eyre::Result;
-use tonic::transport::Channel;
-use zeebe_client::api::{gateway_client::GatewayClient, ActivateJobsRequest};
+use zeebe_client::{api::ActivateJobsRequest, ZeebeClient};
 
 #[derive(Args)]
 pub(crate) struct ActivateArgs {
@@ -41,7 +40,7 @@ impl From<&ActivateJobsArgs> for ActivateJobsRequest {
 }
 
 pub(crate) async fn handle_activate_command(
-    client: &mut GatewayClient<Channel>,
+    client: &mut ZeebeClient,
     args: &ActivateArgs,
 ) -> Result<Box<dyn Debug>> {
     match &args.resource_type {
@@ -50,7 +49,7 @@ pub(crate) async fn handle_activate_command(
 }
 
 async fn handle_activate_jobs_command(
-    client: &mut GatewayClient<Channel>,
+    client: &mut ZeebeClient,
     args: &ActivateJobsArgs,
 ) -> Result<Box<dyn Debug>> {
     let request: ActivateJobsRequest = args.into();

cli/src/cancel_process_instance.rs

@@ -2,8 +2,8 @@ use color_eyre::eyre::Result;
 use std::fmt::Debug;
 
 use clap::Args;
-use tonic::transport::Channel;
-use zeebe_client::api::{gateway_client::GatewayClient, CancelProcessInstanceRequest};
+
+use zeebe_client::{api::CancelProcessInstanceRequest, ZeebeClient};
 
 #[derive(Args)]
 pub struct CancelProcessInstanceArgs {
@@ -19,7 +19,7 @@ impl From<&CancelProcessInstanceArgs> for CancelProcessInstanceRequest {
 }
 
 pub async fn handle_command(
-    client: &mut GatewayClient<Channel>,
+    client: &mut ZeebeClient,
     args: &CancelProcessInstanceArgs,
 ) -> Result<Box<dyn Debug>> {
     let request: CancelProcessInstanceRequest = args.into();

cli/src/create.rs

@@ -1,10 +1,10 @@
 use crate::Debug;
 use clap::{Args, Subcommand};
 use color_eyre::eyre::Result;
-use tonic::transport::Channel;
-use zeebe_client::api::{
-    gateway_client::GatewayClient, CreateProcessInstanceRequest,
-    CreateProcessInstanceWithResultRequest,
+
+use zeebe_client::{
+    api::{CreateProcessInstanceRequest, CreateProcessInstanceWithResultRequest},
+    ZeebeClient,
 };
 
 #[derive(Args, Clone, Debug)]
@@ -31,7 +31,7 @@ struct CreateInstanceArgs {
 }
 
 pub(crate) async fn handle_create_command(
-    client: &mut GatewayClient<Channel>,
+    client: &mut ZeebeClient,
     args: &CreateArgs,
 ) -> Result<Box<dyn Debug>> {
     match &args.resource_type {
@@ -52,7 +52,7 @@ impl From<&CreateInstanceArgs> for CreateProcessInstanceRequest {
 }
 
 async fn handle_create_instance_command(
-    client: &mut GatewayClient<Channel>,
+    client: &mut ZeebeClient,
     args: &CreateInstanceArgs,
 ) -> Result<Box<dyn Debug>> {
     let request: CreateProcessInstanceRequest = args.into();

cli/src/fail_job.rs

@@ -2,8 +2,7 @@ use color_eyre::eyre::Result;
 use std::fmt::Debug;
 
 use clap::Args;
-use tonic::transport::Channel;
-use zeebe_client::api::{gateway_client::GatewayClient, FailJobRequest};
+use zeebe_client::{api::FailJobRequest, ZeebeClient};
 
 #[derive(Args)]
 pub struct FailJobArgs {
@@ -35,7 +34,7 @@ impl From<&FailJobArgs> for FailJobRequest {
 }
 
 pub async fn handle_command(
-    client: &mut GatewayClient<Channel>,
+    client: &mut ZeebeClient,
     args: &FailJobArgs,
 ) -> Result<Box<dyn Debug>> {
     let request: FailJobRequest = args.into();

cli/src/publish.rs

@@ -2,8 +2,8 @@ use color_eyre::eyre::Result;
 use std::fmt::Debug;
 
 use clap::{Args, Subcommand};
-use tonic::transport::Channel;
-use zeebe_client::api::{gateway_client::GatewayClient, PublishMessageRequest};
+
+use zeebe_client::{api::PublishMessageRequest, ZeebeClient};
 
 #[derive(Args, Clone, Debug)]
 pub(crate) struct PublishArgs {
@@ -42,7 +42,7 @@ impl From<&PublishMessageArgs> for PublishMessageRequest {
 }
 
 pub(crate) async fn handle_publish_command(
-    client: &mut GatewayClient<Channel>,
+    client: &mut ZeebeClient,
     args: &PublishArgs,
 ) -> Result<Box<dyn Debug>> {
     match &args.resource_type {
@@ -51,7 +51,7 @@ pub(crate) async fn handle_publish_command(
 }
 
 async fn handle_publish_message_command(
-    client: &mut GatewayClient<Channel>,
+    client: &mut ZeebeClient,
     args: &PublishMessageArgs,
 ) -> Result<Box<dyn Debug>> {
     let request: PublishMessageRequest = args.into();

cli/src/retries.rs

@@ -2,8 +2,8 @@ use crate::Debug;
 
 use clap::Args;
 use color_eyre::Result;
-use tonic::transport::Channel;
-use zeebe_client::api::{gateway_client::GatewayClient, UpdateJobRetriesRequest};
+
+use zeebe_client::{api::UpdateJobRetriesRequest, ZeebeClient};
 
 #[derive(Args)]
 pub(crate) struct UpdateRetriesArgs {
@@ -26,7 +26,7 @@ impl TryFrom<&UpdateRetriesArgs> for UpdateJobRetriesRequest {
 }
 
 pub(crate) async fn handle_set_retries_command(
-    client: &mut GatewayClient<Channel>,
+    client: &mut ZeebeClient,
     args: &UpdateRetriesArgs,
 ) -> Result<Box<dyn Debug>> {
     let request: UpdateJobRetriesRequest = args.try_into()?;

cli/src/throw_error.rs

@@ -2,8 +2,8 @@ use color_eyre::eyre::Result;
 use std::fmt::Debug;
 
 use clap::Args;
-use tonic::transport::Channel;
-use zeebe_client::api::{gateway_client::GatewayClient, ThrowErrorRequest};
+
+use zeebe_client::{api::ThrowErrorRequest, ZeebeClient};
 
 #[derive(Args)]
 pub struct ThrowErrorArgs {
@@ -29,7 +29,7 @@ impl From<&ThrowErrorArgs> for ThrowErrorRequest {
 }
 
 pub async fn handle_command(
-    client: &mut GatewayClient<Channel>,
+    client: &mut ZeebeClient,
     args: &ThrowErrorArgs,
 ) -> Result<Box<dyn Debug>> {
     let request: ThrowErrorRequest = args.into();

client/src/auth.rs

@@ -0,0 +1,9 @@
+use tonic::service::Interceptor;
+
+pub struct AuthInterceptor {}
+
+impl Interceptor for AuthInterceptor {
+    fn call(&mut self, request: tonic::Request<()>) -> Result<tonic::Request<()>, tonic::Status> {
+        Ok(request)
+    }
+}

client/src/lib.rs

@@ -1,9 +1,10 @@
+mod auth;
 use std::str::FromStr;
 
-use api::gateway_client::GatewayClient;
+use auth::AuthInterceptor;
 use thiserror::Error;
 use tonic::{
-    codegen::http::uri::InvalidUri,
+    codegen::{http::uri::InvalidUri, InterceptedService},
     transport::{self, Channel, Uri},
 };
 
@@ -33,13 +34,19 @@ pub enum ConnectionError {
     Uri(#[from] InvalidUri),
 }
 
-pub async fn connect(conn: Connection) -> Result<GatewayClient<Channel>, ConnectionError> {
+pub type ZeebeClient =
+    api::gateway_client::GatewayClient<InterceptedService<Channel, AuthInterceptor>>;
+
+pub async fn connect(conn: Connection) -> Result<ZeebeClient, ConnectionError> {
     let uri = match conn {
         Connection::Address(addr) => Uri::from_str(&addr),
         Connection::HostPort(proto, host, port) => {
             Uri::from_str(&format!("{:?}://{}:{}", proto, host, port))
         }
     }?;
     let channel = Channel::builder(uri);
-    Ok(GatewayClient::new(channel.connect().await?))
+    Ok(api::gateway_client::GatewayClient::with_interceptor(
+        channel.connect().await?,
+        AuthInterceptor {},
+    ))
 }