def insert_swarms(self, torrent_file, filesize, purpose, source):
self.insert_swarms_row([torrent_file, filesize, purpose, source])
- def select_swarms(self, show=True, swarm_id=-1):
+ def select_swarms(self, show=False, swarm_id=-1):
pass
def delete_swarms(self, swarm_id=-1):
def insert_btclients(self, client_name, language, dht, streaming):
self.insert_btclients_row([client_name, language, dht, streaming])
- def select_btclients(self, show=True, id=-1):
+ def select_btclients(self, show=False, id=-1):
pass
- def select_btclients_by_name(self, client_name, show=True):
+ def select_btclients_by_name(self, client_name, show=False):
pass
def select_btclients_id_by_name(self, client_name):
def insert_client_sessions(self, swarm_id, client_id, system_os, system_os_version, system_ram, system_cpu, public_ip, public_port, ds_limit, us_limit, start_time):
self.insert_client_sessions_row([swarm_id, client_id, system_os, system_os_version, system_ram, system_cpu, public_ip, public_port, ds_limit, us_limit, start_time]);
- def select_client_sessions_by_id(self, show=True, cs_id=-1):
+ def select_client_sessions_by_id(self, show=False, cs_id=-1):
pass
- def select_client_sessions_by_swarm(self, show=True, swarm_id=-1, client_id=None):
+ def select_client_sessions_by_swarm(self, show=False, swarm_id=-1, client_id=None):
pass
def delete_client_sessions_by_id(self, cs_id=-1):
def insert_status_messages(self, cs_id, timestamp, peer_num, dht, download_speed, upload_speed, download_size, upload_size, eta):
self.insert_status_messages_row([cs_id, timestamp, peer_num, dht, download_speed, upload_speed, download_size, upload_size, eta])
- def select_status_messages(self, show=True, cs_id=-1, restrictArray=None):
+ def select_status_messages(self, show=False, cs_id=-1, restrictArray=None):
pass
def delete_status_messages(self, cs_id=-1):
def insert_verbose_messages(self, cs_id, timestamp, direction, peer_ip, peer_port, message_type, _index, begin, length, listen_port):
self.insert_verbose_messages_row([cs_id, timestamp, direction, peer_ip, peer_port, message_type, _index, begin, length, listen_port])
- def select_verbose_messages(self, show=True, cs_id=-1, restrictArray=None):
+ def select_verbose_messages(self, show=False, cs_id=-1, restrictArray=None):
pass
def delete_verbose_messages(self, cs_id=-1):
except sqlite3.Error, e:
print ("[swarms]An error ocurred: ", e.args[0])
- def select_swarms(self, show=True, swarm_id=-1):
+ def select_swarms(self, show=False, swarm_id=-1):
try:
if swarm_id == -1:
self.cursor.execute("SELECT * FROM swarms")
except sqlite3.Error, e:
print ("[btclients]An error ocurred: ", e.args[0])
- def select_btclients(self, show=True, id=-1):
+ def select_btclients(self, show=False, id=-1):
try:
if id == -1:
self.cursor.execute("""SELECT * FROM btclients""")
except sqlite3.Error, e:
print ("[btclients]An error ocurred: ", e.args[0])
- def select_btclients_by_name(self, client_name, show=True):
+ def select_btclients_by_name(self, client_name, show=False):
try:
self.cursor.execute("""SELECT * FROM btclients WHERE name='%s'""" %client_name)
if show == True:
except sqlite3.Error, e:
print ("[client_sessions]An error ocurred: ", e.args[0])
- def select_client_sessions_by_id(self, show=True, cs_id=-1):
+ def select_client_sessions_by_id(self, show=False, cs_id=-1):
try:
if cs_id == -1:
self.cursor.execute("""SELECT * FROM client_sessions""")
except sqlite3.Error, e:
print ("[client_sessions]An error ocurred: ", e.args[0])
- def select_client_sessions_by_swarm(self, show=True, swarm_id=-1, client_id=None):
+ def select_client_sessions_by_swarm(self, show=False, swarm_id=-1, client_id=None):
try:
if client_id == None:
if swarm_id == -1:
except sqlite3.Error, e:
print ("[status_messages]An error ocurred: ", e.args[0])
- def select_status_messages(self, show=True, cs_id=-1, restrictArray=None):
+ def select_status_messages(self, show=False, cs_id=-1, restrictArray=None):
try:
if cs_id == -1:
self.cursor.execute("SELECT * FROM status_messages")
except sqlite3.Error, e:
print ("[verbose_messages]An error ocurred: ", e.args[0])
- def select_verbose_messages(self, show=True, cs_id=-1, restrictArray=None):
+ def select_verbose_messages(self, show=False, cs_id=-1, restrictArray=None):
try:
if cs_id == -1:
self.cursor.execute("SELECT * FROM verbose_messages")
"""
Select initial swarm entries. Check against expected_swarms_count.
"""
- self.dba.select_swarms(False)
+ self.dba.select_swarms()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_swarms_count)
"""
self.insert_test_swarms_row()
- self.dba.select_swarms(False)
+ self.dba.select_swarms()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_swarms_count)
"""
self.insert_test_swarms()
- self.dba.select_swarms(False)
+ self.dba.select_swarms()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_swarms_count)
# No rows should longer be present in swarms table.
self.expected_swarms_count = 0
- self.dba.select_swarms(False)
+ self.dba.select_swarms()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_swarms_count)
Select initial btclient entries.
Check against expected_btclients_count.
"""
- self.dba.select_btclients(False)
+ self.dba.select_btclients()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_btclients_count)
"""
Select btclients by name. Use "Tribler" name resulting in one entry.
"""
- self.dba.select_btclients_by_name("Tribler", False)
+ self.dba.select_btclients_by_name("Tribler")
self.expected_btclients_count = 1
num_rows = self.get_cursor_num_rows()
"""
self.insert_test_btclients_row()
- self.dba.select_btclients(False)
+ self.dba.select_btclients()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_btclients_count)
"""
self.insert_test_btclients()
- self.dba.select_btclients(False)
+ self.dba.select_btclients()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_btclients_count)
Select initial client_sessions entries.
Check against expected_sessions_count.
"""
- self.dba.select_client_sessions_by_id(False)
+ self.dba.select_client_sessions_by_id()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_sessions_count)
Select initial client_sessions entries.
Check against expected_sessions_count.
"""
- self.dba.select_client_sessions_by_swarm(False)
+ self.dba.select_client_sessions_by_swarm()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_sessions_count)
"""
self.insert_test_client_sessions_row()
- self.dba.select_client_sessions_by_id(False)
+ self.dba.select_client_sessions_by_id()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_sessions_count)
"""
self.insert_test_client_sessions()
- self.dba.select_client_sessions_by_id(False)
+ self.dba.select_client_sessions_by_id()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_sessions_count)
# Number of entries decreases by 1.
self.expected_sessions_count = self.expected_sessions_count - 1
- self.dba.select_client_sessions_by_id(False)
+ self.dba.select_client_sessions_by_id()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_sessions_count)
# Number of entries decreases by 2.
self.expected_sessions_count = self.expected_sessions_count - 2
- self.dba.select_client_sessions_by_id(False)
+ self.dba.select_client_sessions_by_id()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_sessions_count)
Select initial status messsage entries.
Check against expected_statmsg_count.
"""
- self.dba.select_status_messages(False)
+ self.dba.select_status_messages()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_statmsg_count)
"""
self.insert_test_status_messages_row()
- self.dba.select_status_messages(False)
+ self.dba.select_status_messages()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_statmsg_count)
"""
self.insert_test_status_messages()
- self.dba.select_status_messages(False)
+ self.dba.select_status_messages()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_statmsg_count)
self.dba.delete_status_messages()
self.expected_statmsg_count = 0
- self.dba.select_status_messages(False)
+ self.dba.select_status_messages()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_statmsg_count)
Select initial verbose messages entries.
Check against expected_verbmsg_count.
"""
- self.dba.select_verbose_messages(False)
+ self.dba.select_verbose_messages()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_verbmsg_count)
"""
self.insert_test_verbose_messages_row()
- self.dba.select_verbose_messages(False)
+ self.dba.select_verbose_messages()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_verbmsg_count)
"""
self.insert_test_verbose_messages()
- self.dba.select_verbose_messages(False)
+ self.dba.select_verbose_messages()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_verbmsg_count)
self.dba.delete_verbose_messages()
self.expected_verbmsg_count = 0
- self.dba.select_verbose_messages(False)
+ self.dba.select_verbose_messages()
num_rows = self.get_cursor_num_rows()
self.assertEqual(num_rows, self.expected_verbmsg_count)