Skip to content

Commit 907ee3c

Browse files
authored
Merge pull request projecthorus#75 from LukePrior/testing
Show number of messages/second when connected to websockets
2 parents 7a6e4b4 + 5bdd554 commit 907ee3c

File tree

1 file changed

+25
-1
lines changed

1 file changed

+25
-1
lines changed

js/tracker.js

Lines changed: 25 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,8 @@ var client = new Paho.Client(livedata, clientID);
1212
var clientConnected = false;
1313
var clientActive = false;
1414
var clientTopic;
15+
var messageRate = 0;
16+
var messageRateAverage = 10;
1517

1618
var host_url = "";
1719
var markers_url = "img/markers/";
@@ -345,6 +347,10 @@ function clean_refresh(text, force, history_step) {
345347

346348
if (clientActive) {
347349
clientActive = false;
350+
if (!document.getElementById("stTimer").classList.contains('friendly-dtime') ) {
351+
document.getElementById("stTimer").classList.add('friendly-dtime');
352+
$("#updatedText").text(" Updated: ");
353+
}
348354
$("#stText").text("");
349355
}
350356

@@ -426,7 +432,7 @@ function load() {
426432
onAdd: function(map) {
427433
var div = L.DomUtil.create('div');
428434

429-
div.innerHTML = "<span id='stText'></span><span> Updated: </span><i class='friendly-dtime' id='stTimer'>never</i>";
435+
div.innerHTML = "<span id='stText'></span><span id='updatedText'> Updated: </span><i class='friendly-dtime' id='stTimer'>never</i>";
430436
div.style = "opacity: 0.7; background-color: rgb(245, 245, 245); padding-right: 6px; padding-left: 6px; font-family: Roboto, Arial, sans-serif; color: rgb(68, 68, 68);";
431437

432438
return div;
@@ -2978,18 +2984,36 @@ function liveData() {
29782984
$("#stText").text("error |");
29792985
clientConnected = false;
29802986
clientActive = false;
2987+
if (!document.getElementById("stTimer").classList.contains('friendly-dtime') ) {
2988+
document.getElementById("stTimer").classList.add('friendly-dtime');
2989+
$("#updatedText").text(" Updated: ");
2990+
}
29812991
refresh();
29822992
};
29832993

29842994
function onConnectionLost(responseObject) {
29852995
if (responseObject.errorCode !== 0) {
29862996
clientConnected = false;
29872997
clientActive = false;
2998+
if (!document.getElementById("stTimer").classList.contains('friendly-dtime') ) {
2999+
document.getElementById("stTimer").classList.add('friendly-dtime');
3000+
$("#updatedText").text(" Updated: ");
3001+
}
29883002
refresh();
29893003
}
29903004
};
29913005

29923006
function onMessageArrived(message) {
3007+
messageRate += 1;
3008+
setTimeout(function(){
3009+
messageRate -= 1;
3010+
}, (1000 * messageRateAverage));
3011+
var messageCalculatedRate = Math.round(messageRate / messageRateAverage / 10) * 10;
3012+
if ( document.getElementById("stTimer").classList.contains('friendly-dtime') ) {
3013+
document.getElementById("stTimer").classList.remove('friendly-dtime');
3014+
}
3015+
$("#stTimer").text(messageCalculatedRate + " msg/s");
3016+
$("#updatedText").text(" ");
29933017
var dateNow = new Date().getTime();
29943018
try {
29953019
if (clientActive) {

0 commit comments

Comments
 (0)