Function project_redeploy

app/routers/project.py:1147–1234

(
    request: Request,
    project: Project = Depends(get_project_by_name),
    current_user: User = Depends(get_current_user),
    team_and_membership: tuple[Team, TeamMember] = Depends(get_team_by_slug),
    deployment: Deployment = Depends(get_deployment_by_id),
    db: AsyncSession = Depends(get_db),
    github_service: GitHubService = Depends(get_github_service),
    redis_client: Redis = Depends(get_redis_client),
    queue: ArqRedis = Depends(get_queue),
    github_installation_service: GitHubInstallationService = Depends(
        get_github_installation_service
    ),
)

    name="project_redeploy",
)
async def project_redeploy(
    request: Request,
    project: Project = Depends(get_project_by_name),
    current_user: User = Depends(get_current_user),
    team_and_membership: tuple[Team, TeamMember] = Depends(get_team_by_slug),
    deployment: Deployment = Depends(get_deployment_by_id),
    db: AsyncSession = Depends(get_db),
    github_service: GitHubService = Depends(get_github_service),
    redis_client: Redis = Depends(get_redis_client),
    queue: ArqRedis = Depends(get_queue),
    github_installation_service: GitHubInstallationService = Depends(
        get_github_installation_service
    ),
):
    team, membership = team_and_membership

    form: Any = await ProjectDeployForm.from_formdata(request)

    environment = get_environment_for_branch(
        deployment.branch, project.active_environments
    )

    if environment and request.method == "POST" and await form.validate_on_submit():
        try:
            github_installation = (
                await github_installation_service.get_or_refresh_installation(
                    project.github_installation_id, db
                )
            )
            if not github_installation.token:
                raise ValueError("GitHub installation token missing.")

            commit = await github_service.get_repository_commit(
                user_access_token=github_installation.token,
                repo_id=project.repo_id,
                commit_sha=deployment.commit_sha,
                branch=deployment.branch,
            )

            new_deployment = await DeploymentService().create(
                project=project,
                branch=deployment.branch,
                commit=commit,
                current_user=current_user,
                db=db,
                redis_client=redis_client,
            )
            job = await queue.enqueue_job("start_deployment", new_deployment.id)
            new_deployment.job_id = job.job_id
            await db.commit()

            flash(
                request,
                _(
                    "Deployment %(new_deployment_id)s created.",
                    new_deployment_id=new_deployment.id,
                ),
                "success",