Mirrors/notesnook
1
0
Fork 0
mirror of https://github.com/streetwriters/notesnook.git synced 2025-12-21 14:09:34 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat: handle emailConfirmed SSE

Browse Source
This commit is contained in:
thecodrr
2020-12-23 11:28:38 +05:00
parent d371122940
commit b87ba6259a
2 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
packages/core/api/index.js
View File

@@ -78,6 +78,7 @@ class Database {
await this.settings.init(); await this.settings.init();
await this.outbox.init(); await this.outbox.init();
await this.user.init();
await this.migrations.init(); await this.migrations.init();
await this.migrations.migrate(); await this.migrations.migrate();
@@ -107,6 +108,7 @@ class Database {
this.evtSource.onmessage = async (event) => { this.evtSource.onmessage = async (event) => {
try { try {
var { type, data } = JSON.parse(event.data); var { type, data } = JSON.parse(event.data);
console.log(type, data);
} catch (e) { } catch (e) {
console.log("SSE: Unsupported message. Message = ", event.data); console.log("SSE: Unsupported message. Message = ", event.data);
return; return;
@@ -127,6 +129,11 @@ class Database {
await this.user.logout(); await this.user.logout();
EV.publish("user:passwordChanged"); EV.publish("user:passwordChanged");
break; break;
case "emailConfirmed":
const token = await this.context.read("token");
await this.user.tokenManager._refreshToken(token);
EV.publish("user:emailConfirmed");
break;
case "sync": case "sync":
await this.syncer.eventMerge(data); await this.syncer.eventMerge(data);
EV.publish("db:refresh"); EV.publish("db:refresh");

1
packages/core/utils/http.js
View File

@@ -19,6 +19,7 @@ post.json = function (url, data, token) {
}; };
function transformer(data, json) { function transformer(data, json) {
if (!data) return;
if (json) return JSON.stringify(data); if (json) return JSON.stringify(data);
else { else {
return Object.entries(data) return Object.entries(data)