RealWeather.cs

using System.Collections.Generic;
using System.Configuration;
using BepInEx;
using BepInEx.Configuration;
using HarmonyLib;
using UnityEngine;
using System.Net.Http;
using Newtonsoft.Json;
using System.Linq;
using System;
using System.Threading;

namespace RealWeather;

internal static class ModInfo
{
    internal const string Guid = "me.pocke.real-weather";
    internal const string Name = "Real Weather";
    internal const string Version = "1.0.0";
}

[BepInPlugin(ModInfo.Guid, ModInfo.Name, ModInfo.Version)]
internal class RealWeather : BaseUnityPlugin
{
    public bool IsSyncNeeded { get; private set; } = false;
    public List<Weather.Forecast> forecasts = new List<Weather.Forecast>();

    static string apiUrlBase = "https://api.open-meteo.com/v1/forecast";

    private CancellationTokenSource cancellationTokenSource;

    private void Awake()
    {
        Settings.latitude = Config.Bind("Settings", "Latitude", 35.6895, "Latitude for weather data (default: Tokyo)");
        Settings.longitude = Config.Bind("Settings", "Longitude", 139.6917, "Longitude for weather data (default: Tokyo)");

        cancellationTokenSource = new CancellationTokenSource();
        StartFetchingWeather(cancellationTokenSource.Token);
        Logger.LogInfo("RealWeather Mod is loaded!");
    }

    private void Update()
    {

        if (!EClass.core.IsGameStarted)
        {
            return;
        }

        if (IsSyncNeeded)
        {
            int size = forecasts.Count;
            EClass.world.weather.forecasts = forecasts;
            forecasts = new List<Weather.Forecast>();
            EClass.world.weather.SetConditionFromForecast();
            Logger.LogInfo($"Weather data synced: {size} entries.");
            IsSyncNeeded = false;
        }
    }

    private void OnDestroy()
    {
        try {
            cancellationTokenSource.Cancel();
        }
        finally {
            cancellationTokenSource.Dispose();
        }
    }

    private async void StartFetchingWeather(CancellationToken token)
    {
        while (!token.IsCancellationRequested) {
            if (IsSyncNeeded)
            {
                await System.Threading.Tasks.Task.Delay(TimeSpan.FromSeconds(1));
                continue;
            }

            try
            {
                string url = $"{apiUrlBase}?latitude={Settings.Latitude}&longitude={Settings.Longitude}&hourly=weather_code";
                using (HttpClient client = new HttpClient())
                {
                    client.DefaultRequestHeaders.Add("User-Agent", $"RealWeatherMod/{ModInfo.Version}");

                    HttpResponseMessage response = await client.GetAsync(url);
                    if (response.IsSuccessStatusCode)
                    {
                        string jsonResponse = await response.Content.ReadAsStringAsync();
                        var weatherData = Newtonsoft.Json.JsonConvert.DeserializeObject<ApiResponse>(jsonResponse);
                        if (weatherData != null && weatherData.Hourly != null && weatherData.Hourly.WeatherCode != null && weatherData.Hourly.WeatherCode.Count() > 0)
                        {
                            List<int> wmoCodes = weatherData.Hourly.WeatherCode;
                            forecasts = new List<Weather.Forecast>();

                            Weather.Condition? currentCondition = null;
                            int currentDuration = 0;

                            foreach (int wmoCode in wmoCodes)
                            {
                                Weather.Condition condition = WeatherCode.GetWeatherConditionFromWMOCode(wmoCode);

                                if (currentCondition == condition)
                                {
                                    currentDuration++;
                                }
                                else
                                {
                                    if (currentCondition != null)
                                    {
                                        forecasts.Add(new Weather.Forecast
                                        {
                                            duration = currentDuration,
                                            condition = currentCondition.Value,
                                        });
                                    }

                                    currentCondition = condition;
                                    currentDuration = 1;
                                }
                            }

                            // Add the last forecast
                            if (currentCondition != null)
                            {
                                forecasts.Add(new Weather.Forecast
                                {
                                    duration = currentDuration,
                                    condition = currentCondition.Value,
                                });
                            }
                            IsSyncNeeded = true;

                            Logger.LogInfo($"Updated forecasts: {forecasts.Count} entries.");
                        }
                        else
                        {
                            Logger.LogError("Failed to parse weather data:" + jsonResponse);
                        }
                    }
                    else
                    {
                        Logger.LogError($"Failed to fetch weather data: {response.StatusCode}");
                    }
                }
            }
            catch (System.Exception ex)
            {
                Logger.LogError($"Exception while fetching weather data: {ex.Message}");
            }

            await System.Threading.Tasks.Task.Delay(TimeSpan.FromMinutes(15));
        }
    }
}