@@ -27,6 +27,7 @@ import (
27
27
"github.com/lightninglabs/lightning-terminal/perms"
28
28
"github.com/lightninglabs/lightning-terminal/queue"
29
29
mid "github.com/lightninglabs/lightning-terminal/rpcmiddleware"
30
+ "github.com/lightninglabs/lightning-terminal/rules"
30
31
"github.com/lightninglabs/lightning-terminal/session"
31
32
"github.com/lightninglabs/lndclient"
32
33
"github.com/lightninglabs/loop"
@@ -154,6 +155,8 @@ type LightningTerminal struct {
154
155
faradayServer * frdrpcserver.RPCServer
155
156
faradayStarted bool
156
157
158
+ ruleMgrs rules.ManagerSet
159
+
157
160
loopServer * loopd.Daemon
158
161
loopStarted bool
159
162
@@ -246,6 +249,9 @@ func (g *LightningTerminal) Run() error {
246
249
g .accountRpcServer = accounts .NewRPCServer (
247
250
g .accountService , superMacBaker ,
248
251
)
252
+
253
+ g .ruleMgrs = rules .NewRuleManagerSet ()
254
+
249
255
g .sessionRpcServer , err = newSessionRPCServer (& sessionRpcServerConfig {
250
256
basicAuth : g .rpcProxy .basicAuth ,
251
257
dbDir : filepath .Join (g .cfg .LitDir , g .cfg .Network ),
@@ -975,6 +981,13 @@ func (g *LightningTerminal) shutdown() error {
975
981
g .middleware .Stop ()
976
982
}
977
983
984
+ if g .ruleMgrs != nil {
985
+ if err := g .ruleMgrs .Stop (); err != nil {
986
+ log .Errorf ("Error stopping rule manager set: %v" , err )
987
+ returnErr = err
988
+ }
989
+ }
990
+
978
991
if g .lndClient != nil {
979
992
g .lndClient .Close ()
980
993
}
0 commit comments