|
|
|
|
@@ -461,10 +461,10 @@ function updateRecord(store, data) {
|
|
|
|
|
|
|
|
|
|
async function fetchAllAccounts() {
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
|
let openRequest = indexedDB.open("TimeSafariAccounts");
|
|
|
|
|
const openRequest = indexedDB.open("TimeSafariAccounts");
|
|
|
|
|
|
|
|
|
|
openRequest.onupgradeneeded = function (event) {
|
|
|
|
|
let db = event.target.result;
|
|
|
|
|
const db = event.target.result;
|
|
|
|
|
if (!db.objectStoreNames.contains("accounts")) {
|
|
|
|
|
db.createObjectStore("accounts", { keyPath: "id" });
|
|
|
|
|
}
|
|
|
|
|
@@ -474,10 +474,10 @@ async function fetchAllAccounts() {
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
openRequest.onsuccess = function (event) {
|
|
|
|
|
let db = event.target.result;
|
|
|
|
|
let transaction = db.transaction("accounts", "readonly");
|
|
|
|
|
let objectStore = transaction.objectStore("accounts");
|
|
|
|
|
let getAllRequest = objectStore.getAll();
|
|
|
|
|
const db = event.target.result;
|
|
|
|
|
const transaction = db.transaction("accounts", "readonly");
|
|
|
|
|
const objectStore = transaction.objectStore("accounts");
|
|
|
|
|
const getAllRequest = objectStore.getAll();
|
|
|
|
|
|
|
|
|
|
getAllRequest.onsuccess = function () {
|
|
|
|
|
resolve(getAllRequest.result);
|
|
|
|
|
@@ -494,76 +494,78 @@ async function fetchAllAccounts() {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async function getNotificationCount() {
|
|
|
|
|
let secret = null;
|
|
|
|
|
let accounts = [];
|
|
|
|
|
let result = null;
|
|
|
|
|
if ("secret" in self) {
|
|
|
|
|
secret = self.secret;
|
|
|
|
|
const secretUint8Array = self.decodeBase64(secret);
|
|
|
|
|
// 1 is our master settings ID; see MASTER_SETTINGS_KEY
|
|
|
|
|
const settings = await getSettingById(1);
|
|
|
|
|
let lastNotifiedClaimId = null;
|
|
|
|
|
if ("lastNotifiedClaimId" in settings) {
|
|
|
|
|
lastNotifiedClaimId = settings["lastNotifiedClaimId"];
|
|
|
|
|
}
|
|
|
|
|
const activeDid = settings["activeDid"];
|
|
|
|
|
accounts = await fetchAllAccounts();
|
|
|
|
|
let did = null;
|
|
|
|
|
for (var i = 0; i < accounts.length; i++) {
|
|
|
|
|
let account = accounts[i];
|
|
|
|
|
let did = account["did"];
|
|
|
|
|
if (did == activeDid) {
|
|
|
|
|
let publicKeyHex = account["publicKeyHex"];
|
|
|
|
|
let identity = account["identity"];
|
|
|
|
|
const messageWithNonceAsUint8Array = self.decodeBase64(identity);
|
|
|
|
|
const nonce = messageWithNonceAsUint8Array.slice(0, 24);
|
|
|
|
|
const message = messageWithNonceAsUint8Array.slice(24, identity.length);
|
|
|
|
|
const decoder = new TextDecoder("utf-8");
|
|
|
|
|
const decrypted = self.secretbox.open(message, nonce, secretUint8Array);
|
|
|
|
|
|
|
|
|
|
const msg = decoder.decode(decrypted);
|
|
|
|
|
const identifier = JSON.parse(JSON.parse(msg));
|
|
|
|
|
|
|
|
|
|
const headers = {
|
|
|
|
|
"Content-Type": "application/json",
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
headers["Authorization"] = "Bearer " + (await accessToken(identifier));
|
|
|
|
|
|
|
|
|
|
let response = await fetch(
|
|
|
|
|
settings["apiServer"] + "/api/v2/report/claims",
|
|
|
|
|
{
|
|
|
|
|
method: "GET",
|
|
|
|
|
headers: headers,
|
|
|
|
|
},
|
|
|
|
|
);
|
|
|
|
|
if (response.status == 200) {
|
|
|
|
|
let json = await response.json();
|
|
|
|
|
let claims = json["data"];
|
|
|
|
|
let newClaims = 0;
|
|
|
|
|
for (var i = 0; i < claims.length; i++) {
|
|
|
|
|
let claim = claims[i];
|
|
|
|
|
if (claim["id"] === lastNotifiedClaimId) {
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
newClaims++;
|
|
|
|
|
}
|
|
|
|
|
if (newClaims > 0) {
|
|
|
|
|
result = `There are ${newClaims} new activities on TimeSafari`;
|
|
|
|
|
}
|
|
|
|
|
const most_recent_notified = claims[0]["id"];
|
|
|
|
|
await setMostRecentNotified(most_recent_notified);
|
|
|
|
|
} else {
|
|
|
|
|
console.error(
|
|
|
|
|
"safari-notifications getNotificationsCount got a bad response status when fetching claims",
|
|
|
|
|
response.status,
|
|
|
|
|
response,
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
// 1 is our master settings ID; see MASTER_SETTINGS_KEY
|
|
|
|
|
const settings = await getSettingById(1);
|
|
|
|
|
let lastNotifiedClaimId = null;
|
|
|
|
|
if ("lastNotifiedClaimId" in settings) {
|
|
|
|
|
lastNotifiedClaimId = settings["lastNotifiedClaimId"];
|
|
|
|
|
}
|
|
|
|
|
const activeDid = settings["activeDid"];
|
|
|
|
|
console.log("safari-not getNotificationsCount last", lastNotifiedClaimId);
|
|
|
|
|
accounts = await fetchAllAccounts();
|
|
|
|
|
let activeAccount = null;
|
|
|
|
|
for (let i = 0; i < accounts.length; i++) {
|
|
|
|
|
if (accounts[i]["did"] == activeDid) {
|
|
|
|
|
activeAccount = accounts[i];
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
const headers = {
|
|
|
|
|
"Content-Type": "application/json",
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
const identity = activeAccount && activeAccount["identity"];
|
|
|
|
|
if (identity && "secret" in self) {
|
|
|
|
|
const secret = self.secret;
|
|
|
|
|
const secretUint8Array = self.decodeBase64(secret);
|
|
|
|
|
const messageWithNonceAsUint8Array = self.decodeBase64(identity);
|
|
|
|
|
const nonce = messageWithNonceAsUint8Array.slice(0, 24);
|
|
|
|
|
const message = messageWithNonceAsUint8Array.slice(24, identity.length);
|
|
|
|
|
const decoder = new TextDecoder("utf-8");
|
|
|
|
|
const decrypted = self.secretbox.open(message, nonce, secretUint8Array);
|
|
|
|
|
const msg = decoder.decode(decrypted);
|
|
|
|
|
const identifier = JSON.parse(JSON.parse(msg));
|
|
|
|
|
|
|
|
|
|
headers["Authorization"] = "Bearer " + (await accessToken(identifier));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
console.log("safari-not getNotificationsCount fetch", headers);
|
|
|
|
|
const response = await fetch(
|
|
|
|
|
settings["apiServer"] + "/api/v2/report/claims",
|
|
|
|
|
{
|
|
|
|
|
method: "GET",
|
|
|
|
|
headers: headers,
|
|
|
|
|
},
|
|
|
|
|
);
|
|
|
|
|
console.log("safari-not getNotificationsCount json", response);
|
|
|
|
|
if (response.status == 200) {
|
|
|
|
|
const json = await response.json();
|
|
|
|
|
console.log("safari-not getNotificationsCount json", json);
|
|
|
|
|
const claims = json["data"];
|
|
|
|
|
let newClaims = 0;
|
|
|
|
|
for (let i = 0; i < claims.length; i++) {
|
|
|
|
|
const claim = claims[i];
|
|
|
|
|
if (claim["id"] === lastNotifiedClaimId) {
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
newClaims++;
|
|
|
|
|
}
|
|
|
|
|
if (newClaims > 0) {
|
|
|
|
|
result = `There are ${newClaims} new activities on Time Safari`;
|
|
|
|
|
}
|
|
|
|
|
const most_recent_notified = claims[0]["id"];
|
|
|
|
|
await setMostRecentNotified(most_recent_notified);
|
|
|
|
|
} else {
|
|
|
|
|
console.error(
|
|
|
|
|
"safari-notifications getNotificationsCount got a bad response status when fetching claims",
|
|
|
|
|
response.status,
|
|
|
|
|
response,
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return result;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|