Function JoinPubSub

IceFireDB-SQLProxy/pkg/p2p/pubsub.go:36–59

JoinPubSub joins a pubsub topic and sets up message handling

(p2p *P2P, name string, topicName string)

// JoinPubSub joins a pubsub topic and sets up message handling
func JoinPubSub(p2p *P2P, name string, topicName string) (*PubSub, error) {
	topic, err := p2p.PubSub.Join(topicName)
	if err != nil {
		return nil, err
	}

	sub, err := topic.Subscribe()
	if err != nil {
		return nil, err
	}

	ps := &PubSub{
		PubSub:   p2p.PubSub,
		Topic:    topic,
		Sub:      sub,
		Inbound:  make(chan *Message),
		Outbound: make(chan string),
	}

	go ps.handleInbound(p2p.Ctx)
	go ps.handleOutbound(p2p.Ctx)

	return ps, nil
}

func (ps *PubSub) handleInbound(ctx context.Context) {
	for {