Struct ConnectionStringProvider 

pub struct ConnectionStringProvider { /* private fields */ }

Implementations

impl ConnectionStringProvider

pub fn new(config: ConnectionStringConfig) -> Result<Self, ServiceBusError>

Creates a new ConnectionStringProvider from a connection string configuration.

Parses the connection string to extract the namespace, shared access key name, and shared access key. Validates that all required components are present.

Arguments

• config - Configuration containing the Service Bus connection string

Returns

A configured ConnectionStringProvider ready for authentication

Errors

Returns ServiceBusError::ConfigurationError if:

• Connection string is empty
• Connection string is missing required components (Endpoint, SharedAccessKeyName, SharedAccessKey)
• Connection string format is invalid

Examples

use quetty_server::auth::{ConnectionStringProvider, ConnectionStringConfig};

let config = ConnectionStringConfig {
    value: "Endpoint=sb://test.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=abc123".to_string(),
};

let provider = ConnectionStringProvider::new(config)?;

pub fn connection_string(&self) -> &str

Gets the original connection string value.

Returns

The complete connection string as provided in the configuration

Trait Implementations

impl AuthProvider for ConnectionStringProvider

fn authenticate<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<AuthToken, ServiceBusError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Authenticates using the connection string by generating a SAS token.

Creates a time-limited SAS token (24 hours) using the shared access key from the connection string. The token can be used to authenticate Service Bus operations.

Returns

An AuthToken containing the SAS-based connection string and expiration

Errors

Returns ServiceBusError if SAS token generation fails

fn auth_type(&self) -> AuthType

Returns the authentication type for this provider.

Returns

AuthType::ConnectionString indicating connection string authentication

fn requires_refresh(&self) -> bool

Indicates whether this provider’s tokens require periodic refresh.

Connection string authentication uses SAS tokens that expire, so refresh is required.

Returns

true because SAS tokens have limited validity

fn refresh<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<AuthToken, ServiceBusError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Refreshes the authentication token.

impl Clone for ConnectionStringProvider

fn clone(&self) -> ConnectionStringProvider

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.