/** * Nextcloud - passman * * @copyright Copyright (c) 2016, Sander Brand (brantje@gmail.com) * @copyright Copyright (c) 2016, Marcos Zuriaga Miguel (wolfi@wolfi.es) * @license GNU AGPL version 3 or any later version * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . * */ (function () { 'use strict'; /** * @ngdoc service * @name passmanApp.CredentialService * @description * # CredentialService * Service in the passmanApp. */ angular.module('passmanApp') .service('CredentialService', ['$http', 'EncryptService', 'VaultService', 'FileService', function ($http, EncryptService, VaultService, FileService) { var credential = { 'credential_id': null, 'guid': null, 'vault_id': null, 'label': null, 'description': null, 'created': null, 'changed': null, 'tags': [], 'email': null, 'username': null, 'password': null, 'url': null, 'favicon': null, 'renew_interval': null, 'expire_time': 0, 'delete_time': 0, 'files': [], 'custom_fields': [], 'otp': {}, 'hidden': false }; var _encryptedFields = ['description', 'username', 'password', 'files', 'custom_fields', 'otp', 'email', 'tags', 'url']; return { newCredential: function () { return angular.copy(credential); }, createCredential: function (credential) { var _credential = angular.copy(credential); for (var i = 0; i < _encryptedFields.length; i++) { var field = _encryptedFields[i]; var fieldValue = angular.copy(credential[field]); _credential[field] = EncryptService.encryptString(JSON.stringify(fieldValue)); } _credential.expire_time = new Date(angular.copy(credential.expire_time)).getTime() / 1000; var queryUrl = OC.generateUrl('apps/passman/api/v2/credentials'); return $http.post(queryUrl, _credential).then(function (response) { if (response.data) { return response.data; } else { return response; } }); }, getEncryptedFields: function () { return _encryptedFields; }, updateCredential: function (credential, skipEncyption) { var _credential = angular.copy(credential); if (!skipEncyption) { for (var i = 0; i < _encryptedFields.length; i++) { var field = _encryptedFields[i]; var fieldValue = angular.copy(credential[field]); _credential[field] = EncryptService.encryptString(JSON.stringify(fieldValue)); } } _credential.expire_time = new Date(angular.copy(credential.expire_time)).getTime() / 1000; var queryUrl = OC.generateUrl('apps/passman/api/v2/credentials/' + credential.guid); return $http.patch(queryUrl, _credential).then(function (response) { if (response.data) { return response.data; } else { return response; } }); }, getCredential: function (guid) { var queryUrl = OC.generateUrl('apps/passman/api/v2/credentials/' + guid); return $http.get(queryUrl).then(function (response) { if (response.data) { return response.data; } else { return response; } }); }, destroyCredential: function (guid) { var queryUrl = OC.generateUrl('apps/passman/api/v2/credentials/' + guid); return $http.delete(queryUrl).then(function (response) { if (response.data) { return response.data; } else { return response; } }); }, encryptCredential: function (credential, key) { for (var i = 0; i < _encryptedFields.length; i++) { var field = _encryptedFields[i]; var fieldValue = angular.copy(credential[field]); credential[field] = EncryptService.encryptString(JSON.stringify(fieldValue), key); } return credential; }, decryptCredential: function (credential, key) { for (var i = 0; i < _encryptedFields.length; i++) { var field = _encryptedFields[i]; var fieldValue = angular.copy(credential[field]); var field_decrypted_value; try { field_decrypted_value = EncryptService.decryptString(fieldValue, key); } catch (e) { throw e; } try { credential[field] = JSON.parse(field_decrypted_value); } catch (e) { console.warn('Field' + field + ' in ' + credential.label + ' could not be parsed! Value:' + fieldValue); } } return credential; }, getRevisions: function (guid) { var queryUrl = OC.generateUrl('apps/passman/api/v2/credentials/' + guid + '/revision'); return $http.get(queryUrl).then(function (response) { if (response.data) { return response.data; } else { return response; } }); }, updateRevision: function (revision) { var _revision = angular.copy(revision); _revision.credential_data = window.btoa(JSON.stringify(_revision.credential_data)); var queryUrl = OC.generateUrl('apps/passman/api/v2/credentials/' + revision.credential_data.guid + '/revision/' + revision.revision_id); return $http.patch(queryUrl, _revision).then(function (response) { if (response.data) { return response.data; } else { return response; } }); }, deleteRevision: function (credential_guid, revision_id) { var queryUrl = OC.generateUrl('apps/passman/api/v2/credentials/' + credential_guid + '/revision/' + revision_id); return $http.delete(queryUrl).then(function (response) { if (response.data) { return response.data; } else { return response; } }); }, reencryptCredential: function (credential_guid, old_password, new_password) { var service = this; var progress_datatype = function (current, total, process) { this.process = process; this.current = current; this.total = total; this.calculated = current / total * 100; }; var promise_credential_update = function () { service.getCredential(credential_guid).then((function (credential) { this.parent.plain_credential = service.decryptCredential(credential, this.parent.old_password); var tmp = angular.copy(this.parent.plain_credential); this.parent.new_credential_cryptogram = service.encryptCredential(tmp, this.parent.new_password); this.call_progress(new progress_datatype(1, 2, 'credential')); // Save data this.parent.new_credential_cryptogram.skip_revision = true; service.updateCredential(this.parent.new_credential_cryptogram, true).then((function () { this.call_progress(new progress_datatype(2, 2, 'credential')); this.call_then({ plain_text: this.parent.plain_credential, cryptogram: this.parent.new_credential_cryptogram }); }).bind(this)); }).bind(this)); }; var promise_files_update = function () { // Add the double of the files so we take encryption phase and upload to the server into the math this.total = this.parent.plain_credential.files.length * 2; // Binded on credential finish upload this.current = 0; for (var i = 0; i < this.parent.plain_credential.files.length; i++) { var _file = this.parent.plain_credential.files[i]; /* jshint ignore:start */ FileService.getFile(_file).then((function (fileData) { //Decrypt with old key fileData.filename = EncryptService.decryptString(fileData.filename, this.parent.old_password); fileData.file_data = EncryptService.decryptString(fileData.file_data, this.parent.old_password); this.current++; this.call_progress(new progress_datatype(this.current, this.total, 'files')); FileService.updateFile(fileData, this.parent.new_password).then((function () { this.current++; this.call_progress(new progress_datatype(this.current, this.total, 'files')); if (this.current === this.total) { this.call_then('All files has been updated'); } }).bind(this)); }).bind(this)); /* jshint ignore:end */ } if (this.parent.plain_credential.files.length === 0) { this.call_progress(new progress_datatype(0, 0, 'files')); this.call_then("No files to update"); } }; var promise_revisions_update = function () { service.getRevisions(this.parent.plain_credential.guid).then((function (revisions) { // Double, so we include the actual upload of the data back to the server this.total = revisions.length * 2; this.upload = 0; this.current = 0; this.revisions = revisions; var revision_workload = function () { if (this.revisions.length === 0) { this.call_progress(new progress_datatype(0, 0, 'revisions')); this.call_then("No history to update"); return; } var _revision = revisions[this.current]; //Decrypt! _revision.credential_data = service.decryptCredential(_revision.credential_data, this.parent.old_password); _revision.credential_data = service.encryptCredential(_revision.credential_data, this.parent.new_password); this.current++; this.call_progress(new progress_datatype(this.current + this.upload, this.total, 'revisions')); service.updateRevision(_revision).then((function () { this.upload++; this.call_progress(new progress_datatype(this.upload + this.current, this.total, 'revisions')); if (this.current + this.upload === this.total) { this.call_then("History updated"); } }).bind(this)); if (this.current !== (this.total / 2)) { setTimeout(revision_workload.bind(this), 1); } }; setTimeout(revision_workload.bind(this), 1); }).bind(this)); }; var promise_workload = function () { this.old_password = angular.copy(old_password); this.new_password = angular.copy(new_password); this.promises = 0; var master_promise = this; var password_data = function () { this.old_password = master_promise.old_password; this.new_password = master_promise.new_password; this.plain_credential = master_promise.plain_credential; }; this.credential_data = {}; /** global: C_Promise */ (new C_Promise(promise_credential_update, new password_data())).progress(function (data) { master_promise.call_progress(data); }).then(function (data) { console.warn("End credential update"); master_promise.plain_credential = data.plain_text; master_promise.promises++; master_promise.credential_data = data; /** global: C_Promise */ (new C_Promise(promise_files_update, new password_data())).progress(function (data) { master_promise.call_progress(data); }).then(function () { console.warn("End files update"); master_promise.promises--; if (master_promise.promises === 0) { master_promise.call_then(master_promise.credential_data); } }); master_promise.promises++; /** global: C_Promise */ (new C_Promise(promise_revisions_update, new password_data())).progress(function (data) { master_promise.call_progress(data); }).then(function () { console.warn("End revisions update"); master_promise.promises--; if (master_promise.promises === 0) { master_promise.call_then(master_promise.credential_data); } }); }); }; /** global: C_Promise */ return new C_Promise(promise_workload); } }; }]); }());