Skip to content
Snippets Groups Projects
Commit 7456cb0f authored by Anton Sattarov's avatar Anton Sattarov
Browse files

fix tmpl

parent cc7ef116
No related branches found
No related tags found
No related merge requests found
...@@ -35,24 +35,24 @@ func RegisterServer(grpcSrv *grpc.Server, srv *Server) { ...@@ -35,24 +35,24 @@ func RegisterServer(grpcSrv *grpc.Server, srv *Server) {
{{- $response = (print "*emptypb.Empty") -}} {{- $response = (print "*emptypb.Empty") -}}
{{- end -}} {{- end -}}
// {{$method.Name}} implements {{$.Interface.Name}}
func (s *Server) {{$method.Name}}(ctx context.Context, request *pb.{{$method.Name}}Request) (response {{ $response }}, err error) {
req := {{$method.Name}}RequestFromPB(request)
{{- $paramList := list -}} {{- $paramList := list -}}
{{- range $param := $method.Params -}} {{- range $param := $method.Params -}}
{{- if not ( and $method.AcceptsContext (eq $param.Name "ctx")) -}} {{- if not ( and $method.AcceptsContext (eq $param.Name "ctx")) -}}
{{- $paramList = append $paramList (printf "req.%s" $param.Name ) -}} {{- $paramList = append $paramList (printf "req.%s" $param.Name ) -}}
{{- end -}} {{- end -}}
{{- end }} {{- end -}}
{{ if gt $resListLen 0 }}
{{- $method.ResultsNames | join `,` -}} := s.service.{{- $method.Name -}}(ctx, {{- $paramList | join `, ` -}}) // {{$method.Name}} implements {{$.Interface.Name}}
func (s *Server) {{$method.Name}}(ctx context.Context, request *pb.{{$method.Name}}Request) (response {{ $response }}, err error) {
req := {{$method.Name}}RequestFromPB(request)
{{- if gt $resListLen 0 }}
{{ $method.ResultsNames | join `,` }} := s.service.{{ $method.Name }}(ctx, {{ $paramList | join `, ` }})
{{- else }} {{- else }}
err = s.service.{{- $method.Name -}}(ctx, {{- $paramList | join `, ` -}}) err = s.service.{{ $method.Name }}(ctx, {{ $paramList | join `, ` }})
{{- end }} {{- end }}
{{- if gt $resListLen 0 }}
{{ if gt $resListLen 0 -}} response = {{ $method.Name }}ResponseToPB({{ $resList | join `,` }})
response = {{- $method.Name -}}ResponseToPB({{- $resList | join `,` -}})
{{- end }} {{- end }}
return return
} }
......
...@@ -30,18 +30,14 @@ func RegisterServer(grpcSrv *grpc.Server, srv *Server) { ...@@ -30,18 +30,14 @@ func RegisterServer(grpcSrv *grpc.Server, srv *Server) {
// Accept implements Invitations // Accept implements Invitations
func (s *Server) Accept(ctx context.Context, request *pb.AcceptRequest) (response *emptypb.Empty, err error) { func (s *Server) Accept(ctx context.Context, request *pb.AcceptRequest) (response *emptypb.Empty, err error) {
req := AcceptRequestFromPB(request) req := AcceptRequestFromPB(request)
err = s.service.Accept(ctx, req.invitationId, req.userId) err = s.service.Accept(ctx, req.invitationId, req.userId)
return return
} }
// Create implements Invitations // Create implements Invitations
func (s *Server) Create(ctx context.Context, request *pb.CreateRequest) (response *pb.CreateResponse, err error) { func (s *Server) Create(ctx context.Context, request *pb.CreateRequest) (response *pb.CreateResponse, err error) {
req := CreateRequestFromPB(request) req := CreateRequestFromPB(request)
created, err := s.service.Create(ctx, req.invitation) created, err := s.service.Create(ctx, req.invitation)
response = CreateResponseToPB(created) response = CreateResponseToPB(created)
return return
} }
...@@ -49,18 +45,14 @@ func (s *Server) Create(ctx context.Context, request *pb.CreateRequest) (respons ...@@ -49,18 +45,14 @@ func (s *Server) Create(ctx context.Context, request *pb.CreateRequest) (respons
// Delete implements Invitations // Delete implements Invitations
func (s *Server) Delete(ctx context.Context, request *pb.DeleteRequest) (response *emptypb.Empty, err error) { func (s *Server) Delete(ctx context.Context, request *pb.DeleteRequest) (response *emptypb.Empty, err error) {
req := DeleteRequestFromPB(request) req := DeleteRequestFromPB(request)
err = s.service.Delete(ctx, req.invitationId) err = s.service.Delete(ctx, req.invitationId)
return return
} }
// Find implements Invitations // Find implements Invitations
func (s *Server) Find(ctx context.Context, request *pb.FindRequest) (response *pb.FindResponse, err error) { func (s *Server) Find(ctx context.Context, request *pb.FindRequest) (response *pb.FindResponse, err error) {
req := FindRequestFromPB(request) req := FindRequestFromPB(request)
invitations, total, err := s.service.Find(ctx, req.filter, req.opts) invitations, total, err := s.service.Find(ctx, req.filter, req.opts)
response = FindResponseToPB(invitations, total) response = FindResponseToPB(invitations, total)
return return
} }
...@@ -68,9 +60,7 @@ func (s *Server) Find(ctx context.Context, request *pb.FindRequest) (response *p ...@@ -68,9 +60,7 @@ func (s *Server) Find(ctx context.Context, request *pb.FindRequest) (response *p
// Get implements Invitations // Get implements Invitations
func (s *Server) Get(ctx context.Context, request *pb.GetRequest) (response *pb.GetResponse, err error) { func (s *Server) Get(ctx context.Context, request *pb.GetRequest) (response *pb.GetResponse, err error) {
req := GetRequestFromPB(request) req := GetRequestFromPB(request)
invitation, err := s.service.Get(ctx, req.invitationId) invitation, err := s.service.Get(ctx, req.invitationId)
response = GetResponseToPB(invitation) response = GetResponseToPB(invitation)
return return
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment