Added hotfixes

This commit is contained in:
Sviatoslav Tsariov Yurievich 2025-07-01 12:28:16 +03:00
parent f33a28c06a
commit 5efcfd1f3c

View File

@ -4,18 +4,18 @@ from flask_socketio import emit, join_room, leave_room
from src.infra.server import socketio from src.infra.server import socketio
from src.repos.reservation_repo import ReservationRepository from src.repos.reservation_repo import ReservationRepository
@socketio.on('connect') @socketio.on('connect', namespace='/api')
#@jwt_required() #@jwt_required()
def handle_connect(): def handle_connect():
#current_user = get_jwt_identity() #current_user = get_jwt_identity()
#print(f'Client connected: {current_user}') #print(f'Client connected: {current_user}')
emit('status', {'message': 'Connected'}) emit('status', {'message': 'Connected'})
@socketio.on('disconnect') @socketio.on('disconnect', namespace='/api')
def handle_disconnect(): def handle_disconnect():
print('Client disconnected') print('Client disconnected')
@socketio.on('subscribe_reservations') @socketio.on('subscribe_reservations', namespace='/api')
def handle_subscribe(data): def handle_subscribe(data):
date = data.get('date') date = data.get('date')
room_id = data.get('room_id') room_id = data.get('room_id')
@ -31,7 +31,7 @@ def handle_subscribe(data):
reservations = ReservationRepository.list_all(filters) reservations = ReservationRepository.list_all(filters)
emit('reservations_update', reservations) emit('reservations_update', reservations)
@socketio.on('unsubscribe_reservations') @socketio.on('unsubscribe_reservations', namespace='/api')
def handle_unsubscribe(data): def handle_unsubscribe(data):
date = data.get('date') date = data.get('date')
leave_room(date) leave_room(date)