Function create_vote_pr_success

src/processor.rs:1002–1104

()

    #[tokio::test]
    async fn create_vote_pr_success() {
        let event = setup_test_pr_event();
        let create_vote_input = CreateVoteInput::new(None, &Event::PullRequest(event));
        let cfg = CfgProfile {
            duration: Duration::from_secs(300),
            pass_threshold: 50.0,
            allowed_voters: Some(AllowedVoters::default()),
            ..Default::default()
        };

        let mut db = MockDB::new();
        db.expect_has_vote_open()
            .with(eq(REPOFN), eq(ISSUE_NUM))
            .times(1)
            .returning(|_, _| Box::pin(future::ready(Ok(false))));
        let cfg_copy = cfg.clone();
        let create_vote_input_copy = create_vote_input.clone();
        db.expect_store_vote()
            .withf(move |vote_comment_id, input, cfg| {
                *vote_comment_id == COMMENT_ID && *input == create_vote_input_copy && *cfg == cfg_copy
            })
            .times(1)
            .returning(|_, _, _| Box::pin(future::ready(Ok(Uuid::new_v4()))));
        let mut gh = MockGH::new();
        gh.expect_get_config_file()
            .with(eq(INST_ID), eq(ORG), eq(REPO))
            .times(1)
            .returning(|_, _, _| Box::pin(future::ready(Some(get_test_valid_config()))));
        gh.expect_user_is_collaborator()
            .with(eq(INST_ID), eq(ORG), eq(REPO), eq(USER))
            .times(1)
            .returning(|_, _, _, _| Box::pin(future::ready(Ok(true))));
        let create_vote_input_copy = create_vote_input.clone();
        gh.expect_post_comment()
            .withf(move |inst_id, owner, repo, issue_number, body| {
                let expected_body = tmpl::VoteCreated::new(&create_vote_input_copy, &cfg).render().unwrap();
                *inst_id == INST_ID
                    && owner == ORG
                    && repo == REPO
                    && *issue_number == ISSUE_NUM
                    && body == expected_body.as_str()
            })
            .times(1)
            .returning(|_, _, _, _, _| Box::pin(future::ready(Ok(COMMENT_ID))));
        gh.expect_create_check_run()
            .with(
                eq(INST_ID),
                eq(ORG),
                eq(REPO),
                eq(ISSUE_NUM),
                eq(CheckDetails {
                    status: "in_progress".to_string(),
                    conclusion: None,
                    summary: "Vote open".to_string(),
                }),
            )
            .times(1)
            .returning(|_, _, _, _, _| Box::pin(future::ready(Ok(()))));