Changeset 4ff36b1676f8899d85c264278fbbd183afeff21f

Timestamp:

26/11/10 22:34:36 (2 years ago)

Author:

Agustin Henze - TiN <tin@…>

Children:

eca7cab54a0af29e781009921601f2b1146e2236

Parents:

945ee719561fdc5edb101c445e7866a7b92a4c48

git-committer:

Agustin Henze - TiN <tin@…> (26/11/10 22:34:36)

Message:

Se agrega la cola utilizando yserial, 2 BD en una se lleva la cola de usuarios a crear y en la otra el historial

Location:

arma2/frontend

Files:

• common.py (modified) (2 diffs)
• config.py (modified) (1 diff)
• y_serial_v060.py (added)

arma2/frontend/common.py

@@ -1 +1 @@
 # -*- coding: utf-8 -*-
 import logging
-from config import logFILE, logFORMAT, logDATEFORMAT
+from config import logFILE, logFORMAT, logDATEFORMAT, PATH_USER_CREATED, PATH_HISTORY
+import y_serial_v060  as y_serial
 
 logging.basicConfig(level=logging.DEBUG, filename=logFILE, format=logFORMAT, datefmt=logDATEFORMAT)
@@ -16 +17 @@
     getattr(getLogger(), level.lower())(msg)
     return True
+
+class Fifo(object):
+    __slots__ = ('front', 'back')
+
+    def __init__(self):
+        self.front = []
+        self.back = []
+
+    def __repr__(self):
+        return repr(self.front) + repr(self.back)
+
+    def __len__(self):
+        length = len(self.front)
+        if length == 0:
+            length = len(self.back)
+        return length
+
+    def enqueue(self, value):
+        self.back.append(value)
+
+    def dequeue(self):
+        front = self.front
+        if not front:
+            self.front, self.back = self.back, front
+            front = self.front
+            front.reverse()
+        return front.pop()
+
+class queueUsers(object):
+    def __init__(self):
+        """"""
+        self.users = y_serial.Main(PATH_USER_CREATED)
+        self.historyUsers = y_serial.Main(PATH_HISTORY)
+
+        try:
+            self.listUsers = self.users.select("user_list", "idcentral")
+        except IOError:
+            self.users.insert(Fifo(), "user_list", "idcentral")
+            self.listUsers = self.users.select("user_list", "idcentral")
+
+    def __sync(self):
+        self.users.insert(self.listUsers, "user_list", "idcentral")
+        return True
+
+    def insert(self, newUser):
+        self.listUsers.enqueue(newUser)
+        self.historyUsers.insert(newUser, "history_users", "idcentral")
+        self.__sync()
+
+    def pop(self):
+        try:
+            newUserToCreated = self.listUsers.dequeue()
+            self.historyUsers.insert(newUserToCreated, "history_users_created", "idcentral")
+            self.__sync()
+        except IndexError:
+            newUserToCreated = False
+        return newUserToCreated
+
+    def pending(self):
+        return len(self.listUsers)

arma2/frontend/config.py

@@ -16 +16 @@
 logFORMAT               = '%(asctime)s %(levelname)s: %(message)s'
 logDATEFORMAT           = '%Y-%m-%d %H:%M:%S' 
+
+#Queue Configuration
+PATH_USER_CREATED = '/tmp/user_created'
+PATH_HISTORY = '/tmp/history_user_created'