+
`
+ profileList.appendChild(element);
+ }
+ //document.getElementById("profileInfo").style.display = "none";
+}
+
function postTweet(){
var tweetBox = document.getElementById("tweetBox");
var tweet = tweetBox.value;
@@ -403,6 +430,20 @@ function storeTweet(data,tid){
};
}
+function storeMsg(data){
+ var idb = indexedDB.open("FLO_Tweet");
+ idb.onerror = function(event) {
+ console.log("Error in opening IndexedDB!");
+ };
+ idb.onsuccess = function(event) {
+ var db = event.target.result;
+ var obs = db.transaction("messages", "readwrite").objectStore("messages");
+ data.msgID = `${data.time}_${data.floID}`;
+ obs.add(data);
+ db.close();
+ };
+}
+
function sendTweetToSuperNode(data,tid){
kBucketObj.determineClosestSupernode(selfID).then(result=>{
var superNodeWS = new WebSocket("ws://"+profiles[result[0].floID].onionAddr+"/ws");
@@ -480,7 +521,7 @@ function createTweetElement(floID,time,tweet){
element.innerHTML = `
${profiles[p].name}
+ @${p} +${profiles[floID].name} @${floID}
-${tweet}
+${tweet.replace(/\n/g, "
")}
+
`
+ profileList.appendChild(element);
+ }
+}
+
+function initselfWebSocket(){
+ selfWebsocket = new WebSocket("ws://"+location.host+"/ws");
+ selfWebsocket.onopen = function(evt){
+ console.log("Connecting");
+ var serverPass = encrypt.retrieveShamirSecret(JSON.parse(sessionStorage.serverPass));
+ selfWebsocket.send("$"+serverPass);
+ };
+ selfWebsocket.onclose = function(evt){
+ console.log("DISCONNECTED");
+ };
+ selfWebsocket.onmessage = function(evt){
+ console.log(evt.data);
+ if(evt.data[0] == '$')
+ return;
+ try{
+ data = JSON.parse(evt.data);
+ if(data.follow && encrypt.verify(selfID, data.sign, profiles[data.floID].pubKey)){
+ var idb = indexedDB.open("FLO_Tweet");
+ idb.onsuccess = function(event) {
+ var db = event.target.result;
+ var obs = db.transaction("followers", "readwrite").objectStore("followers");
+ obs.add(data.sign,data.floID);
+ db.close();
+ };
+ selfWebsocket.send(`F${data.floID}-${data.sign}`);
+ }else if(data.unfollow && encrypt.verify(selfID, data.sign, profiles[data.floID].pubKey)){
+ var idb = indexedDB.open("FLO_Tweet");
+ idb.onsuccess = function(event) {
+ var db = event.target.result;
+ var obs = db.transaction("followers", "readwrite").objectStore("followers");
+ obs.delete(data.floID);
+ db.close();
+ };
+ selfWebsocket.send(`U${data.floID}`);
+ }else if(data.message && data.to == selfID){
+ var msg = encrypt.decryptMessage(data.secret,data.pubVal)
+ if(encrypt.verify(msg,data.sign,profiles[data.from].pubKey)){
+ createMsgElement(data.from,data.time,msg,'R')
+ storeMsg({time:data.time,floID:data.from,text:msg,type:'R'});
+ }
+ }
+ }catch(error){
+ console.log(error.message)
+ }
+ };
+ selfWebsocket.onerror = function(evt){
+ console.log(evt);
+ };
+}
+
+function readMsgfromIDB(){
+ return new Promise(
+ function(resolve,reject){
+ var disp = document.getElementById("msgsContainer");
+ for(floID in profiles){
+ var element = document.createElement('div');
+ element.setAttribute("id", floID);
+ element.style.display = 'none';
+ disp.appendChild(element);
+ }
+ var idb = indexedDB.open("FLO_Tweet");
+ idb.onerror = function(event) {
+ reject("Error in opening IndexedDB!");
+ };
+ idb.onsuccess = function(event) {
+ var db = event.target.result;
+ var obs = db.transaction("messages", "readwrite").objectStore("messages");
+ obs.openCursor().onsuccess = function(event) {
+ var cursor = event.target.result;
+ if(cursor) {
+ createMsgElement(cursor.value.floID,cursor.value.time,cursor.value.text,cursor.value.type);
+ cursor.continue();
+ } else {
+ console.log('Entries all displayed.');
+ resolve("Read Msg from IDB");
+ }
+ };
+ db.close();
+ };
+ }
+ );
+}
+
+function changeReceiver(floID){
+ try{
+ if(receiverID !== undefined)
+ document.getElementById(receiverID).style.display = 'none';
+ if(receiverWebSocket !== undefined && receiverWebSocket.readyState === WebSocket.OPEN)
+ receiverWebSocket.close();
+ }catch(e){
+ console.log(e);
+ }
+ console.log(floID);
+ receiverID = floID;
+ document.getElementById('recipient_floID').innerHTML = `${profiles[receiverID].name}${profiles[p].name}
+ @${p} +@${receiverID}`; + recStat = false; + document.getElementById(receiverID).style.display = 'block'; + try{ + receiverWebSocket = new WebSocket("ws://"+profiles[receiverID].onionAddr+"/ws"); + receiverWebSocket.onopen = function(ev){ recStat = true; }; + receiverWebSocket.onerror = function(ev) { recStat = false;}; + receiverWebSocket.onclose = function(ev) { recStat = false; }; + }catch(e){ + console.log(e); + } +} + +function sendMsg(){ + if(receiverID === undefined){ + alert("Select a contact and send message"); + return; + } + var inp = document.getElementById('sendMsgInput') + var msg = inp.value + inp.value = "" + console.log(msg) + var time = Date.now() + var sign = encrypt.sign(msg,privKey) + var msgEncrypt = encrypt.encryptMessage(msg,profiles[receiverID].pubKey) + var data = JSON.stringify({message:true,from:selfID,to:receiverID,time:time,secret:msgEncrypt.secret,sign:sign,pubVal:msgEncrypt.senderPublicKeyString}); + + if(recStat) + receiverWebSocket.send(data); + else{ + var SNdata = JSON.stringify({viaSuperNodeMsg:true,from:selfID,to:receiverID,data:data}) + sendDataToSuperNode(receiverID,SNdata) + } + console.log(`sentMsg : ${data}`); + createMsgElement(receiverID,time,msg,'S') + storeMsg({time:time,floID:receiverID,text:msg,type:'S'}); +} + +function createMsgElement(floID,time,msg,type){ + var msgField = document.getElementById(floID); + var element = document.createElement("div"); + element.setAttribute("class", "media"); + element.innerHTML = ` +
+
`;
+ msgField.appendChild(element);
+}
+
+function storeMsg(data){
+ var idb = indexedDB.open("FLO_Tweet");
+ idb.onerror = function(event) {
+ console.log("Error in opening IndexedDB!");
+ };
+ idb.onsuccess = function(event) {
+ var db = event.target.result;
+ var obs = db.transaction("messages", "readwrite").objectStore("messages");
+ data.msgID = `${data.time}_${data.floID}`;
+ obs.add(data);
+ db.close();
+ };
+}
\ No newline at end of file
diff --git a/app/web/profile.html b/app/web/profile.html
index 6b723f5..4fd9dd7 100644
--- a/app/web/profile.html
+++ b/app/web/profile.html
@@ -27,7 +27,7 @@
Profiles
+
+ ${getTime(time)} +
+ + ${getTime(time)} +
-
- 
+
diff --git a/app/web/profile.js b/app/web/profile.js
index 5f8b4a1..f32c19f 100644
--- a/app/web/profile.js
+++ b/app/web/profile.js
@@ -98,6 +98,22 @@ function displayTweetFromIDB(floID){
);
}
+function listProfiles(){
+ console.log("listProfiles");
+ var profileList = document.getElementById("profileList");
+ profileList.innerHTML = "";
+ for (p in profiles){
+ var element = document.createElement("div");
+ element.setAttribute("class", "media");
+ element.innerHTML = `
diff --git a/app/web/profile.js b/app/web/profile.js
index 5f8b4a1..f32c19f 100644
--- a/app/web/profile.js
+++ b/app/web/profile.js
@@ -98,6 +98,22 @@ function displayTweetFromIDB(floID){
);
}
+function listProfiles(){
+ console.log("listProfiles");
+ var profileList = document.getElementById("profileList");
+ profileList.innerHTML = "";
+ for (p in profiles){
+ var element = document.createElement("div");
+ element.setAttribute("class", "media");
+ element.innerHTML = `
+ ${profiles[p].name}
+ @${p}
+ `
+ profileList.appendChild(element);
+ }
+ //document.getElementById("profileInfo").style.display = "none";
+}
+
function createTweetElement(floID,time,tweet){
var tweetDisplay = document.getElementById("profileBody");
var element = document.createElement("div");
@@ -105,7 +121,7 @@ function createTweetElement(floID,time,tweet){
element.innerHTML = `
${profiles[floID].name} @${floID}
- ${tweet}
+ ${tweet}
${profiles[p].name}
+ @${p} +${profiles[floID].name} @${floID}
-${tweet}
+ ${tweet}