fix: export public API, use config params in all steps

- Add public NewWebSocketPlugin() constructor
- Export GetHub() and BroadcastToRoom on hub
- All step types read from config (template-resolved) instead of current
- Add HTTPPath() to wsServerModule for adapter route registration

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: intel352

internal/hub.go

@@ -157,6 +157,30 @@ func (h *hub) broadcastToRoom(room string, msg []byte, exclude string) {
 	}
 }
 
+// BroadcastToRoom sends msg to all connections in room, returning the recipient count.
+// This satisfies the gameserver plugin's ws_bridge.WSHub interface.
+func (h *hub) BroadcastToRoom(room string, msg []byte) int {
+	h.mu.RLock()
+	members, ok := h.rooms[room]
+	if !ok {
+		h.mu.RUnlock()
+		return 0
+	}
+	ids := make([]string, 0, len(members))
+	for id := range members {
+		ids = append(ids, id)
+	}
+	h.mu.RUnlock()
+
+	count := 0
+	for _, id := range ids {
+		if h.sendTo(id, msg) {
+			count++
+		}
+	}
+	return count
+}
+
 func (h *hub) broadcastAll(msg []byte, exclude string) {
 	h.mu.RLock()
 	ids := make([]string, 0, len(h.connections))

internal/module_ws_server.go

@@ -110,6 +110,9 @@ func (m *wsServerModule) Stop(ctx context.Context) error {
 	return nil
 }
 
+// HTTPPath returns the path this module wants to handle.
+func (m *wsServerModule) HTTPPath() string { return m.path }
+
 // ServeHTTP handles WebSocket upgrade requests.
 // The host workflow engine routes HTTP requests to this handler.
 func (m *wsServerModule) ServeHTTP(w http.ResponseWriter, r *http.Request) {

internal/step_ws_broadcast.go

@@ -23,9 +23,9 @@ func (s *wsBroadcastStep) Execute(ctx context.Context, triggerData map[string]an
 		return &sdk.StepResult{Output: map[string]any{"error": "ws.server not initialized", "recipients": 0}}, nil
 	}
 
-	room, _ := current["room"].(string)
-	message, _ := current["message"].(string)
-	exclude, _ := current["exclude"].(string)
+	room, _ := config["room"].(string)
+	message, _ := config["message"].(string)
+	exclude, _ := config["exclude"].(string)
 
 	msg := []byte(message)
 	var count int

internal/step_ws_close.go

@@ -21,7 +21,7 @@ func (s *wsCloseStep) Execute(ctx context.Context, triggerData map[string]any,
 		return &sdk.StepResult{Output: map[string]any{"error": "ws.server not initialized", "closed": false}}, nil
 	}
 
-	connID, _ := current["connectionId"].(string)
+	connID, _ := config["connectionId"].(string)
 
 	closed := h.closeConnection(connID)
 	return &sdk.StepResult{Output: map[string]any{"closed": closed}}, nil

internal/step_ws_room.go

@@ -23,8 +23,8 @@ func (s *wsRoomJoinStep) Execute(ctx context.Context, triggerData map[string]any
 		return &sdk.StepResult{Output: map[string]any{"error": "ws.server not initialized", "joined": false}}, nil
 	}
 
-	connID, _ := current["connectionId"].(string)
-	room, _ := current["room"].(string)
+	connID, _ := config["connectionId"].(string)
+	room, _ := config["room"].(string)
 
 	if connID == "" || room == "" {
 		return &sdk.StepResult{Output: map[string]any{"error": "connectionId and room are required", "joined": false}}, nil
@@ -54,8 +54,8 @@ func (s *wsRoomLeaveStep) Execute(ctx context.Context, triggerData map[string]an
 		return &sdk.StepResult{Output: map[string]any{"error": "ws.server not initialized", "left": false}}, nil
 	}
 
-	connID, _ := current["connectionId"].(string)
-	room, _ := current["room"].(string)
+	connID, _ := config["connectionId"].(string)
+	room, _ := config["room"].(string)
 
 	if connID == "" || room == "" {
 		return &sdk.StepResult{Output: map[string]any{"error": "connectionId and room are required", "left": false}}, nil
@@ -82,7 +82,7 @@ func (s *wsRoomListStep) Execute(ctx context.Context, triggerData map[string]any
 		return &sdk.StepResult{Output: map[string]any{"error": "ws.server not initialized", "connections": []string{}}}, nil
 	}
 
-	room, _ := current["room"].(string)
+	room, _ := config["room"].(string)
 	members := h.roomMembers(room)
 	if members == nil {
 		members = []string{}

internal/step_ws_send.go

@@ -23,8 +23,8 @@ func (s *wsSendStep) Execute(ctx context.Context, triggerData map[string]any,
 		return &sdk.StepResult{Output: map[string]any{"error": "ws.server not initialized", "sent": false}}, nil
 	}
 
-	connID, _ := current["connectionId"].(string)
-	message, _ := current["message"].(string)
+	connID, _ := config["connectionId"].(string)
+	message, _ := config["message"].(string)
 
 	if connID == "" {
 		return &sdk.StepResult{Output: map[string]any{"error": "connectionId required", "sent": false}}, nil

plugin.go

@@ -10,3 +10,18 @@ import (
 func NewWebSocketPlugin() sdk.PluginProvider {
 	return internal.NewWebSocketPlugin()
 }
+
+// Hub is an exported interface for the WebSocket hub's broadcast capabilities.
+// Satisfied by the internal hub after the ws.server module is initialized.
+type Hub interface {
+	BroadcastToRoom(room string, msg []byte) int
+}
+
+// GetHub returns the global WebSocket hub once the ws.server module has been
+// initialized. Returns nil if the module has not started yet.
+func GetHub() Hub {
+	if h := internal.GetHub(); h != nil {
+		return h
+	}
+	return nil
+}