openwebrx-clone/htdocs/lib/Js8Threads.js

117 lines
3.2 KiB
JavaScript
Raw Normal View History

2020-04-19 20:10:32 +00:00
Js8Thread = function(el){
this.messages = [];
this.el = el;
}
Js8Thread.prototype.getAverageFrequency = function(){
var total = this.messages.map(function(message){
return message.freq;
}).reduce(function(t, f){
return t + f;
}, 0);
return total / this.messages.length;
}
Js8Thread.prototype.pushMessage = function(message) {
this.messages.push(message);
this.render();
}
Js8Thread.prototype.render = function() {
this.el.html(
'<td>' + this.renderTimestamp(this.getLatestTimestamp()) + '</td>' +
'<td class="decimal freq">' + Math.round(this.getAverageFrequency()) + '</td>' +
'<td class="message">&lrm;' + this.renderMessages() + '</td>'
2020-04-19 20:10:32 +00:00
);
}
Js8Thread.prototype.getLatestTimestamp = function() {
var startingMessages = this.messages.filter(function(m){
return m.thread_type & 1;
});
if (startingMessages.length) {
return startingMessages[startingMessages.length - 1].timestamp;
}
return this.messages[0].timestamp;
2020-04-19 20:10:32 +00:00
}
Js8Thread.prototype.renderMessages = function() {
res = []
for (var i = 0; i < this.messages.length; i++) {
var msg = this.messages[i];
if (msg.thread_type & 1) {
res.push('[ ');
} else if (i == 0 || msg.timestamp - this.messages[i - 1].timestamp > 15000) {
2020-04-19 20:10:32 +00:00
res.push(' ... ');
}
res.push(msg.msg);
if (msg.thread_type & 2) {
res.push(' ]');
}
}
return res.join('');
}
Js8Thread.prototype.renderTimestamp = function(timestamp) {
var t = new Date(timestamp);
var pad = function (i) {
return ('' + i).padStart(2, "0");
};
return pad(t.getUTCHours()) + pad(t.getUTCMinutes()) + pad(t.getUTCSeconds());
}
Js8Thread.prototype.purgeOldMessages = function() {
var now = new Date().getTime();
this.messages = this.messages.filter(function(m) {
// keep messages around for 20 minutes
return now - m.timestamp < 20 * 60 * 1000;
});
if (!this.messages.length) {
this.el.remove();
} else {
this.render();
}
return this.messages.length;
}
2020-04-19 20:10:32 +00:00
Js8Threader = function(el){
this.threads = [];
this.tbody = $(el).find('tbody');
var me = this;
this.interval = setInterval(function(){
me.purgeOldMessages();
}, 15000);
};
Js8Threader.prototype.purgeOldMessages = function() {
this.threads = this.threads.filter(function(t) {
return t.purgeOldMessages();
});
2020-04-19 20:10:32 +00:00
};
Js8Threader.prototype.findThread = function(freq) {
var matching = this.threads.filter(function(thread) {
// max frequency deviation: 5 Hz. this may be a little tight.
2020-04-19 20:10:32 +00:00
return Math.abs(thread.getAverageFrequency() - freq) <= 5;
});
return matching[0] || false;
}
Js8Threader.prototype.pushMessage = function(message) {
var thread = this.findThread(message.freq);
if (!thread) {
var line = $("<tr></tr>")
this.tbody.append(line);
var thread = new Js8Thread(line);
this.threads.push(thread);
}
thread.pushMessage(message);
this.tbody.scrollTop(this.tbody[0].scrollHeight);
2020-04-19 20:10:32 +00:00
}
$.fn.js8 = function() {
if (!this.data('threader')) {
this.data('threader', new Js8Threader(this));
}
return this.data('threader');
}