~ruther/NosSmooth

ref: 2023.12 NosSmooth/Core/NosSmooth.Game/PacketHandlers/Raids/RaidBfResponder.cs -rw-r--r-- 2.3 KiB
58d87434 — Rutherther chore: bump versions 2 years ago
                                                                                
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
//
//  RaidBfResponder.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 System.Data;
using NosSmooth.Core.Packets;
using NosSmooth.Game.Data.Raids;
using NosSmooth.Game.Events.Core;
using NosSmooth.Game.Events.Raids;
using NosSmooth.Packets.Enums.Raids;
using NosSmooth.Packets.Server.Raids;
using Remora.Results;

namespace NosSmooth.Game.PacketHandlers.Raids;

/// <summary>
/// A responder to <see cref="RaidBfPacket"/>.
/// </summary>
public class RaidBfResponder : IPacketResponder<RaidBfPacket>
{
    private readonly Game _game;
    private readonly EventDispatcher _eventDispatcher;

    /// <summary>
    /// Initializes a new instance of the <see cref="RaidBfResponder"/> class.
    /// </summary>
    /// <param name="game">The game.</param>
    /// <param name="eventDispatcher">The event dispatcher.</param>
    public RaidBfResponder(Game game, EventDispatcher eventDispatcher)
    {
        _game = game;
        _eventDispatcher = eventDispatcher;
    }

    /// <inheritdoc />
    public async Task<Result> Respond(PacketEventArgs<RaidBfPacket> packetArgs, CancellationToken ct = default)
    {
        var packet = packetArgs.Packet;
        Raid? previousRaid = null;
        var currentRaid = await _game.UpdateRaidAsync
        (
            raid =>
            {
                previousRaid = raid;
                return raid with
                {
                    State = packet.WindowType switch
                    {
                        RaidBfPacketType.MissionStarted => RaidState.Started,
                        RaidBfPacketType.MissionCleared => RaidState.EndedSuccessfully,
                        _ => RaidState
                            .TeamFailed // TODO: figure out whether OutOfLives is sent for both individual member and whole team
                    }
                };
            },
            ct: ct
        );

        if (previousRaid is not null && currentRaid is not null && previousRaid.State != currentRaid.State)
        {
            return await _eventDispatcher.DispatchEvent
                (new RaidStateChangedEvent(previousRaid.State, currentRaid.State, currentRaid), ct);
        }

        return Result.FromSuccess();
    }
}
Do not follow this link