feat: Adiciona classe CertificatesOnSolana para registro de certificados na blockchain Solana e atualiza modelo Participant para incluir URL de verificação de autenticidade

Author: maxsonferovante

certified_builder/certificates_on_solana.py

@@ -0,0 +1,51 @@
+import logging
+import httpx
+from pydantic import BaseModel
+from config import config
+
+logger = logging.getLogger(__name__)
+
+
+class CertificatesOnSolanaException(Exception):
+    """Custom exception for CertificatesOnSolana errors."""
+    def __init__(self, message: str = "Error registering certificate on Solana", 
+                       details: str = "",
+                       cause: Exception = None):
+        super().__init__(message)
+        self.details = details
+        self.cause = cause
+class CertificatesOnSolana:
+
+    """ 
+    A class to manage certificates on the Solana blockchain Service."""
+
+    @staticmethod
+    def register_certificate_on_solana(certificate_data: dict) -> dict:
+        logger.info("Registering certificate on Solana blockchain")
+        """
+        Registers a certificate on the Solana blockchain.
+
+        Args:
+            certificate_data (dict): A dictionary containing certificate details.
+
+        Returns:
+            dict: A dictionary with the registration result.
+        """
+        try:
+            with httpx.Client() as client:
+                response = client.post(
+                    url= config.SERVICE_URL_REGISTRATION_API_SOLANA,
+                    headers={
+                        "x-api-key": config.SERVICE_API_KEY_REGISTRATION_API_SOLANA,
+                        "Content-Type": "application/json"
+                    },
+                    json=certificate_data
+                )
+                logger.info(f"Solana response status code: {response.status_code}")
+                response.raise_for_status()
+                solana_response = response.json()
+                return solana_response                
+            logger.info("Certificate registered successfully on Solana")
+        except Exception as e:
+            logger.error(f"Error registering certificate on Solana: {str(e)}")
+            raise CertificatesOnSolanaException(details=str(e), cause=e)

certified_builder/certified_builder.py

@@ -1,11 +1,13 @@
 import logging
+import tempfile
+import os
 from typing import List
-from models.participant import Participant
 from PIL import Image, ImageDraw, ImageFont
 from io import BytesIO
-import os
+from models.participant import Participant
 from certified_builder.utils.fetch_file_certificate import fetch_file_certificate
-import tempfile
+from certified_builder.certificates_on_solana import CertificatesOnSolana
+
 FONT_NAME = os.path.join(os.path.dirname(__file__), "fonts/PinyonScript/PinyonScript-Regular.ttf")
 VALIDATION_CODE = os.path.join(os.path.dirname(__file__), "fonts/ChakraPetch/ChakraPetch-SemiBold.ttf")
 DETAILS_FONT = os.path.join(os.path.dirname(__file__), "fonts/ChakraPetch/ChakraPetch-Regular.ttf")
@@ -44,6 +46,20 @@ def build_certificates(self, participants: List[Participant]):
 
             for participant in participants:
                 try:
+                    # Register certificate on Solana, with returned data extract url for verification
+                    solana_response = CertificatesOnSolana.register_certificate_on_solana(
+                        certificate_data={
+                            "name": participant.name_completed(),
+                            "event": participant.event.product_name,
+                            "email": participant.email,
+                            "certificate_code": participant.formated_validation_code()
+                        }
+                    )
+                    participant.authenticity_verification_url = solana_response.get("blockchain", {}).get("verificacao_url", "")                    
+                    
+                    if not participant.authenticity_verification_url:                        
+                        raise RuntimeError("Failed to get authenticity verification URL from Solana response")
+
                     # Download template and logo only if they are not shared
                     if not all_same_background:
                         certificate_template = self._download_image(participant.certificate.background)

config.py

@@ -7,7 +7,8 @@ class Config(BaseSettings):
     REGION: str
     BUCKET_NAME: str    
     QUEUE_URL: str
-
+    SERVICE_URL_REGISTRATION_API_SOLANA: str
+    SERVICE_API_KEY_REGISTRATION_API_SOLANA: str
 
     class Config:
         env_file = ".env"

models/participant.py

@@ -21,6 +21,7 @@ class Participant(BaseModel):
     validation_code: Optional[str] = Field(default_factory= lambda: ''.join(random.choices(string.hexdigits, k=9)), init=False)
     certificate: Optional[Certificate] = None
     event: Optional[Event] = None
+    authenticity_verification_url: Optional[str] = None
 
     def __str__(self):
         return f"Participant: {self.first_name} {self.last_name} - {self.email}"   
@@ -117,4 +118,4 @@ def create_name_certificate(self):
         logger.info(f"Código de validação antes da sanitização: {self.formated_validation_code()}")
         logger.info(f"Nome do certificado após a sanitização: {name_certificate}")
 
-        return name_certificate
+        return name_certificate