Method PubLoop

IceFireDB-SQLite/pkg/p2p/pubsub.go:125–154

A method of PubSub that publishes a chatmessage to the PubSub topic until the pubsub context closes

()

// A method of PubSub that publishes a chatmessage
// to the PubSub topic until the pubsub context closes
func (cr *PubSub) PubLoop() {
	for {
		select {
		case <-cr.psctx.Done():
			return

		case message := <-cr.Outbound:
			// Create a ChatMessage
			m := chatmessage{
				Message:    message,
				SenderID:   cr.selfid.String(),
				SenderName: cr.ClientName,
			}

			// Marshal the ChatMessage into a JSON
			messagebytes, err := json.Marshal(m)
			if err != nil {
				cr.Logs <- chatlog{logprefix: "puberr", logmsg: "could not marshal JSON"}
				continue
			}

			// Publish the message to the topic
			err = cr.pstopic.Publish(cr.psctx, messagebytes)
			if err != nil {
				cr.Logs <- chatlog{logprefix: "puberr", logmsg: "could not publish to topic"}
				continue
			}
		}
	}
}

// A method of PubSub that continuously reads from the subscription
// until either the subscription or pubsub context closes.