|
1 | 1 | from app.config import app_config
|
2 | 2 | from app.helpers import azuredevops
|
3 | 3 | from app.helpers import github
|
| 4 | +from app.helpers.git import get_default_branch_name |
4 | 5 |
|
5 | 6 | from azure.devops.credentials import BasicAuthentication
|
6 | 7 | from azure.devops.v7_0.git import GitPullRequest
|
@@ -51,7 +52,14 @@ def is_open_pull_requests(repo: Repo, pull_request_config: dict[str, dict[str, A
|
51 | 52 |
|
52 | 53 | source_ref_name = f"refs/heads/{
|
53 | 54 | repo.active_branch.name}"
|
54 |
| - target_ref_name: str = pull_request_payload['targetRefName'] |
| 55 | + target_ref_name: str = pull_request_payload.get( |
| 56 | + 'targetRefName', None) |
| 57 | + |
| 58 | + if not target_ref_name: |
| 59 | + default_branch_name = get_default_branch_name(repo=repo) |
| 60 | + _logger.info(f"Setting targetRefName to the default branch '{ |
| 61 | + default_branch_name}'") |
| 62 | + target_ref_name = default_branch_name |
55 | 63 |
|
56 | 64 | if not target_ref_name.startswith("refs/heads/"):
|
57 | 65 | _logger.debug(
|
@@ -104,7 +112,13 @@ def is_open_pull_requests(repo: Repo, pull_request_config: dict[str, dict[str, A
|
104 | 112 |
|
105 | 113 | head_ref = f"refs/heads/{
|
106 | 114 | repo.active_branch.name}"
|
107 |
| - base_ref: str = pull_request_payload['base'] |
| 115 | + base_ref: str = pull_request_payload.get('base', None) |
| 116 | + |
| 117 | + if not base_ref: |
| 118 | + default_branch_name = get_default_branch_name(repo=repo) |
| 119 | + _logger.info(f"Setting base to the default branch '{ |
| 120 | + default_branch_name}'") |
| 121 | + base_ref = default_branch_name |
108 | 122 |
|
109 | 123 | if not base_ref.startswith("refs/heads/"):
|
110 | 124 | _logger.debug(
|
@@ -214,7 +228,14 @@ def raise_pull_request(repo: Repo, pull_request_config: dict[str, dict[str, Any]
|
214 | 228 | pull_request_payload.get('description', []))
|
215 | 229 | pull_request_payload['sourceRefName'] = f"refs/heads/{
|
216 | 230 | repo.active_branch.name}"
|
217 |
| - target_ref_name: str = pull_request_payload['targetRefName'] |
| 231 | + target_ref_name: str = pull_request_payload.get( |
| 232 | + 'targetRefName', None) |
| 233 | + |
| 234 | + if not target_ref_name: |
| 235 | + default_branch_name = get_default_branch_name(repo=repo) |
| 236 | + _logger.info(f"Setting targetRefName to the default branch '{ |
| 237 | + default_branch_name}'") |
| 238 | + target_ref_name = default_branch_name |
218 | 239 |
|
219 | 240 | if not target_ref_name.startswith("refs/heads/"):
|
220 | 241 | _logger.debug(
|
@@ -257,7 +278,13 @@ def raise_pull_request(repo: Repo, pull_request_config: dict[str, dict[str, Any]
|
257 | 278 | pull_request_payload.get('body', []))
|
258 | 279 | pull_request_payload['head'] = f"refs/heads/{
|
259 | 280 | repo.active_branch.name}"
|
260 |
| - base_ref: str = pull_request_payload['base'] |
| 281 | + base_ref: str = pull_request_payload.get('base', None) |
| 282 | + |
| 283 | + if not base_ref: |
| 284 | + default_branch_name = get_default_branch_name(repo=repo) |
| 285 | + _logger.info(f"Setting base to the default branch '{ |
| 286 | + default_branch_name}'") |
| 287 | + base_ref = default_branch_name |
261 | 288 |
|
262 | 289 | if not base_ref.startswith("refs/heads/"):
|
263 | 290 | _logger.debug(
|
|
0 commit comments