import logging
import uuid

import boto3
import pytest

import awswrangler as wr

from .._utils import get_df_quicksight

logging.getLogger("awswrangler").setLevel(logging.DEBUG)

client = boto3.client("quicksight")


@pytest.mark.xfail(raises=client.exceptions.ConflictException)
def test_quicksight(path, quicksight_datasource, quicksight_dataset, glue_database, glue_table):
    df = get_df_quicksight()
    wr.s3.to_parquet(
        df=df, path=path, dataset=True, database=glue_database, table=glue_table, partition_cols=["par0", "par1"]
    )

    wr.quicksight.create_athena_data_source(
        name=quicksight_datasource,
        allowed_to_manage=[wr.sts.get_current_identity_name()],
        tags={"Env": "aws-sdk-pandas"},
    )
    assert wr.quicksight.describe_data_source(quicksight_datasource)["Name"] == quicksight_datasource
    assert (
        wr.quicksight.describe_data_source_permissions(quicksight_datasource)[0]["Principal"].endswith(
            wr.sts.get_current_identity_name()
        )
        is True
    )
    dataset_name = f"{quicksight_dataset}-table"
    wr.quicksight.create_athena_dataset(
        name=dataset_name,
        database=glue_database,
        table=glue_table,
        data_source_name=quicksight_datasource,
        allowed_to_manage=[wr.sts.get_current_identity_name()],
        rename_columns={"iint16": "new_col"},
        cast_columns_types={"new_col": "STRING"},
        tag_columns={"string": [{"ColumnGeographicRole": "CITY"}, {"ColumnDescription": {"Text": "some description"}}]},
    )
    assert wr.quicksight.describe_dataset(dataset_name)["Name"] == dataset_name

    wr.quicksight.create_athena_dataset(
        name=f"{quicksight_dataset}-sql",
        sql=f"SELECT * FROM {glue_database}.{glue_table}",
        data_source_name=quicksight_datasource,
        import_mode="SPICE",
        allowed_to_use={"users": [wr.sts.get_current_identity_name()]},
        allowed_to_manage={"users": [wr.sts.get_current_identity_name()]},
        rename_columns={"iint16": "new_col"},
        cast_columns_types={"new_col": "STRING"},
        tag_columns={"string": [{"ColumnGeographicRole": "CITY"}, {"ColumnDescription": {"Text": "some description"}}]},
        tags={"foo": "boo"},
    )

    ingestion_id = wr.quicksight.create_ingestion(f"{quicksight_dataset}-sql")
    status = None
    while status not in ["FAILED", "COMPLETED", "CANCELLED"]:
        status = wr.quicksight.describe_ingestion(ingestion_id, f"{quicksight_dataset}-sql")["IngestionStatus"]
    assert status == "COMPLETED"

    ingestion_id = wr.quicksight.create_ingestion(f"{quicksight_dataset}-sql")
    wr.quicksight.cancel_ingestion(ingestion_id, f"{quicksight_dataset}-sql")
    assert len(wr.quicksight.list_ingestions(f"{quicksight_dataset}-sql")) == 3

    wr.quicksight.list_groups()
    wr.quicksight.list_iam_policy_assignments()
    wr.quicksight.list_iam_policy_assignments_for_user(wr.sts.get_current_identity_name())
    wr.quicksight.list_user_groups(wr.sts.get_current_identity_name())
    wr.quicksight.list_users()
    wr.quicksight.get_dataset_ids(f"{quicksight_dataset}-sql")
    wr.quicksight.get_data_source_ids("test")

    wr.quicksight.delete_all_datasets(regex_filter=quicksight_dataset)
    wr.quicksight.delete_all_data_sources(regex_filter=quicksight_datasource)


def test_quicksight_delete_all_datasources_filter():
    wr.quicksight.delete_all_data_sources(regex_filter="test.*")
    resource_name = f"test-delete-{uuid.uuid4()}"
    wr.quicksight.create_athena_data_source(
        name=resource_name,
        allowed_to_manage={"users": [wr.sts.get_current_identity_name()]},
        tags={"Env": "aws-sdk-pandas"},
    )
    wr.quicksight.delete_all_data_sources(regex_filter="test-no-delete")

    assert len(wr.quicksight.get_data_source_ids(resource_name)) == 1

    wr.quicksight.delete_all_data_sources(regex_filter="test-delete.*")
    assert len(wr.quicksight.get_data_source_ids(resource_name)) == 0


def test_quicksight_delete_all_datasets(path, glue_database, glue_table):
    df = get_df_quicksight()
    wr.s3.to_parquet(
        df=df, path=path, dataset=True, database=glue_database, table=glue_table, partition_cols=["par0", "par1"]
    )
    wr.quicksight.delete_all_datasets(regex_filter="test.*")
    wr.quicksight.delete_all_data_sources(regex_filter="test.*")

    resource_name = f"test{str(uuid.uuid4())[:8]}"
    wr.quicksight.create_athena_data_source(
        name=resource_name,
        allowed_to_manage={"users": [wr.sts.get_current_identity_name()]},
        tags={"Env": "aws-sdk-pandas"},
    )
    wr.quicksight.create_athena_dataset(
        name=f"{resource_name}-sql",
        sql=f"SELECT * FROM {glue_database}.{glue_table}",
        data_source_name=resource_name,
        import_mode="SPICE",
        allowed_to_use={"users": [wr.sts.get_current_identity_name()]},
        allowed_to_manage={"users": [wr.sts.get_current_identity_name()]},
        rename_columns={"iint16": "new_col"},
        cast_columns_types={"new_col": "STRING"},
        tag_columns={"string": [{"ColumnGeographicRole": "CITY"}, {"ColumnDescription": {"Text": "some description"}}]},
        tags={"foo": "boo"},
    )
    wr.quicksight.delete_all_datasets(regex_filter="test.*")
    wr.quicksight.delete_all_data_sources(regex_filter="test.*")

    assert len(wr.quicksight.get_dataset_ids(resource_name)) == 0