//
// SkillUsedResponder.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 Microsoft.Extensions.Logging;
using NosSmooth.Core.Extensions;
using NosSmooth.Core.Packets;
using NosSmooth.Data.Abstractions;
using NosSmooth.Game.Data.Characters;
using NosSmooth.Game.Data.Entities;
using NosSmooth.Game.Data.Info;
using NosSmooth.Game.Events.Battle;
using NosSmooth.Game.Events.Characters;
using NosSmooth.Game.Events.Core;
using NosSmooth.Game.Events.Entities;
using NosSmooth.Game.Extensions;
using NosSmooth.Game.Helpers;
using NosSmooth.Packets.Client.Battle;
using NosSmooth.Packets.Enums.Entities;
using NosSmooth.Packets.Server.Battle;
using NosSmooth.Packets.Server.Skills;
using Remora.Results;
namespace NosSmooth.Game.PacketHandlers.Entities;
/// <summary>
/// Responds to skill used packet.
/// </summary>
public class SkillUsedResponder : IPacketResponder<SuPacket>, IPacketResponder<SrPacket>, IPacketResponder<UseAOESkillPacket>, IPacketResponder<UseSkillPacket>
{
private readonly Game _game;
private readonly EventDispatcher _eventDispatcher;
private readonly IInfoService _infoService;
private readonly ILogger<SkillUsedResponder> _logger;
/// <summary>
/// Initializes a new instance of the <see cref="SkillUsedResponder"/> class.
/// </summary>
/// <param name="game">The game.</param>
/// <param name="eventDispatcher">The event dispatcher.</param>
/// <param name="infoService">The info service.</param>
/// <param name="logger">The logger.</param>
public SkillUsedResponder
(
Game game,
EventDispatcher eventDispatcher,
IInfoService infoService,
ILogger<SkillUsedResponder> logger
)
{
_game = game;
_eventDispatcher = eventDispatcher;
_infoService = infoService;
_logger = logger;
}
/// <inheritdoc />
public async Task<Result> Respond(PacketEventArgs<SuPacket> packetArgs, CancellationToken ct = default)
{
var packet = packetArgs.Packet;
var map = _game.CurrentMap;
// TODO: add to map if the entity is created?
var caster = map?.Entities?.GetEntity<ILivingEntity>
(packet.CasterEntityId) ?? (ILivingEntity)EntityHelpers.CreateEntity
(packet.CasterEntityType, packet.CasterEntityId);
var target = map?.Entities?.GetEntity<ILivingEntity>
(packet.TargetEntityId) ?? (ILivingEntity)EntityHelpers.CreateEntity
(packet.TargetEntityType, packet.TargetEntityId);
if (target.Hp is null)
{
target.Hp = new Health
{
Percentage = packet.HpPercentage,
Maximum = packet.MaxHp,
Amount = packet.Hp
};
}
else
{
target.Hp.Percentage = packet.HpPercentage;
target.Hp.Maximum = packet.MaxHp;
target.Hp.Amount = packet.Hp;
}
if (packet.PositionX is not null && packet.PositionY is not null && packet.PositionX != 0
&& packet.PositionY != 0)
{
caster.Position = new Position(packet.PositionX.Value, packet.PositionY.Value);
}
Skill? skillEntity;
var skills = _game.Skills;
if (packet.SkillVNum is not null && caster is Character && skills is not null)
{
var skillResult = skills.TryGetSkillByVNum(packet.SkillVNum.Value);
if (skillResult.IsDefined(out skillEntity))
{
skillEntity.LastUseTime = DateTimeOffset.Now;
if (skillEntity.LastUseRequestTime is null || skillEntity.LastCooldownReset is null
|| skillEntity.LastUseRequestTime > skillEntity.LastCooldownReset)
{
skillEntity.IsOnCooldown = true;
}
}
else
{
var skillInfoResult = await _infoService.GetSkillInfoAsync(packet.SkillVNum.Value, ct);
skillEntity = new Skill
(packet.SkillVNum.Value, null, skillInfoResult.IsSuccess ? skillInfoResult.Entity : null);
}
}
else if (packet.SkillVNum is not null)
{
var skillInfoResult = await _infoService.GetSkillInfoAsync(packet.SkillVNum.Value, ct);
if (!skillInfoResult.IsSuccess && packet.SkillVNum != 0)
{
_logger.LogWarning
(
"Could not obtain a skill info for vnum {vnum}: {error}",
packet.SkillVNum,
skillInfoResult.ToFullString()
);
}
skillEntity = new Skill
(packet.SkillVNum.Value, null, skillInfoResult.IsSuccess ? skillInfoResult.Entity : null);
}
else
{
skillEntity = new Skill(-1, null, null);
}
var dispatchResult = await _eventDispatcher.DispatchEvent
(
new SkillUsedEvent
(
caster,
target,
skillEntity,
packet.PositionX is null || packet.PositionY is null ? null : new Position(packet.PositionX.Value, packet.PositionY.Value),
packet.HitMode,
packet.Damage
),
ct
);
if (!packet.TargetIsAlive)
{
if (target is not ILivingEntity living || (living.Type is not(EntityType.Player or EntityType.Npc)))
{
map?.Entities?.RemoveEntity(target.Id);
}
target.Hp.Amount = 0;
target.Hp.Percentage = 0;
var diedResult = await _eventDispatcher.DispatchEvent(new EntityDiedEvent(target, skillEntity), ct);
if (!diedResult.IsSuccess)
{
return dispatchResult.IsSuccess
? diedResult
: new AggregateError(diedResult, diedResult);
}
}
return dispatchResult;
}
/// <inheritdoc />
public async Task<Result> Respond(PacketEventArgs<SrPacket> packetArgs, CancellationToken ct = default)
{
var packet = packetArgs.Packet;
var skills = _game.Skills;
if (skills is not null)
{
var skillResult = skills.TryGetSkillByCastId(packet.SkillId);
if (skillResult.IsDefined(out var skillEntity))
{
skillEntity.IsOnCooldown = false;
skillEntity.LastCooldownReset = DateTime.Now;
}
await _eventDispatcher.DispatchEvent
(new SkillReadyEvent(skillEntity, skillEntity?.SkillVNum ?? packet.SkillId), ct);
}
else
{
await _eventDispatcher.DispatchEvent(new SkillReadyEvent(null, packet.SkillId), ct);
}
return Result.FromSuccess();
}
/// <inheritdoc />
public Task<Result> Respond(PacketEventArgs<UseAOESkillPacket> packetArgs, CancellationToken ct = default)
{
var packet = packetArgs.Packet;
var skills = _game.Skills;
if (skills is not null)
{
var skillResult = skills.TryGetSkillByCastId((short)packet.SkillId);
if (skillResult.IsDefined(out var skillEntity))
{
skillEntity.LastUseRequestTime = DateTime.Now;
}
}
return Task.FromResult(Result.FromSuccess());
}
/// <inheritdoc />
public Task<Result> Respond(PacketEventArgs<UseSkillPacket> packetArgs, CancellationToken ct = default)
{
var packet = packetArgs.Packet;
var skills = _game.Skills;
if (skills is not null)
{
var skillResult = skills.TryGetSkillByCastId(packet.CastId);
if (skillResult.IsDefined(out var skillEntity))
{
skillEntity.LastUseRequestTime = DateTime.Now;
}
}
return Task.FromResult(Result.FromSuccess());
}
}