lib.itmens/users/jobs/sync.py
2024-01-12 18:43:06 -05:00

36 lines
1 KiB
Python

from datetime import timedelta
from django.utils import timezone
from loguru import logger
from common.models import BaseJob, JobManager
from users.models import User
@JobManager.register
class MastodonUserSync(BaseJob):
batch = 8
interval_hours = 3
interval = timedelta(hours=interval_hours)
def run(self):
logger.info("Mastodon User Sync start.")
qs = (
User.objects.exclude(
preference__mastodon_skip_userinfo=True,
preference__mastodon_skip_relationship=True,
)
.filter(
mastodon_last_refresh__lt=timezone.now()
- timedelta(hours=self.interval_hours * self.batch)
)
.filter(
username__isnull=False,
is_active=True,
)
.exclude(mastodon_token__isnull=True)
.exclude(mastodon_token="")
)
for user in qs.iterator():
user.refresh_mastodon_data()
logger.info(f"Mastodon User Sync finished.")