diff --git a/7002.py b/7002.py
new file mode 100644
index 0000000..6e47f69
--- /dev/null
+++ b/7002.py
@@ -0,0 +1,56 @@
+from starlette.applications import Starlette
+from starlette.responses import FileResponse, Response
+from starlette.routing import Route
+import os
+
+# stupid loading sequence
+from api.templates import init_templates
+init_templates()
+
+from api.database import database, init_db
+from api.misc import get_4max_version_string
+
+from api.user import routes as user_routes
+from api.ranking import routes as rank_routes
+from api.shop import routes as shop_routes
+
+from config import HOST, PORT, DEBUG, SSL_CERT, SSL_KEY, ROOT_FOLDER, ACTUAL_HOST, ACTUAL_PORT
+
+if (os.path.isfile('./files/dlc_4max.html')):
+ get_4max_version_string()
+
+allowed_folders = ["files"]
+
+async def serve_file(request):
+ path = request.path_params['path']
+ for folder in allowed_folders:
+ if path.startswith(folder):
+ file_path = os.path.join(ROOT_FOLDER, path)
+ if os.path.isfile(file_path):
+ return FileResponse(file_path)
+
+ return Response("", status_code=404)
+
+routes = []
+
+routes = routes + user_routes + rank_routes + shop_routes
+
+routes.append(Route("/{path:path}", serve_file))
+
+app = Starlette(debug=DEBUG, routes=routes)
+
+@app.on_event("startup")
+async def startup():
+ await database.connect()
+ await init_db()
+
+@app.on_event("shutdown")
+async def shutdown():
+ await database.disconnect()
+
+if __name__ == "__main__":
+ import uvicorn
+ ssl_context = (SSL_CERT, SSL_KEY) if SSL_CERT and SSL_KEY else None
+ uvicorn.run(app, host=ACTUAL_HOST, port=ACTUAL_PORT, ssl_certfile=SSL_CERT, ssl_keyfile=SSL_KEY)
+
+# Made By Tony 2025.5.10
\ No newline at end of file
diff --git a/README.md b/README.md
index b64f34c..50d6b34 100644
--- a/README.md
+++ b/README.md
@@ -2,7 +2,7 @@
A small local server for `Groove Coaster 2: Original Style`, implemented with `Python` and `Flask`.
-一个基于`Python`和`Flask`的微型`Groove Coaster 2: Original Style`本地服务器。
+一个基于`Python`和~~`Flask`~~`Starlette`的微型`Groove Coaster 2: Original Style`本地服务器。
English
@@ -14,7 +14,9 @@ This project is for game preservation purposes only. Creative liberty and conven
You shall bare all the responsibility for any potential consequences as a result of running this server. If you do not agree to these requirements, you are not allowed to replicate or run this program.
-It is designed as a **local** server, as Flask face issues with high concurrency. There is an optimized, `async` server, but the code is not open source. Only vetted server owners that will not violate the license terms will be given access. Contact the repo owner for more information.
+~~It is designed as a **local** server, as Flask face issues with high concurrency. There is an optimized, `async` server, but the code is not open source. Only vetted server owners that will not violate the license terms will be given access. Contact the repo owner for more information.~~
+
+The async server is now open source under the GPLv2 license. It has superceded the old server in terms of functionality and performance.
Inspiration: [Lost-MSth/Arcaea-server](https://github.com/Lost-MSth/Arcaea-server)
@@ -65,7 +67,7 @@ The server owner must install the update on their instance. They can download it
- Python
-- Flask
+- ~~Flask~~ `Starlette`
- Crypto (pycryptodome)
@@ -99,13 +101,13 @@ Note that MAC uses `python3`. Code examples in this document will use the defaul
Open command on Windows (MAC open terminal). Type `ipconfig` (MAC `ifconfig`), and obtain your IPV4 address. This assumes that you are connected to a WIFI, and it should start with 192 or 172.
-Open the `config_old.py` of the private server, and change the `IP` accordingly.
+Open the `config.env` of the private server, and change the `IP` accordingly.
Type `cmd` in the file directory on the top of the file explorer, and press enter. A command prompt will be opened for that directory.
Type `pip install -r requirements.txt` to install all the dependencies.
-Type `python 7001.py` to start the server. If an error pops up, resolve it now – did you install all the dependencies? Is the IP correct?
+Type `python 7002.py` to start the server. If an error pops up, resolve it now – did you install all the dependencies? Is the IP correct?
### Android (Harder)
@@ -125,7 +127,7 @@ Use
`pip install ...`
-to install `rust`, `flask`, `passlib`, `pycryptodome`, `requests`.
+to install `rust`, `starlette`, `passlib`, `pycryptodome`, `requests`.
If ssl errors pop up, you might need to ``pkg up ssl -y``.
@@ -135,7 +137,7 @@ change `config.py`'s `IP` to `127.0.0.1` (this is `loopback`. Feel free to use y
`cd storage/shared/.... (server location on android file system)`
-`python 7001.py` to start the server.
+`python 7002.py` to start the server.
@@ -263,7 +265,9 @@ Note that this data is for analytics only, and the functionality to embed this d
你应对因运行本服务器而产生的任何潜在后果承担全部责任。如果您不同意这些要求，则不允许您复制或运行该程序。
-此服务器仅为**本地**运行设计，鉴于Flask糟糕的并发性能。一个高效，`异步`的服务器可供使用，不过代码并非开源。只有经过审核，不会违反许可条款的服务器所有者才能获得访问权限。请联系repo所有者了解更多信息。
+~~此服务器仅为**本地**运行设计，鉴于Flask糟糕的并发性能。一个高效，`异步`的服务器可供使用，不过代码并非开源。只有经过审核，不会违反许可条款的服务器所有者才能获得访问权限。请联系repo所有者了解更多信息。~~
+
+基于`Starlette`的异步服务器已经在功能和性能上超越了老服务器，现在以`GPLv2`许可证开源。
灵感: [Lost-MSth/Arcaea-server](https://github.com/Lost-MSth/Arcaea-server)
@@ -313,7 +317,7 @@ Note that this data is for analytics only, and the functionality to embed this d
- Python
-- Flask
+- ~~Flask~~`Starlette`
- Crypto (pycryptodome)
@@ -348,11 +352,11 @@ PC/MAC安装 `python`，安装 `pip`。
PC打开 `cmd` 输入 `ipconfig`。MAC 打开 `terminal` 输入 `ifconfig`。获得你的`IPV4`,一串为192或172开头的数字。
-PC用文本编辑器打开服务器文件夹的 `config.py`，将`IPV4`填写至`IP`。`PORT`(端口)也可以更改。
+PC用文本编辑器打开服务器文件夹的 `config.env`，将`IPV4`填写至`IP`。`PORT`(端口)也可以更改。
文件管理器上方的文件夹路径清空，输入 `cmd`。命令行窗口会弹出。
-输入 `python 7001.py`来开启服务器。如果出现错误，就解决他们吧。检查依赖项是否安装，网络配置是否正确。
+输入 `python 7002.py`来开启服务器。如果出现错误，就解决他们吧。检查依赖项是否安装，网络配置是否正确。
### 安卓(稍难)
@@ -372,7 +376,7 @@ PC用文本编辑器打开服务器文件夹的 `config.py`，将`IPV4`填写至
`pip install ...`
-来安装 `rust`, `flask`, `bcrypt`, `pycryptodome`, `requests`.
+来安装 `rust`, `starlette`, `bcrypt`, `pycryptodome`, `requests`.
如果出现ssl问题，可能需要``pkg up ssl -y``.
@@ -382,7 +386,7 @@ PC用文本编辑器打开服务器文件夹的 `config.py`，将`IPV4`填写至
`cd storage/shared/.... (服务器在安卓文件系统的位置)`
-`python 7001.py` 来运行服务器。
+`python 7002.py` 来运行服务器。
@@ -516,8 +520,11 @@ server/
│ │ └─ title
│ ├─ web/ (found in common.zip)
│ │ └─ webpage assets
-├─ 7001.py (main script)
+├─ 7002.py (main script)
+├─ api/ (API scripts)
+│ ├─ config/ (various configuration files)
├─ getCrypt.py (debug purpose only)
+├─ old_server (Flask old server (depricated))
└─ config.py (configuration script)
diff --git a/api/crypt.py b/api/crypt.py
new file mode 100644
index 0000000..d794e7c
--- /dev/null
+++ b/api/crypt.py
@@ -0,0 +1,38 @@
+from Crypto.Cipher import AES
+import re
+import urllib.parse
+from starlette.requests import Request
+
+# Found in: aesManager::initialize()
+# Used for: Crypting parameter bytes sent by client
+# Credit: https://github.com/Walter-o/gcm-downloader
+AES_CBC_KEY = b"oLxvgCJjMzYijWIldgKLpUx5qhUhguP1"
+
+# Found in: aesManager::decryptCBC() and aesManager::encryptCBC()
+# Used for: Crypting parameter bytes sent by client
+# Credit: https://github.com/Walter-o/gcm-downloader
+AES_CBC_IV = b"6NrjyFU04IO9j9Yo"
+
+# Decrypt AES encrypted data, takes in a hex string
+# Credit: https://github.com/Walter-o/gcm-downloader
+def decryptAES(data, key=AES_CBC_KEY, iv=AES_CBC_IV):
+ return AES.new(key, AES.MODE_CBC, iv).decrypt(bytes.fromhex(data))
+
+# Encrypt data with AES, takes in a bytes object
+# Credit: https://github.com/Walter-o/gcm-downloader
+def encryptAES(data, key=AES_CBC_KEY, iv=AES_CBC_IV):
+ while len(data) % 16 != 0:
+ data += b"\x00"
+ encryptedData = AES.new(key, AES.MODE_CBC, iv).encrypt(data)
+ return encryptedData.hex()
+
+async def decrypt_fields(request: Request):
+ url = str(request.url)
+ match = re.search(r'\?(.*)', url)
+ if match:
+ original_field = match.group(1)
+ decrypted_fields = urllib.parse.parse_qs(decryptAES(match.group(1))[:-1])
+
+ return decrypted_fields, original_field
+ else:
+ return None, None
\ No newline at end of file
diff --git a/api/database.py b/api/database.py
new file mode 100644
index 0000000..a8e4e25
--- /dev/null
+++ b/api/database.py
@@ -0,0 +1,128 @@
+from starlette.responses import JSONResponse, Response
+from starlette.requests import Request
+
+import sqlalchemy
+from sqlalchemy import Table, Column, Integer, String, DateTime, ForeignKey
+from sqlalchemy.ext.asyncio import create_async_engine
+from sqlalchemy import select, update
+
+import os
+import databases
+import datetime
+
+DB_NAME = "player.db"
+DB_PATH = os.path.join(os.getcwd(), DB_NAME)
+DATABASE_URL = f"sqlite+aiosqlite:///{DB_PATH}"
+
+database = databases.Database(DATABASE_URL)
+metadata = sqlalchemy.MetaData()
+
+user = Table(
+ "user",
+ metadata,
+ Column("id", Integer, primary_key=True, autoincrement=True),
+ Column("username", String(20), unique=True, nullable=False),
+ Column("password_hash", String(255), nullable=False),
+ Column("device_id", String(512)),
+ Column("data", String, nullable=True),
+ Column("save_id", String, nullable=True),
+ Column("crc", Integer, nullable=True),
+ Column("timestamp", DateTime, default=datetime.datetime.utcnow),
+ Column("coin_mp", Integer, default=1),
+)
+
+daily_reward = Table(
+ "daily_reward",
+ metadata,
+ Column("id", Integer, primary_key=True, autoincrement=True),
+ Column("device_id", String(512)),
+ Column("timestamp", DateTime, default=datetime.datetime.utcnow),
+ Column("my_stage", String),
+ Column("my_avatar", String),
+ Column("item", String),
+ Column("day", Integer),
+ Column("coin", Integer),
+ Column("lvl", Integer),
+ Column("title", Integer),
+ Column("avatar", Integer),
+)
+
+result = Table(
+ "result",
+ metadata,
+ Column("rid", Integer, primary_key=True, autoincrement=True),
+ Column("vid", String(512), nullable=False),
+ Column("tid", String(512), nullable=False),
+ Column("sid", String(512), nullable=False),
+ Column("stts", String(64)),
+ Column("id", String(8)),
+ Column("mode", String(4)),
+ Column("avatar", String(4)),
+ Column("score", String(16)),
+ Column("high_score", String(128)),
+ Column("play_rslt", String(128)),
+ Column("item", String(16)),
+ Column("os", String(16)),
+ Column("os_ver", String(16)),
+ Column("ver", String(16)),
+ Column("mike", String(8)),
+
+)
+
+whitelist = Table(
+ "whitelist",
+ metadata,
+ Column("id", String(512), primary_key=True)
+)
+blacklist = Table(
+ "blacklist",
+ metadata,
+ Column("id", String(512), primary_key=True),
+ Column("reason", String(256))
+)
+
+async def init_db():
+
+ if not os.path.exists(DB_PATH):
+ print("[DB] Creating new database:", DB_PATH)
+
+ engine = create_async_engine(DATABASE_URL, echo=False)
+
+ async with engine.begin() as conn:
+ await conn.run_sync(metadata.create_all)
+
+ await engine.dispose()
+ print("[DB] Database initialized successfully.")
+
+async def get_user_data(uid, data_field):
+ query = select(user.c[data_field]).where(user.c.device_id == uid[b'vid'][0].decode())
+ async with database.transaction():
+ result = await database.fetch_one(query)
+ return result[data_field] if result else None
+
+async def set_user_data(uid, data_field, new_data):
+ query = (
+ update(user)
+ .where(user.c.device_id == uid[b'vid'][0].decode())
+ .values({data_field: new_data})
+ )
+ async with database.transaction():
+ await database.execute(query)
+
+async def check_whitelist(uid):
+ query = select(whitelist.c.id).where(whitelist.c.id == uid[b'vid'][0].decode())
+ async with database.transaction():
+ result = await database.fetch_one(query)
+ return result is not None
+
+async def check_blacklist(uid):
+ device_id = uid[b'vid'][0].decode()
+ user_data = await get_user_data(uid, "username")
+ username = user_data[0] if user_data else None
+
+ query = select(blacklist.c.id).where(
+ (blacklist.c.id == device_id) | (blacklist.c.id == username)
+ )
+ async with database.transaction():
+ result = await database.fetch_one(query)
+ return result is None
\ No newline at end of file
diff --git a/api/misc.py b/api/misc.py
new file mode 100644
index 0000000..e07c1ec
--- /dev/null
+++ b/api/misc.py
@@ -0,0 +1,127 @@
+import requests
+import json
+import binascii
+import bcrypt
+import re
+import xml.etree.ElementTree as ET
+from config import MODEL, TUNEFILE, SKIN
+
+FMAX_VER = None
+FMAX_RES = None
+
+def get_4max_version_string():
+ url = "https://studio.code.org/v3/sources/3-aKHy16Y5XaAPXQHI95RnFOKlyYT2O95ia2HN2jKIs/main.json"
+ global FMAX_VER
+ try:
+ with open("./files/4max_ver.txt", 'r') as file:
+ FMAX_VER = file.read().strip()
+ except Exception as e:
+ print(f"An unexpected error occurred when loading files/4max_ver.txt: {e}")
+
+ def fetch():
+ global FMAX_RES
+ try:
+ response = requests.get(url)
+ if 200 <= response.status_code <= 207:
+ try:
+ FMAX_RES = json.loads(json.loads(response.text)['source'])
+ except (json.JSONDecodeError, KeyError):
+ FMAX_RES = 500
+ else:
+ FMAX_RES = response.status_code
+ except requests.RequestException:
+ FMAX_RES = 400
+
+ fetch()
+
+def parse_res(res):
+ parsed_data = []
+ if isinstance(res, int):
+ return "Failed to fetch version info: Error " + str(res)
+
+ for item in res:
+ if item.get("isOpen"):
+ version = item.get("version", "Unknown Version")
+ changelog = " ".join(item.get("changeLog", {}).get("en", []))
+ parsed_data.append(f"Version: {version}
"""
+
+ button_modes = [1, 2, 3]
+ print(len(difficulty_levels))
+
+ if (len(difficulty_levels) == 6):
+ button_labels.extend(["AC-Easy", "AC-Normal", "AC-Hard"])
+ button_modes.extend([11, 12, 13])
+
+ if song_id > 615:
+ button_modes = [x for x in button_modes if x not in [1, 2, 3]]
+ button_labels = [x for x in button_labels if x not in ["Easy", "Normal", "Hard"]]
+
+ row_start = '
'
+ row_end = '
'
+ row_content = []
+
+ for i, (label, mode_value) in enumerate(zip(button_labels, button_modes)):
+ if mode_value == mode:
+ row_content.append(f"""
{label}
""")
+ else:
+ encrypted_mass = encryptAES(("vid=" + device_id + "&song_id=" + str(song_id) + "&mode=" + str(mode_value) + "&dummy=").encode("utf-8"))
+ row_content.append(f"""{label}""")
+
+ if len(row_content) == 3:
+ html += row_start + ''.join(row_content) + row_end
+ row_content = [] # Reset row content
+
+ play_results = None
+ user_result = None
+ device_result = None
+
+ if (song_id == -1):
+ # Filter out the mobile/AC modes
+ if (mode == 1):
+ exclude = []
+ elif mode == 2:
+ exclude = [11, 12, 13]
+ else:
+ exclude = [1, 2, 3]
+
+ query = select(result.c.vid, result.c.sid, result.c.mode, result.c.avatar, result.c.score)
+ play_results = await database.fetch_all(query)
+
+ query = select(daily_reward.c.device_id, daily_reward.c.title, daily_reward.c.avatar)
+ device_results_raw = await database.fetch_all(query)
+ device_results = {row["device_id"]: {"title": row["title"], "avatar": row["avatar"]} for row in device_results_raw}
+
+ query = select(user.c.id, user.c.username, user.c.device_id)
+ user_results_raw = await database.fetch_all(query)
+ user_results = {row["id"]: {"username": row["username"], "device_id": row["device_id"]} for row in user_results_raw}
+
+ query = select(user).where(user.c.device_id == device_id)
+ cur_user = await database.fetch_one(query)
+
+ player_scores = {}
+
+ filtered_play_results = [play for play in play_results if int(play[2]) not in exclude]
+
+ for play in filtered_play_results:
+ did = play[0]
+ sid = play[1]
+ avatar = play[3]
+ score = play[4]
+ username, title = None, None
+
+ if sid:
+ sid = int(sid)
+ if sid in user_results:
+ username = user_results[sid]["username"]
+ did = user_results[sid]["device_id"]
+ else: # Guest
+ username = f"Guest({did[-6:]})"
+
+ # title is device-specific
+ title = device_results.get(did, {}).get("title", "1")
+
+ if username in player_scores:
+ player_scores[username]["score"] += int(score)
+ player_scores[username]["avatar"] = avatar # But avatar is based on latest play submission
+ player_scores[username]["title"] = title
+ else:
+ player_scores[username] = {"score": int(score), "avatar": avatar, "title": title}
+
+ sorted_players = sorted(player_scores.items(), key=lambda x: x[1]["score"], reverse=True)
+
+ username = cur_user[1] if cur_user else f"Guest({device_id[-6:]})"
+
+ player_rank = None
+ user_score = 0
+ avatar = "1"
+ title = "1"
+
+ for rank, (player_name, data) in enumerate(sorted_players, start=1):
+ if player_name == username:
+ player_rank = rank
+ user_score = data["score"]
+ avatar = data["avatar"]
+ title = data["title"]
+ break
+
+ if player_rank is None:
+ device_data = next((device for device in device_results if device[1] == device_id), None)
+ if device_data:
+ avatar = device_data["avatar"]
+ title = device_data["title"]
+
+ html += f"""
+
+ You {"#" + str(player_rank) if player_rank else "N/A"}
+
+
+
{username}
+
+
+
{user_score}
+
+ """
+
+ html += """
+
+ """
+ # Loop leaderboard
+ for rank, (username, data) in enumerate(sorted_players, start=1):
+ html += f"""
+
+
#{rank}
+
+
+
{username}
+
+
+
{data['score']}
+
+ """
+
+ else:
+ query = select(result).where(
+ (result.c.id == song_id) & (result.c.mode == mode)
+ ).order_by(result.c.score.desc())
+ play_results = await database.fetch_all(query)
+
+ query = select(user).where(user.c.device_id == device_id)
+ user_result = await database.fetch_one(query)
+
+ query = select(daily_reward).where(daily_reward.c.device_id == device_id)
+ device_result = await database.fetch_one(query)
+
+ user_id = user_result[0] if user_result else None
+ username = user_result[1] if user_result else f"Guest({device_id[-6:]})"
+ play_record = None
+
+ if user_id:
+ play_record = next((record for record in play_results if int(record[3]) == user_id), None)
+
+ if not play_record:
+ play_record = next((record for record in play_results if record[1] == device_id and record[3] is None), None)
+
+ player_rank = None
+ avatar_index = str(play_record[7]) if play_record else "1"
+ user_score = play_record[8] if play_record else 0
+ for rank, result_obj in enumerate(play_results, start=1):
+ if user_result and int(result_obj[3]) == user_id:
+ player_rank = rank
+ break
+ elif result_obj[1] == device_id and result_obj[3] is None:
+ player_rank = rank
+ break
+
+ html += f"""
+
+ You {"#" + str(player_rank) if player_rank else "N/A"}
+
+
Please report bugs/missing tracks to Discord: #AnTcfgss, or QQ 3421587952.
+
+ This server has version {FMAX_VER}.
+
Update log:
+
{log}
+
+ """
+ elif cnt_id == -1:
+ html = f"""
+
+
Experience the arcade with the GC4MAX expansion! This DLC unlocks 320+ exclusive songs for your 2OS experience.
+
Note that these songs don't have mobile difficulties. A short placeholder is used, and GCoin reward is not available for playing them. You must clear the Normal difficulty to unlock AC content.
+
Due to technical limitations, Extra level charts cannot be ported as of now. After purchasing, you will have access to support information and update logs.
+
+
+
+
+
+ """
+
+ elif cnt_type == "2":
+ avatar = next((item for item in AVATAR_LIST if item.get("id") == cnt_id), None)
+ if avatar:
+ html = f"""
+
+
+
+
Would you like to purchase this avatar?
+
+
{avatar.get("name")}
+
Effect: {avatar.get("effect")}
+
+
+
+ {AVATAR_PRICE}
+
+ """
+ else:
+ html = "
Avatar not found.
"
+
+ elif cnt_type == "3":
+ item = next((item for item in ITEM_LIST if item.get("id") == cnt_id), None)
+ if item:
+ html = f"""
+
+
+
+
Would you like to purchase this item?
+
+
{item.get("name")}
+
Effect: {item.get("effect")}
+
+
+
+ {ITEM_PRICE}
+
+ """
+ else:
+ html = "
Item not found.
"
+
+ if cnt_type == "1" and cnt_id < 0:
+ source_html = f"files/dlc_4max.html"
+ else:
+ source_html = f"files/web_shop_detail.html"
+ html += f"""
+
+
+ 
+ 
+ 
+ 
+ 
+ 
+ 
+ """
+ else:
+ encrypted_mass = encryptAES(f"vid={device_id}&title_id={num}&page_id={page_id}&dummy=".encode("utf-8"))
+ titles_html += f"""
+
+ 
+ 
+
+ """
+ return HTMLResponse(inform_page(html, 1))
+
+ else:
+ return HTMLResponse("""
+ 
+ 
+ {song_stage_price}
+ 
+ 
+