From: Michael Tremer <michael.tremer@ipfire.org>
Date: Tue, 25 Oct 2022 12:30:02 +0000 (+0000)
Subject: sources: Update query to fetch a commit by ID
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=29900b22f245bb0dfea3fb0612f46f4a39599323;p=pbs.git

sources: Update query to fetch a commit by ID

Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>
---

diff --git a/src/buildservice/sources.py b/src/buildservice/sources.py
index cac2a7a8..98b9805c 100644
--- a/src/buildservice/sources.py
+++ b/src/buildservice/sources.py
@@ -106,23 +106,28 @@ class Sources(base.Object):
 
 	# Commits
 
-	def _get_commit(self, query, *args):
-		res = self.db.get(query, *args)
-
-		if res:
-			return Commit(self.backend, res.id, data=res)
-
 	def _get_commits(self, query, *args):
 		res = self.db.query(query, *args)
 
 		for row in res:
 			yield Commit(self.backend, row.id, data=row)
 
-	def get_commit_by_id(self, commit_id):
-		commit = self.db.get("SELECT id FROM sources_commits WHERE id = %s", commit_id)
+	def _get_commit(self, query, *args):
+		res = self.db.get(query, *args)
 
-		if commit:
-			return Commit(self.pakfire, commit.id)
+		if res:
+			return Commit(self.backend, res.id, data=res)
+
+	def get_commit_by_id(self, id):
+		return self._get_commit("""
+			SELECT
+				*
+			FROM
+				source_commits
+			WHERE
+				id = %s
+			""", id,
+		)
 
 
 class Source(base.DataObject):