X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=plugins%2Fpres_view%2Fdaemon-todo%2Fevent2.py;fp=plugins%2Fpres_view%2Fdaemon-todo%2Fevent2.py;h=8913bbefeda797df1255120d0152bccaf51123f7;hb=43ca2628d94ef6f810129e422701f2415d95ceb3;hp=0000000000000000000000000000000000000000;hpb=9c3ecdab818e1792e6d781df95098b30543ff69f;p=unfold.git

diff --git a/plugins/pres_view/daemon-todo/event2.py b/plugins/pres_view/daemon-todo/event2.py
new file mode 100644
index 00000000..8913bbef
--- /dev/null
+++ b/plugins/pres_view/daemon-todo/event2.py
@@ -0,0 +1,129 @@
+# !/usr/bin/python
+# -*-coding: utf-8-*-
+
+import pickle
+import os.path
+import xmlrpclib
+import ast
+import time
+import simplejson
+
+class Event2:
+    def __init__(self, structure):
+        ##Definition des variables##
+        self.data_access_methode    =   ""
+        self.data_access_options    =   ""
+        
+        self.structure              =   structure
+        self.methode                =   ""
+        self.parameters             =   {}
+        self.return_fields          =   []
+        self.print_method           =   ""
+        self.print_options          =   ""
+        self.geo_methode            =   ""
+        self.id                     =   ""
+        self.timestamp              =   ""
+        #on paramètre timestamp, si c'est un dynamique, il sera fournit, sinon, on le met à 0
+        timestamp=0;
+        
+        ##APE###
+        self.raw                    =   ""
+        self.channel                =   ""
+        #######
+        
+        ## On creer l'objet ##
+        self.data = self.make_data(timestamp)
+        
+        
+    def split(self):
+        args = self.structure.split(";");
+        self.channel                =   args[1]  
+        self.raw                    =   args[3]
+        self.data_access_methode    =   args[4]
+        self.data_access_options    =   ast.literal_eval(args[5])
+        self.print_method           =   args[6]
+        self.print_options          =   ast.literal_eval(args[7])
+        self.methode                =   args[8]
+        self.parameters             =   ast.literal_eval(args[9])
+        self.return_fields          =   eval(args[10])
+        self.timestamp              =   args[11]
+
+    def get_event_list_from_xmlrpc(self,timestamp):
+        
+        ## on test pour voir si on est en dynamique, si c'est le cas, on met à jour la valeur du timestamp
+        if timestamp!=0:
+            self.parameters[self.timestamp]         =   int(timestamp)
+            
+            
+        ####on cree l'identification
+        auth = {}
+        if self.data_access_options["authType"]     ==  "anonymous":
+            auth["AuthMethod"]  =   "anonymous"
+            
+        elif self.data_access_options["authType"]   ==  "password":
+            auth["AuthMethod"]  =   "password"
+            auth["Username"]    =   self.data_access_options["Username"]
+            auth["AuthString"]  =   self.data_access_options["AuthString"]
+            
+        elif self.data_access_options["authType"]   ==  "session":
+            auth["AuthMethod"]  =   "session"
+            auth["session"]     =   self.data_access_options["session"]
+            
+        elif self.data_access_options["authType"]   ==  "gpg":
+            auth["AuthMethod"]  =   "gpg"
+            auth["name"]        =   self.data_access_options["name"]
+            auth["signature"]   =   self.data_access_options["signature"]
+        
+         
+        srv = xmlrpclib.Server(self.data_access_options["server"], allow_none = 1)
+        
+        
+        ##On gère en fonction des methodes
+        
+        if self.methode=="GetSites":
+            self.geo_methode="site_id";
+            try :
+                if len(self.return_fields)==0:
+                    data =  srv.GetSites(auth, self.parameters) 
+                else :
+                    data = srv.GetSites(auth, self.parameters, self.return_fields)
+            except:
+                    return self.parameters
+        else:
+            return 2
+        
+        ###on recupère la liste des localisation
+        
+        ##si il y a moins de 8 resultats, on recupère seulement la localisation de ceux-ci
+        list=[]
+        try:
+            sites_id = srv.GetSites(auth,{},["site_id","latitude","longitude"])
+        except :
+            return 3
+        try:
+            for i in data:
+                for j in sites_id:
+                    if i["site_id"]==j["site_id"]:
+                        try:
+                            pos=[{"latitude": j["latitude"], "longitude": j["longitude"]}]
+                        except:
+                            return 4
+                        i["ape_position"] = pos
+                        list.append(i)
+        except:
+            return 5    
+        return list
+        
+
+    
+    def make_data(self,timestamp):
+        try :
+            self.split()
+        except:
+            return 43
+        try :
+            if self.data_access_methode=="xmlrpc":
+                return self.get_event_list_from_xmlrpc(timestamp)
+        except: 
+            return 67
+