Skip to content

feat(persistence): SQLite player position & chat history #4

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Peter08091996 wants to merge 2 commits into
base: main
Choose a base branch
from
Open

feat(persistence): SQLite player position & chat history #4

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
24b2d71
feat(persistence): add SQLite for player position and chat history
Peter08091996 Mar 19, 2026
a3961e1
feat(persistence): add better-sqlite3 dependency
Peter08091996 Mar 19, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 8 additions & 1 deletion package.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,12 +7,19 @@
"start": "node server.js",
"test": "echo \"Error: no test specified\" && exit 1"
},
"keywords": ["mcp", "multi-agent", "pixel-art", "sandbox", "ai-agents"],
"keywords": [
"mcp",
"multi-agent",
"pixel-art",
"sandbox",
"ai-agents"
],
"author": "ceresOPA",
"license": "MIT",
"type": "commonjs",
"dependencies": {
"@modelcontextprotocol/sdk": "^1.27.1",
"better-sqlite3": "^12.8.0",
"express": "^5.2.1",
"socket.io": "^4.8.3",
"socket.io-client": "^4.8.3"
Expand Down
78 changes: 65 additions & 13 deletions server.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,13 +4,48 @@ const http = require('http');
const { Server } = require('socket.io');
const fs = require('fs');
const path = require('path');
const Database = require('better-sqlite3');

const app = express();
const server = http.createServer(app);
const io = new Server(server, { cors: { origin: '*' } });
const PORT = process.env.PORT || 5660;
app.use(express.static('public'));

// ==========================================
// 💾 SQLite 持久化
// ==========================================
const db = new Database(path.join(__dirname, 'world.db'));

db.exec(`
CREATE TABLE IF NOT EXISTS players (
name TEXT PRIMARY KEY,
x INTEGER NOT NULL DEFAULT 5,
y INTEGER NOT NULL DEFAULT 5,
sprite TEXT,
last_seen INTEGER
);
CREATE TABLE IF NOT EXISTS chat_history (
id INTEGER PRIMARY KEY AUTOINCREMENT,
time INTEGER NOT NULL,
name TEXT NOT NULL,
message TEXT NOT NULL
);
CREATE INDEX IF NOT EXISTS idx_chat_time ON chat_history(time);
`);

const stmts = {
upsertPlayer: db.prepare(`
INSERT INTO players (name, x, y, sprite, last_seen) VALUES (?, ?, ?, ?, ?)
ON CONFLICT(name) DO UPDATE SET x=excluded.x, y=excluded.y, sprite=excluded.sprite, last_seen=excluded.last_seen
`),
getPlayer: db.prepare('SELECT * FROM players WHERE name = ?'),
saveChat: db.prepare('INSERT INTO chat_history (time, name, message) VALUES (?, ?, ?)'),
getHistory: db.prepare('SELECT time, name, message FROM chat_history ORDER BY time DESC LIMIT 50'),
};

console.log('💾 SQLite 数据库已就绪: world.db');

// ==========================================
// 🗺️ Tiled 地图与物理引擎
// ==========================================
Expand Down Expand Up @@ -44,22 +79,22 @@ if (fs.existsSync(mapPath)) {
console.error("❌ 找不到 map.tmj！");
}

// 🧠 精准区域判定算法 (支持“临近感知 / 边缘距离计算”)
// 🧠 精准区域判定算法 (支持"临近感知 / 边缘距离计算")
function getZoneAt(gridX, gridY) {
if (semanticZones.length === 0) return null;

// 玩家所在格子的正中心像素坐标
const pixelX = (gridX * worldMap.tilewidth) + (worldMap.tilewidth / 2);
const pixelY = (gridY * worldMap.tileheight) + (worldMap.tileheight / 2);

// 💥 魔法变量：感知边缘 (Margin)。允许玩家站在建筑物外围 1.5 个格子的距离内被判定为“身处该区域”
// 💥 魔法变量：感知边缘 (Margin)。允许玩家站在建筑物外围 1.5 个格子的距离内被判定为"身处该区域"
const INTERACT_MARGIN = worldMap.tilewidth * 1.5;

let closestZone = null;
let minDistance = Infinity;

for (let zone of semanticZones) {
// 算法：计算一个“点”到一个“矩形(AABB)”的最短几何距离
// 算法：计算一个"点"到一个"矩形(AABB)"的最短几何距离
// 如果点在矩形内部，dx 和 dy 都会是 0
const dx = Math.max(zone.x - pixelX, 0, pixelX - (zone.x + zone.width));
const dy = Math.max(zone.y - pixelY, 0, pixelY - (zone.y + zone.height));
Expand Down Expand Up @@ -96,8 +131,11 @@ app.get('/events', (req, res) => {
const initData = `data: ${JSON.stringify(gameState.players)}\n\n`;
res.write(initData);

// Send chat history
const historyData = `event: chatHistory\ndata: ${JSON.stringify(chatHistory)}\n\n`;
// Send chat history：优先从数据库读取（含跨重启记录），合并内存中最新消息去重
const dbHistory = stmts.getHistory.all().reverse(); // 最旧→最新
const merged = [...dbHistory, ...chatHistory.filter(m => !dbHistory.find(d => d.time === m.time && d.name === m.name))];
merged.sort((a, b) => a.time - b.time);
const historyData = `event: chatHistory\ndata: ${JSON.stringify(merged.slice(-50))}\n\n`;
res.write(historyData);

// 网页关闭时，从列表中移除
Expand Down Expand Up @@ -335,13 +373,18 @@ io.on('connection', (socket) => {
chosenSprite = data.sprite;
}

let spawnX = 5, spawnY = 5; // 默认坐标
// 从数据库读取上次位置，没有则用默认坐标
const saved = stmts.getPlayer.get(name);
let spawnX = saved ? saved.x : 5;
let spawnY = saved ? saved.y : 5;
const zone = getZoneAt(spawnX, spawnY);

// Use chosen sprite if valid, otherwise assign round-robin
// Use chosen sprite if valid, otherwise use saved sprite or round-robin
let sprite;
if (chosenSprite && CHARACTER_SPRITES.includes(chosenSprite)) {
sprite = chosenSprite;
} else if (saved?.sprite && CHARACTER_SPRITES.includes(saved.sprite)) {
sprite = saved.sprite;
} else {
sprite = CHARACTER_SPRITES[nextSpriteIndex % CHARACTER_SPRITES.length];
nextSpriteIndex++;
Expand All @@ -353,11 +396,16 @@ io.on('connection', (socket) => {
currentZoneName: zone ? zone.name : "小镇街道",
currentZoneDesc: zone ? (zone.properties?.find(p => p.name === 'description')?.value || '') : "空旷的街道"
};

// 整理一份“地图旅游指南”发给 MCP 网关

// 写入/更新数据库（首次加入或重连）
stmts.upsertPlayer.run(name, spawnX, spawnY, sprite, Date.now());
if (saved) {
console.log(`💾 ${name} 回到上次位置 (${spawnX}, ${spawnY})`);
}

// 整理一份"地图旅游指南"发给 MCP 网关
const directory = semanticZones.map(z => ({
name: z.name,
// 把原始像素坐标换算成 AI 用的网格中心坐标
x: Math.floor((z.x + z.width/2) / worldMap.tilewidth),
y: Math.floor((z.y + z.height/2) / worldMap.tileheight),
description: z.properties?.find(p => p.name === 'description')?.value || ''
Expand All @@ -367,7 +415,7 @@ io.on('connection', (socket) => {
socket.emit('mapDirectory', directory);
io.emit('stateUpdate', gameState.players);
broadcastStateToWeb();
addPlayerActivity(socket.id, { type: 'join', text: `加入了小镇 (角色: ${sprite})` });
addPlayerActivity(socket.id, { type: 'join', text: `加入了小镇 (角色: ${sprite})${saved ? ' [已恢复位置]' : ''}` });
});

// Allow character change after joining
Expand Down Expand Up @@ -418,17 +466,20 @@ io.on('connection', (socket) => {
player.currentZoneDesc = zone ? (zone.properties?.find(p => p.name === 'description')?.value || '') : "空旷的街道";

io.emit('stateUpdate', gameState.players);
broadcastStateToWeb(); // Bug fix: broadcast move events to SSE web viewers
broadcastStateToWeb();
addPlayerActivity(socket.id, { type: 'move', text: `移动到 (${player.x}, ${player.y}) - ${player.currentZoneName}` });
// 持久化新位置
stmts.upsertPlayer.run(player.name, player.x, player.y, player.sprite, Date.now());
});

socket.on('say', (msg) => {
if (gameState.players[socket.id]) {
gameState.players[socket.id].message = msg;

// Add to chat history
// Add to chat history (内存 + 数据库)
const chatEntry = { time: Date.now(), name: gameState.players[socket.id].name, message: msg };
addChatHistory(chatEntry.name, chatEntry.message);
stmts.saveChat.run(chatEntry.time, chatEntry.name, chatEntry.message);
broadcastChatToWeb(chatEntry);
addPlayerActivity(socket.id, { type: 'say', text: `说: "${msg.substring(0, 30)}${msg.length > 30 ? '...' : ''}"` });

Expand All @@ -439,6 +490,7 @@ io.on('connection', (socket) => {
io.emit('stateUpdate', gameState.players);
}
}, 5000);

}
broadcastStateToWeb();
});
Expand Down