Movies.process_missing_movies() - Code Metrics - Inspection of "Updated [README.md]" - fuzeman/Plex-Trakt-Scrobbler - Measure and Improve Code Quality continuously with Scrutinizer

Test Setup Failed

Push — develop ( a5f1b0...06bf6f )

by Dean

created 2016-01-23 10:36 UTC

Movies.process_missing_movies() C

↳ Parent: Movies

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	1
CRAP Score	48.6673

Metric	Value
cc	7
dl	0
loc	57
ccs	1
cts	19
cp	0.0526
crap	48.6673
rs	6.6397

How to fix Long Method

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

from plex_database.models import MetadataItem, MediaItem
from plex_metadata import Guid
import elapsed
import logging

log = logging.getLogger(__name__)


class Movies(Base):
    def __init__(self, task):
        super(Movies, self).__init__(task)

        # Sections
        self.p_sections = None
        self.p_sections_map = None

        # Items
        self.p_count = None
        self.p_movies = None

        self.p_pending = None
        self.p_unsupported = None

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


        # Determine number of movies that will be processed
        self.p_count = self.plex.library.movies.count(

            self.p_sections,
            account=self.current.account.plex.key

        )

        # Increment progress steps total
        self.current.progress.group(Movies, 'matched:movies').add(self.p_count)

        self.current.progress.group(Movies, 'missing:movies')


    @elapsed.clock
    def start(self):
        # Fetch movies with account settings
        self.p_movies = self.plex.library.movies.mapped(

            self.p_sections, [
                MetadataItem.added_at,
                MetadataItem.title,
                MetadataItem.year,

                MediaItem.audio_channels,
                MediaItem.audio_codec,
                MediaItem.height,
                MediaItem.interlaced
            ],
            account=self.current.account.plex.key,

            parse_guid=True
        )

        # Reset state
        self.p_pending = self.trakt.table.movies.copy()

        self.p_unsupported = {}

    @elapsed.clock
    def run(self):
        # Process movies
        self.process_matched_movies()
        self.process_missing_movies()

    def process_matched_movies(self):
        """Trigger actions for movies that have been matched in plex"""

        # Iterate over movies
        for rating_key, guid, p_item in self.p_movies:
            # Increment one step
            self.current.progress.group(Movies, 'matched:movies').step()


            # Ensure `guid` is available
            if not guid or guid.agent not in GUID_AGENTS:
                mark_unsupported(self.p_unsupported, rating_key, guid, p_item)
                continue

            key = (guid.agent, guid.sid)

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


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

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


                self.execute_handlers(

                    SyncMedia.Movies, data,

                    key=rating_key,

                    guid=guid,
                    p_item=p_item,

                    t_item=t_movie
                )

            # Remove movie from `pending` set
            if pk and pk in self.p_pending:
                self.p_pending.remove(pk)

            # Task checkpoint
            self.checkpoint()


        # Stop progress group
        self.current.progress.group(Movies, 'matched:movies').stop()


        # Report unsupported movies (unsupported guid)
        log_unsupported(log, 'Found %d unsupported movie(s)\n%s', self.p_unsupported)

    def process_missing_movies(self):
        """Trigger actions for movies that are in trakt, but was unable to be found in plex"""

        if self.current.kwargs.get('section'):

            # Collection cleaning disabled for individual syncs
            return

        # Increment progress steps
        self.current.progress.group(Movies, 'missing:movies').add(len(self.p_pending))


        # Iterate over movies
        for pk in list(self.p_pending):
            # Increment one step
            self.current.progress.group(Movies, 'missing:movies').step()


            # Iterate over data handlers
            triggered = False

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

                if data not in [SyncData.Collection]:
                    continue

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


                if not t_movie:
                    continue

                log.debug('Found movie missing from plex: %r [data: %r]', pk, SyncData.title(data))

                # Trigger handler
                self.execute_handlers(

                    SyncMedia.Movies, data,

                    key=None,

                    guid=Guid(*pk),
                    p_item=None,

                    t_item=t_movie
                )

                # Mark triggered
                triggered = True

            # Check if action was triggered
            if not triggered:
                continue

            # Remove movie from `pending` set
            self.p_pending.remove(pk)

        # Stop progress group
        self.current.progress.group(Movies, 'missing:movies').stop()


        # Report pending movies (no actions triggered)
        self.log_pending('Unable to process %d movie(s)\n%s', self.p_pending)


1	1	from plugin.sync.core.constants import GUID_AGENTS
2	1	from plugin.sync.core.enums import SyncMedia, SyncData
3	1	from plugin.sync.modes.core.base import log_unsupported, mark_unsupported
4	1	from plugin.sync.modes.push.base import Base
5
6	1	from plex_database.models import MetadataItem, MediaItem
7	1	from plex_metadata import Guid
8	1	import elapsed
9	1	import logging
10
11	1	log = logging.getLogger(__name__)
12
13
14	1	class Movies(Base):
15	1	def __init__(self, task):
16		super(Movies, self).__init__(task)
17
18		# Sections
19		self.p_sections = None
20		self.p_sections_map = None
21
22		# Items
23		self.p_count = None
24		self.p_movies = None
25
26		self.p_pending = None
27		self.p_unsupported = None
28
29	1	@elapsed.clock
30		def construct(self):
31		# Retrieve movie sections
32		self.p_sections, self.p_sections_map = self.sections('movie')
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `sections`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
33
34		# Determine number of movies that will be processed
35		self.p_count = self.plex.library.movies.count(
		0 ignored issues – show Bug introduced 2016-01-17 02:06 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `plex`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
36		self.p_sections,
37		account=self.current.account.plex.key
		0 ignored issues – show Bug introduced 2016-01-17 02:06 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `current`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
38		)
39
40		# Increment progress steps total
41		self.current.progress.group(Movies, 'matched:movies').add(self.p_count)
		0 ignored issues – show Bug introduced 2016-01-17 02:06 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `current`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
42		self.current.progress.group(Movies, 'missing:movies')
		0 ignored issues – show Bug introduced 2016-01-17 02:06 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `current`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
43
44	1	@elapsed.clock
45		def start(self):
46		# Fetch movies with account settings
47		self.p_movies = self.plex.library.movies.mapped(
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `plex`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
48		self.p_sections, [
49		MetadataItem.added_at,
50		MetadataItem.title,
51		MetadataItem.year,
52
53		MediaItem.audio_channels,
54		MediaItem.audio_codec,
55		MediaItem.height,
56		MediaItem.interlaced
57		],
58		account=self.current.account.plex.key,
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `current`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
59		parse_guid=True
60		)
61
62		# Reset state
63		self.p_pending = self.trakt.table.movies.copy()
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `trakt`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
64		self.p_unsupported = {}
65
66	1	@elapsed.clock
67		def run(self):
68		# Process movies
69		self.process_matched_movies()
70		self.process_missing_movies()
71
72	1	def process_matched_movies(self):
73		"""Trigger actions for movies that have been matched in plex"""
74
75		# Iterate over movies
76		for rating_key, guid, p_item in self.p_movies:
77		# Increment one step
78		self.current.progress.group(Movies, 'matched:movies').step()
		0 ignored issues – show Bug introduced 2016-01-17 02:06 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `current`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
79
80		# Ensure `guid` is available
81		if not guid or guid.agent not in GUID_AGENTS:
82		mark_unsupported(self.p_unsupported, rating_key, guid, p_item)
83		continue
84
85		key = (guid.agent, guid.sid)
86
87		# Try retrieve `pk` for `key`
88		pk = self.trakt.table.get(key)
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `trakt`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
89
90		for data in self.get_data(SyncMedia.Movies):
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `get_data`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
91		t_movie = self.trakt[(SyncMedia.Movies, data)].get(pk)
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `trakt`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
92
93		self.execute_handlers(
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `execute_handlers`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
94		SyncMedia.Movies, data,
95
96		key=rating_key,
97
98		guid=guid,
99		p_item=p_item,
100
101		t_item=t_movie
102		)
103
104		# Remove movie from `pending` set
105		if pk and pk in self.p_pending:
106		self.p_pending.remove(pk)
107
108		# Task checkpoint
109		self.checkpoint()
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `checkpoint`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
110
111		# Stop progress group
112		self.current.progress.group(Movies, 'matched:movies').stop()
		0 ignored issues – show Bug introduced 2016-01-17 02:06 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `current`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
113
114		# Report unsupported movies (unsupported guid)
115		log_unsupported(log, 'Found %d unsupported movie(s)\n%s', self.p_unsupported)
116
117	1	def process_missing_movies(self):
118		"""Trigger actions for movies that are in trakt, but was unable to be found in plex"""
119
120		if self.current.kwargs.get('section'):
		0 ignored issues – show Bug introduced 2016-01-17 21:33 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `current`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
121		# Collection cleaning disabled for individual syncs
122		return
123
124		# Increment progress steps
125		self.current.progress.group(Movies, 'missing:movies').add(len(self.p_pending))
		0 ignored issues – show Bug introduced 2016-01-17 02:06 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `current`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
126
127		# Iterate over movies
128		for pk in list(self.p_pending):
129		# Increment one step
130		self.current.progress.group(Movies, 'missing:movies').step()
		0 ignored issues – show Bug introduced 2016-01-17 02:06 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `current`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
131
132		# Iterate over data handlers
133		triggered = False
134
135		for data in self.get_data(SyncMedia.Movies):
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `get_data`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
136		if data not in [SyncData.Collection]:
137		continue
138
139		# Retrieve movie
140		t_movie = self.trakt[(SyncMedia.Movies, data)].get(pk)
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `trakt`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
141
142		if not t_movie:
143		continue
144
145		log.debug('Found movie missing from plex: %r [data: %r]', pk, SyncData.title(data))
146
147		# Trigger handler
148		self.execute_handlers(
		0 ignored issues – show Bug introduced 2015-12-19 01:32 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `execute_handlers`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
149		SyncMedia.Movies, data,
150
151		key=None,
152
153		guid=Guid(*pk),
154		p_item=None,
155
156		t_item=t_movie
157		)
158
159		# Mark triggered
160		triggered = True
161
162		# Check if action was triggered
163		if not triggered:
164		continue
165
166		# Remove movie from `pending` set
167		self.p_pending.remove(pk)
168
169		# Stop progress group
170		self.current.progress.group(Movies, 'missing:movies').stop()
		0 ignored issues – show Bug introduced 2016-01-17 02:06 UTC by Report Bug Copy Issue Report The Instance of `Movies` does not seem to have a member named `current`. This check looks for calls to members that are non-existent. These calls will fail. The member could have been renamed or removed. Loading history...
171
172		# Report pending movies (no actions triggered)
173		self.log_pending('Unable to process %d movie(s)\n%s', self.p_pending)
174

fuzeman / Plex-Trakt-Scrobbler

Push — develop ( a5f1b0...06bf6f )

Movies.process_missing_movies() C

Complexity

Size

Duplication

Code Coverage

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like