Working reception

api/send.go

@@ -37,7 +37,7 @@ func (c *Client) SendUnsafe(m message.Send, param params.Unsafe) ([]id.Round,
 // if it fails.
 func (c *Client) SendCMIX(msg format.Message, param params.CMIX) (id.Round,
 	error) {
-	jww.INFO.Printf("SendCMIX(%v)", msg)
+	jww.INFO.Printf("SendCMIX(%s)", string(msg.GetContents()))
 	return c.network.SendCMIX(msg, param)
 }
 

cmd/root.go

@@ -178,7 +178,8 @@ var rootCmd = &cobra.Command{
 				done = true
 				break
 			case m := <-recvCh:
-				fmt.Printf("Message received: %v", m)
+				fmt.Printf("Message received: %s", string(
+					m.Payload))
 				break
 			}
 		}

network/follow.go

@@ -62,7 +62,7 @@ var followCnt int = 0
 // executes each iteration of the follower
 func (m *manager) follow(rng csprng.Source, comms followNetworkComms) {
 
-	jww.INFO.Printf("follow: %d", followCnt)
+	jww.TRACE.Printf("follow: %d", followCnt)
 	followCnt++
 
 	//randomly select a gateway to poll
@@ -148,8 +148,4 @@ func (m *manager) follow(rng csprng.Source, comms followNetworkComms) {
 	// messages for the user (bloom not implemented yet)
 	checkedRounds.RangeUncheckedMasked(gwRoundsState, roundChecker,
 		int(m.param.MaxCheckedRounds))
-
-	wr := m.Instance.GetWaitingRounds()
-
-	jww.INFO.Printf("WaitingRounds: %+v, %d", wr.GetSlice(), wr.Len())
 }

network/message/handler.go

@@ -62,6 +62,7 @@ func (m *Manager) handleMessage(ecrMsg format.Message) {
 	} else {
 		// if it doesnt match any form of encrypted, hear it as a raw message
 		// and add it to garbled messages to be handled later
+		msg = ecrMsg
 		raw := message.Receive{
 			Payload:     msg.GetRawContents(),
 			MessageType: message.Raw,