Spaces:
Running
Running
import json | |
from . import model_manage as md | |
from channels.generic.websocket import WebsocketConsumer | |
class ChatConsumer(WebsocketConsumer): | |
def connect(self): | |
self.accept() | |
def disconnect(self, close_code): | |
pass | |
def receive(self, text_data): | |
text_data_json = json.loads(text_data) | |
message = text_data_json["message"] | |
print(message) | |
record, messagee = md.full_chain_single_question(message) | |
print("First answer: ",record) | |
self.send(text_data=json.dumps({"message": messagee})) | |