tbd

Author: hieblmi

cmd/loop/staticaddr.go

@@ -22,6 +22,7 @@ var staticAddressCommands = cli.Command{
 		newStaticAddressCommand,
 		listUnspentCommand,
 		withdrawalCommand,
+		summaryCommand,
 	},
 }
 
@@ -183,6 +184,41 @@ func withdraw(ctx *cli.Context) error {
 	return nil
 }
 
+var summaryCommand = cli.Command{
+	Name:      "summary",
+	ShortName: "s",
+	Usage:     "Display a summary of static address related data.",
+	Description: `
+	Displays various static address related data. Utxos, Deposits,
+	Withdrawls, loop-ins...
+	`,
+	Action: summary,
+}
+
+func summary(ctx *cli.Context) error {
+	ctxb := context.Background()
+	if ctx.NArg() > 0 {
+		return cli.ShowCommandHelp(ctx, "summary")
+	}
+
+	client, cleanup, err := getClient(ctx)
+	if err != nil {
+		return err
+	}
+	defer cleanup()
+
+	resp, err := client.GetStaticAddressSummary(
+		ctxb, &looprpc.StaticAddressSummaryRequest{},
+	)
+	if err != nil {
+		return err
+	}
+
+	printRespJSON(resp)
+
+	return nil
+}
+
 func utxosToOutpoints(utxos []string) ([]*looprpc.OutPoint, error) {
 	var outpoints []*looprpc.OutPoint
 	if len(utxos) == 0 {

loopd/perms/perms.go

@@ -90,6 +90,13 @@ var RequiredPermissions = map[string][]bakery.Op{
 		Entity: "loop",
 		Action: "in",
 	}},
+	"/looprpc.SwapClient/GetStaticAddressSummary": {{
+		Entity: "swap",
+		Action: "read",
+	}, {
+		Entity: "loop",
+		Action: "in",
+	}},
 	"/looprpc.SwapClient/GetLsatTokens": {{
 		Entity: "auth",
 		Action: "read",

loopd/swapclient_server.go

@@ -32,6 +32,7 @@ import (
 	looprpc "github.com/lightninglabs/loop/swapserverrpc"
 	"github.com/lightningnetwork/lnd/lnrpc/walletrpc"
 	"github.com/lightningnetwork/lnd/lntypes"
+	"github.com/lightningnetwork/lnd/lnwallet"
 	"github.com/lightningnetwork/lnd/queue"
 	"github.com/lightningnetwork/lnd/routing/route"
 	"github.com/lightningnetwork/lnd/zpay32"
@@ -1319,6 +1320,99 @@ func (s *swapClientServer) WithdrawDeposits(ctx context.Context,
 	return &clientrpc.WithdrawDepositsResponse{}, err
 }
 
+func (s *swapClientServer) GetStaticAddressSummary(ctx context.Context,
+	req *clientrpc.StaticAddressSummaryRequest) (*clientrpc.StaticAddressSummaryResponse,
+	error) {
+
+	allDeposits, err := s.depositManager.GetAllDeposits(ctx)
+	if err != nil {
+		return nil, err
+	}
+
+	return s.depositSummary(ctx, allDeposits, req.StateFilter)
+}
+
+func (s *swapClientServer) depositSummary(ctx context.Context,
+	deposits []*deposit.Deposit,
+	filter string) (*clientrpc.StaticAddressSummaryResponse, error) {
+
+	var (
+		totalNumSwaps    = len(deposits)
+		valueUnconfirmed int64
+		valueDeposited   int64
+		valueExpired     int64
+		valueWithdrawn   int64
+		valueLoopedIn    int64
+	)
+
+	// Value unconfirmed.
+	utxos, err := s.staticAddressManager.ListUnspent(ctx, 0, deposit.MinConfs-1)
+	if err != nil {
+		return nil, err
+	}
+	for _, u := range utxos {
+		valueUnconfirmed += int64(u.Value)
+	}
+
+	for _, d := range deposits {
+		value := int64(d.Value)
+		switch d.State {
+		case deposit.Deposited:
+			valueDeposited += value
+
+		case deposit.SweptExpiredDeposit:
+			valueExpired += value
+
+		case deposit.Withdrawn:
+			valueWithdrawn += value
+		}
+	}
+
+	clientDeposits, err := s.toClientDeposits(deposits)
+	if err != nil {
+		return nil, err
+	}
+
+	return &clientrpc.StaticAddressSummaryResponse{
+		TotalNumSwaps:    uint32(totalNumSwaps),
+		ValueUnconfirmed: valueUnconfirmed,
+		ValueDeposited:   valueDeposited,
+		ValueExpired:     valueExpired,
+		ValueWithdrawn:   valueWithdrawn,
+		ValueLoopedIn:    valueLoopedIn,
+		Deposits:         clientDeposits,
+	}, nil
+}
+
+func (s *swapClientServer) toClientDeposits(deposits []*deposit.Deposit) ([]*clientrpc.Deposit, error) {
+	var clientDeposits []*clientrpc.Deposit
+	for _, d := range deposits {
+		outpoint := wire.NewOutPoint(&d.Hash, d.Index).String()
+		clientDeposits = append(clientDeposits, &clientrpc.Deposit{
+			Id:                 d.ID[:],
+			State:              string(d.State),
+			Outpoint:           outpoint,
+			Value:              int64(d.Value),
+			ConfirmationHeight: d.ConfirmationHeight,
+		})
+	}
+
+	return clientDeposits, nil
+}
+
+func (s *swapClientServer) toDeposits(deposits []*lnwallet.Utxo) []*clientrpc.Deposit {
+	var unconfirmedDeposits []*clientrpc.Deposit
+	for _, u := range deposits {
+		unconfirmedDeposits = append(unconfirmedDeposits, &clientrpc.Deposit{
+			State:    "Unconfirmed",
+			Outpoint: u.OutPoint.String(),
+			Value:    int64(u.Value),
+		})
+	}
+
+	return unconfirmedDeposits
+}
+
 func toServerOutpoints(outpoints []*clientrpc.OutPoint) ([]wire.OutPoint,
 	error) {