Factory.reset() - Code Metrics - Inspection of "Merge remote-tracking branch 'origin/master'" - half2me/libant - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 04a643...97b348 )

by Benjamin

created 2016-09-24 11:08 UTC

Factory.reset() A

↳ Parent: Project

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	3
rs	10
cc	2

from threading import Lock

from libAnt.message import BroadcastMessage
from libAnt.profiles.power_profile import PowerProfileMessage
from libAnt.profiles.speed_cadence_profile import SpeedAndCadenceProfileMessage


class Factory:
    types = {
        121: SpeedAndCadenceProfileMessage,
        11: PowerProfileMessage
    }

    def __init__(self, callback=None):
        self._filter = None
        self._lock = Lock()
        self._messages = {}
        self._callback = callback

    def enableFilter(self):
        with self._lock:
            if self._filter is None:
                self._filter = {}

    def disableFilter(self):
        with self._lock:
            if self._filter is not None:
                self._filter = None

    def clearFilter(self):
        with self._lock:
            if self._filter is not None:
                self._filter.clear()

    def addToFilter(self, deviceNumber: int):
        with self._lock:
            if self._filter is not None:
                self._filter[deviceNumber] = True

    def removeFromFilter(self, deviceNumber: int):
        with self._lock:
            if self._filter is not None:
                if deviceNumber in self._filter:
                    del self._filter[deviceNumber]

    def parseMessage(self, msg: BroadcastMessage):
        with self._lock:
            if self._filter is not None:
                if msg.deviceNumber not in self._filter:
                    return
            if msg.deviceType in Factory.types:
                num = msg.deviceNumber
                type = msg.deviceType
                pmsg = self.types[type](msg, self._messages[(num, type)] if (num, type) in self._messages else None)
                self._messages[(num, type)] = pmsg
                if callable(self._callback):
                    self._callback(pmsg)

    def reset(self):
        with self._lock:
            self._messages = {}

1			from threading import Lock
2
3			from libAnt.message import BroadcastMessage
4			from libAnt.profiles.power_profile import PowerProfileMessage
5			from libAnt.profiles.speed_cadence_profile import SpeedAndCadenceProfileMessage
6
7
8			class Factory:
9			types = {
10			121: SpeedAndCadenceProfileMessage,
11			11: PowerProfileMessage
12			}
13
14			def __init__(self, callback=None):
15			self._filter = None
16			self._lock = Lock()
17			self._messages = {}
18			self._callback = callback
19
20			def enableFilter(self):
21			with self._lock:
22			if self._filter is None:
23			self._filter = {}
24
25			def disableFilter(self):
26			with self._lock:
27			if self._filter is not None:
28			self._filter = None
29
30			def clearFilter(self):
31			with self._lock:
32			if self._filter is not None:
33			self._filter.clear()
34
35			def addToFilter(self, deviceNumber: int):
36			with self._lock:
37			if self._filter is not None:
38			self._filter[deviceNumber] = True
39
40			def removeFromFilter(self, deviceNumber: int):
41			with self._lock:
42			if self._filter is not None:
43			if deviceNumber in self._filter:
44			del self._filter[deviceNumber]
45
46			def parseMessage(self, msg: BroadcastMessage):
47			with self._lock:
48			if self._filter is not None:
49			if msg.deviceNumber not in self._filter:
50			return
51			if msg.deviceType in Factory.types:
52			num = msg.deviceNumber
53			type = msg.deviceType
54			pmsg = self.types[type](msg, self._messages[(num, type)] if (num, type) in self._messages else None)
55			self._messages[(num, type)] = pmsg
56			if callable(self._callback):
57			self._callback(pmsg)
58
59			def reset(self):
60			with self._lock:
61			self._messages = {}

half2me / libant

GitHub Access Token became invalid

Push — master ( 04a643...97b348 )

Factory.reset() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like