fix send mesh messages form
This commit is contained in:
parent
fabfe0c54f
commit
a125cc9110
2 changed files with 2 additions and 2 deletions
|
@ -369,7 +369,7 @@ class MeshUIConsumer(AsyncJsonWebsocketConsumer):
|
||||||
msg_to_send = self.scope["session"].pop("mesh_msg_%s" % content["send_msg"], None)
|
msg_to_send = self.scope["session"].pop("mesh_msg_%s" % content["send_msg"], None)
|
||||||
if not msg_to_send:
|
if not msg_to_send:
|
||||||
return
|
return
|
||||||
self.scope["session"].save()
|
database_sync_to_async(self.scope["session"].save)()
|
||||||
|
|
||||||
await self.channel_layer.group_add("mesh_msg_sent", self.channel_name)
|
await self.channel_layer.group_add("mesh_msg_sent", self.channel_name)
|
||||||
self.msg_sent_filter = {"sender": self.channel_name}
|
self.msg_sent_filter = {"sender": self.channel_name}
|
||||||
|
|
|
@ -102,7 +102,7 @@ class MeshMessage(StructType, union_type_field="msg_type"):
|
||||||
return True
|
return True
|
||||||
|
|
||||||
from c3nav.mesh.models import MeshNode
|
from c3nav.mesh.models import MeshNode
|
||||||
uplink = database_sync_to_async(MeshNode.get_node_and_uplink)(self.dst)
|
uplink = await database_sync_to_async(MeshNode.get_node_and_uplink)(self.dst)
|
||||||
if not uplink:
|
if not uplink:
|
||||||
return False
|
return False
|
||||||
if uplink.node_id == exclude_uplink_address:
|
if uplink.node_id == exclude_uplink_address:
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue