@@ -23,6 +23,7 @@ import (
23
23
"github.com/lightninglabs/faraday/frdrpcserver"
24
24
"github.com/lightninglabs/lightning-terminal/accounts"
25
25
"github.com/lightninglabs/lightning-terminal/firewall"
26
+ "github.com/lightninglabs/lightning-terminal/firewalldb"
26
27
"github.com/lightninglabs/lightning-terminal/litrpc"
27
28
"github.com/lightninglabs/lightning-terminal/perms"
28
29
"github.com/lightninglabs/lightning-terminal/queue"
@@ -180,6 +181,8 @@ type LightningTerminal struct {
180
181
181
182
accountRpcServer * accounts.RPCServer
182
183
184
+ firewallDB * firewalldb.DB
185
+
183
186
restHandler http.Handler
184
187
restCancel func ()
185
188
}
@@ -252,6 +255,12 @@ func (g *LightningTerminal) Run() error {
252
255
253
256
g .ruleMgrs = rules .NewRuleManagerSet ()
254
257
258
+ networkDir := filepath .Join (g .cfg .LitDir , g .cfg .Network )
259
+ g .firewallDB , err = firewalldb .NewDB (networkDir , firewalldb .DBFilename )
260
+ if err != nil {
261
+ return fmt .Errorf ("error creating session DB: %v" , err )
262
+ }
263
+
255
264
g .sessionRpcServer , err = newSessionRPCServer (& sessionRpcServerConfig {
256
265
basicAuth : g .rpcProxy .basicAuth ,
257
266
dbDir : filepath .Join (g .cfg .LitDir , g .cfg .Network ),
@@ -981,6 +990,13 @@ func (g *LightningTerminal) shutdown() error {
981
990
g .middleware .Stop ()
982
991
}
983
992
993
+ if g .firewallDB != nil {
994
+ if err := g .firewallDB .Close (); err != nil {
995
+ log .Errorf ("Error closing rules DB: %v" , err )
996
+ returnErr = err
997
+ }
998
+ }
999
+
984
1000
if g .ruleMgrs != nil {
985
1001
if err := g .ruleMgrs .Stop (); err != nil {
986
1002
log .Errorf ("Error stopping rule manager set: %v" , err )
0 commit comments