feat: download completed export jobs

apps/api/src/modules/exports/routes/admin-export-routes.js

@@ -78,4 +78,21 @@ export async function registerAdminExportRoutes(app, options) {
       },
     });
   });
+
+  app.get('/exports/jobs/:id/download', async (request, reply) => {
+    const job = await adminExportService.getExportJob({
+      sellerId: request.admin.sellerId,
+      jobId: request.params.id,
+    });
+    if (!job) {
+      throw createApplicationError('EXPORT_JOB_NOT_FOUND', 'Export job was not found.', 404);
+    }
+    if (job.status !== 'COMPLETED' || !Array.isArray(job.output)) {
+      throw createApplicationError('EXPORT_NOT_READY', 'Export is not ready for download.', 409);
+    }
+    return reply
+      .type('application/json; charset=utf-8')
+      .header('content-disposition', 'attachment; filename="inventory.json"')
+      .send(JSON.stringify(job.output));
+  });
 }

apps/api/tests/http/admin-export-routes.test.js

@@ -125,4 +125,9 @@ test('enqueues and polls an asynchronous inventory export', async (testContext)
   assert.equal(enqueue.json().data.id, 'job-1');
   assert.equal(poll.statusCode, 200);
   assert.deepEqual(poll.json().data.output, [{ id: 'item-1' }]);
+
+  const download = await app.inject({ method: 'GET', url: '/api/v1/admin/exports/jobs/job-1/download' });
+  assert.equal(download.statusCode, 200);
+  assert.equal(download.headers['content-disposition'], 'attachment; filename="inventory.json"');
+  assert.deepEqual(JSON.parse(download.body), [{ id: 'item-1' }]);
 });