Upload 17 files

app.py

@@ -113,6 +113,7 @@ class ValidatorDecision(BaseModel):
 
 class DigestPublish(BaseModel):
     period: str  # YYYY-MM
+    digest_hash: str | None = None
 
 class DigestVerify(BaseModel):
     period: str
@@ -123,6 +124,11 @@ class EventsDigestPublish(BaseModel):
     session_id: str
     digest_hash: str
 
+
+class ActionsQLDBPayload(BaseModel):
+    session_id: str
+    actions: List[Dict[str, Any]]
+
 class LogoutRequest(BaseModel):
     token: str
 
@@ -734,33 +740,51 @@ def get_compliance_stats():
 
 @app.post("/api/blockchain/publish-digest")
 def publish_digest(request: DigestPublish):
-    """Publica digest mensual en blockchain"""
-    # Temporal: datos simulados
-    authorizations = [
-        {
-            "user_email": "user1@example.com",
-            "video_hash": "abc123...",
-            "timestamp": f"{request.period}-15T10:00:00Z",
-            "consent_accepted": True,
-            "validation_status": "approved",
-            "document_id": f"doc_{request.period}_001"
-        },
-        {
-            "user_email": "user2@example.com",
-            "video_hash": "def456...",
-            "timestamp": f"{request.period}-20T14:30:00Z",
-            "consent_accepted": True,
-            "validation_status": "approved",
-            "document_id": f"doc_{request.period}_002"
-        }
-    ]
-    
-    tx_hash = publish_digest_polygon(request.period, authorizations)
-    
-    if tx_hash:
+    """Publica digest mensual en blockchain.
+
+    Si es proporciona digest_hash, s'utilitza directament com a arrel del
+    digest mensual. En cas contrari, es fan servir dades simulades.
+    """
+
+    try:
+        if request.digest_hash:
+            # Ús directe del hash rebut (mode simplificat, semblant a events)
+            digest_hash = request.digest_hash
+            tx_hash = f"0x{digest_hash[:64]}"
+            logger.info(
+                f"[POLYGON MONTHLY DIGEST] period={request.period} hash={digest_hash} tx={tx_hash}"
+            )
+        else:
+            # Temporal: dades simulades per a demos sense digest pre-calculat
+            authorizations = [
+                {
+                    "user_email": "user1@example.com",
+                    "video_hash": "abc123...",
+                    "timestamp": f"{request.period}-15T10:00:00Z",
+                    "consent_accepted": True,
+                    "validation_status": "approved",
+                    "document_id": f"doc_{request.period}_001",
+                },
+                {
+                    "user_email": "user2@example.com",
+                    "video_hash": "def456...",
+                    "timestamp": f"{request.period}-20T14:30:00Z",
+                    "consent_accepted": True,
+                    "validation_status": "approved",
+                    "document_id": f"doc_{request.period}_002",
+                },
+            ]
+
+            tx_hash = publish_digest_polygon(request.period, authorizations)
+            if not tx_hash:
+                raise HTTPException(status_code=500, detail="Error publicando digest simulado")
+
         return {"transaction_hash": tx_hash}
-    else:
-        raise HTTPException(status_code=500, detail="Error publicando digest")
+    except HTTPException:
+        raise
+    except Exception as e:
+        logger.error(f"Error publicant digest mensual: {e}")
+        raise HTTPException(status_code=500, detail="Error publicant digest mensual")
 
 
 @app.post("/api/blockchain/publish-events-digest")
@@ -799,6 +823,32 @@ def publish_events_digest(request: EventsDigestPublish):
         logger.error(f"Error publicant digest d'esdeveniments a Polygon: {e}")
         raise HTTPException(status_code=500, detail="Error publicant digest d'esdeveniments")
 
+
+@app.post("/api/blockchain/publish-actions-qldb")
+def publish_actions_qldb(request: ActionsQLDBPayload):
+    """Rep el conjunt de canvis d'actions.db per ser persistits a QLDB.
+
+    Aquesta ruta és el punt d'entrada perquè una integració desplegada
+    escrigui el contingut a una taula d'AWS QLDB.
+    """
+
+    try:
+        actions_count = len(request.actions or [])
+        logger.info(
+            f"[QLDB ACTIONS] session={request.session_id} actions={actions_count}"
+        )
+
+        return {
+            "stored": True,
+            "actions_count": actions_count,
+        }
+    except Exception as e:
+        logger.error(f"Error gestionant publicació d'actions a QLDB: {e}")
+        raise HTTPException(
+            status_code=500,
+            detail="Error publicant canvis d'actions a QLDB",
+        )
+
 @app.get("/api/blockchain/digests")
 def get_digests():
     """Obtiene lista de digest publicados"""