Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
stores.docStore.get(doc._id, function (err, metadata) {
if (err) {
return console.warn(err)
}
/* istanbul ignore if */
if (opts.cancelled || opts.done || db.isClosed() ||
isLocalId(metadata.id)) {
return next()
}
docIdsToMetadata.set(doc._id, metadata)
onGetMetadata(metadata)
})
}, function (next) {
docInfos.forEach(function (docInfo) {
if (docInfo._id && isLocalId(docInfo._id)) {
return checkDone(); // skip local docs
}
var id = docInfo.metadata.id;
tx.executeSql('SELECT json FROM ' + DOC_STORE +
' WHERE id = ?', [id], function (tx, result) {
if (result.rows.length) {
var metadata = safeJsonParse(result.rows.item(0).json);
fetchedDocs.set(id, metadata);
}
checkDone();
});
});
}
stores.docStore.get(doc._id, function (err, metadata) {
/* istanbul ignore if */
if (opts.cancelled || opts.done || db.isClosed() ||
pouchdbAdapterUtils.isLocalId(metadata.id)) {
return next();
}
docIdsToMetadata.set(doc._id, metadata);
onGetMetadata(metadata);
});
}, function (next) {
userDocs.forEach(function (doc) {
if (doc._id && isLocalId(doc._id)) {
// skip local docs
return checkDone();
}
txn.get(stores.docStore, doc._id, function (err, info) {
if (err) {
/* istanbul ignore if */
if (err.name !== 'NotFoundError') {
overallErr = err;
}
} else {
fetchedDocs.set(doc._id, info);
}
checkDone();
});
});
}
userDocs.forEach(function (doc) {
if (doc._id && isLocalId(doc._id)) {
// skip local docs
return checkDone()
}
txn.get(stores.docStore, doc._id, function (err, info) {
if (err) {
/* istanbul ignore if */
if (err.name !== 'NotFoundError') {
overallErr = err
}
} else {
fetchedDocs.set(doc._id, info)
}
checkDone()
})
})
}
stores.docStore.get(doc._id, function (err, metadata) {
/* istanbul ignore if */
if (opts.cancelled || opts.done || db.isClosed() ||
pouchdbAdapterUtils.isLocalId(metadata.id)) {
return next();
}
docIdsToMetadata.set(doc._id, metadata);
onGetMetadata(metadata);
});
}, function (next) {
idbProcessDocs();
}
}
function readMetadata(event) {
var metadata = decodeMetadata(event.target.result);
if (metadata) {
fetchedDocs.set(metadata.id, metadata);
}
checkDone();
}
for (var i = 0, len = docInfos.length; i < len; i++) {
var docInfo = docInfos[i];
if (docInfo._id && isLocalId(docInfo._id)) {
checkDone(); // skip local docs
continue;
}
var req = docStore.get(docInfo.metadata.id);
req.onsuccess = readMetadata;
}
}
var docInfos = userDocs.map(function (doc) {
if (doc._id && pouchdbAdapterUtils.isLocalId(doc._id)) {
return doc;
}
var newDoc = pouchdbAdapterUtils.parseDoc(doc, newEdits);
if (newDoc.metadata && !newDoc.metadata.rev_map) {
newDoc.metadata.rev_map = {};
}
return newDoc;
});
var infoErrors = docInfos.filter(function (doc) {
var docInfos = userDocs.map(function (doc) {
if (doc._id && isLocalId(doc._id)) {
return doc;
}
var newDoc = parseDoc(doc, newEdits, api.__opts);
if (newDoc.metadata && !newDoc.metadata.rev_map) {
newDoc.metadata.rev_map = {};
}
return newDoc;
});
var infoErrors = docInfos.filter(function (doc) {
var docInfos = userDocs.map(function (doc) {
if (doc._id && pouchdbAdapterUtils.isLocalId(doc._id)) {
return doc;
}
var newDoc = pouchdbAdapterUtils.parseDoc(doc, newEdits);
if (newDoc.metadata && !newDoc.metadata.rev_map) {
newDoc.metadata.rev_map = {};
}
return newDoc;
});
var infoErrors = docInfos.filter(function (doc) {