X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=plugins%2Fpres_view%2Fpres_view_map%2Fdaemon-todo%2Fevent2.py;fp=plugins%2Fpres_view%2Fpres_view_map%2Fdaemon-todo%2Fevent2.py;h=0000000000000000000000000000000000000000;hb=9c3ecdab818e1792e6d781df95098b30543ff69f;hp=8913bbefeda797df1255120d0152bccaf51123f7;hpb=ce6c1a9a8a96bedd463e6aa3384f588cd2d6d456;p=myslice.git diff --git a/plugins/pres_view/pres_view_map/daemon-todo/event2.py b/plugins/pres_view/pres_view_map/daemon-todo/event2.py deleted file mode 100644 index 8913bbef..00000000 --- a/plugins/pres_view/pres_view_map/daemon-todo/event2.py +++ /dev/null @@ -1,129 +0,0 @@ -# !/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 -