Kord doesn't reconnect

{"url": "wss://gateway.discord.gg", "shards": 15, "session_start_limit": {"total": 1000, "remaining": 950, "reset_after": 63572627, "max_concurrency": 1}}

{"url": "wss://gateway.discord.gg", "shards": 15, "session_start_limit": {"total": 1000, "remaining": 950, "reset_after": 63572627, "max_concurrency": 1}}

public suspend fun startWithConfig(configuration: GatewayConfiguration, maxConcurrency: Int) {
    require(maxConcurrency > 0) { "Invalid maxConcurrency: $maxConcurrency" }

    // see https://discord.com/developers/docs/topics/gateway#sharding-max-concurrency
    return coroutineScope {

        var lastRateLimitKey = -1
        val readyListeners = mutableListOf<Job>()

        // sort gateways.entries to start shards in order
        for ((shardId, gateway) in gateways.entries.sortedBy { it.key }) {
            require(shardId >= 0) { "Negative shardId: $shardId" }

            val rateLimitKey = shardId % maxConcurrency

            if (rateLimitKey <= lastRateLimitKey) {
                readyListeners.joinAll() // wait until all gateways from last bucket are started
                readyListeners.clear()
            }

            // make sure we don't miss the event by executing until first suspension point before starting gateway
            readyListeners += launch(start = UNDISPATCHED) { gateway.events.first { it is Ready } }

            val config = configuration.copy(shard = configuration.shard.copy(index = shardId))
            launch { gateway.start(config) }

            lastRateLimitKey = rateLimitKey
        }

        readyListeners.clear()
    }
}

public suspend fun startWithConfig(configuration: GatewayConfiguration, maxConcurrency: Int) {
    require(maxConcurrency > 0) { "Invalid maxConcurrency: $maxConcurrency" }

    // see https://discord.com/developers/docs/topics/gateway#sharding-max-concurrency
    return coroutineScope {

        var lastRateLimitKey = -1
        val readyListeners = mutableListOf<Job>()

        // sort gateways.entries to start shards in order
        for ((shardId, gateway) in gateways.entries.sortedBy { it.key }) {
            require(shardId >= 0) { "Negative shardId: $shardId" }

            val rateLimitKey = shardId % maxConcurrency

            if (rateLimitKey <= lastRateLimitKey) {
                readyListeners.joinAll() // wait until all gateways from last bucket are started
                readyListeners.clear()
            }

            // make sure we don't miss the event by executing until first suspension point before starting gateway
            readyListeners += launch(start = UNDISPATCHED) { gateway.events.first { it is Ready } }

            val config = configuration.copy(shard = configuration.shard.copy(index = shardId))
            launch { gateway.start(config) }

            lastRateLimitKey = rateLimitKey
        }

        readyListeners.clear()
    }
}

if (enableShutdownHook) {
    Runtime.getRuntime().addShutdownHook(thread(false) {
        runBlocking {
            gateway.detachAll()
        }
    })
}

if (enableShutdownHook) {
    Runtime.getRuntime().addShutdownHook(thread(false) {
        runBlocking {
            gateway.detachAll()
        }
    })
}

suspend fun main() = coroutineScope {
    val kord = Kord("token")

    launch {
        val totalShards = kord.resources.shards.totalShards
        var shardsConnected = 0
        kord.events
            .onEach { event ->
                if (event is ReadyEvent) {
                    shardsConnected++
                    println("$shardsConnected / $totalShards shards connected")
                } else {
                    println("Received $event") // e.g. SessionReset when rate limiting is wrong
                }
            }
            .takeWhile { shardsConnected < totalShards }
            .onCompletion { kord.shutdown() }
            .collect()
    }

    kord.login { intents = Intents.none } // don't care about most events
}

suspend fun main() = coroutineScope {
    val kord = Kord("token")

    launch {
        val totalShards = kord.resources.shards.totalShards
        var shardsConnected = 0
        kord.events
            .onEach { event ->
                if (event is ReadyEvent) {
                    shardsConnected++
                    println("$shardsConnected / $totalShards shards connected")
                } else {
                    println("Received $event") // e.g. SessionReset when rate limiting is wrong
                }
            }
            .takeWhile { shardsConnected < totalShards }
            .onCompletion { kord.shutdown() }
            .collect()
    }

    kord.login { intents = Intents.none } // don't care about most events
}

val kord = Kord(token) {
    sharding { Shards(totalShards = 1344) }
}

val kord = Kord(token) {
    sharding { Shards(totalShards = 1344) }
}

if (client.engine.config.threadsCount < shards.size + 1) {
    logger.warn {
        """
        kord's http client is currently using ${client.engine.config.threadsCount} threads, 
        which is less than the advised thread count of ${shards.size + 1} (number of shards + 1)
        """.trimIndent()
    }
}

if (client.engine.config.threadsCount < shards.size + 1) {
    logger.warn {
        """
        kord's http client is currently using ${client.engine.config.threadsCount} threads, 
        which is less than the advised thread count of ${shards.size + 1} (number of shards + 1)
        """.trimIndent()
    }
}

val kord = Kord(token) {
    client = HttpClient(CIO) {
        engine {
            threadsCount = ... // maybe this helps
            maxConnectionsCount = ... // or this
        }
    }
    sharding { ... }
}

val kord = Kord(token) {
    client = HttpClient(CIO) {
        engine {
            threadsCount = ... // maybe this helps
            maxConnectionsCount = ... // or this
        }
    }
    sharding { ... }
}

HttpClient(CIO) {
    engine {
        maxConnectionsCount = ...
        endpoint {
            maxConnectionsPerRoute = ... // default 100 -> all gw connections are on the same route
        }
    }
}

HttpClient(CIO) {
    engine {
        maxConnectionsCount = ...
        endpoint {
            maxConnectionsPerRoute = ... // default 100 -> all gw connections are on the same route
        }
    }
}