send events from server side only

[aryaniyaps]

so I have an application where people can create objects and update or delete the same via the django-rest-framework. Now, I want to set up a websockets framework over it, such that whenever an object is created, the server sends an event with the associated data.
this is what I've come up with so far.

import json
from channels.generic.websocket import AsyncWebsocketConsumer


class BoxEventsConsumer(AsyncWebsocketConsumer):
    def __init__(self):
        super(BoxEventsConsumer, self).__init__()

    async def connect(self):
        # add the channel_layer to the requested box's group.
        # group names are unique as they include the box-id
        self.box_id = self.scope['url_route']['kwargs']['box_id']
        self.box_group_name = 'ws_box_%s' % self.box_id
        await self.channel_layer.group_add(self.box_group_name, self.channel_name)
        await self.accept()

    async def disconnect(self, close_code):
        await self.channel_layer.group_discard(self.box_group_name, self.channel_name)

    async def receive(self, text_data=None, bytes_data=None):
        # send event data to every channel_layer
        # that is a part of the box's group. global events
        # such as box-creation must be sent to every user
        json_data = json.loads(text_data)
        formatted = {'data': json_data['data'], 'event': json_data['event']}
        await self.channel_layer.group_send(self.box_group_name, formatted)

    async def fire_event(self, event, data):
        # we send events to the box-groups from the
        # server. (data-binding is always outbound) so we don't need
        # to bother to receive data from clients
        await self.send(text_data=json.dumps({'data': data, 'event': event}))

However, I want to make sure that the client cannot send any websockets messages. Only the server can send to clients who are in the associated group with name box_group_name. How can I achieve this? Can someone please help me?

[carltongibson]

I think you can just use HTTP for SSE (and Long polling) use-cases.

See the example consumers in the docs: https://channels.readthedocs.io/en/stable/topics/consumers.html#asynchttpconsumer (towards the bottom).