How to explicitly close a connection from the server?

[heigler]

Let's say I have the following channel name:
ch_name = specific.cb7cabc63f8c49bb9c739ddae0ed2ffe!d97c07413720438a99965233cf635560

And I want to close only that connection in a server event, so I'm trying to do this:

            layer = get_channel_layer()
            params = {"type": "close"}
            async_to_sync(layer.send)(
                ch_name,
                params)

But it always returns invalid params for the method close, it seems trying to pass the whole dictionary.
I also tried to pass params like {"type": "close", "code": 403} and didn't work.

bune26game  | Exception inside application: invalid type '<class 'dict'>' for close code (must be an integer)
bune26game  | Traceback (most recent call last):
bune26game  |   File "/usr/local/lib/python3.8/site-packages/channels/sessions.py", line 183, in __call__
bune26game  |     return await self.inner(receive, self.send)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/channels/middleware.py", line 41, in coroutine_call
bune26game  |     await inner_instance(receive, send)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/channels/consumer.py", line 58, in __call__
bune26game  |     await await_many_dispatch(
bune26game  |   File "/usr/local/lib/python3.8/site-packages/channels/utils.py", line 51, in await_many_dispatch
bune26game  |     await dispatch(result)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/asgiref/sync.py", line 423, in __call__
bune26game  |     ret = await asyncio.wait_for(future, timeout=None)
bune26game  |   File "/usr/local/lib/python3.8/asyncio/tasks.py", line 455, in wait_for
bune26game  |     return await fut
bune26game  |   File "/usr/local/lib/python3.8/concurrent/futures/thread.py", line 57, in run
bune26game  |     result = self.fn(*self.args, **self.kwargs)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/channels/db.py", line 14, in thread_handler
bune26game  |     return super().thread_handler(loop, *args, **kwargs)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/asgiref/sync.py", line 462, in thread_handler
bune26game  |     return func(*args, **kwargs)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/channels/consumer.py", line 105, in dispatch
bune26game  |     handler(message)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/channels/generic/websocket.py", line 88, in close
bune26game  |     super().send({"type": "websocket.close", "code": code})
bune26game  |   File "/usr/local/lib/python3.8/site-packages/channels/consumer.py", line 113, in send
bune26game  |     self.base_send(message)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/asgiref/sync.py", line 222, in __call__
bune26game  |     return call_result.result()
bune26game  |   File "/usr/local/lib/python3.8/concurrent/futures/_base.py", line 437, in result
bune26game  |     return self.__get_result()
bune26game  |   File "/usr/local/lib/python3.8/concurrent/futures/_base.py", line 389, in __get_result
bune26game  |     raise self._exception
bune26game  |   File "/usr/local/lib/python3.8/site-packages/asgiref/sync.py", line 287, in main_wrap
bune26game  |     result = await self.awaitable(*args, **kwargs)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/channels/sessions.py", line 236, in send
bune26game  |     return await self.real_send(message)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/daphne/server.py", line 229, in handle_reply
bune26game  |     protocol.handle_reply(message)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/daphne/ws_protocol.py", line 190, in handle_reply
bune26game  |     self.serverClose(code=message.get("code", None))
bune26game  |   File "/usr/local/lib/python3.8/site-packages/daphne/ws_protocol.py", line 263, in serverClose
bune26game  |     self.sendClose(code=code)
bune26game  |   File "/usr/local/lib/python3.8/site-packages/autobahn/websocket/protocol.py", line 1989, in sendClose
bune26game  |     raise Exception("invalid type '{}' for close code (must be an integer)".format(type(code)))
bune26game  | Exception: invalid type '<class 'dict'>' for close code (must be an integer)

[carltongibson]

> bune26game  |     raise Exception("invalid type '{}' for close code (must be an integer)".format(type(code)))

Looks like code is a dict here, but there's not enough to say why.

[bloodwithmilk25]

UP, Does anybody know an answer? It's a big deal. We do not send code as a dict. My code is exactly like @heigler's

[bloodwithmilk25]

async_to_sync(channel_layer.group_discard)(group_name, channel_name) seems to be working.