basic get jobs

services/job/job/db.py

@@ -75,6 +75,13 @@ async def get_job(id: int):
     return dict(row)
 
 
+async def get_jobs():
+    stm = job.select()
+    rows = await pg.query(stm)
+    jobs = map(lambda row: dict(row), rows)
+    return list(jobs)
+
+
 async def delete_job(id: int):
     stm = job.delete().where(job.c.id == id)
     await pg.fetchrow(stm)

services/job/job/routes.py

@@ -21,6 +21,13 @@ async def post_handler(request: web.Request):
     return web.json_response(body=job_json, status=201)
 
 
+@routes.get('/api/job')
+async def get_jobs_handler(request: web.Request):
+    jobs = await JobService.get_jobs()
+    jobs_json = json.dumps(jobs, default=json_serialize)
+    return web.json_response(body=jobs_json, status=200)
+
+
 @routes.get('/api/job/{id}')
 async def get_handler(request: web.Request):
     id: int = int(request.match_info['id'])

services/job/job/service.py

@@ -17,6 +17,11 @@ async def get_job(id: int):
         job = await db.get_job(id)
         return job
 
+    @staticmethod
+    async def get_jobs():
+        jobs = await db.get_jobs()
+        return jobs
+
     @staticmethod
     async def delete_job(id: int):
         await db.delete_job(id)