Merge branch 'develop'

This commit is contained in:
Alice Gaudon 2021-11-10 17:59:59 +01:00
commit 0ad9143282
12 changed files with 51 additions and 68 deletions

View File

@ -13,7 +13,7 @@ module.exports = {
'./tsconfig.test.json',
'./src/tsconfig.json',
'./src/common/tsconfig.json',
'./src/assets/ts/tsconfig.json',
'./src/assets/ts/tsconfig.eslint.json',
'./src/assets/views/tsconfig.json',
]
},

View File

@ -1,6 +1,6 @@
{
"name": "swaf",
"version": "0.24.0",
"version": "0.24.1",
"description": "Structure Web Application Framework.",
"repository": "https://eternae.ink/ashpie/swaf",
"author": "Alice Gaudon <alice@gaudon.pro>",

View File

@ -23,9 +23,9 @@ export default abstract class FileUploadMiddleware extends Middleware {
resolve();
});
});
} catch (e: any) {
} catch (e) {
const bag = new ValidationBag();
const fileError = new FileError(e);
const fileError = new FileError(String(e));
fileError.thingName = this.getDefaultField();
bag.addMessage(fileError);
next(bag);

View File

@ -1,4 +1,4 @@
import {promises as fs} from "fs";
import fs, {promises as afs} from "fs";
import path from "path";
export async function sleep(ms: number): Promise<void> {
@ -49,10 +49,10 @@ export function getMethods<T extends { [p: string]: unknown }>(obj: T): string[]
}
export async function listFilesRecursively(dir: string): Promise<string[]> {
const localFiles = await fs.readdir(dir);
const localFiles = await afs.readdir(dir);
const files: string[] = [];
for (const file of localFiles.map(file => path.join(dir, file))) {
const stat = await fs.stat(file);
const stat = await afs.stat(file);
if (stat.isDirectory()) {
files.push(...await listFilesRecursively(file));
@ -65,14 +65,17 @@ export async function listFilesRecursively(dir: string): Promise<string[]> {
export async function doesFileExist(file: string): Promise<boolean> {
try {
await fs.stat(file);
} catch (err: any) {
if (err?.code === 'ENOENT') {
return false;
} else {
throw err;
}
}
return true;
return await new Promise<boolean>((resolve, reject) => {
fs.stat(file, err => {
if (err) {
if (err.code === 'ENOENT') {
return resolve(false);
} else {
return reject(err);
}
} else {
return resolve(true);
}
});
});
}

View File

@ -2,7 +2,7 @@ import feather from "feather-icons";
let alreadyReplaced = false;
export function replaceIcons(once: boolean = true) {
export function replaceIcons(once: boolean = true): void {
if (!once || !alreadyReplaced) {
alreadyReplaced = true;
feather.replace();

View File

@ -0,0 +1,6 @@
{
"extends": "./tsconfig.json",
"include": [
"./**/*"
]
}

View File

@ -1,14 +0,0 @@
import Migration from "../../db/Migration.js";
/**
* @deprecated - TODO may be remove at next major version >= 0.24, replace with DummyMigration.
*/
export default class DropNameFromUsers extends Migration {
public async install(): Promise<void> {
await this.query('ALTER TABLE users DROP COLUMN IF EXISTS name');
}
public async rollback(): Promise<void> {
await this.query('ALTER TABLE users ADD COLUMN name VARCHAR(64)');
}
}

View File

@ -1,27 +0,0 @@
import Migration from "../../db/Migration.js";
/**
* @deprecated - TODO may be remove at next major version >= 0.24, replace with DummyMigration.
*/
export default class FixUserMainEmailRelation extends Migration {
public async install(): Promise<void> {
await this.query(`ALTER TABLE users
ADD COLUMN main_email_id INT,
ADD FOREIGN KEY main_user_email_fk (main_email_id) REFERENCES user_emails (id)`);
await this.query(`UPDATE users u LEFT JOIN user_emails ue ON u.id = ue.user_id
SET u.main_email_id=ue.id
WHERE ue.main = true`);
await this.query(`ALTER TABLE user_emails
DROP COLUMN main`);
}
public async rollback(): Promise<void> {
await this.query(`ALTER TABLE user_emails
ADD COLUMN main BOOLEAN DEFAULT false`);
await this.query(`UPDATE user_emails ue LEFT JOIN users u ON ue.id = u.main_email_id
SET ue.main = true`);
await this.query(`ALTER TABLE users
DROP FOREIGN KEY main_user_email_fk,
DROP COLUMN main_email_id`);
}
}

View File

@ -48,8 +48,12 @@ export default class MailComponent extends ApplicationComponent {
try {
await util.promisify(transporter.verify)();
this.transporter = transporter;
} catch (e: any) {
throw new MailError('Connection to mail service unsuccessful.', e);
} catch (e) {
if (e instanceof Error) {
throw new MailError('Connection to mail service unsuccessful.', e);
} else {
throw e;
}
}
logger.info(`Mail ready to be distributed via ${config.get('mail.host')}:${config.get('mail.port')}`);

View File

@ -183,9 +183,14 @@ export default class MysqlConnectionManager {
try {
const result = await query('SELECT id FROM migrations ORDER BY id DESC LIMIT 1');
currentVersion = Number(result.results[0]?.id);
} catch (e: any) {
if (e.code === 'ECONNREFUSED' || e.code !== 'ER_NO_SUCH_TABLE') {
throw new Error('Cannot run migrations: ' + e.code);
} catch (e) {
if (e instanceof Error) {
const mysqlError = e as MysqlError;
if (mysqlError.code !== 'ER_NO_SUCH_TABLE') {
throw new Error('Cannot run migrations: ' + mysqlError.code);
}
} else {
throw e;
}
}

View File

@ -61,8 +61,12 @@ export default class Validator<V> {
if (result instanceof Promise) {
result = await result;
}
} catch (e: any) {
throw new ServerError(`An error occurred while validating ${thingName} with value "${value}".`, e);
} catch (e) {
if (e instanceof Error) {
throw new ServerError(`An error occurred while validating ${thingName} with value "${value}".`, e);
} else {
throw e;
}
}
if (result === false && step.throw) {

View File

@ -1,3 +1,5 @@
import {MysqlError} from "mysql";
import Migration from "../db/Migration.js";
import {query} from "../db/MysqlConnectionManager.js";
@ -8,8 +10,8 @@ export default class CreateMigrationsTable extends Migration {
public async shouldRun(currentVersion: number): Promise<boolean> {
try {
await query('SELECT 1 FROM migrations LIMIT 1');
} catch (e: any) {
if (e.code !== 'ER_NO_SUCH_TABLE') {
} catch (e) {
if (!(e instanceof Error) || (e as MysqlError).code !== 'ER_NO_SUCH_TABLE') {
return false;
}
}