GoldenPogacsa/producer
GoldenPogacsa/producer
Archived
7
0
Fork 0
Code Issues Pull Requests Releases Activity

Mock redis is tests
Some checks failed
continuous-integration/drone/push Build is failing
Details

Browse Source
This commit is contained in:
Scharnitzky Donát 2020-04-17 18:57:46 +02:00
parent 2a95eb392a
commit e65d48b334
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
test.py
View File

@ -9,7 +9,7 @@ import consumerlocator
import communicator
import messagesender
import redisconnector
from pytest_redis import factories
__author__ = "@tormakris"
__copyright__ = "Copyright 2020, GoldenPogácsa Team"
@ -17,7 +17,7 @@ __module_name__ = "test"
__version__text__ = "1"
generateduuid = 'c959ad81-58f9-4445-aab4-8f3d68aee1ad'
redis_db = factories.redisdb(port=6379)
def test_generate_string(mocker):
"""
@ -178,11 +178,12 @@ def test_setcurrentconsumer():
assert comm.currenctconsumer == "10.69.42.1"
def test_learnconsumerlist(httpserver):
def test_learnconsumerlist(httpserver, redis_db):
"""
Tests :func:`consumerlocator.ConsumerLocator.learnconsumerlist`
:param httpserver: simple HTTP server
:param redis_db: mock redis
:return: None
"""
httpserver.expect_request(
@ -203,11 +204,12 @@ def test_learnconsumerlist(httpserver):
assert ret is None
def test_getcurrentconsumer(mocker):
def test_getcurrentconsumer(mocker, redis_db):
"""
Tests :func:`consumerlocator.ConsumerLocator.getcurrentconsumer`
:param mocker: patches the :class:`communicator.Communicator`.
:param redis_db: mock redis
:return: None
"""
mocker.patch('communicator.Communicator')
@ -220,11 +222,12 @@ def test_getcurrentconsumer(mocker):
assert locator.getcurrentconsumer() == consumerlocator.KNOWNCONSUMER
def test_checkcurrentconsumer(httpserver):
def test_checkcurrentconsumer(httpserver, redis_db):
"""
Tests :func:`consumerlocator.ConsumerLocator.checkcurrentconsumer`
:param httpserver: simple HTTP server
:param redis_db: mock redis
:return: None
"""
httpserver.expect_oneshot_request(
@ -245,11 +248,12 @@ def test_checkcurrentconsumer(httpserver):
assert ret == True
def test_updateconsumer(httpserver):
def test_updateconsumer(httpserver, redis_db):
"""
Tests :func:`consumerlocator.ConsumerLocator.updateconsumer`
:param httpserver: simple HTTP server
:param redis_db: mock redis
:return: None
"""
httpserver.expect_oneshot_request(
@ -271,11 +275,12 @@ def test_updateconsumer(httpserver):
assert ret == f"127.0.0.1:{port}"
def test_updateconsumerlist(httpserver):
def test_updateconsumerlist(httpserver, redis_db):
"""
Tests :func:`consumerlocator.ConsumerLocator.updateconsumerlist`
:param httpserver: simple HTTP server
:param redis_db: mock redis
:return: None
"""
httpserver.expect_oneshot_request(