From 9eb652a1e36722af914e89c01069f80541502b10 Mon Sep 17 00:00:00 2001
From: AlGouvea <alvarohsgouvea@gmail.com>
Date: Thu, 23 Sep 2021 09:25:49 -0300
Subject: [PATCH] =?UTF-8?q?Intera=C3=A7=C3=A3o=20inicial=20do=20Vue=20com?=
 =?UTF-8?q?=20Websocket?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 frontend/src/__apps/painel/main.js | 16 ++++++++----
 sapl/painel/consumers.py           | 39 ++++++++++++++++--------------
 sapl/painel/tasks.py               |  1 -
 3 files changed, 32 insertions(+), 24 deletions(-)

diff --git a/frontend/src/__apps/painel/main.js b/frontend/src/__apps/painel/main.js
index af36705c2..52e18fc96 100644
--- a/frontend/src/__apps/painel/main.js
+++ b/frontend/src/__apps/painel/main.js
@@ -11,6 +11,7 @@ var time = null
 var timeEnd = null
 var audioAlertFinish = document.getElementById('audio')
 var cronometroStart = []
+const socket = new WebSocket(`ws://${window.location.host}/ws/painel/`)
 
 const v = new Vue({ // eslint-disable-line
   delimiters: ['[[', ']]'],
@@ -248,9 +249,11 @@ const v = new Vue({ // eslint-disable-line
         this.clockRunning(crono)
       }, 100)
     },
+    foi: function foi () {
+      socket.send('teste')
+    },
     pollData () {
       this.fetchData()
-
       this.polling = setInterval(() => {
         // console.info('Fetching data from backend')
         this.fetchData()
@@ -262,12 +265,15 @@ const v = new Vue({ // eslint-disable-line
     clearInterval(this.polling)
   },
   created () {
-    const socket = new WebSocket(`ws://${window.location.host}/ws/painel/`)
-
     socket.onopen = function (e) {
       console.log('Connection established')
-      console.log(e)
-      socket.send('teste')
+    }
+
+    const _this = this
+
+    socket.onmessage = function (e) {
+      _this.teste = e.data
+      console.log(_this.teste)
     }
 
     socket.onclose = function (e) {
diff --git a/sapl/painel/consumers.py b/sapl/painel/consumers.py
index 190bd358d..7153bdb09 100644
--- a/sapl/painel/consumers.py
+++ b/sapl/painel/consumers.py
@@ -1,26 +1,29 @@
 import json
-from channels.generic.websocket import WebsocketConsumer
+import requests
+from channels.generic.websocket import AsyncJsonWebsocketConsumer
 
 
-class PainelConsumer(WebsocketConsumer):
-    def connect(self):
-        self.channel_layer.group_add('message', self.channel_name)
-        self.accept()
-        self.send('Teste')
+
+class PainelConsumer(AsyncJsonWebsocketConsumer):
+    async def connect (self):
+        await self.accept()
 
     async def disconnect(self, close_code):
-        await self.channel_layer.group_discard('message', self.channel_name)
+        pass
+
+    async def receive(self, text_data):
+        print('Received Message')
+
+        print('Enviando...')
+        url_dados = 'http://localhost:8000/painel/786/dados'
 
-    def receive(self, text_data):
-        print('receive message')
-        text_data_json = json.loads(text_data)
-        message = text_data_json['message']
+        #response = requests.get(url_dados)
+        #print(response)
 
-        self.send(text_data=json.dumps({
-            'message': message
-        }))
+        await self.send_json({
+            'message': 'teste'
+        })
 
-    async def send_message (self, event):
-        new_data = event['text']
-        print(new_data)
-        await self.send(json.dumps(new_data))
\ No newline at end of file
+    async def send(self, event):
+        print('Entrou')
+    
\ No newline at end of file
diff --git a/sapl/painel/tasks.py b/sapl/painel/tasks.py
index 3b1dcd212..befd8442c 100644
--- a/sapl/painel/tasks.py
+++ b/sapl/painel/tasks.py
@@ -23,6 +23,5 @@ def get_cronometro():
         if post.ok: print('conexao realizada com sucesso')
         r = session.get('http://localhost:8000/painel/786/dados')
         json_data = r.json()
-        print(json_data)
 
     async_to_sync(channel_layer.group_send)('message', {'type':'send_message', 'text': json_data})