Struct SlackChannel 

pub struct SlackChannel {
    pub bot_token: String,
    pub client: Client,
    pub channel_id: Option<String>,
    pub last_ts: Arc<Mutex<Option<String>>>,
}

Fields

bot_token: String

client: Client

channel_id: Option<String>

last_ts: Arc<Mutex<Option<String>>>

Cursor tracking the latest message timestamp seen (Slack uses ts as cursor).

Implementations

impl SlackChannel

pub fn new(bot_token: String, channel_id: Option<String>) -> Result<Self>

Trait Implementations

impl Channel for SlackChannel

fn name(&self) -> &str

Human-readable channel name.

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Receiver<IncomingMessage>>> + Send + 'async_trait>>

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

Start listening for incoming messages. Returns a receiver that the engine polls.

fn send<'life0, 'life1, 'async_trait>( &'life0 self, msg: &'life1 OutgoingMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Send a message to a thread/conversation.

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

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

Check if this channel is healthy/connected.

fn ack_interaction<'life0, 'life1, 'async_trait>( &'life0 self, _callback_query_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Acknowledge an interactive callback to dismiss the loading indicator.