index.js

class TypeOrmAdapter {
    constructor(connection) {
        this.connection = connection;
    }

    build(Model, props) {
        const model = new Model(props);
        return model;
    }

    async save(model, Model) {
        return this.connection.manager.save(model);
    }

    async destroy(model, Model) {
        const manager = this.connection.manager;
        const modelRepo = manager.getRepository(Model);
        try {
            if (this.connection.options.type === 'sqlite') {
                await manager.query('PRAGMA foreign_keys = OFF;');
            } else if (this.connection.options.type === 'postgres') {
                await manager.query(`BEGIN;
                    ALTER TABLE "${modelRepo.metadata.tableName}" DISABLE TRIGGER ALL;`);
            } else {
                await manager.query('SET FOREIGN_KEY_CHECKS=0;');
            }
            await manager.delete(Model, model.id ? model.id : model.api_id);
            if (this.connection.options.type === 'sqlite') {
                return manager.query('PRAGMA foreign_keys = ON;');
            } else if (this.connection.options.type === 'postgres') {
                await manager.query(`
                    ALTER TABLE "${modelRepo.metadata.tableName}" ENABLE TRIGGER ALL;
                    COMMIT;`);
            } else {
                return manager.query('SET FOREIGN_KEY_CHECKS=1;');
            }
        } catch (err) {
            return;
        }
    }

    get(model, attr, Model) {
        return model[attr];
    }

    set(props, model, Model) {
        Object.keys(props).forEach((key) => {
            model[key] = props[key];
        });
        return model;
    }
}

module.exports = TypeOrmAdapter;