openmedialibrary/oml/downloads.py

77 lines
2.1 KiB
Python
Raw Normal View History

2014-05-04 17:26:43 +00:00
# -*- coding: utf-8 -*-
# vi:si:et:sw=4:sts=4:ts=4
2014-09-02 22:32:44 +00:00
2016-02-11 15:55:41 +00:00
import os
2014-05-04 17:26:43 +00:00
from threading import Thread
import time
2016-02-11 15:55:41 +00:00
from sqlitedict import SqliteDict
2014-08-09 16:14:14 +00:00
import db
2014-05-04 17:26:43 +00:00
import state
import settings
import update
2014-05-04 17:26:43 +00:00
import logging
2015-11-29 14:56:38 +00:00
logger = logging.getLogger(__name__)
2014-05-17 14:26:59 +00:00
2014-05-04 17:26:43 +00:00
class Downloads(Thread):
2014-08-09 16:33:59 +00:00
def __init__(self):
2014-05-04 17:26:43 +00:00
Thread.__init__(self)
self.daemon = True
self.start()
2016-02-11 15:55:41 +00:00
self._dbpath = os.path.join(settings.data_path, 'transfers.db')
self.transfers = SqliteDict(self._dbpath, tablename='transfers', autocommit=False)
2014-05-04 17:26:43 +00:00
def download_updates(self):
now = int(time.mktime(time.gmtime()))
if now > settings.server.get('last_update_check', 0) + 24*60*60:
settings.server['last_update_check'] = now
update.download()
state.user().export_library()
2014-05-04 17:26:43 +00:00
def download_next(self):
import item.models
self.download_updates()
2016-02-11 15:55:41 +00:00
downloads = list(self.transfers.items())
downloads.sort(key=lambda t: t[1].get('added'))
for itemid, t in downloads:
if state.shutdown:
2015-11-18 00:27:53 +00:00
return False
2016-02-14 10:41:18 +00:00
if itemid not in self.transfers:
continue
2016-02-11 15:55:41 +00:00
if t.get('added') and t.get('progress', -1) < 1:
i = item.models.Item.get(itemid)
for u in i.users:
if state.shutdown:
return False
if state.nodes.is_online(u.id):
logger.debug('DOWNLOAD %s %s', i, u)
r = state.nodes.download(u.id, i)
2014-05-04 17:26:43 +00:00
return False
def run(self):
2016-01-14 04:27:26 +00:00
self.wait(10)
while not state.shutdown:
2016-01-14 04:27:26 +00:00
self.wait_online()
2015-12-24 15:11:47 +00:00
with db.session():
self.download_next()
2016-01-14 04:27:26 +00:00
self.wait(10)
2014-05-04 17:26:43 +00:00
def join(self):
2016-02-11 15:55:41 +00:00
self.transfers.commit()
self.transfers.close(do_log=False)
2014-05-04 17:26:43 +00:00
return Thread.join(self)
2015-03-07 16:24:07 +00:00
2016-01-14 04:27:26 +00:00
def wait_online(self):
while not state.online:
self.wait(5)
def wait(self, timeout):
step = min(timeout, 1)
while not state.shutdown and timeout > 0:
2016-01-14 04:27:26 +00:00
time.sleep(step)
timeout -= step