notify.py

from flask_restful import Resource, request, abort
from marshmallow import Schema, fields
import pika
import json

class NotifySchema(Schema):
    client_id = fields.Str(required=True)
    secret = fields.Str(required=True)
    body = fields.Str(required=True)

class Notify(Resource):
    clients = None
    schema = None

    def __init__(self):
        self.schema = NotifySchema()
        with open("clients.json", "r") as clients_file:
            self.clients = json.load(clients_file)

    def post(self):
        args = request.get_json()
        errors = self.schema.validate(args)
        if errors:
            abort(400, message=str(errors))

        allow = False
        body = args.get("body")
        message = {
            'topic': 'broadcast',
            'message': body,
        }
        client_id = args.get("client_id")
        notify_queue = client_id + "-broadcast"
        if client_id in self.clients:
            client = self.clients.get(client_id)
            if args.get("secret") == client.get("secret"):
                allow = True

        if allow:
            connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost"))
            channel = connection.channel()
            channel.queue_declare(queue=notify_queue, durable=True)
            channel.basic_publish(exchange="", routing_key=notify_queue, body=json.dumps(message))
            connection.close()