hub: Implement listing all uploads

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

diff --git a/src/buildservice/users.py b/src/buildservice/users.py
index 4dd2a498cd5586371d2c6b9e97b97d442a9d4e03..65d089482099cf379aef832118380e9a8616ca2b 100644 (file)
--- a/src/buildservice/users.py
+++ b/src/buildservice/users.py
@@ -540,6 +540,27 @@ class User(base.DataObject):
                        slug,
                )
 
+       @property
+       def uploads(self):
+               """
+                       Returns all uploads that belong to this user
+               """
+               uploads = self.backend.uploads._get_uploads("""
+                       SELECT
+                               *
+                       FROM
+                               uploads
+                       WHERE
+                               user_id = %s
+                       AND
+                               expires_at > CURRENT_TIMESTAMP
+                       ORDER BY
+                               created_at DESC
+                       """, self.id,
+               )
+
+               return list(uploads)
+
 
 class QuotaExceededError(Exception):
        pass

diff --git a/src/hub/uploads.py b/src/hub/uploads.py
index 86ab35d7459a19d539600278e856450b984519b4..88797de189937e27b2d9f2baa6515718d6d4992f 100644 (file)
--- a/src/hub/uploads.py
+++ b/src/hub/uploads.py
@@ -37,6 +37,25 @@ class IndexHandler(BaseHandler):
                """
                self.buffer.write(data)
 
+       @tornado.web.authenticated
+       def get(self):
+               uploads = []
+
+               for upload in self.current_user.uploads:
+                       uploads.append({
+                               "id"         : upload.uuid,
+                               "filename"   : upload.filename,
+                               "size"       : upload.size,
+
+                               "created_at" : upload.created_at.isoformat(),
+                               "expires_at" : upload.expires_at.isoformat(),
+                       })
+
+               self.finish({
+                       "status"  : "ok",
+                       "uploads" : uploads,
+               })
+
        @tornado.web.authenticated
        async def put(self):
                """