package setup import ( "github.com/mholt/caddy/middleware" "github.com/mholt/caddy/middleware/websockets" ) // WebSocket configures a new WebSockets middleware instance. func WebSocket(c *Controller) (middleware.Middleware, error) { var websocks []websockets.Config var respawn bool optionalBlock := func() (hadBlock bool, err error) { for c.NextBlock() { hadBlock = true if c.Val() == "respawn" { respawn = true } else { return true, c.Err("Expected websocket configuration parameter in block") } } return } for c.Next() { var val, path, command string // Path or command; not sure which yet if !c.NextArg() { return nil, c.ArgErr() } val = c.Val() // Extra configuration may be in a block hadBlock, err := optionalBlock() if err != nil { return nil, err } if !hadBlock { // The next argument on this line will be the command or an open curly brace if c.NextArg() { path = val command = c.Val() } else { path = "/" command = val } // Okay, check again for optional block hadBlock, err = optionalBlock() if err != nil { return nil, err } } // Split command into the actual command and its arguments cmd, args, err := middleware.SplitCommandAndArgs(command) if err != nil { return nil, err } websocks = append(websocks, websockets.Config{ Path: path, Command: cmd, Arguments: args, Respawn: respawn, // TODO: This isn't used currently }) } websockets.GatewayInterface = envGatewayInterface websockets.ServerSoftware = envServerSoftware return func(next middleware.Handler) middleware.Handler { return websockets.WebSockets{Next: next, Sockets: websocks} }, nil } const ( envGatewayInterface = "caddy-CGI/1.1" envServerSoftware = "caddy/" // TODO: Version )