Fix refreshing after IrisSubscribeError

mauigpapi/mqtt/conn.py

@@ -247,7 +247,7 @@ class AndroidMQTT:
                 except (asyncio.TimeoutError, IrisSubscribeError) as e:
                     self.log.exception("Error requesting iris subscribe")
                     retry += 1
-                    if retry >= 5:
+                    if retry >= 5 or isinstance(e, IrisSubscribeError):
                         self._disconnect_error = e
                         self.disconnect()
                         break

mautrix_instagram/user.py

@@ -516,7 +516,7 @@ class User(DBUser, BaseUser):
             )
         except IrisSubscribeError as e:
             self.log.warning(f"Got IrisSubscribeError {e}, refreshing...")
-            await self.refresh()
+            asyncio.create_task(self.refresh())
         except (MQTTNotConnected, MQTTNotLoggedIn) as e:
             await self.send_bridge_notice(
                 f"Error in listener: {e}",