Function WebsocketClientFile

http/codegen/websocket.go:274–304

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

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

// WebsocketClientFile returns the file implementing the WebSocket client
// streaming implementation if any.
func WebsocketClientFile(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 client 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 + "/" + "views", Name: data.Service.ViewsPkg},
		{Path: genpkg + "/" + svcName, Name: data.Service.PkgName},
	}
	structSections := clientStructWSSections(data)
	wsSections := clientWSSections(data)
	sections := make([]*codegen.SectionTemplate, 0, 1+len(structSections)+len(wsSections))
	sections = append(sections, codegen.Header(title, "client", imports))
	sections = append(sections, structSections...)
	sections = append(sections, wsSections...)

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

// serverStructWSSections return section templates that generate WebSocket
// related struct type definitions for the server.