U !j>@sdZddlmZddlZddlZddlmZmZmZddl m Z ddl Z ddl Z ddl Z ddlmZejejdedZed d Zed d d ddZeddd ddZeddddddZdddddZedddddd Zddd!d"d#ZdS)$uaТочка входа: FastAPI-приложение. Эндпоинты: - GET /oauth/callback — приём кода авторизации, обмен на токены, регистрация бота - POST /bot/events — события бота (сообщения и нажатия кнопок) - GET /healthz — health-check ) annotationsN)FastAPIRequestResponse) HTMLResponse) poll_loop)levelappzBitrix24 Draft Assistant)titlestartupNone)returncstttdS)N)storeZinit_dbasyncio create_taskrrr*/var/www/spa-bitrix.ru/bitrix_asist/app.py_startupsrz/healthzdictcsdtdS)NT)okZportals)rZall_portal_domainsrrrrhealthz!srz/oauth/callbackrr)requestr cs|jd}|jd}|r |s,tdddSt||IdHt|IdH}t|dpb|d}t|d |t |IdHtd |d S) u`Битрикс возвращает code + domain (member_id) после авторизации.codedomainu4Ожидались параметры code и domaini) status_codeNZIDid operator_idu(

Готово

Портал u подключён. Бот «Черновики» зарегистрирован. Можешь закрыть страницу.

) Z query_paramsgetrbitrixZ exchange_codeZwhoamistrrZset_portal_fieldZ register_bot)rrrmerrrroauth_callback&s    r!z str | None)payloadr cCsf|di}|d}|d}|r.t|nd}|s:dSt|}|rb|drb||dkrbdS|S)uПроверяет, что событие пришло от Битрикс (по application_token), и возвращает domain или None.auth member_idZapplication_tokenN app_token)rrZfind_domain_by_member get_portal)r"r#r$r%rportalrrr _verify_event<s    r(z /bot/eventscs^|IdH}tt|}|dp&d}t|}|sLtd|ddiS|di}|dkr|di}|dpxd}|d pd}t |d } t |||| IdHdd iS|d krV|d i} t | dp| dpd} | dpd} t |} | d }| t |krN| rNt ||}|rNt |||| IdHdd iSdd iS)NeventuLevent %s: неизвестный/непроверенный источникrFdataZONIMCOMMANDADDZCOMMANDZCOMMAND_PARAMSrTZONIMBOTMESSAGEADDZPARAMSZ FROM_USER_IDZ AUTHOR_IDZMESSAGE)form _unflattenrrupperr(logwarninglowerrr&approvalZhandle_commandrstripZpop_edit_stateZhandle_edit_text)rr,r"r)rr+cmdcommandparamsZoperator_dialogpZauthortextr'rZ pending_idrrr bot_eventsKs6         r9)flatr cCsZi}|D]H\}}|ddd}|}|ddD]}||i}q6|||d<q |S)udПревращает ключи вида data[PARAMS][MESSAGE] в вложенный словарь.]r*[N)itemsreplacesplit setdefault)r:rootkeyvaluepartsnodepartrrrr-rsr-)__doc__ __future__rrloggingZfastapirrrZfastapi.responsesrrrr2Zpollerr basicConfigINFO getLoggerr/r Zon_eventrrrr!r(postr9r-rrrrs,     &