Наблюдатель (Информационное агентство "Ulan-Ude news")

[Flags]
public enum MessageType
{
    None = 0,
    WeatherInformation = 1,
    ExchangeRate = 2,
    CityNews = 4
}
 
public enum PrecipitationType
{
    ClearSky = 1,
    Rain,
    Snow
}
 
// Интерфейс для всех сообщений
public interface INewsMessage
{
    MessageType Type { get; }
    DateTime Date { get; }
    string Text { get; }
}
 
// Сообщение о погоде
public class WeatherMessage : INewsMessage
{
    public MessageType Type => MessageType.WeatherInformation;
    public DateTime Date { get; }
    public string Text { get; }
    public int Temperature { get; }
    public PrecipitationType Precipitation { get; }
    public int WindSpeed { get; }
 
    public WeatherMessage(int temperature, PrecipitationType precipitation, int windSpeed, DateTime date)
    {
        Temperature = temperature;
        Precipitation = precipitation;
        WindSpeed = windSpeed;
        Date = date;
        Text = $"Температура: {temperature}, Осадки: {precipitation}, Скорость ветра: {windSpeed}";
    }
}
 
// Сообщение о новостях
public class CityNewsMessage : INewsMessage
{
    public MessageType Type => MessageType.CityNews;
    public DateTime Date { get; }
    public string Text { get; }
 
    public CityNewsMessage(string text, DateTime date)
    {
        Text = text;
        Date = date;
    }
}
 
// Сообщение о курсе валют
public class ExchangeRateMessage : INewsMessage
{
    public MessageType Type => MessageType.ExchangeRate;
    public DateTime Date { get; }
    public string Text { get; }
    public string Currency { get; }
    public decimal Rate { get; }
 
    public ExchangeRateMessage(string currency, decimal rate, DateTime date)
    {
        Currency = currency;
        Rate = rate;
        Date = date;
        Text = $"Курс {currency}: {rate}";
    }
}
 
public interface IObserver
{
    void Update(INewsMessage message);
}
public interface IMessageObserver : IObserver
{
    MessageType SupportedMessageType { get; }
}
 
// Класс информационного агентства
public class NewsAgency
{
    private List<IMessageObserver> observers = new List<IMessageObserver>();
    private string filePath;
 
    public NewsAgency(string filePath)
    {
        this.filePath = filePath;
    }
 
    public void Subscribe(IMessageObserver observer)
    {
        observers.Add(observer);
    }
 
    public void Unsubscribe(IMessageObserver observer)
    {
        observers.Remove(observer);
    }
 
    public void NotifyObservers(INewsMessage message)
    {
        foreach (var observer in observers)
        {
            if (observer.SupportedMessageType.HasFlag(message.Type))
            {
                observer.Update(message);
            }
        }
    }
 
    public void StartReadingData()
    {
        while (true)
        {
            try
            {
                using (var reader = new StreamReader(filePath))
                {
                    string line;
                    while ((line = reader.ReadLine()) != null)
                    {
                        var parts = line.Split(';');
                        if (parts.Length == 3)
                        {
                            int type = int.Parse(parts[2]);
                            DateTime date = DateTime.Parse(parts[1]);
                            INewsMessage message = null;
                            switch (type)
                            {
                                case (int)MessageType.WeatherInformation:
                                    var weatherParts = parts[0].Split(' ');
                                    message = new WeatherMessage(
                                        int.Parse(weatherParts[0]),
                                        (PrecipitationType)int.Parse(weatherParts[1]),
                                        int.Parse(weatherParts[2]),
                                        date);
                                    break;
                                case (int)MessageType.ExchangeRate:
                                    var exchangeParts = parts[0].Split(' ');
                                    message = new ExchangeRateMessage(
                                        exchangeParts[0],
                                        decimal.Parse(exchangeParts[1]),
                                        date);
                                    break;
                                case (int)MessageType.CityNews:
                                    message = new CityNewsMessage(parts[0], date);
                                    break;
                            }
 
                            if (message != null)
                            {
                                NotifyObservers(message);
                            }
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine($"Ошибка при чтении данных: {ex.Message}");
            }
 
            Thread.Sleep(5000); // Задержка в 5 секунд
        }
    }
}
 
// Класс для Газеты Информ полис
public class InformPolis : IMessageObserver
{
    public MessageType SupportedMessageType => MessageType.ExchangeRate | MessageType.CityNews;
 
    public void Update(INewsMessage message)
    {
        Console.WriteLine($"Информ полис получил информацию: {message.Text}, {message.Date}, {message.Type}");
    }
}
 
// Класс для телеканала Ариг Ус
public class ArigUs : IMessageObserver
{
    public MessageType SupportedMessageType => MessageType.WeatherInformation;
 
    public void Update(INewsMessage message)
    {
        Console.WriteLine($"Ариг Ус получил информацию: {message.Text}, {message.Date}, {message.Type}");
    }
}

var newsAgency = new NewsAgency("news.txt");
var informPolis = new InformPolis();
var arigUs = new ArigUs();
newsAgency.Subscribe(informPolis);
newsAgency.Subscribe(arigUs);
newsAgency.StartReadingData();