feat: Gebietseroberung Multiplayer-Spiel
This commit is contained in:
238
backend/src/tools/gebietseroberung/routes.js
Normal file
238
backend/src/tools/gebietseroberung/routes.js
Normal file
@@ -0,0 +1,238 @@
|
||||
const express = require('express');
|
||||
const db = require('../../db');
|
||||
const { authenticate } = require('../../middleware/auth');
|
||||
const router = express.Router();
|
||||
|
||||
// ── DB-Migration ──────────────────────────────────────────────────────────────
|
||||
(function migrate() {
|
||||
const cols = db.pragma('table_info(geo_games)').map(c => c.name);
|
||||
if (!cols.length) {
|
||||
db.exec(`
|
||||
CREATE TABLE IF NOT EXISTS geo_games (
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
owner_id INTEGER NOT NULL,
|
||||
opponent_id INTEGER NOT NULL,
|
||||
owner_color TEXT NOT NULL DEFAULT '#4ecdc4',
|
||||
opp_color TEXT NOT NULL DEFAULT '#ff6b9d',
|
||||
grid TEXT NOT NULL,
|
||||
current_turn INTEGER NOT NULL,
|
||||
status TEXT NOT NULL DEFAULT 'active',
|
||||
winner_id INTEGER,
|
||||
created_at TEXT NOT NULL DEFAULT (datetime('now','localtime')),
|
||||
updated_at TEXT NOT NULL DEFAULT (datetime('now','localtime'))
|
||||
);
|
||||
`);
|
||||
}
|
||||
})();
|
||||
|
||||
const GRID_SIZE = 20;
|
||||
|
||||
// Leeres Grid erstellen: 0=neutral, owner_id=Spieler1, opponent_id=Spieler2
|
||||
function createGrid(ownerId, oppId) {
|
||||
const grid = Array(GRID_SIZE).fill(null).map(() => Array(GRID_SIZE).fill(0));
|
||||
// Startpositionen: Owner oben-links, Opponent unten-rechts
|
||||
grid[0][0] = ownerId;
|
||||
grid[GRID_SIZE - 1][GRID_SIZE - 1] = oppId;
|
||||
return JSON.stringify(grid);
|
||||
}
|
||||
|
||||
// Prüft ob Zelle an Spieler-Gebiet grenzt (oben/unten/links/rechts)
|
||||
function isAdjacent(grid, row, col, playerId) {
|
||||
const dirs = [[-1,0],[1,0],[0,-1],[0,1]];
|
||||
for (const [dr, dc] of dirs) {
|
||||
const r = row + dr, c = col + dc;
|
||||
if (r >= 0 && r < GRID_SIZE && c >= 0 && c < GRID_SIZE && grid[r][c] === playerId) return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
// Prüft ob ein Spieler noch Züge machen kann
|
||||
function canMove(grid, playerId) {
|
||||
for (let r = 0; r < GRID_SIZE; r++) {
|
||||
for (let c = 0; c < GRID_SIZE; c++) {
|
||||
if (grid[r][c] === 0 && isAdjacent(grid, r, c, playerId)) return true;
|
||||
}
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
// Felder zählen
|
||||
function countCells(grid, playerId) {
|
||||
let count = 0;
|
||||
for (let r = 0; r < GRID_SIZE; r++)
|
||||
for (let c = 0; c < GRID_SIZE; c++)
|
||||
if (grid[r][c] === playerId) count++;
|
||||
return count;
|
||||
}
|
||||
|
||||
// Pushover helper
|
||||
function sendPush(userId, title, message) {
|
||||
const cfg = db.prepare('SELECT user_key, app_token FROM pushover_settings WHERE user_id=?').get(userId);
|
||||
if (!cfg?.app_token || !cfg?.user_key) return;
|
||||
fetch('https://api.pushover.net/1/messages.json', {
|
||||
method: 'POST',
|
||||
headers: { 'Content-Type': 'application/json' },
|
||||
body: JSON.stringify({ token: cfg.app_token, user: cfg.user_key, title, message, priority: 0 }),
|
||||
}).catch(() => {});
|
||||
}
|
||||
|
||||
const uid = req => req.user.id;
|
||||
|
||||
// ── Alle Spiele des Users ─────────────────────────────────────────────────────
|
||||
router.get('/', authenticate, (req, res) => {
|
||||
const me = uid(req);
|
||||
const games = db.prepare(`
|
||||
SELECT g.*,
|
||||
u1.username as owner_name,
|
||||
u2.username as opp_name
|
||||
FROM geo_games g
|
||||
JOIN users u1 ON u1.id = g.owner_id
|
||||
JOIN users u2 ON u2.id = g.opponent_id
|
||||
WHERE g.owner_id=? OR g.opponent_id=?
|
||||
ORDER BY g.updated_at DESC
|
||||
`).all(me, me);
|
||||
res.json(games);
|
||||
});
|
||||
|
||||
// ── Alle User (für Einladen) ──────────────────────────────────────────────────
|
||||
router.get('/users', authenticate, (req, res) => {
|
||||
const me = uid(req);
|
||||
const users = db.prepare('SELECT id, username FROM users WHERE id != ? AND hidden != 1 ORDER BY username').all(me);
|
||||
res.json(users);
|
||||
});
|
||||
|
||||
// ── Einzelnes Spiel ───────────────────────────────────────────────────────────
|
||||
router.get('/:id', authenticate, (req, res) => {
|
||||
const me = uid(req);
|
||||
const game = db.prepare(`
|
||||
SELECT g.*,
|
||||
u1.username as owner_name,
|
||||
u2.username as opp_name
|
||||
FROM geo_games g
|
||||
JOIN users u1 ON u1.id = g.owner_id
|
||||
JOIN users u2 ON u2.id = g.opponent_id
|
||||
WHERE g.id=?
|
||||
`).get(req.params.id);
|
||||
if (!game) return res.status(404).json({ error: 'Nicht gefunden' });
|
||||
if (game.owner_id !== me && game.opponent_id !== me)
|
||||
return res.status(403).json({ error: 'Kein Zugriff' });
|
||||
res.json(game);
|
||||
});
|
||||
|
||||
// ── Neues Spiel erstellen ─────────────────────────────────────────────────────
|
||||
router.post('/', authenticate, (req, res) => {
|
||||
const me = uid(req);
|
||||
const { opponent_id } = req.body;
|
||||
if (!opponent_id) return res.status(400).json({ error: 'Gegner fehlt' });
|
||||
if (opponent_id === me) return res.status(400).json({ error: 'Du kannst nicht gegen dich spielen' });
|
||||
|
||||
const opp = db.prepare('SELECT id, username FROM users WHERE id=?').get(opponent_id);
|
||||
if (!opp) return res.status(404).json({ error: 'Benutzer nicht gefunden' });
|
||||
|
||||
const grid = createGrid(me, opponent_id);
|
||||
const result = db.prepare(`
|
||||
INSERT INTO geo_games (owner_id, opponent_id, grid, current_turn)
|
||||
VALUES (?, ?, ?, ?)
|
||||
`).run(me, opponent_id, grid, me);
|
||||
|
||||
const myName = db.prepare('SELECT username FROM users WHERE id=?').get(me)?.username || 'Jemand';
|
||||
sendPush(opponent_id, '🗺️ Gebietseroberung', `${myName} hat dich zu einem Spiel eingeladen! Du bist zuerst dran.`);
|
||||
|
||||
res.json({ id: result.lastInsertRowid });
|
||||
});
|
||||
|
||||
// ── Zug machen ────────────────────────────────────────────────────────────────
|
||||
router.post('/:id/move', authenticate, (req, res) => {
|
||||
const me = uid(req);
|
||||
const { row, col } = req.body;
|
||||
if (row === undefined || col === undefined) return res.status(400).json({ error: 'row/col fehlt' });
|
||||
|
||||
const game = db.prepare('SELECT * FROM geo_games WHERE id=?').get(req.params.id);
|
||||
if (!game) return res.status(404).json({ error: 'Spiel nicht gefunden' });
|
||||
if (game.owner_id !== me && game.opponent_id !== me)
|
||||
return res.status(403).json({ error: 'Kein Zugriff' });
|
||||
if (game.status !== 'active') return res.status(400).json({ error: 'Spiel beendet' });
|
||||
if (game.current_turn !== me) return res.status(400).json({ error: 'Nicht dein Zug' });
|
||||
|
||||
const grid = JSON.parse(game.grid);
|
||||
|
||||
if (row < 0 || row >= GRID_SIZE || col < 0 || col >= GRID_SIZE)
|
||||
return res.status(400).json({ error: 'Ungültige Position' });
|
||||
if (grid[row][col] !== 0)
|
||||
return res.status(400).json({ error: 'Zelle bereits belegt' });
|
||||
if (!isAdjacent(grid, row, col, me))
|
||||
return res.status(400).json({ error: 'Zelle grenzt nicht an dein Gebiet' });
|
||||
|
||||
// Zug ausführen
|
||||
grid[row][col] = me;
|
||||
|
||||
const opponent = game.owner_id === me ? game.opponent_id : game.owner_id;
|
||||
let nextTurn = opponent;
|
||||
let status = 'active';
|
||||
let winnerId = null;
|
||||
|
||||
// Prüfen ob Gegner noch ziehen kann
|
||||
if (!canMove(grid, opponent)) {
|
||||
// Gegner kann nicht — prüfen ob ich auch nicht mehr kann
|
||||
if (!canMove(grid, me)) {
|
||||
// Spiel vorbei
|
||||
status = 'finished';
|
||||
const myCount = countCells(grid, me);
|
||||
const oppCount = countCells(grid, opponent);
|
||||
winnerId = myCount > oppCount ? me : (oppCount > myCount ? opponent : null); // null = Unentschieden
|
||||
} else {
|
||||
// Gegner überspringen, ich mache weiter
|
||||
nextTurn = me;
|
||||
}
|
||||
}
|
||||
|
||||
const newGrid = JSON.stringify(grid);
|
||||
db.prepare(`
|
||||
UPDATE geo_games SET grid=?, current_turn=?, status=?, winner_id=?,
|
||||
updated_at=datetime('now','localtime') WHERE id=?
|
||||
`).run(newGrid, nextTurn, status, winnerId, game.id);
|
||||
|
||||
// Pushover
|
||||
const myName = db.prepare('SELECT username FROM users WHERE id=?').get(me)?.username || 'Jemand';
|
||||
const oppName = db.prepare('SELECT username FROM users WHERE id=?').get(opponent)?.username || 'Jemand';
|
||||
|
||||
if (status === 'finished') {
|
||||
const myCount = countCells(grid, me);
|
||||
const oppCount = countCells(grid, opponent);
|
||||
if (winnerId === me) {
|
||||
sendPush(opponent, '🗺️ Spiel beendet', `${myName} hat gewonnen! ${myCount} vs ${oppCount} Felder.`);
|
||||
sendPush(me, '🗺️ Spiel beendet', `Du hast gewonnen! ${myCount} vs ${oppCount} Felder. 🎉`);
|
||||
} else if (winnerId === opponent) {
|
||||
sendPush(me, '🗺️ Spiel beendet', `${oppName} hat gewonnen. ${myCount} vs ${oppCount} Felder.`);
|
||||
sendPush(opponent, '🗺️ Spiel beendet', `Du hast gewonnen! ${oppCount} vs ${myCount} Felder. 🎉`);
|
||||
} else {
|
||||
sendPush(me, '🗺️ Unentschieden!', `Gleichstand — ${myCount} vs ${oppCount} Felder.`);
|
||||
sendPush(opponent, '🗺️ Unentschieden!', `Gleichstand — ${oppCount} vs ${myCount} Felder.`);
|
||||
}
|
||||
} else if (nextTurn === opponent) {
|
||||
sendPush(opponent, '🗺️ Du bist dran!', `${myName} hat gezogen — jetzt bist du dran!`);
|
||||
}
|
||||
|
||||
const updated = db.prepare('SELECT * FROM geo_games WHERE id=?').get(game.id);
|
||||
res.json(updated);
|
||||
});
|
||||
|
||||
// ── Spiel aufgeben ────────────────────────────────────────────────────────────
|
||||
router.post('/:id/resign', authenticate, (req, res) => {
|
||||
const me = uid(req);
|
||||
const game = db.prepare('SELECT * FROM geo_games WHERE id=?').get(req.params.id);
|
||||
if (!game) return res.status(404).json({ error: 'Nicht gefunden' });
|
||||
if (game.owner_id !== me && game.opponent_id !== me)
|
||||
return res.status(403).json({ error: 'Kein Zugriff' });
|
||||
if (game.status !== 'active') return res.status(400).json({ error: 'Spiel bereits beendet' });
|
||||
|
||||
const winner = game.owner_id === me ? game.opponent_id : game.owner_id;
|
||||
db.prepare(`UPDATE geo_games SET status='finished', winner_id=?, updated_at=datetime('now','localtime') WHERE id=?`).run(winner, game.id);
|
||||
|
||||
const myName = db.prepare('SELECT username FROM users WHERE id=?').get(me)?.username || 'Jemand';
|
||||
sendPush(winner, '🗺️ Spiel gewonnen!', `${myName} hat aufgegeben. Du gewinnst! 🎉`);
|
||||
|
||||
res.json({ ok: true });
|
||||
});
|
||||
|
||||
module.exports = router;
|
||||
Reference in New Issue
Block a user