const express = require('express');
const cors = require('cors');
const path = require('path');
const compression = require('compression');

const db = require('./db');
const { router: authRouter, auth } = require('./routes/auth');
const statsRouter = require('./routes/stats');
const recordsRouter = require('./routes/records');
const ioRouter = require('./routes/io');

const app = express();

app.use(cors());
app.use(express.json());
app.use(compression());
app.use(express.static(path.join(__dirname, '..', 'public'), {
  maxAge: '1h',
  etag: true
}));

// 联系人自动补全
app.use('/api', (req, res, next) => {
  res.setHeader('Cache-Control', 'no-cache');
  next();
});

app.get('/api/contacts', auth, (req, res) => {
  const field = req.query.field;
  const allowed = ['boss', 'partner', 'source', 'destination'];
  if (!field || !allowed.includes(field)) return res.status(400).json({ error: '无效字段' });

  const rows = db.prepare(`
    SELECT ${field} as name, MAX(created_at) as last_used, COUNT(*) as freq
    FROM records WHERE user_id = ? AND ${field} IS NOT NULL AND ${field} != ''
    GROUP BY ${field} ORDER BY MAX(created_at) DESC
  `).all(req.user.id);
  res.json(rows.map(r => r.name));
});

// 路由挂载
app.use('/api', authRouter);
app.use('/api/stats', auth, statsRouter);
app.use('/api/records', auth, recordsRouter);
app.use('/api', auth, ioRouter);

const PORT = process.env.PORT || 3000;
app.listen(PORT, '0.0.0.0', () => {
  console.log(`服务器运行在 http://0.0.0.0:${PORT}`);
});