app.js

const express = require('express')
const path = require('path')
const fs = require('fs')
const bodyParser = require('body-parser')
const multer = require('multer')
const {
	getOrCreateUser,
	updateBalance,
	getTopPlayers,
	getReferrals,
} = require('./database')

const app = express()
const PORT = process.env.PORT || 8080
const ADMIN_KEY = 'Lesha_Self1'
const dbPath = '/data/trump_game.db'

app.use(express.static(path.join(__dirname, 'public')))
app.use(bodyParser.json())

// Настройка загрузки файлов (Multer сохраняет файл во временную папку)
const upload = multer({ dest: '/tmp/' })

/**
 * Получить баланс пользователя.
 * Ожидает в теле запроса:
 * - telegramUserId (обязательное)
 * - username (опционально, для создания пользователя)
 * - referralCode (опционально, если пользователь перешёл по реферальной ссылке)
 */
app.post('/api/getBalance', async (req, res) => {
	try {
		const { telegramUserId, username, referralCode, accountCreationYear } =
			req.body
		if (!telegramUserId) {
			return res.status(400).json({ error: '⛔ No Telegram user ID provided' })
		}
		const userData = await getOrCreateUser(
			telegramUserId,
			username,
			referralCode,
			accountCreationYear
		)
		res.json({
			balance: userData.balance,
			username: userData.username,
			referralCode: userData.referralCode || userData.referral_code,
			referredBy: userData.referredBy,
		})
	} catch (err) {
		console.error('Ошибка в /api/getBalance:', err)
		res.status(500).json({ error: '❌ Internal Server Error' })
	}
})

app.post('/api/incrementBalance', async (req, res) => {
	try {
		const { telegramUserId } = req.body
		if (!telegramUserId) {
			return res.status(400).json({ error: '⛔ No Telegram user ID provided' })
		}
		const userData = await getOrCreateUser(telegramUserId)
		const newBalance = userData.balance + 1
		await updateBalance(telegramUserId, newBalance)
		res.json({ balance: newBalance })
	} catch (err) {
		console.error('Ошибка в /api/incrementBalance:', err)
		res.status(500).json({ error: '❌ Internal Server Error' })
	}
})

app.get('/api/leaderboard', async (req, res) => {
	try {
		const topPlayers = await getTopPlayers(100)
		res.json(topPlayers)
	} catch (err) {
		console.error('Ошибка в /api/leaderboard:', err)
		res.status(500).json({ error: '❌ Internal Server Error' })
	}
})

app.get('/api/referrals', async (req, res) => {
	try {
		const { telegramUserId } = req.query
		if (!telegramUserId) {
			return res.status(400).json({ error: '⛔ No Telegram user ID provided' })
		}
		const referrals = await getReferrals(telegramUserId)
		res.json({ totalReferrals: referrals.length, referrals })
	} catch (err) {
		console.error('Ошибка в /api/referrals:', err)
		res.status(500).json({ error: '❌ Internal Server Error' })
	}
})

app.get('/download-db', (req, res) => {
	if (req.query.key !== ADMIN_KEY) {
		return res.status(403).send('⛔ Доступ запрещён.')
	}
	if (!fs.existsSync(dbPath)) {
		return res.status(404).send('❌ База данных не найдена.')
	}
	res.download(dbPath, 'trump_game.db')
})

app.post('/upload-db', upload.single('database'), (req, res) => {
	if (req.query.key !== ADMIN_KEY) {
		return res.status(403).send('⛔ Доступ запрещён.')
	}
	if (!req.file) {
		return res.status(400).send('❌ Файл базы не загружен.')
	}
	console.log('Получен файл:', req.file)
	fs.rename(req.file.path, dbPath, err => {
		if (err) {
			console.error('Ошибка при перемещении файла через fs.rename:', err)
			fs.copyFile(req.file.path, dbPath, errCopy => {
				if (errCopy) {
					console.error(
						'Ошибка при копировании файла через fs.copyFile:',
						errCopy
					)
					return res.status(500).send('❌ Ошибка загрузки: ' + errCopy.message)
				}
				fs.unlink(req.file.path, unlinkErr => {
					if (unlinkErr) {
						console.error('Ошибка удаления временного файла:', unlinkErr)
					}
					return res.send('✅ База успешно обновлена!')
				})
			})
		} else {
			res.send('✅ База успешно обновлена!')
		}
	})
})

app.listen(PORT, () => {
	console.log(`🚀 Сервер работает на http://localhost:${PORT}`)
})