13481890706

Committed 23 Feb 2025 09:53AM UTC coverage: 46.221% (-12.6%) from 58.825%

Build # 13481890706

Build Type

Pull #9521

github

Committed by

web-flow

Commit Message

Merge 9fb980a6f into 5fe900d18

Pull Request Pull Request #9521: unit: remove GOACC, use Go 1.20 native coverage functionality

Run Details

105094 of 227374 relevant lines covered (46.22%)

19705.84 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/lnrpc/walletunlocker.pb.gw.go

// Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
// source: walletunlocker.proto

/*
Package lnrpc is a reverse proxy.

It translates gRPC into RESTful JSON APIs.
*/
package lnrpc

import (
        "context"
        "io"
        "net/http"

        "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
        "github.com/grpc-ecosystem/grpc-gateway/v2/utilities"
        "google.golang.org/grpc"
        "google.golang.org/grpc/codes"
        "google.golang.org/grpc/grpclog"
        "google.golang.org/grpc/metadata"
        "google.golang.org/grpc/status"
        "google.golang.org/protobuf/proto"
)

// Suppress "imported and not used" errors
var _ codes.Code
var _ io.Reader
var _ status.Status
var _ = runtime.String
var _ = utilities.NewDoubleArray
var _ = metadata.Join

var (
        filter_WalletUnlocker_GenSeed_0 = &utilities.DoubleArray{Encoding: map[string]int{}, Base: []int(nil), Check: []int(nil)}
)

func request_WalletUnlocker_GenSeed_0(ctx context.Context, marshaler runtime.Marshaler, client WalletUnlockerClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
        var protoReq GenSeedRequest
        var metadata runtime.ServerMetadata

        if err := req.ParseForm(); err != nil {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
        }
        if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_WalletUnlocker_GenSeed_0); err != nil {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
        }

        msg, err := client.GenSeed(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
        return msg, metadata, err

}

func local_request_WalletUnlocker_GenSeed_0(ctx context.Context, marshaler runtime.Marshaler, server WalletUnlockerServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
        var protoReq GenSeedRequest
        var metadata runtime.ServerMetadata

        if err := req.ParseForm(); err != nil {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
        }
        if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_WalletUnlocker_GenSeed_0); err != nil {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
        }

        msg, err := server.GenSeed(ctx, &protoReq)
        return msg, metadata, err

}

func request_WalletUnlocker_InitWallet_0(ctx context.Context, marshaler runtime.Marshaler, client WalletUnlockerClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
        var protoReq InitWalletRequest
        var metadata runtime.ServerMetadata

        newReader, berr := utilities.IOReaderFactory(req.Body)
        if berr != nil {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
        }
        if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
        }

        msg, err := client.InitWallet(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
        return msg, metadata, err

}

func local_request_WalletUnlocker_InitWallet_0(ctx context.Context, marshaler runtime.Marshaler, server WalletUnlockerServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
        var protoReq InitWalletRequest
        var metadata runtime.ServerMetadata

        newReader, berr := utilities.IOReaderFactory(req.Body)
        if berr != nil {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
        }
        if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
        }

        msg, err := server.InitWallet(ctx, &protoReq)
        return msg, metadata, err

}

func request_WalletUnlocker_UnlockWallet_0(ctx context.Context, marshaler runtime.Marshaler, client WalletUnlockerClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
        var protoReq UnlockWalletRequest
        var metadata runtime.ServerMetadata

        newReader, berr := utilities.IOReaderFactory(req.Body)
        if berr != nil {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
        }
        if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
        }

        msg, err := client.UnlockWallet(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
        return msg, metadata, err

}

func local_request_WalletUnlocker_UnlockWallet_0(ctx context.Context, marshaler runtime.Marshaler, server WalletUnlockerServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
        var protoReq UnlockWalletRequest
        var metadata runtime.ServerMetadata

        newReader, berr := utilities.IOReaderFactory(req.Body)
        if berr != nil {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
        }
        if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
        }

        msg, err := server.UnlockWallet(ctx, &protoReq)
        return msg, metadata, err

}

func request_WalletUnlocker_ChangePassword_0(ctx context.Context, marshaler runtime.Marshaler, client WalletUnlockerClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
        var protoReq ChangePasswordRequest
        var metadata runtime.ServerMetadata

        newReader, berr := utilities.IOReaderFactory(req.Body)
        if berr != nil {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
        }
        if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
        }

        msg, err := client.ChangePassword(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
        return msg, metadata, err

}

func local_request_WalletUnlocker_ChangePassword_0(ctx context.Context, marshaler runtime.Marshaler, server WalletUnlockerServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
        var protoReq ChangePasswordRequest
        var metadata runtime.ServerMetadata

        newReader, berr := utilities.IOReaderFactory(req.Body)
        if berr != nil {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
        }
        if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
                return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
        }

        msg, err := server.ChangePassword(ctx, &protoReq)
        return msg, metadata, err

}

// RegisterWalletUnlockerHandlerServer registers the http handlers for service WalletUnlocker to "mux".
// UnaryRPC     :call WalletUnlockerServer directly.
// StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
// Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterWalletUnlockerHandlerFromEndpoint instead.
func RegisterWalletUnlockerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WalletUnlockerServer) error {

        mux.Handle("GET", pattern_WalletUnlocker_GenSeed_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
                ctx, cancel := context.WithCancel(req.Context())
                defer cancel()
                var stream runtime.ServerTransportStream
                ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
                inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
                rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/lnrpc.WalletUnlocker/GenSeed", runtime.WithHTTPPathPattern("/v1/genseed"))
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }
                resp, md, err := local_request_WalletUnlocker_GenSeed_0(rctx, inboundMarshaler, server, req, pathParams)
                md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
                ctx = runtime.NewServerMetadataContext(ctx, md)
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }

                forward_WalletUnlocker_GenSeed_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)

        })

        mux.Handle("POST", pattern_WalletUnlocker_InitWallet_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
                ctx, cancel := context.WithCancel(req.Context())
                defer cancel()
                var stream runtime.ServerTransportStream
                ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
                inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
                rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/lnrpc.WalletUnlocker/InitWallet", runtime.WithHTTPPathPattern("/v1/initwallet"))
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }
                resp, md, err := local_request_WalletUnlocker_InitWallet_0(rctx, inboundMarshaler, server, req, pathParams)
                md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
                ctx = runtime.NewServerMetadataContext(ctx, md)
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }

                forward_WalletUnlocker_InitWallet_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)

        })

        mux.Handle("POST", pattern_WalletUnlocker_UnlockWallet_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
                ctx, cancel := context.WithCancel(req.Context())
                defer cancel()
                var stream runtime.ServerTransportStream
                ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
                inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
                rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/lnrpc.WalletUnlocker/UnlockWallet", runtime.WithHTTPPathPattern("/v1/unlockwallet"))
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }
                resp, md, err := local_request_WalletUnlocker_UnlockWallet_0(rctx, inboundMarshaler, server, req, pathParams)
                md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
                ctx = runtime.NewServerMetadataContext(ctx, md)
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }

                forward_WalletUnlocker_UnlockWallet_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)

        })

        mux.Handle("POST", pattern_WalletUnlocker_ChangePassword_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
                ctx, cancel := context.WithCancel(req.Context())
                defer cancel()
                var stream runtime.ServerTransportStream
                ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
                inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
                rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/lnrpc.WalletUnlocker/ChangePassword", runtime.WithHTTPPathPattern("/v1/changepassword"))
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }
                resp, md, err := local_request_WalletUnlocker_ChangePassword_0(rctx, inboundMarshaler, server, req, pathParams)
                md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
                ctx = runtime.NewServerMetadataContext(ctx, md)
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }

                forward_WalletUnlocker_ChangePassword_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)

        })

        return nil
}

// RegisterWalletUnlockerHandlerFromEndpoint is same as RegisterWalletUnlockerHandler but
// automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterWalletUnlockerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
        conn, err := grpc.Dial(endpoint, opts...)
        if err != nil {
                return err
        }
        defer func() {
                if err != nil {
                        if cerr := conn.Close(); cerr != nil {
                                grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
                        }
                        return
                }
                go func() {
                        <-ctx.Done()
                        if cerr := conn.Close(); cerr != nil {
                                grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
                        }
                }()
        }()

        return RegisterWalletUnlockerHandler(ctx, mux, conn)
}

// RegisterWalletUnlockerHandler registers the http handlers for service WalletUnlocker to "mux".
// The handlers forward requests to the grpc endpoint over "conn".
func RegisterWalletUnlockerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
        return RegisterWalletUnlockerHandlerClient(ctx, mux, NewWalletUnlockerClient(conn))
}

// RegisterWalletUnlockerHandlerClient registers the http handlers for service WalletUnlocker
// to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "WalletUnlockerClient".
// Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "WalletUnlockerClient"
// doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
// "WalletUnlockerClient" to call the correct interceptors.
func RegisterWalletUnlockerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WalletUnlockerClient) error {

        mux.Handle("GET", pattern_WalletUnlocker_GenSeed_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
                ctx, cancel := context.WithCancel(req.Context())
                defer cancel()
                inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
                rctx, err := runtime.AnnotateContext(ctx, mux, req, "/lnrpc.WalletUnlocker/GenSeed", runtime.WithHTTPPathPattern("/v1/genseed"))
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }
                resp, md, err := request_WalletUnlocker_GenSeed_0(rctx, inboundMarshaler, client, req, pathParams)
                ctx = runtime.NewServerMetadataContext(ctx, md)
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }

                forward_WalletUnlocker_GenSeed_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)

        })

        mux.Handle("POST", pattern_WalletUnlocker_InitWallet_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
                ctx, cancel := context.WithCancel(req.Context())
                defer cancel()
                inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
                rctx, err := runtime.AnnotateContext(ctx, mux, req, "/lnrpc.WalletUnlocker/InitWallet", runtime.WithHTTPPathPattern("/v1/initwallet"))
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }
                resp, md, err := request_WalletUnlocker_InitWallet_0(rctx, inboundMarshaler, client, req, pathParams)
                ctx = runtime.NewServerMetadataContext(ctx, md)
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }

                forward_WalletUnlocker_InitWallet_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)

        })

        mux.Handle("POST", pattern_WalletUnlocker_UnlockWallet_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
                ctx, cancel := context.WithCancel(req.Context())
                defer cancel()
                inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
                rctx, err := runtime.AnnotateContext(ctx, mux, req, "/lnrpc.WalletUnlocker/UnlockWallet", runtime.WithHTTPPathPattern("/v1/unlockwallet"))
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }
                resp, md, err := request_WalletUnlocker_UnlockWallet_0(rctx, inboundMarshaler, client, req, pathParams)
                ctx = runtime.NewServerMetadataContext(ctx, md)
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }

                forward_WalletUnlocker_UnlockWallet_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)

        })

        mux.Handle("POST", pattern_WalletUnlocker_ChangePassword_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
                ctx, cancel := context.WithCancel(req.Context())
                defer cancel()
                inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
                rctx, err := runtime.AnnotateContext(ctx, mux, req, "/lnrpc.WalletUnlocker/ChangePassword", runtime.WithHTTPPathPattern("/v1/changepassword"))
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }
                resp, md, err := request_WalletUnlocker_ChangePassword_0(rctx, inboundMarshaler, client, req, pathParams)
                ctx = runtime.NewServerMetadataContext(ctx, md)
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }

                forward_WalletUnlocker_ChangePassword_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)

        })

        return nil
}

var (
        pattern_WalletUnlocker_GenSeed_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "genseed"}, ""))

        pattern_WalletUnlocker_InitWallet_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "initwallet"}, ""))

        pattern_WalletUnlocker_UnlockWallet_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "unlockwallet"}, ""))

        pattern_WalletUnlocker_ChangePassword_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "changepassword"}, ""))
)

var (
        forward_WalletUnlocker_GenSeed_0 = runtime.ForwardResponseMessage

        forward_WalletUnlocker_InitWallet_0 = runtime.ForwardResponseMessage

        forward_WalletUnlocker_UnlockWallet_0 = runtime.ForwardResponseMessage

        forward_WalletUnlocker_ChangePassword_0 = runtime.ForwardResponseMessage
)

1	// Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
2	// source: walletunlocker.proto
3
4	/*
5	Package lnrpc is a reverse proxy.
6
7	It translates gRPC into RESTful JSON APIs.
8	*/
9	package lnrpc
10
11	import (
12	"context"
13	"io"
14	"net/http"
15
16	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
17	"github.com/grpc-ecosystem/grpc-gateway/v2/utilities"
18	"google.golang.org/grpc"
19	"google.golang.org/grpc/codes"
20	"google.golang.org/grpc/grpclog"
21	"google.golang.org/grpc/metadata"
22	"google.golang.org/grpc/status"
23	"google.golang.org/protobuf/proto"
24	)
25
26	// Suppress "imported and not used" errors
27	var _ codes.Code
28	var _ io.Reader
29	var _ status.Status
30	var _ = runtime.String
31	var _ = utilities.NewDoubleArray
32	var _ = metadata.Join
33
34	var (
35	filter_WalletUnlocker_GenSeed_0 = &utilities.DoubleArray{Encoding: map[string]int{}, Base: []int(nil), Check: []int(nil)}
36	)
37
38	func request_WalletUnlocker_GenSeed_0(ctx context.Context, marshaler runtime.Marshaler, client WalletUnlockerClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {	×
39	var protoReq GenSeedRequest	×
40	var metadata runtime.ServerMetadata	×
41		×
42	if err := req.ParseForm(); err != nil {	×
43	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)	×
44	}	×
45	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_WalletUnlocker_GenSeed_0); err != nil {	×
46	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)	×
47	}	×
48
49	msg, err := client.GenSeed(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))	×
50	return msg, metadata, err	×
51
52	}
53
54	func local_request_WalletUnlocker_GenSeed_0(ctx context.Context, marshaler runtime.Marshaler, server WalletUnlockerServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {	×
55	var protoReq GenSeedRequest	×
56	var metadata runtime.ServerMetadata	×
57		×
58	if err := req.ParseForm(); err != nil {	×
59	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)	×
60	}	×
61	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_WalletUnlocker_GenSeed_0); err != nil {	×
62	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)	×
63	}	×
64
65	msg, err := server.GenSeed(ctx, &protoReq)	×
66	return msg, metadata, err	×
67
68	}
69
70	func request_WalletUnlocker_InitWallet_0(ctx context.Context, marshaler runtime.Marshaler, client WalletUnlockerClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {	×
71	var protoReq InitWalletRequest	×
72	var metadata runtime.ServerMetadata	×
73		×
74	newReader, berr := utilities.IOReaderFactory(req.Body)	×
75	if berr != nil {	×
76	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)	×
77	}	×
78	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {	×
79	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)	×
80	}	×
81
82	msg, err := client.InitWallet(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))	×
83	return msg, metadata, err	×
84
85	}
86
87	func local_request_WalletUnlocker_InitWallet_0(ctx context.Context, marshaler runtime.Marshaler, server WalletUnlockerServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {	×
88	var protoReq InitWalletRequest	×
89	var metadata runtime.ServerMetadata	×
90		×
91	newReader, berr := utilities.IOReaderFactory(req.Body)	×
92	if berr != nil {	×
93	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)	×
94	}	×
95	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {	×
96	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)	×
97	}	×
98
99	msg, err := server.InitWallet(ctx, &protoReq)	×
100	return msg, metadata, err	×
101
102	}
103
104	func request_WalletUnlocker_UnlockWallet_0(ctx context.Context, marshaler runtime.Marshaler, client WalletUnlockerClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {	×
105	var protoReq UnlockWalletRequest	×
106	var metadata runtime.ServerMetadata	×
107		×
108	newReader, berr := utilities.IOReaderFactory(req.Body)	×
109	if berr != nil {	×
110	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)	×
111	}	×
112	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {	×
113	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)	×
114	}	×
115
116	msg, err := client.UnlockWallet(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))	×
117	return msg, metadata, err	×
118
119	}
120
121	func local_request_WalletUnlocker_UnlockWallet_0(ctx context.Context, marshaler runtime.Marshaler, server WalletUnlockerServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {	×
122	var protoReq UnlockWalletRequest	×
123	var metadata runtime.ServerMetadata	×
124		×
125	newReader, berr := utilities.IOReaderFactory(req.Body)	×
126	if berr != nil {	×
127	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)	×
128	}	×
129	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {	×
130	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)	×
131	}	×
132
133	msg, err := server.UnlockWallet(ctx, &protoReq)	×
134	return msg, metadata, err	×
135
136	}
137
138	func request_WalletUnlocker_ChangePassword_0(ctx context.Context, marshaler runtime.Marshaler, client WalletUnlockerClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {	×
139	var protoReq ChangePasswordRequest	×
140	var metadata runtime.ServerMetadata	×
141		×
142	newReader, berr := utilities.IOReaderFactory(req.Body)	×
143	if berr != nil {	×
144	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)	×
145	}	×
146	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {	×
147	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)	×
148	}	×
149
150	msg, err := client.ChangePassword(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))	×
151	return msg, metadata, err	×
152
153	}
154
155	func local_request_WalletUnlocker_ChangePassword_0(ctx context.Context, marshaler runtime.Marshaler, server WalletUnlockerServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {	×
156	var protoReq ChangePasswordRequest	×
157	var metadata runtime.ServerMetadata	×
158		×
159	newReader, berr := utilities.IOReaderFactory(req.Body)	×
160	if berr != nil {	×
161	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)	×
162	}	×
163	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {	×
164	return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)	×
165	}	×
166
167	msg, err := server.ChangePassword(ctx, &protoReq)	×
168	return msg, metadata, err	×
169
170	}
171
172	// RegisterWalletUnlockerHandlerServer registers the http handlers for service WalletUnlocker to "mux".
173	// UnaryRPC :call WalletUnlockerServer directly.
174	// StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
175	// Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterWalletUnlockerHandlerFromEndpoint instead.
176	func RegisterWalletUnlockerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WalletUnlockerServer) error {	×
177		×
178	mux.Handle("GET", pattern_WalletUnlocker_GenSeed_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {	×
179	ctx, cancel := context.WithCancel(req.Context())	×
180	defer cancel()	×
181	var stream runtime.ServerTransportStream	×
182	ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)	×
183	inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)	×
184	rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/lnrpc.WalletUnlocker/GenSeed", runtime.WithHTTPPathPattern("/v1/genseed"))	×
185	if err != nil {	×
186	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
187	return	×
188	}	×
189	resp, md, err := local_request_WalletUnlocker_GenSeed_0(rctx, inboundMarshaler, server, req, pathParams)	×
190	md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())	×
191	ctx = runtime.NewServerMetadataContext(ctx, md)	×
192	if err != nil {	×
193	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
194	return	×
195	}	×
196
197	forward_WalletUnlocker_GenSeed_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)	×
198
199	})
200
201	mux.Handle("POST", pattern_WalletUnlocker_InitWallet_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {	×
202	ctx, cancel := context.WithCancel(req.Context())	×
203	defer cancel()	×
204	var stream runtime.ServerTransportStream	×
205	ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)	×
206	inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)	×
207	rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/lnrpc.WalletUnlocker/InitWallet", runtime.WithHTTPPathPattern("/v1/initwallet"))	×
208	if err != nil {	×
209	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
210	return	×
211	}	×
212	resp, md, err := local_request_WalletUnlocker_InitWallet_0(rctx, inboundMarshaler, server, req, pathParams)	×
213	md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())	×
214	ctx = runtime.NewServerMetadataContext(ctx, md)	×
215	if err != nil {	×
216	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
217	return	×
218	}	×
219
220	forward_WalletUnlocker_InitWallet_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)	×
221
222	})
223
224	mux.Handle("POST", pattern_WalletUnlocker_UnlockWallet_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {	×
225	ctx, cancel := context.WithCancel(req.Context())	×
226	defer cancel()	×
227	var stream runtime.ServerTransportStream	×
228	ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)	×
229	inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)	×
230	rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/lnrpc.WalletUnlocker/UnlockWallet", runtime.WithHTTPPathPattern("/v1/unlockwallet"))	×
231	if err != nil {	×
232	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
233	return	×
234	}	×
235	resp, md, err := local_request_WalletUnlocker_UnlockWallet_0(rctx, inboundMarshaler, server, req, pathParams)	×
236	md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())	×
237	ctx = runtime.NewServerMetadataContext(ctx, md)	×
238	if err != nil {	×
239	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
240	return	×
241	}	×
242
243	forward_WalletUnlocker_UnlockWallet_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)	×
244
245	})
246
247	mux.Handle("POST", pattern_WalletUnlocker_ChangePassword_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {	×
248	ctx, cancel := context.WithCancel(req.Context())	×
249	defer cancel()	×
250	var stream runtime.ServerTransportStream	×
251	ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)	×
252	inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)	×
253	rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/lnrpc.WalletUnlocker/ChangePassword", runtime.WithHTTPPathPattern("/v1/changepassword"))	×
254	if err != nil {	×
255	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
256	return	×
257	}	×
258	resp, md, err := local_request_WalletUnlocker_ChangePassword_0(rctx, inboundMarshaler, server, req, pathParams)	×
259	md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())	×
260	ctx = runtime.NewServerMetadataContext(ctx, md)	×
261	if err != nil {	×
262	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
263	return	×
264	}	×
265
266	forward_WalletUnlocker_ChangePassword_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)	×
267
268	})
269
270	return nil	×
271	}
272
273	// RegisterWalletUnlockerHandlerFromEndpoint is same as RegisterWalletUnlockerHandler but
274	// automatically dials to "endpoint" and closes the connection when "ctx" gets done.
275	func RegisterWalletUnlockerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {	×
276	conn, err := grpc.Dial(endpoint, opts...)	×
277	if err != nil {	×
278	return err	×
279	}	×
280	defer func() {	×
281	if err != nil {	×
282	if cerr := conn.Close(); cerr != nil {	×
283	grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)	×
284	}	×
285	return	×
286	}
287	go func() {	×
288	<-ctx.Done()	×
289	if cerr := conn.Close(); cerr != nil {	×
290	grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)	×
291	}	×
292	}()
293	}()
294
295	return RegisterWalletUnlockerHandler(ctx, mux, conn)	×
296	}
297
298	// RegisterWalletUnlockerHandler registers the http handlers for service WalletUnlocker to "mux".
299	// The handlers forward requests to the grpc endpoint over "conn".
300	func RegisterWalletUnlockerHandler(ctx context.Context, mux runtime.ServeMux, conn grpc.ClientConn) error {	×
301	return RegisterWalletUnlockerHandlerClient(ctx, mux, NewWalletUnlockerClient(conn))	×
302	}	×
303
304	// RegisterWalletUnlockerHandlerClient registers the http handlers for service WalletUnlocker
305	// to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "WalletUnlockerClient".
306	// Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "WalletUnlockerClient"
307	// doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
308	// "WalletUnlockerClient" to call the correct interceptors.
309	func RegisterWalletUnlockerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WalletUnlockerClient) error {	×
310		×
311	mux.Handle("GET", pattern_WalletUnlocker_GenSeed_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {	×
312	ctx, cancel := context.WithCancel(req.Context())	×
313	defer cancel()	×
314	inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)	×
315	rctx, err := runtime.AnnotateContext(ctx, mux, req, "/lnrpc.WalletUnlocker/GenSeed", runtime.WithHTTPPathPattern("/v1/genseed"))	×
316	if err != nil {	×
317	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
318	return	×
319	}	×
320	resp, md, err := request_WalletUnlocker_GenSeed_0(rctx, inboundMarshaler, client, req, pathParams)	×
321	ctx = runtime.NewServerMetadataContext(ctx, md)	×
322	if err != nil {	×
323	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
324	return	×
325	}	×
326
327	forward_WalletUnlocker_GenSeed_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)	×
328
329	})
330
331	mux.Handle("POST", pattern_WalletUnlocker_InitWallet_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {	×
332	ctx, cancel := context.WithCancel(req.Context())	×
333	defer cancel()	×
334	inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)	×
335	rctx, err := runtime.AnnotateContext(ctx, mux, req, "/lnrpc.WalletUnlocker/InitWallet", runtime.WithHTTPPathPattern("/v1/initwallet"))	×
336	if err != nil {	×
337	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
338	return	×
339	}	×
340	resp, md, err := request_WalletUnlocker_InitWallet_0(rctx, inboundMarshaler, client, req, pathParams)	×
341	ctx = runtime.NewServerMetadataContext(ctx, md)	×
342	if err != nil {	×
343	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
344	return	×
345	}	×
346
347	forward_WalletUnlocker_InitWallet_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)	×
348
349	})
350
351	mux.Handle("POST", pattern_WalletUnlocker_UnlockWallet_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {	×
352	ctx, cancel := context.WithCancel(req.Context())	×
353	defer cancel()	×
354	inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)	×
355	rctx, err := runtime.AnnotateContext(ctx, mux, req, "/lnrpc.WalletUnlocker/UnlockWallet", runtime.WithHTTPPathPattern("/v1/unlockwallet"))	×
356	if err != nil {	×
357	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
358	return	×
359	}	×
360	resp, md, err := request_WalletUnlocker_UnlockWallet_0(rctx, inboundMarshaler, client, req, pathParams)	×
361	ctx = runtime.NewServerMetadataContext(ctx, md)	×
362	if err != nil {	×
363	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
364	return	×
365	}	×
366
367	forward_WalletUnlocker_UnlockWallet_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)	×
368
369	})
370
371	mux.Handle("POST", pattern_WalletUnlocker_ChangePassword_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {	×
372	ctx, cancel := context.WithCancel(req.Context())	×
373	defer cancel()	×
374	inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)	×
375	rctx, err := runtime.AnnotateContext(ctx, mux, req, "/lnrpc.WalletUnlocker/ChangePassword", runtime.WithHTTPPathPattern("/v1/changepassword"))	×
376	if err != nil {	×
377	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
378	return	×
379	}	×
380	resp, md, err := request_WalletUnlocker_ChangePassword_0(rctx, inboundMarshaler, client, req, pathParams)	×
381	ctx = runtime.NewServerMetadataContext(ctx, md)	×
382	if err != nil {	×
383	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
384	return	×
385	}	×
386
387	forward_WalletUnlocker_ChangePassword_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)	×
388
389	})
390
391	return nil	×
392	}
393
394	var (
395	pattern_WalletUnlocker_GenSeed_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "genseed"}, ""))
396
397	pattern_WalletUnlocker_InitWallet_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "initwallet"}, ""))
398
399	pattern_WalletUnlocker_UnlockWallet_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "unlockwallet"}, ""))
400
401	pattern_WalletUnlocker_ChangePassword_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "changepassword"}, ""))
402	)
403
404	var (
405	forward_WalletUnlocker_GenSeed_0 = runtime.ForwardResponseMessage
406
407	forward_WalletUnlocker_InitWallet_0 = runtime.ForwardResponseMessage
408
409	forward_WalletUnlocker_UnlockWallet_0 = runtime.ForwardResponseMessage
410
411	forward_WalletUnlocker_ChangePassword_0 = runtime.ForwardResponseMessage
412	)

lightningnetwork / lnd / 13481890706

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous