from typing import Optional, Union
from tracardi.config import memory_cache
from tracardi.domain.entity import Entity
from tracardi.domain.resource import ResourceRecord
from tracardi.event_server.utils.memory_cache import MemoryCache, CacheItem
from tracardi.service.storage.driver import storage
from tracardi.service.storage.factory import StorageFor


class SourceCacher:

    def __init__(self):
        self._cache = MemoryCache()

    async def validate_source(self, source_id) -> ResourceRecord:
        entity = Entity(id=source_id)

        source = await self.get(entity)  # type: Optional[ResourceRecord]
        if source is None:
            raise ValueError("Invalid source.")

        if not source.enabled:
            raise ValueError("Source disabled.")

        return source

    async def get(self, resource: Entity) -> Optional[Union[ResourceRecord]]:
        if 'resource' in self._cache:
            resource = self._cache['resource'].data
            return resource
        else:
            # Expired
            resource = await storage.driver.resource.load_record(resource.id)  # type: ResourceRecord
            if resource is not None:
                self._cache['resource'] = CacheItem(data=resource, ttl=memory_cache.source_ttl)
                return resource
            return None


source_cache = SourceCacher()

from typing import Optional, Union
from tracardi.config import memory_cache
from tracardi.domain.entity import Entity
from tracardi.domain.resource import ResourceRecord
from tracardi.event_server.utils.memory_cache import MemoryCache, CacheItem
from tracardi.service.storage.driver import storage
from tracardi.service.storage.factory import StorageFor


class SourceCacher:

    def __init__(self):
        self._cache = MemoryCache()

    async def validate_source(self, source_id) -> ResourceRecord:
        entity = Entity(id=source_id)

        source = await self.get(entity)  # type: Optional[ResourceRecord]
        if source is None:
            raise ValueError("Invalid source.")

        if not source.enabled:
            raise ValueError("Source disabled.")

        return source

    async def get(self, resource: Entity) -> Optional[Union[ResourceRecord]]:
        if 'resource' in self._cache:
            resource = self._cache['resource'].data
            return resource
        else:
            # Expired
            resource = await storage.driver.resource.load_record(resource.id)  # type: ResourceRecord
            if resource is not None:
                self._cache['resource'] = CacheItem(data=resource, ttl=memory_cache.source_ttl)
                return resource
            return None


source_cache = SourceCacher()

# type: Optional[ResourceRecord] # Expired # type: ResourceRecord