diff --git a/profile.html b/profile.html new file mode 100644 index 0000000..916bba3 --- /dev/null +++ b/profile.html @@ -0,0 +1,173 @@ + + + + FLO Tweeter + + + + + + + + + + + + + + +
+
+
+ + +
+
+ + +
+ + +
+
+
+
+ +
+
+
+
+
+ +
+
+
+ TWEETS + 1,545 +
+
+
+
+ FOLLOWING + 251 +
+
+
+
+ FOLLOWERS + 153 +
+
+
+
+
+ +
+
+
+
+
+ +
+
+
+ +
+ +
+
+
+

+ Who to follow + Refresh ● View all +

+
+
+
+
+ +
+
+

Nome e cognome

+ + + + + Follow + +
+
+
+
+ +
+
+

Nome e cognome

+ + + + + Follow + +
+
+
+
+ +
+
+

Nome e cognome

+ + + + + Follow + +
+
+
+
+ + + Find people you know + +
+
+
+ +
+
+
+
+ + + + + + \ No newline at end of file diff --git a/profile.js b/profile.js new file mode 100644 index 0000000..d4cf983 --- /dev/null +++ b/profile.js @@ -0,0 +1,210 @@ + +var profileWebsocket; +var profiles; + +function viewProfile(){ + if(sessionStorage.profiles) + profiles = JSON.parse(sessionStorage.profiles) + else{ + alert("Profiles not loaded! redirecting to home!"); + window.location.href = "home.html"; + } + console.log(profiles); + var url = new URL(window.location.href); + var floID = url.searchParams.get("floID"); + if(floID) + displayProfile(floID); + else + listProfiles(); +} + +function listProfiles(){ + console.log("listProfiles"); + var profileBody = document.getElementById("profileBody"); + profileBody.innerHTML = ""; + for (p in profiles){ + var element = document.createElement("div"); + element.setAttribute("class", "media"); + element.innerHTML = `
+

${profiles[p].name}

+ @${p} +
+
` + profileBody.appendChild(element); + } + document.getElementById("profileInfo").style.display = "none"; +} + +function displayProfile(floID){ + if(!validateAddr(floID)){ + alert("Invalid FLO ID"); + listProfiles(); + return; + } + if(!(floID in profiles)){ + alert("FLO ID not registered to FLO Tweet"); + listProfiles(); + return; + } + console.log("displayProfile"); + displayTweetFromIDB(floID).then(function(result){ + connectToX(floID).then(function(result){ + console.log(result); + getTweetsFromX(floID); + }).catch(function(error){ + console.log(error.message); + }); + }).catch(function(error){ + console.log(error.message); + }); +} + +function displayTweetFromIDB(floID){ + return new Promise( + function(resolve,reject){ + var idb = indexedDB.open("FLO_Tweet",2); + idb.onerror = function(event) { + reject("Error in opening IndexedDB!"); + }; + idb.onupgradeneeded = function(event) { + var objectStore = event.target.result.createObjectStore("tweets",{ keyPath: 'id' }); + objectStore.createIndex('floID', 'floID', { unique: false }); + objectStore.createIndex('time', 'time', { unique: false }); + objectStore.createIndex('data', 'data', { unique: false }); + var objectStore2 = event.target.result.createObjectStore("lastTweet"); + }; + idb.onsuccess = function(event) { + var db = event.target.result; + var obs = db.transaction("tweets", "readwrite").objectStore("tweets"); + obs.openCursor().onsuccess = function(event) { + var cursor = event.target.result; + if(cursor) { + console.log(cursor.value) + if(cursor.value.floID == floID) + createTweetElement(floID,cursor.value.time,cursor.value.data); + cursor.continue(); + }else{ + resolve("Displayed Tweets from IDB!"); + } + } + db.close(); + }; + } + ); +} + +function createTweetElement(floID,time,tweet){ + var tweetDisplay = document.getElementById("profileBody"); + var element = document.createElement("div"); + element.setAttribute("class", "media"); + element.innerHTML = ` +
+

${profiles[floID].name} @${floID}

+

${tweet}

+ +
`; + tweetDisplay.insertBefore(element, tweetDisplay.firstChild); +} + +function connectToX(floID){ + return new Promise( + function(resolve,reject){ + profileWebsocket = new WebSocket("ws://"+profiles[floID].onionAddr+"/ws"); + profileWebsocket.onopen = function(ev){ + resolve("Connected to Profile Server!"); + }; + profileWebsocket.onerror = function(ev) { + reject("Profile Server is offline!"); + }; + profileWebsocket.onclose = function(ev) { + console.log("Disconnected from Profile Server!") + }; + profileWebsocket.onmessage = function(evt){ + console.log(evt.data); + try{ + var data = JSON.parse(evt.data); + var id = data.id; + data = data.data; + if( floID!=data.floID || !encrypt.verify(data.tweet,data.sign,profiles[floID].pubKey)) + return + storeTweet({floID:floID,time:data.time,data:data.tweet},id); + createTweetElement(floID,data.time,data.tweet); + }catch(error){ + console.log(error.message); + } + } + } + ); +} + +function storeTweet(data,id){ + var idb = indexedDB.open("FLO_Tweet",2); + idb.onerror = function(event) { + console.log("Error in opening IndexedDB!"); + }; + idb.onupgradeneeded = function(event) { + var objectStore = event.target.result.createObjectStore("tweets",{ keyPath: 'id' }); + objectStore.createIndex('floID', 'floID', { unique: false }); + objectStore.createIndex('time', 'time', { unique: false }); + objectStore.createIndex('data', 'data', { unique: false }); + var objectStore2 = event.target.result.createObjectStore("lastTweet"); + }; + idb.onsuccess = function(event) { + var db = event.target.result; + var obs = db.transaction("tweets", "readwrite").objectStore("tweets"); + data.id = `${data.time}_${data.floID}`; + obs.add(data); + var obsL = db.transaction("lastTweet", "readwrite").objectStore("lastTweet"); + obsL.put(id,data.floID); + db.close(); + }; +} + +function getTweetsFromX(floID){ + return new Promise( + function (resolve,reject){ + var idb = indexedDB.open("FLO_Tweet",2); + idb.onerror = function(event) { + reject("Error in opening IndexedDB!"); + }; + idb.onupgradeneeded = function(event) { + var objectStore = event.target.result.createObjectStore("tweets",{ keyPath: 'id' }); + objectStore.createIndex('floID', 'floID', { unique: false }); + objectStore.createIndex('time', 'time', { unique: false }); + objectStore.createIndex('data', 'data', { unique: false }); + var objectStore2 = event.target.result.createObjectStore("lastTweet"); + }; + idb.onsuccess = function(event) { + var db = event.target.result; + //window["wait"] = addrList.length; + var lastTweet = db.transaction('lastTweet', "readwrite").objectStore('lastTweet'); + //addrList.forEach(function(addr){ + new Promise( + function(res,rej){ + var lastTweetReq = lastTweet.get(floID); + lastTweetReq.onsuccess = function(event){ + var result = event.target.result; + if(result === undefined){ + result = 0; + } + res(result); + } + }).then(function(result){ + console.log(profileWebsocket); + profileWebsocket.send(`>${result}`); + console.log("sent"); + resolve('Sent New tweet request to user server!'); + }).catch(function(error){ + console.log(error.message); + }); + db.close(); + }; + } + ); +}