Compare commits
No commits in common. "c5a3fb2d04db02fd427d24c04601d6960aa3e168" and "58c4e296ea2929de1b338a538c0e0f4b7cb36ad4" have entirely different histories.
c5a3fb2d04
...
58c4e296ea
@ -15,11 +15,9 @@ steps:
|
||||
|
||||
- name: unit_test
|
||||
image: python:3.8
|
||||
environment:
|
||||
PRODUCER_REDIS: cache
|
||||
commands:
|
||||
- pip3 install -r requirements.txt
|
||||
- pytest test.py
|
||||
- echo -e 'pytest test.py'
|
||||
|
||||
- name: build-app
|
||||
image: banzaicloud/drone-kaniko
|
||||
@ -77,8 +75,6 @@ services:
|
||||
volumes:
|
||||
- name: dockersock
|
||||
path: /var/run
|
||||
- name: cache
|
||||
image: redis
|
||||
|
||||
volumes:
|
||||
- name: dockersock
|
||||
|
@ -16,7 +16,6 @@ __version__text__ = "1"
|
||||
logging.basicConfig(level=logging.INFO)
|
||||
LOGGER = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class Communicator:
|
||||
"""
|
||||
Class handling low level communication with consumers.
|
||||
|
@ -18,7 +18,6 @@ __version__text__ = "1"
|
||||
KNOWNCONSUMER = os.getenv("PRODUCER_KNOWNCONSUMER", '10.69.42.1')
|
||||
LOGGER = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class ConsumerLocator:
|
||||
|
||||
"""
|
||||
|
8
test.py
8
test.py
@ -17,8 +17,8 @@ __module_name__ = "test"
|
||||
__version__text__ = "1"
|
||||
|
||||
generateduuid = 'c959ad81-58f9-4445-aab4-8f3d68aee1ad'
|
||||
redis_proc = factories.redis_proc(host='cache', port=6379)
|
||||
redis_db = factories.redisdb('redis_nooproc')
|
||||
redis_proc = factories.redis_proc(port=6379)
|
||||
redis_db = factories.redisdb('redis_db')
|
||||
|
||||
|
||||
def test_generate_string(mocker):
|
||||
@ -31,7 +31,7 @@ def test_generate_string(mocker):
|
||||
comm = communicator.Communicator(
|
||||
currentconsumer="localhost",
|
||||
uuid=generateduuid)
|
||||
mess = messagesender.MessageSender(communicator=comm, uuid=generateduuid)
|
||||
mess = messagesender.MessageSender(communicator=comm, uuid=generateduuid)
|
||||
msg = mess.randomstring(stringlength=32)
|
||||
assert isinstance(msg, str)
|
||||
assert len(msg) == 32
|
||||
@ -71,7 +71,7 @@ def test_send_message(mocker):
|
||||
comm = communicator.Communicator(
|
||||
currentconsumer="127.0.0.1",
|
||||
uuid=generateduuid)
|
||||
mess = messagesender.MessageSender(communicator=comm, uuid=generateduuid)
|
||||
mess = messagesender.MessageSender(communicator=comm, uuid=generateduuid)
|
||||
messa = "SENDING"
|
||||
msg = mess.sendmessage(message=messa)
|
||||
assert msg is None
|
||||
|
Reference in New Issue
Block a user