2222
2323import sys
2424import subprocess
25+ import time
2526import unittest
2627
2728from base import IntegrationTestsBase , test_backends
@@ -110,6 +111,7 @@ def test_tunnel_wireguard(self):
110111 keepalive: 21
111112''' % {'r' : self .backend , 'ec' : self .dev_e_client , 'e2c' : self .dev_e2_client })
112113 self .generate_and_settle ()
114+ time .sleep (2 ) # Give some time for handshake/connection between client & server
113115 # Verify server
114116 out = subprocess .check_output (['wg' , 'show' , 'wg0' , 'private-key' ], universal_newlines = True )
115117 self .assertIn ("4GgaQCy68nzNsUE5aJ9fuLzHhB65tAlwbmA72MWnOm8=" , out )
@@ -121,7 +123,7 @@ def test_tunnel_wireguard(self):
121123 self .assertIn ("fwmark: 0x2a" , out )
122124 self .assertIn ("peer: M9nt4YujIOmNrRmpIRTmYSfMdrpvE7u6WkG8FY8WjG4=" , out )
123125 self .assertIn ("allowed ips: 20.20.20.0/24" , out )
124- self .assertRegex (out , r'latest handshake: \d+ seconds ago' )
126+ self .assertRegex (out , r'latest handshake: \d+ seconds? ago' )
125127 self .assertRegex (out , r'transfer: \d+ B received, \d+ B sent' )
126128 self .assert_iface ('wg0' , ['inet 10.10.10.20/24' ])
127129 # Verify client
@@ -135,7 +137,7 @@ def test_tunnel_wireguard(self):
135137 self .assertIn ("endpoint: 10.10.10.20:51820" , out )
136138 self .assertIn ("allowed ips: 0.0.0.0/0" , out )
137139 self .assertIn ("persistent keepalive: every 21 seconds" , out )
138- self .assertRegex (out , r'latest handshake: \d+ seconds ago' )
140+ self .assertRegex (out , r'latest handshake: \d+ seconds? ago' )
139141 self .assertRegex (out , r'transfer: \d+ B received, \d+ B sent' )
140142 self .assert_iface ('wg1' , ['inet 20.20.20.10/24' ])
141143
0 commit comments