Release notifications endpoints (#353)

* Release notifications endpoints

* Added create release notification and email on display

* Update and delete release notifications

* Json validation

* Small fix returning the result

* small fix

* display notifications in reverse order

* PR comments

* submodules merge

Author: lumburovskalina

alembic/versions/24ca8432bd8b_release_notifications_table.py

@@ -0,0 +1,51 @@
+"""Release notifications table
+
+Revision ID: 24ca8432bd8b
+Revises: 9e606cf1f902
+Create Date: 2025-10-01 08:49:37.899217
+
+"""
+
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+# revision identifiers, used by Alembic.
+revision = "24ca8432bd8b"
+down_revision = "9e606cf1f902"
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.create_table(
+        "release_notification",
+        sa.Column("id", sa.Integer(), autoincrement=True, nullable=False),
+        sa.Column("created_at", sa.DateTime(), nullable=True),
+        sa.Column("created_by", postgresql.UUID(as_uuid=True), nullable=True),
+        sa.Column("link", sa.String(), nullable=False),
+        sa.Column("config", sa.JSON(), nullable=True),
+        sa.ForeignKeyConstraint(["created_by"], ["user.id"], ondelete="SET NULL"),
+        sa.PrimaryKeyConstraint("id"),
+        schema="global",
+    )
+    op.create_index(
+        op.f("ix_global_release_notification_created_by"),
+        "release_notification",
+        ["created_by"],
+        unique=False,
+        schema="global",
+    )
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_index(
+        op.f("ix_global_release_notification_created_by"),
+        table_name="release_notification",
+        schema="global",
+    )
+    op.drop_table("release_notification", schema="global")
+    # ### end Alembic commands ###

controller/organization/manager.py

@@ -128,3 +128,27 @@ def sync_organization_sharepoint_integrations(org_id: str) -> None:
     general.remove_and_refresh_session()
     for integration_id in all_integration_ids:
         transfer_api.post_process_integration(integration_id)
+
+
+def validate_json_release_notification(data: Dict[str, Any]) -> Dict[str, Any]:
+    required_languages = ["en", "de", "nl", "it"]
+    required_fields = ["headline", "description"]
+
+    for lang in required_languages:
+        if lang not in data:
+            return {"message": f"Missing language: {lang}", "is_valid": False}
+
+    for lang in required_languages:
+        for field in required_fields:
+            if field not in data[lang]:
+                return {
+                    "message": f"Missing field '{field}' in language '{lang}'",
+                    "is_valid": False,
+                }
+            if not isinstance(data[lang][field], str):
+                return {
+                    "message": f"Field '{field}' in '{lang}' is not a string",
+                    "is_valid": False,
+                }
+
+    return {"message": "", "is_valid": True}

fast_api/models.py

@@ -531,3 +531,8 @@ class GetEmbeddingNameBody(BaseModel):
     embedding_type: str
     model: Optional[str] = None
     api_token_env_name: Optional[str] = None
+
+
+class CreateUpdateReleaseNotificationBody(BaseModel):
+    link: StrictStr
+    config: Dict[str, Any]

fast_api/routes/organization.py

@@ -8,6 +8,7 @@
     ChangeUserRoleBody,
     CreateAdminMessageBody,
     CreateOrganizationBody,
+    CreateUpdateReleaseNotificationBody,
     DeleteOrganizationBody,
     DeleteUserBody,
     MappedSortedPaginatedUsers,
@@ -16,6 +17,7 @@
 )
 from controller.auth import manager as auth_manager
 from controller.auth.kratos import (
+    resolve_user_mail_by_id,
     resolve_user_name_by_id,
 )
 from controller.organization import manager
@@ -24,7 +26,7 @@
 from controller.user import manager as user_manager
 
 from fast_api.routes.client_response import get_silent_success, pack_json_result
-from submodules.model.business_objects import organization, user
+from submodules.model.business_objects import organization, release_notification, user
 from submodules.model.util import sql_alchemy_to_dict
 from util import notification
 
@@ -64,6 +66,7 @@
     "file_lifespan_days",
     "token_limit",
 }
+RELEASE_NOTIFICATIONS_WHITELIST = {"id", "link", "config"}
 
 
 # in use refinery-ui (07.01.25)
@@ -314,3 +317,58 @@ def get_user_to_organization(request: Request):
     auth_manager.check_admin_access(request.state.info)
     data = user.get_user_to_organization()
     return pack_json_result(data, wrap_for_frontend=False)
+
+
+# in use admin-dashboard (01.10.25)
+@router.get("/all-release-notifications-admin")
+def get_all_release_notifications(request: Request):
+    auth_manager.check_admin_access(request.state.info)
+    data = sql_alchemy_to_dict(release_notification.get_all())
+    for item in data:
+        item["createdByEmail"] = resolve_user_mail_by_id(item["created_by"])
+    return pack_json_result(data)
+
+
+# in use admin-dashboard (08.10.25)
+@router.get("/release-notifications")
+def get_release_notifications(request: Request):
+    data = sql_alchemy_to_dict(
+        release_notification.get_all(),
+        column_whitelist=RELEASE_NOTIFICATIONS_WHITELIST,
+    )
+    return pack_json_result(data)
+
+
+# in use admin-dashboard (01.10.25)
+@router.post("/create-release-notification")
+def create_release_notification(
+    request: Request, body: CreateUpdateReleaseNotificationBody = Body(...)
+):
+    auth_manager.check_admin_access(request.state.info)
+    user_id = auth_manager.get_user_id_by_info(request.state.info)
+    validate_result = manager.validate_json_release_notification(body.config)
+    if validate_result["is_valid"]:
+        release_notification.create(body.link, body.config, user_id, with_commit=True)
+    return pack_json_result(validate_result, wrap_for_frontend=False)
+
+
+# in use admin-dashboard (02.10.25)
+@router.put("/update-release-notification/{notification_id}")
+def update_release_notification(
+    request: Request,
+    notification_id: str,
+    body: CreateUpdateReleaseNotificationBody = Body(...),
+):
+    auth_manager.check_admin_access(request.state.info)
+    release_notification.update(
+        notification_id, body.link, body.config, with_commit=True
+    )
+    return get_silent_success()
+
+
+# in use admin-dashboard (02.10.25)
+@router.delete("/delete-release-notification/{notification_id}")
+def delete_release_notification(request: Request, notification_id: str):
+    auth_manager.check_admin_access(request.state.info)
+    release_notification.delete(notification_id, with_commit=True)
+    return get_silent_success()