X-Git-Url: http://git.maemo.org/git/?a=blobdiff_plain;f=src%2Fgvoice%2Fsession.py;h=adb551e6133f520600948a769d1621dd339502f6;hb=9ccb726096bb444a3f180966a16469fa3309e1e1;hp=35157d98ce02aef247de844acc8f841769f48df6;hpb=0b0ee151c524532cb0cbd7d1905e517c61f50d63;p=theonering

diff --git a/src/gvoice/session.py b/src/gvoice/session.py
index 35157d9..adb551e 100644
--- a/src/gvoice/session.py
+++ b/src/gvoice/session.py
@@ -5,6 +5,7 @@ import logging
 import backend
 import addressbook
 import conversations
+import state_machine
 
 
 _moduleLogger = logging.getLogger("gvoice.session")
@@ -12,31 +13,78 @@ _moduleLogger = logging.getLogger("gvoice.session")
 
 class Session(object):
 
-	def __init__(self, cookiePath):
-		self._cookiePath = cookiePath
+	def __init__(self, cookiePath = None):
 		self._username = None
 		self._password = None
-		self._backend = None
-		self._addressbook = None
-		self._conversations = None
+
+		self._backend = backend.GVoiceBackend(cookiePath)
+
+		self._addressbook = addressbook.Addressbook(self._backend)
+		self._addressbookStateMachine = state_machine.UpdateStateMachine([self.addressbook])
+		self._addressbookStateMachine.set_state_strategy(
+			state_machine.StateMachine.STATE_DND,
+			state_machine.NopStateStrategy()
+		)
+		self._addressbookStateMachine.set_state_strategy(
+			state_machine.StateMachine.STATE_IDLE,
+			state_machine.ConstantStateStrategy(state_machine.to_milliseconds(hours=6))
+		)
+		self._addressbookStateMachine.set_state_strategy(
+			state_machine.StateMachine.STATE_ACTIVE,
+			state_machine.ConstantStateStrategy(state_machine.to_milliseconds(hours=1))
+		)
+
+		self._conversations = conversations.Conversations(self._backend)
+		self._conversationsStateMachine = state_machine.UpdateStateMachine([self.conversations])
+		self._conversationsStateMachine.set_state_strategy(
+			state_machine.StateMachine.STATE_DND,
+			state_machine.NopStateStrategy()
+		)
+		self._conversationsStateMachine.set_state_strategy(
+			state_machine.StateMachine.STATE_IDLE,
+			state_machine.ConstantStateStrategy(state_machine.to_milliseconds(minutes=30))
+		)
+		self._conversationsStateMachine.set_state_strategy(
+			state_machine.StateMachine.STATE_ACTIVE,
+			state_machine.GeometricStateStrategy(
+				state_machine.to_milliseconds(seconds=10),
+				state_machine.to_milliseconds(seconds=1),
+				state_machine.to_milliseconds(minutes=10),
+			)
+		)
+
+		self._masterStateMachine = state_machine.MasterStateMachine()
+		self._masterStateMachine.append_machine(self._addressbookStateMachine)
+		self._masterStateMachine.append_machine(self._conversationsStateMachine)
+
+		self._conversations.updateSignalHandler.register_sink(
+			self._conversationsStateMachine.request_reset_timers
+		)
+
+	def close(self):
+		self._conversations.updateSignalHandler.unregister_sink(
+			self._conversationsStateMachine.request_reset_timers
+		)
+		self._masterStateMachine.close()
 
 	def login(self, username, password):
 		self._username = username
 		self._password = password
-		self._backend = backend.GVoiceBackend(self._cookiePath)
 		if not self._backend.is_authed():
 			self._backend.login(self._username, self._password)
 
+		self._masterStateMachine.start()
+
 	def logout(self):
+		self._masterStateMachine.stop()
+		self._backend.logout()
+
 		self._username = None
 		self._password = None
-		self._backend = None
-		self._addressbook = None
-		self._conversations = None
 
 	def is_logged_in(self):
-		if self._backend is None:
-			_moduleLogger.info("No Backend")
+		if self._username is None and self._password is None:
+			_moduleLogger.info("Hasn't even attempted to login yet")
 			return False
 		elif self._backend.is_authed():
 			return True
@@ -66,9 +114,6 @@ class Session(object):
 		"""
 		Delay initialized addressbook
 		"""
-		if self._addressbook is None:
-			_moduleLogger.info("Initializing addressbook")
-			self._addressbook = addressbook.Addressbook(self.backend)
 		return self._addressbook
 
 	@property
@@ -76,7 +121,16 @@ class Session(object):
 		"""
 		Delay initialized addressbook
 		"""
-		if self._conversations is None:
-			_moduleLogger.info("Initializing conversations")
-			self._conversations = conversations.Conversationst(self.backend)
 		return self._conversations
+
+	@property
+	def stateMachine(self):
+		return self._masterStateMachine
+
+	@property
+	def addressbookStateMachine(self):
+		return self._addressbookStateMachine
+
+	@property
+	def conversationsStateMachine(self):
+		return self._conversationsStateMachine