Merge pull request #124 from Clariteia/0.0.1

0.0.1

.github/workflows/python-tests.yml

@@ -2,46 +2,71 @@ on: push
 
 jobs:
   build:
+
     runs-on: ubuntu-latest
-    strategy:
-      matrix:
-        python-version: [3.9]
-    container:
-        image: python:latest
+    container: python:3.9-buster
+
+
     services:
-        zookeeper:
-            image: bitnami/zookeeper:latest
-            ports:
-                - "2181:2181"
-        kafka:
-            image: bitnami/kafka:latest
-            ports:
-                - "9092:9092"
-            env:
-                KAFKA_BROKER_ID: 1
-                KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
-                KAFKA_ADVERTISED_HOST_NAME: localhost
+      postgres:
+        image: postgres
+        env:
+          POSTGRES_USER: minos
+          POSTGRES_PASSWORD: min0s
+        ports:
+          - 5432:5432
+        options: --health-cmd pg_isready --health-interval 10s --health-timeout 5s --health-retries 5
+
+      zookeeper:
+          image: wurstmeister/zookeeper:latest
+          ports:
+              - 2181:2181
+
+      kafka:
+          image: wurstmeister/kafka:latest
+          ports:
+              - 9092:9092
+          env:
+              KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
+              KAFKA_ADVERTISED_HOST_NAME: kafka
+    env:
+      MINOS_EVENTS_QUEUE_HOST: postgres
+      MINOS_EVENTS_BROKER: kafka
+      MINOS_COMMANDS_QUEUE_HOST: postgres
+      MINOS_COMMANDS_BROKER: kafka
+      MINOS_REPOSITORY_HOST: postgres
+      MINOS_SNAPSHOT_HOST: postgres
+
     steps:
-    - uses: actions/checkout@v2
-    - name: Set up Python ${{ matrix.python-version }}
-      uses: actions/setup-python@v2
-      with:
-        python-version: ${{ matrix.python-version }}
-    - name: Install dependencies
-      run: |
-          apt-get install -y libc6 build-essential
+      - name: Check out repository code
+        uses: actions/checkout@v2
+
+      - name: Install dependencies
+        run: |
           python -m pip install --upgrade pip
           if [ -f requirements_dev.txt ]; then pip install -r requirements_dev.txt; fi
           python setup.py install
-    - name: Test with pytest
-      run: |
+
+      - name: Install Postgresql client
+        run: |
+          apt-get update
+          apt-get install --yes postgresql-client
+
+      - name: Create database
+        run: |
+          PGPASSWORD=min0s psql -U minos -h postgres -tc "CREATE DATABASE order_db OWNER minos;"
+
+      - name: Test with pytest
+        run: |
           make test
-    -   name: Generate coverage report
+
+      - name: Generate coverage report
         run: |
             make coverage
-    -   name: Codecov
+
+      - name: Codecov
         uses: codecov/codecov-action@v1.3.1
         with:
-            token: ${{ secrets.CODECOV_TOKEN }}
-            files: ./coverage.xml
-            fail_ci_if_error: true
+          token: ${{ secrets.CODECOV_TOKEN }}
+          files: ./coverage.xml
+          fail_ci_if_error: true

.gitignore

@@ -102,4 +102,7 @@ ENV/
 .mypy_cache/
 
 # IDE settings
-.vscode/
+.vscode/
+
+# Intellij IDEa / PyCharm / etc.
+.idea

.restyled.yaml

@@ -0,0 +1,28 @@
+---
+enabled: true
+exclude:
+  - "**/*.md"
+  - ".idea/**/*"
+  - "docs/**/*"
+  - "**/*.in"
+  - "Makefile"
+  - ".github/workflows/**/*"
+restylers:
+  - name: black
+    image: restyled/restyler-black:v19.10b0
+    command:
+      - black
+    arguments: ["--line-length", "120"]
+    include:
+      - "**/*.py"
+    interpreters:
+      - python
+  - name: isort
+    image: restyled/restyler-isort:v4.3.21
+    command:
+      - isort
+    arguments: []
+    include:
+      - "**/*.py"
+    interpreters:
+      - python

AUTHORS.rst → AUTHORS.md

@@ -1,4 +1,3 @@
-=======
 Credits
 =======
 
@@ -10,4 +9,5 @@ Development Lead
 Contributors
 ------------
 
-None yet. Why not be the first?
+* Sergio Garcia Prado <sergio.garcia@clariteia.com>
+* Vladyslav Fenchak <vladyslav.fenchak@clariteia.com>`

HISTORY.md

@@ -0,0 +1,14 @@
+History
+=======
+
+0.0.1 (2021-05-12)
+------------------
+
+* Added Event Handler
+* Added Command Handler
+* Added Event Recurring Service
+* Added Command Recurring Service
+* Added Event Broker with Recurrent Service
+* Added Command Broker with Recurrent Service
+* Added REST Service with Health handler
+

Makefile

@@ -59,8 +59,8 @@ test-all: ## run tests on every Python version with tox
 coverage: ## check code coverage quickly with the default Python
 	coverage run --source minos -m pytest
 	coverage report -m
-	coverage html
-	$(BROWSER) htmlcov/index.html
+	coverage xml
+	## $(BROWSER) htmlcov/index.html
 
 docs: ## generate Sphinx HTML documentation, including API docs
 	rm -f docs/minos_microservice_networks.rst

README.md

@@ -0,0 +1,15 @@
+Minos Microservice Networks
+===========================
+
+[![codecov](https://codecov.io/gh/Clariteia/minos_microservice_networks/branch/main/graph/badge.svg)](https://codecov.io/gh/Clariteia/minos_microservice_networks)
+
+![Tests](https://github.com/Clariteia/minos_microservice_networks/actions/workflows/python-tests.yml/badge.svg)
+
+Python Package with the common network classes and utlities used in Minos Microservice
+
+
+Credits
+-------
+
+This package was created with ![Cookiecutter](https://github.com/audreyr/cookiecutter)
+and the ![Minos Package](https://github.com/Clariteia/minos-pypackage) project template.

minos/networks/__init__.py

@@ -1 +1,43 @@
-__version__ = '0.0.1.1-alpha'
+"""
+Copyright (C) 2021 Clariteia SL
+
+This file is part of minos framework.
+
+Minos framework can not be copied and/or distributed without the express permission of Clariteia SL.
+"""
+__version__ = "0.0.1"
+
+from .broker import (
+    MinosCommandBroker,
+    MinosEventBroker,
+    MinosQueueDispatcher,
+    MinosQueueService,
+)
+from .exceptions import (
+    MinosNetworkException,
+    MinosPreviousVersionSnapshotException,
+    MinosSnapshotException,
+)
+from .handler import (
+    MinosCommandHandlerDispatcher,
+    MinosCommandHandlerServer,
+    MinosCommandPeriodicService,
+    MinosCommandReplyHandlerDispatcher,
+    MinosCommandReplyHandlerServer,
+    MinosCommandReplyPeriodicService,
+    MinosCommandReplyServerService,
+    MinosCommandServerService,
+    MinosEventHandlerDispatcher,
+    MinosEventHandlerServer,
+    MinosEventPeriodicService,
+    MinosEventServerService,
+)
+from .rest_interface import (
+    REST,
+    RestInterfaceHandler,
+)
+from .snapshots import (
+    MinosSnapshotDispatcher,
+    MinosSnapshotEntry,
+    MinosSnapshotService,
+)

minos/networks/broker/__init__.py

@@ -0,0 +1,19 @@
+"""
+Copyright (C) 2021 Clariteia SL
+
+This file is part of minos framework.
+
+Minos framework can not be copied and/or distributed without the express permission of Clariteia SL.
+"""
+from .commands import (
+    MinosCommandBroker,
+)
+from .dispatchers import (
+    MinosQueueDispatcher,
+)
+from .events import (
+    MinosEventBroker,
+)
+from .services import (
+    MinosQueueService,
+)