Merge pull request #133 from Clariteia/issue-126-migrate-ticket-microservice

Migrate `ticket` microservice to latest minos version

Author: vladyslav-fenchak

.github/workflows/microservice-ticket-tests.yml

@@ -0,0 +1,54 @@
+on:
+  push:
+    paths:
+      - 'microservices/ticket/**'
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    container: python:3.9-buster
+    services:
+      postgres:
+        image: postgres
+        env:
+          POSTGRES_DB: ticket_db
+          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
+    defaults:
+      run:
+        working-directory: ./microservices/ticket
+
+    env:
+      MINOS_REPOSITORY_HOST: postgres
+      MINOS_SNAPSHOT_HOST: postgres
+      MINOS_BROKER_QUEUE_HOST: postgres
+      MINOS_BROKER_HOST: kafka
+
+    steps:
+      - name: Check out repository code
+        uses: actions/checkout@v2
+
+      - name: Install Poetry
+        uses: snok/[email protected]
+
+      - name: Install dependencies
+        run: poetry install
+
+      - name: Run tests
+        run: poetry run pytest

.github/workflows/microservice-user-tests.yml

@@ -35,13 +35,10 @@ jobs:
         working-directory: ./microservices/user
 
     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
-      MINOS_SAGA_QUEUE_HOST: postgres
+      MINOS_BROKER_QUEUE_HOST: postgres
+      MINOS_BROKER_HOST: kafka
 
     steps:
       - name: Check out repository code

microservices/product/config.yml

@@ -5,6 +5,7 @@ service:
         command_reply_broker: minos.networks.CommandReplyBroker
         event_broker: minos.networks.EventBroker
         repository: minos.common.PostgreSqlRepository
+        reply_pool: minos.networks.ReplyHandlerPool
         saga_manager: minos.saga.SagaManager
         snapshot: minos.common.PostgreSqlSnapshot
         discovery: minos.networks.DiscoveryConnector
@@ -21,37 +22,17 @@ service:
 rest:
     host: 0.0.0.0
     port: 8084
-    endpoints:
-        -   route: /products
-            method: POST
-            controller: src.ProductCommandService
-            action: create_product
-            name: ""
-
-        -   route: /products/{uuid}/inventory
-            method: PUT
-            controller: src.ProductCommandService
-            action: update_inventory
-            name: ""
-
-        -   route: /products/{uuid}/inventory
-            method: PATCH
-            controller: src.ProductCommandService
-            action: update_inventory_diff
-            name: ""
-
-        -   route: /products
-            method: GET
-            controller: src.ProductCommandService
-            action: get_products
-            name: ""
-
-        -   route: /products/{uuid}
-            method: DELETE
-            controller: src.ProductCommandService
-            action: delete_product
-            name: ""
-
+broker:
+    host: localhost
+    port: 9092
+    queue:
+        database: product_db
+        user: minos
+        password: min0s
+        host: localhost
+        port: 5432
+        records: 10
+        retry: 2
 repository:
     database: product_db
     user: minos
@@ -64,72 +45,16 @@ snapshot:
     password: min0s
     host: localhost
     port: 5432
-events:
-    broker: localhost
-    port: 9092
-    queue:
-        database: product_db
-        user: minos
-        password: min0s
-        host: localhost
-        port: 5432
-        records: 10
-        retry: 2
-    items:
-        -   name: ProductCreated
-            controller: src.ProductQueryService
-            action: product_created
-        -   name: ProductUpdated
-            controller: src.ProductQueryService
-            action: product_updated
-        -   name: ProductDeleted
-            controller: src.ProductQueryService
-            action: product_deleted
 commands:
-    broker: localhost
-    port: 9092
-    items:
-        -   name: CreateProduct
-            controller: src.ProductCommandService
-            action: create_product
-        -   name: GetProducts
-            controller: src.ProductCommandService
-            action: get_products
-        -   name: ReserveProducts
-            controller: src.ProductCommandService
-            action: reserve_products
-    queue:
-        database: product_db
-        user: minos
-        password: min0s
-        host: localhost
-        port: 5432
-        records: 10
-        retry: 2
+    service: src.ProductCommandService
+queries:
+    service: src.ProductQueryService
+events:
+    service: src.ProductQueryService
 saga:
-    broker: localhost
-    port: 9092
     storage:
         path: "./product.lmdb"
     items: []
-    queue:
-        database: product_db
-        user: minos
-        password: min0s
-        host: localhost
-        port: 5432
-        records: 10
-        retry: 2
 discovery:
   host: localhost
-  port: 5567
-  endpoints:
-    subscribe:
-      path: subscribe
-      method: POST
-    unsubscribe:
-      path: unsubscribe
-      method: POST
-    discover:
-      path: discover
-      method: GET
+  port: 5567