fix: Set lower log level for health check ChatRooms. (#1183)

Author: bgrozev

jicofo-common/src/main/kotlin/org/jitsi/jicofo/xmpp/XmppProvider.kt

@@ -45,6 +45,7 @@ import org.jxmpp.jid.EntityBareJid
 import org.jxmpp.jid.EntityFullJid
 import java.util.concurrent.CopyOnWriteArraySet
 import java.util.concurrent.atomic.AtomicBoolean
+import java.util.logging.Level
 
 /** Wraps a Smack [XMPPConnection]. */
 class XmppProvider(val config: XmppConnectionConfig, parentLogger: Logger) {
@@ -221,7 +222,7 @@ class XmppProvider(val config: XmppConnectionConfig, parentLogger: Logger) {
 
     @Throws(RoomExistsException::class)
     fun createRoom(name: EntityBareJid): ChatRoom = muc.createChatRoom(name)
-    fun findOrCreateRoom(name: EntityBareJid): ChatRoom = muc.findOrCreateRoom(name)
+    fun findOrCreateRoom(name: EntityBareJid, logLevel: Level): ChatRoom = muc.findOrCreateRoom(name, logLevel)
 
     fun discoverFeatures(jid: EntityFullJid): Set<Features> {
         if (!xmppConnection.isConnected) {
@@ -333,21 +334,21 @@ private class Muc(val xmppProvider: XmppProvider) {
     private val rooms: MutableMap<EntityBareJid, ChatRoomImpl> = HashMap()
 
     @Throws(RoomExistsException::class)
-    fun createChatRoom(roomJid: EntityBareJid): ChatRoom {
+    fun createChatRoom(roomJid: EntityBareJid, logLevel: Level = Level.ALL): ChatRoom {
         synchronized(rooms) {
             if (rooms.containsKey(roomJid)) {
                 throw RoomExistsException("Room '$roomJid' exists")
             }
-            return ChatRoomImpl(xmppProvider, roomJid) { removeRoom(it) }.also {
+            return ChatRoomImpl(xmppProvider, roomJid, logLevel) { removeRoom(it) }.also {
                 rooms[roomJid] = it
             }
         }
     }
 
-    fun findOrCreateRoom(roomJid: EntityBareJid): ChatRoom {
+    fun findOrCreateRoom(roomJid: EntityBareJid, logLevel: Level = Level.ALL): ChatRoom {
         synchronized(rooms) {
             try {
-                return rooms[roomJid] ?: createChatRoom(roomJid)
+                return rooms[roomJid] ?: createChatRoom(roomJid, logLevel)
             } catch (e: RoomExistsException) {
                 throw RuntimeException("Unexpected RoomExistsException.")
             }

jicofo-common/src/main/kotlin/org/jitsi/jicofo/xmpp/muc/ChatRoomImpl.kt

@@ -59,6 +59,7 @@ import org.jxmpp.jid.Jid
 import org.jxmpp.jid.impl.JidCreate
 import org.jxmpp.jid.parts.Resourcepart
 import java.util.concurrent.ConcurrentHashMap
+import java.util.logging.Level
 
 @SuppressFBWarnings(
     value = ["JLM_JSR166_UTILCONCURRENT_MONITORENTER"],
@@ -67,10 +68,12 @@ import java.util.concurrent.ConcurrentHashMap
 class ChatRoomImpl(
     override val xmppProvider: XmppProvider,
     override val roomJid: EntityBareJid,
+    logLevel: Level,
     /** Callback to call when the room is left. */
     private val leaveCallback: (ChatRoomImpl) -> Unit
 ) : ChatRoom, PresenceListener {
     private val logger = createLogger().apply {
+        level = logLevel
         addContext("room", roomJid.toString())
     }
 

jicofo/src/main/java/org/jitsi/jicofo/conference/JitsiMeetConferenceImpl.java

@@ -495,7 +495,7 @@ private void joinTheRoom()
     {
         logger.info("Joining " + roomName);
 
-        ChatRoom chatRoom = getClientXmppProvider().findOrCreateRoom(roomName);
+        ChatRoom chatRoom = getClientXmppProvider().findOrCreateRoom(roomName, logger.getLevel());
         this.chatRoom = chatRoom;
         chatRoom.addListener(chatRoomListener);
 
@@ -1875,7 +1875,7 @@ private String selectVisitorNode()
                     xmppProvider);
 
             // Will call join after releasing the lock
-            chatRoomToJoin = xmppProvider.findOrCreateRoom(visitorMucJid);
+            chatRoomToJoin = xmppProvider.findOrCreateRoom(visitorMucJid, logger.getLevel());
 
             chatRoomToJoin.addListener(new VisitorChatRoomListenerImpl(chatRoomToJoin));
 

jicofo/src/test/kotlin/org/jitsi/jicofo/DebugStateTest.kt

@@ -29,6 +29,7 @@ import org.jitsi.xmpp.extensions.colibri.ColibriStatsExtension
 import org.json.simple.parser.JSONParser
 import org.jxmpp.jid.EntityFullJid
 import org.jxmpp.jid.impl.JidCreate
+import java.util.logging.Level
 
 /**
  * All debugState interfaces should produce valid JSON.
@@ -50,7 +51,7 @@ class DebugStateTest : ShouldSpec() {
         context("ChatRoomImpl and members") {
             val conferenceJid = JidCreate.entityBareFrom("[email protected]")
 
-            val chatRoom = ChatRoomImpl(mockk(relaxed = true), conferenceJid) { }
+            val chatRoom = ChatRoomImpl(mockk(relaxed = true), conferenceJid, Level.INFO) { }
             chatRoom.debugState.shouldBeValidJson()
 
             val member = ChatRoomMemberImpl(

jicofo/src/test/kotlin/org/jitsi/jicofo/mock/MockXmppProvider.kt

@@ -25,7 +25,7 @@ class MockXmppProvider(val xmppConnection: AbstractXMPPConnection = MockXmppConn
     val chatRooms = mutableMapOf<EntityBareJid, MockChatRoom>()
     val xmppProvider = mockk<XmppProvider>(relaxed = true) {
         every { registered } returns true
-        every { findOrCreateRoom(any()) } answers { getRoom(arg(0)).chatRoom }
+        every { findOrCreateRoom(any(), any()) } answers { getRoom(arg(0)).chatRoom }
         every { xmppConnection } returns this@MockXmppProvider.xmppConnection
     }