diff options
author | drebs <drebs@riseup.net> | 2017-11-02 09:28:56 -0200 |
---|---|---|
committer | drebs <drebs@riseup.net> | 2017-11-02 09:28:56 -0200 |
commit | b36ebc87f449af5ad7a677350a3ccfc7d26cfb1e (patch) | |
tree | 6dd6e7a15ace7f7e15815546f43d333f74101050 /scripts/soledad_sync.py | |
parent | 01e2a72ce30f0fbb4a027d3246a8ba16e00ae197 (diff) |
move client responsiveness tests to a subfolder
Diffstat (limited to 'scripts/soledad_sync.py')
-rw-r--r-- | scripts/soledad_sync.py | 96 |
1 files changed, 0 insertions, 96 deletions
diff --git a/scripts/soledad_sync.py b/scripts/soledad_sync.py deleted file mode 100644 index 8c6442f..0000000 --- a/scripts/soledad_sync.py +++ /dev/null @@ -1,96 +0,0 @@ -import os -import json -from ConfigParser import ConfigParser -from leap.soledad.client.api import Soledad -from twisted.internet import defer, reactor -from twisted.internet.task import deferLater - - -# get configs from file -parser = ConfigParser() -parser.read('defaults.conf') - -HOST = parser.get('server', 'host') - -UUID = parser.get('client', 'uuid') -CLIENT_BASEDIR = parser.get('client', 'basedir') -PASSPHRASE = parser.get('client', 'passphrase') - -NUM_DOCS = int(parser.get('sync', 'num_docs')) -PAYLOAD = parser.get('sync', 'payload') -AUTH_TOKEN = parser.get('sync', 'auth_token') - -STATS_FILE = parser.get('test', 'stats_file') - - -DO_THESEUS = os.environ.get('THESEUS', False) - - -def _get_soledad_instance_from_uuid(uuid, passphrase, basedir, server_url, - cert_file, token): - secrets_path = os.path.join(basedir, '%s.secret' % uuid) - local_db_path = os.path.join(basedir, '%s.db' % uuid) - return Soledad( - uuid, - unicode(passphrase), - secrets_path=secrets_path, - local_db_path=local_db_path, - server_url=server_url, - cert_file=cert_file, - auth_token=token, - defer_encryption=True, - syncable=True) - - -def _get_soledad_instance(): - return _get_soledad_instance_from_uuid( - UUID, PASSPHRASE, CLIENT_BASEDIR, HOST, '', AUTH_TOKEN) - -s = _get_soledad_instance() - - -def create_docs(): - global s - # get content for docs - payload = 'a' * 10 - if os.path.isfile(PAYLOAD): - with open(PAYLOAD, 'r') as f: - payload = f.read() - - # create docs - cd = [] - for i in range(NUM_DOCS): - cd.append(s.create_doc({'payload': payload})) - d = defer.gatherResults(cd) - - d.addCallback(lambda _: s.get_all_docs()) - d.addCallback(lambda result: "%d docs created, %d docs on db" % (NUM_DOCS, result[0])) - #d.addCallback(lambda _: s.close()) - - return d - - -def start_sync(): - global s - - if DO_THESEUS: - from theseus import Tracer - t = Tracer() - t.install() - - def stop_tracing(_): - if DO_THESEUS: - with open('callgrind.theseus', 'wb') as outfile: - t.write_data(outfile) - print "STOPPED TRACING, DUMPED IN CALLGRIND.THESEUS<<<<" - - cd = [] - - d = s.sync() - d.addCallback(stop_tracing) - - return d - -def stats(): - global s - return s.sync_stats() |