Rename get_or_create_pull_request -> upsert_pull_request

Author: Sakib25800

src/bors/handlers/info.rs

@@ -12,7 +12,7 @@ pub(super) async fn command_info(
 ) -> anyhow::Result<()> {
     // Geting PR info from database
     let pr_model = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo.client.repository(),
             pr.number,
             &pr.base.name,

src/bors/handlers/mod.rs

@@ -501,7 +501,7 @@ async fn has_permission(
     }
 
     let pr_model = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo_state.repository(),
             pr.number,
             &pr.base.name,

src/bors/handlers/pr_events.rs

@@ -20,7 +20,7 @@ pub(super) async fn handle_pull_request_edited(
     let pr = &payload.pull_request;
     let pr_number = pr.number;
     let pr_model = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo_state.repository(),
             pr_number,
             &pr.base.name,
@@ -54,7 +54,7 @@ pub(super) async fn handle_push_to_pull_request(
     let pr = &payload.pull_request;
     let pr_number = pr.number;
     let pr_model = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo_state.repository(),
             pr_number,
             &pr.base.name,
@@ -132,7 +132,7 @@ pub(super) async fn handle_pull_request_reopened(
 ) -> anyhow::Result<()> {
     let pr = &payload.pull_request;
     let pr_number = pr.number;
-    db.get_or_create_pull_request(
+    db.upsert_pull_request(
         repo_state.repository(),
         pr_number,
         &pr.base.name,

src/bors/handlers/review.rs

@@ -41,7 +41,7 @@ pub(super) async fn command_approve(
         sha: pr.head.sha.to_string(),
     };
     let pr_model = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo_state.repository(),
             pr.number,
             &pr.base.name,
@@ -70,7 +70,7 @@ pub(super) async fn command_unapprove(
         return Ok(());
     };
     let pr_model = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo_state.repository(),
             pr.number,
             &pr.base.name,
@@ -98,7 +98,7 @@ pub(super) async fn command_set_priority(
         return Ok(());
     };
     let pr_model = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo_state.repository(),
             pr.number,
             &pr.base.name,
@@ -129,7 +129,7 @@ pub(super) async fn command_delegate(
     }
 
     let pr_model = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo_state.repository(),
             pr.number,
             &pr.base.name,
@@ -155,7 +155,7 @@ pub(super) async fn command_undelegate(
         return Ok(());
     }
     let pr_model = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo_state.repository(),
             pr.number,
             &pr.base.name,
@@ -181,7 +181,7 @@ pub(super) async fn command_set_rollup(
         return Ok(());
     }
     let pr_model = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo_state.repository(),
             pr.number,
             &pr.base.name,

src/bors/handlers/trybuild.rs

@@ -56,7 +56,7 @@ pub(super) async fn command_try_build(
     // Create pr model based on CI repo, so we can retrieve the pr later when
     // the CI repo emits events
     let pr_model = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo.client.repository(),
             pr.number,
             &pr.base.name,
@@ -208,7 +208,7 @@ pub(super) async fn command_try_cancel(
 
     let pr_number: PullRequestNumber = pr.number;
     let pr = db
-        .get_or_create_pull_request(
+        .upsert_pull_request(
             repo.client.repository(),
             pr_number,
             &pr.base.name,

src/database/client.rs

@@ -93,7 +93,7 @@ impl PgDbClient {
         get_pull_request(&self.pool, repo, pr_number).await
     }
 
-    pub async fn get_or_create_pull_request(
+    pub async fn upsert_pull_request(
         &self,
         repo: &GithubRepoName,
         pr_number: PullRequestNumber,