First commit of lavapdu code
diff --git a/pdurunner.py b/pdurunner.py
new file mode 100644
index 0000000..28a9d6e
--- /dev/null
+++ b/pdurunner.py
@@ -0,0 +1,45 @@
+import sqlite3
+import time
+from engine import PDUEngine
+
+
+conn = sqlite3.connect('pdu.db', check_same_thread = False)
+c = conn.cursor()
+
+class PDURunner():
+ def get_one(self):
+ c.execute("SELECT * FROM pdu_queue ORDER BY id asc limit 1")
+ res = c.fetchone()
+ if res:
+ id,hostname,port,request = res
+ print(id, hostname, request, port)
+ res = self.do_job(hostname,port,request)
+ self.delete_row(id)
+
+ def delete_row(self, id):
+ print("deleting row %i" % id)
+ c.execute("delete from pdu_queue where id=%i" % id)
+ conn.commit()
+
+ def do_job(self, hostname, port, request):
+ pe = PDUEngine(hostname, 23)
+ if request == "reboot":
+ pe.driver.port_reboot(port)
+ elif request == "on":
+ pe.driver.port_on(port)
+ elif request == "off":
+ pe.driver.port_off(port)
+ elif request == "delayed":
+ pe.driver.port_delayed(port)
+ else:
+ print("Unknown request type: %s" % request)
+
+ def run_me(self):
+ print("Starting up the PDURunner")
+ while 1:
+ self.get_one()
+ time.sleep(1)
+
+if __name__ == "__main__":
+ p = PDURunner()
+ p.run_me()
\ No newline at end of file