# Path: resources/lib/modules/cache.py
# def get(function, timeout_hour, *args, **kargs):
# def clear_item(function, *args, **kargs):
# def __get_from_cache(dbcur, table, f, a, timeout_hour):
# def __execute_origin(dbcur, dbcon, function, table, f, a, response, *args, **kargs):
# def delete_file():
# def clear(table=None):
# 
# Path: resources/lib/modules/workers.py
# class Thread(threading.Thread):
# class Workers:
#     def __init__(self, target, *args):
#     def run(self):
#     def get_result(self):
#     def globaltrace(self, frame, event, arg):
#     def localtrace(self, frame, event, arg):
#     def kill(self):
#     def __init__(self, concurrent=30, queue_size=None, target=None, expect_result=True):
#         def _queue_worker():
#     def put(self, item):
#     def join(self):
#     def terminate(self):


from auth import PLATFORM
from auth import get_request_data
from resources.lib.modules import cache
from resources.lib.modules import workers
import requests
import resources.lib.modules.control as control
import scraper_live
import player
import os
import urllib

            result.update({
                'studio': 'Now Online'
            })

            yield result

    if has_more_pages:
        yield {
            'handler': __name__,
            'method': 'search',
            'term': term,
            'page': page + 1,
            'limit': limit,
            'label': control.lang(34136).encode('utf-8'),
            'art': {
                'poster': control.addonNext(),
                'fanart': FANART
            },
            'properties': {
                'SpecialSort': 'bottom'
            }
        }


def request_logged_in(url, use_cache=True, validate=False, force_refresh=False, retry=1):
    headers, cookies = get_request_data(validate)

    control.log('GET %s' % url)
    if use_cache:

# Path: resources/lib/modules/cache.py
# def get(function, timeout_hour, *args, **kargs):
# def clear_item(function, *args, **kargs):
# def __get_from_cache(dbcur, table, f, a, timeout_hour):
# def __execute_origin(dbcur, dbcon, function, table, f, a, response, *args, **kargs):
# def delete_file():
# def clear(table=None):
# 
# Path: resources/lib/modules/workers.py
# class Thread(threading.Thread):
# class Workers:
#     def __init__(self, target, *args):
#     def run(self):
#     def get_result(self):
#     def globaltrace(self, frame, event, arg):
#     def localtrace(self, frame, event, arg):
#     def kill(self):
#     def __init__(self, concurrent=30, queue_size=None, target=None, expect_result=True):
#         def _queue_worker():
#     def put(self, item):
#     def join(self):
#     def terminate(self):


# Path: resources/lib/modules/netnow/scraper_vod.py
from auth import PLATFORM
from auth import get_request_data
from resources.lib.modules import cache
from resources.lib.modules import workers
import requests
import resources.lib.modules.control as control
import scraper_live
import player
import os
import urllib


            result.update({
                'studio': 'Now Online'
            })

            yield result

    if has_more_pages:
        yield {
            'handler': __name__,
            'method': 'search',
            'term': term,
            'page': page + 1,
            'limit': limit,
            'label': control.lang(34136).encode('utf-8'),
            'art': {
                'poster': control.addonNext(),
                'fanart': FANART
            },
            'properties': {
                'SpecialSort': 'bottom'
            }
        }


def request_logged_in(url, use_cache=True, validate=False, force_refresh=False, retry=1):
    headers, cookies = get_request_data(validate)

    control.log('GET %s' % url)
    if use_cache:

        response = cache.get(requests.get, 1, url, headers=headers, cookies=cookies, force_refresh=force_refresh, table="netnow")