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/watchtowerrpc/watchtower.pb.gw.go

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

/*
Package watchtowerrpc is a reverse proxy.

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

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

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

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

}

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

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

}

// RegisterWatchtowerHandlerServer registers the http handlers for service Watchtower to "mux".
// UnaryRPC     :call WatchtowerServer 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 RegisterWatchtowerHandlerFromEndpoint instead.
func RegisterWatchtowerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WatchtowerServer) error {

        mux.Handle("GET", pattern_Watchtower_GetInfo_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, "/watchtowerrpc.Watchtower/GetInfo", runtime.WithHTTPPathPattern("/v2/watchtower/server"))
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }
                resp, md, err := local_request_Watchtower_GetInfo_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_Watchtower_GetInfo_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)

        })

        return nil
}

// RegisterWatchtowerHandlerFromEndpoint is same as RegisterWatchtowerHandler but
// automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterWatchtowerHandlerFromEndpoint(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 RegisterWatchtowerHandler(ctx, mux, conn)
}

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

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

        mux.Handle("GET", pattern_Watchtower_GetInfo_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, "/watchtowerrpc.Watchtower/GetInfo", runtime.WithHTTPPathPattern("/v2/watchtower/server"))
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }
                resp, md, err := request_Watchtower_GetInfo_0(rctx, inboundMarshaler, client, req, pathParams)
                ctx = runtime.NewServerMetadataContext(ctx, md)
                if err != nil {
                        runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
                        return
                }

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

        })

        return nil
}

var (
        pattern_Watchtower_GetInfo_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v2", "watchtower", "server"}, ""))
)

var (
        forward_Watchtower_GetInfo_0 = runtime.ForwardResponseMessage
)

1	// Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
2	// source: watchtowerrpc/watchtower.proto
3
4	/*
5	Package watchtowerrpc is a reverse proxy.
6
7	It translates gRPC into RESTful JSON APIs.
8	*/
9	package watchtowerrpc
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	func request_Watchtower_GetInfo_0(ctx context.Context, marshaler runtime.Marshaler, client WatchtowerClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {	×
35	var protoReq GetInfoRequest	×
36	var metadata runtime.ServerMetadata	×
37		×
38	msg, err := client.GetInfo(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))	×
39	return msg, metadata, err	×
40		×
41	}	×
42
43	func local_request_Watchtower_GetInfo_0(ctx context.Context, marshaler runtime.Marshaler, server WatchtowerServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {	×
44	var protoReq GetInfoRequest	×
45	var metadata runtime.ServerMetadata	×
46		×
47	msg, err := server.GetInfo(ctx, &protoReq)	×
48	return msg, metadata, err	×
49		×
50	}	×
51
52	// RegisterWatchtowerHandlerServer registers the http handlers for service Watchtower to "mux".
53	// UnaryRPC :call WatchtowerServer directly.
54	// StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
55	// Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterWatchtowerHandlerFromEndpoint instead.
56	func RegisterWatchtowerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WatchtowerServer) error {	×
57		×
58	mux.Handle("GET", pattern_Watchtower_GetInfo_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {	×
59	ctx, cancel := context.WithCancel(req.Context())	×
60	defer cancel()	×
61	var stream runtime.ServerTransportStream	×
62	ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)	×
63	inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)	×
64	rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/watchtowerrpc.Watchtower/GetInfo", runtime.WithHTTPPathPattern("/v2/watchtower/server"))	×
65	if err != nil {	×
66	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
67	return	×
68	}	×
69	resp, md, err := local_request_Watchtower_GetInfo_0(rctx, inboundMarshaler, server, req, pathParams)	×
70	md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())	×
71	ctx = runtime.NewServerMetadataContext(ctx, md)	×
72	if err != nil {	×
73	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
74	return	×
75	}	×
76
77	forward_Watchtower_GetInfo_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)	×
78
79	})
80
81	return nil	×
82	}
83
84	// RegisterWatchtowerHandlerFromEndpoint is same as RegisterWatchtowerHandler but
85	// automatically dials to "endpoint" and closes the connection when "ctx" gets done.
86	func RegisterWatchtowerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {	×
87	conn, err := grpc.Dial(endpoint, opts...)	×
88	if err != nil {	×
89	return err	×
90	}	×
91	defer func() {	×
92	if err != nil {	×
93	if cerr := conn.Close(); cerr != nil {	×
94	grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)	×
95	}	×
96	return	×
97	}
98	go func() {	×
99	<-ctx.Done()	×
100	if cerr := conn.Close(); cerr != nil {	×
101	grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)	×
102	}	×
103	}()
104	}()
105
106	return RegisterWatchtowerHandler(ctx, mux, conn)	×
107	}
108
109	// RegisterWatchtowerHandler registers the http handlers for service Watchtower to "mux".
110	// The handlers forward requests to the grpc endpoint over "conn".
111	func RegisterWatchtowerHandler(ctx context.Context, mux runtime.ServeMux, conn grpc.ClientConn) error {	×
112	return RegisterWatchtowerHandlerClient(ctx, mux, NewWatchtowerClient(conn))	×
113	}	×
114
115	// RegisterWatchtowerHandlerClient registers the http handlers for service Watchtower
116	// to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "WatchtowerClient".
117	// Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "WatchtowerClient"
118	// doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
119	// "WatchtowerClient" to call the correct interceptors.
120	func RegisterWatchtowerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WatchtowerClient) error {	×
121		×
122	mux.Handle("GET", pattern_Watchtower_GetInfo_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {	×
123	ctx, cancel := context.WithCancel(req.Context())	×
124	defer cancel()	×
125	inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)	×
126	rctx, err := runtime.AnnotateContext(ctx, mux, req, "/watchtowerrpc.Watchtower/GetInfo", runtime.WithHTTPPathPattern("/v2/watchtower/server"))	×
127	if err != nil {	×
128	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
129	return	×
130	}	×
131	resp, md, err := request_Watchtower_GetInfo_0(rctx, inboundMarshaler, client, req, pathParams)	×
132	ctx = runtime.NewServerMetadataContext(ctx, md)	×
133	if err != nil {	×
134	runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)	×
135	return	×
136	}	×
137
138	forward_Watchtower_GetInfo_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)	×
139
140	})
141
142	return nil	×
143	}
144
145	var (
146	pattern_Watchtower_GetInfo_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v2", "watchtower", "server"}, ""))
147	)
148
149	var (
150	forward_Watchtower_GetInfo_0 = runtime.ForwardResponseMessage
151	)

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