@@ -12,6 +12,8 @@ var client = new Paho.Client(livedata, clientID);
1212var clientConnected = false ;
1313var clientActive = false ;
1414var clientTopic ;
15+ var messageRate = 0 ;
16+ var messageRateAverage = 10 ;
1517
1618var host_url = "" ;
1719var 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