prax-import 0.10.0

//! Multi-file Prisma schema discovery, parse, and merge.
//!
//! Mirrors the design in `docs/superpowers/specs/2026-05-19-multi-file-schema-design.md`.
//! Prisma's `prismaSchemaFolder` mode places multiple `*.prisma` files in one
//! directory and treats them as a single logical schema. This module walks
//! such a directory, parses each file, stamps provenance, and merges into a
//! single [`PrismaSchema`] with conflict detection.

use std::path::{Path, PathBuf};

use walkdir::WalkDir;

use super::parser::parse_prisma_schema;
use super::types::{PrismaSchema, PrismaSourceId};
use crate::error::{ImportError, ImportResult};
use prax_schema::Schema;

/// A discovered `.prisma` file with absolute + relative paths.
#[derive(Debug, Clone)]
pub struct PrismaFile {
    pub absolute: PathBuf,
    pub relative: PathBuf,
}

/// Map of [`PrismaSourceId`] -> [`PrismaFile`], built during multi-file import.
#[derive(Debug, Default)]
pub struct PrismaSourceMap {
    files: Vec<PrismaFile>,
}

impl PrismaSourceMap {
    pub fn get(&self, id: PrismaSourceId) -> Option<&PrismaFile> {
        self.files.get(id.0 as usize)
    }
    pub fn iter(&self) -> impl Iterator<Item = (PrismaSourceId, &PrismaFile)> {
        self.files
            .iter()
            .enumerate()
            .map(|(i, f)| (PrismaSourceId(i as u32), f))
    }
    pub fn len(&self) -> usize {
        self.files.len()
    }
    pub fn is_empty(&self) -> bool {
        self.files.is_empty()
    }
}

/// Discover all `*.prisma` files under `root`, sorted lexicographically by
/// relative path.
///
/// Skips hidden entries, symlinks, and `node_modules/` directories. (We
/// deliberately do not reuse the loader's `target/` skip — the importer's
/// skip set is Prisma-ecosystem-specific.)
pub fn discover_prisma(root: &Path) -> ImportResult<Vec<PrismaFile>> {
    let canonical = root.canonicalize().unwrap_or_else(|_| root.to_path_buf());
    let mut out = Vec::new();
    for entry in WalkDir::new(&canonical)
        .follow_links(false)
        .into_iter()
        .filter_entry(|e| !is_skipped(e))
    {
        let entry = entry.map_err(|e| {
            ImportError::IoError(
                e.into_io_error()
                    .unwrap_or_else(|| std::io::Error::other("walkdir error")),
            )
        })?;
        if !entry.file_type().is_file() {
            continue;
        }
        if entry.path().extension().and_then(|s| s.to_str()) != Some("prisma") {
            continue;
        }
        let relative = entry
            .path()
            .strip_prefix(&canonical)
            .unwrap_or(entry.path())
            .to_path_buf();
        out.push(PrismaFile {
            absolute: entry.path().to_path_buf(),
            relative,
        });
    }
    out.sort_by(|a, b| a.relative.cmp(&b.relative));
    Ok(out)
}

fn is_skipped(entry: &walkdir::DirEntry) -> bool {
    if entry.depth() == 0 {
        return false;
    }
    if let Some(name) = entry.file_name().to_str() {
        if name.starts_with('.') {
            return true;
        }
        if entry.file_type().is_dir() && name == "node_modules" {
            return true;
        }
    }
    if entry.file_type().is_symlink() {
        return true;
    }
    false
}

/// Parse every `.prisma` file under `root`, stamp source provenance, and
/// merge into one [`PrismaSchema`]. Returns the merged schema and the source
/// map; on conflict, returns an error.
pub fn parse_and_merge_directory(root: &Path) -> ImportResult<(PrismaSchema, PrismaSourceMap)> {
    let files = discover_prisma(root)?;
    if files.is_empty() {
        return Err(ImportError::EmptyPrismaDirectory {
            path: root.to_path_buf(),
        });
    }

    let sources = PrismaSourceMap {
        files: files.clone(),
    };
    let mut merged = PrismaSchema::default();

    for (idx, f) in files.iter().enumerate() {
        let sid = PrismaSourceId(idx as u32);
        let content = std::fs::read_to_string(&f.absolute)?;
        let mut per_file = parse_prisma_schema(&content)?;
        stamp_prisma(&mut per_file, sid);
        try_merge_prisma(&mut merged, per_file, sid)?;
    }

    Ok((merged, sources))
}

fn stamp_prisma(s: &mut PrismaSchema, sid: PrismaSourceId) {
    for m in &mut s.models {
        m.source_id = Some(sid);
    }
    for e in &mut s.enums {
        e.source_id = Some(sid);
    }
    if let Some(ds) = &mut s.datasource {
        ds.source_id = Some(sid);
    }
}

fn try_merge_prisma(
    into: &mut PrismaSchema,
    other: PrismaSchema,
    incoming_sid: PrismaSourceId,
) -> ImportResult<()> {
    for m in other.models {
        if let Some(existing) = into.models.iter().find(|x| x.name == m.name) {
            return Err(ImportError::DuplicatePrismaModel {
                name: m.name.clone(),
                first: existing.source_id.unwrap_or(PrismaSourceId(0)),
                second: incoming_sid,
            });
        }
        into.models.push(m);
    }
    for e in other.enums {
        if let Some(existing) = into.enums.iter().find(|x| x.name == e.name) {
            return Err(ImportError::DuplicatePrismaEnum {
                name: e.name.clone(),
                first: existing.source_id.unwrap_or(PrismaSourceId(0)),
                second: incoming_sid,
            });
        }
        into.enums.push(e);
    }
    if let Some(incoming) = other.datasource {
        if let Some(existing) = &into.datasource {
            return Err(ImportError::MultiplePrismaDatasource {
                first: existing.source_id.unwrap_or(PrismaSourceId(0)),
                second: incoming_sid,
            });
        }
        into.datasource = Some(incoming);
    }
    Ok(())
}

/// Convert a directory of `.prisma` files into a mirrored directory of `.prax`
/// files. Each output file contains only the items that came from its
/// corresponding input file (bucketed by `PrismaSourceId`), with the merged
/// AST guaranteeing cross-file relations resolve cleanly.
///
/// `format_text` is the renderer that turns a per-file [`Schema`] back into
/// `.prax` source text — the CLI's existing `format_schema` is a natural fit.
///
/// Returns the number of `.prax` files emitted. Skips source buckets that
/// would produce an empty output (e.g. a `.prisma` file with only comments).
///
/// Pre-flight: if `output` exists and is non-empty, requires `force` to be
/// true; otherwise errors with `ImportError::InvalidConfig`.
pub fn import_prisma_directory<F>(
    input: &Path,
    output: &Path,
    format_text: F,
    force: bool,
) -> ImportResult<usize>
where
    F: Fn(&Schema) -> String,
{
    if output.exists() {
        let is_empty = output
            .read_dir()
            .map(|mut d| d.next().is_none())
            .unwrap_or(true);
        if !is_empty && !force {
            return Err(ImportError::InvalidConfig(format!(
                "output directory {} is not empty (pass --force to overwrite)",
                output.display()
            )));
        }
    }

    let (merged_prisma, sources) = parse_and_merge_directory(input)?;
    let merged_prax = super::parser::convert_prisma_to_prax(merged_prisma)?;

    // Bucket prax items by their (translated) PrismaSourceId.
    let mut buckets: std::collections::BTreeMap<PrismaSourceId, Schema> =
        std::collections::BTreeMap::new();
    bucket_prax_items(&merged_prax, &mut buckets);

    std::fs::create_dir_all(output)?;

    let mut emitted = 0usize;
    for (sid, prax_for_file) in &buckets {
        if is_empty_schema(prax_for_file) {
            continue;
        }
        let Some(file) = sources.get(*sid) else {
            continue;
        };
        let mut out_path = output.join(&file.relative);
        out_path.set_extension("prax");
        if let Some(parent) = out_path.parent() {
            std::fs::create_dir_all(parent)?;
        }
        let text = format_text(prax_for_file);
        std::fs::write(&out_path, text)?;
        emitted += 1;
    }
    Ok(emitted)
}

fn is_empty_schema(s: &Schema) -> bool {
    s.models.is_empty()
        && s.enums.is_empty()
        && s.types.is_empty()
        && s.views.is_empty()
        && s.datasource.is_none()
        && s.generators.is_empty()
}

fn bucket_prax_items(
    merged: &Schema,
    out: &mut std::collections::BTreeMap<PrismaSourceId, Schema>,
) {
    use prax_schema::SourceId;
    let to_prisma = |s: SourceId| PrismaSourceId(s.0);

    for m in merged.models.values() {
        let sid = m.source_id.map(to_prisma).unwrap_or(PrismaSourceId(0));
        out.entry(sid).or_default().add_model(m.clone());
    }
    for e in merged.enums.values() {
        let sid = e.source_id.map(to_prisma).unwrap_or(PrismaSourceId(0));
        out.entry(sid).or_default().add_enum(e.clone());
    }
    if let Some(ds) = &merged.datasource {
        let sid = ds.source_id.map(to_prisma).unwrap_or(PrismaSourceId(0));
        out.entry(sid).or_default().set_datasource(ds.clone());
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use tempfile::tempdir;

    #[test]
    fn parses_and_merges_directory() {
        let dir = tempdir().unwrap();
        std::fs::write(
            dir.path().join("a.prisma"),
            r#"datasource db { provider = "postgresql" url = env("DB_URL") }

model A {
  id Int @id @default(autoincrement())
}
"#,
        )
        .unwrap();
        std::fs::write(
            dir.path().join("b.prisma"),
            "model B { id Int @id @default(autoincrement()) }",
        )
        .unwrap();

        let (merged, sources) = parse_and_merge_directory(dir.path()).unwrap();
        assert_eq!(merged.models.len(), 2);
        assert!(merged.datasource.is_some());
        assert_eq!(sources.len(), 2);
    }

    #[test]
    fn duplicate_models_error() {
        let dir = tempdir().unwrap();
        std::fs::write(
            dir.path().join("a.prisma"),
            "model X { id Int @id @default(autoincrement()) }",
        )
        .unwrap();
        std::fs::write(
            dir.path().join("b.prisma"),
            "model X { id Int @id @default(autoincrement()) }",
        )
        .unwrap();

        let err = parse_and_merge_directory(dir.path()).unwrap_err();
        let msg = format!("{err}");
        assert!(msg.contains("duplicate") && msg.contains("X"), "got: {msg}");
    }

    #[test]
    fn empty_dir_errors() {
        let dir = tempdir().unwrap();
        let err = parse_and_merge_directory(dir.path()).unwrap_err();
        assert!(matches!(err, ImportError::EmptyPrismaDirectory { .. }));
    }

    /// Trivial test renderer — emits a marker so we can verify which models
    /// landed in which file without depending on the CLI's format_schema.
    fn debug_render(s: &Schema) -> String {
        let mut out = String::new();
        if let Some(ds) = &s.datasource {
            out.push_str(&format!(
                "// datasource provider={}\n",
                ds.provider.as_str()
            ));
        }
        for m in s.models.values() {
            out.push_str(&format!("model {} {{}}\n", m.name.as_str()));
        }
        for e in s.enums.values() {
            out.push_str(&format!("enum {} {{}}\n", e.name.as_str()));
        }
        out
    }

    #[test]
    fn directory_round_trip_mirrors_layout() {
        let input = tempdir().unwrap();
        let output = tempdir().unwrap();

        std::fs::create_dir_all(input.path().join("models")).unwrap();
        std::fs::write(
            input.path().join("schema.prisma"),
            r#"datasource db { provider = "postgresql" url = env("DB") }"#,
        )
        .unwrap();
        std::fs::write(
            input.path().join("models/user.prisma"),
            "model User { id Int @id @default(autoincrement()) email String @unique }",
        )
        .unwrap();
        std::fs::write(
            input.path().join("models/post.prisma"),
            "model Post { id Int @id @default(autoincrement()) author_id Int }",
        )
        .unwrap();

        let count = import_prisma_directory(input.path(), output.path(), debug_render, false)
            .expect("import should succeed");

        assert_eq!(count, 3);
        assert!(output.path().join("schema.prax").exists());
        assert!(output.path().join("models/user.prax").exists());
        assert!(output.path().join("models/post.prax").exists());

        // Datasource lives in the mirrored schema.prax, not in the model files.
        let schema_content = std::fs::read_to_string(output.path().join("schema.prax")).unwrap();
        assert!(schema_content.contains("datasource"));
        let user_content = std::fs::read_to_string(output.path().join("models/user.prax")).unwrap();
        assert!(user_content.contains("model User"));
        assert!(!user_content.contains("model Post"));
    }

    #[test]
    fn refuses_to_overwrite_non_empty_output_without_force() {
        let input = tempdir().unwrap();
        let output = tempdir().unwrap();
        std::fs::write(
            input.path().join("a.prisma"),
            "model A { id Int @id @default(autoincrement()) }",
        )
        .unwrap();
        // Pre-populate output dir so it's non-empty.
        std::fs::write(output.path().join("existing.txt"), "hi").unwrap();

        let err =
            import_prisma_directory(input.path(), output.path(), debug_render, false).unwrap_err();
        assert!(matches!(err, ImportError::InvalidConfig(_)));

        // With --force, it succeeds.
        let count =
            import_prisma_directory(input.path(), output.path(), debug_render, true).unwrap();
        assert_eq!(count, 1);
    }
}