diff --git a/home.html b/home.html new file mode 100644 index 0000000..6d63931 --- /dev/null +++ b/home.html @@ -0,0 +1,186 @@ + + + + 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/home.js b/home.js new file mode 100644 index 0000000..fc90f38 --- /dev/null +++ b/home.js @@ -0,0 +1,451 @@ +var profiles = [] +var receiverID,tweeterID,recStat; +var selfwebsocket,receiverWebSocket; +var privKey; + +function userDataStartUp(){ + console.log("StartUp"); + + /*document.getElementById("sendMsgInput").addEventListener("keyup",function(event){ + if(event.keyCode === 13){ + event.preventDefault(); + sendMsg(); + } + });*/ + + getDatafromAPI().then(function (result) { + console.log(result); + getDatafromIDB().then(function (result){ + profiles = arrayToObject(result); + console.log(profiles); + sessionStorage.profiles = JSON.stringify(profiles); + getuserID().then(function(result){ + console.log(result); + tweeterID = result; + sessionStorage.privKey = privKey; + alert(`${tweeterID}\nWelcome ${profiles[tweeterID].name}`) + //readMsgfromIDB().then(function(result){ + //console.log(result); + initselfWebSocket(); + //displayprofiles(); + //const createClock = setInterval(checkStatusInterval, 30000); + //}).catch(function(error){ + //console.log(error.message); + //}); + }).catch(function (error) { + console.log(error.message); + }); + }).catch(function (error) { + console.log(error.message); + }); + }).catch(function (error) { + console.log(error.message); + }); + +} + +function storedata(data){ + return new Promise( + function(resolve, reject) { + 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('profiles', "readwrite").objectStore('profiles'); + objectRequest = obs.put(data); + objectRequest.onerror = function(event) { + reject(Error('Error occured: Unable to store data')); + }; + + objectRequest.onsuccess = function(event) { + resolve('Data saved OK'); + db.close(); + }; + }; + } + ); +} + +function getDatafromAPI(){ + return new Promise( + function(resolve, reject) { + var addr = "F6LUnwRRjFuEW97Y4av31eLqqVMK9FrgE2"; + var idb = indexedDB.open("FLO_Tweet"); + idb.onerror = function(event) { + reject("Error in opening IndexedDB!"); + }; + idb.onupgradeneeded = function(event) { + var objectStore = event.target.result.createObjectStore("profiles",{ keyPath: 'floID' }); + objectStore.createIndex('onionAddr', 'onionAddr', { unique: false }); + objectStore.createIndex('name', 'name', { unique: false }); + objectStore.createIndex('pubKey', 'pubKey', { unique: false }); + var objectStore2 = event.target.result.createObjectStore("lastTx"); + }; + idb.onsuccess = function(event) { + var db = event.target.result; + //window["wait"] = addrList.length; + var lastTx = db.transaction('lastTx', "readwrite").objectStore('lastTx'); + //addrList.forEach(function(addr){ + console.log(addr); + new Promise(function(res,rej){ + var lastTxReq = lastTx.get(addr); + lastTxReq.onsuccess = function(event){ + var lasttx = event.target.result; + if(lasttx === undefined){ + lasttx = 0; + } + res(lasttx); + } + }).then(function(lasttx){ + var response = ajax("GET",`api/addrs/${addr}/txs`); + var nRequired = JSON.parse(response).totalItems - lasttx; + console.log(nRequired); + while(true && nRequired){ + var response = ajax("GET",`api/addrs/${addr}/txs?from=0&to=${nRequired}`); + response = JSON.parse(response); + if (nRequired + lasttx != response.totalItems ){ + nRequired = response.totalItems - lasttx; + continue; + } + response.items.reverse().forEach(function(tx){ + try { + //if (tx.vin[0].addr != addr) + //return; + var data = JSON.parse(tx.floData).FLO_Tweet; + if(data !== undefined){ + if(encrypt.getFLOIDfromPubkeyHex(data.pubKey)!=tx.vin[0].addr) + throw("PublicKey doesnot match with floID") + data = {floID : tx.vin[0].addr, onionAddr : data.onionAddr, name : data.name, pubKey:data.pubKey}; + storedata(data).then(function (response) { + }).catch(function (error) { + console.log(error.message); + }); + } + } catch (e) { + //console.log(e) + } + }); + + var obs = db.transaction('lastTx', "readwrite").objectStore('lastTx'); + obs.put(response.totalItems,addr); + break; + } + db.close(); + resolve('retrived data from API'); + }); + }; + } + ); +} + + +function getuserID(){ + return new Promise( + function(resolve,reject){ + privKey = sessionStorage.privKey || prompt("Enter FLO Private Key : "); + var key = new Bitcoin.ECKey(privKey); + while(key.priv == null){ + privKey = prompt("Invalid FLO Private Key! Retry : ") + key = Bitcoin.ECKey(privKey); + } + key.setCompressed(true); + var userID = key.getBitcoinAddress(); + if (profiles[userID] === undefined) + var reg = confirm(`${userID} is not registers to FLO Tweet!\nRegister FLO ID to this onion?`); + else if (profiles[userID].onionAddr == window.location.host) + resolve(userID) + else + var reg = confirm(`${userID} is registered to another onion!\nChange to this onion?`); + + if(reg){ + var name = prompt("Enter your name :"); + var pubKey = key.getPubKeyHex(); + if(registerID(userID,window.location.host,privKey,pubKey,name)){ + profiles[userID] = {onionAddr : window.location.host, name : name, pubKey : pubKey}; + resolve(userID); + } + } + reject(`Unable to bind ${userID} to this onionAddress!\nTry again later!`); + } + ); +} + +function getDatafromIDB(){ + return new Promise( + function(resolve,reject){ + 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("profiles", "readwrite").objectStore("profiles"); + var getReq = obs.getAll(); + getReq.onsuccess = function(event){ + resolve(event.target.result); + } + getReq.onerror = function(event){ + reject('Unable to read profiles!') + } + db.close(); + }; + } + ); +} + +function readMsgfromIDB(){ + return new Promise( + function(resolve,reject){ + var disp = document.getElementById("conversation"); + for(floID in profiles){ + var createLi = document.createElement('div'); + createLi.setAttribute("id", floID); + createLi.setAttribute("class", "message-inner"); + createLi.style.display = 'none'; + disp.appendChild(createLi); + } + 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("messages",{ keyPath: 'time' }); + objectStore.createIndex('text', 'text', { unique: false }); + objectStore.createIndex('floID', 'floID', { unique: false }); + objectStore.createIndex('type', 'type', { unique: false }); + }; + 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) { + var chat = document.getElementById(cursor.value.floID); + if(cursor.value.type == "R"){ + var msgdiv = document.createElement('div'); + msgdiv.setAttribute("class", "row message-body"); + msgdiv.innerHTML = `
+
+ + ${cursor.value.text} + + + ${getTime(cursor.value.time)} + +
+
`; + chat.appendChild(msgdiv); + }else if(cursor.value.type == "S"){ + var msgdiv = document.createElement('div'); + msgdiv.setAttribute("class", "row message-body"); + msgdiv.innerHTML = `
+
+ ${cursor.value.text} + + + ${getTime(cursor.value.time)} + +
+
`; + chat.appendChild(msgdiv); + } + + cursor.continue(); + } else { + console.log('Entries all displayed.'); + resolve("Read Msg from IDB"); + } + }; + db.close(); + }; + } + ); +} + +function storeMsg(data){ + 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("messages",{ keyPath: 'time' }); + objectStore.createIndex('text', 'text', { unique: false }); + objectStore.createIndex('floID', 'floID', { unique: false }); + objectStore.createIndex('type', 'type', { unique: false }); + }; + idb.onsuccess = function(event) { + var db = event.target.result; + var obs = db.transaction("messages", "readwrite").objectStore("messages"); + obs.add(data); + db.close(); + }; +} + +function displayProfiles(){ + console.log('displayProfiles'); + var listElement = document.getElementById('contact-display'); + for(floID in profiles){ + var createLi = document.createElement('div'); + createLi.setAttribute("name", floID); + createLi.setAttribute("onClick", 'changeReceiver(this)'); + createLi.setAttribute("class", "row sideBar-body"); + createLi.innerHTML = `
+
+
+ ${floID} + +
+
+ ${profiles[floID].name} + +
+
+
` + listElement.appendChild(createLi); + } +} + +function initselfWebSocket(){ + selfwebsocket = new WebSocket("ws://"+location.host+"/ws"); + selfwebsocket.onopen = function(evt){ + console.log("Connecting"); + var pass = sessionStorage.serverPass || prompt("Enter server password :"); + selfwebsocket.send("$"+pass); + sessionStorage.serverPass = pass; + }; + selfwebsocket.onclose = function(evt){ + console.log("DISCONNECTED"); + }; + selfwebsocket.onmessage = function(evt){ + console.log(evt.data); + if(evt.data == "$Access Denied!"){ + var pass = prompt("Access Denied! reEnter server password :"); + selfwebsocket.send("$"+pass); + sessionStorage.serverPass = pass; + }else if(evt.data == "$Access Granted!") + alert("Access Granted!") + }; + selfwebsocket.onerror = function(evt){ + console.log(evt); + }; +} + + +function checkStatusInterval(){ + try{ + if(receiverWebSocket !== undefined && receiverWebSocket.readyState !== WebSocket.OPEN){ + receiverWebSocket.close() + receiverWebSocket = new WebSocket("ws://"+profiles[receiverID].onionAddr+"/ws"); + receiverWebSocket.onopen = function(evt){ receiverWebSocket.send('#') }; + receiverWebSocket.onerror = function(ev) { receiverStatus(false); }; + receiverWebSocket.onclose = function(ev) { receiverStatus(false); }; + receiverWebSocket.onmessage = function(evt){ + console.log(evt.data); + if(evt.data[0]=='#'){ + if (evt.data[1]=='+') + receiverStatus(true); + else if(evt.data[1]=='-') + receiverStatus(false); + } + } + } + }catch(e){ + console.log(e); + } +} + +function postTweet(){ + var tweetBox = document.getElementById("tweetBox"); + var tweet = tweetBox.value; + tweetBox.value = ""; + var time = (new Date).getTime(); + var sign = encrypt.sign(tweet,privKey); + var data = JSON.stringify({floID:tweeterID,time:time,tweet:tweet,sign:sign}); + console.log(data); + selfwebsocket.send(data); +} + + + + + + + + + + +function changeReceiver(param){ + if(receiverID !== undefined) + document.getElementById(receiverID).style.display = 'none'; + console.log(param.getAttribute("name")); + receiverID = param.getAttribute("name"); + document.getElementById('recipient-floID').innerHTML = receiverID; + receiverStatus(false) + document.getElementById(receiverID).style.display = 'block'; + try{ + if(receiverWebSocket !== undefined && receiverWebSocket.readyState === WebSocket.OPEN) + receiverWebSocket.close() + receiverWebSocket = new WebSocket("ws://"+profiles[receiverID].onionAddr+"/ws"); + receiverWebSocket.onopen = function(ev){ receiverWebSocket.send('#'); }; + receiverWebSocket.onerror = function(ev) { receiverStatus(false); }; + receiverWebSocket.onclose = function(ev) { receiverStatus(false); }; + receiverWebSocket.onmessage = function(evt){ + console.log(evt.data); + if(evt.data[0]=='#'){ + if (evt.data[1]=='+') + receiverStatus(true); + else if(evt.data[1]=='-') + receiverStatus(false); + } + } + }catch(e){ + console.log(e); + } +} + +function receiverStatus(status){ + if(status) + document.getElementById('recipient-status').style.color = "#4CC94C"; + else + document.getElementById('recipient-status').style.color = "#CD5C5C"; + recStat = status; +} + + + +function sendMsg(){ + if(receiverID === undefined){ + alert("Select a contact and send message"); + return; + } + if(!recStat){ + alert("Recipient is offline! Try again later") + return + } + var inp = document.getElementById('sendMsgInput') + var msg = inp.value; + inp.value = ""; + console.log(msg); + var sign = encrypt.sign(msg,privKey) + var msgEncrypt = encrypt.encryptMessage(msg,contacts[receiverID].pubKey) + var data = JSON.stringify({from:senderID,secret:msgEncrypt.secret,sign:sign,pubVal:msgEncrypt.senderPublicKeyString}); + receiverWebSocket.send(data); + console.log(`sentMsg : ${data}`); + time = Date.now(); + var disp = document.getElementById(receiverID); + var msgdiv = document.createElement('div'); + msgdiv.setAttribute("class", "row message-body"); + msgdiv.innerHTML = `
+
+ ${msg} + + + ${getTime(time)} + +
+
`; + disp.appendChild(msgdiv); + storeMsg({time:time,floID:receiverID,text:msg,type:"S"}); +} \ No newline at end of file