-
Notifications
You must be signed in to change notification settings - Fork 16
/
TradeOfferUpdateHandler.cs
161 lines (138 loc) · 6.41 KB
/
TradeOfferUpdateHandler.cs
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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
using AutomaticTypeMapper;
using EOLib.Domain.Character;
using EOLib.Domain.Login;
using EOLib.Domain.Notifiers;
using EOLib.Domain.Trade;
using EOLib.IO.Repositories;
using EOLib.Net;
using EOLib.Net.Handlers;
using Optional;
using Optional.Collections;
using System.Collections.Generic;
using System.Linq;
namespace EOLib.PacketHandlers.Trade
{
public abstract class TradeOfferUpdateHandler : InGameOnlyPacketHandler
{
protected readonly ITradeRepository _tradeRepository;
public override PacketFamily Family => PacketFamily.Trade;
protected TradeOfferUpdateHandler(IPlayerInfoProvider playerInfoProvider,
ITradeRepository tradeRepository)
: base(playerInfoProvider)
{
_tradeRepository = tradeRepository;
}
public override bool HandlePacket(IPacket packet)
{
var player1Id = packet.ReadShort();
var player1Items = new List<InventoryItem>();
while (packet.PeekByte() != 255)
{
player1Items.Add(new InventoryItem(packet.ReadShort(), packet.ReadInt()));
}
packet.ReadByte();
var player2Id = packet.ReadShort();
var player2Items = new List<InventoryItem>();
while (packet.PeekByte() != 255)
{
player2Items.Add(new InventoryItem(packet.ReadShort(), packet.ReadInt()));
}
packet.ReadByte();
_tradeRepository.SomeWhen(x => x.PlayerOneOffer.PlayerID == player1Id)
.Match(some: x =>
{
x.PlayerOneOffer = x.PlayerOneOffer.WithItems(player1Items);
x.PlayerTwoOffer = x.PlayerTwoOffer.WithItems(player2Items);
},
none: () =>
{
var x = _tradeRepository;
x.PlayerOneOffer = x.PlayerOneOffer.WithItems(player2Items);
x.PlayerTwoOffer = x.PlayerTwoOffer.WithItems(player1Items);
});
_tradeRepository.PlayerOneOffer = _tradeRepository.PlayerOneOffer.WithAgrees(false);
_tradeRepository.PlayerTwoOffer = _tradeRepository.PlayerTwoOffer.WithAgrees(false);
return true;
}
}
/// <summary>
/// Either player makes an update to their offer
/// </summary>
[AutoMappedType]
public class TradeReplyHandler : TradeOfferUpdateHandler
{
public override PacketAction Action => PacketAction.Reply;
public TradeReplyHandler(IPlayerInfoProvider playerInfoProvider,
ITradeRepository tradeRepository)
: base(playerInfoProvider, tradeRepository)
{
}
}
/// <summary>
/// Trade completed
/// </summary>
[AutoMappedType]
public class TradeUseHandler : TradeOfferUpdateHandler
{
private readonly ICharacterRepository _characterRepository;
private readonly ICharacterInventoryRepository _characterInventoryRepository;
private readonly IEIFFileProvider _eifFileProvider;
private readonly IEnumerable<ITradeEventNotifier> _tradeEventNotifiers;
public override PacketAction Action => PacketAction.Use;
public TradeUseHandler(IPlayerInfoProvider playerInfoProvider,
ITradeRepository tradeRepository,
ICharacterRepository characterRepository,
ICharacterInventoryRepository characterInventoryRepository,
IEIFFileProvider eifFileProvider,
IEnumerable<ITradeEventNotifier> tradeEventNotifiers)
: base(playerInfoProvider, tradeRepository)
{
_characterRepository = characterRepository;
_characterInventoryRepository = characterInventoryRepository;
_eifFileProvider = eifFileProvider;
_tradeEventNotifiers = tradeEventNotifiers;
}
public override bool HandlePacket(IPacket packet)
{
base.HandlePacket(packet);
var (removeItems, addItems) = _tradeRepository
.SomeWhen(x => x.PlayerOneOffer.PlayerID == _characterRepository.MainCharacter.ID)
.Match(some: x => (x.PlayerOneOffer.Items, x.PlayerTwoOffer.Items),
none: () => (_tradeRepository.PlayerTwoOffer.Items, _tradeRepository.PlayerOneOffer.Items));
var stats = _characterRepository.MainCharacter.Stats;
foreach (var removedItem in removeItems)
{
_characterInventoryRepository.ItemInventory.SingleOrNone(x => x.ItemID == removedItem.ItemID)
.MatchSome(x =>
{
_characterInventoryRepository.ItemInventory.Remove(x);
if (x.Amount - removedItem.Amount > 0)
{
_characterInventoryRepository.ItemInventory.Add(x.WithAmount(x.Amount - removedItem.Amount));
}
});
stats = stats.WithNewStat(CharacterStat.Weight, stats[CharacterStat.Weight] - _eifFileProvider.EIFFile[removedItem.ItemID].Weight * removedItem.Amount);
}
foreach (var newItem in addItems)
{
_characterInventoryRepository.ItemInventory.SingleOrNone(x => x.ItemID == newItem.ItemID)
.Match(some: x =>
{
_characterInventoryRepository.ItemInventory.Remove(x);
_characterInventoryRepository.ItemInventory.Add(x.WithAmount(x.Amount + newItem.Amount));
},
none: () =>
{
_characterInventoryRepository.ItemInventory.Add(newItem);
});
stats = stats.WithNewStat(CharacterStat.Weight, stats[CharacterStat.Weight] + _eifFileProvider.EIFFile[newItem.ItemID].Weight * newItem.Amount);
}
if (stats[CharacterStat.Weight] < 0)
stats = stats.WithNewStat(CharacterStat.Weight, 0);
_characterRepository.MainCharacter = _characterRepository.MainCharacter.WithStats(stats);
foreach (var notifier in _tradeEventNotifiers)
notifier.NotifyTradeClose(cancel: false);
return true;
}
}
}