From c3b724c6a96fc3a956558723ace0c662e278aae2 Mon Sep 17 00:00:00 2001 From: Ben Date: Thu, 26 Mar 2020 22:16:07 +0000 Subject: [PATCH] Matchmaking handlers --- houdini/handlers/games/match.py | 187 ++++++++++++++++++++++++++++++++ houdini/houdini.py | 3 + 2 files changed, 190 insertions(+) diff --git a/houdini/handlers/games/match.py b/houdini/handlers/games/match.py index e69de29..fa5b3a9 100644 --- a/houdini/handlers/games/match.py +++ b/houdini/handlers/games/match.py @@ -0,0 +1,187 @@ +import asyncio +import operator +from dataclasses import dataclass + +from houdini import handlers +from houdini.data.room import RoomWaddle +from houdini.handlers import XTPacket +from houdini.handlers.games.ninja.card import CardJitsuLogic +from houdini.handlers.games.ninja.fire import CardJitsuFireLogic +from houdini.handlers.games.ninja.water import CardJitsuWaterLogic +from houdini.penguin import Penguin + + +@dataclass +class MatchMaker: + penguin: Penguin + tick: int + + +class MatchMaking: + SenseiRoom = 951 + SenseiFireRoom = 953 + SenseiWaterRoom = 954 + + def __init__(self, server, on_tick, on_matched, match_by, max_players=2, match_every=10): + self.server = server + self._on_tick = on_tick + self._on_matched = on_matched + + self._match_by = match_by + self._max_players = max_players + self._match_every = match_every + + self._penguins = [] + self._matched_penguins = {} + + async def start(self): + while True: + await self.tick() + await asyncio.sleep(1) + + async def tick(self): + for i in range(0, len(self._penguins) - len(self._penguins) % 2, self._max_players): + matched = self._penguins[i:i+self._max_players] + if any(mm.tick == 0 for mm in matched): + matched_penguins = [mm.penguin for mm in matched] + self._matched_penguins.update({ + mm.penguin.id: matched_penguins + for mm in matched}) + self._penguins = [mm for mm in self._penguins if mm not in matched] + + await self._on_matched(matched) + else: + await self._on_tick(matched) + for mm in matched: + mm.tick -= 1 + + def add_penguin(self, p): + mm = MatchMaker(penguin=p, tick=self._match_every) + self._penguins.append(mm) + self._penguins.sort(key=operator.attrgetter('penguin.' + self._match_by)) + + def remove_penguin(self, p): + self._penguins = [mm for mm in self._penguins if mm.penguin != p] + if p.id in self._matched_penguins: + matched = self._matched_penguins[p.id] + matched.remove(p) + + del self._matched_penguins[p.id] + self._penguins.sort(key=operator.attrgetter('penguin.' + self._match_by)) + + def matched_with(self, p): + if p.id in self._matched_penguins: + return self._matched_penguins[p.id] + + def has_matched(self, p): + return p.id in self._matched_penguins + + +async def card_tick(matched): + nicknames = [mm.penguin.safe_name for mm in matched] + for mm in matched: + await mm.penguin.send_xt('tmm', mm.tick, *nicknames) + + +async def card_color_tick(matched): + nicknames = [f'{mm.penguin.safe_name}|{mm.penguin.color}' for mm in matched] + for mm in matched: + await mm.penguin.send_xt('tmm', len(matched), mm.tick, *nicknames) + + +def card_match(waddle_room_id, waddle_game): + async def match(matched): + nicknames = [f'{mm.penguin.safe_name}|{mm.penguin.color}' for mm in matched] + host = matched[0].penguin + + waddle_room = host.server.rooms[waddle_room_id] + rw = RoomWaddle(id=host.id, room_id=waddle_room.id, seats=len(matched), game=waddle_game, temporary=True) + waddle_room.waddles[rw.id] = rw + + for mm in matched: + await mm.penguin.send_xt('scard', waddle_room.id, rw.id, len(matched), mm.tick, *nicknames) + return match + + +card_matched = card_match(CardJitsuLogic.room_id, 'card') +card_fire_matched = card_match(CardJitsuFireLogic.room_id, 'fire') +card_water_matched = card_match(CardJitsuWaterLogic.room_id, 'water') + + +@handlers.boot +async def match_load(server): + server.match_making = MatchMaking(server, card_tick, card_matched, match_by='ninja_rank') + server.fire_match_making = MatchMaking(server, card_color_tick, card_fire_matched, + match_by='fire_ninja_rank', max_players=4) + server.water_match_making = MatchMaking(server, card_color_tick, card_water_matched, + match_by='water_ninja_rank', max_players=4) + + asyncio.create_task(server.match_making.start()) + asyncio.create_task(server.fire_match_making.start()) + asyncio.create_task(server.water_match_making.start()) + + +@handlers.handler(XTPacket('jmm', ext='z')) +@handlers.player_in_room(MatchMaking.SenseiRoom) +async def handle_join_match_making(p): + p.server.match_making.add_penguin(p) + await p.send_xt('jmm', p.safe_name) + + +@handlers.handler(XTPacket('jmm', ext='z')) +@handlers.player_in_room(MatchMaking.SenseiFireRoom) +async def handle_join_fire_match_making(p): + p.server.fire_match_making.add_penguin(p) + await p.send_xt('jmm', p.safe_name) + + +@handlers.handler(XTPacket('jmm', ext='z')) +@handlers.player_in_room(MatchMaking.SenseiWaterRoom) +async def handle_join_water_match_making(p): + p.server.water_match_making.add_penguin(p) + await p.send_xt('jmm', p.safe_name) + + +@handlers.handler(XTPacket('jsen', ext='z')) +@handlers.player_in_room(MatchMaking.SenseiRoom) +async def handle_join_sensei_match(p): + waddle_room = p.server.rooms[CardJitsuLogic.__room_id__] + rw = RoomWaddle(id=p.id, room_id=waddle_room.id, seats=1, game='sensei', temporary=True) + waddle_room.waddles[rw.id] = rw + + await p.send_xt('scard', waddle_room.id, rw.id, 1, 0, f'{p.safe_name}|{p.color}') + + +@handlers.handler(XTPacket('jsen', ext='z')) +@handlers.player_in_room(MatchMaking.SenseiFireRoom) +async def handle_join_fire_sensei_match(p): + waddle_room = p.server.rooms[CardJitsuFireLogic.__room_id__] + rw = RoomWaddle(id=p.id, room_id=waddle_room.id, seats=1, game='firesensei', temporary=True) + waddle_room.waddles[rw.id] = rw + + await p.send_xt('scard', waddle_room.id, rw.id, 1, 0, f'{p.safe_name}|{p.color}') + + +@handlers.handler(XTPacket('jsen', ext='z')) +@handlers.player_in_room(MatchMaking.SenseiWaterRoom) +async def handle_join_water_sensei_match(p): + waddle_room = p.server.rooms[CardJitsuWaterLogic.__room_id__] + rw = RoomWaddle(id=p.id, room_id=waddle_room.id, seats=1, game='watersensei', temporary=True) + waddle_room.waddles[rw.id] = rw + + await p.send_xt('scard', waddle_room.id, rw.id, 1, 0, f'{p.safe_name}|{p.color}') + + +@handlers.handler(XTPacket('lmm', ext='z')) +async def handle_leave_match_making(p): + p.server.match_making.remove_penguin(p) + p.server.water_match_making.remove_penguin(p) + p.server.fire_match_making.remove_penguin(p) + + +@handlers.disconnected +@handlers.player_attribute(joined_world=True) +async def handle_disconnect_match_making(p): + p.server.match_making.remove_penguin(p) + p.server.water_match_making.remove_penguin(p) + p.server.fire_match_making.remove_penguin(p) diff --git a/houdini/houdini.py b/houdini/houdini.py index 6b7ca37..e2f8af8 100644 --- a/houdini/houdini.py +++ b/houdini/houdini.py @@ -87,6 +87,9 @@ class Houdini: self.music = None self.dance_floor = None + self.match_making = None + self.water_match_making = None + self.fire_match_making = None self.puck = (0, 0)