room topic announce and qrCode method

Author: redmaple1

wechaty/src/main/kotlin/io/github/wechaty/user/Room.kt

@@ -13,6 +13,7 @@ import io.github.wechaty.filebox.FileBox
 import io.github.wechaty.schemas.RoomMemberQueryFilter
 import io.github.wechaty.schemas.RoomPayload
 import io.github.wechaty.type.Sayable
+import io.github.wechaty.utils.QrcodeUtils
 import org.apache.commons.collections4.CollectionUtils
 import org.apache.commons.lang3.StringUtils
 import org.slf4j.LoggerFactory
@@ -31,6 +32,10 @@ class Room(wechaty: Wechaty, val id: String) : Accessory(wechaty), Sayable {
         return ready(true)
     }
 
+    fun isReady(): Boolean {
+        return this.payload != null
+    }
+
     override fun say(something: Any, contact: Contact): Future<Any> {
 
         var msgId: String? = null
@@ -75,8 +80,7 @@ class Room(wechaty: Wechaty, val id: String) : Accessory(wechaty), Sayable {
                         }
                         mentionList = varList.toList()
 
-                        val mentionAlias = mentionList.map {
-                            contact ->
+                        val mentionAlias = mentionList.map { contact ->
                             val alias = alias(contact as Contact)
                             val concatText = if (StringUtils.isNotBlank(alias)) {
                                 alias!!
@@ -213,6 +217,66 @@ class Room(wechaty: Wechaty, val id: String) : Accessory(wechaty), Sayable {
         }
     }
 
+    fun topic(newTopic: String?): Future<Any> {
+        if (!isReady()) {
+            log.warn("Room topic() room not ready")
+            throw Exception("not ready")
+        }
+
+        if (newTopic == null) {
+            if (payload != null && payload!!.topic != null) {
+                return CompletableFuture.supplyAsync {
+                    return@supplyAsync payload!!.topic
+                }
+            } else {
+                val memberIdList = puppet.roomMemberList(id).get()
+                val memberList = memberIdList.filter { it != puppet.selfId() }
+                    .map { wechaty.contactManager.load(it) }
+
+                var defaultTopic = ""
+                if (memberList.isNotEmpty()) {
+                    defaultTopic = memberList[0].name()
+                }
+
+                if (memberList.size >= 2) {
+                    for (index in 1..2) {
+                        defaultTopic += ",${memberList[index].name()}"
+                    }
+                }
+                return CompletableFuture.supplyAsync {
+                    return@supplyAsync defaultTopic
+                }
+            }
+        }
+
+        return CompletableFuture.supplyAsync {
+            try {
+                return@supplyAsync puppet.roomTopic(id, newTopic).get()
+            } catch (e: Exception) {
+                log.warn("Room topic(newTopic=$newTopic) exception:$e")
+                throw Exception(e)
+            }
+        }
+
+    }
+
+    fun announce(text: String?): Future<Any> {
+        return CompletableFuture.supplyAsync {
+            if (text == null) {
+                return@supplyAsync puppet.getRoomAnnounce(id).get()
+            } else {
+                return@supplyAsync puppet.setRoomAnnounce(id, text)
+            }
+        }
+    }
+
+    fun qrCode(): Future<String> {
+        return CompletableFuture.supplyAsync {
+            val qrCodeValue = puppet.roomQRCode(id).get()
+            return@supplyAsync QrcodeUtils.guardQrCodeValue(qrCodeValue)
+        }
+    }
+
     fun memberAll(query: RoomMemberQueryFilter?): List<Contact> {
 
         if (query == null) {

wechaty/src/main/kotlin/io/github/wechaty/utils/QrcodeUtils.kt

@@ -8,8 +8,11 @@ import com.google.zxing.common.BitMatrix
 import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel
 import java.util.*
 
+const val MAX_LEN = 7089
+
 class QrcodeUtils {
 
+
     companion object {
 
         @JvmStatic
@@ -48,6 +51,14 @@ class QrcodeUtils {
             }
             return sb.toString()
         }
+
+        @JvmStatic
+        fun guardQrCodeValue(value: String): String {
+            if (value.length > MAX_LEN) {
+                throw Exception("QR Code Value is larger then the max len. Did you return the image base64 text by mistake? See: https://github.com/wechaty/wechaty/issues/1889")
+            }
+            return value
+        }
     }
 
-}
+}