Struct SafetyGuard 

pub struct SafetyGuard { /* private fields */ }

Combined safety guard for all automation loops.

Provides pre-flight checks that combine rate limiting with deduplication. All automation loops should call SafetyGuard methods before taking actions.

Implementations

impl SafetyGuard

pub fn new(pool: DbPool) -> Self

Create a new safety guard backed by the given database pool.

pub async fn can_reply_to( &self, tweet_id: &str, proposed_reply: Option<&str>, ) -> Result<Result<(), DenialReason>, StorageError>

Check whether replying to a tweet is permitted.

Checks rate limits, exact dedup, and optionally phrasing similarity. Returns Ok(Ok(())) if allowed, Ok(Err(DenialReason)) if blocked, or Err(StorageError) on infrastructure failure.

pub async fn can_post_tweet( &self, ) -> Result<Result<(), DenialReason>, StorageError>

Check whether posting an original tweet is permitted.

Only checks rate limits (no dedup for original tweets).

pub async fn can_post_thread( &self, ) -> Result<Result<(), DenialReason>, StorageError>

Check whether posting a thread is permitted.

Only checks rate limits (no dedup for threads).

pub async fn check_author_limit( &self, author_id: &str, max_per_day: u32, ) -> Result<Result<(), DenialReason>, StorageError>

Check if replying to this author is permitted (per-author daily limit).

pub fn check_banned_phrases( reply_text: &str, banned: &[String], ) -> Result<(), DenialReason>

Check if a generated reply contains a banned phrase.

pub async fn record_author_interaction( &self, author_id: &str, author_username: &str, ) -> Result<(), StorageError>

Record a reply for an author interaction.

pub async fn record_reply(&self) -> Result<(), StorageError>

Record a successful reply action.

pub async fn record_tweet(&self) -> Result<(), StorageError>

Record a successful tweet action.

pub async fn record_thread(&self) -> Result<(), StorageError>

Record a successful thread action.

pub fn rate_limiter(&self) -> &RateLimiter

Get a reference to the underlying rate limiter.

pub fn dedup_checker(&self) -> &DedupChecker

Get a reference to the underlying dedup checker.