Movies

Complexity

Total Complexity

9

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Test Coverage

Coverage

10.71%

1 Method

Rating	Name	Duplication	Size	Complexity
D	run()	0	65	9

from plugin.core.constants import GUID_SERVICES
from plugin.sync.core.enums import SyncData, SyncMedia
from plugin.sync.modes.core.base import log_unsupported, mark_unsupported
from plugin.sync.modes.pull.base import Base

from plex_database.models import MetadataItem
import elapsed
import logging

log = logging.getLogger(__name__)


class Movies(Base):

This class has no __init__ method.

    data = [
        SyncData.Collection,
        SyncData.Playback,
        SyncData.Ratings,
        SyncData.Watched
    ]

    @elapsed.clock
    def run(self):
        # Retrieve movie sections
        p_sections, p_sections_map = self.sections('movie')

The Instance of Movies does not seem to have a member named sections.

The variable p_sections_map seems to be unused.

        # Fetch movies with account settings
        p_items = self.plex.library.movies.mapped(

The Instance of Movies does not seem to have a member named plex.

            p_sections, [
                MetadataItem.library_section
            ],
            account=self.current.account.plex.key,

The Instance of Movies does not seem to have a member named current.

            parse_guid=True
        )

        # Calculate total number of movies
        pending = {}

        for data in self.get_data(SyncMedia.Movies):

The Instance of Movies does not seem to have a member named get_data.

            if data not in pending:
                pending[data] = {}

            for pk in self.trakt[(SyncMedia.Movies, data)]:

The Instance of Movies does not seem to have a member named trakt.

                pending[data][pk] = False

        # Task started
        unsupported_movies = {}

        for rating_key, guid, p_item in p_items:
            if not guid or guid.service not in GUID_SERVICES:
                mark_unsupported(unsupported_movies, rating_key, guid)
                continue

            key = (guid.service, guid.id)

            # Try retrieve `pk` for `key`
            pk = self.trakt.table('movies').get(key)

The Instance of Movies does not seem to have a member named trakt.

            # Store in item map
            self.current.map.add(p_item.get('library_section'), rating_key, [key, pk])

The Instance of Movies does not seem to have a member named current.

            if pk is None:
                # No `pk` found
                continue

            # Execute data handlers
            for data in self.get_data(SyncMedia.Movies):

The Instance of Movies does not seem to have a member named get_data.

                t_movie = self.trakt[(SyncMedia.Movies, data)].get(pk)

The Instance of Movies does not seem to have a member named trakt.

                self.execute_handlers(

The Instance of Movies does not seem to have a member named execute_handlers.

                    SyncMedia.Movies, data,
                    key=rating_key,

                    p_item=p_item,
                    t_item=t_movie
                )

                # Increment one step
                self.step(pending, data, pk)

            # Task checkpoint
            self.checkpoint()

The Instance of Movies does not seem to have a member named checkpoint.

        # Log details
        log_unsupported(log, 'Found %d unsupported movie(s)\n%s', unsupported_movies)
        log.debug('Pending: %r', pending)