Mirrors/unleash.unleash
1
0
Fork 0
mirror of https://github.com/Unleash/unleash.git synced 2025-02-19 00:15:43 +01:00
Code Issues Projects Releases Wiki Activity

wip: can we just reset db?

Browse Source
This commit is contained in:
Ivar Conradi Østhus 2021-03-11 11:42:50 +01:00
parent ad04eeb9b5
commit 6531ad0bbc
No known key found for this signature in database
GPG Key ID: 31AC596886B0BD09
4 changed files with 27 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/lib/server-impl.js
View File

@ -116,7 +116,7 @@ async function start(opts) {
if (options.disableDBMigration) {
logger.info('DB migrations disabled');
} else {
await migrator(options);
await migrator.up(options);
}
} catch (err) {
logger.error('Failed to migrate db', err);

2
src/lib/server-impl.test.js
View File

@ -50,7 +50,7 @@ const serverImpl = proxyquire('./server-impl', {
},
},
'../migrator': function() {
return Promise.resolve();
return { up: Promise.resolve() };
},
});

18
src/migrator.js
View File

@ -4,14 +4,24 @@ require('db-migrate-shared').log.setLogLevel('error');
const { getInstance } = require('db-migrate');
function migrateDb({ db, databaseSchema = 'public' }) {
function getDbInstance({ db, databaseSchema = 'public' }) {
const custom = { ...db, schema: databaseSchema };
const dbmigrate = getInstance(true, {
return getInstance(true, {
cwd: __dirname,
config: { custom },
env: 'custom',
});
return dbmigrate.up();
}
module.exports = migrateDb;
async function up(options) {
return getDbInstance(options).up();
}
async function reset(options) {
return getDbInstance(options).reset();
}
module.exports = {
up,
reset,
};

14
src/test/e2e/helpers/database-init.js
View File

@ -83,7 +83,7 @@ async function setupDatabase(stores) {
module.exports = async function init(databaseSchema = 'test', getLogger) {
const options = {
db: { ...dbConfig.getDb(), pool: { min: 2, max: 8 } },
db: { ...dbConfig.getDb(), pool: { min: 2, max: 20 } },
databaseSchema,
getLogger,
};
@ -93,7 +93,7 @@ module.exports = async function init(databaseSchema = 'test', getLogger) {
await db.raw(`DROP SCHEMA IF EXISTS ${options.databaseSchema} CASCADE`);
await db.raw(`CREATE SCHEMA IF NOT EXISTS ${options.databaseSchema}`);
await migrator(options);
await migrator.up(options);
await db.destroy();
const stores = await createStores(options, eventBus);
stores.clientMetricsStore.setMaxListeners(0);
@ -101,10 +101,18 @@ module.exports = async function init(databaseSchema = 'test', getLogger) {
await resetDatabase(stores);
await setupDatabase(stores);
const reset = async () => {
await db.raw(`DROP SCHEMA IF EXISTS ${options.databaseSchema} CASCADE`);
await db.raw(`CREATE SCHEMA IF NOT EXISTS ${options.databaseSchema}`);
await migrator.reset(options);
await migrator.up(options);
};
return {
stores,
reset: async () => {
await resetDatabase(stores);
// await resetDatabase(stores);
await reset();
await setupDatabase(stores);
},
destroy: async () => {