templates

Documentation

Index

• Constants

Constants

const TEMPLATE = `// Code generated by jrpc. DO NOT EDIT.

package {{ .Package }}

import (
	"context"
	"errors"
	"fmt"

	"gfx.cafe/open/jrpc/contrib/jmux"
)


var _ = context.Background
var _ = errors.New
var _ = fmt.Sprintf




{{- range $name, $component := .Components.Schemas }}
    type {{camelCase $name}} {{template "schemaType" $component}}
{{- end }}

{{define "schemaType" -}}
    {{if not (eq .Ref "") -}}
        {{camelCase (refName .Ref)}}
    {{- else if or
        (not (eq (len .Properties) 0))
        (not (eq (len .OneOf) 0))
        (not (eq (len .AnyOf) 0))
        (not (eq (len .AllOf) 0))
    -}}
        struct {
            {{range $name, $property := .Properties -}}
                {{camelCase $name}} {{template "schemaType" $property}} ` + "`" + `json:"{{$name}}"` + "`" + `
            {{end -}}
            {{range $idx, $property := .OneOf -}}
                Option{{$idx}} {{template "schemaType" $property}}
            {{end -}}
            {{range $idx, $property := .AnyOf -}}
                Option{{$idx}} {{template "schemaType" $property}}
            {{end -}}
            {{range $idx, $property := .AllOf -}}
                Field{{$idx}} {{template "schemaType" $property}}
            {{end -}}
        }
    {{- else if eq .Type "array" -}}
        []{{template "schemaType" (index .Items 0)}}
    {{- else if not (eq (len .Enum) 0) -}}
        string
    {{- else -}}
        {{goType .Type}}
    {{- end}}
{{- end -}}

type GoOpenRPCHandler struct {
	Srv GoOpenRPCService
}
{{range .Methods -}}
    // {{.Summary}}
    func(h *RpcHandler) {{camelCase .Name}}(ctx context.Context,
        {{range .Params -}}{{camelCase .Name}} {{if not .Required}}*{{end}}{{template "schemaType" .Schema}},
        {{end -}}) ({{camelCase .Result.Name}} {{template "schemaType" .Result.Schema}}, err error) {
        handler := h.Fn{{camelCase .Name}}
        if handler == nil {
            err = errors.New("method {{.Name}} not implemented")
            return
        }
        return handler(ctx,
        {{range .Params -}}{{camelCase .Name}},
        {{end -}})
    }
{{end -}}


type GoOpenRPCService interface {
    {{range .Methods -}}
        // {{.Summary}}
        {{camelCase .Name}}(ctx context.Context,
            {{range .Params -}}{{camelCase .Name}} {{if not .Required}}*{{end}}{{template "schemaType" .Schema}},
            {{end -}}
            ) ({{camelCase .Result.Name}} {{template "schemaType" .Result.Schema}}, err error)
    {{end -}}
}



func (h *GoOpenRPCHandler) RouteRPC(r jmux.Router) {
    {{range .Methods -}}
        // {{.Summary}}
        {{if .Namespace}}
            if err := r.RegisterFunc("{{.Namespace}}_{{.MethodName}}", h.Srv.{{camelCase .Name}}); err != nil {
                panic(err)
            }
        {{else}}
            if err := r.RegisterFunc("{{.MethodName}}", h.Srv.{{camelCase .Name}}); err != nil {
                panic(err)
            }
        {{end}}
    {{end -}}
}

type RpcHandler struct {
{{range .Methods -}}
    // {{.Summary}}
  Fn{{camelCase .Name}} func(ctx context.Context,
        {{range .Params -}}{{camelCase .Name}} {{if not .Required}}*{{end}}{{template "schemaType" .Schema}},
        {{end -}})({{camelCase .Result.Name}} {{template "schemaType" .Result.Schema}}, err error)

{{end -}}
}
`