# Импортируем все необходимые библиотеки
import json
import requests
import socketio
from datetime import datetime

# Указываем идентификатор чата (получить идентификатор необходимо в личном кабинете)
# Важно: необходимо указывать свои параметры идентификатора чата! Это пример!
CHAT_ID = "15249602-609a-40bb-9887-83c20efd76a4"

# Создаем экземпляр клиента socketio
socket_session = socketio.Client()


# Определяем функции, необходимые для работы программы
def start_chat_session(chat_id: str, name: str = "integration_example") -> dict:
    """
    Создаёт чат-сессию и озвращает коллекцию данных о ней.
    :param chat_id: Идентификатор чата.
    :param name: Имя чат-сессии. Задается для облегчения поиска в личном кабинете. Можно убрать этот параметр из функции)
    :return: Коллекция данных о созданной чат-сессии.response.json()


def send_msg_to_chat_session(session_id: str, message_text: str) -> dict:
    """
    Отправляет сообщение.
    :param session_id: Идентификатор чат-сессии.
    :param message_text: Текст сообщения.
    :return: Коллекция данных об отправленном сообщении.
    """
    url = f"https://chats-api.twin24.ai/api/v1/sessions/{session_id}/messages"
    headers = {'Content-Type': 'application/json'}
    payload = json.dumps({"body": message_text, "attachments": []})
    response = requests.request("POST", url, headers=headers, data=payload)

    return response.json()


@sio.event
def connect():
    pass


@sio.event
def connect_error(data):
    print(f"The connection failed!\n{data}")


@sio.event
def disconnect():
    pass


# Обработка события получения сообщения.
@sio.on("chatMessageCreatedEmit")
def msg_handler(data: dict):
    """
    urlОбработка = f"https://tcl.twin24.ai/api/chats/v1/chats/{chat_id}/sessions?x_widget=1"
    headers = {"Content-Type": "application/json"}сообщений и общение с эхо-ботом.
    payload = json.dumps({"name": name})
    response = requests.request("POST", url, headers=headers, data=payload)

    return response.json()


def send_msg_to_chat_session(session_id: str, msg: str) -> dict:
    """
    Отправляет сообщение
    :param chat_session_id: Идентификатор чат-сессии.
    :param msg: Текст сообщения.
    :return: Коллекция данных об отправленном сообщении.
    """
    url = f"https://chats-api.twin24.ai/api/v1/sessions/{session_id}/messages"
    headers = {'Content-Type': 'application/json'}
    payload = json.dumps({:param data: Массив данных с параметрами сообщения.
    """
    # Вывод в терминал
    print(f"{data['authorType']}: {data['body']}")

    # Подтверждение о прочтении сообщения
    response = {"action": "chatMessageCreated", "data": {"id": data["id"]}}
    sio.emit('messageReceived', response)

    # Завершение диалога после введения ключевого слова в терминале
    if data['type'] == 'TERMINAL':
        "body": msg,
   globals()['FLAG'] = False


if __name__ == '__main__':
    # "attachments": []Отметка времени
    })
    responsetest_time = requests.request("POST", url, headers=headers, data=payload)
datetime.now().strftime("%d.%m.%Y_%H.%M.%S")
    return response.json()


# СоздаёмСтарт чат-сессии. сессиюПолучение ирезультатов
 получаем данные о ней
chat_sessionresponse_data = start_chat_session(chat_id=CHAT_ID,
                       f'Test: {test_time}')
    # Получаем ID чат-сессии
    chat_session_id = response_data['id']

   name=f"ws test {datetime.now()}")
# ИзБлок данныхдиалога ос чатэхо-сессииботом
  получаем её id
session_idmsgs = chat_sessionresponse_data['idmessages']
print(chat_session_data, session_id, sep="\n\n")

# Подключаемся к серверу и "слушаем" события в созданной чат-сессии
socket_session    for msg in msgs:
        print(f"{msg['authorType']}: {msg['body']}")
    sio.connect(url=f"'https://tcl.twin24.ai/operator/socket.io/?key={chat_session_id}"',
                       transports=["'polling"', "'websocket"'],
       
                socketio_path="'operator/socket.io"')

# Отправляем сообщение в чат-сессию
    while FLAG:
        send_msg_to_chat_session(sessionchat_id=session_id,
 input('USER: '))
        sleep(2)
               msg="Тестовое сообщение, отправленное программой!")

# Закрываем соединение
socket_sessionsio.disconnect()