import json
import os


class CloudfoundryConfig:
    def __init__(self):
        self.parsed_services = json.loads(os.environ.get('VCAP_SERVICES') or '{}')
        buckets = self.parsed_services.get('s3') or []
        self.s3_buckets = {bucket['name']: bucket['credentials'] for bucket in buckets}
        self._empty_bucket_credentials = {
            'bucket': '',
            'access_key_id': '',
            'secret_access_key': '',
            'region': ''
        }

    @property
    def database_url(self):
        return os.environ.get('DATABASE_URL', '').replace('postgres://', 'postgresql://')

    @property
    def redis_url(self):
        try:
            return self.parsed_services['aws-elasticache-redis'][0]['credentials']['uri'].replace(
                'redis://',
                'rediss://'
            )
        except KeyError:
            return os.environ.get('REDIS_URL')

    def s3_credentials(self, service_name):
        return self.s3_buckets.get(service_name) or self._empty_bucket_credentials


cloud_config = CloudfoundryConfig()