mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2024-12-22 03:30:35 +00:00
5a66807989
* First take at updating everything to v5 * Patch gRPC gateway to use prysm v5 Fix patch * Update go ssz --------- Co-authored-by: Preston Van Loon <pvanloon@offchainlabs.com>
105 lines
3.7 KiB
Go
105 lines
3.7 KiB
Go
package sync
|
|
|
|
import (
|
|
"fmt"
|
|
"testing"
|
|
"time"
|
|
|
|
pubsub "github.com/libp2p/go-libp2p-pubsub"
|
|
"github.com/prysmaticlabs/prysm/v5/beacon-chain/p2p"
|
|
"github.com/prysmaticlabs/prysm/v5/beacon-chain/p2p/encoder"
|
|
"github.com/prysmaticlabs/prysm/v5/network/forks"
|
|
"github.com/prysmaticlabs/prysm/v5/testing/assert"
|
|
)
|
|
|
|
func TestSubTopicHandler_CRUD(t *testing.T) {
|
|
h := newSubTopicHandler()
|
|
// Non-existent topic
|
|
assert.Equal(t, false, h.topicExists("junk"))
|
|
assert.Equal(t, false, h.digestExists([4]byte{}))
|
|
|
|
digest, err := forks.CreateForkDigest(time.Now(), make([]byte, 32))
|
|
assert.NoError(t, err)
|
|
enc := encoder.SszNetworkEncoder{}
|
|
|
|
// Valid topic added in.
|
|
topic := fmt.Sprintf(p2p.BlockSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.addTopic(topic, new(pubsub.Subscription))
|
|
assert.Equal(t, true, h.topicExists(topic))
|
|
assert.Equal(t, true, h.digestExists(digest))
|
|
assert.Equal(t, 1, len(h.allTopics()))
|
|
|
|
h.removeTopic(topic)
|
|
assert.Equal(t, false, h.topicExists(topic))
|
|
assert.Equal(t, false, h.digestExists(digest))
|
|
assert.Equal(t, 0, len(h.allTopics()))
|
|
|
|
h = newSubTopicHandler()
|
|
// Multiple Topics added in.
|
|
topic = fmt.Sprintf(p2p.BlockSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.addTopic(topic, new(pubsub.Subscription))
|
|
assert.Equal(t, true, h.topicExists(topic))
|
|
|
|
topic = fmt.Sprintf(p2p.ExitSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.addTopic(topic, new(pubsub.Subscription))
|
|
assert.Equal(t, true, h.topicExists(topic))
|
|
|
|
topic = fmt.Sprintf(p2p.ProposerSlashingSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.addTopic(topic, new(pubsub.Subscription))
|
|
assert.Equal(t, true, h.topicExists(topic))
|
|
|
|
topic = fmt.Sprintf(p2p.AttesterSlashingSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.addTopic(topic, new(pubsub.Subscription))
|
|
assert.Equal(t, true, h.topicExists(topic))
|
|
|
|
topic = fmt.Sprintf(p2p.AggregateAndProofSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.addTopic(topic, new(pubsub.Subscription))
|
|
assert.Equal(t, true, h.topicExists(topic))
|
|
|
|
topic = fmt.Sprintf(p2p.SyncContributionAndProofSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.addTopic(topic, new(pubsub.Subscription))
|
|
assert.Equal(t, true, h.topicExists(topic))
|
|
|
|
topic = fmt.Sprintf(p2p.BlsToExecutionChangeSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.addTopic(topic, new(pubsub.Subscription))
|
|
assert.Equal(t, true, h.topicExists(topic))
|
|
|
|
assert.Equal(t, 7, len(h.allTopics()))
|
|
|
|
// Remove multiple topics
|
|
topic = fmt.Sprintf(p2p.AttesterSlashingSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.removeTopic(topic)
|
|
assert.Equal(t, false, h.topicExists(topic))
|
|
|
|
topic = fmt.Sprintf(p2p.ExitSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.removeTopic(topic)
|
|
assert.Equal(t, false, h.topicExists(topic))
|
|
|
|
topic = fmt.Sprintf(p2p.ProposerSlashingSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.removeTopic(topic)
|
|
assert.Equal(t, false, h.topicExists(topic))
|
|
|
|
assert.Equal(t, true, h.digestExists(digest))
|
|
assert.Equal(t, 4, len(h.allTopics()))
|
|
|
|
// Remove remaining topics.
|
|
topic = fmt.Sprintf(p2p.BlockSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.removeTopic(topic)
|
|
assert.Equal(t, false, h.topicExists(topic))
|
|
|
|
topic = fmt.Sprintf(p2p.AggregateAndProofSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.removeTopic(topic)
|
|
assert.Equal(t, false, h.topicExists(topic))
|
|
|
|
topic = fmt.Sprintf(p2p.SyncContributionAndProofSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.removeTopic(topic)
|
|
assert.Equal(t, false, h.topicExists(topic))
|
|
|
|
topic = fmt.Sprintf(p2p.BlsToExecutionChangeSubnetTopicFormat, digest) + enc.ProtocolSuffix()
|
|
h.removeTopic(topic)
|
|
assert.Equal(t, false, h.topicExists(topic))
|
|
|
|
assert.Equal(t, false, h.digestExists(digest))
|
|
assert.Equal(t, 0, len(h.allTopics()))
|
|
}
|