diff --git a/app/plugins/contactRetry.go b/app/plugins/contactRetry.go index dcfd06d..97e34ce 100644 --- a/app/plugins/contactRetry.go +++ b/app/plugins/contactRetry.go @@ -327,7 +327,7 @@ func (cr *contactRetry) handleEvent(id string, state connections.ConnectionState pinf, _ := cr.connections.Load(id) p := pinf.(*contact) - log.Infof(" managing state change for %v %v to %v by self %v", id, connections.ConnectionStateName[p.state], connections.ConnectionStateName[state], cr.onion) + log.Debugf(" managing state change for %v %v to %v by self %v", id, connections.ConnectionStateName[p.state], connections.ConnectionStateName[state], cr.onion) if state == connections.DISCONNECTED || state == connections.FAILED || state == connections.KILLED { if p.state == connections.SYNCED || p.state == connections.AUTHENTICATED { p.lastSeen = time.Now() diff --git a/peer/cwtch_peer.go b/peer/cwtch_peer.go index 3d7ed6c..d5a9321 100644 --- a/peer/cwtch_peer.go +++ b/peer/cwtch_peer.go @@ -1015,7 +1015,7 @@ func (cp *cwtchPeer) Listen() { cp.mutex.Lock() defer cp.mutex.Unlock() if !cp.listenStatus { - log.Infof("cwtchPeer Listen sending ProtocolEngineStartListen\n") + log.Debugf("cwtchPeer Listen sending ProtocolEngineStartListen\n") cp.listenStatus = true onion, _ := cp.storage.LoadProfileKeyValue(TypeAttribute, attr.PublicScope.ConstructScopedZonedPath(attr.ProfileZone.ConstructZonedPath(constants.Onion)).ToString()) cp.eventBus.Publish(event.NewEvent(event.ProtocolEngineStartListen, map[event.Field]string{event.Onion: string(onion)})) diff --git a/testing/cwtch_peer_server_integration_test.go b/testing/cwtch_peer_server_integration_test.go index 1fbe98f..198799b 100644 --- a/testing/cwtch_peer_server_integration_test.go +++ b/testing/cwtch_peer_server_integration_test.go @@ -267,9 +267,6 @@ func TestCwtchPeerIntegration(t *testing.T) { t.Fatalf("Failed to Add Server Bundle %v", err) } - log.Infof("Waiting for alice to join server...") - waitForConnection(t, alice, ServerAddr, connections.SYNCED) - // Creating a Group log.Infof("Creating group on %v...", ServerAddr) aliceGroupConversationID, err := alice.StartGroup("Our Cool Testing Group", ServerAddr) @@ -300,6 +297,8 @@ func TestCwtchPeerIntegration(t *testing.T) { usedTokens += len(bobLines) } + log.Infof("Waiting for alice to join server...") + waitForConnection(t, alice, ServerAddr, connections.SYNCED) log.Infof("Waiting for Bob to join connect to group server...") waitForConnection(t, bob, ServerAddr, connections.SYNCED)