nejma

Nejma

Inspirado por channels , o Nejma permite gerenciar e enviar mensagens para grupos de canais

Coisas que você pode construir com nejma :

• bater papo
• notificação
• lidar com os usuários conectados de várias guias)
• E mais ...

Exemplo

Dê uma olhada neste exemplo nejma-chat , um aplicativo de bate-papo simples construído usando nejma e starlette .

Instalação

$ pip install nejma

Começando

Aqui está um exemplo de usar nejma com WebSockets.

Primeiro Importar Channel e Channel_layer de Nejma

 from nejma import Channel , channel_layer

Crie um canal no Connect

 async def on_connect ( self , websocket , ** kwargs ):
    await super (). on_connect ( websocket , ** kwargs )

    self . channel = Channel ( send = websocket . send )

Adicionar grupos, canais ou enviar mensagens

 async def on_receive ( self , websocket , data ):
    self . channel_layer . add ( group , self . channel )

    await self . channel_layer . group_send ( group , "Welcome !" )

Finnaly, remova o canal assim que a conexão estiver fechada

 async def on_disconnect ( self , websocket , close_code ):
    self . channel_layer . remove_channel ( self . channel )

Starlette

---

Para usar nejma com starlette , basta importar o WebSockENDPoint do Nejma

 from nejma . ext . starlette import WebSocketEndpoint

@ app . websocket_route ( "/ws" )
class Chat ( WebSocketEndpoint ):
    encoding = "json"

    async def on_receive ( self , websocket , data ):
        room_id = data [ 'room_id' ]
        message = data [ 'message' ]
        username = data [ 'username' ]

        if message . strip ():
            group = f"group_ { room_id } "

            self . channel_layer . add ( group , self . channel )

            payload = {
                "username" : username ,
                "message" : message ,
                "room_id" : room_id
            }
            await self . channel_layer . group_send ( group , payload )

Documentos

A classe ChannelLayer fornecida por nejma expõe os seguintes métodos:

add(group, channel, send=None)

Adiciona um canal a um grupo de doações.

• Enviar: Método para enviar mensagens para um canal

 self . channel_layer . add ( group , self . channel , send = websocket . send )

async group_send(group, "Welcome !")

Envia uma mensagem para um grupo de canais

 await self . channel_layer . group_send ( group , "Welcome !" )

remove(group, channel)

Remove um canal de um determinado grupo

 self . channel_layer . remove ( group , self . channel )

remove_channel(channel)

Remove um canal de todos os grupos

 self . channel_layer . remove_channel ( self . channel )

flush()

Redefina todos os grupos

 self . channel_layer . flush ()