Stackedit/public/res/helpers/couchdbHelper.js
2014-09-10 00:37:21 +01:00

248 lines
5.5 KiB
JavaScript

define([
"jquery",
"underscore",
"constants",
"core",
"utils",
"storage",
"logger",
"settings",
"eventMgr",
"classes/AsyncTask"
], function($, _, constants, core, utils, storage, logger, settings, eventMgr, AsyncTask) {
var couchdbHelper = {};
// Listen to offline status changes
var isOffline = false;
eventMgr.addListener("onOfflineChanged", function(isOfflineParam) {
isOffline = isOfflineParam;
});
couchdbHelper.uploadDocument = function(documentId, title, content, tags, rev, callback) {
var result;
var task = new AsyncTask();
task.onRun(function() {
if(tags) {
// Has to be an array
if(!_.isArray(tags)) {
tags = _.chain(('' + tags).split(/\s+/))
.compact()
.unique()
.value();
}
// Remove invalid tags
tags = tags.filter(function(tag) {
return _.isString(tag) && tag.length < 32;
});
// Limit the number of tags
tags = tags.slice(0, 16);
}
else {
tags = undefined;
}
$.ajax({
type: 'POST',
url: constants.COUCHDB_URL,
contentType: 'application/json',
dataType: 'json',
data: JSON.stringify({
_id: documentId || utils.id(),
title: title,
tags: tags,
updated: Date.now(),
_rev: rev,
_attachments: {
content: {
content_type: 'text\/plain',
data: utils.encodeBase64(content)
}
}
})
}).done(function(data) {
result = data;
task.chain();
}).fail(function(jqXHR) {
handleError(jqXHR, task);
});
});
task.onSuccess(function() {
callback(undefined, result);
});
task.onError(function(error) {
callback(error);
});
task.enqueue();
};
couchdbHelper.checkChanges = function(lastChangeId, syncLocations, callback) {
var changes;
var newChangeId = lastChangeId || 0;
var task = new AsyncTask();
task.onRun(function() {
$.ajax({
type: 'POST',
url: constants.COUCHDB_URL + '/_changes?' + $.param({
filter: '_doc_ids',
since: newChangeId,
include_docs: true,
attachments: true
}),
contentType: 'application/json',
dataType: 'json',
data: JSON.stringify({
doc_ids: Object.keys(syncLocations)
})
}).done(function(data) {
newChangeId = data.last_seq;
changes = _.map(data.results, function(result) {
return result.deleted ? {
_id: result.id,
deleted: true
} : result.doc;
});
task.chain();
}).fail(function(jqXHR) {
handleError(jqXHR, task);
});
});
task.onSuccess(function() {
callback(undefined, changes, newChangeId);
});
task.onError(function(error) {
callback(error);
});
task.enqueue();
};
couchdbHelper.downloadContent = function(documents, callback) {
var result = [];
var task = new AsyncTask();
task.onRun(function() {
function recursiveDownloadContent() {
if(documents.length === 0) {
return task.chain();
}
var document = documents[0];
result.push(document);
if(document.deleted || ((document._attachments || {}).content || {}).data !== undefined) {
documents.shift();
return task.chain(recursiveDownloadContent);
}
$.ajax({
url: constants.COUCHDB_URL + '/' + encodeURIComponent(document._id),
headers: {
Accept: 'application/json'
},
contentType: 'application/json',
dataType: 'json',
data: {
attachments: true
}
}).done(function(doc) {
documents.shift();
_.extend(document, doc);
task.chain(recursiveDownloadContent);
}).fail(function(jqXHR) {
handleError(jqXHR, task);
});
}
task.chain(recursiveDownloadContent);
});
task.onSuccess(function() {
callback(undefined, result);
});
task.onError(function(error) {
callback(error);
});
task.enqueue();
};
couchdbHelper.listDocuments = function(tag, updated, callback) {
var result;
var task = new AsyncTask();
task.onRun(function() {
var ddoc = '/_design/by_' + (tag ? 'tag_and_' : '') + 'update/_view/default';
var startKey = tag ? JSON.stringify([
tag,
updated || []
]) : updated;
var endKey = tag && JSON.stringify([
tag
]);
$.ajax({
url: constants.COUCHDB_URL + ddoc,
data: {
start_key: startKey,
end_key: endKey,
descending: true,
include_docs: true,
limit: 3,
reduce: false
},
dataType: 'json'
}).done(function(data) {
result = _.pluck(data.rows, 'doc');
task.chain();
}).fail(function(jqXHR) {
handleError(jqXHR, task);
});
});
task.onSuccess(function() {
callback(undefined, result);
});
task.onError(function(error) {
callback(error);
});
task.enqueue();
};
couchdbHelper.deleteDocuments = function(docs) {
var task = new AsyncTask();
task.onRun(function() {
$.ajax({
type: 'POST',
url: constants.COUCHDB_URL + '/_bulk_docs',
data: JSON.stringify({
docs: docs.map(function(doc) {
return {
_id: doc._id,
_rev: doc._rev,
_deleted: true
};
})
}),
contentType: 'application/json',
dataType: 'json'
}).done(function() {
task.chain();
}).fail(function(jqXHR) {
handleError(jqXHR, task);
});
});
task.enqueue();
};
function handleError(jqXHR, task) {
var error = {
code: jqXHR.status,
message: jqXHR.statusText,
reason: (jqXHR.responseJSON || {}).reason
};
var errorMsg;
if(error) {
logger.error(error);
// Try to analyze the error
if(typeof error === "string") {
errorMsg = error;
}
else {
errorMsg = "Error " + error.code + ": " + (error.reason || error.message);
}
}
task.error(new Error(errorMsg));
}
return couchdbHelper;
});