Source code for eclypse.builders.application.crud_api.mpi_services.gateway

"""MPI workflow for the CRUD gateway."""

from eclypse.remote.communication import mpi
from eclypse.remote.service import Service
from eclypse.utils import format_log_kv




class GatewayService(Service):
    """Drive a create-and-list workflow."""



    async def step(self):
        """Authenticate the client and create a demo item."""
        await self.auth_request()
        auth_response = await self.mpi.recv()
        self.logger.info("Received response | " + format_log_kv(response=auth_response))
        await self.item_request(auth_response["token"])
        item_response = await self.mpi.recv()
        self.logger.info("Received response | " + format_log_kv(response=item_response))
        return item_response


    @mpi.exchange(send=True)
    def auth_request(self):
        """Send a synthetic authentication request to the auth service."""
        return "AuthService", {
            "request_type": "authenticate",
            "api_key": "demo-key",
        }

    @mpi.exchange(send=True)
    def item_request(self, token: str):
        """Submit a create-item request with the authorised token."""
        return "ItemService", {
            "request_type": "create_item",
            "token": token,
            "item": {"id": "item-1", "name": "demo", "status": "active"},
        }