import sqlalchemy
from wrapt import wrap_function_wrapper as _w

from ddtrace.contrib.internal.trace_utils import unwrap
from ddtrace.internal.settings.asm import config as asm_config

from .engine import _wrap_create_engine


def get_version() -> str:
    return getattr(sqlalchemy, "__version__", "")


def _supported_versions() -> dict[str, str]:
    return {"sqlalchemy": ">=1.3"}


def patch():
    if getattr(sqlalchemy.engine, "__datadog_patch", False):
        return
    sqlalchemy.engine.__datadog_patch = True

    # patch the engine creation function
    _w("sqlalchemy", "create_engine", _wrap_create_engine)
    _w("sqlalchemy.engine", "create_engine", _wrap_create_engine)

    if asm_config._iast_enabled:
        from ddtrace.appsec._iast._metrics import _set_metric_iast_instrumented_sink
        from ddtrace.appsec._iast.constants import VULN_SQL_INJECTION

        _set_metric_iast_instrumented_sink(VULN_SQL_INJECTION)


def unpatch():
    # unpatch sqlalchemy
    if getattr(sqlalchemy.engine, "__datadog_patch", False):
        sqlalchemy.engine.__datadog_patch = False
        unwrap(sqlalchemy, "create_engine")
        unwrap(sqlalchemy.engine, "create_engine")