mirror of
https://github.com/multica-ai/multica.git
synced 2026-07-06 14:00:09 +02:00
9db91e89f5
* feat: add daemon websocket task wakeups * feat: fan out daemon wakeups across nodes * fix: dedupe daemon wakeup loopback events * fix: lengthen daemon polling fallback interval --------- Co-authored-by: Eve <eve@multica.ai>
51 lines
2.0 KiB
Go
51 lines
2.0 KiB
Go
package realtime
|
|
|
|
// Scope types recognised by the broadcaster. Producers and consumers should
|
|
// use these constants rather than raw strings so a typo can never silently
|
|
// route an event to a non-existent room.
|
|
const (
|
|
ScopeWorkspace = "workspace"
|
|
ScopeUser = "user"
|
|
ScopeTask = "task"
|
|
ScopeChat = "chat"
|
|
// ScopeDaemonRuntime routes daemon wakeup frames through the Redis relay.
|
|
// It is consumed by the daemon WebSocket hub, not by browser clients.
|
|
ScopeDaemonRuntime = "daemon_runtime"
|
|
)
|
|
|
|
// Broadcaster is the abstraction every realtime event producer should depend
|
|
// on instead of *Hub directly.
|
|
//
|
|
// Phase 1 (MUL-1138) extends the surface with BroadcastToScope so events can
|
|
// be fanned out to high-frequency per-resource scopes (`task:{id}`,
|
|
// `chat:{id}`) instead of the whole workspace. The legacy methods continue to
|
|
// work and now route through BroadcastToScope under the hood.
|
|
type Broadcaster interface {
|
|
// BroadcastToScope fans a message out to every connection currently
|
|
// subscribed to ({scopeType, scopeID}) on this node.
|
|
BroadcastToScope(scopeType, scopeID string, message []byte)
|
|
|
|
// BroadcastToWorkspace is a back-compat shortcut for
|
|
// BroadcastToScope("workspace", workspaceID, message).
|
|
BroadcastToWorkspace(workspaceID string, message []byte)
|
|
|
|
// SendToUser is a back-compat shortcut for
|
|
// BroadcastToScope("user", userID, message). The optional
|
|
// excludeWorkspace argument is preserved for the `member:added`
|
|
// dedup path: connections whose workspaceID matches excludeWorkspace
|
|
// are skipped.
|
|
SendToUser(userID string, message []byte, excludeWorkspace ...string)
|
|
|
|
// Broadcast fans a message out to every connection on this node.
|
|
// Used for daemon:* events that have no workspace scope.
|
|
Broadcast(message []byte)
|
|
}
|
|
|
|
// DaemonRuntimeDeliverer consumes daemon-runtime scoped relay frames.
|
|
type DaemonRuntimeDeliverer interface {
|
|
DeliverDaemonRuntime(scopeID string, frame []byte, eventID string)
|
|
}
|
|
|
|
// Compile-time assertion that *Hub continues to satisfy Broadcaster.
|
|
var _ Broadcaster = (*Hub)(nil)
|