//
// RbossResponder.cs
//
// Copyright (c) František Boháček. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
using NosSmooth.Core.Packets;
using NosSmooth.Game.Data.Entities;
using NosSmooth.Game.Data.Raids;
using NosSmooth.Game.Events.Core;
using NosSmooth.Game.Events.Raids;
using NosSmooth.Packets.Server.Raids;
using Remora.Results;
namespace NosSmooth.Game.PacketHandlers.Raids;
///
/// A responder to .
///
public class RbossResponder : IPacketResponder
{
private readonly Game _game;
private readonly EventDispatcher _eventDispatcher;
///
/// Initializes a new instance of the class.
///
/// The game.
/// The event dispatcher.
public RbossResponder(Game game, EventDispatcher eventDispatcher)
{
_game = game;
_eventDispatcher = eventDispatcher;
}
///
public async Task Respond(PacketEventArgs packetArgs, CancellationToken ct = default)
{
var packet = packetArgs.Packet;
var map = _game.CurrentMap;
if (map is null)
{
return Result.FromSuccess();
}
var bossEntity = packet.EntityId is not null ? map.Entities.GetEntity(packet.EntityId.Value) : null;
RaidState? previousState = null;
var currentRaid = await _game.UpdateRaidAsync
(
raid =>
{
previousState = raid.State;
if (bossEntity is not null && (raid.Bosses is null || !raid.Bosses.Contains(bossEntity)))
{
return raid with
{
Boss = raid.Boss ?? bossEntity,
Bosses = (raid.Bosses ?? Array.Empty()).Append(bossEntity).ToList(),
State = RaidState.BossFight
};
}
return raid with
{ // this will oscillate between more bosses ...
Boss = bossEntity
};
},
ct: ct
);
if (currentRaid is not null && previousState is not null && previousState != currentRaid.State)
{
return await _eventDispatcher.DispatchEvent
(new RaidStateChangedEvent(previousState.Value, currentRaid.State, currentRaid), ct);
}
return Result.FromSuccess();
}
}