increase cache timeout to 5 hours
This commit is contained in:
		@@ -3,7 +3,6 @@ import json
 | 
				
			|||||||
import sys
 | 
					import sys
 | 
				
			||||||
import urllib.parse
 | 
					import urllib.parse
 | 
				
			||||||
import os
 | 
					import os
 | 
				
			||||||
import time
 | 
					 | 
				
			||||||
import base64
 | 
					import base64
 | 
				
			||||||
import logging
 | 
					import logging
 | 
				
			||||||
import asyncio
 | 
					import asyncio
 | 
				
			||||||
@@ -12,7 +11,6 @@ import tornado.routing
 | 
				
			|||||||
import aiohttp
 | 
					import aiohttp
 | 
				
			||||||
import aiohttp_socks
 | 
					import aiohttp_socks
 | 
				
			||||||
import stream_providers
 | 
					import stream_providers
 | 
				
			||||||
import expiringdict
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
logging.basicConfig(format='[%(filename)s:%(lineno)d] %(message)s', stream=sys.stdout, level=logging.INFO)
 | 
					logging.basicConfig(format='[%(filename)s:%(lineno)d] %(message)s', stream=sys.stdout, level=logging.INFO)
 | 
				
			||||||
logger = logging.getLogger(__name__)
 | 
					logger = logging.getLogger(__name__)
 | 
				
			||||||
@@ -32,7 +30,6 @@ icecast_server = os.environ.get("ICECAST_SERVER")
 | 
				
			|||||||
stream_server = os.environ.get("STREAM_SERVER")
 | 
					stream_server = os.environ.get("STREAM_SERVER")
 | 
				
			||||||
proxy_server = os.environ.get("PROXY_SERVER")
 | 
					proxy_server = os.environ.get("PROXY_SERVER")
 | 
				
			||||||
 | 
					
 | 
				
			||||||
ctype_cache = expiringdict.ExpiringDict(max_len=128, max_age_seconds=1800)
 | 
					 | 
				
			||||||
class ProxyElem():
 | 
					class ProxyElem():
 | 
				
			||||||
    def __init__(self, proxy):
 | 
					    def __init__(self, proxy):
 | 
				
			||||||
        self.proxy = proxy
 | 
					        self.proxy = proxy
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -234,7 +234,7 @@ class NextcloudRunner(MetaProvider):
 | 
				
			|||||||
        stream_data["thumbnail"] = None
 | 
					        stream_data["thumbnail"] = None
 | 
				
			||||||
        return StreamData(**stream_data)
 | 
					        return StreamData(**stream_data)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
upstream_cache = expiringdict.ExpiringDict(max_len=512, max_age_seconds=1800)
 | 
					upstream_cache = expiringdict.ExpiringDict(max_len=512, max_age_seconds=18000)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
async def get_from_runner(cache_key, runner, logger):
 | 
					async def get_from_runner(cache_key, runner, logger):
 | 
				
			||||||
    result = None
 | 
					    result = None
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user