Rename module

quintoandar_kafka/__init__.py

@@ -0,0 +1,2 @@
+from quintoandar_kafka.idempotence_client import IdempotenceClient  # noqa: F401,E501
+from quintoandar_kafka.kafka_consumer import KafkaConsumerClient  # noqa: F401,E501

clients/tests/steps/step_idempotent_client.py → quintoandar_kafka/tests/steps/step_idempotent_client.py

@@ -1,7 +1,7 @@
 from unittest.mock import MagicMock
 from behave import given, when, then  # pylint: disable=E0611
 from hamcrest import assert_that
-from clients import IdempotenceClient
+from quintoandar_kafka import IdempotenceClient
 
 
 message = MagicMock()

clients/tests/steps/step_kafka_consumer.py → quintoandar_kafka/tests/steps/step_kafka_consumer.py

@@ -1,15 +1,15 @@
 from unittest.mock import MagicMock, patch
 from behave import given, when, then  # pylint: disable=E0611
 from hamcrest import assert_that, equal_to
-from clients import KafkaConsumerClient
+from quintoandar_kafka import KafkaConsumerClient
 
 message = MagicMock()
 message.value = {'test1': 'test2'}
 message.topic = 'test3'
 
 
 @given('A default KafkaConsumerClient is instanciated')
-@patch('clients.kafka_consumer.KafkaConsumer')
+@patch('quintoandar_kafka.kafka_consumer.KafkaConsumer')
 def step_impl_given_default_KafkaConsumer_instance(context, kafkaConsumerMock):
     context.processor = MagicMock()
     context.group_id = 'test1'
@@ -23,7 +23,7 @@ def step_impl_given_default_KafkaConsumer_instance(context, kafkaConsumerMock):
 
 
 @given('KafkaConsumerClient with custom deserializer and idempotenceClinet')
-@patch('clients.kafka_consumer.KafkaConsumer')
+@patch('quintoandar_kafka.kafka_consumer.KafkaConsumer')
 def step_impl_given_custom_KafkaConsumer_instance(context, kafkaConsumerMock):
     context.processor = MagicMock()
     context.group_id = 'test1'

setup.py

@@ -5,10 +5,10 @@
 if sys.version_info < (3, 2):
     raise Exception('Only Python 3.2+ is supported')
 
-setup(name='idempotence_client',
-      version='0.0.1',
+setup(name='quintoandar_kafka',
+      version='0.2.0',
       description="Checks messages to avoid reprocessing events.",
-      url='https://github.com/quintoandar/python-kafka-idempotence-client',
+      url='https://github.com/quintoandar/python-kafka',
       packages=find_packages(exclude=['ez_setup', 'examples',
                                       'tests', 'release']),
       include_package_data=True,

unit_tests.py

@@ -20,7 +20,7 @@
 print("------------------ TESTS ----------------")
 print("-----------------------------------------")
 print()
-result = behave_main("clients/tests")
+result = behave_main("quintoandar_kafka/tests")
 cov.stop()
 print()
 print("-----------------------------------------")