SyncIntervalHandler.check() - Code Metrics - Inspection of "Updated scrobbler tests to support the `part` attr..." - fuzeman/Plex-Trakt-Scrobbler - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — develop ( 9e1b8b...5d0b21 )

by Dean

created 2016-08-04 04:17 UTC

SyncIntervalHandler.check() A

↳ Parent: SyncIntervalHandler

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	1
CRAP Score	16.0213

Importance

Changes

Metric	Value
c	0
b	0
f	0
dl	0
loc	20
ccs	1
cts	11
cp	0.0909
rs	9.2
cc	4
crap	16.0213

from plugin.models import SyncResult
from plugin.modules.scheduler.handlers.core.base import Handler
from plugin.preferences.options import SyncIntervalOption
from plugin.sync.core.enums import SyncMode
from plugin.sync.core.exceptions import QueueError
from plugin.sync.main import Sync

from datetime import datetime
import logging

log = logging.getLogger(__name__)


class SyncIntervalHandler(Handler):
    key = 'sync.interval'

    def check(self, job):
        last_result = SyncIntervalOption.get_last_result(job.account, SyncMode.Full)

        if last_result is None or last_result.started_at <= job.due_at:
            return True

        # Re-schedule job
        job.due_at = job.next_at(last_result.started_at)

        log.debug('Job re-scheduled to %r', job.due_at)

        # Check if a trigger is required
        if job.due_at <= datetime.utcnow():
            return True

        # Trigger ignored, update job
        job.save()

        log.debug('Ignoring scheduled sync interval (already triggered)')
        return False

    def run(self, job):
        # Ensure sync hasn't already been triggered
        if not self.check(job):
            return False

        try:
            # Queue sync
            Sync.queue(
                account=job.account,
                mode=SyncMode.Full,

                priority=100,
                trigger=SyncResult.Trigger.Schedule
            )
        except QueueError, ex:
            log.info('Queue error: %s', ex)
        except Exception, ex:
            log.error('Unable to queue sync: %s', ex, exc_info=True)

        return True


1	1	from plugin.models import SyncResult
2	1	from plugin.modules.scheduler.handlers.core.base import Handler
3	1	from plugin.preferences.options import SyncIntervalOption
4	1	from plugin.sync.core.enums import SyncMode
5	1	from plugin.sync.core.exceptions import QueueError
6	1	from plugin.sync.main import Sync
7
8	1	from datetime import datetime
9	1	import logging
10
11	1	log = logging.getLogger(__name__)
12
13
14	1	class SyncIntervalHandler(Handler):
15	1	key = 'sync.interval'
16
17	1	def check(self, job):
18		last_result = SyncIntervalOption.get_last_result(job.account, SyncMode.Full)
19
20		if last_result is None or last_result.started_at <= job.due_at:
21		return True
22
23		# Re-schedule job
24		job.due_at = job.next_at(last_result.started_at)
25
26		log.debug('Job re-scheduled to %r', job.due_at)
27
28		# Check if a trigger is required
29		if job.due_at <= datetime.utcnow():
30		return True
31
32		# Trigger ignored, update job
33		job.save()
34
35		log.debug('Ignoring scheduled sync interval (already triggered)')
36		return False
37
38	1	def run(self, job):
39		# Ensure sync hasn't already been triggered
40		if not self.check(job):
41		return False
42
43		try:
44		# Queue sync
45		Sync.queue(
46		account=job.account,
47		mode=SyncMode.Full,
48
49		priority=100,
50		trigger=SyncResult.Trigger.Schedule
51		)
52		except QueueError, ex:
53		log.info('Queue error: %s', ex)
54		except Exception, ex:
55		log.error('Unable to queue sync: %s', ex, exc_info=True)
56
57		return True
58

fuzeman / Plex-Trakt-Scrobbler

Push — develop ( 9e1b8b...5d0b21 )

SyncIntervalHandler.check() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like