Movies

Complexity

Total Complexity

15

Size/Duplication

Total Lines	106
Duplicated Lines	0 %

Test Coverage

Coverage

6.67%

1 Method

Rating	Name	Duplication	Size	Complexity
F	run()	0	103	15

from plugin.sync.core.constants import GUID_AGENTS
from plugin.sync.core.enums import SyncMode, SyncData, SyncMedia
from plugin.sync.modes.core.base import Mode, log_unsupported, mark_unsupported

from plex_database.models import MetadataItem
from trakt_sync.cache.main import Cache
import elapsed
import logging

log = logging.getLogger(__name__)


class Movies(Mode):

This class has no __init__ method.

    mode = SyncMode.FastPull

    @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 steps
        total = 0

        for key, result in self.trakt.changes:

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

            media, data = key[0:2]

            if media != SyncMedia.Movies:
                # Ignore changes that aren't for episodes
                continue

            data_name = Cache.Data.get(data)

            for count in result.metrics.movies.get(data_name, {}).itervalues():
                total += count

        # Task started
        unsupported_movies = {}

        self.current.progress.start(total)

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

        # Process movies
        for rating_key, p_guid, p_item in p_items:
            if not p_guid or p_guid.agent not in GUID_AGENTS:
                mark_unsupported(unsupported_movies, rating_key, p_guid, p_item)
                continue

            key = (p_guid.agent, p_guid.sid)

            log.debug('Processing movie: %s', key)

            # Try retrieve `pk` for `key`
            pk = self.trakt.table.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

            # Iterate over changed data
            for key, result in self.trakt.changes:

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

                media, data = key[0:2]

                if media != SyncMedia.Movies:
                    # Ignore changes that aren't for movies
                    continue

                if data == SyncData.Watchlist:
                    # Ignore watchlist data
                    continue

                if not self.is_data_enabled(data):

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

                    # Data type has been disabled
                    continue

                data_name = Cache.Data.get(data)

                if data_name not in result.changes:
                    # No changes for collection
                    continue

                for action, items in result.changes[data_name].items():
                    t_item = items.get(pk)

                    if t_item is None:
                        # No item found in changes
                        continue

                    self.execute_handlers(

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

                        SyncMedia.Movies, data,
                        action=action,
                        key=rating_key,

                        p_item=p_item,
                        t_item=t_item
                    )

                    # Increment one step
                    self.current.progress.step()

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

            # 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)

        # Task stopped
        self.current.progress.stop()

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