import base64
import hashlib
from datetime import datetime, timedelta, timezone
import os
import os
import jwt
from cryptography.hazmat.backends import default_backend
from cryptography.hazmat.primitives.serialization import (
    Encoding,
    PublicFormat,
    load_pem_private_key,
)

SPCS_TOKEN_PATH = "/snowflake/session/token"


def get_default_spcs_token() -> str:
    """
    Returns the value of the SnowPark default JWT Oauth Session Token.
    In a Snowpark Container Services environment, there is a 'default' oauth session token. This retrieves it for you (as a string).
    """
    with open(SPCS_TOKEN_PATH) as fp:
        return fp.read()


def is_spcs_environment() -> bool:
    """
    Determines if we're currently in an SPCS (Snowpark Container Services) environment. Does this by checking for the default session token.
    Returns a boolean: whether or not we're in an SPCS environment.
    """
    return (
        os.path.exists(SPCS_TOKEN_PATH) and os.environ.get("SNOWFLAKE_HOST") is not None
    )


def get_spcs_base_url() -> str:
    """
    Returns a correctly formatted URL for making Snowflake API calls from within an SPCS environment.

    Raises a ValueError if not in an SPCS environment.
    Returns a string, https://{some-url} that you can affix an API endpoint such as Cortex to.
    """
    if not is_spcs_environment():
        raise ValueError("Cannot call get_spcs_base_url unless in an spcs environment.")
    return os.getenv("SNOWFLAKE_HOST")


def generate_sf_jwt(sf_account: str, sf_user: str, sf_private_key_filepath: str) -> str:
    """
    Generate a JSON Web Token for a Snowflake user.

    Args:
        sf_account: Fully qualified snowflake account name (ORG_ID-ACCOUNT_ID).
        sf_user: User to generate token for.
        sf_private_key_filepath: Path to user's private key.

    Returns:
        str: JSON Web Token

    """
    with open(sf_private_key_filepath, "rb") as pem_in:
        pemlines = pem_in.read()
        # TODO: Add support for encrypted private keys
        private_key = load_pem_private_key(pemlines, None, default_backend())

    # Get the raw bytes of the public key.
    public_key_raw = private_key.public_key().public_bytes(
        Encoding.DER, PublicFormat.SubjectPublicKeyInfo
    )

    # Get the sha256 hash of the raw bytes.
    sha256hash = hashlib.sha256()
    sha256hash.update(public_key_raw)

    # Base64-encode the value and prepend the prefix 'SHA256:'.
    public_key_fp = "SHA256:" + base64.b64encode(sha256hash.digest()).decode("utf-8")

    # Use uppercase for the account identifier and user name.
    account = sf_account.upper()
    user = sf_user.upper()
    qualified_username = account + "." + user

    # Get the current time in order to specify the time when the JWT was issued and the expiration time of the JWT.
    now = datetime.now(timezone.utc)

    # Specify the length of time during which the JWT will be valid. You can specify at most 1 hour.
    lifetime = timedelta(minutes=59)

    # Create the payload for the token.
    payload = {
        # Set the issuer to the fully qualified username concatenated with the public key fingerprint (calculated in the  previous step).
        "iss": qualified_username + "." + public_key_fp,
        # Set the subject to the fully qualified username.
        "sub": qualified_username,
        # Set the issue time to now.
        "iat": now,
        # Set the expiration time, based on the lifetime specified for this object.
        "exp": now + lifetime,
    }

    # Generate the JWT. private_key is the private key that you read from the private key file in the previous step when you generated the public key fingerprint.
    encoding_algorithm = "RS256"
    return jwt.encode(payload, key=private_key, algorithm=encoding_algorithm)

import base64
import hashlib
from datetime import datetime, timedelta, timezone
import os
import jwt
from cryptography.hazmat.backends import default_backend
from cryptography.hazmat.primitives.serialization import (
    Encoding,
    PublicFormat,
    load_pem_private_key,
)

SPCS_TOKEN_PATH = "/snowflake/session/token"


def get_default_spcs_token() -> str:
    """
    Returns the value of the SnowPark default JWT Oauth Session Token.
    In a Snowpark Container Services environment, there is a 'default' oauth session token. This retrieves it for you (as a string).
    """
    with open(SPCS_TOKEN_PATH) as fp:
        return fp.read()


def is_spcs_environment() -> bool:
    """
    Determines if we're currently in an SPCS (Snowpark Container Services) environment. Does this by checking for the default session token.
    Returns a boolean: whether or not we're in an SPCS environment.
    """
    return (
        os.path.exists(SPCS_TOKEN_PATH)
        and os.environ.get("SNOWFLAKE_HOST") is not None
        and os.environ.get("SNOWFLAKE_ACCOUNT") is not None
    )


def get_spcs_base_url() -> str:
    """
    Returns a correctly formatted URL for making Snowflake API calls from within an SPCS environment.

    Raises a ValueError if not in an SPCS environment.
    Returns a string, https://{some-url} that you can affix an API endpoint such as Cortex to.
    """
    if not is_spcs_environment():
        raise ValueError("Cannot call get_spcs_base_url unless in an spcs environment.")
    return "https://" + os.environ.get("SNOWFLAKE_HOST").replace(
        "snowflake",
        os.environ.get("SNOWFLAKE_ACCOUNT").lower().replace("_", "-"),
        1,
    )


def generate_sf_jwt(sf_account: str, sf_user: str, sf_private_key_filepath: str) -> str:
    """
    Generate a JSON Web Token for a Snowflake user.

    Args:
        sf_account: Fully qualified snowflake account name (ORG_ID-ACCOUNT_ID).
        sf_user: User to generate token for.
        sf_private_key_filepath: Path to user's private key.

    Returns:
        str: JSON Web Token

    """
    with open(sf_private_key_filepath, "rb") as pem_in:
        pemlines = pem_in.read()
        # TODO: Add support for encrypted private keys
        private_key = load_pem_private_key(pemlines, None, default_backend())

    # Get the raw bytes of the public key.
    public_key_raw = private_key.public_key().public_bytes(
        Encoding.DER, PublicFormat.SubjectPublicKeyInfo
    )

    # Get the sha256 hash of the raw bytes.
    sha256hash = hashlib.sha256()
    sha256hash.update(public_key_raw)

    # Base64-encode the value and prepend the prefix 'SHA256:'.
    public_key_fp = "SHA256:" + base64.b64encode(sha256hash.digest()).decode("utf-8")

    # Use uppercase for the account identifier and user name.
    account = sf_account.upper()
    user = sf_user.upper()
    qualified_username = account + "." + user

    # Get the current time in order to specify the time when the JWT was issued and the expiration time of the JWT.
    now = datetime.now(timezone.utc)

    # Specify the length of time during which the JWT will be valid. You can specify at most 1 hour.
    lifetime = timedelta(minutes=59)

    # Create the payload for the token.
    payload = {
        # Set the issuer to the fully qualified username concatenated with the public key fingerprint (calculated in the  previous step).
        "iss": qualified_username + "." + public_key_fp,
        # Set the subject to the fully qualified username.
        "sub": qualified_username,
        # Set the issue time to now.
        "iat": now,
        # Set the expiration time, based on the lifetime specified for this object.
        "exp": now + lifetime,
    }

    # Generate the JWT. private_key is the private key that you read from the private key file in the previous step when you generated the public key fingerprint.
    encoding_algorithm = "RS256"
    return jwt.encode(payload, key=private_key, algorithm=encoding_algorithm)
