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
23 os.environ["PATH"] = "@bindir@" + ":" + os.environ["PATH"];
26 tmp = os.getenv ("TEMP")
31 get = './gnunet-dht-get.exe'
32 put = './gnunet-dht-put.exe'
33 arm = 'gnunet-arm.exe'
35 get = './gnunet-dht-get'
36 put = './gnunet-dht-put'
39 tf, tempcfg = tempfile.mkstemp (prefix='test_dht_api_peer1.')
42 run_get = [get, '-c', tempcfg]
43 run_put = [put, '-c', tempcfg]
44 run_arm = [arm, '-c', tempcfg]
45 debug = os.getenv ('DEBUG')
47 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)
71 r_arm (['-e'], want_stdo = False)
74 def r_something (to_run, extra_args, failer = None, normal = True, **kw):
75 rc, stdo, stde = sub_run (to_run + extra_args, nofail = True, **kw)
76 if failer is not None:
77 failer (to_run + extra_args, rc, stdo, stde, normal)
78 return (rc, stdo, stde)
80 def r_arm (extra_args, **kw):
81 return r_something (run_arm, extra_args, **kw)
83 def r_get (extra_args, **kw):
84 return r_something (run_get, extra_args, **kw)
86 def r_put (extra_args, **kw):
87 return r_something (run_put, extra_args, **kw)
89 def end_arm_failer (command, rc, stdo, stde, normal):
92 fail ("FAIL: error running {}\nCommand output was:\n{}\n{}".format (command, stdo, stde))
95 fail ("FAIL: expected error while running {}\nCommand output was:\n{}\n{}".format (command, stdo, stde))
97 def print_only_failer (command, rc, stdo, stde, normal):
100 print ("FAIL: error running {}\nCommand output was:\n{}\n{}".format (command, stdo, stde))
104 print ("FAIL: expected error while running {}\nCommand output was:\n{}\n{}".format (command, stdo, stde))
107 shutil.copyfile ('test_dht_api_peer1.conf', tempcfg)
109 print ("TEST: Starting ARM...", end='')
110 r_arm (['-s'], failer = end_arm_failer, want_stdo = False, want_stde = False)
114 print ("TEST: Testing put...", end='')
115 r_put (['-k', 'testkey', '-d', 'testdata', '-t', '8'], failer = end_arm_failer)
119 print ("TEST: Testing get...", end='')
120 rc, stdo, stde = r_get (['-k', 'testkey', '-T', '50 ms', '-t', '8'], want_stdo = True, failer = end_arm_failer)
121 stdo = stdo.replace ('\r', '').splitlines ()
122 expect = "Result 0, type 8:\ntestdata".splitlines()
123 if len (stdo) != 2 or len (expect) != 2 or stdo[0] != expect[0] or stdo[1] != expect[1]:
124 fail ("output `{}' differs from expected `{}'".format (stdo, expect))
127 r_arm (['-e', '-d'], failer = print_only_failer)