- 
-
-
-
- %[RX_PHOTO_TITLE]
- %[RX_PHOTO_DESC]
-
- 
- 
- 
- 
-
-
-
-
- %[RX_TITLE]
- %[RX_LOC] | Loc: %[RX_QRA], ASL: %[RX_ASL] m, [maps]
-
- 
- 
+ 
+
-
+
+
-
+
+
+ 
+ 
+
+
-
+
+
+ 
+
+
+
+
+
+
+
+ 
+ 
+
+
+
+ -
+
Status
+ 
Log
+ 
Receiver
+
-
-
Status
- 
Log
- 
Receiver
-
@@ -90,6 +75,10 @@
diff --git a/htdocs/openwebrx.css b/htdocs/openwebrx.css
index 250c54a..4736bf3 100644
--- a/htdocs/openwebrx.css
+++ b/htdocs/openwebrx.css
@@ -155,22 +155,12 @@ input[type=range]:focus::-ms-fill-upper
.webrx-top-bar-parts
{
- position: absolute;
- top: 0px;
- left: 0px;
- width:100%;
height:67px;
}
-#webrx-top-bar-background
-{
- background-color: #808080;
- opacity: 0.15;
- filter:alpha(opacity=15);
-}
-
#webrx-top-bar
{
+ background: rgba(128, 128, 128, 0.15);
margin:0;
padding:0;
user-select: none;
@@ -179,20 +169,23 @@ input[type=range]:focus::-ms-fill-upper
-khtml-user-select: none;
-moz-user-select: none;
-ms-user-select: none;
+ overflow: hidden;
+ position: absolute;
+ left: 0;
+ top: 0;
+ right: 0;
}
#webrx-top-logo
{
- position: absolute;
- top: 12px;
- left: 15px;
+ padding: 12px;
+ float: left;
}
#webrx-ha5kfu-top-logo
{
- position: absolute;
- top: 15px;
- right: 15px;
+ float: right;
+ padding: 15px;
}
#webrx-top-photo
@@ -204,79 +197,37 @@ input[type=range]:focus::-ms-fill-upper
#webrx-rx-avatar-background
{
cursor:pointer;
- position: absolute;
- left: 285px;
- top: 6px;
+ background-image: url(gfx/openwebrx-avatar-background.png);
+ background-origin: content-box;
+ background-repeat: no-repeat;
+ float: left;
+ width: 54px;
+ height: 54px;
+ padding: 7px;
}
#webrx-rx-avatar
{
cursor:pointer;
- position: absolute;
- left: 289px;
- top: 10px;
width: 46px;
height: 46px;
+ padding: 4px;
}
#webrx-top-photo-clip
{
+ min-height: 67px;
max-height: 350px;
overflow: hidden;
position: relative;
}
-/*#webrx-bottom-bar
-{
- position: absolute;
- bottom: 0px;
- width: 100%;
- height: 117px;
- background-image:url(gfx/webrx-bottom-bar.png);
-}*/
-
#webrx-page-container
{
min-height:100%;
position:relative;
}
-/*#webrx-photo-gradient-left
-{
- position: absolute;
- bottom: 0px;
- left: 0px;
- background-image:url(gfx/webrx-photo-gradient-corner.png);
- width: 59px;
- height: 92px;
-
-}
-
-#webrx-photo-gradient-middle
-{
- position: absolute;
- bottom: 0px;
- left: 59px;
- right: 59px;
- height: 92px;
- background-image:url(gfx/webrx-photo-gradient-middle.png);
-}
-
-#webrx-photo-gradient-right
-{
- position: absolute;
- bottom: 0px;
- right: 0px;
- background-image:url(gfx/webrx-photo-gradient-corner.png);
- width: 59px;
- height: 92px;
- -webkit-transform:scaleX(-1);
- -moz-transform:scaleX(-1);
- -ms-transform:scaleX(-1);
- -o-transform:scaleX(-1);
- transform:scaleX(-1);
-}*/
-
#webrx-rx-photo-title
{
position: absolute;
@@ -303,10 +254,17 @@ input[type=range]:focus::-ms-fill-upper
#webrx-rx-photo-desc a
{
- /*color: #007df1;*/
color: #5ca8ff;
text-shadow: none;
- /*text-shadow: 0px 0px 7px #fff;*/
+}
+
+#webrx-rx-texts {
+ float: left;
+ padding: 10px;
+}
+
+#webrx-rx-texts div {
+ padding: 3px;
}
#webrx-rx-title
@@ -314,9 +272,6 @@ input[type=range]:focus::-ms-fill-upper
white-space:nowrap;
overflow: hidden;
cursor:pointer;
- position: absolute;
- left: 350px;
- top: 13px;
font-family: "DejaVu Sans", Verdana, Geneva, sans-serif;
color: #909090;
font-size: 11pt;
@@ -330,15 +285,11 @@ input[type=range]:focus::-ms-fill-upper
cursor:pointer;
font-size: 10pt;
color: #909090;
- position: absolute;
- left: 350px;
- top: 34px;
}
#webrx-rx-desc a
{
color: #909090;
- /*text-decoration: none;*/
}
#openwebrx-rx-details-arrow
@@ -718,9 +669,7 @@ img.openwebrx-mirror-img
#openwebrx-main-buttons
{
- position: absolute;
- right: 133px;
- top: 3px;
+ float: right;
margin:0;
color: white;
text-shadow: 0px 0px 4px #000000;
@@ -841,10 +790,7 @@ img.openwebrx-mirror-img
transition: width 500ms, left 500ms;
}
-#openwebrx-secondary-demod-listbox
-{
- width: 201px;
- height: 27px;
+.openwebrx-panel select {
border-radius: 5px;
background-color: #373737;
color: White;
@@ -856,16 +802,27 @@ img.openwebrx-mirror-img
border-color: transparent;
border-width: 0px;
-moz-appearance: none;
- padding-left:3px;
}
-#openwebrx-secondary-demod-listbox option
-{
+.openwebrx-panel select option {
border-width: 0px;
background-color: #373737;
color: White;
}
+#openwebrx-secondary-demod-listbox
+{
+ width: 201px;
+ height: 27px;
+ padding-left:3px;
+}
+
+#openwebrx-sdr-profiles-listbox {
+ width: 100%;
+ font-size: 10pt;
+ height: 27px;
+}
+
#openwebrx-cursor-blink
{
animation: cursor-blink 1s infinite;
diff --git a/htdocs/openwebrx.js b/htdocs/openwebrx.js
index 8adda72..f5b7da8 100644
--- a/htdocs/openwebrx.js
+++ b/htdocs/openwebrx.js
@@ -52,6 +52,7 @@ var waterfall_setup_done=0;
var waterfall_queue = [];
var waterfall_timer;
var secondary_fft_size;
+var audio_allowed;
/*function fade(something,from,to,time_ms,fps)
{
@@ -79,7 +80,9 @@ is_chrome = /Chrome/.test(navigator.userAgent);
function init_rx_photo()
{
- e("webrx-top-photo-clip").style.maxHeight=rx_photo_height.toString()+"px";
+ var clip = e("webrx-top-photo-clip");
+ rx_photo_height = clip.clientHeight
+ clip.style.maxHeight=rx_photo_height+"px";
window.setTimeout(function() { animate(e("webrx-rx-photo-title"),"opacity","",1,0,1,500,30); },1000);
window.setTimeout(function() { animate(e("webrx-rx-photo-desc"),"opacity","",1,0,1,500,30); },1500);
window.setTimeout(function() { close_rx_photo() },2500);
@@ -133,14 +136,14 @@ function toggleMute()
if (mute) {
mute = false;
e("openwebrx-mute-on").id="openwebrx-mute-off";
- e("openwebrx-mute-img").src="gfx/openwebrx-speaker.png";
+ e("openwebrx-mute-img").src="static/gfx/openwebrx-speaker.png";
e("openwebrx-panel-volume").disabled=false;
e("openwebrx-panel-volume").style.opacity=1.0;
e("openwebrx-panel-volume").value = volumeBeforeMute;
} else {
mute = true;
e("openwebrx-mute-off").id="openwebrx-mute-on";
- e("openwebrx-mute-img").src="gfx/openwebrx-speaker-muted.png";
+ e("openwebrx-mute-img").src="static/gfx/openwebrx-speaker-muted.png";
e("openwebrx-panel-volume").disabled=true;
e("openwebrx-panel-volume").style.opacity=0.5;
volumeBeforeMute = e("openwebrx-panel-volume").value;
@@ -160,7 +163,7 @@ function updateSquelch()
{
var sliderValue=parseInt(e("openwebrx-panel-squelch").value);
var outputValue=(sliderValue==parseInt(e("openwebrx-panel-squelch").min))?0:getLinearSmeterValue(sliderValue);
- ws.send("SET squelch_level="+outputValue.toString());
+ ws.send(JSON.stringify({"type":"dspcontrol","params":{"squelch_level":outputValue}}));
}
function updateWaterfallColors(which)
@@ -470,9 +473,13 @@ function demodulator_default_analog(offset_frequency,subtype)
this.doset=function(first_time)
{ //this function sends demodulator parameters to the server
- ws.send("SET"+((first_time)?" mod="+this.server_mod:"")+
- " low_cut="+this.low_cut.toString()+" high_cut="+this.high_cut.toString()+
- " offset_freq="+this.offset_frequency.toString());
+ params = {
+ "low_cut": this.low_cut,
+ "high_cut": this.high_cut,
+ "offset_freq": this.offset_frequency
+ };
+ if (first_time) params.mod = this.server_mod;
+ ws.send(JSON.stringify({"type":"dspcontrol","params":params}));
}
this.doset(true); //we set parameters on object creation
@@ -1155,169 +1162,140 @@ var COMPRESS_FFT_PAD_N=10; //should be the same as in csdr.c
function on_ws_recv(evt)
{
- if(!(evt.data instanceof ArrayBuffer)) { divlog("on_ws_recv(): Not ArrayBuffer received...",1); return; }
- //
- debug_ws_data_received+=evt.data.byteLength/1000;
- first4Chars=getFirstChars(evt.data,4);
- first3Chars=first4Chars.slice(0,3);
- if(first3Chars=="CLI")
- {
- var stringData=arrayBufferToString(evt.data);
- if(stringData.substring(0,16)=="CLIENT DE SERVER") divlog("Server acknowledged WebSocket connection.");
+ if (typeof evt.data == 'string') {
+ // text messages
+ debug_ws_data_received += evt.data.length / 1000;
- }
- if(first3Chars=="AUD")
- {
- var audio_data;
- if(audio_compression=="adpcm") audio_data=new Uint8Array(evt.data,4)
- else audio_data=new Int16Array(evt.data,4);
- audio_prepare(audio_data);
- audio_buffer_current_size_debug+=audio_data.length;
- audio_buffer_all_size_debug+=audio_data.length;
- if(!(ios||is_chrome) && (audio_initialized==0 && audio_prepared_buffers.length>audio_buffering_fill_to)) audio_init()
- }
- else if(first3Chars=="FFT")
- {
- //alert("Yupee! Doing FFT");
- //if(first4Chars=="FFTS") console.log("FFTS");
- if(fft_compression=="none") waterfall_add_queue(new Float32Array(evt.data,4));
- else if(fft_compression="adpcm")
- {
- fft_codec.reset();
+ if (evt.data.substr(0, 16) == "CLIENT DE SERVER") {
+ divlog("Server acknowledged WebSocket connection.");
+ } else {
+ try {
+ json = JSON.parse(evt.data)
+ switch (json.type) {
+ case "config":
+ config = json.value;
+ window.waterfall_colors = config.waterfall_colors;
+ window.waterfall_min_level_default = config.waterfall_min_level;
+ window.waterfall_max_level_default = config.waterfall_max_level;
+ window.waterfall_auto_level_margin = config.waterfall_auto_level_margin;
+ waterfallColorsDefault();
+
+ window.starting_mod = config.start_mod
+ window.starting_offset_frequency = config.start_offset_frequency;
+ window.audio_buffering_fill_to = config.client_audio_buffer_size;
+ bandwidth = config.samp_rate;
+ center_freq = config.center_freq + config.lfo_offset;
+ fft_size = config.fft_size;
+ fft_fps = config.fft_fps;
+ audio_compression = config.audio_compression;
+ divlog( "Audio stream is "+ ((audio_compression=="adpcm")?"compressed":"uncompressed")+"." )
+ fft_compression = config.fft_compression;
+ divlog( "FFT stream is "+ ((fft_compression=="adpcm")?"compressed":"uncompressed")+"." )
+ max_clients_num = config.max_clients;
+ mathbox_waterfall_colors = config.mathbox_waterfall_colors;
+ mathbox_waterfall_frequency_resolution = config.mathbox_waterfall_frequency_resolution;
+ mathbox_waterfall_history_length = config.mathbox_waterfall_history_length;
- var waterfall_i16=fft_codec.decode(new Uint8Array(evt.data,4));
- var waterfall_f32=new Float32Array(waterfall_i16.length-COMPRESS_FFT_PAD_N);
- for(var i=0;i85);
- break;
- case "clients":
- var clients_num=parseInt(param[1]);
- progressbar_set(e("openwebrx-bar-clients"),clients_num/max_clients_num,"Clients ["+param[1]+"]",clients_num>max_clients_num*0.85);
- break;
- case "max_clients":
- max_clients_num=parseInt(param[1]);
- break;
- case "s":
- smeter_level=parseFloat(param[1]);
- setSmeterAbsoluteValue(smeter_level);
- break;
- }
- }
- /*}
- catch(err)
- {
- divlog("Received invalid message over WebSocket.");
- }*/
- } else if (first3Chars=='MET')
- {
- var stringData=arrayBufferToString(evt.data);
- var metaPanels = Array.prototype.filter.call(document.getElementsByClassName('openwebrx-panel'), function(el) {
- return el.dataset.panelName == 'metadata';
- });
+ break;
+ case "receiver_details":
+ var r = json.value;
+ e('webrx-rx-title').innerHTML = r.receiver_name;
+ e('webrx-rx-desc').innerHTML = r.receiver_location + ' | Loc: ' + r.receiver_qra + ', ASL: ' + r.receiver_asl + ' m, [maps]';
+ e('webrx-rx-photo-title').innerHTML = r.photo_title;
+ e('webrx-rx-photo-desc').innerHTML = r.photo_desc;
+ break;
+ case "smeter":
+ smeter_level = json.value;
+ setSmeterAbsoluteValue(smeter_level);
+ break;
+ case "cpuusage":
+ var server_cpu_usage = json.value;
+ progressbar_set(e("openwebrx-bar-server-cpu"),server_cpu_usage/100,"Server CPU [" + server_cpu_usage + "%]",server_cpu_usage>85);
+ break;
+ case "clients":
+ var clients = json.value;
+ progressbar_set(e("openwebrx-bar-clients"), clients / max_clients_num, "Clients [" + clients + "]", clients > max_clients_num*0.85);
+ break;
+ case "profiles":
+ var listbox = e("openwebrx-sdr-profiles-listbox");
+ listbox.innerHTML = json.value.map(function(profile){
+ return '";
+ }).join("");
+ break;
+ default:
+ console.warn('received message of unknown type: ' + json.type);
+ }
+ } catch (e) {
+ // don't lose exception
+ console.error(e)
+ }
+ }
+ } else if (evt.data instanceof ArrayBuffer) {
+ // binary messages
+ debug_ws_data_received += evt.data.byteLength / 1000;
- var meta = {};
- stringData.substr(4).split(";").forEach(function(s) {
- var item = s.split(":");
- meta[item[0]] = item[1];
- });
+ type = new Uint8Array(evt.data, 0, 1)[0]
+ data = evt.data.slice(1)
- var update = function(el) {
- el.innerHTML = "";
- }
- if (meta.protocol) switch (meta.protocol) {
- case 'DMR':
- if (meta.slot) {
- var html = 'Timeslot: ' + meta.slot;
- if (meta.type) html += ' Typ: ' + meta.type;
- if (meta.source && meta.target) html += ' Source: ' + meta.source + ' Target: ' + meta.target;
- update = function(el) {
- var slotEl = el.getElementsByClassName('slot-' + meta.slot);
- if (!slotEl.length) {
- slotEl = document.createElement('div');
- slotEl.className = 'slot-' + meta.slot;
- el.appendChild(slotEl);
- } else {
- slotEl = slotEl[0];
- }
- slotEl.innerHTML = html;
- };
+ switch (type) {
+ case 1:
+ // FFT data
+ if (fft_compression=="none") {
+ waterfall_add_queue(new Float32Array(data));
+ } else if (fft_compression == "adpcm") {
+ fft_codec.reset();
+
+ var waterfall_i16=fft_codec.decode(new Uint8Array(data));
+ var waterfall_f32=new Float32Array(waterfall_i16.length-COMPRESS_FFT_PAD_N);
+ for(var i=0;iaudio_buffering_fill_to)) audio_init()
+ break;
+ case 3:
+ // secondary FFT
+ if (fft_compression == "none") {
+ secondary_demod_waterfall_add_queue(new Float32Array(data));
+ } else if (fft_compression == "adpcm") {
+ fft_codec.reset();
- metaPanels.forEach(update);
+ var waterfall_i16=fft_codec.decode(new Uint8Array(data));
+ var waterfall_f32=new Float32Array(waterfall_i16.length-COMPRESS_FFT_PAD_N);
+ for(var i=0;i44100*4)
audio_buffer_size = 4096 * 4;
- audio_rebuffer = new sdrjs.Rebuffer(audio_buffer_size,sdrjs.REBUFFER_FIXED);
- audio_last_output_buffer = new Float32Array(audio_buffer_size);
+ if (!audio_rebuffer) {
+ audio_rebuffer = new sdrjs.Rebuffer(audio_buffer_size,sdrjs.REBUFFER_FIXED);
+ audio_last_output_buffer = new Float32Array(audio_buffer_size);
- //we send our setup packet
- parsehash();
+ //we send our setup packet
+ parsehash();
- audio_calculate_resampling(audio_context.sampleRate);
- audio_resampler = new sdrjs.RationalResamplerFF(audio_client_resampling_factor,1);
- ws.send("SET output_rate="+audio_server_output_rate.toString()+" action=start"); //now we'll get AUD packets as well
+ audio_calculate_resampling(audio_context.sampleRate);
+ audio_resampler = new sdrjs.RationalResamplerFF(audio_client_resampling_factor,1);
+ }
+ ws.send(JSON.stringify({"type":"dspcontrol","action":"start","params":{"output_rate":audio_server_output_rate}}));
}
function audio_init()
@@ -1751,7 +1733,10 @@ function on_ws_closed()
audio_node.disconnect();
}
catch (dont_care) {}
- divlog("WebSocket has closed unexpectedly. Please reload the page.", 1);
+ audio_initialized = 0;
+ divlog("WebSocket has closed unexpectedly. Attempting to reconnect in 5 seconds...", 1);
+
+ setTimeout(open_websocket, 5000);
}
function on_ws_error(event)
@@ -1763,14 +1748,10 @@ String.prototype.startswith=function(str){ return this.indexOf(str) == 0; }; //h
function open_websocket()
{
- //if(ws_url.startswith("ws://localhost:")&&window.location.hostname!="127.0.0.1"&&window.location.hostname!="localhost")
- //{
- //divlog("Server administrator should set server_hostname correctly, because it is left as \"localhost\". Now guessing hostname from page URL.",1);
- ws_url="ws://"+(window.location.origin.split("://")[1])+"/ws/"; //guess automatically -> now default behaviour
- //}
+ ws_url="ws://"+(window.location.origin.split("://")[1])+"/ws/"; //guess automatically -> now default behaviour
if (!("WebSocket" in window))
divlog("Your browser does not support WebSocket, which is required for WebRX to run. Please upgrade to a HTML5 compatible browser.");
- ws = new WebSocket(ws_url+client_id);
+ ws = new WebSocket(ws_url);
ws.onopen = on_ws_opened;
ws.onmessage = on_ws_recv;
ws.onclose = on_ws_closed;
@@ -2023,27 +2004,23 @@ function waterfall_add(data)
waterfall_image.data[base+x*4+i] = ((color>>>0)>>((3-i)*8))&0xff;
}*/
- if(mathbox_mode==MATHBOX_MODES.WATERFALL)
- {
+ if (mathbox_mode==MATHBOX_MODES.WATERFALL) {
//Handle mathbox
for(var i=0;i>>0)>>((3-i)*8))&0xff;
- }
+ } else {
+ //Add line to waterfall image
+ oneline_image = canvas_context.createImageData(w,1);
+ for (x=0;x>>0)>>((3-i)*8))&0xff;
+ }
- //Draw image
- canvas_context.putImageData(oneline_image, 0, canvas_actual_line--);
- shift_canvases();
- if(canvas_actual_line<0) add_canvas();
+ //Draw image
+ canvas_context.putImageData(oneline_image, 0, canvas_actual_line--);
+ shift_canvases();
+ if(canvas_actual_line<0) add_canvas();
}
@@ -2272,7 +2249,7 @@ function openwebrx_init()
//Synchronise volume with slider
updateVolume();
- waterfallColorsDefault();
+
}
function iosPlayButtonClick()
@@ -2281,6 +2258,7 @@ function iosPlayButtonClick()
audio_init();
e("openwebrx-big-grey").style.opacity=0;
window.setTimeout(function(){ e("openwebrx-big-grey").style.display="none"; },1100);
+ audio_allowed = 1;
}
/*
@@ -2616,19 +2594,19 @@ function secondary_demod_init()
function secondary_demod_start(subtype)
{
secondary_demod_canvases_initialized = false;
- ws.send("SET secondary_mod="+subtype);
- secondary_demod = subtype;
+ ws.send(JSON.stringify({"type":"dspcontrol","params":{"secondary_mod":subtype}}));
+ secondary_demod = subtype;
}
function secondary_demod_set()
{
- ws.send("SET secondary_offset_freq="+secondary_demod_offset_freq.toString());
+ ws.send(JSON.stringify({"type":"dspcontrol","params":{"secondary_offset_freq":secondary_demod_offset_freq}}));
}
function secondary_demod_stop()
{
- ws.send("SET secondary_mod=off");
- secondary_demod = false;
+ ws.send(JSON.stringify({"type":"dspcontrol","params":{"secondary_mod":false}}));
+ secondary_demod = false;
secondary_demod_waterfall_queue = [];
}
@@ -2755,7 +2733,7 @@ function secondary_demod_update_channel_freq_from_event(evt)
{
secondary_demod_waiting_for_set = true;
window.setTimeout(()=>{
- ws.send("SET secondary_offset_freq="+Math.floor(secondary_demod_channel_freq));
+ ws.send(JSON.stringify({"type":"dspcontrol","params":{"secondary_offset_freq":Math.floor(secondary_demod_channel_freq)}}));
//console.log("doneset:", secondary_demod_channel_freq);
secondary_demod_waiting_for_set = false;
}, 50);
@@ -2815,3 +2793,8 @@ function secondary_demod_waterfall_set_zoom(low_cut, high_cut)
secondary_demod_canvases.map((x)=>{$(x).css("left",secondary_demod_canvas_left+"px").css("width",secondary_demod_canvas_width+"px");});
secondary_demod_update_channel_freq_from_event();
}
+
+function sdr_profile_changed() {
+ value = $('#openwebrx-sdr-profiles-listbox').val();
+ ws.send(JSON.stringify({ type:"selectprofile", params:{ profile:value }}));
+}
diff --git a/openwebrx.py b/openwebrx.py
old mode 100755
new mode 100644
index ed5af8c..99b1419
--- a/openwebrx.py
+++ b/openwebrx.py
@@ -1,757 +1,52 @@
-#!/usr/bin/python2
-print "" # python2.7 is required to run OpenWebRX instead of python3. Please run me by: python2 openwebrx.py
-"""
+from http.server import HTTPServer
+from owrx.http import RequestHandler
+from owrx.config import PropertyManager
+from owrx.feature import FeatureDetector
+from owrx.source import SdrService, ClientRegistry
+from socketserver import ThreadingMixIn
+from owrx.sdrhu import SdrHuUpdater
- This file is part of OpenWebRX,
- an open-source SDR receiver software with a web UI.
- Copyright (c) 2013-2015 by Andras Retzler
+import logging
+logging.basicConfig(level = logging.DEBUG, format = "%(asctime)s - %(name)s - %(levelname)s - %(message)s")
- This program is free software: you can redistribute it and/or modify
- it under the terms of the GNU Affero General Public License as
- published by the Free Software Foundation, either version 3 of the
- License, or (at your option) any later version.
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU Affero General Public License for more details.
-
- You should have received a copy of the GNU Affero General Public License
- along with this program. If not, see "
- print
+ print("""
- no_arguments=len(sys.argv)==1
- if no_arguments: print "[openwebrx-main] Configuration script not specified. I will use: \"config_webrx.py\""
- cfg=__import__("config_webrx" if no_arguments else sys.argv[1])
- for option in ("access_log","csdr_dynamic_bufsize","csdr_print_bufsizes","csdr_through"):
- if not option in dir(cfg): setattr(cfg, option, False) #initialize optional config parameters
+OpenWebRX - Open Source SDR Web App for Everyone! | for license see LICENSE file in the package
+_________________________________________________________________________________________________
- #Open log files
- logs = type("logs_class", (object,), {"access_log":open(cfg.access_log if cfg.access_log else "/dev/null","a"), "error_log":""})()
+Author contact info: Andras Retzler, HA7ILM
- #Set signal handler
- signal.signal(signal.SIGINT, handle_signal) #http://stackoverflow.com/questions/1112343/how-do-i-capture-sigint-in-python
- signal.signal(signal.SIGUSR1, handle_signal)
- signal.signal(signal.SIGUSR2, handle_signal)
+ """)
- #Pypy
- if pypy: print "pypy detected (and now something completely different: c code is expected to run at a speed of 3*10^8 m/s?)"
+ pm = PropertyManager.getSharedInstance().loadConfig("config_webrx")
- #Change process name to "openwebrx" (to be seen in ps)
- try:
- for libcpath in ["/lib/i386-linux-gnu/libc.so.6","/lib/libc.so.6"]:
- if os.path.exists(libcpath):
- libc = dl.open(libcpath)
- libc.call("prctl", 15, "openwebrx", 0, 0, 0)
- break
- except:
- pass
-
- #Start rtl thread
- if os.system("csdr 2> /dev/null") == 32512: #check for csdr
- print "[openwebrx-main] You need to install \"csdr\" to run OpenWebRX!\n"
+ featureDetector = FeatureDetector()
+ if not featureDetector.is_available("core"):
+ print("you are missing required dependencies to run openwebrx. "
+ "please check that the following core requirements are installed:")
+ print(", ".join(featureDetector.get_requirements("core")))
return
- if os.system("nmux --help 2> /dev/null") == 32512: #check for nmux
- print "[openwebrx-main] You need to install an up-to-date version of \"csdr\" that contains the \"nmux\" tool to run OpenWebRX! Please upgrade \"csdr\"!\n"
- return
- if cfg.start_rtl_thread:
- nmux_bufcnt = nmux_bufsize = 0
- while nmux_bufsize < cfg.samp_rate/4: nmux_bufsize += 4096
- while nmux_bufsize * nmux_bufcnt < cfg.nmux_memory * 1e6: nmux_bufcnt += 1
- if nmux_bufcnt == 0 or nmux_bufsize == 0:
- print "[openwebrx-main] Error: nmux_bufsize or nmux_bufcnt is zero. These depend on nmux_memory and samp_rate options in config_webrx.py"
- return
- print "[openwebrx-main] nmux_bufsize = %d, nmux_bufcnt = %d" % (nmux_bufsize, nmux_bufcnt)
- cfg.start_rtl_command += "| nmux --bufsize %d --bufcnt %d --port %d --address 127.0.0.1" % (nmux_bufsize, nmux_bufcnt, cfg.iq_server_port)
- rtl_thread=threading.Thread(target = lambda:subprocess.Popen(cfg.start_rtl_command, shell=True), args=())
- rtl_thread.start()
- print "[openwebrx-main] Started rtl_thread: "+cfg.start_rtl_command
- print "[openwebrx-main] Waiting for I/Q server to start..."
- while True:
- testsock=socket.socket()
- try: testsock.connect(("127.0.0.1", cfg.iq_server_port))
- except:
- time.sleep(0.1)
- continue
- testsock.close()
- break
- print "[openwebrx-main] I/Q server started."
- #Initialize clients
- clients=[]
- clients_mutex=threading.Lock()
- lock_try_time=0
+ # Get error messages about unknown / unavailable features as soon as possible
+ SdrService.loadProps()
- #Start watchdog thread
- print "[openwebrx-main] Starting watchdog threads."
- mutex_test_thread=threading.Thread(target = mutex_test_thread_function, args = ())
- mutex_test_thread.start()
- mutex_watchdog_thread=threading.Thread(target = mutex_watchdog_thread_function, args = ())
- mutex_watchdog_thread.start()
+ if "sdrhu_key" in pm and pm["sdrhu_public_listing"]:
+ updater = SdrHuUpdater()
+ updater.start()
+
+ server = ThreadedHttpServer(('0.0.0.0', pm.getPropertyValue("web_port")), RequestHandler)
+ server.serve_forever()
- #Start spectrum thread
- print "[openwebrx-main] Starting spectrum thread."
- spectrum_thread=threading.Thread(target = spectrum_thread_function, args = ())
- spectrum_thread.start()
- #spectrum_watchdog_thread=threading.Thread(target = spectrum_watchdog_thread_function, args = ())
- #spectrum_watchdog_thread.start()
-
- get_cpu_usage()
- bcastmsg_thread=threading.Thread(target = bcastmsg_thread_function, args = ())
- bcastmsg_thread.start()
-
- #threading.Thread(target = measure_thread_function, args = ()).start()
-
- #Start sdr.hu update thread
- if sdrhu and cfg.sdrhu_key and cfg.sdrhu_public_listing:
- print "[openwebrx-main] Starting sdr.hu update thread..."
- avatar_ctime=str(os.path.getctime("htdocs/gfx/openwebrx-avatar.png"))
- sdrhu_thread=threading.Thread(target = sdrhu.run, args = ())
- sdrhu_thread.start()
-
- #Start HTTP thread
- httpd = MultiThreadHTTPServer(('', cfg.web_port), WebRXHandler)
- print('[openwebrx-main] Starting HTTP server.')
- access_log("Starting OpenWebRX...")
- httpd.serve_forever()
-
-
-# This is a debug function below:
-measure_value=0
-def measure_thread_function():
- global measure_value
- while True:
- print "[openwebrx-measure] value is",measure_value
- measure_value=0
- time.sleep(1)
-
-def bcastmsg_thread_function():
- global clients
- while True:
- time.sleep(3)
- try: cpu_usage=get_cpu_usage()
- except: cpu_usage=0
- cma("bcastmsg_thread")
- for i in range(0,len(clients)):
- clients[i].bcastmsg="MSG cpu_usage={0} clients={1}".format(int(cpu_usage*100),len(clients))
- cmr()
-
-def mutex_test_thread_function():
- global clients_mutex, lock_try_time
- while True:
- time.sleep(0.5)
- lock_try_time=time.time()
- clients_mutex.acquire()
- clients_mutex.release()
- lock_try_time=0
-
-def cma(what): #clients_mutex acquire
- global clients_mutex
- global clients_mutex_locker
- if not clients_mutex.locked(): clients_mutex_locker = what
- clients_mutex.acquire()
-
-def cmr():
- global clients_mutex
- global clients_mutex_locker
- clients_mutex_locker = None
- clients_mutex.release()
-
-def mutex_watchdog_thread_function():
- global lock_try_time
- global clients_mutex_locker
- global clients_mutex
- while True:
- if lock_try_time != 0 and time.time()-lock_try_time > 3.0:
- #if 3 seconds pass without unlock
- print "[openwebrx-mutex-watchdog] Mutex unlock timeout. Locker: \""+str(clients_mutex_locker)+"\" Now unlocking..."
- clients_mutex.release()
- time.sleep(0.5)
-
-def spectrum_watchdog_thread_function():
- global spectrum_thread_watchdog_last_tick, receiver_failed
- while True:
- time.sleep(60)
- if spectrum_thread_watchdog_last_tick and time.time()-spectrum_thread_watchdog_last_tick > 60.0:
- print "[openwebrx-spectrum-watchdog] Spectrum timeout. Seems like no I/Q data is coming from the receiver.\nIf you're using RTL-SDR, the receiver hardware may randomly fail under some circumstances:\n1) high temperature,\n2) insufficient current available from the USB port."
- print "[openwebrx-spectrum-watchdog] Deactivating receiver."
- receiver_failed="spectrum"
- return
-
-def check_server():
- global spectrum_dsp, server_fail, rtl_thread
- if server_fail: return server_fail
- #print spectrum_dsp.process.poll()
- if spectrum_dsp and spectrum_dsp.process.poll()!=None: server_fail = "spectrum_thread dsp subprocess failed"
- #if rtl_thread and not rtl_thread.is_alive(): server_fail = "rtl_thread failed"
- if server_fail: print "[openwebrx-check_server] >>>>>>> ERROR:", server_fail
- return server_fail
-
-def apply_csdr_cfg_to_dsp(dsp):
- dsp.csdr_dynamic_bufsize = cfg.csdr_dynamic_bufsize
- dsp.csdr_print_bufsizes = cfg.csdr_print_bufsizes
- dsp.csdr_through = cfg.csdr_through
-
-def spectrum_thread_function():
- global clients, spectrum_dsp, spectrum_thread_watchdog_last_tick
- spectrum_dsp=dsp=csdr.dsp()
- dsp.nc_port=cfg.iq_server_port
- dsp.set_demodulator("fft")
- dsp.set_samp_rate(cfg.samp_rate)
- dsp.set_fft_size(cfg.fft_size)
- dsp.set_fft_fps(cfg.fft_fps)
- dsp.set_fft_averages(int(round(1.0 * cfg.samp_rate / cfg.fft_size / cfg.fft_fps / (1.0 - cfg.fft_voverlap_factor))) if cfg.fft_voverlap_factor>0 else 0)
- dsp.set_fft_compression(cfg.fft_compression)
- dsp.set_format_conversion(cfg.format_conversion)
- apply_csdr_cfg_to_dsp(dsp)
- sleep_sec=0.87/cfg.fft_fps
- print "[openwebrx-spectrum] Spectrum thread initialized successfully."
- dsp.start()
- if cfg.csdr_dynamic_bufsize:
- dsp.read_async(8) #dummy read to skip bufsize & preamble
- print "[openwebrx-spectrum] Note: CSDR_DYNAMIC_BUFSIZE_ON = 1"
- print "[openwebrx-spectrum] Spectrum thread started."
- bytes_to_read=int(dsp.get_fft_bytes_to_read())
- spectrum_thread_counter=0
- while True:
- data=dsp.read_async(bytes_to_read)
- if data is None:
- time.sleep(.01)
- continue
- #print "gotcha",len(data),"bytes of spectrum data via spectrum_thread_function()"
- if spectrum_thread_counter >= cfg.fft_fps:
- spectrum_thread_counter=0
- spectrum_thread_watchdog_last_tick = time.time() #once every second
- else: spectrum_thread_counter+=1
- cma("spectrum_thread")
- correction=0
- for i in range(0,len(clients)):
- i-=correction
- if (clients[i].ws_started):
- if clients[i].spectrum_queue.full():
- print "[openwebrx-spectrum] client spectrum queue full, closing it."
- close_client(i, False)
- correction+=1
- else:
- clients[i].spectrum_queue.put([data]) # add new string by "reference" to all clients
- cmr()
-
-def get_client_by_id(client_id, use_mutex=True):
- global clients
- output=-1
- if use_mutex: cma("get_client_by_id")
- for i in range(0,len(clients)):
- if(clients[i].id==client_id):
- output=i
- break
- if use_mutex: cmr()
- if output==-1:
- raise ClientNotFoundException
- else:
- return output
-
-def log_client(client, what):
- print "[openwebrx-httpd] client {0}#{1} :: {2}".format(client.ip,client.id,what)
-
-def cleanup_clients(end_all=False):
- # - if a client doesn't open websocket for too long time, we drop it
- # - or if end_all is true, we drop all clients
- global clients
- cma("cleanup_clients")
- correction=0
- for i in range(0,len(clients)):
- i-=correction
- #print "cleanup_clients:: len(clients)=", len(clients), "i=", i
- if end_all or ((not clients[i].ws_started) and (time.time()-clients[i].gen_time)>45):
- if not end_all: print "[openwebrx] cleanup_clients :: client timeout to open WebSocket"
- close_client(i, False)
- correction+=1
- cmr()
-
-def generate_client_id(ip):
- #add a client
- global clients
- new_client=namedtuple("ClientStruct", "id gen_time ws_started sprectum_queue ip closed bcastmsg dsp loopstat")
- new_client.id=md5.md5(str(random.random())).hexdigest()
- new_client.gen_time=time.time()
- new_client.ws_started=False # to check whether client has ever tried to open the websocket
- new_client.spectrum_queue=Queue.Queue(1000)
- new_client.ip=ip
- new_client.bcastmsg=""
- new_client.closed=[False] #byref, not exactly sure if required
- new_client.dsp=None
- cma("generate_client_id")
- clients.append(new_client)
- log_client(new_client,"client added. Clients now: {0}".format(len(clients)))
- cmr()
- cleanup_clients()
- return new_client.id
-
-def close_client(i, use_mutex=True):
- global clients
- log_client(clients[i],"client being closed.")
- if use_mutex: cma("close_client")
+if __name__ == "__main__":
try:
- clients[i].dsp.stop()
- except:
- exc_type, exc_value, exc_traceback = sys.exc_info()
- print "[openwebrx] close_client dsp.stop() :: error -",exc_type,exc_value
- traceback.print_tb(exc_traceback)
- clients[i].closed[0]=True
- access_log("Stopped streaming to client: "+clients[i].ip+"#"+str(clients[i].id)+" (users now: "+str(len(clients)-1)+")")
- del clients[i]
- if use_mutex: cmr()
-
-# http://www.codeproject.com/Articles/462525/Simple-HTTP-Server-and-Client-in-Python
-# some ideas are used from the artice above
-
-class WebRXHandler(BaseHTTPRequestHandler):
- def proc_read_thread():
- pass
-
- def send_302(self,what):
- self.send_response(302)
- self.send_header('Content-type','text/html')
- self.send_header("Location", "http://{0}:{1}/{2}".format(cfg.server_hostname,cfg.web_port,what))
- self.end_headers()
- self.wfile.write("
-
- This program is free software: you can redistribute it and/or modify
- it under the terms of the GNU Affero General Public License as
- published by the Free Software Foundation, either version 3 of the
- License, or (at your option) any later version.
-
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU Affero General Public License for more details.
-
- You should have received a copy of the GNU Affero General Public License
- along with this program. If not, see
---.--- MHz
---.--- MHz
+
+
+
@@ -118,23 +107,23 @@
- 
+ 
- 
+ 
- 
+ 
- 
+ 
- 
- 
- 
- 
- 
+ 
+ 
+ 
+ 
+ 
0 dB
@@ -160,7 +149,7 @@
-
+
Under construction
We're working on the code right now, so the application might fail.
@@ -182,7 +171,7 @@
We're working on the code right now, so the application might fail.
- 
+ 
Start OpenWebRX
+
Start OpenWebRX