Function websocketServerFile

http/codegen/websocket.go:241–270

websocketServerFile returns the file implementing the WebSocket server streaming implementation if any.

(genpkg string, svc *expr.HTTPServiceExpr, services *ServicesData)

// websocketServerFile returns the file implementing the WebSocket server
// streaming implementation if any.
func websocketServerFile(genpkg string, svc *expr.HTTPServiceExpr, services *ServicesData) *codegen.File {
	data := services.Get(svc.Name())
	if !HasWebSocket(data) {
		return nil
	}
	svcName := data.Service.PathName
	title := fmt.Sprintf("%s WebSocket server streaming", svc.Name())
	imports := []*codegen.ImportSpec{
		{Path: "context"},
		{Path: "io"},
		{Path: "net/http"},
		{Path: "sync"},
		{Path: "time"},
		{Path: "github.com/gorilla/websocket"},
		codegen.GoaImport(""),
		codegen.GoaNamedImport("http", "goahttp"),
		{Path: genpkg + "/" + svcName, Name: data.Service.PkgName},
	}
	structSections := serverStructWSSections(data)
	wsSections := serverWSSections(data)
	sections := make([]*codegen.SectionTemplate, 0, 1+len(structSections)+len(wsSections))
	sections = append(sections, codegen.Header(title, "server", imports))
	sections = append(sections, structSections...)
	sections = append(sections, wsSections...)

	return &codegen.File{
		Path:             filepath.Join(codegen.Gendir, "http", svcName, "server", "websocket.go"),
		SectionTemplates: sections,
	}
}

// WebsocketClientFile returns the file implementing the WebSocket client
// streaming implementation if any.