3 # This testcase simply checks that the DHT command-line tools work.
4 # It launches a single peer, stores a value "testdata" under "testkey",
5 # and then gives the system 50 ms to fetch it.
8 # - command line tool interfaces fail
9 # - DHT plugins for storage are not installed / working
10 # - block plugins for verification (the test plugin) is not installed
12 # The code does NOT depend on DHT routing or any actual P2P functionality.
14 from __future__ import print_function
15 from __future__ import absolute_import
24 os.environ["PATH"] = "@bindir@" + ":" + os.environ["PATH"]
27 tmp = os.getenv("TEMP")
32 get = './gnunet-dht-get.exe'
33 put = './gnunet-dht-put.exe'
34 arm = 'gnunet-arm.exe'
36 get = './gnunet-dht-get'
37 put = './gnunet-dht-put'
40 cfgfile = 'test_dht_api_peer1.conf'
41 run_get = [get, '-c', cfgfile]
42 run_put = [put, '-c', cfgfile]
43 run_arm = [arm, '-c', cfgfile]
44 debug = os.getenv('DEBUG')
46 run_arm += [debug.split(' ')]
49 def cleanup(exitcode):
53 def sub_run(args, want_stdo=True, want_stde=False, nofail=False):
55 stdo = subprocess.PIPE
59 stde = subprocess.PIPE
62 p = subprocess.Popen(args, stdout=stdo, stderr=stde)
63 stdo, stde = p.communicate()
66 sys.exit(p.returncode)
67 return (p.returncode, stdo, stde)
72 r_arm(['-e'], want_stdo=False)
76 def r_something(to_run, extra_args, failer=None, normal=True, **kw):
77 rc, stdo, stde = sub_run(to_run + extra_args, nofail=True, **kw)
78 if failer is not None:
79 failer(to_run + extra_args, rc, stdo, stde, normal)
80 return (rc, stdo, stde)
83 def r_arm(extra_args, **kw):
84 return r_something(run_arm, extra_args, **kw)
87 def r_get(extra_args, **kw):
88 return r_something(run_get, extra_args, **kw)
91 def r_put(extra_args, **kw):
92 return r_something(run_put, extra_args, **kw)
95 def end_arm_failer(command, rc, stdo, stde, normal):
98 fail("FAIL: error running {}\nCommand output was:\n{}\n{}".format(command, stdo, stde))
101 fail("FAIL: expected error while running {}\nCommand output was:\n{}\n{}".format(command, stdo, stde))
104 def print_only_failer(command, rc, stdo, stde, normal):
107 print("FAIL: error running {}\nCommand output was:\n{}\n{}".format(command, stdo, stde))
111 print("FAIL: expected error while running {}\nCommand output was:\n{}\n{}".format(command, stdo, stde))
115 print("TEST: Starting ARM...", end='')
116 r_arm(['-s'], failer=end_arm_failer, want_stdo=False, want_stde=False)
120 print("TEST: Testing put...", end='')
121 r_put(['-k', 'testkey', '-d', 'testdata', '-t', '8'], failer=end_arm_failer)
125 print("TEST: Testing get...", end='')
126 rc, stdo, stde = r_get(['-k', 'testkey', '-T', '50 ms', '-t', '8'], want_stdo=True, failer=end_arm_failer)
127 stdo = stdo.replace('\r', '').splitlines()
128 expect = "Result 0, type 8:\ntestdata".splitlines()
129 if len(stdo) != 2 or len(expect) != 2 or stdo[0] != expect[0] or stdo[1] != expect[1]:
130 fail("output `{}' differs from expected `{}'".format(stdo, expect))
133 r_arm(['-e', '-d'], failer=print_only_failer)