Source: database/Models/JWT/TokenRepository.js

  1. const Token = require('./Token.js');
  3. /**
  4.  * DB Connection to the invalidToken Table
  5.  */
  6. class TokenRepository {
  7.     /**
  8.      * @constructor
  9.      * @param {Database} db sqlite connection
  10.      */
  11.     constructor(db) {
  12.         this.db = db;
  13.     }
  15.     /**
  16.      * Insert a new invalid Token to the DB
  17.      * @param {Token} token 
  18.      * @returns {object} an info object describing any changes made
  19.      */
  20.     async insert(token) {
  21.         await this.cleanup();
  23.         const sql = "INSERT INTO invalidToken(token) VALUES (?)";
  24.         return await this.db.run(sql, [token.token]);
  25.     }
  27.     /**
  28.      * Search for a token in the db
  29.      * @param {Token} token 
  30.      * @returns Token
  31.      */
  32.     async selectToken(token) {
  33.         await this.cleanup();
  35.         const sql = "SELECT * FROM invalidToken WHERE invalidToken.token = ?"
  36.         return await this.db.get(sql, [token.token]);
  37.     }
  39.     /**
  40.      * Get all invalid token in the DB
  41.      * @returns Array.<Token>
  42.      */
  43.     async selectAllToken() {
  44.         await this.cleanup();
  46.         const sql = "SELECT * FROM invalidToken"
  47.         return await this.db.getAll(sql, []);
  48.     }
  50.     /**
  51.      * Remove all token that are invalid by them self
  52.      */
  53.     async cleanup() {
  54.         const currentUnixTime = Date.now();
  56.         const sql = "DELETE FROM invalidToken WHERE expiration > ?";
  57.         await this.db.run(sql, [currentUnixTime]);
  58.     }
  59. }
  61. module.exports = TokenRepository;