diego_pcto
/
ProgettoMessaggi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Aggiunta orario invio messaggi

master
diego_pcto 2025-06-19 11:02:11 +02:00
parent febcb92d01
commit bfb517a2f3
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
main.py
View File

@ -2,13 +2,14 @@ from fastapi import FastAPI, WebSocket, WebSocketDisconnect
from fastapi.responses import HTMLResponse from fastapi.responses import HTMLResponse
from fastapi.staticfiles import StaticFiles from fastapi.staticfiles import StaticFiles
from typing import List from typing import List
from datetime import datetime
app = FastAPI() app = FastAPI()
with open("index.html", "r") as file: with open("index.html", "r") as file:
html = file.read() html = file.read()
listaConnessioni: List[WebSocket] = [] # Lista di connessioni listaConnessioni: List[WebSocket] = [] #lista delle connessioni
@app.get("/") @app.get("/")
async def get(): async def get():
@ -17,16 +18,19 @@ async def get():
@app.websocket("/ws") @app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket): async def websocket_endpoint(websocket: WebSocket):
await websocket.accept() await websocket.accept()
listaConnessioni.append(websocket) # Aggiungo il websocket listaConnessioni.append(websocket) #aggiungo il websocket
try: try:
while True: while True:
data = await websocket.receive_text() data = await websocket.receive_text()
orario = datetime.now().strftime("%H:%M") #orario di quando e' stato inviato il messaggio
messaggio_con_orario = orario + " ---> " + data
for connection in listaConnessioni: for connection in listaConnessioni:
try: try:
await connection.send_text(data) await connection.send_text(messaggio_con_orario)
except Exception as e: except Exception as e:
print("Errore nell'invio dei dati a"+ connection + e) print("Errore nell'invio dei dati a " + connection + ": " + e)
listaConnessioni.remove(connection) listaConnessioni.remove(connection)
except WebSocketDisconnect: except WebSocketDisconnect:
listaConnessioni.remove(websocket) listaConnessioni.remove(websocket)