Function load_entries_inner

rust/crates/ccusage/src/adapter/codebuff/loader.rs:22–53

(shared: &SharedArgs, pricing: &PricingMap)

}

fn load_entries_inner(shared: &SharedArgs, pricing: &PricingMap) -> Result<Vec<LoadedEntry>> {
    let tz = parse_tz(shared.timezone.as_deref());
    let mut files = discover_chat_files()?;
    files.sort();
    // Read files in parallel but apply the last-wins dedup sequentially over the
    // original (sorted) file order, so the surviving entry per dedup key is
    // identical to the single-threaded read.
    let loaded = read_files_parallel(&files, shared.single_thread, |file| {
        load_chat_file(file).unwrap_or_else(|error| {
            debug_log(
                shared,
                format!(
                    "Failed to read Codebuff chat file {}: {error}",
                    file.display()
                ),
            );
            Vec::new()
        })
    });
    let mut deduped = HashMap::<String, CodebuffEntry>::new();
    for file_entries in loaded {
        for entry in file_entries {
            deduped.insert(entry.dedup_key.clone(), entry);
        }
    }
    let mut entries = deduped
        .into_values()
        .map(|entry| to_loaded_entry(entry, tz.as_ref(), pricing))
        .collect::<Vec<_>>();
    entries.sort_by_key(|entry| entry.timestamp);
    Ok(entries)
}

fn to_loaded_entry(
    entry: CodebuffEntry,