d02689fc67
* discovery changes * app head: tag page and content sorting * app head: fix styles and tag page load * app head: update subscriptions view using claim_search results * app head: add horizontal subscribed channels list * app head: add tag customisation to explore and trending pages * update to sdk 0.38.3. app head: subscriptions and suggested channels
109 lines
4.1 KiB
Python
109 lines
4.1 KiB
Python
import asyncio
|
|
import keyring
|
|
import logging
|
|
import pathlib
|
|
import platform
|
|
import sys
|
|
from jnius import autoclass
|
|
from keyring.backend import KeyringBackend
|
|
from lbry import __version__ as lbrynet_version, build_type
|
|
from lbry.conf import Config
|
|
from lbry.extras.daemon.loggly_handler import get_loggly_handler
|
|
from lbry.extras.daemon.Components import DHT_COMPONENT, HASH_ANNOUNCER_COMPONENT, PEER_PROTOCOL_SERVER_COMPONENT
|
|
from lbry.extras.daemon.Daemon import Daemon
|
|
from lbry.extras.daemon.loggly_handler import get_loggly_handler
|
|
|
|
log = logging.getLogger(__name__)
|
|
log.setLevel(logging.DEBUG)
|
|
|
|
lbrynet_android_utils = autoclass('io.lbry.browser.Utils')
|
|
service = autoclass('io.lbry.browser.LbrynetService').serviceInstance
|
|
platform.platform = lambda: 'Android %s (API %s)' % (lbrynet_android_utils.getAndroidRelease(), lbrynet_android_utils.getAndroidSdk())
|
|
build_type.BUILD = 'dev' if lbrynet_android_utils.isDebug() else 'release'
|
|
|
|
# Keyring backend
|
|
class LbryAndroidKeyring(KeyringBackend):
|
|
priority = 1
|
|
|
|
def __init__(self):
|
|
self._keystore = lbrynet_android_utils.initKeyStore(service.getApplicationContext())
|
|
|
|
def set_password(self, servicename, username, password):
|
|
context = service.getApplicationContext()
|
|
lbrynet_android_utils.setPassword(servicename, username, password, context, self._keystore)
|
|
|
|
def get_password(self, servicename, username):
|
|
context = service.getApplicationContext()
|
|
return lbrynet_android_utils.getPassword(servicename, username, context, self._keystore)
|
|
|
|
def delete_password(self, servicename, username):
|
|
context = service.getApplicationContext()
|
|
lbrynet_android_utils.deletePassword(servicename, username, context, self._keystore)
|
|
|
|
def ensure_directory_exists(path: str):
|
|
if not os.path.isdir(path):
|
|
pathlib.Path(path).mkdir(parents=True, exist_ok=True)
|
|
|
|
def configure_logging(conf):
|
|
default_formatter = logging.Formatter("%(asctime)s %(levelname)-8s %(name)s:%(lineno)d: %(message)s")
|
|
|
|
file_handler = logging.handlers.RotatingFileHandler(
|
|
conf.log_file_path, maxBytes=2097152, backupCount=5
|
|
)
|
|
file_handler.setFormatter(default_formatter)
|
|
logging.getLogger('lbry').addHandler(file_handler)
|
|
logging.getLogger('torba').addHandler(file_handler)
|
|
|
|
handler = logging.StreamHandler()
|
|
handler.setFormatter(default_formatter)
|
|
|
|
log.addHandler(handler)
|
|
logging.getLogger('lbry').addHandler(handler)
|
|
logging.getLogger('torba').addHandler(handler)
|
|
|
|
logging.getLogger('aioupnp').setLevel(logging.WARNING)
|
|
logging.getLogger('aiohttp').setLevel(logging.CRITICAL)
|
|
logging.getLogger('lbry').setLevel(logging.DEBUG if lbrynet_android_utils.isDebug() else logging.INFO)
|
|
logging.getLogger('torba').setLevel(logging.INFO)
|
|
|
|
loggly_handler = get_loggly_handler()
|
|
loggly_handler.setLevel(logging.ERROR)
|
|
logging.getLogger('lbry').addHandler(loggly_handler)
|
|
|
|
def start():
|
|
keyring.set_keyring(LbryAndroidKeyring())
|
|
private_storage_dir = lbrynet_android_utils.getAppInternalStorageDir(service.getApplicationContext())
|
|
conf = Config(
|
|
data_dir=f'{private_storage_dir}/lbrynet',
|
|
wallet_dir=f'{private_storage_dir}/lbryum',
|
|
download_dir=f'{lbrynet_android_utils.getInternalStorageDir(service.getApplicationContext())}/Download',
|
|
blob_lru_cache_size=32,
|
|
components_to_skip=[DHT_COMPONENT, HASH_ANNOUNCER_COMPONENT, PEER_PROTOCOL_SERVER_COMPONENT],
|
|
save_blobs=False,
|
|
save_files=False,
|
|
use_upnp=False
|
|
)
|
|
|
|
for directory in (conf.data_dir, conf.download_dir, conf.wallet_dir):
|
|
ensure_directory_exists(directory)
|
|
|
|
configure_logging(conf)
|
|
|
|
log.info('Starting lbry sdk {}'.format(lbrynet_version));
|
|
|
|
loop = asyncio.get_event_loop()
|
|
loop.set_debug(lbrynet_android_utils.isDebug())
|
|
|
|
daemon = Daemon(conf)
|
|
try:
|
|
loop.run_until_complete(daemon.start())
|
|
loop.run_forever()
|
|
except (GracefulExit, asyncio.CancelledError):
|
|
pass
|
|
finally:
|
|
loop.run_until_complete(daemon.stop())
|
|
if hasattr(loop, 'shutdown_asyncgens'):
|
|
loop.run_until_complete(loop.shutdown_asyncgens())
|
|
|
|
if __name__ == '__main__':
|
|
start()
|