taprpc: Updated ListAssetRequest to include additional filter options

lightninglabs · Nov 16, 2024 · b6e90aa · b6e90aa
1 parent ee06af7
commit b6e90aa
Show file tree

Hide file tree

Showing 4 changed files with 994 additions and 880 deletions.
diff --git a/rpcserver.go b/rpcserver.go
@@ -963,8 +963,9 @@ func (r *rpcServer) ListAssets(ctx context.Context,
 	}
 
 	rpcAssets, err := r.fetchRpcAssets(
-		ctx, req.WithWitness, req.IncludeSpent, req.IncludeLeased,
+		ctx, req.WithWitness, req.IncludeSpent, req.IncludeLeased, req.MinAmount,
 	)
+
 	if err != nil {
 		return nil, err
 	}
@@ -1017,10 +1018,14 @@ func (r *rpcServer) ListAssets(ctx context.Context,
 }
 
 func (r *rpcServer) fetchRpcAssets(ctx context.Context, withWitness,
-	includeSpent, includeLeased bool) ([]*taprpc.Asset, error) {
+	includeSpent, includeLeased bool, minAmountFilter uint64) ([]*taprpc.Asset, error) {
+
+	filters := &r.cfg.AssetStore.AssetQueryFilters{
+		MinAmt: minAmountFilter,
+	}
 
 	assets, err := r.cfg.AssetStore.FetchAllAssets(
-		ctx, includeSpent, includeLeased, nil,
+		ctx, includeSpent, includeLeased, filters,
 	)
 	if err != nil {
 		return nil, fmt.Errorf("unable to read chain assets: %w", err)