mirror of
https://github.com/jkingsman/Remote-Terminal-for-MeshCore.git
synced 2026-03-28 17:43:05 +01:00
Add channel name to broadcasts
This commit is contained in:
@@ -196,6 +196,7 @@ class Message(BaseModel):
|
||||
outgoing: bool = False
|
||||
acked: int = 0
|
||||
sender_name: str | None = None
|
||||
channel_name: str | None = None
|
||||
|
||||
|
||||
class MessagesAroundResponse(BaseModel):
|
||||
|
||||
@@ -208,6 +208,7 @@ async def create_message_from_decrypted(
|
||||
paths=paths,
|
||||
sender_name=sender,
|
||||
sender_key=resolved_sender_key,
|
||||
channel_name=channel_name,
|
||||
).model_dump(),
|
||||
realtime=trigger_bot,
|
||||
)
|
||||
@@ -301,6 +302,7 @@ async def create_dm_message_from_decrypted(
|
||||
paths = [MessagePath(path=path or "", received_at=received)] if path is not None else None
|
||||
|
||||
# Broadcast new message to connected clients (and fanout modules when realtime)
|
||||
sender_name = contact.name if contact and not outgoing else None
|
||||
broadcast_event(
|
||||
"message",
|
||||
Message(
|
||||
|
||||
@@ -172,6 +172,7 @@ export interface Message {
|
||||
/** ACK count: 0 = not acked, 1+ = number of acks/flood echoes received */
|
||||
acked: number;
|
||||
sender_name: string | null;
|
||||
channel_name?: string | null;
|
||||
}
|
||||
|
||||
export interface MessagesAroundResponse {
|
||||
|
||||
@@ -290,6 +290,7 @@ class TestContactMessageCLIFiltering:
|
||||
"outgoing",
|
||||
"acked",
|
||||
"sender_name",
|
||||
"channel_name",
|
||||
}
|
||||
|
||||
with patch("app.event_handlers.broadcast_event") as mock_broadcast:
|
||||
|
||||
Reference in New Issue
Block a user