loopd: wire recovery service into daemon startup

Register a recovery gRPC endpoint, attach the new recovery package to the
swap client server, and have daemon startup write an encrypted backup file
whenever recoverable static-address or l402 state already exists locally.

Author: hieblmi

loopd/daemon.go

@@ -22,6 +22,7 @@ import (
 	"github.com/lightninglabs/loop/loopdb"
 	loop_looprpc "github.com/lightninglabs/loop/looprpc"
 	"github.com/lightninglabs/loop/notifications"
+	"github.com/lightninglabs/loop/recovery"
 	"github.com/lightninglabs/loop/staticaddr/address"
 	"github.com/lightninglabs/loop/staticaddr/deposit"
 	"github.com/lightninglabs/loop/staticaddr/loopin"
@@ -255,6 +256,7 @@ func (d *Daemon) startWebServers() error {
 		grpc.StreamInterceptor(streamInterceptor),
 	)
 	loop_looprpc.RegisterSwapClientServer(d.grpcServer, d)
+	d.grpcServer.RegisterService(&recoveryServiceDesc, d)
 
 	// Register our debug server if it is compiled in.
 	d.registerDebugServer()
@@ -689,6 +691,18 @@ func (d *Daemon) initialize(withMacaroonService bool) error {
 		return fmt.Errorf("unable to create loop-in manager: %w", err)
 	}
 
+	recoveryService := recovery.NewService(
+		d.cfg.DataDir, d.cfg.Network, d.lnd.Signer, d.lnd.WalletKit,
+		staticAddressManager, depositManager,
+	)
+	backupFile, err := recoveryService.WriteBackup(d.mainCtx)
+	if err != nil {
+		return fmt.Errorf("unable to write backup file: %w", err)
+	}
+	if backupFile != "" {
+		infof("Wrote encrypted backup file to %s", backupFile)
+	}
+
 	var (
 		reservationManager *reservation.Manager
 		instantOutManager  *instantout.Manager
@@ -753,6 +767,7 @@ func (d *Daemon) initialize(withMacaroonService bool) error {
 		staticLoopInManager:  staticLoopInManager,
 		openChannelManager:   openChannelManager,
 		assetClient:          d.assetClient,
+		recoveryService:      recoveryService,
 		stopDaemon:           d.Stop,
 	}
 

loopd/recovery_service.go

@@ -0,0 +1,77 @@
+package loopd
+
+import (
+	"context"
+
+	"google.golang.org/grpc"
+	"google.golang.org/protobuf/types/known/structpb"
+	"google.golang.org/protobuf/types/known/wrapperspb"
+)
+
+type recoveryServer interface {
+	Recover(context.Context, *wrapperspb.StringValue) (*structpb.Struct,
+		error)
+}
+
+var recoveryServiceDesc = grpc.ServiceDesc{
+	ServiceName: "looprpc.Recovery",
+	HandlerType: (*recoveryServer)(nil),
+	Methods: []grpc.MethodDesc{{
+		MethodName: "Recover",
+		Handler:    recoveryHandler,
+	}},
+	Metadata: "loopd/recovery_service.go",
+}
+
+func recoveryHandler(srv interface{}, ctx context.Context,
+	dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (
+	interface{}, error) {
+
+	in := new(wrapperspb.StringValue)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+
+	if interceptor == nil {
+		return srv.(recoveryServer).Recover(ctx, in)
+	}
+
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/looprpc.Recovery/Recover",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(recoveryServer).Recover(
+			ctx, req.(*wrapperspb.StringValue),
+		)
+	}
+
+	return interceptor(ctx, in, info, handler)
+}
+
+// Recover restores the local L402 token material and static address state from
+// an encrypted backup file.
+func (s *swapClientServer) Recover(ctx context.Context,
+	req *wrapperspb.StringValue) (*structpb.Struct, error) {
+
+	result, err := s.recoveryService.Restore(ctx, req.GetValue())
+	if err != nil {
+		return nil, err
+	}
+
+	values := map[string]any{
+		"backup_file":             result.BackupFile,
+		"restored_l402":           result.RestoredL402,
+		"restored_static_address": result.RestoredStaticAddress,
+		"num_deposits_found":      result.NumDepositsFound,
+	}
+	if result.StaticAddress != "" {
+		values["static_address"] = result.StaticAddress
+	}
+	if result.DepositReconciliationError != "" {
+		values["deposit_reconciliation_error"] =
+			result.DepositReconciliationError
+	}
+
+	return structpb.NewStruct(values)
+}

loopd/swapclient_server.go

@@ -29,6 +29,7 @@ import (
 	"github.com/lightninglabs/loop/liquidity"
 	"github.com/lightninglabs/loop/loopdb"
 	"github.com/lightninglabs/loop/looprpc"
+	"github.com/lightninglabs/loop/recovery"
 	"github.com/lightninglabs/loop/staticaddr/address"
 	"github.com/lightninglabs/loop/staticaddr/deposit"
 	"github.com/lightninglabs/loop/staticaddr/loopin"
@@ -101,6 +102,7 @@ type swapClientServer struct {
 	staticLoopInManager  *loopin.Manager
 	openChannelManager   *openchannel.Manager
 	assetClient          *assets.TapdClient
+	recoveryService      *recovery.Service
 	swaps                map[lntypes.Hash]loop.SwapInfo
 	subscribers          map[int]chan<- any
 	statusChan           chan loop.SwapInfo