Enable users to migrate a Case thread to a Case dedicated channel.

src/dispatch/case/flows.py

@@ -887,6 +887,41 @@ def case_assign_role_flow(
         conversation_flows.set_conversation_topic(case, db_session)
 
 
+def case_create_conversation_flow(
+    db_session: Session,
+    case: Case,
+    participant_emails: list[str],
+    conversation_target: str = None,
+):
+    """Runs the case conversation creation flow."""
+
+    conversation_flows.create_case_conversation(case, conversation_target, db_session)
+
+    event_service.log_case_event(
+        db_session=db_session,
+        source="Dispatch Core App",
+        description="Conversation added to case",
+        case_id=case.id,
+    )
+
+    for email in participant_emails:
+        # we don't rely on on this flow to add folks to the conversation because in this case
+        # we want to do it in bulk
+        case_add_or_reactivate_participant_flow(
+            db_session=db_session,
+            user_email=email,
+            case_id=case.id,
+            add_to_conversation=False,
+        )
+
+    # we add the participant to the conversation
+    conversation_flows.add_case_participants(
+        case=case,
+        participant_emails=participant_emails,
+        db_session=db_session,
+    )
+
+
 def case_create_resources_flow(
     db_session: Session,
     case_id: int,
@@ -948,32 +983,15 @@ def case_create_resources_flow(
         )
 
     try:
-        # we create the conversation and add participants to the thread
-        conversation_flows.create_case_conversation(case, conversation_target, db_session)
-
-        event_service.log_case_event(
-            db_session=db_session,
-            source="Dispatch Core App",
-            description="Conversation added to case",
-            case_id=case.id,
-        )
         # wait until all resources are created before adding suggested participants
         individual_participants = [x.email for x, _ in individual_participants]
 
-        for email in individual_participants:
-            # we don't rely on on this flow to add folks to the conversation because in this case
-            # we want to do it in bulk
-            case_add_or_reactivate_participant_flow(
-                db_session=db_session,
-                user_email=email,
-                case_id=case.id,
-                add_to_conversation=False,
-            )
-        # # we add the participant to the conversation
-        conversation_flows.add_case_participants(
+        # we create the conversation and add participants to the thread
+        case_create_conversation_flow(
+            db_session=db_session,
             case=case,
             participant_emails=individual_participants,
-            db_session=db_session,
+            conversation_target=conversation_target,
         )
 
         for user_email in set(individual_participants):

src/dispatch/case/views.py

@@ -35,6 +35,7 @@
     case_new_create_flow,
     case_triage_create_flow,
     case_update_flow,
+    case_create_conversation_flow,
     case_create_resources_flow,
     get_case_participants_flow,
 )
@@ -188,6 +189,35 @@ def create_case(
     return case
 
 
+@router.post(
+    "/{case_id}/resources/conversation",
+    response_model=CaseRead,
+    summary="Creates conversation channel for an existing case.",
+)
+def create_case_channel(
+    db_session: DbSession,
+    case_id: PrimaryKey,
+    current_case: CurrentCase,
+    background_tasks: BackgroundTasks,
+):
+    """Creates conversation channel for an existing case."""
+
+    case = get(case_id=case_id, db_session=db_session)
+    case.dedicated_channel = True
+
+    participant_emails = [participant.individual.email for participant in current_case.participants]
+
+    # Add all case participants to the case channel
+    case_create_conversation_flow(
+        db_session=db_session,
+        case=case,
+        participant_emails=participant_emails,
+        conversation_target=None,
+    )
+
+    return current_case
+
+
 @router.post(
     "/{case_id}/resources",
     response_model=CaseRead,

src/dispatch/conversation/flows.py

@@ -8,16 +8,18 @@
 from dispatch.document.models import Document
 from dispatch.event import service as event_service
 from dispatch.incident.models import Incident
+from dispatch.messaging.strings import MessageType
 from dispatch.plugin import service as plugin_service
+from dispatch.plugins.dispatch_slack.case import messages
 from dispatch.storage.models import Storage
 from dispatch.ticket.models import Ticket
 from dispatch.service.models import Service
 from dispatch.project.models import Project
 from dispatch.utils import deslug_and_capitalize_resource_type
 from dispatch.types import Subject
 
-from .models import Conversation, ConversationCreate
-from .service import create
+from .models import Conversation, ConversationCreate, ConversationUpdate
+from .service import create, update
 
 log = logging.getLogger(__name__)
 
@@ -44,6 +46,13 @@ def create_case_conversation(
 
     conversation = None
 
+    # Do not overwrite a case conversation with one of the same type (thread, channel)
+    if case.conversation:
+        if case.has_channel:
+            return case.conversation
+        if case.has_thread and not case.dedicated_channel:
+            return case.conversation
+
     # This case is a thread version, we send a new messaged (threaded) to the conversation target
     # for the configured case type
     if conversation_target and not case.dedicated_channel:
@@ -73,21 +82,86 @@ def create_case_conversation(
 
     conversation.update({"resource_type": plugin.plugin.slug, "resource_id": conversation["id"]})
 
-    conversation_in = ConversationCreate(
-        resource_id=conversation["resource_id"],
-        resource_type=conversation["resource_type"],
-        weblink=conversation["weblink"],
-        thread_id=conversation.get("timestamp"),
-        channel_id=conversation["id"],
-    )
-    case.conversation = create(db_session=db_session, conversation_in=conversation_in)
+    if not case.conversation:
+        conversation_in = ConversationCreate(
+            resource_id=conversation["resource_id"],
+            resource_type=conversation["resource_type"],
+            weblink=conversation["weblink"],
+            thread_id=conversation.get("timestamp"),
+            channel_id=conversation["id"],
+        )
+        case.conversation = create(db_session=db_session, conversation_in=conversation_in)
 
-    event_service.log_case_event(
-        db_session=db_session,
-        source=plugin.plugin.title,
-        description="Case conversation created",
-        case_id=case.id,
-    )
+        event_service.log_case_event(
+            db_session=db_session,
+            source=plugin.plugin.title,
+            description="Case conversation created",
+            case_id=case.id,
+        )
+    elif case.conversation.thread_id and case.dedicated_channel:
+        thread_conversation_channel_id = case.conversation.channel_id
+        thread_converstaion_thread_id = case.conversation.thread_id
+        thread_conversation_weblink = case.conversation.weblink
+
+        conversation_in = ConversationUpdate(
+            resource_id=conversation.get("resource_id"),
+            resource_type=conversation.get("resource_type"),
+            weblink=conversation.get("weblink"),
+            thread_id=conversation.get("timestamp"),
+            channel_id=conversation.get("id"),
+        )
+
+        update(
+            db_session=db_session, conversation=case.conversation, conversation_in=conversation_in
+        )
+
+        event_service.log_case_event(
+            db_session=db_session,
+            source=plugin.plugin.title,
+            description=f"Case conversation has migrated from thread [{thread_conversation_weblink}] to channel[{case.conversation.weblink}].",
+            case_id=case.id,
+        )
+
+    # Inform users in the case thread that the conversation has migrated to a channel
+    try:
+        plugin.instance.send(
+            thread_conversation_channel_id,
+            "Notify Case conversation migration",
+            [],
+            MessageType.case_notification,
+            blocks=messages.create_case_thread_migration_message(
+                channel_weblink=conversation.get("weblink")
+            ),
+            ts=thread_converstaion_thread_id,
+        )
+    except Exception as e:
+        event_service.log_subject_event(
+            subject=case,
+            db_session=db_session,
+            source="Dispatch Core App",
+            description=f"Setting the incident/case conversation topic failed. Reason: {e}",
+        )
+        log.exception(e)
+
+    # Provide users in the case channel which thread the conversation originated from.
+    try:
+        plugin.instance.send(
+            case.conversation.channel_id,
+            "Maintain Case conversation context",
+            [],
+            MessageType.case_notification,
+            blocks=messages.create_case_channel_migration_message(
+                thread_weblink=thread_conversation_weblink
+            ),
+        )
+    except Exception as e:
+        event_service.log_subject_event(
+            subject=case,
+            db_session=db_session,
+            source="Dispatch Core App",
+            description=f"Failed to send message to dedicated channel. Reason: {e}",
+        )
+        log.exception(e)
 
     db_session.add(case)
     db_session.commit()

src/dispatch/plugins/dispatch_slack/case/enums.py

@@ -4,6 +4,7 @@
 
 class CaseNotificationActions(DispatchEnum):
     edit = "case-notification-edit"
+    migrate = "case-notification-migrate"
     escalate = "case-notification-escalate"
     join_incident = "case-notification-join-incident"
     reopen = "case-notification-reopen"
@@ -30,6 +31,10 @@ class CaseEscalateActions(DispatchEnum):
     project_select = "case-notification-escalate-project-select"
 
 
+class CaseMigrateActions(DispatchEnum):
+    submit = "case-notification-migrate-submit"
+
+
 class CaseReportActions(DispatchEnum):
     submit = "case-report-submit"
     project_select = "case-report-project-select"