team-board/tracker
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

simplify: humans get all WS events, no subscription needed
Some checks failed
Deploy Tracker / deploy (push) Failing after 2s
Details

Browse Source
This commit is contained in:
Markov 2026-02-23 19:15:28 +01:00
parent f50182bc52
commit a1be497cfe
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/tracker/ws/manager.py
View File

@ -43,43 +43,43 @@ class ConnectionManager:
await self.disconnect(slug) await self.disconnect(slug)
async def broadcast_message(self, project_id: str, message: dict, author_slug: str): async def broadcast_message(self, project_id: str, message: dict, author_slug: str):
"""Broadcast message.new — filtered by chat_listen.""" """Broadcast message.new. Humans get everything, agents filtered by subscription."""
logger.info("broadcast_message: project=%s, author=%s, clients=%s", project_id, author_slug, list(self.clients.keys()))
for slug, client in list(self.clients.items()):
logger.info(" checking %s: subscribed=%s, chat_listen=%s", slug, client.subscribed_projects, client.chat_listen)
mentions = message.get("mentions", []) mentions = message.get("mentions", [])
for slug, client in list(self.clients.items()): for slug, client in list(self.clients.items()):
if slug == author_slug: if slug == author_slug:
continue # don't echo to sender continue
# Humans/bridges get ALL messages — filtering on client side
if client.member_type in ("human", "bridge"):
await self.send_to(slug, {"type": "message.new", "data": message})
continue
# Agents: check subscription + chat_listen
if project_id not in client.subscribed_projects: if project_id not in client.subscribed_projects:
continue continue
# Filter by chat_listen
if client.chat_listen == "none": if client.chat_listen == "none":
continue # don't send any chat messages continue
if client.chat_listen == "mentions" and slug not in mentions: if client.chat_listen == "mentions" and slug not in mentions:
continue continue
await self.send_to(slug, {"type": "message.new", "data": message}) await self.send_to(slug, {"type": "message.new", "data": message})
async def broadcast_task_event(self, project_id: str, event_type: str, data: dict): async def broadcast_task_event(self, project_id: str, event_type: str, data: dict):
"""Broadcast task events — filtered by task_listen + ownership.""" """Broadcast task events. Humans get everything, agents filtered."""
assignee = data.get("assignee_slug") assignee = data.get("assignee_slug")
reviewer = data.get("reviewer_slug") reviewer = data.get("reviewer_slug")
watchers = data.get("watchers", []) watchers = data.get("watchers", [])
for slug, client in list(self.clients.items()): for slug, client in list(self.clients.items()):
# Humans/bridges get ALL task events
if client.member_type in ("human", "bridge"):
await self.send_to(slug, {"type": event_type, "data": data})
continue
# Agents: subscription + task_listen filter
if project_id not in client.subscribed_projects: if project_id not in client.subscribed_projects:
continue continue
# task_listen: none → skip all task events
if client.task_listen == "none": if client.task_listen == "none":
continue continue
# task_listen: all → get everything
if client.task_listen == "all": if client.task_listen == "all":
await self.send_to(slug, {"type": event_type, "data": data}) await self.send_to(slug, {"type": event_type, "data": data})
continue continue
# task_listen: mentions → only if involved
if slug in (assignee, reviewer) or slug in watchers: if slug in (assignee, reviewer) or slug in watchers:
await self.send_to(slug, {"type": event_type, "data": data}) await self.send_to(slug, {"type": event_type, "data": data})