broadcasting

type AuthController ¶

type AuthController struct {
	// contains filtered or unexported fields
}

AuthController handles channel authorization for private and presence channels.

func NewAuthController(authorizer ChannelAuthorizer) *AuthController

func (ac *AuthController) AuthorizeRequest(w http.ResponseWriter, r *http.Request)

type BroadcastMessage ¶

type BroadcastMessage struct {
	Event   string `json:"event"`
	Channel string `json:"channel"`
	Data    any    `json:"data"`
}

BroadcastMessage defines the custom JSON protocol format.

type Broadcaster ¶

type Broadcaster interface {
	Broadcast(channels []string, eventName string, payload map[string]any) error
}

Broadcaster handles the actual transmission of the event.

type Channel ¶

type Channel interface {
	Name() string
}

Channel represents an abstract broadcasting channel (e.g. public, private, presence).

type ChannelAuthorizer ¶

type ChannelAuthorizer interface {
	Authorize(userID any, channelName string) bool
}

ChannelAuthorizer determines if a user can access a channel.

type ChannelCallback ¶

type ChannelCallback func(user any, channelName string) (authorized bool, data map[string]any)

ChannelCallback is invoked when a user attempts to authenticate to a private or presence channel. `user` is the currently authenticated user (from context). `authorized` should be true if they can join. `data` is the PresenceMember user info (only required for presence channels).

type ChannelManager ¶

type ChannelManager struct {
	// contains filtered or unexported fields
}

ChannelManager stores authorization callbacks for private and presence channels.

func NewChannelManager() *ChannelManager

func (m *ChannelManager) Authorize(user any, channelName string) (bool, map[string]any)

func (m *ChannelManager) Channel(pattern string, callback ChannelCallback)

type Client ¶

type Client struct {
	// contains filtered or unexported fields
}

Client is a middleman between the websocket connection and the hub.

type Event ¶

type Event interface {
	BroadcastOn() []Channel
	BroadcastAs() string
	BroadcastWith() map[string]any
}

Event represents an event that can be broadcasted.

type Hub ¶

type Hub struct {
	Broadcast  chan BroadcastMessage
	Register   chan *Client
	Unregister chan *Client
	// contains filtered or unexported fields
}

Hub maintains the set of active clients and broadcasts messages to the channels.

func NewHub() *Hub

func (h *Hub) Run()

func (h *Hub) Stop()

type LogDriver ¶

type LogDriver struct{}

LogDriver outputs the broadcast to the standard logger for local development.

func (d *LogDriver) Broadcast(channels []string, eventName string, payload map[string]any) error

type Manager ¶

type Manager struct {
	// contains filtered or unexported fields
}

Manager resolves broadcast drivers and dispatches events.

func NewManager(defaultDriver string) *Manager

func (m *Manager) Broadcast(channels []string, eventName string, payload map[string]any) error

func (m *Manager) Connection(name string) Broadcaster

func (m *Manager) Extend(name string, driver Broadcaster)

type PresenceChannel ¶

type PresenceChannel struct {
	// contains filtered or unexported fields
}

PresenceChannel represents a channel requiring authorization and tracking users.

func NewPresenceChannel(name string) *PresenceChannel

func (c *PresenceChannel) Name() string

type PresenceMember ¶

type PresenceMember struct {
	UserID   string         `json:"user_id"`
	UserInfo map[string]any `json:"user_info"`
}

PresenceMember defines a member in a presence channel.

type PrivateChannel ¶

type PrivateChannel struct {
	// contains filtered or unexported fields
}

PrivateChannel represents a channel requiring authorization.

func NewPrivateChannel(name string) *PrivateChannel

func (c *PrivateChannel) Name() string

type PublicChannel ¶

type PublicChannel struct {
	// contains filtered or unexported fields
}

PublicChannel represents a channel anyone can subscribe to.

func NewPublicChannel(name string) *PublicChannel

func (c *PublicChannel) Name() string

type PusherBroadcaster ¶

type PusherBroadcaster struct {
	// contains filtered or unexported fields
}

PusherBroadcaster broadcasts events using the Pusher HTTP API.

func NewPusherBroadcaster(appID, key, secret, cluster string) *PusherBroadcaster

func (p *PusherBroadcaster) Broadcast(channels []string, eventName string, payload map[string]any) error

type RedisBroadcaster ¶

type RedisBroadcaster struct {
	// contains filtered or unexported fields
}

RedisBroadcaster broadcasts events using Redis pub/sub.

func NewRedisBroadcaster(url string) *RedisBroadcaster

func (r *RedisBroadcaster) Broadcast(channels []string, eventName string, payload map[string]any) error

func (r *RedisBroadcaster) ChannelExists(channel string) bool

func (r *RedisBroadcaster) GetChannelCount(channel string) int

func (r *RedisBroadcaster) Subscribe(channel string) <-chan BroadcastMessage

func (r *RedisBroadcaster) Unsubscribe(channel string, msgChan chan BroadcastMessage)

type ServiceProvider ¶

type ServiceProvider struct {
	foundation.BaseServiceProvider
}

ServiceProvider bootstraps the native WebSocket broadcasting system. It creates a Hub (started in background), the WebSocketDriver, registers the driver with the broadcasting Manager (if present in container), and binds both for dependency injection.

To wire the WebSocket endpoint, register the route in your application routes:

hub := app.Make(broadcasting.Hub{})
router.Any("/ws", func(w http.ResponseWriter, r *http.Request) {
    broadcasting.ServeWs(hub, w, r)
})

The /ws path is conventional for native WebSocket connections.

func (p *ServiceProvider) Boot(app *foundation.Application)

func (p *ServiceProvider) Register(app *foundation.Application)

type WebSocketDriver ¶

type WebSocketDriver struct {
	// contains filtered or unexported fields
}

WebSocketDriver implements the Broadcaster interface to push messages into the native WebSocket server Hub.

func NewWebSocketDriver(hub *Hub) *WebSocketDriver

func (d *WebSocketDriver) Broadcast(channels []string, eventName string, payload map[string]any) error