Function exampleServiceFile

codegen/service/example_svc.go:60–113

exampleServiceFile returns a basic implementation of the given service.

(genpkg string, _ *expr.RootExpr, svc *expr.ServiceExpr, services *ServicesData, apipkg string)

// exampleServiceFile returns a basic implementation of the given service.
func exampleServiceFile(genpkg string, _ *expr.RootExpr, svc *expr.ServiceExpr, services *ServicesData, apipkg string) *codegen.File {
	data := services.Get(svc.Name)
	svcName := data.PathName
	fpath := svcName + ".go"
	if _, err := os.Stat(fpath); !os.IsNotExist(err) {
		return nil // file already exists, skip it.
	}
	specs := []*codegen.ImportSpec{
		{Path: "io"},
		{Path: "context"},
		{Path: "fmt"},
		{Path: "strings"},
		{Path: path.Join(genpkg, svcName), Name: data.PkgName},
		{Path: "goa.design/clue/log"},
		{Path: "goa.design/goa/v3/security"},
	}
	sections := []*codegen.SectionTemplate{
		codegen.Header("", apipkg, specs),
		{
			Name:   "basic-service-struct",
			Source: serviceTemplates.Read(exampleServiceStructT),
			Data:   data,
		}, {
			Name:   "basic-service-init",
			Source: serviceTemplates.Read(exampleServiceInitT),
			Data:   data,
		},
	}
	if len(data.Schemes) > 0 {
		sections = append(sections, &codegen.SectionTemplate{
			Name:   "security-authfuncs",
			Source: serviceTemplates.Read(exampleSecurityAuthfuncsT),
			Data:   data,
		})
	}
	for _, m := range svc.Methods {
		sections = append(sections, basicEndpointSection(m, data))
	}

	// Add HandleStream method for JSON-RPC WebSocket services (not SSE)
	if hasJSONRPCStreaming(data) && !isJSONRPCSSE(services, svc) {
		sections = append(sections, &codegen.SectionTemplate{
			Name:   "jsonrpc-handle-stream",
			Source: serviceTemplates.Read(jsonrpcHandleStreamT),
			Data:   data,
		})
	}

	return &codegen.File{
		Path:             fpath,
		SectionTemplates: sections,
		SkipExist:        true,
	}
}

// basicEndpointSection returns a section with a basic implementation for the
// given method.