analytics.js

// analytics.js
const { Pool } = require('pg');

const pool = new Pool({
  user: 'my_app_user',
  host: 'localhost',
  database: 'my_app_db1',
  password: '123129',
  port: 5432,
});

async function logSearchQuery(query, resultCount) {
  const queryText = `
    INSERT INTO search_analytics(query, result_count, created_at)
    VALUES($1, $2, NOW());
  `;
  try {
    await pool.query(queryText, [query, resultCount]);
  } catch (err) {
    console.error('Ошибка при логировании поискового запроса:', err);
  }
}

async function getSearchFrequency() {
  const queryText = `
    SELECT
      query,
      COUNT(*) as frequency
    FROM search_analytics
    GROUP BY query
    ORDER BY frequency DESC
    LIMIT 10;
  `;
  try {
    const result = await pool.query(queryText);
    return result.rows;
  } catch (err) {
    console.error('Ошибка при получении частоты поиска:', err);
    return null;
  }
}

module.exports = {
  logSearchQuery,
  getSearchFrequency,
};