a91082900/ElegyOfDisaster
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

spec added; card function 1, 2, 3, 4 modified

Browse Source
This commit is contained in:
a91082900
2018-05-17 23:21:59 +08:00
committed by GitHub
parent 22cb3f44f3
commit 152a71ff05
5 changed files with 621 additions and 161 deletions
Download Patch File Download Diff File Expand all files Collapse all files

184
pyws.py
View File

@@ -6,73 +6,157 @@ import asyncio
import datetime
import random
import websockets
from json import dumps, loads
connected = {-1: []}
character = dict()
name=["安","圭月","梅","小兔","銀","正作","W","桑德","海爾","雪村"]
for i in range(len(name)):
character[str(i+1)] = name[i]
character[str(i+1)] = name[i]
sad = None
fut = None
async def wait(websocket, *cors, timeout=45, futs=None):
if futs != None:
fut_cor = futs
else:
fut_cor = [cor() for cor in cors]
done, pending = await asyncio.wait(fut_cor,
return_when=asyncio.FIRST_EXCEPTION, timeout=timeout)
#print(done, pending)
if pending:
#print("coroutine doesn't finish its work")
pass
if len(done):
return list(done)[0].result()
else:
#print("SADDDDD")
return
def random_room():
global connected, rooms
try:
print(rooms)
except:
rooms = list(connected)
rooms.remove(-1)
print(rooms)
while len(rooms)>=1:
enter = random.choice(rooms)
print("rooms", enter, rooms)
rooms.remove(enter)
if len(connected[enter]) < 2:
return enter
while 1:
enter = random.randint(1, 99999)
if enter not in connected:
rooms.append(enter)
return enter
async def enter_room(websocket):
global connected ,sad, fut
room_list = [room_id for room_id in connected if len(connected[room_id])<2 and room_id != -1]
#print("I'm here")
await websocket.send(str(room_list))
#print("In enter_room, SAD")
message = await wait(websocket, websocket.recv)
if message == "n":
room_id = random_room()
else:
room_id = int(message)
connected[room_id] = connected.get(room_id, Room(room_id))
count = len(connected[room_id])
print(count)
if count <= 1: # Enter the room
connected[room_id].player_add(websocket)
connected[-1].remove(websocket)
websocket.room = room_id
websocket.status = Room.WAITING
if count+1 == 1: # 該玩家已加入房間
await websocket.send(str(room_id))
sad = websocket
else:
players = connected[websocket.room].start()
for ws in connected[room_id]:
ws.status = Room.PLAYING
wsene = connected[room_id].players[0] if connected[room_id].players[1] is websocket else connected[room_id].players[1]
await ws.send(dumps({"room": room_id, "cur": websocket.player.name, "ene": wsene.player.name}))
await ws.send(dumps({"msg": "firstAttack", "data": [players[0].player.name], "hand": ws.player.hand}))
fut.cancel()
for ws_list, message in Room.start_turn(*players):
await sendTo(message, *ws_list)
async def handler(websocket, path):
global connected
global connected,sad, fut
# Register.
connected[-1].append(websocket)
websocket.status = Room.CONNECTED
# CHOOSE CHARACTER
await websocket.send("CHOOSE CHARACTER")
try:
choice = await wait(websocket, websocket.recv)
if int(choice) not in range(1, len(name)+1):
raise ValueError("Wrong input, close the connection...")
websocket.player = game.Player(name[int(choice)-1], card.default_deck)
websocket.status = Room.MATCHING
except:
return # close the connection
try:
# Implement logic here.
while 1:
message = await websocket.recv()
if websocket.status == Room.CONNECTED: # choose character
choice = message
while choice not in map(lambda x : str(x+1),list(range(len(name)))):
await websocket.send("CHOOSE")
await websocket.send("CHOOSE: "+ str(choice) + "\n" + str(list(range(len(name)))))
choice = await websocket.recv()
p_name = character[choice]
await websocket.send("PLAYER "+p_name)
websocket.player = game.Player(p_name,card.default_deck)
websocket.status = Room.MATCHING
elif websocket.status == Room.MATCHING:
try:
room_id = int(message)
connected[room_id] = connected.get(room_id, Room(room_id))
count = connected[room_id].count()
if count <= 1: # Enter the room
connected[room_id].player_add(websocket)
connected[-1].remove(websocket)
await websocket.send("You have entered room "+ str(connected[room_id]))
websocket.room = room_id
if count+1 == 1: # 該玩家已加入房間
await websocket.send("Waiting for another player...")
else:
for ws in connected[room_id]:
ws.status = Room.PLAYING
await ws.send("The game will start soon.....")
# await connected[room_id].start()
# Testing
else: # Can't enter the room
await websocket.send("SAD, This room is full. Please enter another room.")
except Exception as e:
print(e)
print("STATUS = MATCHING")
elif websocket.status == Room.PLAYING:
print("STATUS = PLAYING, message got")
for ws in connected[websocket.room]:
await ws.send("STARTING... But unfortunately, we haven't completed this part of code.")
print("STATUS = PLAYING, message sent")
while 1:
#message = await wait(websocket, websocket.recv, timeout=10)
if websocket.status == Room.MATCHING:
await enter_room(websocket)
elif websocket.status == Room.WAITING:
print("SAD", "FIRST" if websocket == sad else "SECOND")
fut = asyncio.ensure_future(websocket.recv())
try:
message = await wait(websocket, timeout=100000, futs=[fut])
if message == "e":
connected[websocket.room].player_delete(websocket)
await websocket.send("You have left Room "+str(connected[websocket.room]))
del websocket.room
connected[-1].append(websocket)
websocket.status = Room.MATCHING
except asyncio.CancelledError:
pass
print("SADDDDDD", "FIRST" if websocket == sad else "SECOND")
elif websocket.status == Room.PLAYING:
print("wait for message", "FIRST" if websocket == sad else "SECOND")
message = await wait(websocket, websocket.recv, timeout=100000)
print("received message", "FIRST" if websocket == sad else "SECOND")
message_to_send = connected[websocket.room].process(websocket, message)
for ws_list, message in message_to_send:
await sendTo(message, *ws_list)
finally:
# Unregister.
connected[websocket.room].player_delete(websocket)
try:
connected[websocket.room].player_delete(websocket)
except:
connected[-1].remove(websocket)
print(connected)