Update server.py

server.py

@@ -1,12 +1,8 @@
 import random
 import json
 import socketio
-from flask import Flask, jsonify
+from flask import Flask, render_template, jsonify
 import eventlet
-import threading
-from nats.aio.client import Client as NATS
-import asyncpg
-import asyncio
 
 eventlet.monkey_patch()
 
@@ -14,39 +10,10 @@ sio = socketio.Server(cors_allowed_origins='*')
 app = Flask(__name__)
 app.wsgi_app = socketio.WSGIApp(sio, app.wsgi_app)
 
-DB_DSN = "postgresql://postgres:postgres@pgbouncer:6432/postgres"
-NATS_URL = "nats://nats:4222"
-
 WAITING_PLAYERS = []
 PLAYER_DATA = {}
 GAME_STATES = {}
 
-nats_client = NATS()
-loop = asyncio.new_event_loop()
-asyncio.set_event_loop(loop)
-
-async def init_db():
-    return await asyncpg.create_pool(dsn=DB_DSN)
-
-db_pool = loop.run_until_complete(init_db())
-
-async def publish_event(event_type, data):
-    message = json.dumps({'type': event_type, 'data': data})
-    await nats_client.publish("checkers", message.encode())
-
-async def subscribe():
-    async def message_handler(msg):
-        event = json.loads(msg.data.decode())
-        if event['type'] == 'opponent_move':
-            sio.emit('opponent_move', event['data']['move'], room=event['data']['room'], skip_sid=event['data']['sid'])
-        elif event['type'] == 'game_over':
-            sio.emit('game_over', event['data'], room=event['data']['room'])
-        elif event['type'] == 'opponent_disconnected':
-            sio.emit('opponent_disconnected', room=event['data']['room'])
-
-    await nats_client.connect(servers=[NATS_URL], loop=loop)
-    await nats_client.subscribe("checkers", cb=message_handler)
-
 def init_board():
     board = [[None for _ in range(8)] for _ in range(8)]
     for row in range(3):
@@ -79,7 +46,7 @@ def get_valid_moves(board, row, col, color, is_king):
 
 @app.route('/')
 def index():
-    return "Checkers server running."
+    return render_template('client.html')
 
 @app.route('/state')
 def game_state():
@@ -166,18 +133,18 @@ def move(sid, data):
 
     flat = sum(board, [])
     if all(p not in flat for p in ['r', 'R']):
-        loop.create_task(publish_event('game_over', {'winner': 'black', 'room': room}))
+        sio.emit('game_over', {'winner': 'black', 'room': room}, room=room)
         del GAME_STATES[room]
         return
     if all(p not in flat for p in ['b', 'B']):
-        loop.create_task(publish_event('game_over', {'winner': 'red', 'room': room}))
+        sio.emit('game_over', {'winner': 'red', 'room': room}, room=room)
         del GAME_STATES[room]
         return
 
     state['board'] = board
     state['turn'] = 'black' if turn == 'red' else 'red'
     GAME_STATES[room] = state
-    loop.create_task(publish_event('opponent_move', {'move': data, 'room': room, 'sid': sid}))
+    sio.emit('opponent_move', {'move': data, 'room': room, 'sid': sid}, room=room, skip_sid=sid)
 
 @sio.event
 def disconnect(sid):
@@ -192,8 +159,7 @@ def disconnect(sid):
                 del PLAYER_DATA[psid]
         if room in GAME_STATES:
             del GAME_STATES[room]
-        loop.create_task(publish_event('opponent_disconnected', {'room': room}))
+        sio.emit('opponent_disconnected', room=room)
 
 if __name__ == '__main__':
-    threading.Thread(target=lambda: loop.run_until_complete(subscribe()), daemon=True).start()
     eventlet.wsgi.server(eventlet.listen(('0.0.0.0', 5000)), app)