Struct ContentStorageAdapter 

pub struct ContentStorageAdapter { /* private fields */ }

Adapts DbPool + posting queue to the ContentStorage port trait.

Implementations

impl ContentStorageAdapter

pub fn new(pool: DbPool, post_tx: Sender<PostAction>) -> Self

Trait Implementations

impl ContentStorage for ContentStorageAdapter

fn last_tweet_time<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<DateTime<Utc>>, ContentLoopError>> + Send + 'async_trait>>

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

Get the timestamp of the most recent posted tweet.

fn todays_tweet_times<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<DateTime<Utc>>, ContentLoopError>> + Send + 'async_trait>>

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

Get the timestamps of all tweets posted today (for slot-based scheduling).

fn last_thread_time<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<DateTime<Utc>>, ContentLoopError>> + Send + 'async_trait>>

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

Get the timestamp of the most recent posted thread.

fn post_tweet<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, topic: &'life1 str, content: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), ContentLoopError>> + Send + 'async_trait>>

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

Post a tweet (sends to posting queue and records in DB).

fn create_thread<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 str, tweet_count: usize, ) -> Pin<Box<dyn Future<Output = Result<String, ContentLoopError>> + Send + 'async_trait>>

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

Create a thread record in the database. Returns the thread ID.

fn update_thread_status<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, thread_id: &'life1 str, status: &'life2 str, tweet_count: usize, root_tweet_id: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<(), ContentLoopError>> + Send + 'async_trait>>

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

Update thread status (pending, posting, sent, partial).

fn store_thread_tweet<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, thread_id: &'life1 str, position: usize, tweet_id: &'life2 str, content: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), ContentLoopError>> + Send + 'async_trait>>

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

Record a thread tweet (position in reply chain).

fn log_action<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, action_type: &'life1 str, status: &'life2 str, message: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), ContentLoopError>> + Send + 'async_trait>>

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

Log an action to the audit trail.

fn next_scheduled_item<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<(i64, String, String)>, ContentLoopError>> + Send + 'async_trait>>

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

Check for scheduled content that is due for posting.

fn mark_scheduled_posted<'life0, 'life1, 'async_trait>( &'life0 self, id: i64, tweet_id: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<(), ContentLoopError>> + Send + 'async_trait>>

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

Mark a scheduled content item as posted.

fn mark_failed_permanent<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, thread_id: &'life1 str, error: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), ContentLoopError>> + Send + 'async_trait>>

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

Mark a thread as permanently failed (no more retries). Stores error reason and failure timestamp.

fn increment_retry<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, thread_id: &'life1 str, error: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<u32, ContentLoopError>> + Send + 'async_trait>>

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

Increment retry count for a thread (for transient failures). Returns the new retry count; implementation tracks failure_kind=‘transient’.