Introduce concept of a head server

- Treat the lowest server id as the head server.
- Head server runs the timer task
- When timer task fires, if individual channel actions are required, use
  the RPC manager to send an internal message.
- Update the EpitaphWeeklyReward task to send a message to all channels.

Arrowgene.Ddon.GameServer/Characters/EpitaphRoadManager.cs

@@ -1321,5 +1321,14 @@ public List<InstancedGatheringItem> RollGatheringLoot(GameClient client, Charact
 
             return results;
         }
+
+        public void PerformWeeklyReset()
+        {
+            // Clear out cached data related to epitaph weekly rewards
+            foreach (var client in _Server.ClientLookup.GetAll())
+            {
+                client.Character.EpitaphRoadState.WeeklyRewardsClaimed.Clear();
+            }
+        }
     }
 }

Arrowgene.Ddon.GameServer/DdonGameServer.cs

@@ -130,8 +130,13 @@ public DdonGameServer(GameServerSetting setting, IDatabase database, AssetReposi
         public override void Start()
         {
             QuestManager.LoadQuests(this.AssetRepository);
-            ScheduleManager.Start();
             GpCourseManager.EvaluateCourses();
+
+            if (ServerUtils.IsHeadServer(this))
+            {
+                ScheduleManager.StartServerTasks();
+            }
+
             LoadChatHandler();
             LoadPacketHandler();
             base.Start();

Arrowgene.Ddon.GameServer/RpcManager.cs

@@ -9,9 +9,11 @@
 using Arrowgene.Logging;
 using System;
 using System.Collections.Generic;
+using System.Collections.Immutable;
 using System.Linq;
 using System.Net.Http;
 using System.Net.Http.Json;
+using System.Security.Claims;
 using System.Text.Json;
 using System.Text.Json.Serialization;
 using System.Threading.Tasks;
@@ -142,6 +144,11 @@ public List<CDataGameServerListInfo> ServerListInfo()
             return ChannelInfo.Keys.Select(x => ServerListInfo(x)).ToList();
         }
 
+        public ServerInfo HeadServer()
+        {
+            return ChannelInfo.Values.ToList().OrderBy(x => x.Id).ToList()[0];
+        }
+
         public CDataGameServerListInfo ServerListInfo(ushort channelId)
         {
             var info = ChannelInfo[channelId].ToCDataGameServerListInfo();
@@ -412,5 +419,10 @@ public void AnnounceClanPacket<T>(uint clanId, T packet, uint characterId = 0)
                 AnnounceClan(clanId, "internal/packet", RpcInternalCommand.AnnouncePacketClan, data);
             }
         }
+
+        public void AnnounceEpitaphWeeklyReset()
+        {
+            AnnounceAll("internal/packet", RpcInternalCommand.EpitaphRoadWeeklyReset, null);
+        }
     }
 }

Arrowgene.Ddon.GameServer/ScheduleManager.cs

@@ -45,7 +45,7 @@ private int GetTimerTick(ScheduleInterval interval)
             }
         }
 
-        public void Start()
+        public void StartServerTasks()
         {
             Dictionary<TaskType, SchedulerTaskEntry> entries = Server.Database.SelectAllTaskEntries();
 

Arrowgene.Ddon.GameServer/ServerUtils.cs

@@ -0,0 +1,12 @@
+using System.Linq;
+
+namespace Arrowgene.Ddon.GameServer
+{
+    public class ServerUtils
+    {
+        public static bool IsHeadServer(DdonGameServer server)
+        {
+            return server.RpcManager.HeadServer().Id == server.Id;
+        }
+    }
+}

Arrowgene.Ddon.GameServer/Tasks/EpitaphSchedulerTask.cs

@@ -1,5 +1,6 @@
 using Arrowgene.Ddon.Server;
 using Arrowgene.Ddon.Shared.Model;
+using Arrowgene.Ddon.Shared.Model.Rpc;
 using Arrowgene.Ddon.Shared.Model.Scheduler;
 using Arrowgene.Logging;
 using System;
@@ -23,14 +24,9 @@ public override bool IsEnabled(DdonGameServer server)
         public override void RunTask(DdonGameServer server)
         {
             Logger.Info("Performing weekly epitaph reset");
-            server.ChatManager.SendMessage("Performing weekly epitaph reset", string.Empty, string.Empty, LobbyChatMsgType.ManagementAlertN, server.ClientLookup.GetAll());
-
             server.Database.DeleteWeeklyEpitaphClaimedRewards();
 
-            foreach (var client in server.ClientLookup.GetAll())
-            {
-                client.Character.EpitaphRoadState.WeeklyRewardsClaimed.Clear();
-            }
+            server.RpcManager.AnnounceEpitaphWeeklyReset();
         }
     }
 }

Arrowgene.Ddon.GameServer/Tasks/SchedulerTask.cs

@@ -13,6 +13,12 @@ public SchedulerTask(ScheduleInterval interval, TaskType type)
             Interval = interval;
         }
 
+        /// <summary>
+        /// Runs on the head server. Should deal with things like modifying the database.
+        /// Should use the RPC manage if it is required to update clients on different channels
+        /// or send annoucements to players.
+        /// </summary>
+        /// <param name="server"></param>
         public abstract void RunTask(DdonGameServer server);
         public abstract long NextTimestamp();
 

Arrowgene.Ddon.Rpc.Web/Route/Internal/PacketRoute.cs

@@ -168,6 +168,9 @@ public override RpcCommandResult Execute(DdonGameServer gameServer)
                                 Message = $"AnnouncePacketClan Ch.{_entry.Origin} ClanID {data.ClanId} -> {packet.Id}"
                             };
                         }
+                    case RpcInternalCommand.EpitaphRoadWeeklyReset:
+                        gameServer.EpitaphRoadManager.PerformWeeklyReset();
+                        return new RpcCommandResult(this, true);
                     default:
                         return new RpcCommandResult(this, false);
                 }

Arrowgene.Ddon.Shared/Model/Rpc/RpcInternalCommand.cs

@@ -10,5 +10,7 @@ public enum RpcInternalCommand
 
         AnnouncePacketAll, // RpcPacketData
         AnnouncePacketClan, // RpcPacketData
+
+        EpitaphRoadWeeklyReset
     }
 }