mirror of
https://github.com/moparisthebest/mail
synced 2025-02-07 10:30:18 -05:00
delete old cloud storage code from email dao
This commit is contained in:
Tankred Hase
parent
fbaa43aff6
commit
9767e3ace6
@ -5,7 +5,6 @@ define(function(require) {
|
|||||||
util = require('cryptoLib/util'),
|
util = require('cryptoLib/util'),
|
||||||
crypto = require('js/crypto/crypto'),
|
crypto = require('js/crypto/crypto'),
|
||||||
jsonDB = require('js/dao/lawnchair-dao'),
|
jsonDB = require('js/dao/lawnchair-dao'),
|
||||||
devicestorage = require('js/dao/devicestorage-dao'),
|
|
||||||
str = require('js/app-config').string;
|
str = require('js/app-config').string;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -485,245 +484,5 @@ define(function(require) {
|
|||||||
return self._account.folders[folderName][itemId];
|
return self._account.folders[folderName][itemId];
|
||||||
};
|
};
|
||||||
|
|
||||||
//
|
|
||||||
// Cloud storage Apis
|
|
||||||
//
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Fetch a list of emails from the device's local storage
|
|
||||||
* @param offset [Number] The offset of items to fetch (0 is the last stored item)
|
|
||||||
* @param num [Number] The number of items to fetch (null means fetch all)
|
|
||||||
*/
|
|
||||||
EmailDAO.prototype.listItems = function(folderName, offset, num, callback) {
|
|
||||||
var self = this,
|
|
||||||
collection, folder;
|
|
||||||
|
|
||||||
// check if items are in memory already (_account.folders model)
|
|
||||||
folder = self._account.get('folders').where({
|
|
||||||
name: folderName
|
|
||||||
})[0];
|
|
||||||
|
|
||||||
if (!folder) {
|
|
||||||
// get encrypted items from storage
|
|
||||||
devicestorage.listEncryptedItems('email_' + folderName, offset, num, function(err, encryptedList) {
|
|
||||||
if (err) {
|
|
||||||
callback(err);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (encryptedList.length === 0) {
|
|
||||||
callback(null, []);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// decrypt list
|
|
||||||
crypto.decryptKeysAndList(encryptedList, function(err, decryptedList) {
|
|
||||||
if (err) {
|
|
||||||
callback(err);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// cache collection in folder memory
|
|
||||||
if (decryptedList.length > 0) {
|
|
||||||
folder = {
|
|
||||||
name: folderName
|
|
||||||
};
|
|
||||||
folder.set('items', decryptedList);
|
|
||||||
self._account.get('folders').add(folder);
|
|
||||||
}
|
|
||||||
|
|
||||||
callback(null, decryptedList);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
} else {
|
|
||||||
// read items from memory
|
|
||||||
collection = folder.get('items');
|
|
||||||
callback(null, collection);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Synchronize a folder's items from the cloud to the device-storage
|
|
||||||
* @param folderName [String] The name of the folder e.g. 'inbox'
|
|
||||||
*/
|
|
||||||
EmailDAO.prototype.syncFromCloud = function(folderName, callback) {
|
|
||||||
var self = this,
|
|
||||||
folder, already, pubkeyIds = [];
|
|
||||||
|
|
||||||
// fetch most recent date
|
|
||||||
this.listItems(folderName, 0, 1, function(err, localItems) {
|
|
||||||
if (err) {
|
|
||||||
callback(err); // error
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
var filter = '';
|
|
||||||
if (localItems && localItems.length > 0) {
|
|
||||||
// get gmt date since that's what the storage service seems to use
|
|
||||||
var sentDate = localItems[localItems.length - 1].sentDate;
|
|
||||||
var date = util.parseDate(sentDate);
|
|
||||||
date.setHours(date.getHours() + (date.getTimezoneOffset() / 60));
|
|
||||||
var gmtDate = util.formatDate(date);
|
|
||||||
|
|
||||||
// sync delta of last item sent date
|
|
||||||
filter = '?date=' + gmtDate;
|
|
||||||
startSync(filter);
|
|
||||||
|
|
||||||
} else {
|
|
||||||
// do a full sync of all items on the cloud
|
|
||||||
startSync(filter);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
function startSync(filter) {
|
|
||||||
// fetch items from the cloud
|
|
||||||
self._cloudstorage.listEncryptedItems('email', self._account.get('emailAddress'), folderName + filter, function(err, encryptedList) {
|
|
||||||
// return if an error occured
|
|
||||||
if (err) {
|
|
||||||
callback({
|
|
||||||
errMsg: 'Syncing encrypted items from cloud failed!',
|
|
||||||
err: err
|
|
||||||
}); // error
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (encryptedList.length === 0) {
|
|
||||||
callback();
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// TODO: remove old folder items from devicestorage
|
|
||||||
|
|
||||||
reencryptItems(encryptedList);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
function reencryptItems(encryptedList) {
|
|
||||||
// gather public key ids required to verify signatures
|
|
||||||
encryptedList.forEach(function(i) {
|
|
||||||
already = null;
|
|
||||||
already = _.findWhere(pubkeyIds, {
|
|
||||||
_id: i.senderPk
|
|
||||||
});
|
|
||||||
if (!already) {
|
|
||||||
pubkeyIds.push({
|
|
||||||
_id: i.senderPk
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
// fetch public keys from keychain
|
|
||||||
self._keychain.getPublicKeys(pubkeyIds, function(err, senderPubkeys) {
|
|
||||||
if (err) {
|
|
||||||
callback(err);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// verfiy signatures and re-encrypt item keys
|
|
||||||
crypto.reencryptListKeysForUser(encryptedList, senderPubkeys, function(err, encryptedKeyList) {
|
|
||||||
if (err) {
|
|
||||||
callback(err);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// persist encrypted list in device storage
|
|
||||||
devicestorage.storeEcryptedList(encryptedKeyList, 'email_' + folderName, function() {
|
|
||||||
// remove cached folder in _account model
|
|
||||||
folder = self._account.get('folders').where({
|
|
||||||
name: folderName
|
|
||||||
})[0];
|
|
||||||
if (folder) {
|
|
||||||
self._account.get('folders').remove(folder);
|
|
||||||
}
|
|
||||||
callback();
|
|
||||||
});
|
|
||||||
});
|
|
||||||
});
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Send a plaintext Email to the user's outbox in the cloud
|
|
||||||
*/
|
|
||||||
EmailDAO.prototype.sendEmail = function(email, callback) {
|
|
||||||
var self = this,
|
|
||||||
userId = self._account.get('emailAddress');
|
|
||||||
|
|
||||||
// validate email addresses
|
|
||||||
var invalidRecipient;
|
|
||||||
_.each(email.to, function(i) {
|
|
||||||
if (!util.validateEmailAddress(i.address)) {
|
|
||||||
invalidRecipient = i.address;
|
|
||||||
}
|
|
||||||
});
|
|
||||||
if (invalidRecipient) {
|
|
||||||
callback({
|
|
||||||
errMsg: 'Invalid recipient: ' + invalidRecipient
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (!util.validateEmailAddress(email.from[0].address)) {
|
|
||||||
callback({
|
|
||||||
errMsg: 'Invalid sender: ' + email.from
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// generate a new UUID for the new email
|
|
||||||
email.id = util.UUID();
|
|
||||||
// set sent date
|
|
||||||
email.sentDate = util.formatDate(new Date());
|
|
||||||
|
|
||||||
// only support single recipient for e-2-e encryption
|
|
||||||
var recipient = email.to[0].address;
|
|
||||||
|
|
||||||
// check if receiver has a public key
|
|
||||||
self._keychain.getReveiverPublicKey(recipient, function(err, receiverPubkey) {
|
|
||||||
if (err) {
|
|
||||||
callback(err);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (receiverPubkey) {
|
|
||||||
// public key found... encrypt and send
|
|
||||||
encrypt(email, receiverPubkey);
|
|
||||||
} else {
|
|
||||||
// no public key found... send plaintext mail via SMTP
|
|
||||||
send(email);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
function encrypt(email, receiverPubkey) {
|
|
||||||
// encrypt the email
|
|
||||||
crypto.encryptListForUser([email], [receiverPubkey], function(err, encryptedList) {
|
|
||||||
if (err) {
|
|
||||||
callback(err);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
var ct = encryptedList[0];
|
|
||||||
|
|
||||||
var envelope = {
|
|
||||||
id: email.id,
|
|
||||||
crypto: 'rsa-1024-sha-256-aes-128-cbc',
|
|
||||||
sentDate: email.sentDate,
|
|
||||||
ciphertext: ct.ciphertext,
|
|
||||||
encryptedKey: ct.encryptedKey,
|
|
||||||
iv: ct.iv,
|
|
||||||
signature: ct.signature,
|
|
||||||
senderPk: ct.senderPk
|
|
||||||
};
|
|
||||||
|
|
||||||
send(envelope);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
function send(email) {
|
|
||||||
// send email via cloud service
|
|
||||||
self._cloudstorage.deliverEmail(email, userId, recipient, function(err) {
|
|
||||||
callback(err);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
return EmailDAO;
|
return EmailDAO;
|
||||||
});
|
});
|
||||||
Loading…
Reference in New Issue
Block a user