mirror of
https://github.com/Lost-MSth/Arcaea-server.git
synced 2026-02-04 21:47:28 +08:00
6fcca17918
- Code refactoring - Fix a bug that the other player will not become the host of the room at once, when the player disconnect in link play. > Maybe add many unknown bugs. XD > The song database `arcsong.db` will not used in the future. You can use a tool in `tool` folder to import old data.
82 lines
2.8 KiB
Python
82 lines
2.8 KiB
Python
from multiprocessing import Pipe
|
|
|
|
from core.error import ArcError
|
|
from core.linkplay import LocalMultiPlayer, Player, Room
|
|
from core.sql import Connect
|
|
from flask import Blueprint, request
|
|
from setting import Config
|
|
|
|
from .auth import auth_required
|
|
from .func import error_return, success_return
|
|
|
|
bp = Blueprint('multiplayer', __name__, url_prefix='/multiplayer')
|
|
|
|
conn1, conn2 = Pipe()
|
|
|
|
|
|
@bp.route('/me/room/create', methods=['POST']) # 创建房间
|
|
@auth_required(request)
|
|
def room_create(user_id):
|
|
if not Config.UDP_PORT or Config.UDP_PORT == '':
|
|
return error_return(ArcError('The local udp server is down.', 151)), 404
|
|
with Connect() as c:
|
|
try:
|
|
x = LocalMultiPlayer(conn1)
|
|
user = Player(c, user_id)
|
|
user.get_song_unlock(request.json['clientSongMap'])
|
|
x.create_room(user)
|
|
r = x.to_dict()
|
|
r['endPoint'] = request.host.split(
|
|
':')[0] if Config.LINK_PLAY_HOST == '' else Config.LINK_PLAY_HOST
|
|
r['port'] = int(Config.UDP_PORT)
|
|
return success_return(r)
|
|
except ArcError as e:
|
|
return error_return(e), 400
|
|
return error_return()
|
|
|
|
|
|
@bp.route('/me/room/join/<room_code>', methods=['POST']) # 加入房间
|
|
@auth_required(request)
|
|
def room_join(user_id, room_code):
|
|
if not Config.UDP_PORT or Config.UDP_PORT == '':
|
|
return error_return(ArcError('The local udp server is down.', 151)), 404
|
|
|
|
with Connect() as c:
|
|
try:
|
|
x = LocalMultiPlayer(conn1)
|
|
user = Player(c, user_id)
|
|
user.get_song_unlock(request.json['clientSongMap'])
|
|
room = Room()
|
|
room.room_code = room_code
|
|
x.join_room(room, user)
|
|
r = x.to_dict()
|
|
r['endPoint'] = request.host.split(
|
|
':')[0] if Config.LINK_PLAY_HOST == '' else Config.LINK_PLAY_HOST
|
|
r['port'] = int(Config.UDP_PORT)
|
|
return success_return(r)
|
|
except ArcError as e:
|
|
return error_return(e), 400
|
|
return error_return()
|
|
|
|
|
|
@bp.route('/me/update', methods=['POST']) # 更新房间
|
|
@auth_required(request)
|
|
def multiplayer_update(user_id):
|
|
if not Config.UDP_PORT or Config.UDP_PORT == '':
|
|
return error_return(ArcError('The local udp server is down.', 151)), 404
|
|
|
|
with Connect() as c:
|
|
try:
|
|
x = LocalMultiPlayer(conn1)
|
|
user = Player(c, user_id)
|
|
user.token = int(request.json['token'])
|
|
x.update_room(user)
|
|
r = x.to_dict()
|
|
r['endPoint'] = request.host.split(
|
|
':')[0] if Config.LINK_PLAY_HOST == '' else Config.LINK_PLAY_HOST
|
|
r['port'] = int(Config.UDP_PORT)
|
|
return success_return(r)
|
|
except ArcError as e:
|
|
return error_return(e), 400
|
|
return error_return()
|