| async def handle_control_message(cl, command): | |
| command_parts = command.split() | |
| main_command = command_parts[0].lower() | |
| if main_command == 'start': | |
| await cl.Message(content="Starting new session...").send() | |
| elif main_command == 'stop': | |
| session_state = cl.user_session.get("session_state") | |
| end_time = datetime.now() | |
| duration = end_time - session_state.start_time | |
| duration_minutes = round(duration.total_seconds() / 60) | |
| session_state.end_time = end_time | |
| session_state.duration_minutes = duration_minutes | |
| await cl.Message(content=f"Ending current session after {session_state.duration_minutes} minutes").send() | |
| elif main_command == 'pause': | |
| await cl.Message(content="Ending current session...").send() | |
| elif main_command == 'time': | |
| session_state = cl.user_session.get("session_state") | |
| duration = session_state.get_session_duration() | |
| await cl.Message(content=f"Current session duration: {duration}").send() | |
| else: | |
| await cl.Message(content=f"Unknown command: {main_command}").send() | |