Merge pull request #7875 from ellemouton/moveStateServerRestRegister
refactor: move State server REST registration
This commit is contained in:
2 files changed
+10
-8
No files matched your search
@@ -901,14 +901,7 @@ func startRestProxy(cfg *Config, rpcServer *rpcServer, restDialOpts []grpc.DialO
|
|||||||
)
|
)
|
||||||
|
|
||||||
// Register our services with the REST proxy.
|
// Register our services with the REST proxy.
|
||||||
err := lnrpc.RegisterStateHandlerFromEndpoint(
|
err := rpcServer.RegisterWithRestProxy(
|
||||||
ctx, mux, restProxyDest, restDialOpts,
|
|
||||||
)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
err = rpcServer.RegisterWithRestProxy(
|
|
||||||
ctx, mux, restDialOpts, restProxyDest,
|
ctx, mux, restDialOpts, restProxyDest,
|
||||||
)
|
)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
@@ -906,6 +906,15 @@ func (r *rpcServer) RegisterWithRestProxy(restCtx context.Context,
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Register our State service with the REST proxy.
|
||||||
|
err = lnrpc.RegisterStateHandlerFromEndpoint(
|
||||||
|
restCtx, restMux, restProxyDest, restDialOpts,
|
||||||
|
)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// Register all the subservers with the REST proxy.
|
||||||
for _, subServer := range r.subGrpcHandlers {
|
for _, subServer := range r.subGrpcHandlers {
|
||||||
err := subServer.RegisterWithRestServer(
|
err := subServer.RegisterWithRestServer(
|
||||||
restCtx, restMux, restProxyDest, restDialOpts,
|
restCtx, restMux, restProxyDest, restDialOpts,
|
||||||
|
|||||||
Reference in new issue
Block a user