vato007/picar
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove obsolete, unimplemented classes

Browse Source
This commit is contained in:
Michael Pivato
2019-01-17 14:46:11 +10:30
parent 90445bfd14
commit a8b3491661
7 changed files with 0 additions and 103 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
DecisionSystem/centralisedvoter.py
View File

@@ -1,5 +0,0 @@
import voter
class BallotVoter(Voter):
def submit_vote(self):
pass

7
DecisionSystem/decentralisedvoter.py
View File

@@ -1,7 +0,0 @@
import voter
class VoteReplicator(Voter):
def __init__(self):
pass

2
DecisionSystem/executor.py
View File

@@ -1,2 +0,0 @@
class Executor:
pass

32
DecisionSystem/mqttvoter.py
View File

@@ -1,32 +0,0 @@
from DecisionSystem.voter import Voter
import Messaging.mqttsession as ms
from Messaging.packmessage import PackMessage
from DecisionSystem.vote import Vote
class MqttVoter(Voter):
def __init__(self, host = "10.0.123.11"):
# Should use a factory here to always get the same session.
# Just going to use a singleton for now, as there should only be
# one session in the program.
ms.client = ms.Client()
ms.connect()
def submit_vote(self):
pass
def set_vote(self, vote):
if isinstance(vote, Vote):
self._vote = vote
return True
else:
return False
def get_vote(self):
return self._vote
# This is meant to be the mqtt callback... Should've documented this earlier.
def request_vote(self, client, userdata, message):
# Perhaps do some checking to see what is being voted on...
self.submit_vote()

5
DecisionSystem/timeoutexecutor.py
View File

@@ -1,5 +0,0 @@
import executor
class TimeoutExecutor(Executor):
pass

43
DecisionSystem/vote.py
View File

@@ -1,43 +0,0 @@
from Messaging.packmessage import PackMessage
class Vote(PackMessage):
def __init__(self, client, vote = None):
self._vote = vote
self._client = client
@property
def vote(self):
return self._vote
@vote.setter
def vote(self, value):
self._vote = value
def __eq__(self, other):
if not isinstance(other, Vote):
return False
if other.vote == self.vote:
return True
def serialise(self):
# Still need associated device as well? to know who went the message,
# to check that we don't add too many messages in case of multiple
# sends.
self.message = {"vote": self.vote}
# Call super method equivalent.
super(Vote, self).serialise()
def deserialise(self):
super(Vote, self).deserialise()
if "vote" in self.message:
self.vote = self.message["vote"]
else:
# Do something.
pass

9
DecisionSystem/voter.py
View File

@@ -1,9 +0,0 @@
from Messaging.packmessage import PackMessage
import umsgpack
class Voter:
def submit_vote(self):
raise NotImplementedError()
def send_connected(self):
raise NotImplementedError()