X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=plugins%2Fpres_view_map%2Fdaemon-todo%2Feventd.py;fp=plugins%2Fpres_view_map%2Fdaemon-todo%2Feventd.py;h=5f3de865d76d8796318a0825c039b9347c23c4c0;hb=a09c116497c4fce2e8e2290e7255a3ec946163be;hp=0000000000000000000000000000000000000000;hpb=96cf681a06ae76e67bb186e5bc02a696a9784c3d;p=unfold.git

diff --git a/plugins/pres_view_map/daemon-todo/eventd.py b/plugins/pres_view_map/daemon-todo/eventd.py
new file mode 100644
index 00000000..5f3de865
--- /dev/null
+++ b/plugins/pres_view_map/daemon-todo/eventd.py
@@ -0,0 +1,69 @@
+#!/usr/bin/env python
+
+import sys, time
+from daemon import Daemon
+from event2 import Event2
+import cgi
+import urllib2
+import simplejson
+
+class MyDaemon(Daemon):    
+    def run(self):
+        self.server = 'http://0.ape.planet-lab.eu:443/?'
+        self.ape_pwd = 'testpasswd'
+        self.ape_cmd = 'inlinepush'
+        ## Ouverture et traitement du fichier de conf
+        #ouverture du fichier
+        config = open("config_method_dynamic", "r")
+        events=[]
+        #initialisation de la liste des instance d'objet event:
+        for ligne in config:
+            #on creer l'objet
+            event = Event2(ligne.rstrip('\n\r'))
+            
+            events.append(event)
+        config.close()
+        ## creation des objets et ajout dans une liste
+        timestamp=time.time()-800000
+        #timestamp_new=time.time()
+        while True:
+            for event in events:
+                event.data = event.make_data(timestamp);
+                cmd = [{"cmd": self.ape_cmd,
+                        "params": {
+                           "password": self.ape_pwd,
+                           "raw": event.raw,
+                           "channel": event.channel,
+                           "data": {
+                                "print_options": event.print_options,
+                                "print_method": event.print_method,
+                                "message": event.data
+                           }
+                       }
+                }]
+                print cmd
+                url = self.server + urllib2.quote(simplejson.dumps(cmd))
+                urllib2.urlopen(url)
+            ##pour chaque objet de la liste on regarde les data 
+            ## => il faut instancier un tableau de temps
+            ## on instancie un temps en debut de boucle ex temps=time.now()
+            time.sleep(15)
+            #timestamp=timestamp_new
+            #timestamp_new=time.time()
+
+if __name__ == "__main__":
+    daemon = MyDaemon('/tmp/daemon-example.pid')
+    if len(sys.argv) == 2:
+        if 'start' == sys.argv[1]:
+            daemon.start()
+        elif 'stop' == sys.argv[1]:
+            daemon.stop()
+        elif 'restart' == sys.argv[1]:
+            daemon.restart()
+        else:
+            print "Unknown command"
+            sys.exit(2)
+        sys.exit(0)
+    else:
+        print "usage: %s start|stop|restart" % sys.argv[0]
+        sys.exit(2)