fix: add flushLogs for typescript

Author: venki91

lib/index.js

@@ -451,7 +451,7 @@ class ErrsoleSQLite extends EventEmitter {
     const query = `DELETE FROM ${this.usersTable} WHERE id = ?`;
     return new Promise((resolve, reject) => {
       this.db.run(query, [id], function (err) { // You must use an old-school function () { ... } style callback rather than a lambda function, otherwise this.lastID and this.changes will be undefined.
-        if (err) return reject(err);
+        if (err) return reject(new Error(err.message || err.toString()));
         if (this.changes === 0) return reject(new Error('User not found.'));
         resolve({});
       });
@@ -508,7 +508,7 @@ class ErrsoleSQLite extends EventEmitter {
 
     return new Promise((resolve, reject) => {
       this.db.run(query, flatValues, function (err) {
-        if (err) return reject(err);
+        if (err) return reject(new Error(err.message || err.toString()));
         resolve({});
       });
     });
@@ -581,7 +581,7 @@ class ErrsoleSQLite extends EventEmitter {
 
     return new Promise((resolve, reject) => {
       this.db.all(query, values, (err, rows) => {
-        if (err) return reject(err);
+        if (err) return reject(new Error(err.message || err.toString()));
         if (shouldReverse) rows.reverse();
         resolve({ items: rows });
       });
@@ -672,7 +672,7 @@ class ErrsoleSQLite extends EventEmitter {
 
     return new Promise((resolve, reject) => {
       this.db.all(query, values, (err, rows) => {
-        if (err) return reject(err);
+        if (err) return reject(new Error(err.message || err.toString()));
         if (shouldReverse) rows.reverse();
         resolve({ items: rows, filters });
       });

types/index.d.ts

@@ -63,6 +63,7 @@ declare module 'errsole-sqlite' {
     deleteUser(id: number): Promise<{}>;
 
     postLogs(logEntries: Log[]): Promise<{}>;
+    flushLogs(): Promise<{}>;
     getLogs(filters?: LogFilter): Promise<{ items: Log[] }>;
     searchLogs(searchTerms: string[], filters?: LogFilter): Promise<{ items: Log[], filters: LogFilter[] }>;
     deleteAllLogs(): Promise<{}>;