2017-06-12 21:49:46 +00:00
|
|
|
import deepEqual from 'deep-equal';
|
|
|
|
import * as models from './index';
|
|
|
|
import * as db from '../common/database';
|
2017-06-30 03:30:22 +00:00
|
|
|
import {compressObject, decompressObject} from '../common/misc';
|
2017-06-12 21:49:46 +00:00
|
|
|
export const name = 'Request Version';
|
|
|
|
export const type = 'RequestVersion';
|
|
|
|
export const prefix = 'rvr';
|
|
|
|
export const canDuplicate = false;
|
|
|
|
|
|
|
|
const FIELDS_TO_IGNORE_IN_REQUEST_DIFF = [
|
|
|
|
'_id',
|
|
|
|
'type',
|
|
|
|
'created',
|
|
|
|
'modified',
|
|
|
|
'metaSortKey',
|
|
|
|
'description',
|
|
|
|
'name'
|
|
|
|
];
|
|
|
|
|
|
|
|
export function init () {
|
|
|
|
return {
|
|
|
|
compressedRequest: null
|
|
|
|
};
|
|
|
|
}
|
|
|
|
|
|
|
|
export function migrate (doc) {
|
|
|
|
return doc;
|
|
|
|
}
|
|
|
|
|
|
|
|
export function getById (id) {
|
|
|
|
return db.get(type, id);
|
|
|
|
}
|
|
|
|
|
|
|
|
export async function create (request) {
|
|
|
|
if (!request.type === models.request.type) {
|
|
|
|
throw new Error(`New ${type} was not given a valid ${models.request.type} instance`);
|
|
|
|
}
|
|
|
|
|
|
|
|
const parentId = request._id;
|
|
|
|
const latestRequestVersion = await getLatestByParentId(parentId);
|
|
|
|
const latestRequest = latestRequestVersion
|
2017-06-30 03:30:22 +00:00
|
|
|
? decompressObject(latestRequestVersion.compressedRequest)
|
2017-06-12 21:49:46 +00:00
|
|
|
: null;
|
|
|
|
|
|
|
|
const hasChanged = _diffRequests(latestRequest, request);
|
|
|
|
if (hasChanged) {
|
|
|
|
// Create a new version if the request has been modified
|
2017-06-30 03:30:22 +00:00
|
|
|
const compressedRequest = compressObject(request);
|
2017-06-12 21:49:46 +00:00
|
|
|
return db.docCreate(type, {parentId, compressedRequest});
|
|
|
|
} else {
|
|
|
|
// Re-use the latest version if not modified since
|
|
|
|
return latestRequestVersion;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
export function getLatestByParentId (parentId) {
|
|
|
|
return db.getMostRecentlyModified(type, {parentId});
|
|
|
|
}
|
|
|
|
|
|
|
|
export async function restore (requestVersionId) {
|
|
|
|
const requestVersion = await getById(requestVersionId);
|
|
|
|
|
|
|
|
// Older responses won't have versions saved with them
|
|
|
|
if (!requestVersion) {
|
|
|
|
return null;
|
|
|
|
}
|
|
|
|
|
2017-06-30 03:30:22 +00:00
|
|
|
const request = decompressObject(requestVersion.compressedRequest);
|
2017-06-12 21:49:46 +00:00
|
|
|
return models.request.update(request);
|
|
|
|
}
|
|
|
|
|
|
|
|
function _diffRequests (rOld, rNew) {
|
|
|
|
if (!rOld) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
for (const key of Object.keys(rOld)) {
|
|
|
|
// Skip fields that aren't useful
|
|
|
|
if (FIELDS_TO_IGNORE_IN_REQUEST_DIFF.includes(key)) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!deepEqual(rOld[key], rNew[key])) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return false;
|
|
|
|
}
|