From: Razvan Deaconescu <razvan.deaconescu@cs.pub.ro>
Date: Fri, 19 Aug 2011 18:35:27 +0000 (+0300)
Subject: ppf: Add datetime insert functions in access.py.
X-Git-Url: http://p2p-next.cs.pub.ro/gitweb/?a=commitdiff_plain;h=14f53122461470d676b5d4aa6acb92b5246b0484;p=cs-p2p-next.git

ppf: Add datetime insert functions in access.py.
---

diff --git a/ppf/db/access.py b/ppf/db/access.py
index 642a975..06f7118 100644
--- a/ppf/db/access.py
+++ b/ppf/db/access.py
@@ -2,6 +2,7 @@ import sys
 import sqlite3
 import os.path
 import logging
+import julian
 
 #
 # Logging code heavily inspired by Logging HOWTO documentation:
@@ -289,6 +290,22 @@ class SQLiteDatabaseAccess(DatabaseAccess):
             logger.error("An exception was raised: %s" %e.args[0])
             raise DatabaseError(e.args[0])
 
+    def insert_client_sessions_date_time(self, swarm_id, client_id, system_os,
+            system_os_version, system_ram, system_cpu, public_ip,
+            public_port, ds_limit, us_limit, date, time):
+        jd = float(julian.stringToJulian(date, time))
+        self.insert_client_sessions(swarm_id, client_id,
+                system_os, system_os_version, system_ram, system_cpu,
+                public_ip, public_port, ds_limit, us_limit, jd)
+
+    def insert_client_sessions_datetime(self, swarm_id, client_id, system_os,
+            system_os_version, system_ram, system_cpu, public_ip,
+            public_port, ds_limit, us_limit, dt):
+        jd = float(julian.datetimeToJulian(dt))
+        self.insert_client_sessions(swarm_id, client_id,
+                system_os, system_os_version, system_ram, system_cpu,
+                public_ip, public_port, ds_limit, us_limit, jd)
+
     def select_client_sessions_by_id(self, show=False, cs_id=None):
         try:
             if cs_id == None:
@@ -388,6 +405,22 @@ class SQLiteDatabaseAccess(DatabaseAccess):
             logger.error("An exception was raised: %s" %e.args[0])
             raise DatabaseError(e.args[0])
 
+    def insert_status_messages_date_time(self, cs_id, date, time,
+            peer_num, dht, download_speed, upload_speed, download_size,
+            upload_size, eta_seconds):
+        timestamp = float(julian.stringToJulian(date, time))
+        self.insert_status_messages(cs_id, timestamp, peer_num,
+                dht, download_speed, upload_speed, download_size,
+                upload_size, eta_seconds)
+
+    def insert_status_messages_datetime(self, cs_id, dt, peer_num,
+            dht, download_speed, upload_speed, download_size,
+            upload_size, eta_seconds):
+        timestamp = float(julian.datetimeToJulian(dt))
+        self.insert_status_messages(cs_id, timestamp, peer_num,
+                dht, download_speed, upload_speed, download_size,
+                upload_size, eta_seconds)
+
     def select_status_messages(self, show=False, cs_id=None,
             restrictArray=None):
         try:
@@ -440,6 +473,22 @@ class SQLiteDatabaseAccess(DatabaseAccess):
             logger.error("An exception was raised: %s" %e.args[0])
             raise DatabaseError(e.args[0])
 
+    def insert_verbose_messages_date_time(self, cs_id, date, time,
+            direction, peer_ip, peer_port, message_type, index,
+            begin, length, listen_port):
+        timestamp = float(julian.stringToJulian(date, time))
+        self.insert_verbose_messages(cs_id, timestamp, direction,
+                peer_ip, peer_port, message_type, index, begin,
+                length, listen_port)
+
+    def insert_verbose_messages_datetime(self, cs_id, dt, direction,
+            peer_ip, peer_port, message_type, index, begin,
+            length, listen_port):
+        timestamp = float(julian.datetimeToJulian(dt))
+        self.insert_verbose_messages(cs_id, timestamp, direction,
+                peer_ip, peer_port, message_type, index, begin,
+                length, listen_port)
+
     def select_verbose_messages(self, show=False, cs_id=None,
             restrictArray=None):
         try: