const helpers = require('../common/helpers');
const { queryDatabase, updateRows } = require('../common/sqlDB');

function mapUser(row) {
  return {
    id: Number(row.ID),
    name: row.Name || '',
    credits: Number(row.Credits || 0),
    settings: row.Settings || '',
    role: Number(row.Role || 0),
    reminderTimer: Number(row.ReminderTimer || 1),
    workingHours: row.WorkingHours || ''
  };
}

async function getCurrentUser(userId) {
  const rows = await queryDatabase(
    `SELECT ID, Name, Credits, Settings, Role, ReminderTimer, WorkingHours
     FROM Users
     WHERE ID = ? AND Deleted = 0
     LIMIT 1`,
    [userId]
  );

  if (!rows.length) {
    const error = new Error('User not found.');
    error.statusCode = 404;
    throw error;
  }

  return mapUser(rows[0]);
}

async function updateCurrentUser(userId, body) {
  helpers.requireFields(body, ['settings', 'reminderTimer', 'workingHours']);

  await updateRows('Users', {
    Settings: body.settings,
    ReminderTimer: Number(body.reminderTimer),
    WorkingHours: body.workingHours
  }, 'ID = ? AND Deleted = 0', [userId]);

  return getCurrentUser(userId);
}

module.exports = {
  getCurrentUser,
  updateCurrentUser
};