Function import_session_data

crates/opencode-cli/src/main.rs:3962–4009

(file_or_url: String)

}

async fn import_session_data(file_or_url: String) -> anyhow::Result<()> {
    let raw = if file_or_url.starts_with("http://") || file_or_url.starts_with("https://") {
        let client = reqwest::Client::new();
        let mut text = client.get(&file_or_url).send().await?.text().await?;

        if let Some(slug) = parse_share_slug(&file_or_url) {
            if serde_json::from_str::<serde_json::Value>(&text).is_err() {
                let share_api = format!("https://opencode.ai/api/share/{}/data", slug);
                text = client.get(share_api).send().await?.text().await?;
            }
        }
        text
    } else {
        fs::read_to_string(&file_or_url)?
    };
    let payload: SessionImportPayload = serde_json::from_str(&raw)?;
    let entries = normalize_import_payload(payload);

    if entries.is_empty() {
        anyhow::bail!("No session entries found in {}", file_or_url);
    }

    let db = Database::new().await?;
    let session_repo = SessionRepository::new(db.pool().clone());
    let message_repo = MessageRepository::new(db.pool().clone());

    let mut imported = 0usize;
    for mut entry in entries {
        entry.info.messages.clear();

        if session_repo.get(&entry.info.id).await?.is_some() {
            session_repo.update(&entry.info).await?;
        } else {
            session_repo.create(&entry.info).await?;
        }

        for mut message in entry.messages {
            if message.session_id.is_empty() {
                message.session_id = entry.info.id.clone();
            }
            message_repo.upsert(&message).await?;
        }
        imported += 1;
    }

    println!("Imported {} session(s) from {}", imported, file_or_url);
    Ok(())
}

fn parse_github_remote(url: &str) -> Option<(String, String)> {
    let normalized = url.trim().trim_end_matches('/').trim_end_matches(".git");