Compare commits

...

3 Commits

3 changed files with 7 additions and 7 deletions

View File

@ -237,7 +237,7 @@ document.getElementById("file_cancel").onclick = function() {
let msgLog = document.getElementById("msg_log"); let msgLog = document.getElementById("msg_log");
msgLog.onscroll = function() { msgLog.onscroll = function() {
let session = sessionsData.get(currentSessionId); let session = sessionsData.get(currentSessionId);
if (typeof sessions !== "undefined") { if (typeof session !== "undefined") {
if (session.isContact) { if (session.isContact) {
if (msgLog.scrollTop < 30) { if (msgLog.scrollTop < 30) {
socket.send("load_msgs "+currentSessionId); socket.send("load_msgs "+currentSessionId);
@ -1245,9 +1245,9 @@ function displayHistory(scrollToBottom = true) {
} }
let div; let div;
if (entry[0]) { //is file if (entry[0]) { //is file
div = generateFile(name, currentSessionId, true, entry[1]); div = generateFile(name, undefined, true, entry[1]);
} else { } else {
div = generateMessage(name, currentSessionId, entry[1]); div = generateMessage(name, undefined, entry[1]);
} }
let li = document.createElement("li"); let li = document.createElement("li");
li.appendChild(div); li.appendChild(div);

View File

@ -69,7 +69,6 @@ async fn start_websocket_server(global_vars: Arc<RwLock<GlobalVars>>) -> u16 {
fn discover_peers(session_manager: Arc<SessionManager>) { fn discover_peers(session_manager: Arc<SessionManager>) {
tokio::spawn(async move { tokio::spawn(async move {
discovery::discover_peers(move |discovery_manager, ip| { discovery::discover_peers(move |discovery_manager, ip| {
println!("New peer discovered: {}", ip);
let session_manager = session_manager.clone(); let session_manager = session_manager.clone();
if session_manager.is_identity_loaded() { if session_manager.is_identity_loaded() {
tokio::spawn( async move { tokio::spawn( async move {
@ -153,6 +152,8 @@ async fn websocket_worker(mut ui_connection: UiConnection, global_vars: Arc<RwLo
ui_connection.write_message(tungstenite::Message::Pong(Vec::new())); //not sure if I'm doing this right ui_connection.write_message(tungstenite::Message::Pong(Vec::new())); //not sure if I'm doing this right
} else if msg.is_text() { } else if msg.is_text() {
let msg = msg.into_text().unwrap(); let msg = msg.into_text().unwrap();
#[cfg(debug_assertions)]
println!("Message: {}", msg);
let mut ui_connection = ui_connection.clone(); let mut ui_connection = ui_connection.clone();
let session_manager = session_manager.clone(); let session_manager = session_manager.clone();
handle.spawn(async move { handle.spawn(async move {

View File

@ -438,6 +438,7 @@ impl SessionManager {
timestamp, timestamp,
data: buffer, data: buffer,
}; };
self.set_seen(session_id, false);
self.with_ui_connection(|ui_connection| { self.with_ui_connection(|ui_connection| {
ui_connection.on_new_msg(&session_id, &msg); ui_connection.on_new_msg(&session_id, &msg);
}); });
@ -447,6 +448,7 @@ impl SessionManager {
if let Some((filename, content)) = protocol::parse_file(&buffer) { if let Some((filename, content)) = protocol::parse_file(&buffer) {
match self.store_file(&session_id, content) { match self.store_file(&session_id, content) {
Ok(file_uuid) => { Ok(file_uuid) => {
self.set_seen(session_id, false);
self.with_ui_connection(|ui_connection| { self.with_ui_connection(|ui_connection| {
ui_connection.on_new_file(&session_id, false, timestamp, filename, file_uuid); ui_connection.on_new_file(&session_id, false, timestamp, filename, file_uuid);
}); });
@ -469,9 +471,6 @@ impl SessionManager {
} }
_ => {} _ => {}
} }
if header == protocol::Headers::MESSAGE || header == protocol::Headers::FILE {
self.set_seen(session_id, false);
}
} }
} }
} }