2019-06-29 09:19:06 +00:00
|
|
|
package api
|
|
|
|
|
|
|
|
import (
|
|
|
|
"context"
|
|
|
|
|
2019-09-24 21:13:47 +00:00
|
|
|
"github.com/ipfs/go-cid"
|
2019-07-25 00:55:19 +00:00
|
|
|
"github.com/libp2p/go-libp2p-core/network"
|
2019-09-24 21:13:47 +00:00
|
|
|
"github.com/libp2p/go-libp2p-core/peer"
|
2019-07-25 00:55:19 +00:00
|
|
|
|
2019-10-22 11:29:41 +00:00
|
|
|
"github.com/filecoin-project/lotus/chain/actors"
|
2019-10-18 04:47:41 +00:00
|
|
|
"github.com/filecoin-project/lotus/chain/address"
|
|
|
|
"github.com/filecoin-project/lotus/chain/store"
|
|
|
|
"github.com/filecoin-project/lotus/chain/types"
|
2019-06-29 09:19:06 +00:00
|
|
|
)
|
|
|
|
|
2019-07-23 20:05:44 +00:00
|
|
|
// All permissions are listed in permissioned.go
|
|
|
|
var _ = AllPermissions
|
|
|
|
|
2019-07-24 00:09:34 +00:00
|
|
|
type CommonStruct struct {
|
2019-07-24 01:10:26 +00:00
|
|
|
Internal struct {
|
2019-10-23 09:18:22 +00:00
|
|
|
AuthVerify func(ctx context.Context, token string) ([]Permission, error) `perm:"read"`
|
|
|
|
AuthNew func(ctx context.Context, perms []Permission) ([]byte, error) `perm:"admin"`
|
2019-07-23 17:27:45 +00:00
|
|
|
|
2019-07-25 00:55:19 +00:00
|
|
|
NetConnectedness func(context.Context, peer.ID) (network.Connectedness, error) `perm:"read"`
|
|
|
|
NetPeers func(context.Context) ([]peer.AddrInfo, error) `perm:"read"`
|
|
|
|
NetConnect func(context.Context, peer.AddrInfo) error `perm:"write"`
|
|
|
|
NetAddrsListen func(context.Context) (peer.AddrInfo, error) `perm:"read"`
|
|
|
|
NetDisconnect func(context.Context, peer.ID) error `perm:"write"`
|
2019-07-24 00:09:34 +00:00
|
|
|
|
2019-07-23 20:05:44 +00:00
|
|
|
ID func(context.Context) (peer.ID, error) `perm:"read"`
|
|
|
|
Version func(context.Context) (Version, error) `perm:"read"`
|
2019-07-24 00:09:34 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// FullNodeStruct implements API passing calls to user-provided function values.
|
|
|
|
type FullNodeStruct struct {
|
|
|
|
CommonStruct
|
2019-07-08 19:07:16 +00:00
|
|
|
|
2019-07-24 00:09:34 +00:00
|
|
|
Internal struct {
|
2019-11-08 05:36:50 +00:00
|
|
|
ChainNotify func(context.Context) (<-chan []*store.HeadChange, error) `perm:"read"`
|
|
|
|
ChainHead func(context.Context) (*types.TipSet, error) `perm:"read"`
|
|
|
|
ChainGetRandomness func(context.Context, types.TipSetKey, []*types.Ticket, int) ([]byte, error) `perm:"read"`
|
|
|
|
ChainGetBlock func(context.Context, cid.Cid) (*types.BlockHeader, error) `perm:"read"`
|
|
|
|
ChainGetTipSet func(context.Context, types.TipSetKey) (*types.TipSet, error) `perm:"read"`
|
|
|
|
ChainGetBlockMessages func(context.Context, cid.Cid) (*BlockMessages, error) `perm:"read"`
|
|
|
|
ChainGetParentReceipts func(context.Context, cid.Cid) ([]*types.MessageReceipt, error) `perm:"read"`
|
|
|
|
ChainGetParentMessages func(context.Context, cid.Cid) ([]Message, error) `perm:"read"`
|
|
|
|
ChainGetTipSetByHeight func(context.Context, uint64, *types.TipSet) (*types.TipSet, error) `perm:"read"`
|
|
|
|
ChainReadObj func(context.Context, cid.Cid) ([]byte, error) `perm:"read"`
|
|
|
|
ChainSetHead func(context.Context, *types.TipSet) error `perm:"admin"`
|
|
|
|
ChainGetGenesis func(context.Context) (*types.TipSet, error) `perm:"read"`
|
|
|
|
ChainTipSetWeight func(context.Context, *types.TipSet) (types.BigInt, error) `perm:"read"`
|
2019-07-09 15:19:27 +00:00
|
|
|
|
2019-11-18 21:39:07 +00:00
|
|
|
SyncState func(context.Context) (*SyncState, error) `perm:"read"`
|
|
|
|
SyncSubmitBlock func(ctx context.Context, blk *types.BlockMsg) error `perm:"write"`
|
|
|
|
SyncIncomingBlocks func(ctx context.Context) (<-chan *types.BlockHeader, error) `perm:"read"`
|
2019-09-30 21:06:47 +00:00
|
|
|
|
2019-09-16 21:26:19 +00:00
|
|
|
MpoolPending func(context.Context, *types.TipSet) ([]*types.SignedMessage, error) `perm:"read"`
|
|
|
|
MpoolPush func(context.Context, *types.SignedMessage) error `perm:"write"`
|
2019-09-17 08:15:26 +00:00
|
|
|
MpoolPushMessage func(context.Context, *types.Message) (*types.SignedMessage, error) `perm:"sign"`
|
2019-11-17 07:44:06 +00:00
|
|
|
MpoolGetNonce func(context.Context, address.Address) (uint64, error) `perm:"read"`
|
|
|
|
MpoolSub func(context.Context) (<-chan MpoolUpdate, error) `perm:"read"`
|
2019-07-11 02:36:43 +00:00
|
|
|
|
2019-08-27 00:46:39 +00:00
|
|
|
MinerRegister func(context.Context, address.Address) error `perm:"admin"`
|
|
|
|
MinerUnregister func(context.Context, address.Address) error `perm:"admin"`
|
|
|
|
MinerAddresses func(context.Context) ([]address.Address, error) `perm:"write"`
|
2019-09-18 02:50:03 +00:00
|
|
|
MinerCreateBlock func(context.Context, address.Address, *types.TipSet, []*types.Ticket, types.ElectionProof, []*types.SignedMessage, uint64) (*types.BlockMsg, error) `perm:"write"`
|
2019-07-09 22:58:51 +00:00
|
|
|
|
2019-08-09 15:59:12 +00:00
|
|
|
WalletNew func(context.Context, string) (address.Address, error) `perm:"write"`
|
|
|
|
WalletHas func(context.Context, address.Address) (bool, error) `perm:"write"`
|
|
|
|
WalletList func(context.Context) ([]address.Address, error) `perm:"write"`
|
|
|
|
WalletBalance func(context.Context, address.Address) (types.BigInt, error) `perm:"read"`
|
|
|
|
WalletSign func(context.Context, address.Address, []byte) (*types.Signature, error) `perm:"sign"`
|
|
|
|
WalletSignMessage func(context.Context, address.Address, *types.Message) (*types.SignedMessage, error) `perm:"sign"`
|
|
|
|
WalletDefaultAddress func(context.Context) (address.Address, error) `perm:"write"`
|
2019-10-17 10:18:40 +00:00
|
|
|
WalletSetDefault func(context.Context, address.Address) error `perm:"admin"`
|
2019-10-08 09:46:36 +00:00
|
|
|
WalletExport func(context.Context, address.Address) (*types.KeyInfo, error) `perm:"admin"`
|
|
|
|
WalletImport func(context.Context, *types.KeyInfo) (address.Address, error) `perm:"admin"`
|
2019-10-08 09:17:03 +00:00
|
|
|
|
2019-10-23 09:18:22 +00:00
|
|
|
ClientImport func(ctx context.Context, path string) (cid.Cid, error) `perm:"admin"`
|
2019-08-26 13:45:36 +00:00
|
|
|
ClientListImports func(ctx context.Context) ([]Import, error) `perm:"write"`
|
|
|
|
ClientHasLocal func(ctx context.Context, root cid.Cid) (bool, error) `perm:"write"`
|
2019-08-26 18:23:11 +00:00
|
|
|
ClientFindData func(ctx context.Context, root cid.Cid) ([]QueryOffer, error) `perm:"read"`
|
2019-08-07 20:06:10 +00:00
|
|
|
ClientStartDeal func(ctx context.Context, data cid.Cid, miner address.Address, price types.BigInt, blocksDuration uint64) (*cid.Cid, error) `perm:"admin"`
|
2019-11-06 19:44:28 +00:00
|
|
|
ClientGetDealInfo func(context.Context, cid.Cid) (*DealInfo, error) `perm:"read"`
|
2019-09-10 14:13:24 +00:00
|
|
|
ClientListDeals func(ctx context.Context) ([]DealInfo, error) `perm:"write"`
|
2019-08-27 22:10:23 +00:00
|
|
|
ClientRetrieve func(ctx context.Context, order RetrievalOrder, path string) error `perm:"admin"`
|
2019-09-13 21:00:36 +00:00
|
|
|
ClientQueryAsk func(ctx context.Context, p peer.ID, miner address.Address) (*types.SignedStorageAsk, error) `perm:"read"`
|
2019-08-07 06:35:57 +00:00
|
|
|
|
2019-11-08 18:15:13 +00:00
|
|
|
StateMinerSectors func(context.Context, address.Address, *types.TipSet) ([]*ChainSectorInfo, error) `perm:"read"`
|
|
|
|
StateMinerProvingSet func(context.Context, address.Address, *types.TipSet) ([]*ChainSectorInfo, error) `perm:"read"`
|
2019-10-22 10:09:36 +00:00
|
|
|
StateMinerPower func(context.Context, address.Address, *types.TipSet) (MinerPower, error) `perm:"read"`
|
|
|
|
StateMinerWorker func(context.Context, address.Address, *types.TipSet) (address.Address, error) `perm:"read"`
|
|
|
|
StateMinerPeerID func(ctx context.Context, m address.Address, ts *types.TipSet) (peer.ID, error) `perm:"read"`
|
|
|
|
StateMinerProvingPeriodEnd func(ctx context.Context, actor address.Address, ts *types.TipSet) (uint64, error) `perm:"read"`
|
2019-10-16 07:07:16 +00:00
|
|
|
StateMinerSectorSize func(context.Context, address.Address, *types.TipSet) (uint64, error) `perm:"read"`
|
2019-10-22 10:09:36 +00:00
|
|
|
StateCall func(context.Context, *types.Message, *types.TipSet) (*types.MessageReceipt, error) `perm:"read"`
|
|
|
|
StateReplay func(context.Context, *types.TipSet, cid.Cid) (*ReplayResults, error) `perm:"read"`
|
|
|
|
StateGetActor func(context.Context, address.Address, *types.TipSet) (*types.Actor, error) `perm:"read"`
|
|
|
|
StateReadState func(context.Context, *types.Actor, *types.TipSet) (*ActorState, error) `perm:"read"`
|
|
|
|
StatePledgeCollateral func(context.Context, *types.TipSet) (types.BigInt, error) `perm:"read"`
|
|
|
|
StateWaitMsg func(context.Context, cid.Cid) (*MsgWait, error) `perm:"read"`
|
|
|
|
StateListMiners func(context.Context, *types.TipSet) ([]address.Address, error) `perm:"read"`
|
|
|
|
StateListActors func(context.Context, *types.TipSet) ([]address.Address, error) `perm:"read"`
|
|
|
|
StateMarketBalance func(context.Context, address.Address, *types.TipSet) (actors.StorageParticipantBalance, error) `perm:"read"`
|
2019-10-22 19:29:05 +00:00
|
|
|
StateMarketParticipants func(context.Context, *types.TipSet) (map[string]actors.StorageParticipantBalance, error) `perm:"read"`
|
|
|
|
StateMarketDeals func(context.Context, *types.TipSet) (map[string]actors.OnChainDeal, error) `perm:"read"`
|
2019-11-07 07:57:10 +00:00
|
|
|
StateMarketStorageDeal func(context.Context, uint64, *types.TipSet) (*actors.OnChainDeal, error) `perm:"read"`
|
2019-11-15 16:39:43 +00:00
|
|
|
StateLookupID func(ctx context.Context, addr address.Address, ts *types.TipSet) (address.Address, error) `perm:"read"`
|
2019-11-16 12:34:52 +00:00
|
|
|
StateChangedActors func(context.Context, cid.Cid, cid.Cid) (map[string]types.Actor, error) `perm:"read"`
|
2019-11-20 19:44:38 +00:00
|
|
|
StateGetReceipt func(context.Context, cid.Cid, *types.TipSet) (*types.MessageReceipt, error) `perm:"read"`
|
2019-08-09 21:41:50 +00:00
|
|
|
|
2019-11-08 17:15:38 +00:00
|
|
|
MarketEnsureAvailable func(context.Context, address.Address, types.BigInt) error `perm:"sign"`
|
|
|
|
|
2019-09-24 21:13:47 +00:00
|
|
|
PaychGet func(ctx context.Context, from, to address.Address, ensureFunds types.BigInt) (*ChannelInfo, error) `perm:"sign"`
|
|
|
|
PaychList func(context.Context) ([]address.Address, error) `perm:"read"`
|
|
|
|
PaychStatus func(context.Context, address.Address) (*PaychStatus, error) `perm:"read"`
|
|
|
|
PaychClose func(context.Context, address.Address) (cid.Cid, error) `perm:"sign"`
|
|
|
|
PaychAllocateLane func(context.Context, address.Address) (uint64, error) `perm:"sign"`
|
|
|
|
PaychNewPayment func(ctx context.Context, from, to address.Address, vouchers []VoucherSpec) (*PaymentInfo, error) `perm:"sign"`
|
|
|
|
PaychVoucherCheck func(context.Context, *types.SignedVoucher) error `perm:"read"`
|
|
|
|
PaychVoucherCheckValid func(context.Context, address.Address, *types.SignedVoucher) error `perm:"read"`
|
|
|
|
PaychVoucherCheckSpendable func(context.Context, address.Address, *types.SignedVoucher, []byte, []byte) (bool, error) `perm:"read"`
|
|
|
|
PaychVoucherAdd func(context.Context, address.Address, *types.SignedVoucher, []byte, types.BigInt) (types.BigInt, error) `perm:"write"`
|
|
|
|
PaychVoucherCreate func(context.Context, address.Address, types.BigInt, uint64) (*types.SignedVoucher, error) `perm:"sign"`
|
|
|
|
PaychVoucherList func(context.Context, address.Address) ([]*types.SignedVoucher, error) `perm:"write"`
|
|
|
|
PaychVoucherSubmit func(context.Context, address.Address, *types.SignedVoucher) (cid.Cid, error) `perm:"sign"`
|
2019-06-29 09:19:06 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2019-07-24 00:09:34 +00:00
|
|
|
type StorageMinerStruct struct {
|
|
|
|
CommonStruct
|
2019-07-23 17:27:45 +00:00
|
|
|
|
2019-07-24 01:10:26 +00:00
|
|
|
Internal struct {
|
2019-10-14 02:32:32 +00:00
|
|
|
ActorAddress func(context.Context) (address.Address, error) `perm:"read"`
|
2019-08-10 01:54:45 +00:00
|
|
|
|
2019-10-29 17:52:07 +00:00
|
|
|
StoreGarbageData func(context.Context) error `perm:"write"`
|
2019-07-27 21:08:10 +00:00
|
|
|
|
2019-11-08 18:15:13 +00:00
|
|
|
SectorsStatus func(context.Context, uint64) (SectorInfo, error) `perm:"read"`
|
|
|
|
SectorsList func(context.Context) ([]uint64, error) `perm:"read"`
|
|
|
|
SectorsRefs func(context.Context) (map[string][]SealedRef, error) `perm:"read"`
|
2019-08-26 10:04:57 +00:00
|
|
|
|
2019-11-08 18:15:13 +00:00
|
|
|
WorkerStats func(context.Context) (WorkerStats, error) `perm:"read"`
|
2019-07-24 00:09:34 +00:00
|
|
|
}
|
2019-07-23 17:27:45 +00:00
|
|
|
}
|
|
|
|
|
2019-10-23 09:18:22 +00:00
|
|
|
func (c *CommonStruct) AuthVerify(ctx context.Context, token string) ([]Permission, error) {
|
2019-07-24 00:58:31 +00:00
|
|
|
return c.Internal.AuthVerify(ctx, token)
|
|
|
|
}
|
|
|
|
|
2019-10-23 09:18:22 +00:00
|
|
|
func (c *CommonStruct) AuthNew(ctx context.Context, perms []Permission) ([]byte, error) {
|
2019-07-24 00:58:31 +00:00
|
|
|
return c.Internal.AuthNew(ctx, perms)
|
|
|
|
}
|
|
|
|
|
2019-07-25 00:55:19 +00:00
|
|
|
func (c *CommonStruct) NetConnectedness(ctx context.Context, pid peer.ID) (network.Connectedness, error) {
|
|
|
|
return c.Internal.NetConnectedness(ctx, pid)
|
|
|
|
}
|
|
|
|
|
2019-07-24 00:58:31 +00:00
|
|
|
func (c *CommonStruct) NetPeers(ctx context.Context) ([]peer.AddrInfo, error) {
|
|
|
|
return c.Internal.NetPeers(ctx)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *CommonStruct) NetConnect(ctx context.Context, p peer.AddrInfo) error {
|
|
|
|
return c.Internal.NetConnect(ctx, p)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *CommonStruct) NetAddrsListen(ctx context.Context) (peer.AddrInfo, error) {
|
|
|
|
return c.Internal.NetAddrsListen(ctx)
|
2019-07-25 00:55:19 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
func (c *CommonStruct) NetDisconnect(ctx context.Context, p peer.ID) error {
|
|
|
|
return c.Internal.NetDisconnect(ctx, p)
|
2019-07-24 00:58:31 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// ID implements API.ID
|
|
|
|
func (c *CommonStruct) ID(ctx context.Context) (peer.ID, error) {
|
|
|
|
return c.Internal.ID(ctx)
|
|
|
|
}
|
|
|
|
|
|
|
|
// Version implements API.Version
|
|
|
|
func (c *CommonStruct) Version(ctx context.Context) (Version, error) {
|
|
|
|
return c.Internal.Version(ctx)
|
|
|
|
}
|
|
|
|
|
2019-07-24 00:09:34 +00:00
|
|
|
func (c *FullNodeStruct) ClientListImports(ctx context.Context) ([]Import, error) {
|
2019-07-12 10:44:01 +00:00
|
|
|
return c.Internal.ClientListImports(ctx)
|
|
|
|
}
|
|
|
|
|
2019-07-24 00:09:34 +00:00
|
|
|
func (c *FullNodeStruct) ClientImport(ctx context.Context, path string) (cid.Cid, error) {
|
2019-07-12 09:59:18 +00:00
|
|
|
return c.Internal.ClientImport(ctx, path)
|
|
|
|
}
|
|
|
|
|
2019-08-26 13:45:36 +00:00
|
|
|
func (c *FullNodeStruct) ClientHasLocal(ctx context.Context, root cid.Cid) (bool, error) {
|
|
|
|
return c.Internal.ClientHasLocal(ctx, root)
|
|
|
|
}
|
|
|
|
|
2019-08-26 18:23:11 +00:00
|
|
|
func (c *FullNodeStruct) ClientFindData(ctx context.Context, root cid.Cid) ([]QueryOffer, error) {
|
2019-08-26 13:45:36 +00:00
|
|
|
return c.Internal.ClientFindData(ctx, root)
|
|
|
|
}
|
|
|
|
|
2019-08-07 20:06:10 +00:00
|
|
|
func (c *FullNodeStruct) ClientStartDeal(ctx context.Context, data cid.Cid, miner address.Address, price types.BigInt, blocksDuration uint64) (*cid.Cid, error) {
|
|
|
|
return c.Internal.ClientStartDeal(ctx, data, miner, price, blocksDuration)
|
2019-08-01 17:12:41 +00:00
|
|
|
}
|
2019-11-06 19:44:28 +00:00
|
|
|
func (c *FullNodeStruct) ClientGetDealInfo(ctx context.Context, deal cid.Cid) (*DealInfo, error) {
|
|
|
|
return c.Internal.ClientGetDealInfo(ctx, deal)
|
|
|
|
}
|
2019-08-27 18:45:21 +00:00
|
|
|
|
2019-09-10 14:13:24 +00:00
|
|
|
func (c *FullNodeStruct) ClientListDeals(ctx context.Context) ([]DealInfo, error) {
|
|
|
|
return c.Internal.ClientListDeals(ctx)
|
|
|
|
}
|
|
|
|
|
2019-08-27 22:10:23 +00:00
|
|
|
func (c *FullNodeStruct) ClientRetrieve(ctx context.Context, order RetrievalOrder, path string) error {
|
|
|
|
return c.Internal.ClientRetrieve(ctx, order, path)
|
2019-08-27 18:45:21 +00:00
|
|
|
}
|
2019-08-01 17:12:41 +00:00
|
|
|
|
2019-09-13 21:00:36 +00:00
|
|
|
func (c *FullNodeStruct) ClientQueryAsk(ctx context.Context, p peer.ID, miner address.Address) (*types.SignedStorageAsk, error) {
|
|
|
|
return c.Internal.ClientQueryAsk(ctx, p, miner)
|
|
|
|
}
|
|
|
|
|
2019-07-26 04:54:22 +00:00
|
|
|
func (c *FullNodeStruct) MpoolPending(ctx context.Context, ts *types.TipSet) ([]*types.SignedMessage, error) {
|
2019-07-11 02:36:43 +00:00
|
|
|
return c.Internal.MpoolPending(ctx, ts)
|
|
|
|
}
|
|
|
|
|
2019-07-25 22:15:03 +00:00
|
|
|
func (c *FullNodeStruct) MpoolPush(ctx context.Context, smsg *types.SignedMessage) error {
|
2019-07-17 06:15:07 +00:00
|
|
|
return c.Internal.MpoolPush(ctx, smsg)
|
2019-07-17 03:05:55 +00:00
|
|
|
}
|
|
|
|
|
2019-09-17 08:15:26 +00:00
|
|
|
func (c *FullNodeStruct) MpoolPushMessage(ctx context.Context, msg *types.Message) (*types.SignedMessage, error) {
|
2019-09-16 14:17:08 +00:00
|
|
|
return c.Internal.MpoolPushMessage(ctx, msg)
|
|
|
|
}
|
|
|
|
|
2019-11-17 07:44:06 +00:00
|
|
|
func (c *FullNodeStruct) MpoolSub(ctx context.Context) (<-chan MpoolUpdate, error) {
|
|
|
|
return c.Internal.MpoolSub(ctx)
|
|
|
|
}
|
|
|
|
|
2019-08-20 16:50:17 +00:00
|
|
|
func (c *FullNodeStruct) MinerRegister(ctx context.Context, addr address.Address) error {
|
|
|
|
return c.Internal.MinerRegister(ctx, addr)
|
2019-07-11 02:36:43 +00:00
|
|
|
}
|
|
|
|
|
2019-08-20 18:05:17 +00:00
|
|
|
func (c *FullNodeStruct) MinerUnregister(ctx context.Context, addr address.Address) error {
|
|
|
|
return c.Internal.MinerUnregister(ctx, addr)
|
|
|
|
}
|
|
|
|
|
2019-08-21 15:14:38 +00:00
|
|
|
func (c *FullNodeStruct) MinerAddresses(ctx context.Context) ([]address.Address, error) {
|
|
|
|
return c.Internal.MinerAddresses(ctx)
|
|
|
|
}
|
|
|
|
|
2019-09-18 02:50:03 +00:00
|
|
|
func (c *FullNodeStruct) MinerCreateBlock(ctx context.Context, addr address.Address, base *types.TipSet, tickets []*types.Ticket, eproof types.ElectionProof, msgs []*types.SignedMessage, ts uint64) (*types.BlockMsg, error) {
|
2019-08-27 00:46:39 +00:00
|
|
|
return c.Internal.MinerCreateBlock(ctx, addr, base, tickets, eproof, msgs, ts)
|
2019-07-09 22:58:51 +00:00
|
|
|
}
|
|
|
|
|
2019-07-26 04:54:22 +00:00
|
|
|
func (c *FullNodeStruct) ChainHead(ctx context.Context) (*types.TipSet, error) {
|
2019-07-09 15:19:27 +00:00
|
|
|
return c.Internal.ChainHead(ctx)
|
|
|
|
}
|
|
|
|
|
2019-11-08 05:36:50 +00:00
|
|
|
func (c *FullNodeStruct) ChainGetRandomness(ctx context.Context, pts types.TipSetKey, ticks []*types.Ticket, lb int) ([]byte, error) {
|
2019-09-06 06:26:02 +00:00
|
|
|
return c.Internal.ChainGetRandomness(ctx, pts, ticks, lb)
|
2019-07-11 02:36:43 +00:00
|
|
|
}
|
|
|
|
|
2019-09-18 00:08:49 +00:00
|
|
|
func (c *FullNodeStruct) ChainGetTipSetByHeight(ctx context.Context, h uint64, ts *types.TipSet) (*types.TipSet, error) {
|
|
|
|
return c.Internal.ChainGetTipSetByHeight(ctx, h, ts)
|
|
|
|
}
|
|
|
|
|
2019-07-24 00:09:34 +00:00
|
|
|
func (c *FullNodeStruct) WalletNew(ctx context.Context, typ string) (address.Address, error) {
|
2019-07-13 00:41:32 +00:00
|
|
|
return c.Internal.WalletNew(ctx, typ)
|
|
|
|
}
|
|
|
|
|
2019-08-08 17:29:23 +00:00
|
|
|
func (c *FullNodeStruct) WalletHas(ctx context.Context, addr address.Address) (bool, error) {
|
|
|
|
return c.Internal.WalletHas(ctx, addr)
|
|
|
|
}
|
|
|
|
|
2019-07-24 00:09:34 +00:00
|
|
|
func (c *FullNodeStruct) WalletList(ctx context.Context) ([]address.Address, error) {
|
2019-07-13 00:41:32 +00:00
|
|
|
return c.Internal.WalletList(ctx)
|
|
|
|
}
|
|
|
|
|
2019-07-24 00:09:34 +00:00
|
|
|
func (c *FullNodeStruct) WalletBalance(ctx context.Context, a address.Address) (types.BigInt, error) {
|
2019-07-18 20:26:04 +00:00
|
|
|
return c.Internal.WalletBalance(ctx, a)
|
|
|
|
}
|
|
|
|
|
2019-07-24 05:38:16 +00:00
|
|
|
func (c *FullNodeStruct) WalletSign(ctx context.Context, k address.Address, msg []byte) (*types.Signature, error) {
|
2019-07-17 03:05:55 +00:00
|
|
|
return c.Internal.WalletSign(ctx, k, msg)
|
|
|
|
}
|
|
|
|
|
2019-08-09 15:59:12 +00:00
|
|
|
func (c *FullNodeStruct) WalletSignMessage(ctx context.Context, k address.Address, msg *types.Message) (*types.SignedMessage, error) {
|
|
|
|
return c.Internal.WalletSignMessage(ctx, k, msg)
|
|
|
|
}
|
|
|
|
|
2019-07-24 00:09:34 +00:00
|
|
|
func (c *FullNodeStruct) WalletDefaultAddress(ctx context.Context) (address.Address, error) {
|
2019-07-17 03:05:55 +00:00
|
|
|
return c.Internal.WalletDefaultAddress(ctx)
|
|
|
|
}
|
|
|
|
|
2019-10-17 10:18:40 +00:00
|
|
|
func (c *FullNodeStruct) WalletSetDefault(ctx context.Context, a address.Address) error {
|
|
|
|
return c.Internal.WalletSetDefault(ctx, a)
|
|
|
|
}
|
|
|
|
|
2019-10-08 09:46:36 +00:00
|
|
|
func (c *FullNodeStruct) WalletExport(ctx context.Context, a address.Address) (*types.KeyInfo, error) {
|
2019-10-08 09:17:03 +00:00
|
|
|
return c.Internal.WalletExport(ctx, a)
|
|
|
|
}
|
|
|
|
|
2019-10-08 09:46:36 +00:00
|
|
|
func (c *FullNodeStruct) WalletImport(ctx context.Context, ki *types.KeyInfo) (address.Address, error) {
|
|
|
|
return c.Internal.WalletImport(ctx, ki)
|
2019-10-08 09:17:03 +00:00
|
|
|
}
|
|
|
|
|
2019-07-24 00:09:34 +00:00
|
|
|
func (c *FullNodeStruct) MpoolGetNonce(ctx context.Context, addr address.Address) (uint64, error) {
|
2019-07-17 06:05:11 +00:00
|
|
|
return c.Internal.MpoolGetNonce(ctx, addr)
|
2019-07-17 03:05:55 +00:00
|
|
|
}
|
|
|
|
|
2019-07-25 22:15:03 +00:00
|
|
|
func (c *FullNodeStruct) ChainGetBlock(ctx context.Context, b cid.Cid) (*types.BlockHeader, error) {
|
2019-07-23 00:54:27 +00:00
|
|
|
return c.Internal.ChainGetBlock(ctx, b)
|
|
|
|
}
|
|
|
|
|
2019-11-08 05:36:50 +00:00
|
|
|
func (c *FullNodeStruct) ChainGetTipSet(ctx context.Context, key types.TipSetKey) (*types.TipSet, error) {
|
|
|
|
return c.Internal.ChainGetTipSet(ctx, key)
|
2019-10-11 06:25:25 +00:00
|
|
|
}
|
|
|
|
|
2019-08-02 03:51:34 +00:00
|
|
|
func (c *FullNodeStruct) ChainGetBlockMessages(ctx context.Context, b cid.Cid) (*BlockMessages, error) {
|
2019-07-23 00:54:27 +00:00
|
|
|
return c.Internal.ChainGetBlockMessages(ctx, b)
|
|
|
|
}
|
|
|
|
|
2019-10-03 20:22:21 +00:00
|
|
|
func (c *FullNodeStruct) ChainGetParentReceipts(ctx context.Context, b cid.Cid) ([]*types.MessageReceipt, error) {
|
|
|
|
return c.Internal.ChainGetParentReceipts(ctx, b)
|
|
|
|
}
|
|
|
|
|
2019-10-06 00:37:28 +00:00
|
|
|
func (c *FullNodeStruct) ChainGetParentMessages(ctx context.Context, b cid.Cid) ([]Message, error) {
|
2019-10-03 20:22:21 +00:00
|
|
|
return c.Internal.ChainGetParentMessages(ctx, b)
|
2019-08-07 23:22:35 +00:00
|
|
|
}
|
|
|
|
|
2019-09-18 11:01:52 +00:00
|
|
|
func (c *FullNodeStruct) ChainNotify(ctx context.Context) (<-chan []*store.HeadChange, error) {
|
2019-07-28 19:19:33 +00:00
|
|
|
return c.Internal.ChainNotify(ctx)
|
|
|
|
}
|
|
|
|
|
2019-10-01 16:28:07 +00:00
|
|
|
func (c *FullNodeStruct) ChainReadObj(ctx context.Context, obj cid.Cid) ([]byte, error) {
|
|
|
|
return c.Internal.ChainReadObj(ctx, obj)
|
|
|
|
}
|
|
|
|
|
2019-10-10 03:50:50 +00:00
|
|
|
func (c *FullNodeStruct) ChainSetHead(ctx context.Context, ts *types.TipSet) error {
|
|
|
|
return c.Internal.ChainSetHead(ctx, ts)
|
|
|
|
}
|
|
|
|
|
2019-10-11 02:14:22 +00:00
|
|
|
func (c *FullNodeStruct) ChainGetGenesis(ctx context.Context) (*types.TipSet, error) {
|
|
|
|
return c.Internal.ChainGetGenesis(ctx)
|
|
|
|
}
|
|
|
|
|
2019-10-15 05:00:30 +00:00
|
|
|
func (c *FullNodeStruct) ChainTipSetWeight(ctx context.Context, ts *types.TipSet) (types.BigInt, error) {
|
|
|
|
return c.Internal.ChainTipSetWeight(ctx, ts)
|
|
|
|
}
|
|
|
|
|
2019-09-30 21:06:47 +00:00
|
|
|
func (c *FullNodeStruct) SyncState(ctx context.Context) (*SyncState, error) {
|
|
|
|
return c.Internal.SyncState(ctx)
|
|
|
|
}
|
|
|
|
|
2019-10-14 14:21:37 +00:00
|
|
|
func (c *FullNodeStruct) SyncSubmitBlock(ctx context.Context, blk *types.BlockMsg) error {
|
|
|
|
return c.Internal.SyncSubmitBlock(ctx, blk)
|
|
|
|
}
|
|
|
|
|
2019-11-18 21:39:07 +00:00
|
|
|
func (c *FullNodeStruct) SyncIncomingBlocks(ctx context.Context) (<-chan *types.BlockHeader, error) {
|
|
|
|
return c.Internal.SyncIncomingBlocks(ctx)
|
|
|
|
}
|
|
|
|
|
2019-11-08 18:15:13 +00:00
|
|
|
func (c *FullNodeStruct) StateMinerSectors(ctx context.Context, addr address.Address, ts *types.TipSet) ([]*ChainSectorInfo, error) {
|
2019-10-27 10:27:21 +00:00
|
|
|
return c.Internal.StateMinerSectors(ctx, addr, ts)
|
2019-08-07 06:35:57 +00:00
|
|
|
}
|
|
|
|
|
2019-11-08 18:15:13 +00:00
|
|
|
func (c *FullNodeStruct) StateMinerProvingSet(ctx context.Context, addr address.Address, ts *types.TipSet) ([]*ChainSectorInfo, error) {
|
2019-09-18 02:50:03 +00:00
|
|
|
return c.Internal.StateMinerProvingSet(ctx, addr, ts)
|
2019-08-07 06:35:57 +00:00
|
|
|
}
|
|
|
|
|
2019-08-21 16:31:14 +00:00
|
|
|
func (c *FullNodeStruct) StateMinerPower(ctx context.Context, a address.Address, ts *types.TipSet) (MinerPower, error) {
|
|
|
|
return c.Internal.StateMinerPower(ctx, a, ts)
|
|
|
|
}
|
|
|
|
|
2019-09-03 04:36:07 +00:00
|
|
|
func (c *FullNodeStruct) StateMinerWorker(ctx context.Context, m address.Address, ts *types.TipSet) (address.Address, error) {
|
|
|
|
return c.Internal.StateMinerWorker(ctx, m, ts)
|
|
|
|
}
|
|
|
|
|
2019-09-16 20:11:17 +00:00
|
|
|
func (c *FullNodeStruct) StateMinerPeerID(ctx context.Context, m address.Address, ts *types.TipSet) (peer.ID, error) {
|
|
|
|
return c.Internal.StateMinerPeerID(ctx, m, ts)
|
|
|
|
}
|
2019-10-16 07:07:16 +00:00
|
|
|
|
2019-09-18 00:08:49 +00:00
|
|
|
func (c *FullNodeStruct) StateMinerProvingPeriodEnd(ctx context.Context, actor address.Address, ts *types.TipSet) (uint64, error) {
|
|
|
|
return c.Internal.StateMinerProvingPeriodEnd(ctx, actor, ts)
|
|
|
|
}
|
|
|
|
|
2019-10-16 07:07:16 +00:00
|
|
|
func (c *FullNodeStruct) StateMinerSectorSize(ctx context.Context, actor address.Address, ts *types.TipSet) (uint64, error) {
|
|
|
|
return c.Internal.StateMinerSectorSize(ctx, actor, ts)
|
|
|
|
}
|
|
|
|
|
2019-09-06 06:26:02 +00:00
|
|
|
func (c *FullNodeStruct) StateCall(ctx context.Context, msg *types.Message, ts *types.TipSet) (*types.MessageReceipt, error) {
|
|
|
|
return c.Internal.StateCall(ctx, msg, ts)
|
|
|
|
}
|
|
|
|
|
2019-09-19 20:25:18 +00:00
|
|
|
func (c *FullNodeStruct) StateReplay(ctx context.Context, ts *types.TipSet, mc cid.Cid) (*ReplayResults, error) {
|
|
|
|
return c.Internal.StateReplay(ctx, ts, mc)
|
|
|
|
}
|
|
|
|
|
2019-09-06 06:26:02 +00:00
|
|
|
func (c *FullNodeStruct) StateGetActor(ctx context.Context, actor address.Address, ts *types.TipSet) (*types.Actor, error) {
|
|
|
|
return c.Internal.StateGetActor(ctx, actor, ts)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *FullNodeStruct) StateReadState(ctx context.Context, act *types.Actor, ts *types.TipSet) (*ActorState, error) {
|
|
|
|
return c.Internal.StateReadState(ctx, act, ts)
|
|
|
|
}
|
|
|
|
|
2019-09-25 23:32:33 +00:00
|
|
|
func (c *FullNodeStruct) StatePledgeCollateral(ctx context.Context, ts *types.TipSet) (types.BigInt, error) {
|
|
|
|
return c.Internal.StatePledgeCollateral(ctx, ts)
|
|
|
|
}
|
|
|
|
|
2019-10-08 05:51:34 +00:00
|
|
|
func (c *FullNodeStruct) StateWaitMsg(ctx context.Context, msgc cid.Cid) (*MsgWait, error) {
|
|
|
|
return c.Internal.StateWaitMsg(ctx, msgc)
|
|
|
|
}
|
2019-10-12 06:45:48 +00:00
|
|
|
func (c *FullNodeStruct) StateListMiners(ctx context.Context, ts *types.TipSet) ([]address.Address, error) {
|
|
|
|
return c.Internal.StateListMiners(ctx, ts)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *FullNodeStruct) StateListActors(ctx context.Context, ts *types.TipSet) ([]address.Address, error) {
|
|
|
|
return c.Internal.StateListActors(ctx, ts)
|
|
|
|
}
|
2019-10-08 05:51:34 +00:00
|
|
|
|
2019-10-22 10:09:36 +00:00
|
|
|
func (c *FullNodeStruct) StateMarketBalance(ctx context.Context, addr address.Address, ts *types.TipSet) (actors.StorageParticipantBalance, error) {
|
|
|
|
return c.Internal.StateMarketBalance(ctx, addr, ts)
|
|
|
|
}
|
|
|
|
|
2019-10-22 19:29:05 +00:00
|
|
|
func (c *FullNodeStruct) StateMarketParticipants(ctx context.Context, ts *types.TipSet) (map[string]actors.StorageParticipantBalance, error) {
|
|
|
|
return c.Internal.StateMarketParticipants(ctx, ts)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *FullNodeStruct) StateMarketDeals(ctx context.Context, ts *types.TipSet) (map[string]actors.OnChainDeal, error) {
|
|
|
|
return c.Internal.StateMarketDeals(ctx, ts)
|
|
|
|
}
|
|
|
|
|
2019-11-07 07:57:10 +00:00
|
|
|
func (c *FullNodeStruct) StateMarketStorageDeal(ctx context.Context, dealid uint64, ts *types.TipSet) (*actors.OnChainDeal, error) {
|
|
|
|
return c.Internal.StateMarketStorageDeal(ctx, dealid, ts)
|
|
|
|
}
|
|
|
|
|
2019-11-15 16:39:43 +00:00
|
|
|
func (c *FullNodeStruct) StateLookupID(ctx context.Context, addr address.Address, ts *types.TipSet) (address.Address, error) {
|
|
|
|
return c.Internal.StateLookupID(ctx, addr, ts)
|
|
|
|
}
|
|
|
|
|
2019-11-15 18:38:09 +00:00
|
|
|
func (c *FullNodeStruct) StateChangedActors(ctx context.Context, olnstate cid.Cid, newstate cid.Cid) (map[string]types.Actor, error) {
|
|
|
|
return c.Internal.StateChangedActors(ctx, olnstate, newstate)
|
|
|
|
}
|
|
|
|
|
2019-11-19 21:27:25 +00:00
|
|
|
func (c *FullNodeStruct) StateGetReceipt(ctx context.Context, msg cid.Cid, ts *types.TipSet) (*types.MessageReceipt, error) {
|
|
|
|
return c.Internal.StateGetReceipt(ctx, msg, ts)
|
|
|
|
}
|
|
|
|
|
2019-11-08 17:15:38 +00:00
|
|
|
func (c *FullNodeStruct) MarketEnsureAvailable(ctx context.Context, addr address.Address, amt types.BigInt) error {
|
|
|
|
return c.Internal.MarketEnsureAvailable(ctx, addr, amt)
|
|
|
|
}
|
|
|
|
|
2019-09-16 13:46:05 +00:00
|
|
|
func (c *FullNodeStruct) PaychGet(ctx context.Context, from, to address.Address, ensureFunds types.BigInt) (*ChannelInfo, error) {
|
|
|
|
return c.Internal.PaychGet(ctx, from, to, ensureFunds)
|
2019-08-09 21:41:50 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
func (c *FullNodeStruct) PaychList(ctx context.Context) ([]address.Address, error) {
|
|
|
|
return c.Internal.PaychList(ctx)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *FullNodeStruct) PaychStatus(ctx context.Context, pch address.Address) (*PaychStatus, error) {
|
|
|
|
return c.Internal.PaychStatus(ctx, pch)
|
|
|
|
}
|
|
|
|
|
2019-08-12 17:09:56 +00:00
|
|
|
func (c *FullNodeStruct) PaychVoucherCheckValid(ctx context.Context, addr address.Address, sv *types.SignedVoucher) error {
|
|
|
|
return c.Internal.PaychVoucherCheckValid(ctx, addr, sv)
|
2019-08-09 21:41:50 +00:00
|
|
|
}
|
|
|
|
|
2019-08-12 17:09:56 +00:00
|
|
|
func (c *FullNodeStruct) PaychVoucherCheckSpendable(ctx context.Context, addr address.Address, sv *types.SignedVoucher, secret []byte, proof []byte) (bool, error) {
|
|
|
|
return c.Internal.PaychVoucherCheckSpendable(ctx, addr, sv, secret, proof)
|
|
|
|
}
|
|
|
|
|
2019-09-16 21:25:23 +00:00
|
|
|
func (c *FullNodeStruct) PaychVoucherAdd(ctx context.Context, addr address.Address, sv *types.SignedVoucher, proof []byte, minDelta types.BigInt) (types.BigInt, error) {
|
|
|
|
return c.Internal.PaychVoucherAdd(ctx, addr, sv, proof, minDelta)
|
2019-08-09 21:41:50 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
func (c *FullNodeStruct) PaychVoucherCreate(ctx context.Context, pch address.Address, amt types.BigInt, lane uint64) (*types.SignedVoucher, error) {
|
|
|
|
return c.Internal.PaychVoucherCreate(ctx, pch, amt, lane)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *FullNodeStruct) PaychVoucherList(ctx context.Context, pch address.Address) ([]*types.SignedVoucher, error) {
|
|
|
|
return c.Internal.PaychVoucherList(ctx, pch)
|
|
|
|
}
|
|
|
|
|
2019-08-13 04:27:54 +00:00
|
|
|
func (c *FullNodeStruct) PaychClose(ctx context.Context, a address.Address) (cid.Cid, error) {
|
2019-08-09 21:41:50 +00:00
|
|
|
return c.Internal.PaychClose(ctx, a)
|
|
|
|
}
|
|
|
|
|
2019-09-16 13:46:05 +00:00
|
|
|
func (c *FullNodeStruct) PaychAllocateLane(ctx context.Context, ch address.Address) (uint64, error) {
|
|
|
|
return c.Internal.PaychAllocateLane(ctx, ch)
|
|
|
|
}
|
|
|
|
|
2019-09-24 21:13:47 +00:00
|
|
|
func (c *FullNodeStruct) PaychNewPayment(ctx context.Context, from, to address.Address, vouchers []VoucherSpec) (*PaymentInfo, error) {
|
|
|
|
return c.Internal.PaychNewPayment(ctx, from, to, vouchers)
|
|
|
|
}
|
|
|
|
|
2019-08-13 04:27:54 +00:00
|
|
|
func (c *FullNodeStruct) PaychVoucherSubmit(ctx context.Context, ch address.Address, sv *types.SignedVoucher) (cid.Cid, error) {
|
|
|
|
return c.Internal.PaychVoucherSubmit(ctx, ch, sv)
|
|
|
|
}
|
|
|
|
|
2019-10-14 02:32:32 +00:00
|
|
|
func (c *StorageMinerStruct) ActorAddress(ctx context.Context) (address.Address, error) {
|
|
|
|
return c.Internal.ActorAddress(ctx)
|
2019-08-10 01:54:45 +00:00
|
|
|
}
|
|
|
|
|
2019-10-29 17:52:07 +00:00
|
|
|
func (c *StorageMinerStruct) StoreGarbageData(ctx context.Context) error {
|
2019-07-27 01:54:03 +00:00
|
|
|
return c.Internal.StoreGarbageData(ctx)
|
|
|
|
}
|
|
|
|
|
2019-07-27 21:08:10 +00:00
|
|
|
// Get the status of a given sector by ID
|
2019-11-08 18:15:13 +00:00
|
|
|
func (c *StorageMinerStruct) SectorsStatus(ctx context.Context, sid uint64) (SectorInfo, error) {
|
2019-07-27 21:08:10 +00:00
|
|
|
return c.Internal.SectorsStatus(ctx, sid)
|
|
|
|
}
|
|
|
|
|
|
|
|
// List all staged sectors
|
2019-10-14 02:32:32 +00:00
|
|
|
func (c *StorageMinerStruct) SectorsList(ctx context.Context) ([]uint64, error) {
|
|
|
|
return c.Internal.SectorsList(ctx)
|
2019-07-27 21:08:10 +00:00
|
|
|
}
|
|
|
|
|
2019-08-26 10:04:57 +00:00
|
|
|
func (c *StorageMinerStruct) SectorsRefs(ctx context.Context) (map[string][]SealedRef, error) {
|
|
|
|
return c.Internal.SectorsRefs(ctx)
|
|
|
|
}
|
|
|
|
|
2019-11-08 18:15:13 +00:00
|
|
|
func (c *StorageMinerStruct) WorkerStats(ctx context.Context) (WorkerStats, error) {
|
|
|
|
return c.Internal.WorkerStats(ctx)
|
|
|
|
}
|
|
|
|
|
2019-07-24 00:09:34 +00:00
|
|
|
var _ Common = &CommonStruct{}
|
|
|
|
var _ FullNode = &FullNodeStruct{}
|
|
|
|
var _ StorageMiner = &StorageMinerStruct{}
|