Feature/async map export

.env

@@ -48,6 +48,10 @@ EMAIL_ADDRESS="no-reply@regmel.com"
 CORS_ALLOW_ORIGIN='^https?://(localhost|127\.0\.0\.1)(:[0-9]+)?$'
 ###< nelmio/cors-bundle ###
 
+###> symfony/messenger ###
+MESSENGER_TRANSPORT_DSN=doctrine://default?queue_name=async
+###< symfony/messenger ###
+
 ###> symfony/mailer ###
 MAILER_DSN=null://null
 ###< symfony/mailer ###

assets/js/notifications.js

@@ -0,0 +1,42 @@
+/**
+ * Gerenciamento de notificações - verifica expiração de downloads
+ */
+document.addEventListener('DOMContentLoaded', function() {
+    checkExpiredDownloads();
+
+    // Verifica a cada minuto
+    setInterval(checkExpiredDownloads, 60000);
+});
+
+function checkExpiredDownloads() {
+    const downloadLinks = document.querySelectorAll('a[data-expires-at]');
+    const now = new Date();
+
+    downloadLinks.forEach(link => {
+        const expiresAt = new Date(link.dataset.expiresAt);
+
+        if (now > expiresAt) {
+            // Arquivo expirou
+            link.classList.remove('btn-primary');
+            link.classList.add('btn-secondary', 'disabled');
+            link.setAttribute('aria-disabled', 'true');
+            link.style.pointerEvents = 'none';
+            link.innerHTML = 'Arquivo Expirado';
+
+            // Atualiza mensagem ao lado
+            const parent = link.parentElement;
+            const expiredMsg = parent.querySelector('.text-muted');
+            if (expiredMsg) {
+                expiredMsg.innerHTML = '<span class="text-danger">(expirado - gere novamente)</span>';
+            }
+        } else {
+            // Mostra tempo restante
+            const timeLeft = Math.floor((expiresAt - now) / 1000 / 60); // minutos
+            const expiredMsg = link.parentElement.querySelector('.text-muted');
+
+            if (expiredMsg && timeLeft < 60) {
+                expiredMsg.innerHTML = `<span class="text-warning">(expira em ${timeLeft} min)</span>`;
+            }
+        }
+    });
+}

composer.json

@@ -26,11 +26,13 @@
         "symfony/asset": "7.2.*",
         "symfony/asset-mapper": "7.2.*",
         "symfony/console": "7.2.*",
+        "symfony/doctrine-messenger": "7.2.*",
         "symfony/dotenv": "7.2.*",
         "symfony/expression-language": "7.2.*",
         "symfony/flex": "^2",
         "symfony/framework-bundle": "7.2.*",
         "symfony/mailer": "7.2.*",
+        "symfony/messenger": "7.2.*",
         "symfony/mime": "7.2.*",
         "symfony/monolog-bundle": "^3.10",
         "symfony/property-access": "7.2.*",

config/packages/messenger.yaml

@@ -0,0 +1,19 @@
+framework:
+    messenger:
+        failure_transport: failed
+
+        transports:
+            async:
+                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
+                options:
+                    queue_name: async
+                retry_strategy:
+                    max_retries: 3
+                    multiplier: 2
+
+            failed: 
+                dsn: 'doctrine://default?queue_name=failed'
+
+        routing:
+            'App\Regmel\Message\GenerateMapFilesZipMessage': async
+            'App\Regmel\Message\GenerateAgreementsZipMessage': async

docker-compose.yml

@@ -93,6 +93,22 @@ services:
     networks:
       - regmel_network
 
+  messenger-worker:
+    container_name: regmel-messenger-worker
+    build:
+      context: ./
+      dockerfile: ./docker/php/Dockerfile
+    restart: unless-stopped
+    command: php bin/console messenger:consume async --time-limit=3600 --memory-limit=512M --limit=10
+    volumes:
+      - ./:/var/www
+      - ./docker/php/local.ini:/usr/local/etc/php/conf.d/local.ini
+    depends_on:
+      - postgres
+      - mongo
+    networks:
+      - regmel_network
+
 networks:
   regmel_network:
     driver: bridge

helm/pvr/templates/cronjob-cleanup.yaml

@@ -0,0 +1,73 @@
+apiVersion: batch/v1
+kind: CronJob
+metadata:
+  name: pvr-cleanup-export-files
+  namespace: default
+  labels:
+    app: pvr
+    component: cleanup
+spec:
+  # Executa a cada 2 horas (no minuto 0)
+  schedule: "0 */2 * * *"
+
+  # Manter histórico dos últimos 3 jobs
+  successfulJobsHistoryLimit: 3
+  failedJobsHistoryLimit: 3
+
+  # Política de concorrência: não permitir múltiplas execuções simultâneas
+  concurrencyPolicy: Forbid
+
+  jobTemplate:
+    metadata:
+      labels:
+        app: pvr
+        component: cleanup-job
+    spec:
+      # Manter pod por 1 hora após conclusão para análise de logs
+      ttlSecondsAfterFinished: 3600
+
+      template:
+        metadata:
+          labels:
+            app: pvr
+            component: cleanup-job
+        spec:
+          restartPolicy: Never
+
+          containers:
+          - name: cleanup
+            # Usar a mesma imagem do PHP da aplicação
+            image: pvr-php:latest
+            imagePullPolicy: IfNotPresent
+
+            command:
+            - php
+            - bin/console
+            - app:cleanup-export-files
+            - --max-age=2
+
+            # Variáveis de ambiente (mesmas da aplicação)
+            envFrom:
+            - configMapRef:
+                name: pvr-config
+            - secretRef:
+                name: pvr-secrets
+
+            # Montagem do volume de exportação
+            volumeMounts:
+            - name: exports-volume
+              mountPath: /app/var/exports
+
+            # Recursos limitados (job leve)
+            resources:
+              requests:
+                memory: "64Mi"
+                cpu: "50m"
+              limits:
+                memory: "128Mi"
+                cpu: "100m"
+
+          volumes:
+          - name: exports-volume
+            persistentVolumeClaim:
+              claimName: pvr-exports-pvc

helm/pvr/templates/pvc-exports.yaml

@@ -0,0 +1,19 @@
+{{- if .Values.exports.persistence.enabled }}
+apiVersion: v1
+kind: PersistentVolumeClaim
+metadata:
+  name: {{ include "pvr.fullname" . }}-exports
+  labels:
+    {{- include "pvr.labels" . | nindent 4 }}
+    component: exports
+spec:
+  accessModes:
+    - {{ .Values.exports.persistence.accessMode | default "ReadWriteMany" }}
+  resources:
+    requests:
+      storage: {{ .Values.exports.persistence.size | default "5Gi" }}
+  {{- if .Values.exports.persistence.storageClass }}
+  storageClassName: {{ .Values.exports.persistence.storageClass }}
+  {{- end }}
+{{- end }}
+