GetLSession

Complexity

Total Complexity

5

Size/Duplication

Total Lines	37
Duplicated Lines	70.27 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
B	or_create()	26	26	3
A	__call__()	0	8	2

from plugin.core.helpers.variable import to_integer, merge
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 63))

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

from datetime import datetime
import apsw

The import apsw could not be resolved.

import logging
import peewee

log = logging.getLogger(__name__)


class GetLSession(GetSession):

This class has no __init__ method.

    def __call__(self, info):
        machine_identifier = info.get('machineIdentifier')

        if not machine_identifier:
            return None

        return super(GetLSession, self).__call__(
            Session.session_key == machine_identifier
        )

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

This code seems to be duplicated in your project.

        machine_identifier = info.get('machineIdentifier')

        if not machine_identifier:
            log.info('No machine identifier available, unable to create session')
            return None

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

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

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

                state='create'
            )

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

The Instance of GetLSession 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 UpdateLSession(UpdateSession):

This class has no __init__ method.

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

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

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

    def to_dict(self, obj, info, fetch=False):
        view_offset = to_integer(info.get('time'))
        rating_key = info.get('ratingKey')

        result = {
            'view_offset': view_offset,

            'updated_at': datetime.utcnow()
        }

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

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

            })

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

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

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

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

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

            })

        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.

                'key': info.get('machineIdentifier'),
                'title': info.get('client')
            }, fetch=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.

                'key': to_integer(info.get('user_id')),
                'title': info.get('user_name')
            }, fetch=True)

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

The Instance of UpdateLSession 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, {
            'duration': p_metadata.duration,
            'progress': self.get_progress(p_metadata.duration, view_offset)

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

        })


class LSessionManager(Manager):

This class has no __init__ method.

    get = GetLSession
    update = UpdateLSession

    model = Session