UpdateWSession

Complexity

Total Complexity

10

Size/Duplication

Total Lines	112
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__call__()	0	9	1
F	to_dict()	0	101	9

from plugin.core.helpers.variable import to_integer, merge, resolve
from plugin.managers.core.base import Manager

The name base does not seem to exist in module plugin.managers.core.

Unable to import 'plugin.managers.core.base' (invalid syntax (<string>, line 39))

from plugin.managers.client import ClientManager
from plugin.managers.core.exceptions import FilteredException
from plugin.managers.session.base import GetSession, UpdateSession

The name base does not seem to exist in module plugin.managers.session.

Unable to import 'plugin.managers.session.base' (invalid syntax (<string>, line 67))

from plugin.managers.user import UserManager
from plugin.models import Session
from plugin.modules.core.manager import ModuleManager

The name manager does not seem to exist in module plugin.modules.core.

Unable to import 'plugin.modules.core.manager' (invalid syntax (<string>, line 40))

from datetime import datetime
from plex import Plex
import apsw

The import apsw could not be resolved.

import logging
import peewee


log = logging.getLogger(__name__)


class GetWSession(GetSession):

This class has no __init__ method.

    def __call__(self, info):
        session_key = to_integer(info.get('sessionKey'))

        return super(GetWSession, self).__call__(
            Session.session_key == self.build_session_key(session_key)

The Instance of GetWSession does not seem to have a member named build_session_key.

        )

    def or_create(self, info, fetch=False):

This code seems to be duplicated in your project.

        session_key = to_integer(info.get('sessionKey'))

        try:
            # Create new session
            obj = self.manager.create(

The Instance of GetWSession does not seem to have a member named manager.

                rating_key=to_integer(info.get('ratingKey')),
                session_key=self.build_session_key(session_key),

The Instance of GetWSession does not seem to have a member named build_session_key.

                state='create'
            )

            # Update newly created object
            self.manager.update(obj, info, fetch)

The Instance of GetWSession does not seem to have a member named manager.

            # Update active sessions
            ModuleManager['sessions'].on_created(obj)

            return obj
        except (apsw.ConstraintError, peewee.IntegrityError):
            # Return existing object
            return self(info)


class UpdateWSession(UpdateSession):

This class has no __init__ method.

    def __call__(self, obj, info, fetch=False):
        data = self.to_dict(obj, info, fetch)

        success = super(UpdateWSession, self).__call__(
            obj, data
        )

        ModuleManager['sessions'].on_updated(obj)
        return success

    def to_dict(self, obj, info, fetch=False):
        fetch = resolve(fetch, obj, info)

        view_offset = to_integer(info.get('viewOffset'))

        result = {
            'rating_key': to_integer(info.get('ratingKey')),
            'view_offset': view_offset,

            'updated_at': datetime.utcnow()
        }

        if not fetch:
            # Return simple update
            return merge(result, {
                'progress': self.get_progress(

The Instance of UpdateWSession does not seem to have a member named get_progress.

                    obj.duration, view_offset,
                    obj.part, obj.part_count, obj.part_duration
                )
            })

        # Retrieve session key
        session_key = to_integer(info.get('sessionKey'))

        if not session_key:
            log.info('Missing session key, unable to fetch session details')
            return result

        # Retrieve active sessions
        log.debug('Fetching details for session #%s', session_key)

        p_sessions = Plex['status'].sessions()

        if not p_sessions:
            log.info('Unable to retrieve active sessions')
            return result

        # Find session matching `session_key`
        p_item = p_sessions.get(session_key)

        if not p_item:
            log.info('Unable to find session with key %r', session_key)
            return result

        # Retrieve metadata and guid
        p_metadata, guid = self.get_metadata(p_item.rating_key)

The Instance of UpdateWSession does not seem to have a member named get_metadata.

        if not p_metadata:
            log.info('Unable to retrieve metadata for rating_key %r', p_item.rating_key)
            return result

        if not guid or not guid.valid:
            return merge(result, {
                'duration': p_metadata.duration,
                'progress': self.get_progress(p_metadata.duration, view_offset)

The Instance of UpdateWSession does not seem to have a member named get_progress.

            })

        # Retrieve media parts
        part, part_count, part_duration = self.match_parts(p_metadata, guid, view_offset)

The Instance of UpdateWSession does not seem to have a member named match_parts.

        log.debug('Part: %s (part_count: %s, part_duration: %s)', part, part_count, part_duration)

        # Find matching client + user for session
        try:
            # Create/Retrieve `Client` for session
            result['client'] = ClientManager.get.or_create(

It seems like a value for argument player is missing in the unbound method call.

                p_item.session.player,

                fetch=True,
                match=True,
                filtered_exception=True
            )

            # Create/Retrieve `User` for session
            result['user'] = UserManager.get.or_create(

It seems like a value for argument user is missing in the unbound method call.

                p_item.session.user,

                fetch=True,
                match=True,
                filtered_exception=True
            )

            # Pick account from `client` or `user` objects
            result['account'] = self.get_account(result)

The Instance of UpdateWSession does not seem to have a member named get_account.

        except FilteredException:
            log.debug('Activity has been filtered')

            result['client'] = None
            result['user'] = None

            result['account'] = None

        return merge(result, {
            'part': part,
            'part_count': part_count,
            'part_duration': part_duration,

            'duration': p_metadata.duration,
            'progress': self.get_progress(

The Instance of UpdateWSession does not seem to have a member named get_progress.

                p_metadata.duration, view_offset,
                part, part_count, part_duration
            )
        })


class WSessionManager(Manager):

This class has no __init__ method.

    get = GetWSession
    update = UpdateWSession

    model = Session