feat(models): add ServiceLogs table (#248)

Closes reanahub/reana#880
Closes reanahub/reana-workflow-controller#627

Author: Alputer

reana_db/alembic/versions/20250613_1422_3da4dd5d0b75_add_service_logs_table.py

@@ -0,0 +1,47 @@
+"""Add service_logs table.
+
+Revision ID: 3da4dd5d0b75
+Revises: 3d0994430da7
+Create Date: 2025-06-13 14:22:24.633881
+
+"""
+
+import sqlalchemy_utils
+import sqlalchemy as sa
+from alembic import op
+from sqlalchemy.dialects import postgresql
+
+# revision identifiers, used by Alembic.
+revision = "3da4dd5d0b75"
+down_revision = "3d0994430da7"
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    """Upgrade to 3da4dd5d0b75 revision."""
+    op.create_table(
+        "service_logs",
+        sa.Column("id", sqlalchemy_utils.types.uuid.UUIDType(), nullable=False),
+        sa.Column("service_id", sqlalchemy_utils.types.uuid.UUIDType(), nullable=False),
+        sa.Column(
+            "event_time",
+            sa.DateTime(timezone=True),
+            server_default=sa.text("TIMEZONE('utc', CURRENT_TIMESTAMP)"),
+            nullable=False,
+        ),
+        sa.Column("log", postgresql.JSONB(astext_type=sa.Text()), nullable=False),
+        sa.ForeignKeyConstraint(
+            ["service_id"],
+            ["__reana.service.id_"],
+            name=op.f("fk_service_logs_service_id_service"),
+            ondelete="CASCADE",
+        ),
+        sa.PrimaryKeyConstraint("id", name=op.f("pk_service_logs")),
+        schema="__reana",
+    )
+
+
+def downgrade():
+    """Downgrade to 3d0994430da7 revision."""
+    op.drop_table("service_logs", schema="__reana")

reana_db/models.py

@@ -1,7 +1,7 @@
 # -*- coding: utf-8 -*-
 #
 # This file is part of REANA.
-# Copyright (C) 2018, 2019, 2020, 2021, 2022, 2023, 2024 CERN.
+# Copyright (C) 2018, 2019, 2020, 2021, 2022, 2023, 2024, 2025 CERN.
 #
 # REANA is free software; you can redistribute it and/or modify it
 # under the terms of the MIT License; see LICENSE file for more details.
@@ -58,14 +58,15 @@
     event,
     func,
     or_,
+    text,
 )
 from sqlalchemy.ext.declarative import declarative_base
 from sqlalchemy.ext.hybrid import hybrid_property
 from sqlalchemy.orm import relationship, backref
 from sqlalchemy_utils import EncryptedType, JSONType, UUIDType
 from sqlalchemy_utils.models import Timestamp
 from sqlalchemy_utils.types.encrypted.encrypted_type import AesEngine
-from sqlalchemy.dialects.postgresql import ARRAY
+from sqlalchemy.dialects.postgresql import ARRAY, JSONB
 
 
 convention = {
@@ -503,6 +504,26 @@ class ServiceType(enum.Enum):
     dask = 0
 
 
+class ServiceLog(Base):
+    """ServiceLog table."""
+
+    __tablename__ = "service_logs"
+    __table_args__ = {"schema": "__reana"}
+
+    id = Column(UUIDType, primary_key=True, default=generate_uuid)
+    service_id = Column(
+        UUIDType, ForeignKey("__reana.service.id_", ondelete="CASCADE"), nullable=False
+    )
+    event_time = Column(
+        DateTime(timezone=True),
+        server_default=text("TIMEZONE('utc', CURRENT_TIMESTAMP)"),
+        nullable=False,
+    )
+    log = Column(JSONB, nullable=False)
+
+    service = relationship("Service", back_populates="logs")
+
+
 class Service(Base):
     """Service table."""
 
@@ -516,6 +537,11 @@ class Service(Base):
         Enum(ServiceType),
         nullable=False,
     )
+    logs = relationship(
+        "ServiceLog",
+        back_populates="service",
+        lazy="dynamic",
+    )
 
     __table_args__ = (
         UniqueConstraint("name", "uri"),