DRF channels WS

Library Azerbaijan Python Users Community ucun publish olunur

Installation

• pip3 install drf-async-ws

Usage

UPDATE

m2m_senders = [User.groups.through] hemcinin m2m fields der ucunde elave olundu

 class Test(AzPUG):
        model = User
        stream = 'users'
        m2m_senders = [User.groups.through]

        @classmethod
        def group_names(cls, instance):
            return ['test']

        def serialize_data(self, instance):
            return {'id': instance.id, 'username': instance.username}

Vacibdir

DRFJsonConsumerMixinAsync mixsini consumer class da gostermeyiniz shertdi

from drf_async.mixins import DRFJsonConsumerMixinAsync

    class TestConsumer(AsyncJsonWebsocketConsumer, DRFJsonConsumerMixinAsync):
        async def connect(self):
            await self.channel_layer.group_add('test', self.channel_name)
            await self.accept()

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

Nece isdeyir(example)

Example projects

from django.db import models
from rest_framework import serializers
from drf_async.jsonasync import AzPUG

class Garage(models.Model):
    name = models.CharField(max_length=255)

class Car(models.Model):
    name = models.CharField(max_length=255)
    garage = models.ForeignKey('Garage', on_delete=models.CASCADE)


class CarSerializer(serializers.ModelSerializer):
    class Meta:
        model = Car
        fields = '__all__'


class CarWS(AzPUG):
    model = Car
    stream = 'cars'
    serializer = CarSerializer

    @classmethod
    def group_names(cls, instance):
        return [instance.garage.name]

class GarageWS(AzPUG):
    """
    serializers-siz versiyasi 
    """
    model = Garage
    stream = 'garage-cars'

    @classmethod
    def group_names(cls, instance):
        return [instance.name]

    def serialize_data(self, instance):
        return {'id': instance.id, 'name': instance.name}

Bundan sonra emin olunki WebsocketConsumer-de duzgun add eleyirsiz grupu misal self.channel_layer.group_add('bmw', self.channel_name)
Garage.objects.create(name='bmw') duzgun websocket connect bu halda olacag. Serializersiz versiya ucun.!

{
    "stream": "garage-cars",
    "payload": {
        "action": "create",
        "data": {"id": 1, "name": "bmw"},
        "model": "your_app.garage",
        "pk": 1
    }
}

Hemcinin ("action": "update") ve ya ("action": "delete") eyni netice alacagsiz.