loop: add manual static deposit recovery

Add recoverdeposit CLI/RPC support for verifying one static-address output on-chain, matching it to a derived static address, restoring the address/import, and directly creating or reactivating the deposit row.

The recovery request also accepts optional seed metadata so operators can recover deposits before the local static-address seed row has been restored.

Author: hieblmi

cmd/loop/main.go

@@ -89,6 +89,7 @@ var (
 		listSwapsCommand, swapInfoCommand, getLiquidityParamsCommand,
 		setLiquidityRuleCommand, suggestSwapCommand, setParamsCommand,
 		getInfoCommand, abandonSwapCommand, recoverCommand,
+		recoverDepositCommand,
 		reservationsCommands,
 		instantOutCommand, listInstantOutsCommand, stopCommand,
 		printManCommand, printMarkdownCommand,

cmd/loop/recover.go

@@ -25,6 +25,42 @@ var recoverCommand = &cli.Command{
 	Action: runRecover,
 }
 
+var recoverDepositCommand = &cli.Command{
+	Name:  "recoverdeposit",
+	Usage: "recover one static address deposit from on-chain data",
+	Description: "Verifies the provided transaction output on-chain, " +
+		"restores the matching static address, stores the deposit, and " +
+		"starts normal deposit tracking.",
+	Flags: []cli.Flag{
+		&cli.StringFlag{
+			Name:     "txid",
+			Usage:    "transaction ID containing the deposit output",
+			Required: true,
+		},
+		&cli.UintFlag{
+			Name:     "vout",
+			Usage:    "deposit output index",
+			Required: true,
+		},
+		&cli.IntFlag{
+			Name:     "height_hint",
+			Usage:    "block height hint for the deposit transaction",
+			Required: true,
+		},
+		&cli.StringFlag{
+			Name:     "pkscript_hex",
+			Usage:    "expected static address P2TR pkScript in hex",
+			Required: true,
+		},
+		&cli.UintFlag{
+			Name: "scan_limit",
+			Usage: "optional highest child index to scan in each " +
+				"static address key family",
+		},
+	},
+	Action: runRecoverDeposit,
+}
+
 func runRecover(ctx context.Context, cmd *cli.Command) error {
 	if cmd.NArg() > 0 {
 		return showCommandHelp(ctx, cmd)
@@ -48,3 +84,31 @@ func runRecover(ctx context.Context, cmd *cli.Command) error {
 	printRespJSON(resp)
 	return nil
 }
+
+func runRecoverDeposit(ctx context.Context, cmd *cli.Command) error {
+	if cmd.NArg() > 0 {
+		return showCommandHelp(ctx, cmd)
+	}
+
+	client, cleanup, err := getClient(cmd)
+	if err != nil {
+		return err
+	}
+	defer cleanup()
+
+	resp, err := client.RecoverDeposit(
+		ctx, &looprpc.RecoverDepositRequest{
+			Txid:        cmd.String("txid"),
+			Vout:        uint32(cmd.Uint("vout")),
+			HeightHint:  int32(cmd.Int("height_hint")),
+			PkscriptHex: cmd.String("pkscript_hex"),
+			ScanLimit:   uint32(cmd.Uint("scan_limit")),
+		},
+	)
+	if err != nil {
+		return err
+	}
+
+	printRespJSON(resp)
+	return nil
+}

loopd/swapclient_server.go

@@ -1297,6 +1297,44 @@ func (s *swapClientServer) Recover(ctx context.Context,
 	}, nil
 }
 
+// RecoverDeposit verifies and restores one static-address deposit from
+// caller-supplied on-chain coordinates.
+func (s *swapClientServer) RecoverDeposit(ctx context.Context,
+	req *looprpc.RecoverDepositRequest) (*looprpc.RecoverDepositResponse,
+	error) {
+
+	if s.recoveryService == nil {
+		return nil, status.Error(
+			codes.Unavailable, "recovery service not configured",
+		)
+	}
+
+	result, err := s.recoveryService.RecoverDeposit(
+		ctx, &recovery.RecoverDepositRequest{
+			TxID:        req.GetTxid(),
+			VOut:        req.GetVout(),
+			HeightHint:  req.GetHeightHint(),
+			PkScriptHex: req.GetPkscriptHex(),
+			ScanLimit:   req.GetScanLimit(),
+		},
+	)
+	if err != nil {
+		return nil, err
+	}
+
+	return &looprpc.RecoverDepositResponse{
+		Outpoint:           result.OutPoint,
+		Value:              int64(result.Value),
+		ConfirmationHeight: result.ConfirmationHeight,
+		ClientKeyFamily:    result.ClientKeyFamily,
+		ClientKeyIndex:     result.ClientKeyIndex,
+		StaticAddress:      result.StaticAddress,
+		RecoveredAddress:   result.RecoveredAddress,
+		RecoveredDeposit:   result.RecoveredDeposit,
+		DepositId:          result.DepositID,
+	}, nil
+}
+
 // GetInfo returns basic information about the loop daemon and details to swaps
 // from the swap store.
 func (s *swapClientServer) GetInfo(ctx context.Context,

loopd/swapclient_server_staticaddr_test.go

@@ -34,6 +34,12 @@ func (s *staticAddrDepositStore) UpdateDeposit(context.Context,
 	return nil
 }
 
+func (s *staticAddrDepositStore) UpdateRecoveredDeposit(context.Context,
+	*deposit.Deposit) error {
+
+	return nil
+}
+
 func (s *staticAddrDepositStore) GetDeposit(context.Context,
 	deposit.ID) (*deposit.Deposit, error) {
 

loopd/swapclient_server_test.go

@@ -1019,6 +1019,12 @@ func (s *mockDepositStore) UpdateDeposit(_ context.Context,
 	return nil
 }
 
+func (s *mockDepositStore) UpdateRecoveredDeposit(_ context.Context,
+	_ *deposit.Deposit) error {
+
+	return nil
+}
+
 func (s *mockDepositStore) GetDeposit(_ context.Context,
 	_ deposit.ID) (*deposit.Deposit, error) {
 

loopdb/sqlc/querier.go

@@ -32,6 +32,18 @@ SET
 WHERE
     deposits.deposit_id = $1;
 
+-- name: UpdateRecoveredDeposit :exec
+UPDATE deposits
+SET
+    tx_hash = $2,
+    out_index = $3,
+    amount = $4,
+    confirmation_height = $5,
+    timeout_sweep_pk_script = $6,
+    static_address_id = $7
+WHERE
+    deposits.deposit_id = $1;
+
 -- name: InsertDepositUpdate :exec
 INSERT INTO deposit_updates (
     deposit_id,