kindred/silo
1
1
Fork 0
Code Issues 30 Pull Requests Actions Packages Projects Releases Wiki Activity

feat(sse): per-connection filtering with user and workstation context #171

Merged
forbes merged 1 commits from feat/sse-per-connection-filtering into main 2026-03-01 16:05:35 +00:00
Conversation 0 Commits 1 Files Changed 4 +223 -14
forbes commented 2026-03-01 16:04:17 +00:00
Owner
Copy Link
  • Extend sseClient with userID, workstationID, and item filter set
  • Update Subscribe() to accept userID and workstationID params
  • Add WatchItem/UnwatchItem/IsWatchingItem methods on sseClient
  • Add PublishToItem, PublishToWorkstation, PublishToUser targeted delivery
  • Targeted events get IDs but skip history ring buffer (real-time only)
  • Update HandleEvents to pass auth user ID and workstation_id query param
  • Touch workstation last_seen on SSE connect
  • Existing Publish() broadcast unchanged; all current callers unaffected
  • Add 5 new tests for targeted delivery and item watch lifecycle

Closes #162

- Extend sseClient with userID, workstationID, and item filter set - Update Subscribe() to accept userID and workstationID params - Add WatchItem/UnwatchItem/IsWatchingItem methods on sseClient - Add PublishToItem, PublishToWorkstation, PublishToUser targeted delivery - Targeted events get IDs but skip history ring buffer (real-time only) - Update HandleEvents to pass auth user ID and workstation_id query param - Touch workstation last_seen on SSE connect - Existing Publish() broadcast unchanged; all current callers unaffected - Add 5 new tests for targeted delivery and item watch lifecycle Closes #162
forbes added 1 commit 2026-03-01 16:04:18 +00:00
feat(sse): per-connection filtering with user and workstation context e7da3ee94d 
- Extend sseClient with userID, workstationID, and item filter set
- Update Subscribe() to accept userID and workstationID params
- Add WatchItem/UnwatchItem/IsWatchingItem methods on sseClient
- Add PublishToItem, PublishToWorkstation, PublishToUser targeted delivery
- Targeted events get IDs but skip history ring buffer (real-time only)
- Update HandleEvents to pass auth user ID and workstation_id query param
- Touch workstation last_seen on SSE connect
- Existing Publish() broadcast unchanged; all current callers unaffected
- Add 5 new tests for targeted delivery and item watch lifecycle

Closes #162
forbes merged commit 82cdd221ef into main 2026-03-01 16:05:35 +00:00
forbes deleted branch feat/sse-per-connection-filtering 2026-03-01 16:05:36 +00:00
Sign in to join this conversation.
Reviewers
No Reviewers
Labels
No items
No Label
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
forbes
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: kindred/silo#171
Delete Branch "feat/sse-per-connection-filtering"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?