Compare commits
No commits in common. "d106078dac4c869dbc9d3c329d014e571924c39c" and "97576f67505749c3f5e91fb2ca3e4ca447264292" have entirely different histories.
d106078dac
...
97576f6750
|
@ -1,16 +1,14 @@
|
||||||
"""Blind tests, starting the minode process"""
|
"""Blind tests, starting the minode process"""
|
||||||
import os
|
import unittest
|
||||||
import signal
|
import signal
|
||||||
import socket
|
import socket
|
||||||
import subprocess
|
import subprocess
|
||||||
import sys
|
import sys
|
||||||
import tempfile
|
import tempfile
|
||||||
import time
|
import time
|
||||||
import unittest
|
|
||||||
|
|
||||||
import psutil
|
import psutil
|
||||||
|
|
||||||
from minode.i2p import util
|
|
||||||
from minode.structure import NetAddrNoPrefix
|
from minode.structure import NetAddrNoPrefix
|
||||||
|
|
||||||
try:
|
try:
|
||||||
|
@ -140,39 +138,10 @@ class TestProcess(TestProcessProto):
|
||||||
class TestProcessI2P(TestProcess):
|
class TestProcessI2P(TestProcess):
|
||||||
"""Test minode process with --i2p and no IP"""
|
"""Test minode process with --i2p and no IP"""
|
||||||
_process_cmd = ['minode', '--i2p', '--no-ip']
|
_process_cmd = ['minode', '--i2p', '--no-ip']
|
||||||
|
_connection_limit = 4
|
||||||
_listen = True
|
_listen = True
|
||||||
_listening_port = 8448
|
_listening_port = 8448
|
||||||
|
|
||||||
@classmethod
|
|
||||||
def setUpClass(cls):
|
|
||||||
cls.freezed = False
|
|
||||||
cls.keyfile = os.path.join(cls.home, 'i2p_dest.pub')
|
|
||||||
saved = os.path.isfile(cls.keyfile)
|
|
||||||
super().setUpClass()
|
|
||||||
for _ in range(cls._wait_time):
|
|
||||||
if saved:
|
|
||||||
if cls.process.num_threads() > 3:
|
|
||||||
break
|
|
||||||
elif os.path.isfile(cls.keyfile):
|
|
||||||
break
|
|
||||||
time.sleep(1)
|
|
||||||
else:
|
|
||||||
cls.freezed = True
|
|
||||||
|
|
||||||
def setUp(self):
|
|
||||||
"""Skip any test if I2PController freezed"""
|
|
||||||
if self.freezed:
|
|
||||||
raise unittest.SkipTest(
|
|
||||||
'I2PController has probably failed to start')
|
|
||||||
|
|
||||||
def test_saved_keys(self):
|
|
||||||
"""Check saved i2p keys"""
|
|
||||||
with open(self.keyfile, 'br') as src:
|
|
||||||
i2p_dest_pub = src.read()
|
|
||||||
with open(os.path.join(self.home, 'i2p_dest_priv.key'), 'br') as src:
|
|
||||||
i2p_dest_priv = src.read()
|
|
||||||
self.assertEqual(util.pub_from_priv(i2p_dest_priv), i2p_dest_pub)
|
|
||||||
|
|
||||||
def test_connections(self):
|
def test_connections(self):
|
||||||
"""Ensure all connections are I2P"""
|
"""Ensure all connections are I2P"""
|
||||||
super().test_connections()
|
super().test_connections()
|
||||||
|
|
Loading…
Reference in New Issue
Block a user