mirror of
https://github.com/Kong/insomnia.git
synced 2026-10-26 08:38:58 -04:00
51 lines
1.2 KiB
JavaScript
51 lines
1.2 KiB
JavaScript
import {bindActionCreators} from 'redux';
|
|
import * as entitiesActions from './modules/entities';
|
|
import * as db from '../database';
|
|
|
|
const CHANGE_ID = 'store.listener';
|
|
|
|
export function initStore (dispatch) {
|
|
db.offChange(CHANGE_ID);
|
|
|
|
const entities = bindActionCreators(entitiesActions, dispatch);
|
|
|
|
const docChanged = (event, doc) => {
|
|
if (!doc.hasOwnProperty('type')) {
|
|
return;
|
|
}
|
|
|
|
if (event === 'insert') {
|
|
entities.insert(doc);
|
|
} else if (event === 'update') {
|
|
entities.update(doc);
|
|
} else if (event === 'remove') {
|
|
entities.remove(doc);
|
|
}
|
|
};
|
|
|
|
console.log('-- Restoring Store --');
|
|
|
|
const start = Date.now();
|
|
|
|
// Restore docs in parent->child->grandchild order
|
|
return Promise.all([
|
|
db.settingsGet(),
|
|
db.workspaceAll(),
|
|
db.environmentAll(),
|
|
db.cookieJarAll(),
|
|
db.requestGroupAll(),
|
|
db.requestAll()
|
|
]).then(results => {
|
|
for (let docs of results) {
|
|
docs = Array.isArray(docs) ? docs : [docs];
|
|
|
|
for (let doc of docs) {
|
|
docChanged('update', doc);
|
|
}
|
|
}
|
|
|
|
console.log(`-- Restored DB in ${(Date.now() - start) / 1000} s --`);
|
|
db.onChange(CHANGE_ID, docChanged);
|
|
});
|
|
}
|