import type { MaybePromise } from '@mtcute/core'
import { MemoryStorage } from '@mtcute/core'
import { setPlatform } from '@mtcute/core/platform.js'
import { LogManager, sleep } from '@mtcute/core/utils.js'
import { DenoCryptoProvider, DenoPlatform, SqliteStorage, TcpTransport } from '@mtcute/deno'

export function getApiParams(storage?: string) {
    if (!Deno.env.has('API_ID') || !Deno.env.has('API_HASH')) {
        throw new Error('API_ID and API_HASH env variables must be set')
    }

    Deno.mkdirSync('.sessions', { recursive: true })

    setPlatform(new DenoPlatform())

    return {
        apiId: Number.parseInt(Deno.env.get('API_ID')!),
        apiHash: Deno.env.get('API_HASH')!,
        testMode: true,
        storage: storage ? new SqliteStorage(`.sessions/${storage}`) : new MemoryStorage(),
        logLevel: LogManager.VERBOSE,
        transport: () => new TcpTransport(),
        crypto: new DenoCryptoProvider(),
    }
}

export async function waitFor(condition: () => MaybePromise<void>, timeout = 5000): Promise<void> {
    const start = Date.now()
    let lastError

    while (Date.now() - start < timeout) {
        try {
            await condition()

            return
        } catch (e) {
            lastError = e
            await sleep(100)
        }
    }

    throw lastError
}