Method SubLoop

IceFireDB-PubSub/pkg/ppubsub/pubsubStore.go:223–260

A method of PubSub that continuously reads from the subscription until either the subscription or pubsub context closes. The received message is parsed sent into the inbound channel

()

// until either the subscription or pubsub context closes.
// The received message is parsed sent into the inbound channel
func (cr *PubSub) SubLoop() {
	// Start loop
	for {
		select {
		case <-cr.psctx.Done():
			return

		default:
			// Read a message from the subscription
			message, err := cr.psub.Next(cr.psctx)
			// Check error
			if err != nil {
				// Close the messages queue (subscription has closed)
				close(cr.Inbound)
				cr.Logs <- chatlog{logprefix: "suberr", logmsg: "subscription has closed"}
				return
			}

			// Check if message is from self
			//if message.ReceivedFrom == cr.selfid {
			//	continue
			//}

			// Declare a ChatMessage
			cm := &chatmessage{}
			// Unmarshal the message data into a ChatMessage
			err = json.Unmarshal(message.Data, cm)
			if err != nil {
				cr.Logs <- chatlog{logprefix: "suberr", logmsg: "could not unmarshal JSON"}
				continue
			}

			// Send the ChatMessage into the message queue
			cr.Inbound <- *cm
			logrus.Infof("Inbound Message: %s", cm.Message)
		}
	}
}

func (cr *PubSub) Writer() {
	for {