Add sync request via pybotx

backend/app/api/endpoints/botx.py

@@ -8,74 +8,44 @@
     Bot,
     BotXMethodCallbackNotFoundError,
     UnknownBotAccountError,
-    UnsupportedBotAPIVersionError,
     UnverifiedRequestError,
     build_bot_disabled_response,
     build_command_accepted_response,
     build_unverified_request_response,
 )
-from pybotx.constants import BOT_API_VERSION
 
 from app.api.dependencies.bot import bot_dependency
+from app.api.exceptions.botx import handle_exceptions
 from app.logger import logger
-from app.settings import settings
 
 router = APIRouter()
 
 
 @router.post("/command")
+@handle_exceptions
 async def command_handler(request: Request, bot: Bot = bot_dependency) -> JSONResponse:
     """Receive commands from users. Max timeout - 5 seconds."""
-    try:  # noqa: WPS225
-        bot.async_execute_raw_bot_command(
-            await request.json(),
-            request_headers=request.headers,
-        )
-    except ValueError:
-        error_label = "Bot command validation error"
-
-        if settings.DEBUG:
-            logger.exception(error_label)
-        else:
-            logger.warning(error_label)
-
-        return JSONResponse(
-            build_bot_disabled_response(error_label),
-            status_code=HTTPStatus.SERVICE_UNAVAILABLE,
-        )
-    except UnknownBotAccountError as exc:
-        error_label = f"No credentials for bot {exc.bot_id}"
-        logger.warning(error_label)
-
-        return JSONResponse(
-            build_bot_disabled_response(error_label),
-            status_code=HTTPStatus.SERVICE_UNAVAILABLE,
-        )
-    except UnsupportedBotAPIVersionError as exc:
-        error_label = (
-            f"Unsupported Bot API version: `{exc.version}`. "
-            f"Set protocol version to `{BOT_API_VERSION}` in Admin panel."
-        )
-        logger.warning(error_label)
-
-        return JSONResponse(
-            build_bot_disabled_response(error_label),
-            status_code=HTTPStatus.SERVICE_UNAVAILABLE,
-        )
-    except UnverifiedRequestError as exc:
-        logger.warning(f"UnverifiedRequestError: {exc.args[0]}")
-        return JSONResponse(
-            content=build_unverified_request_response(
-                status_message=exc.args[0],
-            ),
-            status_code=HTTPStatus.UNAUTHORIZED,
-        )
-
+    bot.async_execute_raw_bot_command(
+        await request.json(),
+        request_headers=request.headers,
+    )
     return JSONResponse(
         build_command_accepted_response(), status_code=HTTPStatus.ACCEPTED
     )
 
 
+@router.post("/smartapps/request")
+@handle_exceptions
+async def sync_smartapp_event_handler(
+    request: Request, bot: Bot = bot_dependency
+) -> JSONResponse:
+    response = await bot.sync_execute_raw_smartapp_event(
+        await request.json(),
+        request_headers=request.headers,
+    )
+    return JSONResponse(response.jsonable_dict(), status_code=HTTPStatus.OK)
+
+
 @router.get("/status")
 async def status_handler(request: Request, bot: Bot = bot_dependency) -> JSONResponse:
     """Show bot status and commands list."""

backend/app/api/exceptions/botx.py

@@ -0,0 +1,66 @@
+"""Handlers for BotX request exceptions."""
+
+from functools import wraps
+from http import HTTPStatus
+from typing import Any, Callable
+
+from fastapi.responses import JSONResponse
+from pybotx import (
+    UnknownBotAccountError,
+    UnsupportedBotAPIVersionError,
+    UnverifiedRequestError,
+    build_bot_disabled_response,
+    build_unverified_request_response,
+)
+from pybotx.constants import BOT_API_VERSION
+
+from app.logger import logger
+from app.settings import settings
+
+
+def handle_exceptions(func: Callable) -> Callable:  # noqa: WPS212
+    @wraps(func)
+    async def wrapper(*args: Any, **kwargs: Any) -> JSONResponse:
+        try:  # noqa: WPS225
+            return await func(*args, **kwargs)
+        except ValueError:
+            error_label = "Bot command validation error"
+
+            if settings.DEBUG:
+                logger.exception(error_label)
+            else:
+                logger.warning(error_label)
+
+            return JSONResponse(
+                build_bot_disabled_response(error_label),
+                status_code=HTTPStatus.SERVICE_UNAVAILABLE,
+            )
+        except UnknownBotAccountError as exc:
+            error_label = f"No credentials for bot {exc.bot_id}"
+            logger.warning(error_label)
+
+            return JSONResponse(
+                build_bot_disabled_response(error_label),
+                status_code=HTTPStatus.SERVICE_UNAVAILABLE,
+            )
+        except UnsupportedBotAPIVersionError as exc:
+            error_label = (
+                f"Unsupported Bot API version: `{exc.version}`. "
+                f"Set protocol version to `{BOT_API_VERSION}` in Admin panel."
+            )
+            logger.warning(error_label)
+
+            return JSONResponse(
+                build_bot_disabled_response(error_label),
+                status_code=HTTPStatus.SERVICE_UNAVAILABLE,
+            )
+        except UnverifiedRequestError as exc:
+            logger.warning(f"UnverifiedRequestError: {exc.args[0]}")
+            return JSONResponse(
+                content=build_unverified_request_response(
+                    status_message=exc.args[0],
+                ),
+                status_code=HTTPStatus.UNAUTHORIZED,
+            )
+
+    return wrapper

backend/app/bot/commands/common.py

@@ -10,9 +10,11 @@
     IncomingMessage,
     SmartAppEvent,
     StatusRecipient,
+    SyncSmartAppEventResponsePayload,
 )
 
 from app.resources import strings
+from app.bot.smartapp import smartapp
 
 collector = HandlerCollector()
 
@@ -49,6 +51,13 @@ async def help_handler(message: IncomingMessage, bot: Bot) -> None:
     await bot.answer_message(answer_body)
 
 
+@collector.sync_smartapp_event
+async def handle_sync_smartapp_event(
+    event: SmartAppEvent, bot: Bot
+) -> SyncSmartAppEventResponsePayload:
+    return await smartapp.handle_sync_smartapp_event(event, bot)
+
+
 @collector.command("/_debug:git-commit-sha", visible=False)
 async def git_commit_sha(message: IncomingMessage, bot: Bot) -> None:
     """Show git commit SHA."""

backend/pyproject.toml

@@ -10,8 +10,8 @@ authors = []
 [tool.poetry.dependencies]
 python = ">=3.9, <3.11"
 
-pybotx = "~0.63.0"
-pybotx-smartapp-rpc = ">=0.5.6,<0.8.0"
+pybotx = ">=0.67.1"
+pybotx-smartapp-rpc = ">=0.9.0"
 
 fastapi = "~0.70.0"
 uvicorn = "~0.13.4"

frontend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@smartapp/feature-smartapp",
-  "version": "1.2.6",
+  "version": "1.3.0",
   "private": true,
   "homepage": ".",
   "dependencies": {