topic.go

package core

import (
	pubsub "github.com/libp2p/go-libp2p-pubsub"
)

var (
	msgTopic *pubsub.Topic
)

func (w *Witness) JoinTopic(topic string) (err error) {
	msgTopic, err = w.p2pSrv.JoinTopic("topic")
	return err
}