Function commands_handler_stops_after_processing_queued_cmd

src/processor.rs:631–654

()

    #[tokio::test]
    async fn commands_handler_stops_after_processing_queued_cmd() {
        let mut db = MockDB::new();
        db.expect_cancel_vote()
            .with(eq(REPOFN), eq(ISSUE_NUM))
            .times(1)
            .returning(|_, _| Box::pin(future::ready(Err(format_err!(ERROR)))));
        let mut gh = MockGH::new();
        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 (cmds_tx, cmds_rx) = async_channel::unbounded();
        let cancel_token = CancellationToken::new();
        let event = setup_test_issue_event();
        let cmd = Command::CancelVote(CancelVoteInput::new(&Event::Issue(event)));
        cmds_tx.send(cmd).await.unwrap();
        let cmds_handler = CommandsHandler::new(Arc::new(db), Arc::new(gh), cmds_rx.clone());
        let cmds_handler_handle = cmds_handler.run(cancel_token.clone());
        cancel_token.cancel();

        assert!(cmds_handler_handle.await.is_ok());
        assert!(cmds_rx.is_empty());
    }

    #[tokio::test]
    async fn votes_closer_stops_when_requested_none_closed() {