gobby-code 0.9.7

use postgres::{Client, NoTls};

pub struct ProjectCleanup {
    database_url: String,
    project_id: String,
}

impl ProjectCleanup {
    pub fn new(database_url: &str, project_id: &str) -> Self {
        Self {
            database_url: database_url.to_string(),
            project_id: project_id.to_string(),
        }
    }
}

impl Drop for ProjectCleanup {
    fn drop(&mut self) {
        let mut conn = match Client::connect(&self.database_url, NoTls) {
            Ok(conn) => conn,
            Err(err) => {
                eprintln!(
                    "ProjectCleanup Drop::drop: Client::connect failed for project {}: {err}",
                    self.project_id
                );
                return;
            }
        };

        if let Err(err) = cleanup_project(&mut conn, &self.project_id) {
            eprintln!(
                "ProjectCleanup Drop::drop: cleanup_project failed for project {}: {err}",
                self.project_id
            );
        }
    }
}

pub fn cleanup_project(conn: &mut Client, project_id: &str) -> Result<(), postgres::Error> {
    let mut tx = conn.transaction()?;
    tx.execute(
        "DELETE FROM code_calls WHERE project_id = $1",
        &[&project_id],
    )?;
    tx.execute(
        "DELETE FROM code_imports WHERE project_id = $1",
        &[&project_id],
    )?;
    tx.execute(
        "DELETE FROM code_symbols WHERE project_id = $1",
        &[&project_id],
    )?;
    tx.execute(
        "DELETE FROM code_content_chunks WHERE project_id = $1",
        &[&project_id],
    )?;
    tx.execute(
        "DELETE FROM code_indexed_files WHERE project_id = $1",
        &[&project_id],
    )?;
    tx.execute(
        "DELETE FROM code_indexed_projects WHERE id = $1",
        &[&project_id],
    )?;
    tx.commit()
}