diff --git a/bothub/project/consumers/project_consumer.py b/bothub/project/consumers/project_consumer.py index a20b5b80..693fb148 100644 --- a/bothub/project/consumers/project_consumer.py +++ b/bothub/project/consumers/project_consumer.py @@ -3,6 +3,7 @@ from ..usecases.project.projectdto import ProjectCreationDTO from ..usecases.project.creation import ProjectCreationUseCase +from ..usecases.organization.creation import OrganizationAuthorizationCreateUsecase from bothub.event_driven.parsers import JSONParser from bothub.event_driven.consumer.consumers import EDAConsumer @@ -27,6 +28,11 @@ def consume(self, message: amqp.Message): project_creation = ProjectCreationUseCase() project_creation.create_project(project_dto, body.get("user_email")) + auth_creation = OrganizationAuthorizationCreateUsecase() + auth_creation.eda_consume_organization_authorization( + authorizations=body.get("authorizations"), + organization_id=body.get("organization_id") + ) message.channel.basic_ack(message.delivery_tag)