async fn record_room(
    client: ShowRoomClient,
    room_slug: &str,
    room_id: u64,
    operator: Operator,
) -> anyhow::Result<()> {
    log::debug!("Attempt to record room {room_slug}, id = {room_id}");
    let room_info = client.room_profile(room_id).await?;
    if !room_info.is_live() {
        log::debug!("Room {room_slug} is not live, skipping...");
        return Ok(());
    }
    let stream = client.live_streaming_url(room_id).await?;
    let Some(stream) = stream.best(false) else {
        log::debug!("Room {room_slug} is not live, skipping...");
        return Ok(());
    };
    let live_id = room_info.live_id;
    let live_started_at = chrono::DateTime::from_timestamp(room_info.current_live_started_at, 0)
        .unwrap()
        .with_timezone(&chrono_tz::Asia::Tokyo)
        .to_rfc3339();
    let prefix = format!("{room_slug}/{live_id}_{live_started_at}");
    let client = HttpClient::default();
    let source = CommonM3u8LiveSource::new(client, stream.url.clone(), None, None);
    let cache = IoriCache::opendal(operator.clone(), prefix, false);
    let merger = IoriMerger::skip();
    log::info!("Start recording room {room_slug}, id = {room_id}, live_id = {live_id}");
    ParallelDownloaderBuilder::new()
        .cache(cache)
        .merger(merger)
        .download(source)
        .await?;
    Ok(())
}