Episodes

Complexity

Total Complexity

3

Size/Duplication

Total Lines	22
Duplicated Lines	0 %

Test Coverage

Coverage

36.36%

2 Methods

Rating	Name	Duplication	Size	Complexity
A	on_removed()	0	3	1
A	on_added()	0	14	2

from plugin.core.session_status import SessionStatus
from plugin.sync.core.enums import SyncData, SyncMedia, SyncMode
from plugin.sync.handlers.core import DataHandler, PushHandler, bind
from plugin.sync.handlers.watched.base import WatchedHandler

import logging

log = logging.getLogger(__name__)


class Base(PushHandler, WatchedHandler):

The method fast_pull which was declared abstract in the super-class MediaHandler
was not overridden.

The method full which was declared abstract in the super-class MediaHandler
was not overridden.

The method on_added which was declared abstract in the super-class MediaHandler
was not overridden.

The method on_changed which was declared abstract in the super-class MediaHandler
was not overridden.

The method on_removed which was declared abstract in the super-class MediaHandler
was not overridden.

The method pull which was declared abstract in the super-class MediaHandler
was not overridden.

    def push(self, p_item, t_item, key, **kwargs):
        # Ensure item isn't currently being watched in plex
        if SessionStatus.is_watching(self.current.account.id, key):
            log.debug('Item %r is currently being watched, ignoring push watched handler', key)
            return

        super(Base, self).push(
            p_item, t_item,
            key=key,
            **kwargs
        )


class Movies(Base):

This code seems to be duplicated in your project.

The method fast_pull which was declared abstract in the super-class MediaHandler
was not overridden.

The method full which was declared abstract in the super-class MediaHandler
was not overridden.

The method on_changed which was declared abstract in the super-class MediaHandler
was not overridden.

The method pull which was declared abstract in the super-class MediaHandler
was not overridden.

    media = SyncMedia.Movies

    @bind('added', [SyncMode.Full, SyncMode.Push])
    def on_added(self, key, guid, p_item, p_value, t_value, **kwargs):
        # Retrieve plex `view_count`
        p_settings = p_item.get('settings', {})
        p_view_count = p_settings.get('view_count', 0)

        log.debug('Movies.on_added(%r, ...) - p_view_count: %r, p_value: %r, t_value: %r', key, p_view_count, p_value, t_value)

This line is too long as per the coding-style (127/120).

        if t_value:
            return

        self.store_movie('add', guid,
            p_item,
            watched_at=p_value
        )

    @bind('removed', [SyncMode.Full, SyncMode.Push])
    def on_removed(self, key, t_value, **kwargs):

The argument t_value seems to be unused.

        log.debug('Movies.on_removed(%r, ...)', key)


class Episodes(Base):

This code seems to be duplicated in your project.

The method fast_pull which was declared abstract in the super-class MediaHandler
was not overridden.

The method full which was declared abstract in the super-class MediaHandler
was not overridden.

The method on_changed which was declared abstract in the super-class MediaHandler
was not overridden.

The method pull which was declared abstract in the super-class MediaHandler
was not overridden.

    media = SyncMedia.Episodes

    @bind('added', [SyncMode.Full, SyncMode.Push])
    def on_added(self, key, guid, identifier, p_show, p_item, p_value, t_value, **kwargs):
        # Retrieve plex `view_count`
        p_settings = p_item.get('settings', {})
        p_view_count = p_settings.get('view_count', 0)

        log.debug('Episodes.on_added(%r, ...) - p_view_count: %r, p_value: %r, t_value: %r', key, p_view_count, p_value, t_value)

This line is too long as per the coding-style (129/120).

        if t_value:
            return

        self.store_episode('add', guid,
            identifier, p_show,
            watched_at=p_value
        )

    @bind('removed', [SyncMode.Full, SyncMode.Push])
    def on_removed(self, key, t_value, **kwargs):

The argument t_value seems to be unused.

        log.debug('Episodes.on_removed(%r, ...)', key)


class Push(DataHandler):
    data = SyncData.Watched
    mode = SyncMode.Push

    children = [
        Movies,
        Episodes
    ]