87240238cc
OpenAI gpt-4o-mini-tts (female voice nova by default; TTS_MODEL/TTS_VOICE) renders OGG/Opus, sent with sendVoice in order with rendered output. Up to 4500 characters per call, split into 1500-character parts at paragraph/sentence/word boundaries; all parts are synthesized before any is sent, and API errors come back to the agent as text with the key hidden. On whenever OPENAI_API_KEY is set.
60 lines
3.4 KiB
C#
60 lines
3.4 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);
|
|
}
|
|
|
|
/// <summary>Send OGG/Opus audio as a voice note, in order with rendered output (the <c>voice</c> tool). Returns the message id.</summary>
|
|
public Task<int> SendVoiceAsync(byte[] ogg, string fileName, CancellationToken cancellationToken)
|
|
{
|
|
ArgumentNullException.ThrowIfNull(ogg);
|
|
return renderer.RunInOrderAsync(async ct =>
|
|
{
|
|
var result = await sender.SendVoiceAsync(renderer.DeliveryChatId, ogg, fileName, ct).ConfigureAwait(false);
|
|
return result.MessageId ?? throw new ChatDeliveryException($"Telegram refused the voice message: {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));
|
|
}
|