Function sseClientFile

http/codegen/sse_client.go:14–56

sseClientFile returns the file implementing the SSE client code for SSE endpoints if any. Relies on SSEData (ed.SSE) for all codegen needs.

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

// sseClientFile returns the file implementing the SSE client code for SSE endpoints if any.
// Relies on SSEData (ed.SSE) for all codegen needs.
func sseClientFile(genpkg string, svc *expr.HTTPServiceExpr, services *ServicesData) *codegen.File {
	data := services.Get(svc.Name())
	if data == nil {
		return nil
	}
	// Check if any endpoint has SSE
	hasSSE := false
	for _, ed := range data.Endpoints {
		if ed.SSE != nil {
			hasSSE = true
			break
		}
	}
	if !hasSSE {
		return nil
	}
	path := filepath.Join(codegen.Gendir, "http", codegen.SnakeCase(svc.Name()), "client", "sse.go")
	tmplSections := sseClientTemplateSections(data)
	sections := make([]*codegen.SectionTemplate, 0, 1+len(tmplSections))
	sections = append(sections,
		codegen.Header(
			"sse-client",
			"client",
			[]*codegen.ImportSpec{
				{Path: "bytes"},
				{Path: "context"},
				{Path: "encoding/json"},
				{Path: "errors"},
				{Path: "io"},
				{Path: "net/http"},
				{Path: "fmt"},
				{Path: "strings"},
				{Path: "strconv"},
				{Path: "sync"},
				{Path: genpkg + "/" + codegen.SnakeCase(svc.Name()), Name: data.Service.PkgName},
				{Path: genpkg + "/" + codegen.SnakeCase(svc.Name()) + "/views", Name: data.Service.ViewsPkg},
				{Path: "goa.design/goa/v3/http", Name: "goahttp"},
			},
		),
	)
	sections = append(sections, tmplSections...) // add SSE client methods
	return &codegen.File{Path: path, SectionTemplates: sections}
}

// sseClientTemplateSections returns section templates for SSE client endpoints.
func sseClientTemplateSections(data *ServiceData) []*codegen.SectionTemplate {