from botocore.session import get_session

from client_grants import ClientGrantsCredentialProvider

boto3.set_stream_logger('boto3.resources', logging.DEBUG)

bc_session = get_session()
bc_session.get_component('credential_provider').insert_before(
    'env',
    ClientGrantsCredentialProvider('NZLOOFRSluw9RfIkuHGqfk1HFp4a',
                                   '0Z4VTG8uJBSekn42HE40DK9vQb4a'),
)

# Dependencies
import urllib3
from botocore.credentials import CredentialProvider, RefreshableCredentials
from botocore.exceptions import CredentialRetrievalError
from dateutil.parser import parse

from .sts_element import STSElement


class ClientGrantsCredentialProvider(CredentialProvider):
    """
    ClientGrantsCredentialProvider implements CredentialProvider compatible
    implementation to be used with boto_session
    """

    }

    @Override
    public boolean isChallengeComplete() {
        return false;
    }

    @Override
    public boolean isResponseReady(final HttpHost host, final CredentialsProvider credentialsProvider, final HttpContext context)
            throws AuthenticationException {
        return false;
    }

    @Override
    public Principal getPrincipal() {
        return null;
    }

    }

    /**
     * Sets the credentials provider for authentication.
     *
     * @param credentialsProvider The credentials provider
     */
    public void setCredentialsProvider(final CredentialsProvider credentialsProvider) {
        this.credentialsProvider = credentialsProvider;
    }

    /**
     * Sets the authentication cache.
     *

    }

    /**
     * Sets the credentials provider for authentication.
     *
     * @param credentialsProvider The credentials provider
     */
    public void setCredentialsProvider(final CredentialsStore credentialsProvider) {
        this.credentialsProvider = credentialsProvider;
    }

    /**
     * Sets the authentication cache.
     *

        this.bucket = bucket;

        final AwsBasicCredentials credentials = AwsBasicCredentials.create(accessKey, secretKey);
        final S3ClientBuilder builder =
                S3Client.builder().credentialsProvider(StaticCredentialsProvider.create(credentials)).region(Region.of(getRegion(region)));

        // For non-AWS endpoints (MinIO, etc.), set custom endpoint with path-style access
        if (StringUtil.isNotBlank(endpoint)) {