Method create_vote

src/processor.rs:165–241

(&self, i: &CreateVoteInput)

    /// Create a new vote.
    #[instrument(fields(repo = i.repository_full_name, issue_number = i.issue_number), skip_all, err(Debug))]
    async fn create_vote(&self, i: &CreateVoteInput) -> Result<()> {
        // Get vote configuration profile
        let inst_id = i.installation_id as u64;
        let (owner, repo) = split_full_name(&i.repository_full_name);
        let cfg = match CfgProfile::get(
            self.gh.clone(),
            inst_id,
            owner,
            i.organization.is_some(),
            repo,
            i.profile_name.clone(),
        )
        .await
        {
            Ok(cfg) => cfg,
            Err(err) => {
                let body = match err {
                    CfgError::ConfigNotFound => tmpl::ConfigNotFound {}.render()?,
                    CfgError::ProfileNotFound => tmpl::ConfigProfileNotFound {}.render()?,
                    CfgError::InvalidConfig(reason) => tmpl::InvalidConfig::new(&reason).render()?,
                };
                self.gh.post_comment(inst_id, owner, repo, i.issue_number, &body).await?;
                return Ok(());
            }
        };

        // Only repository collaborators can create votes
        if !self.gh.user_is_collaborator(inst_id, owner, repo, &i.created_by).await? {
            let body = tmpl::VoteRestricted::new(&i.created_by).render()?;
            self.gh.post_comment(inst_id, owner, repo, i.issue_number, &body).await?;
            return Ok(());
        }

        // Only allow one vote open at the same time per issue/pr
        if self.db.has_vote_open(&i.repository_full_name, i.issue_number).await? {
            let body = tmpl::VoteInProgress::new(&i.created_by, i.is_pull_request).render()?;
            self.gh.post_comment(inst_id, owner, repo, i.issue_number, &body).await?;
            return Ok(());
        }

        // Post vote created comment on the issue/pr
        let body = tmpl::VoteCreated::new(i, &cfg).render()?;
        let vote_comment_id = self.gh.post_comment(inst_id, owner, repo, i.issue_number, &body).await?;

        // Store vote information in database
        let vote_id = self.db.store_vote(vote_comment_id, i, &cfg).await?;

        // Create check run if the vote is on a pull request
        if i.is_pull_request {
            let check_details = CheckDetails {
                status: "in_progress".to_string(),
                conclusion: None,
                summary: "Vote open".to_string(),
            };
            self.gh.create_check_run(inst_id, owner, repo, i.issue_number, &check_details).await?;
        }

        // Update issue/pr labels