Method subscribe_logs

components/webapi/src/routes/ws.rs:215–240

(&mut self, guild_id: Id<GuildMarker>)

    }

    async fn subscribe_logs(&mut self, guild_id: Id<GuildMarker>) -> WsResult {
        if self
            .active_log_streams
            .iter()
            .any(|s| s.guild_id == guild_id)
        {
            // already subscribed
            return Ok(());
        }

        self.check_guild_acces(guild_id).await?;

        let stream = self
            .app_state
            .bot_rpc_client
            .stream_guild_logs(GuildSpecifier { guild_id })
            .await
            .map_err(|_| WsCloseReason::BotRpcError)?;

        self.active_log_streams.push(GuildLogStream {
            guild_id,
            inner: stream,
        });

        self.emit_subscriptions().await
    }

    async fn unsubscribe_logs(&mut self, guild_id: Id<GuildMarker>) -> WsResult {
        let current_streams = std::mem::replace(&mut self.active_log_streams, SelectAll::new());