Try to find what's happening with broadcasts from unknown addresses

This commit is contained in:
Dmitri Bogomolov 2021-09-02 17:29:59 +03:00
parent bb9065ee07
commit 850ec7e478
Signed by untrusted user: g1itch
GPG Key ID: 720A756F18DEED13

View File

@ -28,7 +28,7 @@ from network.bmproto import BMProto
from network.connectionpool import BMConnectionPool
from network.node import Node, Peer
from network.tcp import Socks4aBMConnection, Socks5BMConnection, TCPConnection
from queues import excQueue
from queues import excQueue, workerQueue
from version import softwareVersion
from common import cleanup
@ -351,6 +351,18 @@ class TestCore(unittest.TestCase):
streams = decoded[7:]
self.assertEqual(streams, [1, 2, 3])
def test_worker_exceptions(self):
"""try to provoke an exception in singleWorker"""
for _ in range(5):
helper_sent.insert(
fromAddress='BM-2cXrFSw75fT5FP7qWbM86jpMTSGFBD7uLU',
subject='test subject',
message='test message',
status='broadcastqueued'
)
workerQueue.put(('sendbroadcast', ''))
time.sleep(5)
def test_insert_method_msgid(self):
"""Test insert method of helper_sent module with message sending"""
fromAddress = 'BM-2cTrmD22fLRrumi3pPLg1ELJ6PdAaTRTdfg'