jobs: Import packages when the job finishes

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

diff --git a/src/buildservice/jobs.py b/src/buildservice/jobs.py
index 9029e83b3bf00501a1dfdf514e82c0ef829011ea..7c210830f08f2c6bc8b4d1f7fbf409f821dbce9c 100644 (file)
--- a/src/buildservice/jobs.py
+++ b/src/buildservice/jobs.py
@@ -164,10 +164,27 @@ class Job(base.DataObject):
                """
                        Will take a list of uploads and import them as packages
                """
-               for upload in uploads:
-                       pass
+               # Import all packages
+               packages = await asyncio.gather(
+                       *(self.backend.packages.create(upload) for upload in uploads),
+               )
+
+               # Add them to the database
+               self.db.executemany("""
+                       INSERT INTO
+                               jobs_packages(
+                                       job_id,
+                                       pkg_id
+                               )
+                       VALUES(
+                               %s, %s
+                       )""", (
+                               (self.id, package.id) for package in packages
+                       )
+               )
 
-               # XXX TODO
+               # Update the cache
+               self.packages = packages
 
        @property
        def size(self):