lotus/node/impl/full.go

164 lines
4.4 KiB
Go
Raw Normal View History

package impl
2019-07-08 19:07:16 +00:00
import (
"context"
2019-07-26 04:54:22 +00:00
"golang.org/x/xerrors"
2019-07-16 16:07:08 +00:00
2019-07-08 19:07:16 +00:00
"github.com/filecoin-project/go-lotus/api"
2019-07-09 15:19:27 +00:00
"github.com/filecoin-project/go-lotus/chain"
2019-07-11 02:36:43 +00:00
"github.com/filecoin-project/go-lotus/chain/address"
2019-07-25 22:15:33 +00:00
"github.com/filecoin-project/go-lotus/chain/gen"
2019-07-26 04:54:22 +00:00
"github.com/filecoin-project/go-lotus/chain/store"
2019-07-18 20:26:04 +00:00
"github.com/filecoin-project/go-lotus/chain/types"
2019-07-25 22:15:33 +00:00
"github.com/filecoin-project/go-lotus/chain/wallet"
2019-07-11 02:36:43 +00:00
"github.com/filecoin-project/go-lotus/miner"
2019-07-12 09:59:18 +00:00
"github.com/filecoin-project/go-lotus/node/client"
2019-07-23 20:27:05 +00:00
"github.com/ipfs/go-cid"
2019-07-23 17:27:45 +00:00
logging "github.com/ipfs/go-log"
2019-07-09 15:19:27 +00:00
pubsub "github.com/libp2p/go-libp2p-pubsub"
2019-07-08 19:07:16 +00:00
)
2019-07-23 17:27:45 +00:00
var log = logging.Logger("node")
type FullNodeAPI struct {
2019-07-12 09:59:18 +00:00
client.LocalStorage
2019-07-24 00:58:31 +00:00
CommonAPI
2019-07-26 04:54:22 +00:00
Chain *store.ChainStore
2019-07-24 01:10:26 +00:00
PubSub *pubsub.PubSub
Mpool *chain.MessagePool
2019-07-25 22:15:33 +00:00
Wallet *wallet.Wallet
2019-07-09 15:19:27 +00:00
}
func (a *FullNodeAPI) ChainNotify(ctx context.Context) (<-chan *store.HeadChange, error) {
return a.Chain.SubHeadChanges(ctx), nil
}
func (a *FullNodeAPI) ChainSubmitBlock(ctx context.Context, blk *chain.BlockMsg) error {
2019-07-11 02:36:43 +00:00
if err := a.Chain.AddBlock(blk.Header); err != nil {
return err
}
2019-07-09 15:19:27 +00:00
b, err := blk.Serialize()
if err != nil {
return err
}
// TODO: anything else to do here?
return a.PubSub.Publish("/fil/blocks", b)
}
2019-07-26 04:54:22 +00:00
func (a *FullNodeAPI) ChainHead(context.Context) (*types.TipSet, error) {
2019-07-11 02:36:43 +00:00
return a.Chain.GetHeaviestTipSet(), nil
}
2019-07-26 04:54:22 +00:00
func (a *FullNodeAPI) ChainGetRandomness(ctx context.Context, pts *types.TipSet) ([]byte, error) {
2019-07-11 02:36:43 +00:00
// TODO: this needs to look back in the chain for the right random beacon value
return []byte("foo bar random"), nil
2019-07-08 19:07:16 +00:00
}
func (a *FullNodeAPI) ChainWaitMsg(ctx context.Context, msg cid.Cid) (*api.MsgWait, error) {
2019-07-28 02:32:09 +00:00
blkcid, recpt, err := a.Chain.WaitForMessage(ctx, msg)
if err != nil {
return nil, err
}
return &api.MsgWait{
InBlock: blkcid,
Receipt: *recpt,
2019-07-28 02:32:09 +00:00
}, nil
}
func (a *FullNodeAPI) ChainGetBlock(ctx context.Context, msg cid.Cid) (*types.BlockHeader, error) {
2019-07-23 00:54:27 +00:00
return a.Chain.GetBlock(msg)
}
func (a *FullNodeAPI) ChainGetBlockMessages(ctx context.Context, msg cid.Cid) ([]*types.SignedMessage, error) {
2019-07-23 00:54:27 +00:00
b, err := a.Chain.GetBlock(msg)
if err != nil {
return nil, err
}
return a.Chain.MessagesForBlock(b)
}
2019-07-26 04:54:22 +00:00
func (a *FullNodeAPI) MpoolPending(ctx context.Context, ts *types.TipSet) ([]*types.SignedMessage, error) {
2019-07-11 02:36:43 +00:00
// TODO: need to make sure we don't return messages that were already included in the referenced chain
// also need to accept ts == nil just fine, assume nil == chain.Head()
2019-07-09 22:58:51 +00:00
return a.Mpool.Pending(), nil
}
func (a *FullNodeAPI) MpoolPush(ctx context.Context, smsg *types.SignedMessage) error {
msgb, err := smsg.Serialize()
if err != nil {
return err
}
if err := a.Mpool.Add(smsg); err != nil {
return err
}
return a.PubSub.Publish("/fil/messages", msgb)
}
func (a *FullNodeAPI) MpoolGetNonce(ctx context.Context, addr address.Address) (uint64, error) {
return a.Mpool.GetNonce(addr)
}
func (a *FullNodeAPI) MinerStart(ctx context.Context, addr address.Address) error {
2019-07-11 02:36:43 +00:00
// hrm...
m := miner.NewMiner(a, addr)
go m.Mine(context.TODO())
return nil
}
2019-07-26 04:54:22 +00:00
func (a *FullNodeAPI) MinerCreateBlock(ctx context.Context, addr address.Address, parents *types.TipSet, tickets []types.Ticket, proof types.ElectionProof, msgs []*types.SignedMessage) (*chain.BlockMsg, error) {
2019-07-25 22:15:33 +00:00
fblk, err := gen.MinerCreateBlock(ctx, a.Chain, addr, parents, tickets, proof, msgs)
2019-07-11 02:36:43 +00:00
if err != nil {
return nil, err
}
var out chain.BlockMsg
out.Header = fblk.Header
for _, msg := range fblk.Messages {
out.Messages = append(out.Messages, msg.Cid())
}
return &out, nil
}
func (a *FullNodeAPI) WalletNew(ctx context.Context, typ string) (address.Address, error) {
2019-07-13 00:41:32 +00:00
return a.Wallet.GenerateKey(typ)
}
func (a *FullNodeAPI) WalletList(ctx context.Context) ([]address.Address, error) {
return a.Wallet.ListAddrs()
2019-07-13 00:41:32 +00:00
}
func (a *FullNodeAPI) WalletBalance(ctx context.Context, addr address.Address) (types.BigInt, error) {
2019-07-18 20:26:04 +00:00
return a.Chain.GetBalance(addr)
}
func (a *FullNodeAPI) WalletSign(ctx context.Context, k address.Address, msg []byte) (*types.Signature, error) {
return a.Wallet.Sign(k, msg)
}
func (a *FullNodeAPI) WalletDefaultAddress(ctx context.Context) (address.Address, error) {
2019-07-18 19:12:30 +00:00
addrs, err := a.Wallet.ListAddrs()
if err != nil {
return address.Undef, err
}
if len(addrs) == 0 {
return address.Undef, xerrors.New("no addresses in wallet")
}
// TODO: store a default address in the config or 'wallet' portion of the repo
return addrs[0], nil
}
var _ api.FullNode = &FullNodeAPI{}