Compare commits

...

3 Commits

Author SHA1 Message Date
kirill 3dbb0257ae reformat 2 years ago
kirill 2a0189e892 use secondary_functions in ws_handler 2 years ago
kirill 5edc3beb78 add package secondary_functions 2 years ago
  1. 1
      demo/func/__init__.py
  2. 20
      demo/func/secondary_functions.py
  3. 3
      demo/routes.py
  4. 19
      demo/views/frontend.py

@ -0,0 +1 @@
from . import secondary_functions

@ -0,0 +1,20 @@
import time
import asyncio
from aiohttp.web_ws import WebSocketResponse
async def time_response(ws: WebSocketResponse, delay: int = 60):
while True:
new_time: time.gmtime = time.gmtime(time.time())
hour = new_time.tm_hour + 3
if hour >= 24:
hour = hour - 24
minutes = new_time.tm_min
if minutes < 10:
minutes = f'0{minutes}'
result_response = f'Время: {hour}:{minutes}'
try:
await ws.send_str(result_response)
await asyncio.sleep(delay)
except ConnectionResetError:
await asyncio.sleep(delay)

@ -6,7 +6,6 @@ def setup_routes(app):
app.router.add_routes([aiohttp.web.get('/index.html', frontend.index),
aiohttp.web.post('/submit', frontend.button_clicked),
aiohttp.web.get('/index_2.html', frontend.index_2),
aiohttp.web.get('/ws', frontend.websocket_handler)
]
aiohttp.web.get('/ws', frontend.websocket_handler),]
)

@ -1,20 +1,10 @@
import asyncio
import aiohttp
from aiohttp import WSMsgType
from aiohttp.web_response import Response
from aiohttp.web_ws import WebSocketResponse
from aiohttp_jinja2 import template
import time
import asyncio
async def time_response(ws: WebSocketResponse, delay: int = 60):
while True:
new_time: time.gmtime = time.gmtime(time.time())
time_response = f'Время: {new_time.tm_hour + 3}:{new_time.tm_min} Задержка: {delay}'
try:
await ws.send_str(time_response)
await asyncio.sleep(delay)
except ConnectionResetError:
await asyncio.sleep(delay)
from ..func import secondary_functions
@template('index.html')
@ -26,11 +16,10 @@ async def index_2(request):
return {}
async def websocket_handler(request):
ws: WebSocketResponse = WebSocketResponse()
await ws.prepare(request)
asyncio.create_task(time_response(ws))
asyncio.create_task(secondary_functions.time_response(ws, delay=60))
async for msg in ws:
if msg.type == aiohttp.WSMsgType.TEXT:
@ -38,7 +27,7 @@ async def websocket_handler(request):
if msg.data == 'close':
await ws.close()
else:
await ws.send_str(f'Вы послали: {msg.data}')
await ws.send_str(f'Вы ввели: {msg.data}')
elif msg.type == WSMsgType.ERROR:
print('ws connection closed with exception %s' %
ws.exception())

Loading…
Cancel
Save