Porównaj commity

...

2 Commity

Autor SHA1 Wiadomość Data
Mark Jessop beb9db5b4e Update readme and example config 2022-09-22 16:02:22 +09:30
Mark Jessop 8f4a73245f Use websockets to access sondehub/sondehub-amateur chase car data. 2022-09-22 15:47:51 +09:30
8 zmienionych plików z 2615 dodań i 209 usunięć

Wyświetl plik

@ -7,15 +7,14 @@ The primary purpose of chasemapper is to provide an easy-to-use mapping interfac
Chasemapper is intended to be run on a 'headless' machine like a Raspberry Pi and is accessed from a tablet or laptop computer via a web browser. Multiple clients can connect to the server to see what's going on, which is a nice way of keeping passengers entertained ;-)
It will quite happily run alongside other Project Horus applications such as [radiosonde_auto_rx](https://github.com/projecthorus/radiosonde_auto_rx).
It will quite happily run alongside other Project Horus applications such as [radiosonde_auto_rx](https://github.com/projecthorus/radiosonde_auto_rx/wiki), or [horusdemodlib](https://github.com/projecthorus/horusdemodlib/wiki)
### Contacts
* [Mark Jessop](https://github.com/darksidelemm) - vk5qi@rfhead.net
## Update Notes
* If you have previously had chasemapper or auto_rx installed, you may need to update flask-socketio to the most recent version. You can do this by running `sudo pip3 install -U flask-socketio`
* As of mid-April, there have been additions to the chasemapper configuration file format to enable interfacing with the new [v2 Sondehub Tracker](https://v2.sondehub.org/), including a selection for the online tracker in use. You will need to update your configuration files for chasemapper to continue working. Integration with Sondehub v2 is still in progress.
* Further updates to interface with SondeHub's payload recovery reporting system have been introduced in early June (v1.3.0).
* Chasemapper has now dropped support for the HabHub tracker, which is due to be retired later this year (2022). Chasemapper supports uploading chase-car position information to both [SondeHub](https://tracker.sondehub.org) (for radiosonde chasers), and [SondeHub-Amateur]((https://amateur.sondehub.org)) (for amateur high-altitude balloon launches)
## Docker Install
The fastest (and most recommended) way to get chasemapper up and running is to use the pre-built docker container. Information on using this is available here: https://github.com/projecthorus/chasemapper/wiki/Docker
@ -46,9 +45,8 @@ $ git clone https://github.com/projecthorus/chasemapper.git
To use the map, you need some kind of data to plot on it! The mapping backend accepts telemetry data in a few formats:
* 'Payload Summary', 'Chase Car Position' and 'Bearing' messages, via UDP broadcast in a JSON format [described here](https://github.com/projecthorus/horus_utils/wiki/5.-UDP-Broadcast-Messages#payload-summary-payload_summary). The standard ports used for these are 55672 (for hobbyist HAB payloads) and 55673 (radiosondes). These can be generated by:
* [radiosonde_auto_rx](https://github.com/projecthorus/radiosonde_auto_rx/wiki) - See [here](https://github.com/projecthorus/radiosonde_auto_rx/wiki/Configuration-Settings#payload-summary-output) for configuration info.
* Various 'bridge' utilities within the [horus_utils](https://github.com/projecthorus/horus_utils/wiki) repository. For example, [FldigiBridge](https://github.com/projecthorus/horus_utils/wiki#fldigibridge-processing-of-data-from-dl-fldigi) or [HabitatBridge](https://github.com/projecthorus/horus_utils/wiki#habitat-bridge)
* The [Horus-GUI](https://github.com/projecthorus/horus-gui) and [Horus Binary](https://github.com/projecthorus/horusdemodlib/wiki) 4FSK telemetry decoders will emit these messages on port 55672 by default.
* My [Kerberos-SDR fork](https://github.com/darksidelemm/kerberossdr) will emit TDOA bearing information in the appropriate UDP message format on port 55672. Note that the bearing functionality is very much experimental at this time.
* My [Kraken-SDR fork](https://github.com/darksidelemm/krakensdr_doa) will emit TDOA bearing information in the appropriate UDP message format on port 55672. Note that the bearing functionality is very much experimental at this time.
* 'OziMux' messages, via UDP broadcast in a simple CSV format [described here](https://github.com/projecthorus/oziplotter/wiki/3---Data-Sources#3---oziplotter-data-inputs).
* [radiosonde_auto_rx](https://github.com/projecthorus/radiosonde_auto_rx/wiki) - See [here](https://github.com/projecthorus/radiosonde_auto_rx/wiki/Configuration-Settings#sending-payload-data-to-chasemapper--oziplotter--ozimux) for configuration info, though I suggest using the 'Payload Summary' message as described above as it provides callsign information.
* Pi-in-the-Sky's [lora_gateway](https://github.com/PiInTheSky/lora-gateway) - Using the `OziPort=8942` configuration option.
@ -76,7 +74,7 @@ The server can be stopped with CTRL+C. Sometimes the server doesn't stop cleanly
You should then be able to access the webpage by visiting http://your_ip_here:5001/
## Live Predictions
By default, chasemapper will attempt to request flight-path predictions from the [Tawhiri Predictor API](https://tawhiri.readthedocs.io/en/latest/api.html), which requires an internet connection. If you have a semi-reliable internet connection during the flight, this might be all you need to get chasing!
By default, chasemapper will attempt to request flight-path predictions from the SondeHub instance of the [Tawhiri Predictor](https://github.com/projecthorus/tawhiri), which requires an internet connection. If you have a semi-reliable internet connection during the flight, this might be all you need to get chasing!
However, if you think you might be going out of phone coverage range, you may want to set up offline predictions:
@ -93,7 +91,7 @@ You can then click 'Download Model' in the web interface's setting tab to trigge
## Chase Car Positions
At the moment Chasemapper supports receiving chase-car positions via either GPSD, a Serial-attached GPS, or Horus UDP messages. Refer to the configuration file for setup information for these options.
This application can also plot your position onto the tracker.habhub.org map, so others can see when you're out balloon chasing. You can also fetch positions of nearby chase cars from Habitat, to see if others are out chasing as well :-) These options can be enabled from the control pane on the left of the web interface, and can also be set within the configuration file.
This application can also plot your position onto the tracker.habhub.org map, so others can see when you're out balloon chasing. You can also fetch positions of nearby chase cars from SondeHub/SondeHub-Amateur, to see if others are out chasing as well :-) These options can be enabled from the control pane on the left of the web interface, and can also be set within the configuration file.
## Offline Mapping
Chasemapper can serve up map tiles from a specified directory to the web client. Of course, for this to be useful, we need map tiles to serve!
@ -192,8 +190,8 @@ The above formats are accepted via a horus_udp listener, and so you must have a
Bearings are plotted on the map as thin lines, which slowly become transparent as they get older, and then disappear. The style of the line and the maximum age bearings shown can be configured in the new bearing settings tab on the left of the screen (click the compass icon). You can also filter bearings by the optionally supplied confidence level ('Confidence Threshold'). Bearings provided while the chase-car is stationary (i.e. when the heading is essentially unknown) are filtered out of the display by default, but can be enabled if desired ('Show stationary bearings'). Most of the filter settings will only take effect by clicking the 'Redraw Bearings' button.
My [Kerberos-SDR fork](https://github.com/darksidelemm/kerberossdr) will emit relative bearings in the above format on UDP port 55672, including the raw TDOA data, which is plotted on a polar plot on the bottom-right of the display. Bearing data will be emitted as soon as TDOA processing is started. Note that I have only tested with data from a Uniform Circular Array and do not currently handle forward/reverse ambiguities from a linear array configuration. I would *not* suggest running Chasemapper on the same device as the Kerberos-SDR software, due to the high processor load of the Kerberos algorithms.
My [Kraken-SDR fork](https://github.com/darksidelemm/krakensdr_doa) will emit relative bearings in the above format on UDP port 55672, including the raw TDOA data, which is plotted on a polar plot on the bottom-right of the display. Bearing data will be emitted as soon as TDOA processing is started. Note that I have only tested with data from a Uniform Circular Array and do not currently handle forward/reverse ambiguities from a linear array configuration. I would *not* suggest running Chasemapper on the same device as the Kerberos-SDR software, due to the high processor load of the Kerberos algorithms.
Note that the bearing display (in particular the TDOA data polar plot) does put a fairly big strain on some slower devices. Currently the polar plot is generated in a fairly naive way, and definitely has room for improvement.
I make no promises as to the usefulness and/or performance of this feature in chasemapper - it's essentially a re-implementation of a radio-direction finding mapping system developed by fellow Amateur Radio Experimenters Group members a very long time ago, and has yet to be used 'in anger'. It's also important to note that attempting to direction-find radiosonde/high-altitude balloon payloads which are located at high relative elevations (>40 degrees or so) is likely to lead to very inaccurate results due to coning angle limitations (where a bearing cannot be resolved due to insufficient phase-delta between receive antennae).
I make no promises as to the usefulness and/or performance of this feature in chasemapper - it's essentially a re-implementation of a radio-direction finding mapping system developed by fellow Amateur Radio Experimenters Group members a very long time ago. I've used it in a few local amateur radio direction finding competitions have found it to be useful. It's also important to note that attempting to direction-find radiosonde/high-altitude balloon payloads which are located at high relative elevations (>40 degrees or so) is likely to lead to very inaccurate results due to coning angle limitations (where a bearing cannot be resolved due to insufficient phase-delta between receive antennae).

Wyświetl plik

@ -8,4 +8,4 @@
# Now using Semantic Versioning (https://semver.org/) MAJOR.MINOR.PATCH
__version__ = "1.4.5"
__version__ = "1.5.0"

Wyświetl plik

@ -3,7 +3,7 @@
#
# Copy this file to horusmapper.cfg and modify as required.
#
# This is the default config file for chasemapper 1.3.0, be aware there might be changes and it might not run on older/newer versions.
# This is the default config file for chasemapper 1.5.0, be aware there might be changes and it might not run on older/newer versions.
#
#
@ -32,12 +32,12 @@ telemetry_source_port = 55673
# Car Position Source
# none - No Chase-Car GPS
# horus_udp - Read Horus UDP Broadcast 'Car GPS' messages
# serial - Read GPS positions from a serial-connected GPS receiver.
# gpsd - Poll GPSD for positions.
# serial - Read GPS positions from a serial-connected GPS receiver. RECOMMENDED
# gpsd - Poll a local GPSD instance for positions. (Known to have some reliability issues...)
# station - Stationary position (set in the [map] section below)
car_source_type = gpsd
car_source_type = serial
# Car position source port (UDP) - only used if horus_udp is selected, but still needs to be provided.
car_source_port = 12345
car_source_port = 55672
# Online Tracker System
# Where to upload chase-car positions and balloon recovery notifications to.
@ -81,6 +81,7 @@ online_tracker = sondehubamateur
[gpsd]
# GPSD Host/Port - Only used if selected in a telemetry profile above.
# Note that GPSD support is somewhat buggy.
gpsd_host = localhost
gpsd_port = 2947
@ -129,7 +130,7 @@ stadia_api_key = none
# Enable Predictor (True/False) - This can also be enabled from the web client.
predictor_enabled = True
# Predictor defaults - these can be modified at runtime in the web interface.
# Predictor defaults - these can also be modified at runtime in the web interface.
default_burst = 30000
default_descent_rate = 5.0
@ -181,20 +182,24 @@ tile_server_path = /home/pi/Maps/
#tile_server_path = /opt/chasemapper/Maps/
#
# Habitat / SondeHub Chase-Car Position Upload
# If you want, this application can upload your chase-car position to the Habhub / Sondehub trackers,
# SondeHub Chase-Car Position Upload
# If you want, this application can upload your chase-car position to the SondeHub/SondeHub-Amateur trackers,
# for those follwing along at home.
# The settings below can be modified from the web interface, but they will default to what is set below on startup.
#
# Note - Variables in this section still refer to habitat to avoid breaking existing configurations.
[habitat]
# Enable uploading of chase-car position to Habitat (True / False)
# Enable uploading of chase-car position to SondeHub / SondeHub-Amateur (True / False)
# Which tracker positions are uploaded to depends on the online_tracker setting of the selected
# profile (further up in this config file).
habitat_upload_enabled = False
# Callsign to use when uploading. Note that _chase is automatically appended to this callsign
# i.e. N0CALL will show up as N0CALL_chase on tracker.habhub.org
# when displayed on the tracker maps.
# i.e. N0CALL will show up as N0CALL_chase on sondehub.org
habitat_call = N0CALL
# Attempt to upload position to habitat every x seconds.
# Attempt to upload position to SondeHub every x seconds.
habitat_update_rate = 30

Wyświetl plik

@ -159,22 +159,3 @@ function get_habitat_vehicles(){
}
// Show/Hide all vehicles.
function show_habitat_vehicles(){
var state = document.getElementById("showOtherCars").checked;
for (_car in chase_vehicles){
// Add to map, if its not already on there.
if(state){
if(!chase_vehicles[_car].onmap){
chase_vehicles[_car].marker.addTo(map);
chase_vehicles[_car].onmap = true;
}
} else{
if(chase_vehicles[_car].onmap){
chase_vehicles[_car].marker.remove();
chase_vehicles[_car].onmap = false;
}
}
}
}

Plik diff jest za duży Load Diff

Wyświetl plik

@ -79,6 +79,7 @@ function serverSettingsUpdate(data){
// Update version
$('#chasemapper_version').html(chase_config.version);
}
function clientSettingsUpdate(){

Wyświetl plik

@ -1,189 +1,227 @@
//
// Project Horus - Browser-Based Chase Mapper - SondeHub Data Scraping
// Project Horus - Browser-Based Chase Mapper - SondeHub Websockets Connection.
//
// Copyright (C) 2021 Mark Jessop <vk5qi@rfhead.net>
// Copyright (C) 2022 Mark Jessop <vk5qi@rfhead.net>
// Released under GNU GPL v3 or later
//
// URL to scrape recent vehicle position data from.
var sondehub_vehicle_url = "https://api.v2.sondehub.org/listeners/telemetry?duration=1h";
var sondehub_vehicle_url_amateur = "https://api.v2.sondehub.org/amateur/listeners/telemetry?duration=1h";
function handleSondeHubWebSocketPacket(data){
// Handle a packet of vehicle / listener telemetry from a SondeHub / SondeHub-Amateur Websockets Connection.
// Only process frames where the 'mobile' flag is present and is true.
if (data.hasOwnProperty('mobile')){
if(data['mobile'] == true){
// We have found a mobile station!
//console.log(data);
// Not really sure if this is necessary.
var sondehub_request_running = false;
// Extract position.
var v_lat = parseFloat(data.uploader_position[0]);
var v_lon = parseFloat(data.uploader_position[1]);
var v_alt = parseFloat(data.uploader_position[2]);
var vcallsign = data.uploader_callsign;
// If the vehicle is already known to us, then update it position.
// Update any existing entries (even if the range is above the threshold)
if (chase_vehicles.hasOwnProperty(vcallsign)){
//console.log("Updating: " + vcallsign);
// Update the position ID.
chase_vehicles[vcallsign].position_id = data.ts;
var temp_sondehub = null;
// Since we don't always get a heading with the vehicle position, calculate it.
var old_v_pos = {lat:chase_vehicles[vcallsign].latest_data[0],
lon: chase_vehicles[vcallsign].latest_data[1],
alt:chase_vehicles[vcallsign].latest_data[2]};
var new_v_pos = {lat: v_lat, lon:v_lon, alt:v_alt};
chase_vehicles[vcallsign].heading = calculate_lookangles(old_v_pos, new_v_pos).azimuth;
function process_sondehub_vehicles(data){
// Check we have a 'valid' response to process.
if (data === null ||
data === {}) {
sondehub_request_running = false;
return;
}
// Update the position data.
chase_vehicles[vcallsign].latest_data = [v_lat, v_lon, v_alt];
// Now iterate over all the callsigns in the response.
Object.keys(data).forEach(function(vcallsign){
// Skip over our own data.
if (vcallsign.startsWith(chase_config.habitat_call)){
return;
}
// Update the marker position.
chase_vehicles[vcallsign].marker.setLatLng(chase_vehicles[vcallsign].latest_data).update();
if( (data[vcallsign] === null) || (data[vcallsign] == {})){
// No data. This shouldn't happen, as the DB shouldn't give us empty results.
return;
// Rotate/replace the icon to match the bearing.
var _car_heading = chase_vehicles[vcallsign].heading - 90.0;
if (_car_heading<=90.0){
chase_vehicles[vcallsign].marker.setIcon(habitat_car_icons[chase_vehicles[vcallsign].colour]);
chase_vehicles[vcallsign].marker.setRotationAngle(_car_heading);
}else{
// We are travelling West - we need to use the flipped car icon.
_car_heading = _car_heading - 180.0;
chase_vehicles[vcallsign].marker.setIcon(habitat_car_icons_flipped[chase_vehicles[vcallsign].colour]);
chase_vehicles[vcallsign].marker.setRotationAngle(_car_heading);
}
}else{
// Array of times for each callsign
_position_times = Object.keys(data[vcallsign]);
// Get last position, which should be the latest.
_last_position = data[vcallsign][_position_times[_position_times.length - 1]];
} else {
// Check if the vehicle is marked as a 'mobile' station
if (_last_position.hasOwnProperty('mobile')){
if(_last_position['mobile'] == true){
// We have found a mobile station!
//console.log(_last_position);
// Otherwise, we need to decide if we're going to add it or not.
// Determine the vehicle distance from our current position.
var v_pos = {lat: v_lat, lon:v_lon, alt:v_alt};
if (chase_car_position.marker === "NONE"){
var my_pos = {lat:chase_config.default_lat, lon:chase_config.default_lon, alt:0};
}else{
var my_pos = {lat:chase_car_position.latest_data[0], lon:chase_car_position.latest_data[1], alt:chase_car_position.latest_data[2]};
}
var v_range = calculate_lookangles(my_pos, v_pos).range/1000.0;
// Extract position.
var v_lat = parseFloat(_last_position.uploader_position[0]);
var v_lon = parseFloat(_last_position.uploader_position[1]);
var v_alt = parseFloat(_last_position.uploader_position[2]);
// If the vehicle is already known to us, then update it position.
// Update any existing entries (even if the range is above the threshold)
if (chase_vehicles.hasOwnProperty(vcallsign)){
// If the range is less than the threshold, add it to our list of chase vehicles.
if(v_range < vehicle_max_range){
//console.log("Adding: " + vcallsign);
chase_vehicles[vcallsign] = {};
// Initialise a few default values
chase_vehicles[vcallsign].heading = 90;
chase_vehicles[vcallsign].latest_data = [v_lat, v_lon, v_alt];
chase_vehicles[vcallsign].position_id = data.ts;
// Only update if the position ID of this position is newer than that last seen.
if (chase_vehicles[vcallsign].position_id !== _last_position.ts){
//console.log("Updating: " + vcallsign);
// Update the position ID.
chase_vehicles[vcallsign].position_id = _last_position.ts;
// Get an index for the car icon. This is incremented for each vehicle,
// giving each a different colour.
chase_vehicles[vcallsign].colour = car_colour_values[car_colour_idx];
car_colour_idx = (car_colour_idx+1)%car_colour_values.length;
// Since we don't always get a heading with the vehicle position, calculate it.
var old_v_pos = {lat:chase_vehicles[vcallsign].latest_data[0],
lon: chase_vehicles[vcallsign].latest_data[1],
alt:chase_vehicles[vcallsign].latest_data[2]};
var new_v_pos = {lat: v_lat, lon:v_lon, alt:v_alt};
chase_vehicles[vcallsign].heading = calculate_lookangles(old_v_pos, new_v_pos).azimuth;
// Create marker
chase_vehicles[vcallsign].marker = L.marker(chase_vehicles[vcallsign].latest_data,
{title:vcallsign,
icon: habitat_car_icons[chase_vehicles[vcallsign].colour],
rotationOrigin: "center center"});
// Update the position data.
chase_vehicles[vcallsign].latest_data = [v_lat, v_lon, v_alt];
// Update the marker position.
chase_vehicles[vcallsign].marker.setLatLng(chase_vehicles[vcallsign].latest_data).update();
// Rotate/replace the icon to match the bearing.
var _car_heading = chase_vehicles[vcallsign].heading - 90.0;
if (_car_heading<=90.0){
chase_vehicles[vcallsign].marker.setIcon(habitat_car_icons[chase_vehicles[vcallsign].colour]);
chase_vehicles[vcallsign].marker.setRotationAngle(_car_heading);
}else{
// We are travelling West - we need to use the flipped car icon.
_car_heading = _car_heading - 180.0;
chase_vehicles[vcallsign].marker.setIcon(habitat_car_icons_flipped[chase_vehicles[vcallsign].colour]);
chase_vehicles[vcallsign].marker.setRotationAngle(_car_heading);
}
return;
}
// No need to go any further.
return;
}
// Otherwise, we need to decide if we're going to add it or not.
// Determine the vehicle distance from our current position.
var v_pos = {lat: v_lat, lon:v_lon, alt:v_alt};
if (chase_car_position.marker === "NONE"){
var my_pos = {lat:chase_config.default_lat, lon:chase_config.default_lon, alt:0};
}else{
var my_pos = {lat:chase_car_position.latest_data[0], lon:chase_car_position.latest_data[1], alt:chase_car_position.latest_data[2]};
}
var v_range = calculate_lookangles(my_pos, v_pos).range/1000.0;
// If the range is less than the threshold, add it to our list of chase vehicles.
if(v_range < vehicle_max_range){
//console.log("Adding: " + vcallsign);
chase_vehicles[vcallsign] = {};
// Initialise a few default values
chase_vehicles[vcallsign].heading = 90;
chase_vehicles[vcallsign].latest_data = [v_lat, v_lon, v_alt];
chase_vehicles[vcallsign].position_id = _last_position.ts;
// Get an index for the car icon. This is incremented for each vehicle,
// giving each a different colour.
chase_vehicles[vcallsign].colour = car_colour_values[car_colour_idx];
car_colour_idx = (car_colour_idx+1)%car_colour_values.length;
// Create marker
chase_vehicles[vcallsign].marker = L.marker(chase_vehicles[vcallsign].latest_data,
{title:vcallsign,
icon: habitat_car_icons[chase_vehicles[vcallsign].colour],
rotationOrigin: "center center"})
.addTo(map);
// Add tooltip, with custom CSS which removes all tooltip borders, and adds a text shadow.
chase_vehicles[vcallsign].marker.bindTooltip(vcallsign,
{permanent: true,
direction: 'center',
offset:[0,25],
className:'custom_label'}).openTooltip();
if(document.getElementById("showOtherCars").checked){
// Add the car to the map if we have the show other cars button checked.
chase_vehicles[vcallsign].marker.addTo(map);
// Keep our own record of if this marker has been added to a map,
// as we shouldn't be using the private _map property of the marker object.
chase_vehicles[vcallsign].onmap = true;
// Add tooltip, with custom CSS which removes all tooltip borders, and adds a text shadow.
chase_vehicles[vcallsign].marker.bindTooltip(vcallsign,
{permanent: true,
direction: 'center',
offset:[0,25],
className:'custom_label'}).openTooltip();
}
}
}
}
}
});
sondehub_request_running = false;
}
}
// Request the latest vehicle positions from Sondehub
function get_sondehub_vehicles(){
if(!sondehub_request_running){
sondehub_request_running = true;
console.log("Requesting vehicles from Sondehub...")
$.ajax({
url: sondehub_vehicle_url,
dataType: 'json',
timeout: 15000,
async: true,
success: function(data) {
console.log(data);
process_sondehub_vehicles(data);
}
});
function flush_sondehub_vehicles(){
for (_car in chase_vehicles){
// Remove from map if present.
if(chase_vehicles[_car].onmap){
chase_vehicles[_car].marker.remove();
chase_vehicles[_car].onmap = false;
}
delete chase_vehicles[_car];
}
}
// Request the latest vehicle positions from Sondehub-Amateur
function get_sondehub_amateur_vehicles(){
//
// SondeHub Websockets connection.
//
var livedata = "wss://ws-reader.v2.sondehub.org/";
var clientID = "ChaseMapper-" + Math.floor(Math.random() * 10000000000);
var client;
var clientConnected = false;
var clientActive = false;
var clientTopic;
if(!sondehub_request_running){
sondehub_request_running = true;
console.log("Requesting vehicles from Sondehub Amateur...")
$.ajax({
url: sondehub_vehicle_url_amateur,
dataType: 'json',
timeout: 15000,
async: true,
success: function(data) {
console.log(data);
process_sondehub_vehicles(data);
}
});
}
function onConnect() {
if (chase_config.profiles[chase_config.selected_profile].online_tracker === "sondehub") {
var topic = "listener/#";
client.subscribe(topic);
clientTopic = topic;
} else if (chase_config.profiles[chase_config.selected_profile].online_tracker === "sondehubamateur") {
var topic = "amateur-listener/#";
client.subscribe(topic);
clientTopic = topic;
} else {
return;
}
clientConnected = true;
clientActive = true;
console.log("SondeHub Websockets Connected - Subscribed to " + clientTopic);
};
function connectionError(error) {
clientConnected = false;
clientActive = false;
console.log("SondeHub Websockets Connection Error");
};
function onConnectionLost(responseObject) {
if (responseObject.errorCode !== 0) {
clientConnected = false;
clientActive = false;
console.log("SondeHub Websockets Connection Lost");
}
};
function onMessageArrived(message) {
try {
if (clientActive) {
var frame = JSON.parse(message.payloadString.toString());
handleSondeHubWebSocketPacket(frame);
}
}
catch(err) {}
};
function startSondeHubWebsockets() {
if(document.getElementById("showOtherCars").checked){
// Clear off any vehicles on the map.
flush_sondehub_vehicles();
if(clientConnected == false){
// Not connected yet. Start a new connection.
client = new Paho.Client(livedata, clientID);
client.onConnectionLost = onConnectionLost;
client.onMessageArrived = onMessageArrived;
client.connect({onSuccess:onConnect,onFailure:connectionError,reconnect:true});
} else {
// Already connected, un-sub and re-sub to the correct topic.
client.unsubscribe(clientTopic);
onConnect();
}
} else {
if(clientConnected || (client != null)){
client.disconnect();
clientConnected = false;
console.log("SondeHub Websockets Disconnected.")
}
}
}
// Show/Hide all vehicles.
function show_sondehub_vehicles(){
var state = document.getElementById("showOtherCars").checked;
for (_car in chase_vehicles){
// Add to map, if its not already on there.
if(state){
if(!chase_vehicles[_car].onmap){
chase_vehicles[_car].marker.addTo(map);
chase_vehicles[_car].onmap = true;
}
} else{
if(chase_vehicles[_car].onmap){
chase_vehicles[_car].marker.remove();
chase_vehicles[_car].onmap = false;
}
}
}
// Re-connect to websockets if necessary.
startSondeHubWebsockets();
}
/* Habitat ChaseCar lib (copied from SondeHub Tracker)
* Uploads geolocation for chase cars to habitat
*

Wyświetl plik

@ -44,7 +44,7 @@
<script src="{{ url_for('static', filename='js/predictions.js') }}"></script>
<script src="{{ url_for('static', filename='js/car.js') }}"></script>
<script src="{{ url_for('static', filename='js/bearings.js') }}"></script>
<script src="{{ url_for('static', filename='js/paho-mqtt.js') }}"></script>
<meta name="viewport" content="width=device-width, initial-scale=1.0, maximum-scale=1.0, user-scalable=no" />
@ -134,6 +134,8 @@
// (i.e. when another client makes a change)
socket.on('server_settings_update', function(data){
serverSettingsUpdate(data);
// Re-Connect to websockets if necessary.
startSondeHubWebsockets();
});
// Add handlers for various text fields.
@ -675,22 +677,8 @@
}
}, age_update_rate);
// Habitat/Sondehub Chase Car Position Grabber
var habitat_update_rate = 20000;
window.setInterval(function(){
if(document.getElementById("showOtherCars").checked){
if (chase_config.profiles[chase_config.selected_profile].online_tracker === "sondehub"){
get_sondehub_vehicles();
}
else if (chase_config.profiles[chase_config.selected_profile].online_tracker === "sondehubamateur"){
get_sondehub_amateur_vehicles();
}
else{
// Do nothing...
}
}
}, habitat_update_rate);
// Start connection to Sondehub Websockets.
startSondeHubWebsockets();
// Sadly we can't request location information unless chasemapper is served up via HTTPS
// which is a bit difficult to make happen.
@ -859,7 +847,7 @@
<h3>Chase Car Upload</h3>
<div class="form-switch form-check-reverse">
<input class="form-check-input" type="checkbox" role="switch" value="" id="showOtherCars" onclick="show_habitat_vehicles();">
<input class="form-check-input" type="checkbox" role="switch" value="" id="showOtherCars" onclick="show_sondehub_vehicles();">
<label class="form-check-label" for="showOtherCars">
<b>Show Nearby Chase-Cars </b>
</label>