From 3dbe0b76989aed2c8e1f87861f21034689caf187 Mon Sep 17 00:00:00 2001
From: Leonid Pershin <lpershin@syntellect.ru>
Date: Fri, 31 Jul 2026 21:20:25 +0300
Subject: [PATCH] Enhance TelegramNotifier to manage previous alerts and
 improve notification clarity

Updated the TelegramNotifier to delete previous alert messages before sending new notifications, ensuring that only the latest alert is visible to subscribers. Introduced a new property in TelegramSubscriber to track the latest alert message ID. Adjusted related tests to verify the new alert management behavior and updated documentation to reflect these changes, enhancing the overall user experience in message handling.
---
 .../Notifications/TelegramNotifier.cs         |   43 +-
 .../Notifications/TelegramSubscriber.cs       |   10 +
 ...731181609_TelegramAlertMessage.Designer.cs | 1602 +++++++++++++++++
 .../20260731181609_TelegramAlertMessage.cs    |   27 +
 .../Migrations/AppDbContextModelSnapshot.cs   |    3 +
 .../Notifications/TelegramNotifierTests.cs    |   57 +
 docs/telegram-bot.md                          |   15 +-
 7 files changed, 1739 insertions(+), 18 deletions(-)
 create mode 100644 backend/src/TeleWave.Infrastructure/Migrations/20260731181609_TelegramAlertMessage.Designer.cs
 create mode 100644 backend/src/TeleWave.Infrastructure/Migrations/20260731181609_TelegramAlertMessage.cs

diff --git a/backend/src/TeleWave.Application/Notifications/TelegramNotifier.cs b/backend/src/TeleWave.Application/Notifications/TelegramNotifier.cs
index 4595d46..f3bc59a 100644
--- a/backend/src/TeleWave.Application/Notifications/TelegramNotifier.cs
+++ b/backend/src/TeleWave.Application/Notifications/TelegramNotifier.cs
@@ -162,7 +162,13 @@ public sealed class TelegramNotifier(IAppDbContext dbContext, ITelegramApi api)
             .Select(s => s.Name)
             .FirstOrDefaultAsync(cancellationToken);
 
-    /// <summary>Шлёт всем, кто подписан на этот канал и вид. Возвращает число доставленных сообщений.</summary>
+    /// <summary>
+    /// Шлёт всем, кто подписан на этот канал и вид, и убирает своё предыдущее оповещение.
+    /// Возвращает число доставленных сообщений.
+    ///
+    /// Подписчики читаются с отслеживанием: идентификатор нового сообщения тут же ложится на них,
+    /// а сохраняет его тот, кто вызвал рассылку, — одной транзакцией с границей разобранного.
+    /// </summary>
     private async Task<int> SendAsync(
         TelegramSettings settings,
         Guid channelId,
@@ -171,26 +177,35 @@ public sealed class TelegramNotifier(IAppDbContext dbContext, ITelegramApi api)
         CancellationToken cancellationToken
     )
     {
-        var chats = await (
-            from subscription in dbContext.TelegramSubscriptions
-            join subscriber in dbContext.TelegramSubscribers
-                on subscription.SubscriberId equals subscriber.Id
-            where
-                subscription.ChannelId == channelId
-                && subscription.Kind == kind
-                && !subscriber.IsStopped
-            select subscriber.ChatId
-        )
-            .Distinct()
+        var subscribers = await dbContext
+            .TelegramSubscribers.Where(subscriber =>
+                !subscriber.IsStopped
+                && subscriber.Subscriptions.Any(s => s.ChannelId == channelId && s.Kind == kind)
+            )
             .ToListAsync(cancellationToken);
 
         var sent = 0;
-        foreach (var chatId in chats)
+        foreach (var subscriber in subscribers)
         {
             // Один недоступный чат (бота заблокировали) не должен срывать рассылку остальным.
             try
             {
-                await api.SendMessageAsync(settings, chatId, text, null, cancellationToken);
+                if (subscriber.AlertMessageId is { } previous)
+                    await api.DeleteMessageAsync(
+                        settings,
+                        subscriber.ChatId,
+                        previous,
+                        cancellationToken
+                    );
+
+                var messageId = await api.SendMessageAsync(
+                    settings,
+                    subscriber.ChatId,
+                    text,
+                    null,
+                    cancellationToken
+                );
+                subscriber.SetAlertMessage(messageId);
                 sent++;
             }
             catch (Exception exception) when (exception is not OperationCanceledException)
diff --git a/backend/src/TeleWave.Domain/Notifications/TelegramSubscriber.cs b/backend/src/TeleWave.Domain/Notifications/TelegramSubscriber.cs
index eff9aec..4aabff2 100644
--- a/backend/src/TeleWave.Domain/Notifications/TelegramSubscriber.cs
+++ b/backend/src/TeleWave.Domain/Notifications/TelegramSubscriber.cs
@@ -46,6 +46,14 @@ public class TelegramSubscriber
     /// </summary>
     public long? NoticeMessageId { get; private set; }
 
+    /// <summary>
+    /// Последнее оповещение рассылки («сейчас в эфире», «через 5 минут»). Живёт до следующего:
+    /// оповещение — это отметка о том, что идёт сейчас, и вчерашние «сейчас в эфире» в чате
+    /// превращают его в ленту неправды. Отдельно от <see cref="NoticeMessageId"/> намеренно:
+    /// рассылка приходит сама и не должна сносить программу, которую зритель только что запросил.
+    /// </summary>
+    public long? AlertMessageId { get; private set; }
+
     public IReadOnlyList<TelegramSubscription> Subscriptions => _subscriptions;
 
     private TelegramSubscriber() { }
@@ -82,6 +90,8 @@ public class TelegramSubscriber
 
     public void SetNoticeMessage(long? messageId) => NoticeMessageId = messageId;
 
+    public void SetAlertMessage(long? messageId) => AlertMessageId = messageId;
+
     public void Stop() => IsStopped = true;
 
     public void Resume() => IsStopped = false;
diff --git a/backend/src/TeleWave.Infrastructure/Migrations/20260731181609_TelegramAlertMessage.Designer.cs b/backend/src/TeleWave.Infrastructure/Migrations/20260731181609_TelegramAlertMessage.Designer.cs
new file mode 100644
index 0000000..8a1a602
--- /dev/null
+++ b/backend/src/TeleWave.Infrastructure/Migrations/20260731181609_TelegramAlertMessage.Designer.cs
@@ -0,0 +1,1602 @@
+// <auto-generated />
+using System;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
+using TeleWave.Infrastructure.Persistence;
+
+#nullable disable
+
+namespace TeleWave.Infrastructure.Migrations
+{
+    [DbContext(typeof(AppDbContext))]
+    [Migration("20260731181609_TelegramAlertMessage")]
+    partial class TelegramAlertMessage
+    {
+        /// <inheritdoc />
+        protected override void BuildTargetModel(ModelBuilder modelBuilder)
+        {
+#pragma warning disable 612, 618
+            modelBuilder
+                .HasAnnotation("ProductVersion", "10.0.10")
+                .HasAnnotation("Relational:MaxIdentifierLength", 63);
+
+            NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
+
+            modelBuilder.Entity("Microsoft.AspNetCore.Identity.IdentityRoleClaim<System.Guid>", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<string>("ClaimType")
+                        .HasColumnType("text");
+
+                    b.Property<string>("ClaimValue")
+                        .HasColumnType("text");
+
+                    b.Property<Guid>("RoleId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("RoleId");
+
+                    b.ToTable("AspNetRoleClaims", (string)null);
+                });
+
+            modelBuilder.Entity("Microsoft.AspNetCore.Identity.IdentityUserClaim<System.Guid>", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer");
+
+                    NpgsqlPropertyBuilderExtensions.UseIdentityByDefaultColumn(b.Property<int>("Id"));
+
+                    b.Property<string>("ClaimType")
+                        .HasColumnType("text");
+
+                    b.Property<string>("ClaimValue")
+                        .HasColumnType("text");
+
+                    b.Property<Guid>("UserId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("UserId");
+
+                    b.ToTable("AspNetUserClaims", (string)null);
+                });
+
+            modelBuilder.Entity("Microsoft.AspNetCore.Identity.IdentityUserLogin<System.Guid>", b =>
+                {
+                    b.Property<string>("LoginProvider")
+                        .HasColumnType("text");
+
+                    b.Property<string>("ProviderKey")
+                        .HasColumnType("text");
+
+                    b.Property<string>("ProviderDisplayName")
+                        .HasColumnType("text");
+
+                    b.Property<Guid>("UserId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("LoginProvider", "ProviderKey");
+
+                    b.HasIndex("UserId");
+
+                    b.ToTable("AspNetUserLogins", (string)null);
+                });
+
+            modelBuilder.Entity("Microsoft.AspNetCore.Identity.IdentityUserRole<System.Guid>", b =>
+                {
+                    b.Property<Guid>("UserId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid>("RoleId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("UserId", "RoleId");
+
+                    b.HasIndex("RoleId");
+
+                    b.ToTable("AspNetUserRoles", (string)null);
+                });
+
+            modelBuilder.Entity("Microsoft.AspNetCore.Identity.IdentityUserToken<System.Guid>", b =>
+                {
+                    b.Property<Guid>("UserId")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("LoginProvider")
+                        .HasColumnType("text");
+
+                    b.Property<string>("Name")
+                        .HasColumnType("text");
+
+                    b.Property<string>("Value")
+                        .HasColumnType("text");
+
+                    b.HasKey("UserId", "LoginProvider", "Name");
+
+                    b.ToTable("AspNetUserTokens", (string)null);
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Auth.RefreshToken", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<DateTimeOffset>("ExpiresAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("ReplacedByTokenHash")
+                        .HasColumnType("text");
+
+                    b.Property<DateTimeOffset?>("RevokedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("TokenHash")
+                        .IsRequired()
+                        .HasColumnType("text");
+
+                    b.Property<Guid>("UserId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("TokenHash")
+                        .IsUnique();
+
+                    b.HasIndex("UserId");
+
+                    b.ToTable("RefreshTokens");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Broadcast.BumperAsset", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid?>("BackgroundAssetId")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<Guid>("MediaAssetId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid?>("PosterShowId")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("RenderedLinesJson")
+                        .IsRequired()
+                        .HasColumnType("jsonb");
+
+                    b.Property<string>("Signature")
+                        .IsRequired()
+                        .HasMaxLength(128)
+                        .HasColumnType("character varying(128)");
+
+                    b.Property<Guid>("TemplateId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid>("VariantId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("MediaAssetId");
+
+                    b.HasIndex("Signature")
+                        .IsUnique();
+
+                    b.ToTable("BumperAssets");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Broadcast.BumperTemplate", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("AccentColor")
+                        .IsRequired()
+                        .HasMaxLength(32)
+                        .HasColumnType("character varying(32)");
+
+                    b.Property<double?>("AudioDurationSeconds")
+                        .HasColumnType("double precision");
+
+                    b.Property<string>("AudioExtension")
+                        .HasMaxLength(16)
+                        .HasColumnType("character varying(16)");
+
+                    b.Property<string>("BackgroundColor")
+                        .IsRequired()
+                        .HasMaxLength(32)
+                        .HasColumnType("character varying(32)");
+
+                    b.Property<string>("BackgroundColor2")
+                        .IsRequired()
+                        .HasMaxLength(32)
+                        .HasColumnType("character varying(32)");
+
+                    b.Property<Guid?>("BackgroundImageId")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<int>("Font")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasMaxLength(64)
+                        .HasColumnType("character varying(64)");
+
+                    b.Property<int>("Revision")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("TextColor")
+                        .IsRequired()
+                        .HasMaxLength(32)
+                        .HasColumnType("character varying(32)");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("Name");
+
+                    b.ToTable("BumperTemplates");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Broadcast.BumperTextVariant", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("Background")
+                        .HasColumnType("integer");
+
+                    b.Property<Guid?>("BackgroundClipShowId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid>("BumperTemplateId")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasMaxLength(64)
+                        .HasColumnType("character varying(64)");
+
+                    b.Property<int>("Position")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("Trigger")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("Weight")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer")
+                        .HasDefaultValue(1);
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("BumperTemplateId", "Position");
+
+                    b.ToTable("BumperTextVariants");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Broadcast.Channel", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<double>("AnalogFilterStrength")
+                        .HasColumnType("double precision");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<TimeOnly>("DayStartTime")
+                        .HasColumnType("time without time zone");
+
+                    b.Property<DateTimeOffset>("EpochUtc")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<Guid?>("FillerAssetId")
+                        .HasColumnType("uuid");
+
+                    b.Property<bool>("IsEnabled")
+                        .HasColumnType("boolean");
+
+                    b.Property<int>("LogoCorner")
+                        .HasColumnType("integer");
+
+                    b.Property<Guid?>("LogoImageId")
+                        .HasColumnType("uuid");
+
+                    b.Property<double>("LogoOpacity")
+                        .HasColumnType("double precision");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<int?>("Number")
+                        .HasColumnType("integer");
+
+                    b.Property<bool>("ShowClock")
+                        .HasColumnType("boolean");
+
+                    b.Property<string>("Slug")
+                        .IsRequired()
+                        .HasMaxLength(128)
+                        .HasColumnType("character varying(128)");
+
+                    b.Property<Guid?>("TemplateId")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("UtcOffsetMinutes")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("Number")
+                        .IsUnique()
+                        .HasFilter("\"Number\" IS NOT NULL");
+
+                    b.HasIndex("Slug")
+                        .IsUnique();
+
+                    b.ToTable("Channels");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Broadcast.ScheduleEntry", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid?>("BumperVariantId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid>("ChannelId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid?>("CollectionId")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateTimeOffset>("EndsAtUtc")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<int?>("EpisodeIndex")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("Kind")
+                        .HasColumnType("integer");
+
+                    b.Property<Guid>("MediaAssetId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid?>("ShowId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid?>("SlotId")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateTimeOffset>("StartsAtUtc")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("TraceJson")
+                        .HasColumnType("jsonb");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("ChannelId", "EndsAtUtc");
+
+                    b.HasIndex("ChannelId", "StartsAtUtc");
+
+                    b.HasIndex("ChannelId", "ShowId", "StartsAtUtc");
+
+                    b.ToTable("ScheduleEntries");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Images.Image", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("Category")
+                        .HasColumnType("integer");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("FileExtension")
+                        .IsRequired()
+                        .HasMaxLength(16)
+                        .HasColumnType("character varying(16)");
+
+                    b.Property<string>("OriginalFileName")
+                        .HasMaxLength(512)
+                        .HasColumnType("character varying(512)");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("Category", "CreatedAt");
+
+                    b.ToTable("Images");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.Collection", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("Description")
+                        .HasMaxLength(2048)
+                        .HasColumnType("character varying(2048)");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<Guid?>("PosterImageId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Collections");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.CollectionItem", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid>("CollectionId")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("Position")
+                        .HasColumnType("integer");
+
+                    b.Property<Guid>("ShowId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("ShowId");
+
+                    b.HasIndex("CollectionId", "Position");
+
+                    b.HasIndex("CollectionId", "ShowId")
+                        .IsUnique();
+
+                    b.ToTable("CollectionItems");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.Genre", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<bool>("IsSystem")
+                        .HasColumnType("boolean");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasMaxLength(128)
+                        .HasColumnType("character varying(128)");
+
+                    b.Property<string>("Slug")
+                        .IsRequired()
+                        .HasMaxLength(64)
+                        .HasColumnType("character varying(64)");
+
+                    b.Property<int>("SortOrder")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("Slug")
+                        .IsUnique();
+
+                    b.ToTable("Genres");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.GenreAlias", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid>("GenreId")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("Value")
+                        .IsRequired()
+                        .HasMaxLength(128)
+                        .HasColumnType("character varying(128)");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("GenreId");
+
+                    b.HasIndex("Value")
+                        .IsUnique();
+
+                    b.ToTable("GenreAliases");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.Show", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<int?>("Audience")
+                        .HasColumnType("integer");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("Description")
+                        .HasMaxLength(2048)
+                        .HasColumnType("character varying(2048)");
+
+                    b.Property<string>("FranchiseExternalId")
+                        .HasMaxLength(64)
+                        .HasColumnType("character varying(64)");
+
+                    b.Property<string>("FranchiseName")
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<int>("Kind")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("MetadataExternalId")
+                        .HasMaxLength(64)
+                        .HasColumnType("character varying(64)");
+
+                    b.Property<string>("MetadataProvider")
+                        .HasMaxLength(16)
+                        .HasColumnType("character varying(16)");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<string>("OriginalName")
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<Guid?>("PosterImageId")
+                        .HasColumnType("uuid");
+
+                    b.Property<int?>("Year")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Shows");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.ShowEpisode", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateOnly?>("AirDate")
+                        .HasColumnType("date");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<int?>("Episode")
+                        .HasColumnType("integer");
+
+                    b.Property<Guid>("MediaAssetId")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("Overview")
+                        .HasMaxLength(4096)
+                        .HasColumnType("character varying(4096)");
+
+                    b.Property<int>("Position")
+                        .HasColumnType("integer");
+
+                    b.Property<int?>("Season")
+                        .HasColumnType("integer");
+
+                    b.Property<Guid>("ShowId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid?>("StillImageId")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("Title")
+                        .HasMaxLength(512)
+                        .HasColumnType("character varying(512)");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("MediaAssetId");
+
+                    b.HasIndex("ShowId", "Position");
+
+                    b.ToTable("ShowEpisode");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.ShowGenre", b =>
+                {
+                    b.Property<Guid>("ShowId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid>("GenreId")
+                        .HasColumnType("uuid");
+
+                    b.Property<bool>("IsPrimary")
+                        .HasColumnType("boolean");
+
+                    b.HasKey("ShowId", "GenreId");
+
+                    b.HasIndex("GenreId");
+
+                    b.ToTable("ShowGenres");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Media.MediaAsset", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("AudioCodec")
+                        .HasMaxLength(32)
+                        .HasColumnType("character varying(32)");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<TimeSpan?>("Duration")
+                        .HasColumnType("interval");
+
+                    b.Property<string>("ErrorMessage")
+                        .HasMaxLength(2048)
+                        .HasColumnType("character varying(2048)");
+
+                    b.Property<int?>("Height")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("OriginalExtension")
+                        .IsRequired()
+                        .HasMaxLength(16)
+                        .HasColumnType("character varying(16)");
+
+                    b.Property<string>("OriginalFileName")
+                        .IsRequired()
+                        .HasMaxLength(512)
+                        .HasColumnType("character varying(512)");
+
+                    b.Property<TimeSpan?>("ProcessingDuration")
+                        .HasColumnType("interval");
+
+                    b.Property<DateTimeOffset?>("ProcessingStartedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("RelativePath")
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<int?>("SegmentCount")
+                        .HasColumnType("integer");
+
+                    b.Property<int?>("SegmentSeconds")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("Source")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("Status")
+                        .HasColumnType("integer");
+
+                    b.Property<DateTimeOffset>("UpdatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("VideoCodec")
+                        .HasMaxLength(32)
+                        .HasColumnType("character varying(32)");
+
+                    b.Property<int?>("Width")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("CreatedAt");
+
+                    b.HasIndex("Status");
+
+                    b.ToTable("MediaAssets");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Notifications.TelegramLinkCode", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("Code")
+                        .IsRequired()
+                        .HasMaxLength(64)
+                        .HasColumnType("character varying(64)");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<DateTimeOffset>("ExpiresAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<DateTimeOffset?>("UsedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<Guid>("UserId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("Code")
+                        .IsUnique();
+
+                    b.ToTable("TelegramLinkCodes");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Notifications.TelegramSettings", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("BotToken")
+                        .HasMaxLength(128)
+                        .HasColumnType("character varying(128)");
+
+                    b.Property<string>("BotUsername")
+                        .HasMaxLength(64)
+                        .HasColumnType("character varying(64)");
+
+                    b.Property<bool>("IsEnabled")
+                        .HasColumnType("boolean");
+
+                    b.Property<DateTimeOffset?>("LastContactAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("LastError")
+                        .HasMaxLength(512)
+                        .HasColumnType("character varying(512)");
+
+                    b.Property<long>("LastUpdateId")
+                        .HasColumnType("bigint");
+
+                    b.Property<DateTimeOffset?>("NotifiedUntil")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("ProxyHost")
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<int>("ProxyKind")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("ProxyPassword")
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<int?>("ProxyPort")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("ProxyUsername")
+                        .HasMaxLength(128)
+                        .HasColumnType("character varying(128)");
+
+                    b.Property<int>("Transport")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("WebhookSecret")
+                        .HasMaxLength(128)
+                        .HasColumnType("character varying(128)");
+
+                    b.Property<string>("WebhookUrl")
+                        .HasMaxLength(512)
+                        .HasColumnType("character varying(512)");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("TelegramSettings");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Notifications.TelegramSubscriber", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<long?>("AlertMessageId")
+                        .HasColumnType("bigint");
+
+                    b.Property<long>("ChatId")
+                        .HasColumnType("bigint");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("DisplayName")
+                        .HasMaxLength(128)
+                        .HasColumnType("character varying(128)");
+
+                    b.Property<bool>("IsStopped")
+                        .HasColumnType("boolean");
+
+                    b.Property<DateTimeOffset?>("LastSeenAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<long?>("MenuMessageId")
+                        .HasColumnType("bigint");
+
+                    b.Property<long?>("NoticeMessageId")
+                        .HasColumnType("bigint");
+
+                    b.Property<Guid>("UserId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("ChatId")
+                        .IsUnique();
+
+                    b.HasIndex("UserId");
+
+                    b.ToTable("TelegramSubscribers");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Notifications.TelegramSubscription", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid>("ChannelId")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("Kind")
+                        .HasColumnType("integer");
+
+                    b.Property<Guid>("SubscriberId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("ChannelId", "Kind");
+
+                    b.HasIndex("SubscriberId", "ChannelId", "Kind")
+                        .IsUnique();
+
+                    b.ToTable("TelegramSubscriptions");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.GridLayer", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("ApplicabilityJson")
+                        .HasColumnType("jsonb");
+
+                    b.Property<bool>("IsBackground")
+                        .HasColumnType("boolean");
+
+                    b.Property<bool>("IsEnabled")
+                        .HasColumnType("boolean");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasMaxLength(128)
+                        .HasColumnType("character varying(128)");
+
+                    b.Property<int>("Priority")
+                        .HasColumnType("integer");
+
+                    b.Property<Guid>("TemplateId")
+                        .HasColumnType("uuid");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("TemplateId", "Priority");
+
+                    b.ToTable("GridLayers");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.Group", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("Description")
+                        .HasMaxLength(2048)
+                        .HasColumnType("character varying(2048)");
+
+                    b.Property<string>("FilterJson")
+                        .HasColumnType("jsonb");
+
+                    b.Property<int>("ItemCount")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("Mode")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer")
+                        .HasDefaultValue(0);
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<DateTimeOffset?>("StatsComputedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<TimeSpan>("TotalDuration")
+                        .HasColumnType("interval");
+
+                    b.Property<int>("UnitCount")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Groups");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.GroupItem", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid>("ElementId")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("ElementKind")
+                        .HasColumnType("integer");
+
+                    b.Property<Guid>("GroupId")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("Position")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("Role")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer")
+                        .HasDefaultValue(0);
+
+                    b.Property<int>("Weight")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("ElementKind", "ElementId");
+
+                    b.HasIndex("GroupId", "Position");
+
+                    b.HasIndex("GroupId", "ElementKind", "ElementId")
+                        .IsUnique();
+
+                    b.ToTable("GroupItems");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.JunctionElement", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("AmountMode")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("AmountValue")
+                        .HasColumnType("integer");
+
+                    b.Property<Guid?>("BumperTemplateId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid?>("BumperVariantId")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("ChoiceKey")
+                        .HasMaxLength(64)
+                        .HasColumnType("character varying(64)");
+
+                    b.Property<int>("ChoiceWeight")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("integer")
+                        .HasDefaultValue(1);
+
+                    b.Property<string>("ConditionsJson")
+                        .HasColumnType("jsonb");
+
+                    b.Property<Guid?>("GroupId")
+                        .HasColumnType("uuid");
+
+                    b.Property<bool>("IsRequired")
+                        .HasColumnType("boolean");
+
+                    b.Property<Guid>("JunctionTemplateId")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("Kind")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("Position")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("BumperTemplateId");
+
+                    b.HasIndex("BumperVariantId");
+
+                    b.HasIndex("GroupId");
+
+                    b.HasIndex("JunctionTemplateId", "Position");
+
+                    b.ToTable("JunctionElements");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.JunctionTemplate", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<int?>("MaxTotalSeconds")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasMaxLength(128)
+                        .HasColumnType("character varying(128)");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("Name");
+
+                    b.ToTable("JunctionTemplates");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.ScheduleTemplate", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("AppliedRevision")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("AppliedSnapshotJson")
+                        .HasColumnType("jsonb");
+
+                    b.Property<Guid>("ChannelId")
+                        .HasColumnType("uuid");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<Guid?>("DefaultJunctionId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid?>("FallbackGroupId")
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("Name")
+                        .IsRequired()
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<int>("Revision")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("RulesJson")
+                        .HasColumnType("jsonb");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("ChannelId");
+
+                    b.ToTable("ScheduleTemplates");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.Slot", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("BlockMode")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("BlockValue")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("Daypart")
+                        .HasColumnType("integer");
+
+                    b.Property<Guid?>("GroupId")
+                        .HasColumnType("uuid");
+
+                    b.Property<bool>("IsAnchor")
+                        .HasColumnType("boolean");
+
+                    b.Property<Guid?>("JunctionAfterId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid?>("JunctionBetweenId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid>("LayerId")
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("MaxDriftMinutes")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("OverflowPolicy")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("RepeatSourceJson")
+                        .HasColumnType("jsonb");
+
+                    b.Property<int>("SlotKind")
+                        .HasColumnType("integer");
+
+                    b.Property<int?>("SnapToMinutes")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("StrategyJson")
+                        .HasColumnType("jsonb");
+
+                    b.Property<int>("TargetDurationMinutes")
+                        .HasColumnType("integer");
+
+                    b.Property<TimeOnly>("TargetStart")
+                        .HasColumnType("time without time zone");
+
+                    b.Property<string>("Title")
+                        .IsRequired()
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<int?>("Weekday")
+                        .HasColumnType("integer");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("GroupId");
+
+                    b.HasIndex("LayerId", "TargetStart");
+
+                    b.ToTable("Slots");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.SlotState", b =>
+                {
+                    b.Property<Guid>("SlotId")
+                        .HasColumnType("uuid");
+
+                    b.Property<Guid?>("CurrentElementId")
+                        .HasColumnType("uuid");
+
+                    b.Property<int?>("CurrentElementKind")
+                        .HasColumnType("integer");
+
+                    b.Property<int>("NextUnitIndex")
+                        .HasColumnType("integer");
+
+                    b.HasKey("SlotId");
+
+                    b.ToTable("SlotStates");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Settings.AppSetting", b =>
+                {
+                    b.Property<string>("Key")
+                        .HasMaxLength(128)
+                        .HasColumnType("character varying(128)");
+
+                    b.Property<string>("Value")
+                        .IsRequired()
+                        .HasMaxLength(1024)
+                        .HasColumnType("character varying(1024)");
+
+                    b.HasKey("Key");
+
+                    b.ToTable("AppSettings");
+                });
+
+            modelBuilder.Entity("TeleWave.Infrastructure.Identity.AppRole", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("uuid");
+
+                    b.Property<string>("ConcurrencyStamp")
+                        .IsConcurrencyToken()
+                        .HasColumnType("text");
+
+                    b.Property<bool>("IsSystem")
+                        .HasColumnType("boolean");
+
+                    b.Property<string>("Name")
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<string>("NormalizedName")
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("NormalizedName")
+                        .IsUnique()
+                        .HasDatabaseName("RoleNameIndex");
+
+                    b.ToTable("AspNetRoles", (string)null);
+                });
+
+            modelBuilder.Entity("TeleWave.Infrastructure.Identity.AppUser", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("uuid");
+
+                    b.Property<int>("AccessFailedCount")
+                        .HasColumnType("integer");
+
+                    b.Property<string>("ConcurrencyStamp")
+                        .IsConcurrencyToken()
+                        .HasColumnType("text");
+
+                    b.Property<DateTimeOffset>("CreatedAt")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("Email")
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<bool>("EmailConfirmed")
+                        .HasColumnType("boolean");
+
+                    b.Property<bool>("IsBlocked")
+                        .HasColumnType("boolean");
+
+                    b.Property<bool>("LockoutEnabled")
+                        .HasColumnType("boolean");
+
+                    b.Property<DateTimeOffset?>("LockoutEnd")
+                        .HasColumnType("timestamp with time zone");
+
+                    b.Property<string>("NormalizedEmail")
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<string>("NormalizedUserName")
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.Property<string>("PasswordHash")
+                        .HasColumnType("text");
+
+                    b.Property<string>("PhoneNumber")
+                        .HasColumnType("text");
+
+                    b.Property<bool>("PhoneNumberConfirmed")
+                        .HasColumnType("boolean");
+
+                    b.Property<string>("SecurityStamp")
+                        .HasColumnType("text");
+
+                    b.Property<bool>("TwoFactorEnabled")
+                        .HasColumnType("boolean");
+
+                    b.Property<string>("UserName")
+                        .HasMaxLength(256)
+                        .HasColumnType("character varying(256)");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("NormalizedEmail")
+                        .HasDatabaseName("EmailIndex");
+
+                    b.HasIndex("NormalizedUserName")
+                        .IsUnique()
+                        .HasDatabaseName("UserNameIndex");
+
+                    b.ToTable("AspNetUsers", (string)null);
+                });
+
+            modelBuilder.Entity("Microsoft.AspNetCore.Identity.IdentityRoleClaim<System.Guid>", b =>
+                {
+                    b.HasOne("TeleWave.Infrastructure.Identity.AppRole", null)
+                        .WithMany()
+                        .HasForeignKey("RoleId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("Microsoft.AspNetCore.Identity.IdentityUserClaim<System.Guid>", b =>
+                {
+                    b.HasOne("TeleWave.Infrastructure.Identity.AppUser", null)
+                        .WithMany()
+                        .HasForeignKey("UserId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("Microsoft.AspNetCore.Identity.IdentityUserLogin<System.Guid>", b =>
+                {
+                    b.HasOne("TeleWave.Infrastructure.Identity.AppUser", null)
+                        .WithMany()
+                        .HasForeignKey("UserId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("Microsoft.AspNetCore.Identity.IdentityUserRole<System.Guid>", b =>
+                {
+                    b.HasOne("TeleWave.Infrastructure.Identity.AppRole", null)
+                        .WithMany()
+                        .HasForeignKey("RoleId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.HasOne("TeleWave.Infrastructure.Identity.AppUser", null)
+                        .WithMany()
+                        .HasForeignKey("UserId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("Microsoft.AspNetCore.Identity.IdentityUserToken<System.Guid>", b =>
+                {
+                    b.HasOne("TeleWave.Infrastructure.Identity.AppUser", null)
+                        .WithMany()
+                        .HasForeignKey("UserId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Broadcast.BumperTextVariant", b =>
+                {
+                    b.HasOne("TeleWave.Domain.Broadcast.BumperTemplate", null)
+                        .WithMany("Variants")
+                        .HasForeignKey("BumperTemplateId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.OwnsMany("TeleWave.Domain.Broadcast.BumperLine", "Lines", b1 =>
+                        {
+                            b1.Property<Guid>("BumperTextVariantId");
+
+                            b1.Property<int>("__synthesizedOrdinal")
+                                .ValueGeneratedOnAdd();
+
+                            b1.Property<int>("Color");
+
+                            b1.Property<int>("Position");
+
+                            b1.Property<int>("Style");
+
+                            b1.Property<string>("Text")
+                                .IsRequired()
+                                .HasMaxLength(120);
+
+                            b1.HasKey("BumperTextVariantId", "__synthesizedOrdinal");
+
+                            b1.ToTable("BumperTextVariants");
+
+                            b1
+                                .ToJson("Lines")
+                                .HasColumnType("jsonb");
+
+                            b1.WithOwner()
+                                .HasForeignKey("BumperTextVariantId");
+                        });
+
+                    b.Navigation("Lines");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.CollectionItem", b =>
+                {
+                    b.HasOne("TeleWave.Domain.Library.Collection", null)
+                        .WithMany("Items")
+                        .HasForeignKey("CollectionId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.HasOne("TeleWave.Domain.Library.Show", null)
+                        .WithMany()
+                        .HasForeignKey("ShowId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.GenreAlias", b =>
+                {
+                    b.HasOne("TeleWave.Domain.Library.Genre", null)
+                        .WithMany("Aliases")
+                        .HasForeignKey("GenreId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.ShowEpisode", b =>
+                {
+                    b.HasOne("TeleWave.Domain.Library.Show", null)
+                        .WithMany("Episodes")
+                        .HasForeignKey("ShowId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.ShowGenre", b =>
+                {
+                    b.HasOne("TeleWave.Domain.Library.Genre", null)
+                        .WithMany()
+                        .HasForeignKey("GenreId")
+                        .OnDelete(DeleteBehavior.Restrict)
+                        .IsRequired();
+
+                    b.HasOne("TeleWave.Domain.Library.Show", null)
+                        .WithMany("Genres")
+                        .HasForeignKey("ShowId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Notifications.TelegramSubscription", b =>
+                {
+                    b.HasOne("TeleWave.Domain.Notifications.TelegramSubscriber", null)
+                        .WithMany("Subscriptions")
+                        .HasForeignKey("SubscriberId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.GridLayer", b =>
+                {
+                    b.HasOne("TeleWave.Domain.Programming.ScheduleTemplate", null)
+                        .WithMany("Layers")
+                        .HasForeignKey("TemplateId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.GroupItem", b =>
+                {
+                    b.HasOne("TeleWave.Domain.Programming.Group", null)
+                        .WithMany("Items")
+                        .HasForeignKey("GroupId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.JunctionElement", b =>
+                {
+                    b.HasOne("TeleWave.Domain.Broadcast.BumperTemplate", null)
+                        .WithMany()
+                        .HasForeignKey("BumperTemplateId")
+                        .OnDelete(DeleteBehavior.Restrict);
+
+                    b.HasOne("TeleWave.Domain.Broadcast.BumperTextVariant", null)
+                        .WithMany()
+                        .HasForeignKey("BumperVariantId")
+                        .OnDelete(DeleteBehavior.Restrict);
+
+                    b.HasOne("TeleWave.Domain.Programming.Group", null)
+                        .WithMany()
+                        .HasForeignKey("GroupId")
+                        .OnDelete(DeleteBehavior.Restrict);
+
+                    b.HasOne("TeleWave.Domain.Programming.JunctionTemplate", null)
+                        .WithMany("Elements")
+                        .HasForeignKey("JunctionTemplateId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.Slot", b =>
+                {
+                    b.HasOne("TeleWave.Domain.Programming.Group", null)
+                        .WithMany()
+                        .HasForeignKey("GroupId")
+                        .OnDelete(DeleteBehavior.Restrict);
+
+                    b.HasOne("TeleWave.Domain.Programming.GridLayer", null)
+                        .WithMany("Slots")
+                        .HasForeignKey("LayerId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.SlotState", b =>
+                {
+                    b.HasOne("TeleWave.Domain.Programming.Slot", null)
+                        .WithOne()
+                        .HasForeignKey("TeleWave.Domain.Programming.SlotState", "SlotId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Broadcast.BumperTemplate", b =>
+                {
+                    b.Navigation("Variants");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.Collection", b =>
+                {
+                    b.Navigation("Items");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.Genre", b =>
+                {
+                    b.Navigation("Aliases");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Library.Show", b =>
+                {
+                    b.Navigation("Episodes");
+
+                    b.Navigation("Genres");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Notifications.TelegramSubscriber", b =>
+                {
+                    b.Navigation("Subscriptions");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.GridLayer", b =>
+                {
+                    b.Navigation("Slots");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.Group", b =>
+                {
+                    b.Navigation("Items");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.JunctionTemplate", b =>
+                {
+                    b.Navigation("Elements");
+                });
+
+            modelBuilder.Entity("TeleWave.Domain.Programming.ScheduleTemplate", b =>
+                {
+                    b.Navigation("Layers");
+                });
+#pragma warning restore 612, 618
+        }
+    }
+}
diff --git a/backend/src/TeleWave.Infrastructure/Migrations/20260731181609_TelegramAlertMessage.cs b/backend/src/TeleWave.Infrastructure/Migrations/20260731181609_TelegramAlertMessage.cs
new file mode 100644
index 0000000..7e40257
--- /dev/null
+++ b/backend/src/TeleWave.Infrastructure/Migrations/20260731181609_TelegramAlertMessage.cs
@@ -0,0 +1,27 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+
+#nullable disable
+
+namespace TeleWave.Infrastructure.Migrations
+{
+    /// <inheritdoc />
+    public partial class TelegramAlertMessage : Migration
+    {
+        /// <inheritdoc />
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.AddColumn<long>(
+                name: "AlertMessageId",
+                table: "TelegramSubscribers",
+                type: "bigint",
+                nullable: true
+            );
+        }
+
+        /// <inheritdoc />
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropColumn(name: "AlertMessageId", table: "TelegramSubscribers");
+        }
+    }
+}
diff --git a/backend/src/TeleWave.Infrastructure/Migrations/AppDbContextModelSnapshot.cs b/backend/src/TeleWave.Infrastructure/Migrations/AppDbContextModelSnapshot.cs
index 7d01512..027393a 100644
--- a/backend/src/TeleWave.Infrastructure/Migrations/AppDbContextModelSnapshot.cs
+++ b/backend/src/TeleWave.Infrastructure/Migrations/AppDbContextModelSnapshot.cs
@@ -834,6 +834,9 @@ namespace TeleWave.Infrastructure.Migrations
                     b.Property<Guid>("Id")
                         .HasColumnType("uuid");
 
+                    b.Property<long?>("AlertMessageId")
+                        .HasColumnType("bigint");
+
                     b.Property<long>("ChatId")
                         .HasColumnType("bigint");
 
diff --git a/backend/tests/TeleWave.Application.Tests/Notifications/TelegramNotifierTests.cs b/backend/tests/TeleWave.Application.Tests/Notifications/TelegramNotifierTests.cs
index 39e0b51..382235c 100644
--- a/backend/tests/TeleWave.Application.Tests/Notifications/TelegramNotifierTests.cs
+++ b/backend/tests/TeleWave.Application.Tests/Notifications/TelegramNotifierTests.cs
@@ -146,4 +146,61 @@ public class TelegramNotifierTests
         // Граница разобранного двигается всегда — иначе следующий тик оповестил бы о том же.
         Assert.Equal(Now, settings.NotifiedUntil);
     }
+
+    [Fact]
+    public async Task Notifies_ReplacingItsPreviousAlert()
+    {
+        var fixture = new TestDb();
+        var channel = Channel.Create("Мультреалити", "mult", Now);
+        var previous = Show.Create("Симпсоны", ShowKind.Series);
+        var started = Show.Create("Футурама", ShowKind.Series);
+
+        var subscriber = TelegramSubscriber.Create(100, Guid.NewGuid(), "viewer", Now);
+        subscriber.Toggle(channel.Id, TelegramNotificationKind.ShowStart);
+        subscriber.SetAlertMessage(777);
+        // Программа, запрошенная зрителем, — не оповещение: рассылка её трогать не должна.
+        subscriber.SetNoticeMessage(555);
+
+        await using (var seed = fixture.New())
+        {
+            seed.Channels.Add(channel);
+            seed.Shows.AddRange(previous, started);
+            seed.TelegramSubscribers.Add(subscriber);
+            seed.ScheduleEntries.Add(Program(channel.Id, previous.Id, Now.AddMinutes(-30), 25));
+            seed.ScheduleEntries.Add(Program(channel.Id, started.Id, Now.AddMinutes(-1), 25));
+            await seed.SaveChangesAsync(CancellationToken.None);
+        }
+
+        var api = Substitute.For<ITelegramApi>();
+        api.SendMessageAsync(
+                Arg.Any<TelegramSettings>(),
+                Arg.Any<long>(),
+                Arg.Any<string>(),
+                Arg.Any<IReadOnlyList<IReadOnlyList<TelegramButton>>?>(),
+                Arg.Any<CancellationToken>()
+            )
+            .Returns(4242L);
+        var settings = Settings();
+        settings.MarkNotifiedUntil(Now.AddMinutes(-5));
+
+        await using (var db = fixture.New())
+        {
+            await new TelegramNotifier(db, api).RunAsync(settings, Now, CancellationToken.None);
+            await db.SaveChangesAsync(CancellationToken.None);
+        }
+
+        // Вчерашнее «сейчас в эфире» — уже неправда: старое снимаем, новое запоминаем.
+        await api.Received(1)
+            .DeleteMessageAsync(
+                Arg.Any<TelegramSettings>(),
+                100,
+                777,
+                Arg.Any<CancellationToken>()
+            );
+
+        await using var check = fixture.New();
+        var stored = check.TelegramSubscribers.Single();
+        Assert.Equal(4242L, stored.AlertMessageId);
+        Assert.Equal(555L, stored.NoticeMessageId);
+    }
 }
diff --git a/docs/telegram-bot.md b/docs/telegram-bot.md
index ba12beb..02b7a66 100644
--- a/docs/telegram-bot.md
+++ b/docs/telegram-bot.md
@@ -48,6 +48,12 @@ NAT и через прокси, и это единственный вариан
 пройти. Догон ограничен пятнадцатью минутами — после долгого простоя бот не станет пересказывать
 вчерашний эфир.
 
+В чате живёт только последнее оповещение: новое снимает предыдущее (`TelegramSubscriber.AlertMessageId`).
+Оповещение отвечает на вопрос «что идёт сейчас», а вчерашнее «сейчас в эфире» на этот вопрос
+отвечает неправдой — за сутки таких набирается несколько десятков, и найти среди них актуальное
+нельзя. Счётчик отдельный от одноразовых ответов бота: рассылка приходит сама и не должна сносить
+программу передач, которую зритель только что запросил.
+
 ## Меню в чате
 
 `/start` с кодом привязывает чат и открывает меню; `/start` без кода — открывает меню уже
@@ -60,10 +66,11 @@ NAT и через прокси, и это единственный вариан
 нажатие снимает подписку. `/stop` останавливает рассылку, не стирая подписки: вернувшись, зритель
 получит свои каналы, а не пустой список.
 
-**Бот убирает за собой.** В чате живут ровно два его сообщения: меню подписок и последнее
-одноразовое — программа передач, подтверждение привязки или отказ. Новое меню снимает предыдущее
-(две панели с разными галочками означают, что одна врёт), новая программа — предыдущую программу.
-Идентификаторы обоих сообщений хранятся у подписчика. Команды зрителя остаются: в личном чате бот
+**Бот убирает за собой.** В чате живут ровно три его сообщения: меню подписок, последнее
+одноразовое (программа передач, подтверждение привязки или отказ) и последнее оповещение рассылки.
+Новое меню снимает предыдущее (две панели с разными галочками означают, что одна врёт), новая
+программа — предыдущую программу, новое оповещение — предыдущее оповещение. Идентификаторы всех
+трёх хранятся у подписчика. Команды зрителя остаются: в личном чате бот
 вправе удалять только собственные сообщения, и права на чужие у него нет и не будет. Не удалившееся
 сообщение (зритель убрал его сам, прошло больше 48 часов) уборку не срывает — это не та задача,
 ради которой стоит рвать разговор.