import threading

from diskcache import Cache

import ofscraper.utils.config.data as data
import ofscraper.utils.paths.common as common_paths
import ofscraper.utils.settings as settings

cache = None
lock = threading.Lock()


def get(*args, **kwargs):
    global lock
    lock.acquire()
    try:
        if settings.get_cache_disabled():
            return kwargs.get("default")
        global cache
        if cache is None:
            cache = Cache(common_paths.getcachepath(), disk=data.get_cache_mode())
        return cache.get(*args, **kwargs)
    except Exception as E:
        raise E
    finally:
        lock.release()


def set(*args, **kwargs):
    global lock
    lock.acquire()
    try:
        if settings.get_cache_disabled():
            return
        global cache
        if cache is None:
            cache = Cache(common_paths.getcachepath(), disk=data.get_cache_mode())
        cache.set(*args, **kwargs)
    except Exception as E:
        raise E
    finally:
        lock.release()


def close(*args, **kwargs):
    global lock
    lock.acquire()
    try:
        if settings.get_cache_disabled():
            return None
        global cache
        if cache is None:
            cache = Cache(common_paths.getcachepath(), disk=data.get_cache_mode())
        cache.close(*args, **kwargs)
    except Exception as E:
        raise E
    finally:
        lock.release()


def touch(*args, **kwargs):
    global lock
    lock.acquire()
    try:
        if settings.get_cache_disabled():
            return None
        global cache
        if cache is None:
            cache = Cache(common_paths.getcachepath(), disk=data.get_cache_mode())
        cache.touch(*args, **kwargs)

    except Exception as E:
        raise E
    finally:
        lock.release()