Method check_vote

src/processor.rs:300–338

(&self, i: &CheckVoteInput)

    /// checked in `MAX_VOTE_CHECK_FREQUENCY`.
    #[instrument(fields(vote_id), skip_all, err(Debug))]
    async fn check_vote(&self, i: &CheckVoteInput) -> Result<()> {
        // Get open vote (if any) from database
        let Some(vote) = self
            .db
            .get_open_vote(&i.repository_full_name, i.issue_number)
            .await
            .context("error getting open vote")?
        else {
            return Ok(());
        };

        // Record vote_id as part of the current span
        tracing::Span::current().record("vote_id", vote.vote_id.to_string());

        // Check if the vote has already been checked recently
        let inst_id = vote.installation_id as u64;
        let (owner, repo) = split_full_name(&vote.repository_full_name);
        if let Some(checked_at) = vote.checked_at
            && OffsetDateTime::now_utc() - checked_at < MAX_VOTE_CHECK_FREQUENCY
        {
            // Post comment on the issue/pr and return
            let body = tmpl::VoteCheckedRecently {}.render()?;
            self.gh.post_comment(inst_id, owner, repo, vote.issue_number, &body).await?;
            return Ok(());
        }

        // Calculate results
        let (owner, repo) = split_full_name(&vote.repository_full_name);
        let results = results::calculate(self.gh.clone(), owner, repo, &vote).await?;

        // Post vote status comment on the issue/pr
        let body = tmpl::VoteStatus::new(&results).render()?;
        self.gh.post_comment(inst_id, owner, repo, vote.issue_number, &body).await?;

        // Update vote's last check ts
        self.db.update_vote_last_check(vote.vote_id).await?;

        Ok(())
    }
}

/// Worker that periodically checks the database for votes that should be