---

необходимо провести доработку-унификацию функций подписки по ws и ретраями
сейчас во многих функциях вот такая проблема:
Подключение по ws, получение данных SchemeSignalsStateContent для датчика AK.CHTN.LU_TIHVEL.KP_8.SW_8-3.Pin (id=31572) 2 sub-steps10s 003ms
Вызов SubscribeSchemeSignalsStateRequest c параметрами {'tuId': 6}0s
Получение сообщения с контентом типа: SchemeSignalsStateContent - попытка 1 из 1210s 002ms
asyncio.exceptions.TimeoutError: Timeout при фильтрации сообщений 10.0 секунд
Failed: Не удалось получить сообщение типа: SchemeSignalsStateContent для датчика AK.CHTN.LU_TIHVEL.KP_8.SW_8-3.Pin (id=31572). Ошибка: Timeout при фильтрации сообщений 10.0 секунд

вместо 12 запросов делается 1 с ожиданием 10 секунл.
Необходимо доработать подключение с ретраями чтобы добиться аналогичного результата:
Подключение по ws и получение сообщения об утечке типа: LeaksContent 14 sub-steps, 2 attachments54s 468ms
Получение сообщения с контентом типа: LeaksContent - попытка 1 из 7 1 sub-step5s 004ms
Получение сообщения с контентом типа: LeaksContent - попытка 2 из 7 1 sub-step5s 004ms
Получение сообщения с контентом типа: LeaksContent - попытка 3 из 7 1 sub-step5s 003ms
Получение сообщения с контентом типа: LeaksContent - попытка 4 из 7 1 sub-step5s 003ms
Получение сообщения с контентом типа: LeaksContent - попытка 5 из 7 1 sub-step5s 004ms
Получение сообщения с контентом типа: LeaksContent - попытка 6 из 7 1 sub-step5s 003ms
Получение сообщения с контентом типа: LeaksContent - попытка 7 из 7 1 sub-step156ms
Распакованное сообщение от api-gateway 2026-09-16 03:39:47.731365+03:00
 2.3 KiB
SubscribeLeaksReply

(Раньше было 7 я увеличл до 12 в этой ветке)

По сути для подписок типа LeaksContent используется одна функция работающая правильно, а для других подписок другая функция не совсем правильно выполняющая ретраи, нужно сделать так, чтобы все подписки основанные на async def connect_and_get_msg* стали правильно ретраить запросы на подключение
сформируй план исправления