Add pubsub support to drand beacon

Signed-off-by: Jakub Sztandera <kubuxu@protocol.ai>

node/modules/services.go

@@ -123,12 +123,19 @@ func RetrievalResolver(l *discovery.Local) retrievalmarket.PeerResolver {
 	return discovery.Multi(l)
 }
 
-func RandomBeacon(cs *store.ChainStore, _ dtypes.AfterGenesisSet) (beacon.RandomBeacon, error) {
-	gen, err := cs.GetGenesis()
+type RandomBeaconParams struct {
+	fx.In
+
+	PubSub *pubsub.PubSub `optional:"true"`
+	Cs     *store.ChainStore
+}
+
+func RandomBeacon(p RandomBeaconParams, _ dtypes.AfterGenesisSet) (beacon.RandomBeacon, error) {
+	gen, err := p.Cs.GetGenesis()
 	if err != nil {
 		return nil, err
 	}
 
 	//return beacon.NewMockBeacon(build.BlockDelay * time.Second)
-	return drand.NewDrandBeacon(gen.Timestamp, build.BlockDelay)
+	return drand.NewDrandBeacon(gen.Timestamp, build.BlockDelay, p.PubSub)
 }

node/modules/storageminer.go

@@ -43,8 +43,6 @@ import (
 
 	lapi "github.com/filecoin-project/lotus/api"
 	"github.com/filecoin-project/lotus/build"
-	"github.com/filecoin-project/lotus/chain/beacon"
-	"github.com/filecoin-project/lotus/chain/beacon/drand"
 	"github.com/filecoin-project/lotus/chain/gen"
 	"github.com/filecoin-project/lotus/chain/types"
 	"github.com/filecoin-project/lotus/markets/retrievaladapter"
@@ -364,12 +362,3 @@ func StorageAuth(ctx helpers.MetricsCtx, ca lapi.Common) (sectorstorage.StorageA
 	headers.Add("Authorization", "Bearer "+string(token))
 	return sectorstorage.StorageAuth(headers), nil
 }
-
-func MinerRandomBeacon(api lapi.FullNode) (beacon.RandomBeacon, error) {
-	gents, err := api.ChainGetGenesis(context.TODO())
-	if err != nil {
-		return nil, err
-	}
-
-	return drand.NewDrandBeacon(gents.Blocks()[0].Timestamp, build.BlockDelay)
-}