ServerStorage.vue 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544
  1. <template>
  2. <div></div>
  3. </template>
  4. <script>
  5. //-----------------------------------------------------------------------------
  6. import Vue from 'vue';
  7. import Component from 'vue-class-component';
  8. import _ from 'lodash';
  9. import bookManager from '../share/bookManager';
  10. import readerApi from '../../../api/reader';
  11. import * as utils from '../../../share/utils';
  12. import * as cryptoUtils from '../../../share/cryptoUtils';
  13. export default @Component({
  14. watch: {
  15. serverSyncEnabled: function() {
  16. this.serverSyncEnabledChanged();
  17. },
  18. serverStorageKey: function() {
  19. this.serverStorageKeyChanged(true);
  20. },
  21. settings: function() {
  22. this.debouncedSaveSettings();
  23. },
  24. profiles: function() {
  25. this.saveProfiles();
  26. },
  27. currentProfile: function() {
  28. this.currentProfileChanged(true);
  29. },
  30. },
  31. })
  32. class ServerStorage extends Vue {
  33. created() {
  34. this.inited = false;
  35. this.keyInited = false;
  36. this.commit = this.$store.commit;
  37. this.prevServerStorageKey = null;
  38. this.$root.$on('generateNewServerStorageKey', () => {this.generateNewServerStorageKey()});
  39. this.debouncedSaveSettings = _.debounce(() => {
  40. this.saveSettings();
  41. }, 500);
  42. this.debouncedSaveRecent = _.debounce(() => {
  43. this.saveRecent();
  44. }, 1000);
  45. this.debouncedNotifySuccess = _.debounce(() => {
  46. this.success('Данные синхронизированы с сервером');
  47. }, 1000);
  48. this.oldProfiles = {};
  49. this.oldSettings = {};
  50. this.oldRecent = {};
  51. this.oldRecentDiff = {};
  52. }
  53. async init() {
  54. try {
  55. if (!this.serverStorageKey) {
  56. //генерируем новый ключ
  57. await this.generateNewServerStorageKey();
  58. } else {
  59. await this.serverStorageKeyChanged();
  60. }
  61. bookManager.addEventListener(this.bookManagerEvent);
  62. } finally {
  63. this.inited = true;
  64. }
  65. }
  66. async bookManagerEvent(eventName) {
  67. if (eventName == 'load-stored-finish') {
  68. this.oldRecent = _.cloneDeep(bookManager.recent);
  69. this.oldRecentLast = _.cloneDeep(bookManager.recentLast) || {};
  70. }
  71. if (eventName == 'recent-changed') {
  72. let i = 0;
  73. while (!bookManager.loaded && i++ < 1000) await utils.sleep(100);
  74. i = 0;
  75. while (!this.inited && i++ < 1000) await utils.sleep(100);
  76. this.debouncedSaveRecent();
  77. }
  78. }
  79. async generateNewServerStorageKey() {
  80. const key = utils.toBase58(utils.randomArray(32));
  81. this.commit('reader/setServerStorageKey', key);
  82. await this.serverStorageKeyChanged(true);
  83. }
  84. async serverSyncEnabledChanged() {
  85. if (this.serverSyncEnabled) {
  86. this.prevServerStorageKey = null;
  87. if (!this.serverStorageKey) {
  88. //генерируем новый ключ
  89. await this.generateNewServerStorageKey();
  90. } else {
  91. await this.serverStorageKeyChanged(true);
  92. }
  93. }
  94. }
  95. async serverStorageKeyChanged(force) {
  96. if (this.prevServerStorageKey != this.serverStorageKey) {
  97. this.prevServerStorageKey = this.serverStorageKey;
  98. this.hashedStorageKey = utils.toBase58(cryptoUtils.sha256(this.serverStorageKey));
  99. this.keyInited = true;
  100. await this.loadProfiles(force);
  101. this.checkCurrentProfile();
  102. await this.currentProfileChanged(force);
  103. await this.loadRecent(force);
  104. if (force)
  105. await this.saveRecent();
  106. }
  107. }
  108. async currentProfileChanged(force) {
  109. if (!this.currentProfile)
  110. return;
  111. await this.loadSettings(force);
  112. }
  113. get serverSyncEnabled() {
  114. return this.$store.state.reader.serverSyncEnabled;
  115. }
  116. get settings() {
  117. return this.$store.state.reader.settings;
  118. }
  119. get settingsRev() {
  120. return this.$store.state.reader.settingsRev;
  121. }
  122. get serverStorageKey() {
  123. return this.$store.state.reader.serverStorageKey;
  124. }
  125. get profiles() {
  126. return this.$store.state.reader.profiles;
  127. }
  128. get profilesRev() {
  129. return this.$store.state.reader.profilesRev;
  130. }
  131. get currentProfile() {
  132. return this.$store.state.reader.currentProfile;
  133. }
  134. get showServerStorageMessages() {
  135. return this.settings.showServerStorageMessages;
  136. }
  137. checkCurrentProfile() {
  138. if (!this.profiles[this.currentProfile]) {
  139. this.commit('reader/setCurrentProfile', '');
  140. }
  141. }
  142. success(message) {
  143. if (this.showServerStorageMessages)
  144. this.$notify.success({message});
  145. }
  146. warning(message) {
  147. if (this.showServerStorageMessages)
  148. this.$notify.warning({message});
  149. }
  150. error(message) {
  151. if (this.showServerStorageMessages)
  152. this.$notify.error({message});
  153. }
  154. async loadSettings(force = false, doNotifySuccess = true) {
  155. if (!this.keyInited || !this.serverSyncEnabled || !this.currentProfile)
  156. return;
  157. const setsId = `settings-${this.currentProfile}`;
  158. const oldRev = this.settingsRev[setsId] || 0;
  159. //проверим ревизию на сервере
  160. if (!force) {
  161. try {
  162. const revs = await this.storageCheck({[setsId]: {}});
  163. if (revs.state == 'success' && revs.items[setsId].rev == oldRev) {
  164. return;
  165. }
  166. } catch(e) {
  167. this.error(`Ошибка соединения с сервером: ${e.message}`);
  168. return;
  169. }
  170. }
  171. let sets = null;
  172. try {
  173. sets = await this.storageGet({[setsId]: {}});
  174. } catch(e) {
  175. this.error(`Ошибка соединения с сервером: ${e.message}`);
  176. return;
  177. }
  178. if (sets.state == 'success') {
  179. sets = sets.items[setsId];
  180. if (sets.rev == 0)
  181. sets.data = {};
  182. this.oldSettings = _.cloneDeep(sets.data);
  183. this.commit('reader/setSettings', sets.data);
  184. this.commit('reader/setSettingsRev', {[setsId]: sets.rev});
  185. if (doNotifySuccess)
  186. this.debouncedNotifySuccess();
  187. } else {
  188. this.warning(`Неверный ответ сервера: ${sets.state}`);
  189. }
  190. }
  191. async saveSettings() {
  192. if (!this.keyInited || !this.serverSyncEnabled || !this.currentProfile || this.savingSettings)
  193. return;
  194. const diff = utils.getObjDiff(this.oldSettings, this.settings);
  195. if (utils.isEmptyObjDiff(diff))
  196. return;
  197. this.savingSettings = true;
  198. try {
  199. const setsId = `settings-${this.currentProfile}`;
  200. let result = {state: ''};
  201. const oldRev = this.settingsRev[setsId] || 0;
  202. try {
  203. result = await this.storageSet({[setsId]: {rev: oldRev + 1, data: this.settings}});
  204. } catch(e) {
  205. this.error(`Ошибка соединения с сервером (${e.message}). Данные не сохранены и могут быть перезаписаны.`);
  206. }
  207. if (result.state == 'reject') {
  208. await this.loadSettings(true, false);
  209. this.warning(`Последние изменения отменены. Данные синхронизированы с сервером.`);
  210. } else if (result.state == 'success') {
  211. this.oldSettings = _.cloneDeep(this.settings);
  212. this.commit('reader/setSettingsRev', {[setsId]: this.settingsRev[setsId] + 1});
  213. }
  214. } finally {
  215. this.savingSettings = false;
  216. }
  217. }
  218. async loadProfiles(force = false, doNotifySuccess = true) {
  219. if (!this.keyInited || !this.serverSyncEnabled)
  220. return;
  221. const oldRev = this.profilesRev;
  222. //проверим ревизию на сервере
  223. if (!force) {
  224. try {
  225. const revs = await this.storageCheck({profiles: {}});
  226. if (revs.state == 'success' && revs.items.profiles.rev == oldRev) {
  227. return;
  228. }
  229. } catch(e) {
  230. this.error(`Ошибка соединения с сервером: ${e.message}`);
  231. return;
  232. }
  233. }
  234. let prof = null;
  235. try {
  236. prof = await this.storageGet({profiles: {}});
  237. } catch(e) {
  238. this.error(`Ошибка соединения с сервером: ${e.message}`);
  239. return;
  240. }
  241. if (prof.state == 'success') {
  242. prof = prof.items.profiles;
  243. if (prof.rev == 0)
  244. prof.data = {};
  245. this.oldProfiles = _.cloneDeep(prof.data);
  246. this.commit('reader/setProfiles', prof.data);
  247. this.commit('reader/setProfilesRev', prof.rev);
  248. this.checkCurrentProfile();
  249. if (doNotifySuccess)
  250. this.debouncedNotifySuccess();
  251. } else {
  252. this.warning(`Неверный ответ сервера: ${prof.state}`);
  253. }
  254. }
  255. async saveProfiles() {
  256. if (!this.keyInited || !this.serverSyncEnabled || this.savingProfiles)
  257. return;
  258. const diff = utils.getObjDiff(this.oldProfiles, this.profiles);
  259. if (utils.isEmptyObjDiff(diff))
  260. return;
  261. //обнуляются профили во время разработки при hotReload, подстраховка
  262. if (!this.$store.state.reader.allowProfilesSave) {
  263. console.error('Сохранение профилей не санкционировано');
  264. return;
  265. }
  266. this.savingProfiles = true;
  267. try {
  268. let result = {state: ''};
  269. try {
  270. result = await this.storageSet({profiles: {rev: this.profilesRev + 1, data: this.profiles}});
  271. } catch(e) {
  272. this.error(`Ошибка соединения с сервером (${e.message}). Данные не сохранены и могут быть перезаписаны.`);
  273. }
  274. if (result.state == 'reject') {
  275. await this.loadProfiles(true, false);
  276. this.warning(`Последние изменения отменены. Данные синхронизированы с сервером.`);
  277. } else if (result.state == 'success') {
  278. this.oldProfiles = _.cloneDeep(this.profiles);
  279. this.commit('reader/setProfilesRev', this.profilesRev + 1);
  280. }
  281. } finally {
  282. this.savingProfiles = false;
  283. }
  284. }
  285. async loadRecent(force = false, doNotifySuccess = true) {
  286. if (!this.keyInited || !this.serverSyncEnabled)
  287. return;
  288. const oldRecentRev = bookManager.recentRev;
  289. const oldRecentDiffRev = bookManager.recentDiffRev;
  290. //проверим ревизию на сервере
  291. let revs = null;
  292. if (!force) {
  293. try {
  294. revs = await this.storageCheck({recent: {}, recentDiff: {}});
  295. if (revs.state == 'success' && revs.items.recent.rev == oldRecentRev &&
  296. revs.items.recentDiff.rev == oldRecentDiffRev) {
  297. return;
  298. }
  299. } catch(e) {
  300. this.error(`Ошибка соединения с сервером: ${e.message}`);
  301. return;
  302. }
  303. }
  304. console.log('load');
  305. let recentDiff = null;
  306. if (force || revs.items.recentDiff.rev != oldRecentDiffRev) {
  307. try {
  308. recentDiff = await this.storageGet({recentDiff: {}});
  309. } catch(e) {
  310. this.error(`Ошибка соединения с сервером: ${e.message}`);
  311. return;
  312. }
  313. if (recentDiff.state == 'success') {
  314. recentDiff = recentDiff.items.recentDiff;
  315. if (recentDiff.rev == 0)
  316. recentDiff.data = {};
  317. this.oldRecentDiff = _.cloneDeep(recentDiff.data);
  318. await bookManager.setRecentDiffRev(recentDiff.rev);
  319. } else {
  320. this.warning(`Неверный ответ сервера: ${recentDiff.state}`);
  321. recentDiff = null;
  322. }
  323. }
  324. if (force || revs.items.recent.rev != oldRecentRev) {
  325. let recent = null;
  326. try {
  327. recent = await this.storageGet({recent: {}});
  328. } catch(e) {
  329. this.error(`Ошибка соединения с сервером: ${e.message}`);
  330. return;
  331. }
  332. if (recent.state == 'success') {
  333. recent = recent.items.recent;
  334. if (recent.rev == 0)
  335. recent.data = {};
  336. let newRecent = {};
  337. if (recentDiff && recentDiff.data) {
  338. newRecent = utils.applyObjDiff(recent.data, recentDiff.data);
  339. } else {
  340. newRecent = recent.data;
  341. }
  342. this.oldRecent = _.cloneDeep(newRecent);
  343. await bookManager.setRecent(newRecent);
  344. await bookManager.setRecentRev(recent.rev);
  345. } else {
  346. this.warning(`Неверный ответ сервера: ${recent.state}`);
  347. }
  348. }
  349. if (doNotifySuccess)
  350. this.debouncedNotifySuccess();
  351. }
  352. async saveRecent() {
  353. if (!this.keyInited || !this.serverSyncEnabled || this.savingRecent)
  354. return;
  355. const bm = bookManager;
  356. const diff = utils.getObjDiff(this.oldRecent, bm.recent);
  357. if (utils.isEmptyObjDiff(diff))
  358. return;
  359. console.log('save');
  360. this.savingRecent = true;
  361. try {
  362. let result = {state: ''};
  363. try {
  364. result = await this.storageSet({recent: {rev: bm.recentRev + 1, data: bm.recent}});
  365. } catch(e) {
  366. this.error(`Ошибка соединения с сервером (${e.message}). Данные не сохранены и могут быть перезаписаны.`);
  367. }
  368. if (result.state == 'reject') {
  369. await this.loadRecent(true, false);
  370. this.warning(`Последние изменения отменены. Данные синхронизированы с сервером.`);
  371. } else if (result.state == 'success') {
  372. this.oldRecent = _.cloneDeep(bm.recent);
  373. await bm.setRecentRev(bm.recentRev + 1);
  374. }
  375. } finally {
  376. this.savingRecent = false;
  377. }
  378. }
  379. async storageCheck(items) {
  380. return await this.storageApi('check', items);
  381. }
  382. async storageGet(items) {
  383. return await this.storageApi('get', items);
  384. }
  385. async storageSet(items, force) {
  386. return await this.storageApi('set', items, force);
  387. }
  388. async storageApi(action, items, force) {
  389. const request = {action, items};
  390. if (force)
  391. request.force = true;
  392. const encodedRequest = await this.encodeStorageItems(request);
  393. return await this.decodeStorageItems(await readerApi.storage(encodedRequest));
  394. }
  395. async encodeStorageItems(request) {
  396. if (!this.hashedStorageKey)
  397. throw new Error('hashedStorageKey is empty');
  398. if (!_.isObject(request.items))
  399. throw new Error('items is not an object');
  400. let result = Object.assign({}, request);
  401. let items = {};
  402. for (const id of Object.keys(request.items)) {
  403. const item = request.items[id];
  404. if (request.action == 'set' && !_.isObject(item.data))
  405. throw new Error('encodeStorageItems: data is not an object');
  406. let encoded = Object.assign({}, item);
  407. if (item.data) {
  408. const comp = utils.pako.deflate(JSON.stringify(item.data), {level: 1});
  409. let encrypted = null;
  410. try {
  411. encrypted = cryptoUtils.aesEncrypt(comp, this.serverStorageKey);
  412. } catch (e) {
  413. throw new Error('encrypt failed');
  414. }
  415. encoded.data = '1' + utils.toBase64(encrypted);
  416. }
  417. items[`${this.hashedStorageKey}.${utils.toBase58(id)}`] = encoded;
  418. }
  419. result.items = items;
  420. return result;
  421. }
  422. async decodeStorageItems(response) {
  423. if (!this.hashedStorageKey)
  424. throw new Error('hashedStorageKey is empty');
  425. let result = Object.assign({}, response);
  426. let items = {};
  427. if (response.items) {
  428. if (!_.isObject(response.items))
  429. throw new Error('items is not an object');
  430. for (const id of Object.keys(response.items)) {
  431. const item = response.items[id];
  432. let decoded = Object.assign({}, item);
  433. if (item.data) {
  434. if (!_.isString(item.data) || !item.data.length)
  435. throw new Error('decodeStorageItems: data is not a string');
  436. if (item.data[0] !== '1')
  437. throw new Error('decodeStorageItems: unknown data format');
  438. const a = utils.fromBase64(item.data.substr(1));
  439. let decrypted = null;
  440. try {
  441. decrypted = cryptoUtils.aesDecrypt(a, this.serverStorageKey);
  442. } catch (e) {
  443. throw new Error('decrypt failed');
  444. }
  445. decoded.data = JSON.parse(utils.pako.inflate(decrypted, {to: 'string'}));
  446. }
  447. const ids = id.split('.');
  448. if (!(ids.length == 2) || !(ids[0] == this.hashedStorageKey))
  449. throw new Error(`decodeStorageItems: bad id - ${id}`);
  450. items[utils.fromBase58(ids[1])] = decoded;
  451. }
  452. }
  453. result.items = items;
  454. return result;
  455. }
  456. }
  457. //-----------------------------------------------------------------------------
  458. </script>