mirror of
https://github.com/nikdoof/test-auth.git
synced 2025-12-18 12:19:29 +00:00
Switch EVE API update job to a recurring task
This commit is contained in:
@@ -10,37 +10,6 @@ from eve_api.app_defines import *
|
||||
|
||||
from eve_api.tasks import *
|
||||
|
||||
class UpdateAPIs():
|
||||
"""
|
||||
Updates all Eve API elements in the database
|
||||
"""
|
||||
|
||||
settings = { 'update_corp': True }
|
||||
|
||||
last_update_delay = 86400
|
||||
batches = 50
|
||||
|
||||
@property
|
||||
def _logger(self):
|
||||
if not hasattr(self, '__logger'):
|
||||
self.__logger = logging.getLogger(__name__)
|
||||
return self.__logger
|
||||
|
||||
def job(self, args):
|
||||
# Update all the eve accounts and related corps
|
||||
|
||||
delta = datetime.timedelta(seconds=self.last_update_delay)
|
||||
self._logger.debug("Updating APIs older than %s" % (datetime.datetime.now() - delta))
|
||||
|
||||
accounts = EVEAccount.objects.filter(api_last_updated__lt=(datetime.datetime.now() - delta)).exclude(api_status=API_STATUS_ACC_EXPIRED).exclude(api_status=API_STATUS_AUTH_ERROR).order_by('api_last_updated')[:self.batches]
|
||||
self._logger.debug("%s account(s) to update" % len(accounts))
|
||||
for acc in accounts:
|
||||
self._logger.info("Queueing UserID %s for update" % acc.api_user_id)
|
||||
if not acc.user:
|
||||
acc.delete()
|
||||
continue
|
||||
import_apikey.delay(api_key=acc.api_key, api_userid=acc.api_user_id)
|
||||
|
||||
class AllianceUpdate():
|
||||
"""
|
||||
Pulls the AllianceList.xml.aspx and updates the alliance objects
|
||||
|
||||
Reference in New Issue
Block a user