#consumers.py

import json
from channels.channel import Group
from time import sleep
import uuid
import os

import asyncio

def ws_connect(message):
    name = message.reply_channel.name
    name = name.split('.')[2]
    uid = str(uuid.uuid4())
    Group(uid).add(message.reply_channel)
    message.reply_channel.send({'accept': True})
    Group(uid).send({'text': json.dumps({'uid': uid, 'sender': message.reply_channel.name})})

def ws_message(message):
    content = message.content
    text = json.loads(content['text'])
    uid = text['uid']

    os.system(f"python parser.py {uid}")

    Group(uid).send({'text': json.dumps({
        'message': text['text'],
        'sender': message.reply_channel.name,
        'uid': uid
        })})

def ws_disconnect(message):
    # name = message.reply_channel.name
    # Group('chat').discard(message.reply_channel)
    pass


#parser.py
from time import sleep
from channels.channel import Group
import sys
import json


uid = sys.argv[1]
for i in range(10):
    print(i)
    Group(uid).send({'text': json.dumps({
        'message': i,
        'uid': uid
        })})