Adiciona trigger para atualizar os dados de coleção no opac_5

.envs/.local/.django

@@ -19,4 +19,8 @@ CELERY_FLOWER_PASSWORD=QgScyefPrYhHgO6onW61u0nazc5xdBuP4sM7jMRrBBFuA2RjsFhZLp7xb
 FETCH_DATA_TIMEOUT=2
 
 DJANGO_PROFILING_ENABLED=True
-RUN_ASYNC=False
+RUN_ASYNC=False
+
+# ENDPOINT PARA ATUALIZAÇÃO DE COLEÇÕES
+# ------------------------------------------------------------------------------
+ENDPOINT_COLLECTION="/api/v1/update_collection/"

.envs/.local/.jwt

@@ -0,0 +1,6 @@
+JWT_ISS="https://api.seu-django.com"
+JWT_AUD="seu-flask-servico"
+JWT_EXP_SECONDS=600
+JWT_ALG="RS256"
+# JWT_PRIVATE_KEY JA CORRESPONDENTE AO jwt_public OPAC_5 PARA TESTES.
+JWT_PRIVATE_KEY_PATH="/app/jwt_private_local.pem"

collection/api/v1/serializers.py

@@ -2,6 +2,8 @@
 from collection import models
 from core.api.v1.serializers import LanguageSerializer
 from organization.api.v1.serializers import OrganizationSerializer
+from wagtail.models.sites import Site
+
 
 class CollectionNameSerializer(serializers.ModelSerializer):
     """Serializer para nomes traduzidos da coleção"""
@@ -14,6 +16,32 @@ class Meta:
             "language",
         ]
 
+class CollectionLogoListSerializer(serializers.ListSerializer):
+    """
+    Agrupa os logos por 'purpose' e consolida por idioma,
+    eliminando duplicatas por (purpose, lang_code2).
+    """
+    def to_representation(self, data):
+        items = super().to_representation(data)
+        grouped = {}
+        seen = set()
+
+        for item in items:
+            purpose = item.get("purpose")
+            url = item.get("logo_url")
+            lang = item.get("language", {})
+            code2 = lang.get("code2")
+
+            if not purpose or not code2 or not url:
+                continue
+
+            key = (purpose, code2)
+            if key in seen:
+                continue
+            seen.add(key)
+
+            grouped.setdefault(purpose, {}).update({code2: url})
+        return grouped
 
 class CollectionLogoSerializer(serializers.ModelSerializer):
     """Serializer para logos da coleção"""
@@ -22,38 +50,21 @@ class CollectionLogoSerializer(serializers.ModelSerializer):
 
     class Meta:
         model = models.CollectionLogo
+        list_serializer_class = CollectionLogoListSerializer
         fields = [
-            "logo",
             "logo_url",
-            "size",
+            "purpose",
             "language",
         ]
 
     def get_logo_url(self, obj):
-        """Retorna a URL do logo renderizado no tamanho apropriado"""
         if obj.logo:
-            # Ajusta o rendition baseado no tamanho
-            rendition_specs = {
-                'small': 'fill-100x100',
-                'medium': 'fill-200x200',
-                'large': 'fill-400x400',
-                'banner': 'width-1200',
-                'thumbnail': 'fill-150x150',
-                'header': 'height-80',
-                'footer': 'height-60',
-            }
-            spec = rendition_specs.get(obj.size, 'fill-200x200')
-            rendition = obj.logo.get_rendition(spec)
-
-            # Retorna URL completa se houver request no contexto
-            request = self.context.get('request')
-            if request:
-                return request.build_absolute_uri(rendition.url)
-            return rendition.url
+            domain = Site.objects.get(is_default_site=True).hostname
+            domain = f"http://{domain}"
+            return f"{domain}{obj.logo.file.url}"
         return None
 
 
-
 class SupportingOrganizationSerializer(serializers.ModelSerializer):
     """Serializer para organizações de suporte"""
     organization = OrganizationSerializer(read_only=True, many=False)
@@ -93,7 +104,6 @@ class Meta:
 
 class CollectionSerializer(serializers.ModelSerializer):
     """Serializer principal para Collection com todos os relacionamentos"""
-    # Campos relacionados (read-only por padrão)
     collection_names = CollectionNameSerializer(source='collection_name', many=True, read_only=True)
     logos = CollectionLogoSerializer(many=True, read_only=True)
     supporting_organizations = SupportingOrganizationSerializer(source='supporting_organization', many=True, read_only=True)

collection/apps.py

@@ -4,3 +4,6 @@
 class CollectionConfig(AppConfig):
     default_auto_field = "django.db.models.BigAutoField"
     name = "collection"
+
+    def ready(self):
+        from . import signals

collection/choices.py

@@ -14,3 +14,11 @@
     ("books", _("Books")),
     ("data", _("Data repository")),
 ]
+
+LOGO_PURPOSE = [
+    ("homepage", _("Homepage")),
+    ("header", _("Header")),
+    ("logo_drop_menu", _("Logo drop menu")),
+    ("footer", _("Footer")),
+    ("menu", _("Menu")),
+]

collection/migrations/0007_alter_collectionexecutingorganization_options_and_more.py

@@ -0,0 +1,65 @@
+# Generated by Django 5.2.3 on 2025-09-25 17:30
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        (
+            "collection",
+            "0006_alter_collection_options_alter_collection_acron2_and_more",
+        ),
+        ("core", "0007_alter_language_options_alter_license_options_and_more"),
+    ]
+
+    operations = [
+        migrations.AlterModelOptions(
+            name="collectionexecutingorganization",
+            options={
+                "ordering": ["sort_order"],
+                "verbose_name": "Executing Organization",
+                "verbose_name_plural": "Executing Organizations",
+            },
+        ),
+        migrations.AlterModelOptions(
+            name="collectionlogo",
+            options={
+                "ordering": ["sort_order", "language"],
+                "verbose_name": "Collection Logo",
+                "verbose_name_plural": "Collection Logos",
+            },
+        ),
+        migrations.AlterModelOptions(
+            name="collectionsupportingorganization",
+            options={
+                "ordering": ["sort_order"],
+                "verbose_name": "Supporting Organization",
+                "verbose_name_plural": "Supporting Organizations",
+            },
+        ),
+        migrations.AlterUniqueTogether(
+            name="collectionlogo",
+            unique_together={("collection", "language", "purpose")},
+        ),
+        migrations.AddField(
+            model_name="collectionlogo",
+            name="purpose",
+            field=models.CharField(
+                blank=True,
+                choices=[
+                    ("homepage", "Homepage"),
+                    ("header", "Header"),
+                    ("logo_drop_menu", "Logo drop menu"),
+                    ("footer", "Footer"),
+                    ("menu", "Menu"),
+                ],
+                help_text="Select the purpose of this logo",
+                max_length=20,
+            ),
+        ),
+        migrations.RemoveField(
+            model_name="collectionlogo",
+            name="size",
+        ),
+    ]

collection/models.py

@@ -278,6 +278,7 @@ def get_name_for_language(self, lang_code=None):
             return name_obj.text
         return self.main_name or (self.collection_name.first().text if self.collection_name.exists() else "")
 
+
 class CollectionSocialNetwork(Orderable, SocialNetwork):
     page = ParentalKey(
         Collection,
@@ -309,6 +310,7 @@ class CollectionSupportingOrganization(Orderable, ClusterableModel, BaseHistory)
     class Meta:
         verbose_name = _("Supporting Organization")
         verbose_name_plural = _("Supporting Organizations")
+        ordering = ['sort_order'] # Ordena os icons no opac_5
 
     def __str__(self):
         return str(self.organization)
@@ -336,6 +338,7 @@ class CollectionExecutingOrganization(Orderable, ClusterableModel, BaseHistory):
     class Meta:
         verbose_name = _("Executing Organization")
         verbose_name_plural = _("Executing Organizations")
+        ordering = ['sort_order'] # Ordena os icons no opac_5
 
     def __str__(self):
         return str(self.organization)
@@ -352,14 +355,25 @@ class CollectionLogo(Orderable, BaseLogo):
         related_name='logos',
         verbose_name=_("Collection")
     )
-
+    purpose = models.CharField(
+        max_length=20,
+        choices=choices.LOGO_PURPOSE,
+        blank=True,
+        help_text=_("Select the purpose of this logo"),
+    )
+
+    panels = [
+        FieldPanel("logo"),
+        AutocompletePanel("language"),
+        FieldPanel("purpose"),
+    ]
     class Meta:
         verbose_name = _("Collection Logo")
         verbose_name_plural = _("Collection Logos")
-        ordering = ['sort_order', 'language', 'size']
+        ordering = ['sort_order', 'language']
         unique_together = [
-            ('collection', 'size', 'language', ),
+            ('collection', 'language', 'purpose'),
         ]
 
     def __str__(self):
-        return f"{self.collection} - {self.language} ({self.size})"
+        return f"{self.collection} - {self.language} ({self.purpose})"

collection/signals.py

@@ -0,0 +1,21 @@
+from django.db import transaction
+from django.db.models.signals import post_save
+from django.dispatch import receiver
+from django.conf import settings
+from .models import Collection
+from .tasks import build_collection_webhook
+
+
+@receiver(post_save, sender=Collection, dispatch_uid="collection.signals.post_save")
+def collection_post_save(sender, instance, created, **kwargs):
+    def _on_commit():
+        if settings.ACTIVATE_UPDATE_COLLECTION_WEBHOOK:
+            event = "collection.created" if created else "collection.updated"
+            build_collection_webhook.apply_async(
+                kwargs=dict(
+                    event=event,
+                    collection_acron=instance.acron3,
+                    # headers=headers,
+                )
+            )
+    transaction.on_commit(_on_commit)

collection/tasks.py

@@ -1,10 +1,19 @@
+import logging
+import sys
+
+import requests
+from django.conf import settings
 from django.contrib.auth import get_user_model
 from django.utils.translation import gettext_lazy as _
 
 from collection.models import Collection
 from config import celery_app
+from core.utils.jwt import issue_jwt_for_flask
+
+from .api.v1.serializers import CollectionSerializer
 
 User = get_user_model()
+from tracker.models import UnexpectedEvent
 
 
 @celery_app.task(bind=True)
@@ -14,3 +23,84 @@ def task_load_collections(self, user_id=None, username=None):
     if username:
         user = User.objects.get(username=username)
     Collection.load(user)
+
+
+def fetch_with_schema_guess(host_or_url, timeout=10):
+    """
+    Algumas coleções não possuem o schema no domínio, por isso é necessário
+    tentar os schemas http e https para obter o resultado correto.
+    """
+    if "://" in host_or_url:
+        return host_or_url
+
+    for schema in ["http", "https"]:
+        url = f"{schema}://{host_or_url}"
+        try:
+            resp = requests.post(url, timeout=timeout)
+            resp.raise_for_status()
+            return url
+        except requests.exceptions.SSLError:
+            continue
+        except requests.exceptions.RequestException:
+            continue
+
+
+def _send_payload(url, headers, payload):
+    url_with_schema = fetch_with_schema_guess(url)
+    pattern_url = url_with_schema + settings.ENDPOINT_COLLECTION
+
+    try:
+        resp = requests.post(pattern_url, json=payload, headers=headers, timeout=5)
+        if resp.status_code != 200:
+            logging.error(f"Erro ao enviar dados de coleção para {url}. Status: {resp.status_code}. Body: {resp.text}")  
+        resp.raise_for_status()
+        return resp.json()
+    except Exception as e:
+        exc_type, exc_value, exc_traceback = sys.exc_info()
+        UnexpectedEvent.create(
+            exception=e,
+            exc_traceback=exc_traceback,
+            detail={
+                "task": "collection.tasks.build_collection_webhook",
+                "url": url,
+                "payload": payload,
+                "headers": headers,
+                "pattern_url": pattern_url,
+            },
+        )
+
+
+@celery_app.task
+def build_collection_webhook_for_all(event=False, headers=None):
+    collections = Collection.objects.filter(domain__isnull=False, is_active=True)
+    for collection in collections:
+        build_collection_webhook.apply_async(
+            kwargs=dict(
+                event=event,
+                collection_acron=collection.acron3,
+                headers=headers,
+            )
+        )
+
+@celery_app.task
+def build_collection_webhook(event, collection_acron, headers=None):
+    collection = Collection.objects.get(acron3=collection_acron)
+    if not collection.domain:
+        return None
+    serializer = CollectionSerializer(collection)
+    payload = {
+        "event": event,
+        "results": serializer.data,
+    }
+    token = issue_jwt_for_flask(
+        sub="service:django",
+        claims={"roles": ["m2m"], "scope": "ingest:write"}
+    )
+
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json",
+    }
+    _send_payload(url=collection.domain, headers=headers, payload=payload)
+
+