Download progress bar => WIP

Makefile

@@ -23,6 +23,8 @@ list:
 	@echo "  phpcs            > Run php code sniffer test suite"
 	@echo "  install_services > install services dependencies (virtualenv)"
 	@echo "  shell_services   > Shell into python services"
+	@echo "  install_tasks    > install tasks dependencies (virtualenv)"
+	@echo "  shell_tasks      > Shell into python tasks"
 	@echo "  create-db        > Create a database for dev only (need token_enabled=0)"
 	@echo "  remove-pgdata    > Remove the anis-next database"
 	@echo ""
@@ -91,6 +93,12 @@ install_services:
 shell_services:
 	@docker-compose exec services bash
 
+install_tasks:
+	@docker run --init -it --rm --user $(UID):$(GID) -v $(CURDIR)/tasks:/project -w /project python:3.8 /bin/bash -c "python3 -m venv venv && source /project/venv/bin/activate && pip install -r requirements.txt"
+
+shell_tasks:
+	@docker-compose exec tasks bash
+
 create-db:
 	@docker-compose exec server sh /mnt/init-keycloak.sh
 	@docker-compose exec server sh /mnt/create-db.sh

client/src/app/instance/search/services/download.service.ts

+import { HttpClient } from "@angular/common/http";
+import { Observable } from "rxjs";
+
+export class DownloadService {
+    constructor(private http: HttpClient) { }
+
+    download(url: string): Observable<Blob> {
+        return this.http.get(url, {
+            reportProgress: true,
+            responseType: 'blob'
+        });
+    }
+}

tasks/requirements.txt

 certifi==2021.10.8
 charset-normalizer==2.0.12
+decorator==5.1.1
 idna==3.3
 pika==1.2.0
+py==1.11.0
 requests==2.27.1
+retry==0.9.2
 urllib3==1.26.8

tasks/src/anis_tasks/app.py

@@ -3,10 +3,12 @@ import logging, sys
 
 # Third party imports
 import pika
+from retry import retry
 
 # Local application imports
 from anis_tasks import utils, archive
 
+@retry(pika.exceptions.AMQPConnectionError, delay=5, jitter=(1, 3))
 def run():
     try:
         # Check config variables