Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 644749929e | |||
| 8528b814d8 | |||
| d60bef7070 | |||
| 7556b3d638 |
@@ -17,8 +17,6 @@ internal sealed class CommandsRegistry
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
public CommandsRegistry Map<TPage>(string commandTemplate, bool publish = false, string? description = null) where TPage : Page
|
public CommandsRegistry Map<TPage>(string commandTemplate, bool publish = false, string? description = null) where TPage : Page
|
||||||
{
|
{
|
||||||
var pattern = ToRegex(commandTemplate);
|
|
||||||
|
|
||||||
return Map(commandTemplate, (ctx, args, ct) => ctx.Navigation.GoToAsync<TPage>(ctx, ct), publish, description);
|
return Map(commandTemplate, (ctx, args, ct) => ctx.Navigation.GoToAsync<TPage>(ctx, ct), publish, description);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -67,15 +65,25 @@ internal sealed class CommandsRegistry
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
private static Regex ToRegex(string template)
|
private static Regex ToRegex(string template)
|
||||||
{
|
{
|
||||||
var escaped = Regex.Escape(template)
|
// Заменяем все {name} и {name?} на регулярные группы
|
||||||
.Replace("\\{", "{").Replace("\\}", "}");
|
var pattern = "^" + Regex.Replace(template, @"\s*\{(\w+)(\?)?\}", m =>
|
||||||
|
|
||||||
var pattern = "^" + Regex.Replace(escaped, @"\{(\w+)(\?)?\}", m =>
|
|
||||||
{
|
{
|
||||||
var name = m.Groups[1].Value;
|
var name = m.Groups[1].Value;
|
||||||
var optional = m.Groups[2].Success;
|
var optional = m.Groups[2].Success;
|
||||||
return optional ? $"(?<{name}>\\S+)?" : $"(?<{name}>\\S+)";
|
|
||||||
}) + "$";
|
var argPattern = $"(?:\"(?<{name}>[^\"]+)\"|(?<{name}>\\S+))";
|
||||||
|
|
||||||
|
if (optional)
|
||||||
|
{
|
||||||
|
// необязательный параметр: пробел + значение целиком необязательны
|
||||||
|
return $"(?:\\s+{argPattern})?";
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
// обязательный параметр: пробел обязателен
|
||||||
|
return $"\\s+{argPattern}";
|
||||||
|
}
|
||||||
|
}) + "\\s*$"; // допускаем пробелы/переносы в конце
|
||||||
|
|
||||||
return new Regex(pattern, RegexOptions.Compiled | RegexOptions.IgnoreCase);
|
return new Regex(pattern, RegexOptions.Compiled | RegexOptions.IgnoreCase);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -10,6 +10,7 @@ using System.Linq;
|
|||||||
using System.Threading;
|
using System.Threading;
|
||||||
using System.Threading.Tasks;
|
using System.Threading.Tasks;
|
||||||
using Telegram.Bot;
|
using Telegram.Bot;
|
||||||
|
using Telegram.Bot.Exceptions;
|
||||||
using Telegram.Bot.Types;
|
using Telegram.Bot.Types;
|
||||||
using Telegram.Bot.Types.Enums;
|
using Telegram.Bot.Types.Enums;
|
||||||
using Telegram.Bot.Types.ReplyMarkups;
|
using Telegram.Bot.Types.ReplyMarkups;
|
||||||
@@ -66,11 +67,24 @@ public sealed class TelegramAdapter : IMessangerAdapterSetup
|
|||||||
var mapped = TelegramUpdateMapper.Map(MessengerType, update, _client);
|
var mapped = TelegramUpdateMapper.Map(MessengerType, update, _client);
|
||||||
if (mapped is not null)
|
if (mapped is not null)
|
||||||
await onUpdate(mapped);
|
await onUpdate(mapped);
|
||||||
|
if (update.CallbackQuery is not null)
|
||||||
|
{
|
||||||
|
await _.AnswerCallbackQuery(update.CallbackQuery.Id);
|
||||||
|
}
|
||||||
},
|
},
|
||||||
|
|
||||||
errorHandler: async (_, ex, ct2) =>
|
errorHandler: async (_, ex, ct2) =>
|
||||||
{
|
{
|
||||||
_logger.Log(LogLevel.Warn, $"{MessengerType} error.", ex);
|
_logger.Log(LogLevel.Warn, $"{MessengerType} error.", ex);
|
||||||
|
|
||||||
|
if (ex is ApiRequestException apiEx)
|
||||||
|
{
|
||||||
|
if (apiEx.ErrorCode == 409)
|
||||||
|
{
|
||||||
|
_logger.Log(LogLevel.Critical, $"{MessengerType} остановлен.");
|
||||||
|
await _.Close(ct2);
|
||||||
|
}
|
||||||
|
}
|
||||||
await Task.CompletedTask;
|
await Task.CompletedTask;
|
||||||
},
|
},
|
||||||
|
|
||||||
|
|||||||
@@ -54,8 +54,8 @@ public sealed class DetailsPage : StatefullPage<string>
|
|||||||
await ctx.Navigation.GoToAsync<FilesPage>(ctx, ct);
|
await ctx.Navigation.GoToAsync<FilesPage>(ctx, ct);
|
||||||
}
|
}
|
||||||
|
|
||||||
internal static string Command => "/create_request {title}";
|
internal static string Command => "/create_request {title?}";
|
||||||
internal static string CommandDescription => "создание заявки /create_request {title";
|
internal static string CommandDescription => "создание заявки /create_request {title}";
|
||||||
internal static CommandHandler CommandHandler = async (ctx, args, ct) =>
|
internal static CommandHandler CommandHandler = async (ctx, args, ct) =>
|
||||||
{
|
{
|
||||||
string? title = "";
|
string? title = "";
|
||||||
|
|||||||
162
TZ.md
162
TZ.md
@@ -1,162 +0,0 @@
|
|||||||
# Техническое задание
|
|
||||||
## Проект: BotPages
|
|
||||||
|
|
||||||
### 1. Общая информация
|
|
||||||
- **Название:** BotPages
|
|
||||||
- **Цель:** Создание библиотеки (NuGet‑пакета) для управления страницами в ботах (Telegram, VK, Discord, WhatsApp и др.), позволяющей строить логику без жёсткой привязки к конкретному API.
|
|
||||||
- **Платформа:** .NET 8
|
|
||||||
- **Артефакты:**
|
|
||||||
- `BotPages.Core` — ядро, независимое от транспорта.
|
|
||||||
- `BotPages.Telegram` — адаптер для Telegram.
|
|
||||||
- В будущем: адаптеры для VK, Discord, WhatsApp.
|
|
||||||
- **Демо:** `Demo.exe` — демонстрация работы (создание заявки через несколько страниц, кнопки, файлы).
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 2. Основные понятия
|
|
||||||
- **Page** — класс, отвечающий за состояние экрана бота.
|
|
||||||
- `Page` — базовый класс.
|
|
||||||
- `Page<TArguments>` — страница с аргументами.
|
|
||||||
- **Контекст:**
|
|
||||||
- `UserContext` — данные пользователя (UserId, MessengerType).
|
|
||||||
- `ChatContext` — данные чата (ChatId, Title, ThreadId?, ленивое обновление).
|
|
||||||
- `PageContext` — объединяет UserContext, ChatContext, состояние, навигацию, файлы.
|
|
||||||
- **Состояние:**
|
|
||||||
- `IStateStorage` — универсальный интерфейс хранения.
|
|
||||||
- Базовая реализация: InMemory.
|
|
||||||
- Ключ: `CompositeSessionKey(MessengerType:string, ChatId, UserId)`.
|
|
||||||
- История состояний: опционально (None, LastN, TimeWindow, Full).
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 3. Жизненный цикл страницы
|
|
||||||
- Методы (все async, с `CancellationToken`):
|
|
||||||
- `OnEnter(ctx)` — вход.
|
|
||||||
- `OnUpdate(ctx, update)` — общий обработчик.
|
|
||||||
- `OnText(ctx, text)` — текстовые сообщения.
|
|
||||||
- `OnFile(ctx, file)` — файлы.
|
|
||||||
- `OnButton(ctx, action)` — кнопки.
|
|
||||||
- `OnLeave(ctx)` — выход.
|
|
||||||
- `OnError(ctx, exception)` — ошибки.
|
|
||||||
- `OnTimeout(ctx, timeoutInfo)` — таймауты.
|
|
||||||
- Прогресс фоновых операций:
|
|
||||||
- `StartProgress()`, `UpdateProgress(percent)` + событие обновления.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 4. Навигация
|
|
||||||
- Императивный API:
|
|
||||||
```csharp
|
|
||||||
ctx.GoTo<CitySelectionPage>();
|
|
||||||
ctx.GoTo<ConfirmationPage>(new ConfirmationArgs { PhotoId = photoId });
|
|
||||||
ctx.GoTo<DetailsPage>(args => { args.Photo = photoId; });
|
|
||||||
ctx.ReplaceWith<MainPage>();
|
|
||||||
ctx.Back();
|
|
||||||
```
|
|
||||||
- Декларативный роутинг:
|
|
||||||
- Атрибуты `[Route("order/create")]`.
|
|
||||||
- Реестр `routes.Map<CreateOrderPage>("order/create")`.
|
|
||||||
- Проверка конфликтов при старте.
|
|
||||||
- Стек навигации: отдельный пакет `BotPages.Navigation.Stack`.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 5. Команды
|
|
||||||
- Команды имеют приоритет над событиями страниц.
|
|
||||||
- Поддержка шаблонов:
|
|
||||||
```csharp
|
|
||||||
app.Commands.Map("/start").To<WelcomePage>();
|
|
||||||
app.Commands.Map("/open {page} {id?}")
|
|
||||||
.To(ctx => ctx.GoToByName(page, new { id }));
|
|
||||||
```
|
|
||||||
- Возможность указать страницу, которая открывается при вводе команды.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 6. Файлы
|
|
||||||
- **FileDescriptor:**
|
|
||||||
- `Id`, `Name`, `Extension`, `Size`, `Mime`, `Type(enum)`, `SourceMessenger`, `GetStreamAsync()`, `Checksum?`.
|
|
||||||
- Отправка:
|
|
||||||
```csharp
|
|
||||||
await ctx.Chat.SendFileAsync(file, caption: "Документ");
|
|
||||||
await ctx.Chat.Files.BeginAlbum().Add(file1).Add(file2).SendAsync();
|
|
||||||
```
|
|
||||||
- Альбомы, сжатие — на уровне адаптера.
|
|
||||||
- Метаданные файлов — временно в контексте, экспорт в состояние вручную.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 7. Адаптеры
|
|
||||||
- Интерфейс `IMessengerAdapter`:
|
|
||||||
- `SendMessage`, `EditMessage`, `DeleteMessage`, `SendFile`, `SendAlbum`.
|
|
||||||
- `ReceiveUpdate`.
|
|
||||||
- `GetChat`, `GetFileStream`.
|
|
||||||
- `AnswerCallback`, `SetTypingIndicator`.
|
|
||||||
- Telegram: первая реализация.
|
|
||||||
- Поддержка **Webhook** и **Polling** (выбор конфигом).
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 8. Capabilities
|
|
||||||
- В `ChatContext.Capabilities`:
|
|
||||||
- `SupportsInlineButtons`, `SupportsReplyButtons`, `SupportsAlbums`, `SupportsFormattingMarkdown`, `SupportsFormattingHtml`, `MaxMessageLength`.
|
|
||||||
- Разработчик может проверять возможности.
|
|
||||||
- Адаптер всегда деградирует и логирует `Warn`.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 9. Логирование
|
|
||||||
- Уровни: `Info`, `Warn`, `Critical`.
|
|
||||||
- Примеры:
|
|
||||||
- Info: вход на страницу, прогресс.
|
|
||||||
- Warn: деградация возможностей.
|
|
||||||
- Critical: падение хранилища.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 10. Middleware
|
|
||||||
- Интерфейс:
|
|
||||||
```csharp
|
|
||||||
public interface IUpdateMiddleware
|
|
||||||
{
|
|
||||||
Task InvokeAsync(UpdateContext ctx, Func<Task> next, CancellationToken ct);
|
|
||||||
}
|
|
||||||
```
|
|
||||||
- Пример:
|
|
||||||
```csharp
|
|
||||||
app.AddMiddleware<LoggingMiddleware>();
|
|
||||||
app.AddMiddleware<ErrorMiddleware>(params);
|
|
||||||
```
|
|
||||||
- Порядок регистрации = порядок выполнения.
|
|
||||||
- Middleware только для входящих обновлений.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 11. Дефолтная страница
|
|
||||||
- Конфигурация:
|
|
||||||
```csharp
|
|
||||||
app.UseDefaultPage<WelcomePage>();
|
|
||||||
```
|
|
||||||
- Одна дефолтная страница для всех мессенджеров.
|
|
||||||
- Условия не нужны.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 12. Demo.exe
|
|
||||||
- Сценарий: создание заявки.
|
|
||||||
- Страницы:
|
|
||||||
1. **StartPage** — приветствие, кнопка «Создать заявку».
|
|
||||||
2. **TitlePage** — ввод текста.
|
|
||||||
3. **DetailsPage** — доп. поля, inline/reply кнопки.
|
|
||||||
4. **FilesPage** — загрузка файлов, просмотр списка.
|
|
||||||
5. **ConfirmPage** — подтверждение заявки.
|
|
||||||
6. **SubmitPage** — отправка, итоговое сообщение.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### 13. TODO (будущие версии)
|
|
||||||
- Поддержка модальных страниц со стеком.
|
|
||||||
- Расширенные Capabilities (rate limits, threads).
|
|
||||||
- View‑DSL как надстройка над контекстом.
|
|
||||||
- Cross‑transport identity.
|
|
||||||
- Расширенные таймауты и политики отката.
|
|
||||||
Reference in New Issue
Block a user