Settings

class Settings(OpenAlephSettings):
    """
    `ingest-file` settings management using
    [pydantic-settings](https://docs.pydantic.dev/latest/concepts/pydantic_settings/)

    Note:
        All settings can be set via environment variables, prepending
        `INGESTORS_` (except for those with another alias) via runtime or in a
        `.env` file.
    """

    model_config = SettingsConfigDict(
        env_prefix="ingestors_",
        env_file=".env",
        extra="ignore",  # other envs in .env file
    )

    convert_timeout: int = 300
    """Headless libreoffice document convert timeout in seconds"""

    unoserver_uri: str | None = None
    """URI of a running unoserver XML-RPC listener
    to convert office documents to PDF with."""

    soffice_bin: str = "/usr/bin/libreoffice"
    """Path to the LibreOffice/soffice binary"""

    lakehouse_flush_size: int = 10_000
    """Size cap until when the journal should be flushed to parquet"""

    crawl_threads: int = 1
    """Crawl parallelization, worth raising if archive storage is over the network"""

    @property
    def tags_database_uri(self) -> str:
        """Resolve the tags database URI from fragments_uri, forcing psycopg3
        driver for PostgreSQL."""
        uri = self.fragments_uri
        if uri and uri.startswith("postgresql://"):
            uri = uri.replace("postgresql://", "postgresql+psycopg://", 1)
        return uri