Method cliCommand

modules/clibridge/clibridge.go:190–235

(rest string, user *users.UserRecord, room *rooms.Room, flags events.EventFlag)

}

func (m *CLIBridgeModule) cliCommand(rest string, user *users.UserRecord, room *rooms.Room, flags events.EventFlag) (bool, error) {
	if !m.isEnabled() {
		user.SendText("CLI bridge is not enabled.")
		return true, nil
	}

	connId := users.GetConnectionId(user.UserId)
	connDetails := connections.Get(connId)
	if connDetails == nil {
		user.SendText("Connection not found.")
		return true, nil
	}

	if connDetails.IsWebSocket() {
		user.SendText("CLI tools are not supported over WebSocket connections.")
		return true, nil
	}

	parts := strings.Fields(rest)
	if len(parts) < 1 {
		user.SendText("Usage: cli <tool> [args...]")
		return true, nil
	}

	if m.getSession(connId) != nil {
		user.SendText("A CLI session is already active on this connection.")
		return true, nil
	}

	toolName := parts[0]
	args := parts[1:]

	if !m.isToolAllowed(toolName) {
		user.SendText(fmt.Sprintf("Tool %q is not in the allowed tools list.", toolName))
		return true, nil
	}

	events.AddToQueue(events.CLIRequest{
		UserId:       user.UserId,
		ConnectionId: connId,
		Command:      toolName,
		Args:         args,
	})

	return true, nil
}

func (m *CLIBridgeModule) onCLIRequest(e events.Event) events.ListenerReturn {
	evt, ok := e.(events.CLIRequest)