configs.py

import os
import pika
from schema.schema import SphexNotification
from utils.convertors import json_deserializer_factory

web_api_conf = {
    "identity_authorization_url": os.environ.get("AUTHORIZATION_URL", "http://api/user_info"),
    "authorization_header_key": "Authorization",
    "authorization_header_prefix": "Bearer"
}

cookie_authorization = {
    "TOKEN_KEY": "token"
}


#  the key is the WebSocket topic,
#  the value is a list of RabbitMQ topic information with keys representing RabbitMQ topics,
#  exchange name, exchange type, topic name and the callable hook that recieves input from rabbit topic and
#  its output will be used for the WebSocket topic.
ws_rmq_topics = {
    "alerts": [
        {
            "exchange_name": "notification",
            "exchange_type": "topic",
            "topic": "sphex.ticket.warning",
            "hook": json_deserializer_factory(SphexNotification),
        },
        {
            "exchange_name": "notification",
            "exchange_type": "topic",
            "topic": "sphex.ticket.error",
            "hook": json_deserializer_factory(SphexNotification),
        }
    ],
    "activities": [
        {
            "exchange_name": "notification",
            "exchange_type": "topic",
            "topic": "sphex.ticket.info",
            "hook": json_deserializer_factory(SphexNotification),
        }
    ],
}

# pika.connection.Parameters compatible
rabbitmq_connection = {
    'host': os.environ.get("RABBITMQ_HOST", "rabbitmq"),
    'port': int(os.environ.get("RABBITMQ_PORT", 5672)),
    'credentials': pika.PlainCredentials(
        os.environ.get('RABBITMQ_USER', 'guest'),
        os.environ.get('RABBITMQ_PASSWORD', 'guest')
    )
}

rabbitmq_connection_sleep_retry = 30

server_address = {
    "address": "0.0.0.0",
    "port": 9000
}