47 lines
1.5 KiB
JavaScript
47 lines
1.5 KiB
JavaScript
const establishedDatabase = require('src/database/database');
|
|
|
|
class SearchHistory {
|
|
constructor(database) {
|
|
this.database = database || establishedDatabase;
|
|
this.queries = {
|
|
'create': 'insert into search_history (search_query, user_name) values (?, ?)',
|
|
'read': 'select search_query from search_history where user_name = ? order by id desc',
|
|
};
|
|
}
|
|
|
|
/**
|
|
* Retrive a search queries for a user from the database.
|
|
* @param {User} user existing user
|
|
* @returns {Promise}
|
|
*/
|
|
read(user) {
|
|
return new Promise((resolve, reject) => this.database.all(this.queries.read, user)
|
|
.then((result, error) => {
|
|
if (error) throw new Error(error);
|
|
resolve(result.map(row => row.search_query));
|
|
})
|
|
.catch((error) => {
|
|
console.log('Error when fetching history from database:', error)
|
|
reject('Unable to get history.');
|
|
}));
|
|
}
|
|
|
|
/**
|
|
* Creates a new search entry in the database.
|
|
* @param {User} user a new user
|
|
* @param {String} searchQuery the query the user searched for
|
|
* @returns {Promise}
|
|
*/
|
|
create(user, searchQuery) {
|
|
return Promise.resolve()
|
|
.then(() => this.database.run(this.queries.create, [searchQuery, user]))
|
|
.catch((error) => {
|
|
if (error.message.includes('FOREIGN')) {
|
|
throw new Error('Could not create search history.');
|
|
}
|
|
});
|
|
}
|
|
}
|
|
|
|
module.exports = SearchHistory;
|