v1.24.0-rc4-gw

protofire · Nov 6, 2023 · d3a9b0f · d3a9b0f
1 parent ee0152f
commit d3a9b0f
Show file tree

Hide file tree

Showing 6 changed files with 69 additions and 0 deletions.
diff --git a/api/api_gateway.go b/api/api_gateway.go
@@ -33,6 +33,8 @@ import (
 //  * Generate openrpc blobs
 
 type Gateway interface {
+	StateMinerAvailableBalance(context.Context, address.Address, types.TipSetKey) (types.BigInt, error)
+	StateMarketParticipants(context.Context, types.TipSetKey) (map[string]MarketBalance, error)
 	MpoolPending(context.Context, types.TipSetKey) ([]*types.SignedMessage, error)
 	ChainGetBlock(context.Context, cid.Cid) (*types.BlockHeader, error)
 	MinerGetBaseInfo(context.Context, address.Address, abi.ChainEpoch, types.TipSetKey) (*MiningBaseInfo, error)

diff --git a/api/proxy_gen.go b/api/proxy_gen.go
diff --git a/api/v0api/gateway.go b/api/v0api/gateway.go
@@ -35,6 +35,8 @@ import (
 //  * Generate openrpc blobs
 
 type Gateway interface {
+	StateMinerAvailableBalance(context.Context, address.Address, types.TipSetKey) (types.BigInt, error)
+	StateMarketParticipants(context.Context, types.TipSetKey) (map[string]api.MarketBalance, error)
 	MpoolPending(context.Context, types.TipSetKey) ([]*types.SignedMessage, error)
 	ChainGetBlock(context.Context, cid.Cid) (*types.BlockHeader, error)
 	MinerGetBaseInfo(context.Context, address.Address, abi.ChainEpoch, types.TipSetKey) (*api.MiningBaseInfo, error)

diff --git a/api/v0api/proxy_gen.go b/api/v0api/proxy_gen.go
diff --git a/gateway/node.go b/gateway/node.go
@@ -43,6 +43,7 @@ const (
 // TargetAPI defines the API methods that the Node depends on
 // (to make it easy to mock for tests)
 type TargetAPI interface {
+    StateMarketParticipants(context.Context, types.TipSetKey) (map[string]api.MarketBalance, error)
 	MpoolPending(context.Context, types.TipSetKey) ([]*types.SignedMessage, error)
 	ChainGetBlock(context.Context, cid.Cid) (*types.BlockHeader, error)
 	MinerGetBaseInfo(context.Context, address.Address, abi.ChainEpoch, types.TipSetKey) (*api.MiningBaseInfo, error)

diff --git a/gateway/proxy_fil.go b/gateway/proxy_fil.go
@@ -23,6 +23,16 @@ import (
 	"github.com/filecoin-project/lotus/node/modules/dtypes"
 )
 
+func (gw *Node) StateMarketParticipants(ctx context.Context, tsk types.TipSetKey) (map[string]api.MarketBalance, error) {
+	if err := gw.limit(ctx, stateRateLimitTokens); err != nil {
+		return nil, err
+	}
+	if err := gw.checkTipsetKey(ctx, tsk); err != nil {
+		return nil, err
+	}
+	return gw.target.StateMarketParticipants(ctx, tsk)
+}
+
 func (gw *Node) MpoolPending(ctx context.Context, tsk types.TipSetKey) ([]*types.SignedMessage, error) {
 	if err := gw.limit(ctx, stateRateLimitTokens); err != nil {
 		return nil, err