Function JoinPubSub

IceFireDB-PubSub/pkg/ppubsub/pubsubStore.go:122–184

A constructor function that generates and returns a new PubSub for a given P2PHost, username and roomname

(p2phost *p2p.P2P, clientName string, topicName string)

// A constructor function that generates and returns a new
// PubSub for a given P2PHost, username and roomname
func JoinPubSub(p2phost *p2p.P2P, clientName string, topicName string) (*PubSub, error) {

	// Create a PubSub topic with the room name
	topic, err := p2phost.PubSub.Join(fmt.Sprintf("pub-sub-p2p-%s", topicName))
	// Check the error
	if err != nil {
		return nil, err
	}

	// Subscribe to the PubSub topic
	sub, err := topic.Subscribe()
	// Check the error
	if err != nil {
		return nil, err
	}

	// Check the provided clientname
	if clientName == "" {
		// Use the default client name
		clientName = defaultclient
	}

	// Check the provided topicname
	if topicName == "" {
		// Use the default topic name
		topicName = defaulttopic
	}

	// Create cancellable context
	pubsubctx, cancel := context.WithCancel(context.Background())

	// Create a PubSub object
	PubSub := &PubSub{
		Host: p2phost,

		Inbound:  make(chan chatmessage),
		Outbound: make(chan string),
		Logs:     make(chan chatlog),

		psctx:    pubsubctx,
		pscancel: cancel,
		pstopic:  topic,
		psub:     sub,

		ClientName: clientName,
		TopicName:  topicName,
		selfid:     p2phost.Host.ID(),
	}

	//// Start the subscribe loop
	//go PubSub.SubLoop()
	//// Start the publish loop
	//go PubSub.PubLoop()

	pss.join[topicName] = PubSub
	go PubSub.PubLoop()
	go PubSub.SubLoop()
	go PubSub.Writer()