diff --git a/node/p2p/blossomsub.go b/node/p2p/blossomsub.go index 68f6dc6..4ab113e 100644 --- a/node/p2p/blossomsub.go +++ b/node/p2p/blossomsub.go @@ -349,6 +349,7 @@ func NewBlossomSubWithHost( bs.peerID = peerID bs.h = host bs.signKey = privKey + bs.derivedPeerID = peerID go bs.background(ctx) diff --git a/types/worker/manager.go b/types/worker/manager.go index 2b36f7b..8c0e51d 100644 --- a/types/worker/manager.go +++ b/types/worker/manager.go @@ -15,5 +15,6 @@ type WorkerManager interface { GetFilterByWorkerId(coreId uint) ([]byte, error) RegisterWorker(info *store.WorkerInfo) error ProposeAllocations(coreIds []uint, filters [][]byte) error + DecideAllocations(reject [][]byte, confirm [][]byte) error RangeWorkers() ([]*store.WorkerInfo, error) }