Replace sync_to_async with database_sync_to_async

changes/355.fixed

@@ -0,0 +1 @@
+Fixed "Server has gone away" error in Slack Socket Mode.

nautobot_chatops/sockets/slack.py

@@ -4,7 +4,7 @@
 import json
 import shlex
 
-from asgiref.sync import sync_to_async
+from channels.db import database_sync_to_async
 from django.conf import settings
 from slack_sdk.socket_mode.aiohttp import SocketModeClient
 from slack_sdk.socket_mode.request import SocketModeRequest
@@ -72,7 +72,7 @@ async def process_slash_command(client, req):
             client.logger.error("%s", err)
             return
 
-        registry = await sync_to_async(get_commands_registry)()
+        registry = await database_sync_to_async(get_commands_registry)()
 
         if command not in registry:
             SlackDispatcher(context).send_markdown(commands_help(prefix=SLASH_PREFIX))
@@ -211,7 +211,7 @@ async def process_interactive(client, req):
 
         client.logger.info(f"command: {command}, subcommand: {subcommand}, params: {params}")
 
-        registry = await sync_to_async(get_commands_registry)()
+        registry = await database_sync_to_async(get_commands_registry)()
 
         if command not in registry:
             SlackDispatcher(context).send_markdown(commands_help(prefix=SLASH_PREFIX))
@@ -242,7 +242,7 @@ async def process_mention(client, req):
             client.logger.error("%s", err)
             return
 
-        registry = await sync_to_async(get_commands_registry)()
+        registry = await database_sync_to_async(get_commands_registry)()
 
         if command not in registry:
             SlackDispatcher(context).send_markdown(commands_help(prefix=SLASH_PREFIX))

nautobot_chatops/utils.py

@@ -4,7 +4,7 @@
 import sys
 from datetime import datetime, timezone
 
-from asgiref.sync import sync_to_async
+from channels.db import database_sync_to_async
 from django.conf import settings
 from django.db.models import Q
 from django.http import HttpResponse, JsonResponse
@@ -113,7 +113,7 @@ def create_command_log(dispatcher, registry, command, subcommand, params=()):
     )
 
 
-@sync_to_async
+@database_sync_to_async
 def socket_check_and_enqueue_command(*args, **kwargs):
     """Calls check_and_enqueue_command() when in Socket mode."""
     return check_and_enqueue_command(*args, **kwargs)

pyproject.toml

@@ -50,6 +50,7 @@ aiodns = "^1.0"
 aiohttp = "^3.7.3"
 asgiref = "^3.4.1"
 certifi = { version = ">=2021.5.30", optional = true }
+channels = "^4.2.0"
 cloudvision = { version = "^1.1", optional = true }
 cvprac = { version = "^1.0.6", optional = true }
 defusedxml = { version = "^0.7.1", optional = true }