test: migrate account deletion sync tests to testcontainers (#34091)

Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>

api/tests/test_containers_integration_tests/services/enterprise/test_account_deletion_sync.py

@@ -0,0 +1,200 @@
+"""Integration tests for account deletion synchronization.
+
+Verifies enterprise account deletion sync functionality including
+Redis queuing, error handling, and community vs enterprise behavior.
+"""
+
+from __future__ import annotations
+
+from unittest.mock import patch
+from uuid import uuid4
+
+import pytest
+from redis import RedisError
+
+from extensions.ext_redis import redis_client
+from models.account import TenantAccountJoin
+from services.enterprise.account_deletion_sync import (
+    _queue_task,
+    sync_account_deletion,
+    sync_workspace_member_removal,
+)
+
+
+class TestQueueTask:
+    def test_queue_task_success(self):
+        workspace_id = str(uuid4())
+        member_id = str(uuid4())
+
+        result = _queue_task(workspace_id=workspace_id, member_id=member_id, source="test_source")
+
+        assert result is True
+
+        import json
+
+        raw = redis_client.rpop("enterprise:member:sync:queue")
+        assert raw is not None
+        task_data = json.loads(raw)
+        assert task_data["workspace_id"] == workspace_id
+        assert task_data["member_id"] == member_id
+        assert task_data["source"] == "test_source"
+        assert task_data["type"] == "sync_member_deletion_from_workspace"
+        assert task_data["retry_count"] == 0
+        assert "task_id" in task_data
+        assert "created_at" in task_data
+
+    def test_queue_task_redis_error(self, caplog):
+        with patch("services.enterprise.account_deletion_sync.redis_client") as mock_redis:
+            mock_redis.lpush.side_effect = RedisError("Connection failed")
+
+            result = _queue_task(workspace_id="ws-123", member_id="member-456", source="test_source")
+
+            assert result is False
+            assert "Failed to queue account deletion sync" in caplog.text
+
+    def test_queue_task_type_error(self, caplog):
+        with patch("services.enterprise.account_deletion_sync.redis_client") as mock_redis:
+            mock_redis.lpush.side_effect = TypeError("Cannot serialize")
+
+            result = _queue_task(workspace_id="ws-123", member_id="member-456", source="test_source")
+
+            assert result is False
+            assert "Failed to queue account deletion sync" in caplog.text
+
+
+class TestSyncWorkspaceMemberRemoval:
+    @pytest.fixture
+    def mock_queue_task(self):
+        with patch("services.enterprise.account_deletion_sync._queue_task") as mock_queue:
+            mock_queue.return_value = True
+            yield mock_queue
+
+    def test_sync_workspace_member_removal_enterprise_enabled(self, mock_queue_task):
+        workspace_id = str(uuid4())
+        member_id = str(uuid4())
+
+        with patch("services.enterprise.account_deletion_sync.dify_config") as mock_config:
+            mock_config.ENTERPRISE_ENABLED = True
+
+            result = sync_workspace_member_removal(workspace_id=workspace_id, member_id=member_id, source="removed")
+
+            assert result is True
+            mock_queue_task.assert_called_once_with(workspace_id=workspace_id, member_id=member_id, source="removed")
+
+    def test_sync_workspace_member_removal_enterprise_disabled(self, mock_queue_task):
+        with patch("services.enterprise.account_deletion_sync.dify_config") as mock_config:
+            mock_config.ENTERPRISE_ENABLED = False
+
+            result = sync_workspace_member_removal(
+                workspace_id=str(uuid4()), member_id=str(uuid4()), source="test_source"
+            )
+
+            assert result is True
+            mock_queue_task.assert_not_called()
+
+    def test_sync_workspace_member_removal_queue_failure(self, mock_queue_task):
+        mock_queue_task.return_value = False
+
+        with patch("services.enterprise.account_deletion_sync.dify_config") as mock_config:
+            mock_config.ENTERPRISE_ENABLED = True
+
+            result = sync_workspace_member_removal(
+                workspace_id=str(uuid4()), member_id=str(uuid4()), source="test_source"
+            )
+
+            assert result is False
+
+
+class TestSyncAccountDeletion:
+    @pytest.fixture
+    def mock_queue_task(self):
+        with patch("services.enterprise.account_deletion_sync._queue_task") as mock_queue:
+            mock_queue.return_value = True
+            yield mock_queue
+
+    def test_sync_account_deletion_enterprise_disabled(self, mock_queue_task):
+        with patch("services.enterprise.account_deletion_sync.dify_config") as mock_config:
+            mock_config.ENTERPRISE_ENABLED = False
+
+            result = sync_account_deletion(account_id=str(uuid4()), source="account_deleted")
+
+            assert result is True
+            mock_queue_task.assert_not_called()
+
+    def test_sync_account_deletion_multiple_workspaces(
+        self, flask_app_with_containers, db_session_with_containers, mock_queue_task
+    ):
+        account_id = str(uuid4())
+        tenant_ids = [str(uuid4()) for _ in range(3)]
+
+        for tenant_id in tenant_ids:
+            join = TenantAccountJoin(tenant_id=tenant_id, account_id=account_id)
+            db_session_with_containers.add(join)
+        db_session_with_containers.commit()
+
+        with patch("services.enterprise.account_deletion_sync.dify_config") as mock_config:
+            mock_config.ENTERPRISE_ENABLED = True
+
+            result = sync_account_deletion(account_id=account_id, source="account_deleted")
+
+            assert result is True
+            assert mock_queue_task.call_count == 3
+
+            queued_workspace_ids = {call.kwargs["workspace_id"] for call in mock_queue_task.call_args_list}
+            assert queued_workspace_ids == set(tenant_ids)
+
+    def test_sync_account_deletion_no_workspaces(
+        self, flask_app_with_containers, db_session_with_containers, mock_queue_task
+    ):
+        with patch("services.enterprise.account_deletion_sync.dify_config") as mock_config:
+            mock_config.ENTERPRISE_ENABLED = True
+
+            result = sync_account_deletion(account_id=str(uuid4()), source="account_deleted")
+
+            assert result is True
+            mock_queue_task.assert_not_called()
+
+    def test_sync_account_deletion_partial_failure(
+        self, flask_app_with_containers, db_session_with_containers, mock_queue_task
+    ):
+        account_id = str(uuid4())
+        tenant_ids = [str(uuid4()) for _ in range(3)]
+        fail_tenant = tenant_ids[1]
+
+        for tenant_id in tenant_ids:
+            join = TenantAccountJoin(tenant_id=tenant_id, account_id=account_id)
+            db_session_with_containers.add(join)
+        db_session_with_containers.commit()
+
+        def queue_side_effect(workspace_id, member_id, source):
+            return workspace_id != fail_tenant
+
+        mock_queue_task.side_effect = queue_side_effect
+
+        with patch("services.enterprise.account_deletion_sync.dify_config") as mock_config:
+            mock_config.ENTERPRISE_ENABLED = True
+
+            result = sync_account_deletion(account_id=account_id, source="account_deleted")
+
+            assert result is False
+            assert mock_queue_task.call_count == 3
+
+    def test_sync_account_deletion_all_failures(
+        self, flask_app_with_containers, db_session_with_containers, mock_queue_task
+    ):
+        account_id = str(uuid4())
+        tenant_id = str(uuid4())
+
+        join = TenantAccountJoin(tenant_id=tenant_id, account_id=account_id)
+        db_session_with_containers.add(join)
+        db_session_with_containers.commit()
+
+        mock_queue_task.return_value = False
+
+        with patch("services.enterprise.account_deletion_sync.dify_config") as mock_config:
+            mock_config.ENTERPRISE_ENABLED = True
+
+            result = sync_account_deletion(account_id=account_id, source="account_deleted")
+
+            assert result is False
+            mock_queue_task.assert_called_once()