92a0061fdd
While on, the admin's updates are routed as the target user's (allow-list, chat, workspace, session, settings, jobs) and the target chat's output goes to the admin's chat. The target's own updates are dropped with a notice that an admin is working with their account. In memory; /impersonate 0 stops.
49 lines
2.8 KiB
C#
49 lines
2.8 KiB
C#
using System.Globalization;
|
|
using Volcanic.AgenticCore.Abstractions.Ui;
|
|
using Volcanic.AgenticCore.Telegram.Rendering;
|
|
|
|
namespace Volcanic.AgenticCore.Telegram.Chats;
|
|
|
|
/// <summary>
|
|
/// One chat's <see cref="IChatChannel"/>. Every delivery goes through the chat renderer's queue
|
|
/// (<see cref="ChatRenderer.RunInOrderAsync{T}"/>), so it can't overtake rendered output, and works while no run is active.
|
|
/// </summary>
|
|
public sealed class TelegramChatChannel(TelegramSender sender, ChatRenderer renderer) : IChatChannel
|
|
{
|
|
private static readonly HashSet<string> PhotoExtensions = new(StringComparer.OrdinalIgnoreCase) { ".jpg", ".jpeg", ".png", ".webp" };
|
|
|
|
public ChatChannelLimits Limits { get; } = new(TelegramLimits.MaxPhotoBytes, TelegramLimits.MaxDocumentBytes, TelegramLimits.MaxCaptionLength);
|
|
|
|
public async Task<ChatDelivery> SendTextAsync(string markdown, CancellationToken cancellationToken)
|
|
{
|
|
ArgumentNullException.ThrowIfNull(markdown);
|
|
var (first, complete) = await renderer.ReplyInOrderAsync(markdown, cancellationToken).ConfigureAwait(false);
|
|
if (!complete) throw new ChatDeliveryException("Telegram did not accept the message.");
|
|
return new ChatDelivery(null, first?.ToString(CultureInfo.InvariantCulture));
|
|
}
|
|
|
|
public Task<ChatDelivery> SendFileAsync(ChatFile file, CancellationToken cancellationToken)
|
|
{
|
|
ArgumentNullException.ThrowIfNull(file);
|
|
return renderer.RunInOrderAsync(async ct =>
|
|
{
|
|
var asPhoto = file.Kind == ChatFileKind.Photo || (file.Kind == ChatFileKind.Auto && LooksLikePhoto(file.Path));
|
|
var result = await sender.SendFileAsync(renderer.DeliveryChatId, file.Path, asPhoto, file.Caption, ct).ConfigureAwait(false);
|
|
if (result.MessageId is { } id) return Delivered(asPhoto, id);
|
|
if (asPhoto && file.Kind == ChatFileKind.Auto && result.PhotoRejected)
|
|
{
|
|
// Telegram refuses some images as photos (dimensions, aspect ratio): send the file as a document instead.
|
|
result = await sender.SendFileAsync(renderer.DeliveryChatId, file.Path, asPhoto: false, file.Caption, ct).ConfigureAwait(false);
|
|
if (result.MessageId is { } documentId) return Delivered(false, documentId);
|
|
}
|
|
throw new ChatDeliveryException($"Telegram refused the file: {result.Error}");
|
|
}, cancellationToken);
|
|
}
|
|
|
|
private bool LooksLikePhoto(string path) =>
|
|
PhotoExtensions.Contains(Path.GetExtension(path)) && new FileInfo(path) is { Exists: true } info && info.Length <= Limits.MaxPhotoBytes;
|
|
|
|
private static ChatDelivery Delivered(bool asPhoto, int messageId) =>
|
|
new(asPhoto ? ChatFileKind.Photo : ChatFileKind.Document, messageId.ToString(CultureInfo.InvariantCulture));
|
|
}
|