2021-03-27 16:22:48 -04:00
#!/usr/bin/python
# -*- coding: utf-8 -*-
# NRSC5 DUI - A graphical interface for nrsc5
2021-04-02 05:49:38 -04:00
# Copyright (C) 2017-2019 Cody Nybo & Clayton Smith, 2019 zefie, 2021 Mark J. Fine
2021-03-27 16:22:48 -04:00
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU 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 General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
# Updated by zefie for modern nrsc5 ~ 2019
# Updated and enhanced by markjfine ~ 2021
#import os, sys, shutil, re, gtk, gobject, json, datetime, numpy, glob, time, platform
2021-03-28 14:52:44 -04:00
import os , pty , select , sys , shutil , re , json , datetime , numpy , glob , time , platform
2021-03-27 16:22:48 -04:00
from subprocess import Popen , PIPE
from threading import Timer , Thread
from dateutil import tz
from PIL import Image , ImageFont , ImageDraw
import gi
gi . require_version ( " Gtk " , " 3.0 " )
from gi . repository import Gtk , GObject , Gdk , GdkPixbuf , GLib
2021-04-02 15:21:18 -04:00
import urllib3
from OpenSSL import SSL
2021-03-27 16:22:48 -04:00
# print debug messages to stdout (if debugger is attached)
debugMessages = ( sys . gettrace ( ) != None )
debugAutoStart = True
if hasattr ( sys , ' frozen ' ) :
runtimeDir = os . path . dirname ( sys . executable ) # for py2exe
else :
runtimeDir = sys . path [ 0 ]
aasDir = os . path . join ( runtimeDir , " aas " ) # aas (data from nrsc5) file directory
mapDir = os . path . join ( runtimeDir , " map " ) # map (data we process) file directory
resDir = os . path . join ( runtimeDir , " res " ) # resource (application dependencies) file directory
cfgDir = os . path . join ( runtimeDir , " cfg " ) # config file directory
class NRSC5_DUI ( object ) :
def __init__ ( self ) :
2021-04-08 08:46:07 -04:00
global runtimeDir , resDir
2021-03-27 16:22:48 -04:00
#gobject.threads_init()
2021-04-01 18:17:21 -04:00
#Gdk.threads_init()
2021-03-27 16:22:48 -04:00
self . windowsOS = False # save our determination as a var in case we change how we determine.
self . getControls ( ) # get controls and windows
self . initStreamInfo ( ) # initilize stream info and clear status widgets
2021-04-02 15:21:18 -04:00
self . http = urllib3 . PoolManager ( )
2021-04-19 16:17:23 -04:00
# self.headers = urllib3.util.make_headers(keep_alive=True, accept_encoding=True, user_agent="Mozilla/5.0 (Macintosh; Intel Mac OS X 10.15; rv:87.0) Gecko/20100101 Firefox/87.0")
2021-03-27 16:22:48 -04:00
self . debugLog ( " Local path determined as " + runtimeDir )
if ( platform . system ( ) == ' Windows ' ) :
# Windows release layout
self . windowsOS = True
self . binDir = os . path . join ( runtimeDir , " bin " ) # windows binaries directory
self . nrsc5Path = os . path . join ( self . binDir , ' nrsc5.exe ' )
else :
# Linux/Mac/proper posix
# if nrsc5 and transcoder are not in the system path, set the full path here
2021-04-01 10:45:06 -04:00
arg1 = " "
if ( len ( sys . argv [ 1 : ] ) > 0 ) :
arg1 = sys . argv [ 1 ] . strip ( )
self . nrsc5Path = arg1 + " nrsc5 "
2021-03-27 16:22:48 -04:00
self . debugLog ( " OS Determination: Windows = {} " . format ( self . windowsOS ) )
self . mapFile = os . path . join ( resDir , " map.png " )
self . defaultSize = [ 490 , 250 ] # default width,height of main app
self . nrsc5 = None # nrsc5 process
2021-03-28 14:52:44 -04:00
self . nrsc5master = None
self . nrsc5slave = None
2021-03-27 16:22:48 -04:00
self . playerThread = None # player thread
self . playing = False # currently playing
self . statusTimer = None # status update timer
self . imageChanged = False # has the album art changed
self . xhdrChanged = False # has the HDDR data changed
self . nrsc5Args = [ ] # arguments for nrsc5
self . logFile = None # nrsc5 log file
self . lastImage = " " # last image file displayed
self . coverImage = " "
2021-04-02 15:21:18 -04:00
self . id3Changed = False
2021-03-28 02:09:32 -04:00
#self.lastXHDR = ["", -1] # the last XHDR data received
self . lastXHDR = " " # the last XHDR data received
2021-04-20 13:52:52 -04:00
self . lastLOT = " " # the last LOT received with XHDR
2021-03-27 16:22:48 -04:00
self . stationStr = " " # current station frequency (string)
2021-03-28 02:09:32 -04:00
self . streamNum = 0 # current station stream number
2021-03-28 14:52:44 -04:00
self . nrsc5msg = " " # send key command to nrsc5 (streamNum)
2021-03-27 16:22:48 -04:00
self . update_btns = True
self . set_program_btns ( )
self . bookmarks = [ ] # station bookmarks
2021-04-01 16:05:47 -04:00
self . booknames = [ " " , " " , " " , " " ] # station bookmark names
2021-03-27 16:22:48 -04:00
self . stationLogos = { } # station logos
self . bookmarked = False # is current station bookmarked
self . mapViewer = None # map viewer window
self . weatherMaps = [ ] # list of current weathermaps sorted by time
self . waittime = 10 # time in seconds to wait for file to exist
self . waitdivider = 4 # check this many times per second for file
self . pixbuf = None # store image buffer for rescaling on resize
self . mimeTypes = { # as defined by iHeartRadio anyway, defined here for possible future use
" 4F328CA0 " : [ " image/png " , " png " ] ,
" 1E653E9C " : [ " image/jpg " , " jpg " ] ,
" BB492AAC " : [ " text/plain " , " txt " ]
}
self . mapData = {
" mapMode " : 1 ,
" mapTiles " : [ [ 0 , 0 , 0 ] , [ 0 , 0 , 0 ] , [ 0 , 0 , 0 ] ] ,
" mapComplete " : False ,
" weatherTime " : 0 ,
" weatherPos " : [ 0 , 0 , 0 , 0 ] ,
" weatherNow " : " " ,
" weatherID " : " " ,
" viewerConfig " : {
" mode " : 1 ,
" animate " : False ,
" scale " : True ,
" windowPos " : ( 0 , 0 ) ,
" windowSize " : ( 764 , 632 ) ,
" animationSpeed " : 0.5
}
}
self . ServiceDataType = {
0 : " Non_Specific " ,
1 : " News " ,
3 : " Sports " ,
29 : " Weather " ,
31 : " Emergency " ,
65 : " Traffic " ,
66 : " Image Maps " ,
80 : " Text " ,
256 : " Advertising " ,
257 : " Financial " ,
258 : " Stock Ticker " ,
259 : " Navigation " ,
260 : " Electronic Program Guide " ,
261 : " Audio " ,
262 : " Private Data Network " ,
263 : " Service Maintenance " ,
264 : " HD Radio System Services " ,
2021-03-28 14:52:44 -04:00
265 : " Audio-Related Objects " ,
2021-03-27 16:22:48 -04:00
511 : " Test_Str_E "
}
self . ProgramType = {
2021-03-28 14:52:44 -04:00
0 : " None " ,
2021-03-27 16:22:48 -04:00
1 : " News " ,
2 : " Information " ,
3 : " Sports " ,
4 : " Talk " ,
5 : " Rock " ,
6 : " Classic Rock " ,
7 : " Adult Hits " ,
8 : " Soft Rock " ,
9 : " Top 40 " ,
10 : " Country " ,
11 : " Oldies " ,
12 : " Soft " ,
13 : " Nostalgia " ,
14 : " Jazz " ,
15 : " Classical " ,
2021-03-28 14:52:44 -04:00
16 : " Rhythm and Blues " ,
17 : " Soft Rhythm and Blues " ,
2021-03-27 16:22:48 -04:00
18 : " Foreign Language " ,
19 : " Religious Music " ,
20 : " Religious Talk " ,
21 : " Personality " ,
22 : " Public " ,
23 : " College " ,
24 : " Spanish Talk " ,
25 : " Spanish Music " ,
2021-03-28 14:52:44 -04:00
26 : " Hip-Hop " ,
2021-03-27 16:22:48 -04:00
29 : " Weather " ,
30 : " Emergency Test " ,
31 : " Emergency " ,
65 : " Traffic " ,
76 : " Special Reading Services "
}
2021-03-31 10:44:30 -04:00
self . pointer_cursor = Gdk . Cursor ( Gdk . CursorType . LEFT_PTR )
self . hand_cursor = Gdk . Cursor ( Gdk . CursorType . HAND2 )
2021-04-01 18:17:21 -04:00
#self.missing_image = Gtk.Image.new_from_icon_name("MISSING_IMAGE",Gtk.IconSize.LARGE_TOOLBAR)
2021-03-31 10:44:30 -04:00
2021-03-27 16:22:48 -04:00
# set events on info labels
2021-03-31 10:44:30 -04:00
self . set_tuning_actions ( self . btnAudioPrgs0 , " btn_prg0 " , False , False )
self . set_tuning_actions ( self . btnAudioPrgs1 , " btn_prg1 " , False , False )
self . set_tuning_actions ( self . btnAudioPrgs2 , " btn_prg2 " , False , False )
self . set_tuning_actions ( self . btnAudioPrgs3 , " btn_prg3 " , False , False )
self . set_tuning_actions ( self . lblAudioPrgs0 , " prg0 " , True , True )
self . set_tuning_actions ( self . lblAudioPrgs1 , " prg1 " , True , True )
self . set_tuning_actions ( self . lblAudioPrgs2 , " prg2 " , True , True )
self . set_tuning_actions ( self . lblAudioPrgs3 , " prg3 " , True , True )
self . set_tuning_actions ( self . lblAudioSvcs0 , " svc0 " , True , True )
self . set_tuning_actions ( self . lblAudioSvcs1 , " svc1 " , True , True )
self . set_tuning_actions ( self . lblAudioSvcs2 , " svc2 " , True , True )
self . set_tuning_actions ( self . lblAudioSvcs3 , " svc3 " , True , True )
2021-03-27 16:22:48 -04:00
# setup bookmarks listview
nameRenderer = Gtk . CellRendererText ( )
nameRenderer . set_property ( " editable " , True )
nameRenderer . connect ( " edited " , self . on_bookmarkNameEdited )
colStation = Gtk . TreeViewColumn ( " Station " , Gtk . CellRendererText ( ) , text = 0 )
colName = Gtk . TreeViewColumn ( " Name " , nameRenderer , text = 1 )
colStation . set_resizable ( True )
colStation . set_sort_column_id ( 2 )
colName . set_resizable ( True )
colName . set_sort_column_id ( 1 )
self . lvBookmarks . append_column ( colStation )
self . lvBookmarks . append_column ( colName )
# regex for getting nrsc5 output
self . regex = [
#re.compile("^.*main\.c:[\d]+: Station name: (.*)$"), # 0 match station name
#re.compile("^.*main\.c:[\d]+: Station location: (-?[\d]+\.[\d]+) (-?[\d]+\.[\d]+), ([\d]+)m$"), # 1 match station location
#re.compile("^.*main\.c:[\d]+: Slogan: (.*)$"), # 2 match station slogan
#re.compile("^.*main\.c:[\d]+: Audio bit rate: (.*) kbps$"), # 3 match audio bit rate
#re.compile("^.*main\.c:[\d]+: Title: (.*)$"), # 4 match title
#re.compile("^.*main\.c:[\d]+: Artist: (.*)$"), # 5 match artist
#re.compile("^.*main\.c:[\d]+: Album: (.*)$"), # 6 match album
#re.compile("^.*main\.c:[\d]+: LOT file: port=([\d]+) lot=([\d]+) name=(.*\.(?:jpg|png|txt)) size=([\d]+) mime=([\w]+)$"), # 7 match file (album art, maps, weather info)
#re.compile("^.*main\.c:[\d]+: MER: (-?[\d]+\.[\d]+) dB \(lower\), (-?[\d]+\.[\d]+) dB \(upper\)$"), # 8 match MER
#re.compile("^.*main\.c:[\d]+: BER: (0\.[\d]+), avg: (0\.[\d]+), min: (0\.[\d]+), max: (0\.[\d]+)$"), # 9 match BER
#re.compile("^.*nrsc5\.c:[\d]+: Best gain: (.*) dB,.*$"), # 10 match gain
#re.compile("^.*main\.c:[\d]+: SIG Service: type=(.*) number=(.*) name=(.*)$"), # 11 match stream
#re.compile("^.*main\.c:[\d]+: .*Data component:.* port=([\d]+).* type=([\d]+) .*$"), # 12 match port
#re.compile("^.*main\.c:[\d]+: XHDR: .* ([0-9A-Fa-f]{8}) (.*)$"), # 13 match xhdr tag
#re.compile("^.*main\.c:[\d]+: Unique file identifier: PPC;07; ([\S]+).*$") # 14 match unique file id
re . compile ( " ^[0-9 \ :] { 8,8} Station name: (.*)$ " ) , # 0 match station name
re . compile ( " ^[0-9 \ :] { 8,8} Station location: (-?[ \ d]+ \ .[ \ d]+) (-?[ \ d]+ \ .[ \ d]+), ([ \ d]+)m$ " ) , # 1 match station location
re . compile ( " ^[0-9 \ :] { 8,8} Slogan: (.*)$ " ) , # 2 match station slogan
re . compile ( " ^[0-9 \ :] { 8,8} Audio bit rate: (.*) kbps$ " ) , # 3 match audio bit rate
re . compile ( " ^[0-9 \ :] { 8,8} Title: (.*)$ " ) , # 4 match title
re . compile ( " ^[0-9 \ :] { 8,8} Artist: (.*)$ " ) , # 5 match artist
re . compile ( " ^[0-9 \ :] { 8,8} Album: (.*)$ " ) , # 6 match album
2021-04-19 16:17:23 -04:00
re . compile ( " ^[0-9 \ :] { 8,8} LOT file: port=([ \ d]+) lot=([ \ d]+) name=(.* \ .(?:jpg|jpeg|png|txt)) size=([ \ d]+) mime=([ \ w]+)$ " ) , # 7 match file (album art, maps, weather info)
2021-03-27 16:22:48 -04:00
re . compile ( " ^[0-9 \ :] { 8,8} MER: (-?[ \ d]+ \ .[ \ d]+) dB \ (lower \ ), (-?[ \ d]+ \ .[ \ d]+) dB \ (upper \ )$ " ) , # 8 match MER
re . compile ( " ^[0-9 \ :] { 8,8} BER: (0 \ .[ \ d]+), avg: (0 \ .[ \ d]+), min: (0 \ .[ \ d]+), max: (0 \ .[ \ d]+)$ " ) , # 9 match BER
re . compile ( " ^[0-9 \ :] { 8,8} Best gain: (.*) dB,.*$ " ) , # 10 match gain
re . compile ( " ^[0-9 \ :] { 8,8} SIG Service: type=(.*) number=(.*) name=(.*)$ " ) , # 11 match stream
re . compile ( " ^[0-9 \ :] { 8,8} .*Data component:.* id=([ \ d]+).* port=([ \ d]+).* service_data_type=([ \ d]+) .*$ " ) , # 12 match port (and data_service_type)
2021-03-28 02:09:32 -04:00
re . compile ( " ^[0-9 \ :] { 8,8} XHDR: (.*) ([0-9A-Fa-f] {8} ) (.*)$ " ) , # 13 match xhdr tag
2021-03-27 16:22:48 -04:00
re . compile ( " ^[0-9 \ :] { 8,8} Unique file identifier: PPC;07; ([ \ S]+).*$ " ) , # 14 match unique file id
re . compile ( " ^[0-9 \ :] { 8,8} Genre: (.*)$ " ) , # 15 match genre
re . compile ( " ^[0-9 \ :] { 8,8} Message: (.*)$ " ) , # 16 match message
re . compile ( " ^[0-9 \ :] { 8,8} Alert: (.*)$ " ) , # 17 match alert
re . compile ( " ^[0-9 \ :] { 8,8} .*Audio component:.* id=([ \ d]+).* port=([ \ d]+).* type=([ \ d]+) .*$ " ) , # 18 match port (and type)
re . compile ( " ^[0-9 \ :] { 8,8} Synchronized$ " ) , # 19 synchronized
re . compile ( " ^[0-9 \ :] { 8,8} Lost synchronization$ " ) , # 20 lost synch
2021-04-07 07:47:26 -04:00
re . compile ( " ^[0-9 \ :] { 8,8} Lost device$ " ) , # 21 lost device
re . compile ( " ^[0-9 \ :] { 8,8} Open device failed.$ " ) # 22 No device
2021-03-27 16:22:48 -04:00
]
self . loadSettings ( )
self . proccessWeatherMaps ( )
#self..connect('check-resize',self.on_window_resized) # TODO: fix on resize infinite loop
2021-03-28 14:52:44 -04:00
# set up pty
self . nrsc5master , self . nrsc5slave = pty . openpty ( )
2021-03-27 16:22:48 -04:00
2021-03-31 10:44:30 -04:00
def set_tuning_actions ( self , widget , name , has_win , set_curs ) :
widget . set_property ( " name " , name )
2021-04-06 16:26:20 -04:00
widget . set_sensitive ( False )
2021-03-31 10:44:30 -04:00
if has_win :
widget . set_has_window ( True )
widget . set_events ( Gdk . EventMask . BUTTON_PRESS_MASK )
widget . connect ( " button-press-event " , self . on_program_select )
if set_curs :
widget . add_events ( Gdk . EventMask . ENTER_NOTIFY_MASK )
widget . connect ( " enter-notify-event " , self . on_enter_set_cursor )
def on_enter_set_cursor ( self , widget , event ) :
if ( widget . get_label ( ) != " " ) :
widget . get_window ( ) . set_cursor ( self . hand_cursor )
2021-03-27 16:22:48 -04:00
def img_to_pixbuf ( self , img ) :
""" convert PIL.Image to GdkPixbuf.Pixbuf """
data = GLib . Bytes . new ( img . tobytes ( ) )
return GdkPixbuf . Pixbuf . new_from_bytes ( data , GdkPixbuf . Colorspace . RGB , ' A ' in img . getbands ( ) , 8 , img . width , img . height , len ( img . getbands ( ) ) * img . width )
def on_cover_resize ( self , container ) :
global mapDir
if self . coverImage != " " :
2021-04-05 09:26:11 -04:00
#img_size = min(self.alignmentCover.get_allocated_height(), self.alignmentCover.get_allocated_width()) - 12
#pixbuf = GdkPixbuf.Pixbuf.new_from_file(self.coverImage)
#pixbuf = pixbuf.scale_simple(img_size, img_size, GdkPixbuf.InterpType.BILINEAR)
#self.imgCover.set_from_pixbuf(pixbuf)
self . showArtwork ( self . coverImage )
2021-03-27 16:22:48 -04:00
img_size = min ( self . alignmentMap . get_allocated_height ( ) , self . alignmentMap . get_allocated_width ( ) ) - 12
if ( self . mapData [ " mapMode " ] == 0 ) :
map_file = os . path . join ( mapDir , " TrafficMap.png " )
if os . path . isfile ( map_file ) :
map_img = Image . open ( map_file ) . resize ( ( img_size , img_size ) , Image . LANCZOS )
self . imgMap . set_from_pixbuf ( self . img_to_pixbuf ( map_img ) )
else :
2021-04-01 18:17:21 -04:00
#self.imgMap.set_from_stock(Gtk.STOCK_MISSING_IMAGE, Gtk.IconSize.LARGE_TOOLBAR)
2021-04-03 17:19:54 -04:00
self . imgMap . set_from_icon_name ( " MISSING_IMAGE " , Gtk . IconSize . DIALOG )
2021-03-27 16:22:48 -04:00
elif ( self . mapData [ " mapMode " ] == 1 ) :
if os . path . isfile ( self . mapData [ " weatherNow " ] ) :
map_img = Image . open ( self . mapData [ " weatherNow " ] ) . resize ( ( img_size , img_size ) , Image . LANCZOS )
self . imgMap . set_from_pixbuf ( self . img_to_pixbuf ( map_img ) )
else :
2021-04-01 18:17:21 -04:00
#self.imgMap.set_from_stock(Gtk.STOCK_MISSING_IMAGE, Gtk.IconSize.LARGE_TOOLBAR)
2021-04-03 17:19:54 -04:00
self . imgMap . set_from_icon_name ( " MISSING_IMAGE " , Gtk . IconSize . DIALOG )
2021-03-27 16:22:48 -04:00
2021-04-02 15:21:18 -04:00
def id3_did_change ( self ) :
2021-04-19 16:17:23 -04:00
oldTitle = self . txtTitle . get_label ( ) . strip ( )
oldArtist = self . txtArtist . get_label ( ) . strip ( )
newTitle = self . streamInfo [ " Title " ] . strip ( )
newArtist = self . streamInfo [ " Artist " ] . strip ( )
2021-04-02 15:21:18 -04:00
return ( ( newArtist != oldArtist ) and ( newTitle != oldTitle ) )
def get_cover_data ( self , response ) :
check = - 1
resultUrl = " "
resultArtist = " "
m = re . search ( r " card card_large float_fix " , response )
if ( m . start ( ) > - 1 ) :
response = response [ m . start ( ) : ]
m = re . search ( r " <img data-src= \" " , response )
if ( m . start ( ) > - 1 ) :
response = response [ m . start ( ) + 15 : ]
m = re . search ( r " \" " , response )
if ( m . start ( ) > - 1 ) :
resultUrl = response [ : m . start ( ) ]
response = response [ m . start ( ) + 1 : ]
m = re . search ( r " <span title= \" " , response )
if ( m . start ( ) > - 1 ) :
response = response [ m . start ( ) + 13 : ]
m = re . search ( r " \" " , response )
if ( m . start ( ) > - 1 ) :
resultArtist = response [ : m . start ( ) ]
response = response [ m . start ( ) + 1 : ]
check = 0
return check , response , resultUrl , resultArtist
2021-04-03 17:19:54 -04:00
def fix_artist ( self ) :
newArtist = self . streamInfo [ " Artist " ]
if ( " / " in newArtist ) :
m = re . search ( r " / " , newArtist )
if ( m . start ( ) > - 1 ) :
newArtist = newArtist [ : m . start ( ) ] . strip ( )
return newArtist
2021-04-02 15:21:18 -04:00
def get_cover_image_online ( self ) :
2021-04-08 08:46:07 -04:00
global aasDir
2021-04-02 15:21:18 -04:00
got_cover = False
# only change when there's a new ID3
2021-04-09 15:59:56 -04:00
#if (self.id3Changed):
# only care about the first artist listed if separated by slashes
newArtist = self . fix_artist ( )
baseStr = str ( newArtist + " - " + self . streamInfo [ " Title " ] ) . replace ( " / " , " _ " ) . replace ( " : " , " _ " )
saveStr = os . path . join ( aasDir , baseStr . replace ( " " , " _ " ) + " .jpg " )
searchStr = baseStr . replace ( " " , " + " )
# does it already exist?
if ( os . path . isfile ( saveStr ) ) :
self . coverImage = saveStr
# if not, get it from Discogs
else :
try :
searchStr = " https://www.discogs.com/search/?q= " + searchStr + " &type=all "
2021-04-19 16:17:23 -04:00
#r = self.http.request('GET', searchStr, self.headers)
r = self . http . request ( ' GET ' , searchStr )
2021-04-09 15:59:56 -04:00
if ( r . status == 200 ) :
response = r . data . decode ( ' utf-8 ' )
# loop through the page until you either get an artist match or you run out of page (check)
while ( not got_cover ) :
resultUrl = " "
resultArtist = " "
check , response , resultUrl , resultArtist = self . get_cover_data ( response )
got_cover = ( newArtist . lower ( ) in resultArtist . lower ( ) ) and ( check == 0 )
# if you got a match, save it
if ( resultUrl != " " ) :
with self . http . request ( ' GET ' , resultUrl , preload_content = False ) as r , open ( saveStr , ' wb ' ) as out_file :
if ( r . status == 200 ) :
shutil . copyfileobj ( r , out_file )
self . coverImage = saveStr
# If no match use the station logo if there is one
else :
self . coverImage = os . path . join ( aasDir , self . stationLogos [ self . stationStr ] [ self . streamNum ] )
except :
pass
# now display it by simulating a window resize
self . on_cover_resize ( self . mainWindow )
2021-04-02 15:21:18 -04:00
2021-04-05 09:26:11 -04:00
def showArtwork ( self , art ) :
img_size = min ( self . alignmentCover . get_allocated_height ( ) , self . alignmentCover . get_allocated_width ( ) ) - 12
self . pixbuf = GdkPixbuf . Pixbuf . new_from_file ( art )
self . pixbuf = self . pixbuf . scale_simple ( img_size , img_size , GdkPixbuf . InterpType . BILINEAR )
self . imgCover . set_from_pixbuf ( self . pixbuf )
2021-03-28 02:09:32 -04:00
def displayLogo ( self ) :
global aasDir
#if (self.stationLogos.has_key(self.stationStr)):
if ( self . stationStr in self . stationLogos ) :
# show station logo if it's cached
logo = os . path . join ( aasDir , self . stationLogos [ self . stationStr ] [ self . streamNum ] )
if ( os . path . isfile ( logo ) ) :
self . streamInfo [ " Logo " ] = self . stationLogos [ self . stationStr ] [ self . streamNum ]
2021-04-05 09:26:11 -04:00
#img_size = min(self.alignmentCover.get_allocated_height(), self.alignmentCover.get_allocated_width()) - 12
2021-03-28 02:09:32 -04:00
#self.pixbuf = Gtk.gdk.pixbuf_new_from_file(logo)
2021-04-05 09:26:11 -04:00
#self.pixbuf = GdkPixbuf.Pixbuf.new_from_file(logo)
2021-03-28 02:09:32 -04:00
self . coverImage = logo
#self.handle_window_resize()
2021-04-05 09:26:11 -04:00
#self.pixbuf = self.pixbuf.scale_simple(img_size, img_size, GdkPixbuf.InterpType.BILINEAR)
#self.imgCover.set_from_pixbuf(self.pixbuf)
self . showArtwork ( logo )
2021-03-28 02:09:32 -04:00
else :
# add entry in database for the station if it doesn't exist
self . stationLogos [ self . stationStr ] = [ " " , " " , " " , " " ]
2021-03-27 16:22:48 -04:00
def service_data_type_name ( self , type ) :
for key , value in self . ServiceDataType . items ( ) :
if ( key == type ) :
return value
def program_type_name ( self , type ) :
for key , value in self . ProgramType . items ( ) :
if ( key == type ) :
return value
def handle_window_resize ( self ) :
if ( self . pixbuf != None ) :
#allocation = self.imgCover.get_allocation()
#desired_width = int(allocation.width / 2.5)
#desired_height = desired_width
desired_size = min ( self . alignmentCover . get_allocated_height ( ) , self . alignmentCover . get_allocated_width ( ) ) - 12
#self.pixbuf = self.pixbuf.scale_simple(desired_width, desired_height, Gtk.gdk.INTERP_HYPER)
self . pixbuf = self . pixbuf . scale_simple ( desired_size , desired_size , GdkPixbuf . InterpType . BILINEAR )
self . imgCover . set_from_pixbuf ( self . pixbuf )
def on_window_resized ( self , window ) :
self . handle_window_resize ( )
def on_btnPlay_clicked ( self , btn ) :
global aasDir
# start playback
if ( not self . playing ) :
self . nrsc5Args = [ self . nrsc5Path ]
# update all of the spin buttons to prevent the text from sticking
self . spinFreq . update ( )
#self.spinStream.update()
self . spinGain . update ( )
self . spinPPM . update ( )
self . spinRTL . update ( )
# enable aas output if temp dir was created
if ( aasDir is not None ) :
self . nrsc5Args . append ( " --dump-aas-files " )
self . nrsc5Args . append ( aasDir )
2021-04-22 11:39:55 -04:00
# set IP address if rtl_tcp is used
if ( self . cbDevIP . get_active ( ) ) :
self . nrsc5Args . append ( " -H " )
self . nrsc5Args . append ( self . txtDevIP . get_text ( ) )
2021-03-27 16:22:48 -04:00
# set gain if auto gain is not selected
if ( not self . cbAutoGain . get_active ( ) ) :
self . streamInfo [ " Gain " ] = self . spinGain . get_value ( )
self . nrsc5Args . append ( " -g " )
#self.nrsc5Args.append(str(int(self.streamInfo["Gain"]*10)))
self . nrsc5Args . append ( str ( int ( self . streamInfo [ " Gain " ] ) ) )
# set ppm error if not zero
if ( self . spinPPM . get_value ( ) != 0 ) :
self . nrsc5Args . append ( " -p " )
self . nrsc5Args . append ( str ( int ( self . spinPPM . get_value ( ) ) ) )
# set rtl device number if not zero
if ( self . spinRTL . get_value ( ) != 0 ) :
self . nrsc5Args . append ( " -d " )
self . nrsc5Args . append ( str ( int ( self . spinRTL . get_value ( ) ) ) )
# set frequency and stream
self . nrsc5Args . append ( str ( self . spinFreq . get_value ( ) ) )
#self.nrsc5Args.append(str(int(self.spinStream.get_value()-1)))
2021-03-28 02:09:32 -04:00
self . nrsc5Args . append ( str ( int ( self . streamNum ) ) )
2021-03-27 16:22:48 -04:00
#print(self.nrsc5Args)
# start the timer
self . statusTimer = Timer ( 1 , self . checkStatus )
self . statusTimer . start ( )
# disable the controls
self . spinFreq . set_sensitive ( False )
#self.spinStream.set_sensitive(False)
self . spinGain . set_sensitive ( False )
self . spinPPM . set_sensitive ( False )
self . spinRTL . set_sensitive ( False )
self . btnPlay . set_sensitive ( False )
self . btnStop . set_sensitive ( True )
self . cbAutoGain . set_sensitive ( False )
self . playing = True
2021-03-28 02:09:32 -04:00
#self.lastXHDR = ["", -1]
self . lastXHDR = " "
2021-04-20 13:52:52 -04:00
self . lastLOT = " "
2021-04-19 16:17:23 -04:00
#print("lastXHDR reset")
2021-03-27 16:22:48 -04:00
# start the player thread
self . playerThread = Thread ( target = self . play )
self . playerThread . start ( )
self . stationStr = str ( self . spinFreq . get_value ( ) )
#self.stationNum = int(self.spinStream.get_value())-1
2021-03-28 02:09:32 -04:00
#self.set_program_btns()
self . displayLogo ( )
2021-03-27 16:22:48 -04:00
# check if station is bookmarked
self . bookmarked = False
#freq = int((self.spinFreq.get_value()+0.005)*100) + int(self.spinStream.get_value())
2021-03-28 02:09:32 -04:00
freq = int ( ( self . spinFreq . get_value ( ) + 0.005 ) * 100 ) + int ( self . streamNum + 1 )
2021-03-27 16:22:48 -04:00
for b in self . bookmarks :
if ( b [ 2 ] == freq ) :
self . bookmarked = True
break
2021-04-01 16:05:47 -04:00
self . get_bookmark_names ( )
2021-03-27 16:22:48 -04:00
self . btnBookmark . set_sensitive ( not self . bookmarked )
if ( self . notebookMain . get_current_page ( ) != 3 ) :
self . btnDelete . set_sensitive ( self . bookmarked )
2021-04-01 16:05:47 -04:00
def get_bookmark_names ( self ) :
self . booknames = [ " " , " " , " " , " " ]
freq = str ( int ( ( self . spinFreq . get_value ( ) + 0.005 ) * 10 ) )
for b in self . bookmarks :
test = str ( b [ 2 ] )
if ( test [ : - 1 ] == freq ) :
self . booknames [ int ( test [ - 1 ] ) - 1 ] = b [ 1 ]
2021-03-27 16:22:48 -04:00
def on_btnStop_clicked ( self , btn ) :
# stop playback
if ( self . playing ) :
self . playing = False
# shutdown nrsc5
if ( self . nrsc5 is not None and not self . nrsc5 . poll ( ) ) :
self . nrsc5 . terminate ( )
2021-04-07 07:47:26 -04:00
if ( self . playerThread is not None ) and ( btn is not None ) :
2021-03-27 16:22:48 -04:00
self . playerThread . join ( 1 )
# stop timer
self . statusTimer . cancel ( )
self . statusTimer = None
# enable controls
if ( not self . cbAutoGain . get_active ( ) ) :
self . spinGain . set_sensitive ( True )
self . spinFreq . set_sensitive ( True )
#self.spinStream.set_sensitive(True)
self . spinPPM . set_sensitive ( True )
self . spinRTL . set_sensitive ( True )
self . btnPlay . set_sensitive ( True )
self . btnStop . set_sensitive ( False )
self . btnBookmark . set_sensitive ( False )
self . cbAutoGain . set_sensitive ( True )
# clear stream info
self . initStreamInfo ( )
self . btnBookmark . set_sensitive ( False )
if ( self . notebookMain . get_current_page ( ) != 3 ) :
self . btnDelete . set_sensitive ( False )
def on_btnBookmark_clicked ( self , btn ) :
# pack frequency and channel number into one int
#freq = int((self.spinFreq.get_value()+0.005)*100) + int(self.spinStream.get_value())
2021-03-28 02:09:32 -04:00
freq = int ( ( self . spinFreq . get_value ( ) + 0.005 ) * 100 ) + int ( self . streamNum + 1 )
2021-03-27 16:22:48 -04:00
# create bookmark
bookmark = [
#"{:4.1f}-{:1.0f}".format(self.spinFreq.get_value(), self.spinStream.get_value()),
2021-03-28 02:09:32 -04:00
" {:4.1f} - {:1.0f} " . format ( self . spinFreq . get_value ( ) , self . streamNum + 1 ) ,
2021-03-27 16:22:48 -04:00
self . streamInfo [ " Callsign " ] ,
freq
]
self . bookmarked = True # mark as bookmarked
self . bookmarks . append ( bookmark ) # store bookmark in array
self . lsBookmarks . append ( bookmark ) # add bookmark to listview
self . btnBookmark . set_sensitive ( False ) # disable bookmark button
if ( self . notebookMain . get_current_page ( ) != 3 ) :
self . btnDelete . set_sensitive ( True ) # enable delete button
2021-04-01 16:05:47 -04:00
self . get_bookmark_names ( )
2021-03-27 16:22:48 -04:00
def on_btnDelete_clicked ( self , btn ) :
# select current station if not on bookmarks page
if ( self . notebookMain . get_current_page ( ) != 3 ) :
2021-03-28 02:09:32 -04:00
station = int ( ( self . spinFreq . get_value ( ) + 0.005 ) * 100 ) + int ( self . streamNum + 1 )
2021-03-27 16:22:48 -04:00
for i in range ( 0 , len ( self . lsBookmarks ) ) :
if ( self . lsBookmarks [ i ] [ 2 ] == station ) :
self . lvBookmarks . set_cursor ( i )
break
# get station of selected row
( model , iter ) = self . lvBookmarks . get_selection ( ) . get_selected ( )
station = model . get_value ( iter , 2 )
# remove row
model . remove ( iter )
# remove bookmark
for i in range ( 0 , len ( self . bookmarks ) ) :
if ( self . bookmarks [ i ] [ 2 ] == station ) :
self . bookmarks . pop ( i )
break
if ( self . notebookMain . get_current_page ( ) != 3 and self . playing ) :
self . btnBookmark . set_sensitive ( True )
self . bookmarked = False
2021-04-01 16:05:47 -04:00
self . get_bookmark_names ( )
2021-03-27 16:22:48 -04:00
def on_btnAbout_activate ( self , btn ) :
2021-04-08 08:46:07 -04:00
global resDir
2021-03-27 16:22:48 -04:00
# sets up and displays about dialog
if self . about_dialog :
self . about_dialog . present ( )
return
authors = [
2021-03-28 02:09:32 -04:00
" Cody Nybo <cmnybo@gmail.com> " ,
2021-04-02 06:00:54 -04:00
" Clayton Smith <argilo@gmail.com> " ,
" nefie <zefie@zefie.net> " ,
" Mark J. Fine <mark.fine@fineware-swl.com> "
2021-03-27 16:22:48 -04:00
]
license = """
2021-04-02 06:00:54 -04:00
NRSC5 DUI - A second - generation graphical interface for nrsc5
2021-04-02 05:49:38 -04:00
Copyright ( C ) 2017 - 2019 Cody Nybo & Clayton Smith , 2019 zefie , 2021 Mark J . Fine
2021-03-27 16:22:48 -04:00
This program is free software : you can redistribute it and / or modify
it under the terms of the GNU 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 General Public License for more details .
You should have received a copy of the GNU General Public License
along with this program . If not , see < http : / / www . gnu . org / licenses / > . """
about_dialog = Gtk . AboutDialog ( )
about_dialog . set_transient_for ( self . mainWindow )
about_dialog . set_destroy_with_parent ( True )
about_dialog . set_name ( " NRSC5 DUI " )
2021-04-02 06:00:54 -04:00
about_dialog . set_program_name ( " NRSC5 DUI " )
2021-03-27 16:22:48 -04:00
about_dialog . set_version ( " 2.1.0 " )
2021-03-28 02:09:32 -04:00
about_dialog . set_copyright ( " Copyright © 2017-2019 Cody Nybo & Clayton Smith, 2019 zefie, 2021 Mark J. Fine " )
2021-03-27 16:22:48 -04:00
about_dialog . set_website ( " https://github.com/markjfine/nrsc5-dui " )
2021-04-02 06:00:54 -04:00
about_dialog . set_comments ( " A second-generation graphical interface for nrsc5. " )
2021-03-27 16:22:48 -04:00
about_dialog . set_authors ( authors )
about_dialog . set_license ( license )
#about_dialog.set_logo(Gtk.gdk.pixbuf_new_from_file("logo.png"))
2021-04-08 08:46:07 -04:00
about_dialog . set_logo ( GdkPixbuf . Pixbuf . new_from_file ( os . path . join ( resDir , " logo.png " ) ) )
2021-03-27 16:22:48 -04:00
# callbacks for destroying the dialog
def close ( dialog , response , editor ) :
editor . about_dialog = None
dialog . destroy ( )
def delete_event ( dialog , event , editor ) :
editor . about_dialog = None
return True
about_dialog . connect ( " response " , close , self )
about_dialog . connect ( " delete-event " , delete_event , self )
self . about_dialog = about_dialog
about_dialog . show ( )
2021-03-28 02:09:32 -04:00
def on_stream_changed ( self ) :
self . lastXHDR = " "
2021-04-20 13:52:52 -04:00
self . lastLOT = " "
2021-03-28 02:09:32 -04:00
self . streamInfo [ " Title " ] = " "
self . streamInfo [ " Album " ] = " "
self . streamInfo [ " Artist " ] = " "
self . streamInfo [ " Genre " ] = " "
self . streamInfo [ " Cover " ] = " "
self . streamInfo [ " Logo " ] = " "
self . streamInfo [ " Bitrate " ] = 0
self . set_program_btns ( )
2021-04-19 16:17:23 -04:00
#print("lastXHDR, cover, and logo reset")
2021-03-28 14:52:44 -04:00
if self . playing :
self . nrsc5msg = str ( self . streamNum )
self . displayLogo ( )
2021-03-28 02:09:32 -04:00
#TODO: fix so stream change is smoother - should be able to pipe new stream number to running application and update display_logo()
# For now, just restart
2021-03-28 14:52:44 -04:00
#if (self.playing):
# self.on_btnStop_clicked(None)
# self.on_btnPlay_clicked(None)
2021-03-28 02:09:32 -04:00
2021-03-27 16:22:48 -04:00
def set_program_btns ( self ) :
2021-03-28 02:09:32 -04:00
self . btnAudioPrgs0 . set_active ( self . update_btns and self . streamNum == 0 )
self . btnAudioPrgs1 . set_active ( self . update_btns and self . streamNum == 1 )
self . btnAudioPrgs2 . set_active ( self . update_btns and self . streamNum == 2 )
self . btnAudioPrgs3 . set_active ( self . update_btns and self . streamNum == 3 )
2021-03-27 16:22:48 -04:00
self . update_btns = True
def on_program_select ( self , _label , evt ) :
stream_num = int ( _label . get_property ( " name " ) [ - 1 ] )
2021-03-31 10:44:30 -04:00
is_lbl = _label . get_property ( " name " ) [ 0 ] != " b "
self . update_btns = is_lbl
2021-03-28 02:09:32 -04:00
self . streamNum = stream_num
self . on_stream_changed ( )
2021-03-27 16:22:48 -04:00
def on_cbAutoGain_toggled ( self , btn ) :
self . spinGain . set_sensitive ( not btn . get_active ( ) )
self . lblGain . set_visible ( btn . get_active ( ) )
def on_listviewBookmarks_row_activated ( self , treeview , path , view_column ) :
if ( len ( path ) != 0 ) :
# get station from bookmark row
tree_iter = treeview . get_model ( ) . get_iter ( path [ 0 ] )
station = treeview . get_model ( ) . get_value ( tree_iter , 2 )
# set frequency and stream
self . spinFreq . set_value ( float ( int ( station / 10 ) / 10.0 ) )
#self.spinStream.set_value(station%10)
2021-03-28 02:09:32 -04:00
self . streamNum = ( station % 10 ) - 1
self . on_stream_changed ( )
2021-03-27 16:22:48 -04:00
# stop playback if playing
2021-03-28 02:09:32 -04:00
if ( self . playing ) :
self . on_btnStop_clicked ( None )
2021-04-08 10:21:41 -04:00
time . sleep ( 1 )
2021-03-27 16:22:48 -04:00
# play bookmarked station
self . on_btnPlay_clicked ( None )
def on_lvBookmarks_selection_changed ( self , tree_selection ) :
# enable delete button if bookmark is selected
( model , pathlist ) = self . lvBookmarks . get_selection ( ) . get_selected_rows ( )
self . btnDelete . set_sensitive ( len ( pathlist ) != 0 )
def on_bookmarkNameEdited ( self , cell , path , text , data = None ) :
# update name in listview
iter = self . lsBookmarks . get_iter ( path )
self . lsBookmarks . set ( iter , 1 , text )
# update name in bookmarks array
for b in self . bookmarks :
if ( b [ 2 ] == self . lsBookmarks [ path ] [ 2 ] ) :
b [ 1 ] = text
break
def on_notebookMain_switch_page ( self , notebook , page , page_num ) :
# disable delete button if not on bookmarks page and station is not bookmarked
if ( page_num != 3 and ( not self . bookmarked or not self . playing ) ) :
self . btnDelete . set_sensitive ( False )
# enable delete button if not on bookmarks page and station is bookmarked
elif ( page_num != 3 and self . bookmarked ) :
self . btnDelete . set_sensitive ( True )
# enable delete button if on bookmarks page and a bookmark is selected
else :
( model , iter ) = self . lvBookmarks . get_selection ( ) . get_selected ( )
self . btnDelete . set_sensitive ( iter is not None )
def on_radMap_toggled ( self , btn ) :
global mapDir
if ( btn . get_active ( ) ) :
if ( btn == self . radMapTraffic ) :
self . mapData [ " mapMode " ] = 0
mapFile = os . path . join ( mapDir , " TrafficMap.png " )
if ( os . path . isfile ( mapFile ) ) : # check if map exists
mapImg = Image . open ( mapFile ) . resize ( ( 200 , 200 ) , Image . LANCZOS ) # scale map to fit window
self . imgMap . set_from_pixbuf ( imgToPixbuf ( mapImg ) ) # convert image to pixbuf and display
else :
#self.imgMap.set_from_stock(Gtk.STOCK_MISSING_IMAGE, Gtk.ICON_SIZE_LARGE_TOOLBAR) # display missing image if file is not found
2021-04-01 18:17:21 -04:00
#self.imgMap.set_from_stock(Gtk.STOCK_MISSING_IMAGE, Gtk.IconSize.LARGE_TOOLBAR) # display missing image if file is not found
2021-04-03 17:19:54 -04:00
self . imgMap . set_from_icon_name ( " MISSING_IMAGE " , Gtk . IconSize . DIALOG )
2021-03-27 16:22:48 -04:00
elif ( btn == self . radMapWeather ) :
self . mapData [ " mapMode " ] = 1
if ( os . path . isfile ( self . mapData [ " weatherNow " ] ) ) :
mapImg = Image . open ( self . mapData [ " weatherNow " ] ) . resize ( ( 200 , 200 ) , Image . LANCZOS ) # scale map to fit window
self . imgMap . set_from_pixbuf ( imgToPixbuf ( mapImg ) ) # convert image to pixbuf and display
else :
#self.imgMap.set_from_stock(Gtk.STOCK_MISSING_IMAGE, Gtk.ICON_SIZE_LARGE_TOOLBAR) # display missing image if file is not found
2021-04-01 18:17:21 -04:00
#self.imgMap.set_from_stock(Gtk.STOCK_MISSING_IMAGE, Gtk.IconSize.LARGE_TOOLBAR) # display missing image if file is not found
2021-04-03 17:19:54 -04:00
self . imgMap . set_from_icon_name ( " MISSING_IMAGE " , Gtk . IconSize . DIALOG )
2021-03-27 16:22:48 -04:00
def on_btnMap_clicked ( self , btn ) :
# open map viewer window
if ( self . mapViewer is None ) :
self . mapViewer = NRSC5_Map ( self , self . mapViewerCallback , self . mapData )
self . mapViewer . mapWindow . show ( )
def mapViewerCallback ( self ) :
# delete the map viewer
self . mapViewer = None
def play ( self ) :
FNULL = open ( os . devnull , ' w ' )
FTMP = open ( ' tmp.log ' , ' w ' )
# run nrsc5 and output stdout & stderr to pipes
2021-03-28 14:52:44 -04:00
#self.nrsc5 = Popen(self.nrsc5Args, stdout=PIPE, stderr=PIPE, universal_newlines=True)
self . nrsc5 = Popen ( self . nrsc5Args , shell = False , stdin = self . nrsc5slave , stdout = PIPE , stderr = PIPE , universal_newlines = True )
2021-03-27 16:22:48 -04:00
while True :
2021-03-28 14:52:44 -04:00
# send input to nrsc5 if needed
if ( self . nrsc5msg != " " ) :
select . select ( [ ] , [ self . nrsc5master ] , [ ] )
os . write ( self . nrsc5master , str . encode ( self . nrsc5msg ) )
#print(self.nrsc5msg)
self . nrsc5msg = " "
2021-03-27 16:22:48 -04:00
# read output from nrsc5
output = self . nrsc5 . stderr . readline ( )
# parse the output
self . parseFeedback ( output )
# write output to log file if enabled
if ( self . cbLog . get_active ( ) and self . logFile is not None ) :
self . logFile . write ( output )
self . logFile . flush ( )
# check if nrsc5 has exited
if ( self . nrsc5 . poll ( ) and not self . playing ) :
# cleanup if shutdown
self . debugLog ( " Process Terminated " )
self . nrsc5 = None
break
elif ( self . nrsc5 . poll ( ) and self . playing ) :
# restart nrsc5 if it crashes
self . debugLog ( " Restarting NRSC5 " )
time . sleep ( 1 )
2021-03-28 20:48:01 -04:00
self . nrsc5 = Popen ( self . nrsc5Args , shell = False , stdin = self . nrsc5slave , stdout = PIPE , stderr = PIPE , universal_newlines = True )
2021-03-27 16:22:48 -04:00
def set_synchronization ( self , state ) :
self . imgNoSynch . set_visible ( state == 0 )
self . imgSynch . set_visible ( state == 1 )
self . imgLostDevice . set_visible ( state == - 1 )
2021-04-06 16:26:20 -04:00
def set_button_name ( self , btnWidget , lblWidget , stream ) :
2021-04-01 16:05:47 -04:00
temp = self . streamInfo [ " Streams " ] [ stream ]
if ( ( temp == " " ) or ( temp == " MPS " ) or ( temp [ 0 : 3 ] == " SPS " ) or ( temp [ 0 : 2 ] == " HD " ) ) :
if ( self . booknames [ stream ] != " " ) :
temp = self . booknames [ stream ]
2021-04-06 16:26:20 -04:00
lblWidget . set_label ( temp )
btnWidget . set_sensitive ( temp != " " )
def set_label_name ( self , lblWidget , inString , doSens ) :
lblWidget . set_label ( inString )
lblWidget . set_tooltip_text ( inString )
if ( doSens ) :
lblWidget . set_sensitive ( inString != " " )
2021-04-01 16:05:47 -04:00
2021-04-20 13:52:52 -04:00
def getImageLot ( self , imgStr ) :
r = re . compile ( " ^([ \ d]+)_.*$ " )
m = r . match ( imgStr )
#print("lot is "+m.group(1))
return m . group ( 1 )
2021-03-27 16:22:48 -04:00
def checkStatus ( self ) :
# update status information
def update ( ) :
2021-03-28 02:09:32 -04:00
global aasDir
2021-04-01 18:17:21 -04:00
#Gdk.threads_enter()
2021-03-27 16:22:48 -04:00
try :
imagePath = " "
image = " "
2021-03-28 02:09:32 -04:00
#ber = [self.streamInfo["BER"][0]*100,self.streamInfo["BER"][1]*100,self.streamInfo["BER"][2]*100,self.streamInfo["BER"][3]*100]
ber = [ self . streamInfo [ " BER " ] [ i ] * 100 for i in range ( 4 ) ]
2021-04-02 15:21:18 -04:00
self . id3Changed = self . id3_did_change ( )
2021-03-27 16:22:48 -04:00
self . txtTitle . set_text ( self . streamInfo [ " Title " ] )
2021-04-01 10:45:06 -04:00
self . txtTitle . set_tooltip_text ( self . streamInfo [ " Title " ] )
2021-03-27 16:22:48 -04:00
self . txtArtist . set_text ( self . streamInfo [ " Artist " ] )
2021-04-01 10:45:06 -04:00
self . txtArtist . set_tooltip_text ( self . streamInfo [ " Artist " ] )
2021-03-27 16:22:48 -04:00
self . txtAlbum . set_text ( self . streamInfo [ " Album " ] )
2021-04-01 10:45:06 -04:00
self . txtAlbum . set_tooltip_text ( self . streamInfo [ " Album " ] )
2021-03-27 16:22:48 -04:00
self . txtGenre . set_text ( self . streamInfo [ " Genre " ] )
2021-04-01 10:45:06 -04:00
self . txtGenre . set_tooltip_text ( self . streamInfo [ " Genre " ] )
2021-03-27 16:22:48 -04:00
self . lblBitRate . set_label ( " {:3.1f} kbps " . format ( self . streamInfo [ " Bitrate " ] ) )
self . lblBitRate2 . set_label ( " {:3.1f} kbps " . format ( self . streamInfo [ " Bitrate " ] ) )
#self.lblError.set_label("{:2.2f}% BER ".format(self.streamInfo["BER"][1]*100))
self . lblError . set_label ( " {:2.2f} % BER " . format ( self . streamInfo [ " BER " ] [ 0 ] * 100 ) )
self . lblCall . set_label ( " " + self . streamInfo [ " Callsign " ] )
self . lblName . set_label ( self . streamInfo [ " Callsign " ] )
self . lblSlogan . set_label ( self . streamInfo [ " Slogan " ] )
self . lblSlogan . set_tooltip_text ( self . streamInfo [ " Slogan " ] )
self . lblMessage . set_label ( self . streamInfo [ " Message " ] )
self . lblMessage . set_tooltip_text ( self . streamInfo [ " Message " ] )
self . lblAlert . set_label ( self . streamInfo [ " Alert " ] )
self . lblAlert . set_tooltip_text ( self . streamInfo [ " Alert " ] )
2021-04-06 16:26:20 -04:00
self . set_button_name ( self . btnAudioPrgs0 , self . btnAudioLbl0 , 0 )
self . set_button_name ( self . btnAudioPrgs1 , self . btnAudioLbl1 , 1 )
self . set_button_name ( self . btnAudioPrgs2 , self . btnAudioLbl2 , 2 )
self . set_button_name ( self . btnAudioPrgs3 , self . btnAudioLbl3 , 3 )
self . set_label_name ( self . lblAudioPrgs0 , self . streamInfo [ " Streams " ] [ 0 ] , True )
self . set_label_name ( self . lblAudioPrgs1 , self . streamInfo [ " Streams " ] [ 1 ] , True )
self . set_label_name ( self . lblAudioPrgs2 , self . streamInfo [ " Streams " ] [ 2 ] , True )
self . set_label_name ( self . lblAudioPrgs3 , self . streamInfo [ " Streams " ] [ 3 ] , True )
self . set_label_name ( self . lblAudioSvcs0 , self . streamInfo [ " Programs " ] [ 0 ] , True )
self . set_label_name ( self . lblAudioSvcs1 , self . streamInfo [ " Programs " ] [ 1 ] , True )
self . set_label_name ( self . lblAudioSvcs2 , self . streamInfo [ " Programs " ] [ 2 ] , True )
self . set_label_name ( self . lblAudioSvcs3 , self . streamInfo [ " Programs " ] [ 3 ] , True )
self . set_label_name ( self . lblDataSvcs0 , self . streamInfo [ " Services " ] [ 0 ] , False )
self . set_label_name ( self . lblDataSvcs1 , self . streamInfo [ " Services " ] [ 1 ] , False )
self . set_label_name ( self . lblDataSvcs2 , self . streamInfo [ " Services " ] [ 2 ] , False )
self . set_label_name ( self . lblDataSvcs3 , self . streamInfo [ " Services " ] [ 3 ] , False )
self . set_label_name ( self . lblDataType0 , self . streamInfo [ " SvcTypes " ] [ 0 ] , False )
self . set_label_name ( self . lblDataType1 , self . streamInfo [ " SvcTypes " ] [ 1 ] , False )
self . set_label_name ( self . lblDataType2 , self . streamInfo [ " SvcTypes " ] [ 2 ] , False )
self . set_label_name ( self . lblDataType3 , self . streamInfo [ " SvcTypes " ] [ 3 ] , False )
2021-03-27 16:22:48 -04:00
self . lblMerLower . set_label ( " {:1.2f} dB " . format ( self . streamInfo [ " MER " ] [ 0 ] ) )
self . lblMerUpper . set_label ( " {:1.2f} dB " . format ( self . streamInfo [ " MER " ] [ 1 ] ) )
self . lblBerNow . set_label ( " {:1.3f} % (Now) " . format ( ber [ 0 ] ) )
self . lblBerAvg . set_label ( " {:1.3f} % (Avg) " . format ( ber [ 1 ] ) )
self . lblBerMin . set_label ( " {:1.3f} % (Min) " . format ( ber [ 2 ] ) )
self . lblBerMax . set_label ( " {:1.3f} % (Max) " . format ( ber [ 3 ] ) )
if ( self . cbAutoGain . get_active ( ) ) :
self . spinGain . set_value ( self . streamInfo [ " Gain " ] )
self . lblGain . set_label ( " {:2.1f} dB " . format ( self . streamInfo [ " Gain " ] ) )
# second param is lot id, if -1, show cover, otherwise show cover
# technically we should show the file with the matching lot id
2021-04-20 13:52:52 -04:00
lot = - 1
2021-03-28 02:09:32 -04:00
#if (int(self.lastXHDR[1]) > 0 and self.streamInfo["Cover"] != None):
2021-04-19 19:53:27 -04:00
if ( ( self . lastXHDR == " 0 " ) and ( self . streamInfo [ " Cover " ] != " " ) ) :
2021-03-27 16:22:48 -04:00
imagePath = os . path . join ( aasDir , self . streamInfo [ " Cover " ] )
image = self . streamInfo [ " Cover " ]
2021-04-20 13:52:52 -04:00
lot = self . getImageLot ( image )
2021-04-19 16:17:23 -04:00
#print("lastXHDR is 0, set image to Cover:"+imagePath)
2021-03-28 02:09:32 -04:00
#elif (int(self.lastXHDR[1]) < 0 or self.streamInfo["Cover"] == None):
2021-04-19 19:53:27 -04:00
elif ( ( ( self . lastXHDR == " 1 " ) or ( self . lastImage != " " ) ) and ( self . streamInfo [ " Logo " ] != " " ) ) :
2021-03-27 16:22:48 -04:00
imagePath = os . path . join ( aasDir , self . streamInfo [ " Logo " ] )
image = self . streamInfo [ " Logo " ]
2021-04-19 16:17:23 -04:00
#print("lastXHDR is 1, set image to Logo:"+imagePath)
2021-03-27 16:22:48 -04:00
if ( not os . path . isfile ( imagePath ) ) :
self . imgCover . clear ( )
self . coverImage = " "
# resize and display image if it changed and exists
2021-04-20 13:52:52 -04:00
if ( self . xhdrChanged and ( self . lastImage != image ) and ( ( self . lastLOT == lot ) or ( lot == - 1 ) ) and os . path . isfile ( imagePath ) ) :
2021-04-19 16:17:23 -04:00
#if ((self.lastImage != image) and os.path.isfile(imagePath)):
2021-04-20 13:52:52 -04:00
#print("xhdrChanged, image changed, lot matches image, and file exists:"+imagePath)
2021-03-27 16:22:48 -04:00
self . xhdrChanged = False
self . lastImage = image
2021-04-05 09:26:11 -04:00
#img_size = min(self.alignmentCover.get_allocated_height(), self.alignmentCover.get_allocated_width()) - 12
2021-03-27 16:22:48 -04:00
#self.pixbuf = Gtk.gdk.pixbuf_new_from_file(imagePath)
2021-04-05 09:26:11 -04:00
#self.pixbuf = GdkPixbuf.Pixbuf.new_from_file(imagePath)
2021-03-27 16:22:48 -04:00
self . coverImage = imagePath
2021-04-05 09:26:11 -04:00
#self.pixbuf = self.pixbuf.scale_simple(img_size, img_size, GdkPixbuf.InterpType.BILINEAR)
#self.imgCover.set_from_pixbuf(self.pixbuf)
self . showArtwork ( imagePath )
2021-04-19 16:17:23 -04:00
#print("displaying image:"+imagePath)
2021-03-28 02:09:32 -04:00
#self.handle_window_resize()
2021-03-27 16:22:48 -04:00
self . debugLog ( " Image Changed " )
2021-04-03 17:19:54 -04:00
if ( self . cbCovers . get_active ( ) and self . id3Changed ) :
self . get_cover_image_online ( )
2021-03-27 16:22:48 -04:00
finally :
2021-04-01 18:17:21 -04:00
#Gdk.threads_leave()
pass
2021-03-27 16:22:48 -04:00
if ( self . playing ) :
#gobject.idle_add(update)
GLib . idle_add ( update )
self . statusTimer = Timer ( 1 , self . checkStatus )
self . statusTimer . start ( )
def processTrafficMap ( self , fileName ) :
global aasDir , mapDir
r = re . compile ( " ^[ \ d]+_TMT_.*_([1-3])_([1-3])_([ \ d] {4} )([ \ d] {2} )([ \ d] {2} )_([0-9A-Fa-f] {2} )([0-9A-Fa-f] {2} )_([0-9A-Fa-f] {4} ) \ ..*$ " ) # match file name
m = r . match ( fileName )
if ( m ) :
x = int ( m . group ( 1 ) ) - 1 # X position
y = int ( m . group ( 2 ) ) - 1 # Y position
# get time from map tile and convert to local time
dt = datetime . datetime ( int ( m . group ( 3 ) ) , int ( m . group ( 4 ) ) , int ( m . group ( 5 ) ) , int ( m . group ( 6 ) ) , int ( m . group ( 7 ) ) , tzinfo = tz . tzutc ( ) )
t = dt . astimezone ( tz . tzlocal ( ) ) # local time
ts = dtToTs ( dt ) # unix timestamp (utc)
# check if the tile has already been loaded
if ( self . mapData [ " mapTiles " ] [ x ] [ y ] == ts ) :
try :
os . remove ( os . path . join ( aasDir , fileName ) ) # delete this tile, it's not needed
except :
pass
return # no need to recreate the map if it hasn't changed
self . debugLog ( " Got Traffic Map Tile: {:g} , {:g} " . format ( x , y ) )
self . mapData [ " mapComplete " ] = False # new tiles are coming in, the map is nolonger complete
self . mapData [ " mapTiles " ] [ x ] [ y ] = ts # store time for current tile
try :
currentPath = os . path . join ( aasDir , fileName )
newPath = os . path . join ( mapDir , " TrafficMap_ {:g} _ {:g} .png " . format ( x , y ) ) # create path to new tile location
if ( os . path . exists ( newPath ) ) : os . remove ( newPath ) # delete old image if it exists (only necessary on windows)
shutil . move ( currentPath , newPath ) # move and rename map tile
except :
self . debugLog ( " Error moving map tile (src: " + currentPath + " , dest: " + newPath + " ) " , True )
self . mapData [ " mapTiles " ] [ x ] [ y ] = 0
# check if all of the tiles are loaded
if ( self . checkTiles ( ts ) ) :
self . debugLog ( " Got complete traffic map " )
self . mapData [ " mapComplete " ] = True # map is complete
# stitch the map tiles into one image
imgMap = Image . new ( " RGB " , ( 600 , 600 ) , " white " ) # create blank image for traffic map
for i in range ( 0 , 3 ) :
for j in range ( 0 , 3 ) :
tileFile = os . path . join ( mapDir , " TrafficMap_ {:g} _ {:g} .png " . format ( i , j ) ) # get path to tile
imgMap . paste ( Image . open ( tileFile ) , ( j * 200 , i * 200 ) ) # paste tile into map
os . remove ( tileFile ) # delete tile image
2021-03-29 19:19:58 -04:00
# now put a timestamp on it.
2021-03-30 07:07:38 -04:00
imgMap = imgMap . convert ( " RGBA " )
imgBig = ( 981 , 981 ) # size of a weather map
#posTS = (imgMap.size[0]-235, imgMap.size[1]-29) # calculate position to put timestamp (bottom right)
posTS = ( imgBig [ 0 ] - 235 , imgBig [ 1 ] - 29 ) # calculate position to put timestamp (bottom right)
#imgTS = self.mkTimestamp(t, imgMap.size, posTS) # create timestamp
imgTS = self . mkTimestamp ( t , imgBig , posTS ) # create timestamp for a weather map
imgTS = imgTS . resize ( ( imgMap . size [ 0 ] , imgMap . size [ 1 ] ) , Image . LANCZOS ) # resize it so it's proportional to the size of a traffic map (981 -> 600)
imgMap = Image . alpha_composite ( imgMap , imgTS ) # overlay timestamp on traffic map
2021-03-29 19:19:58 -04:00
2021-03-27 16:22:48 -04:00
imgMap . save ( os . path . join ( mapDir , " TrafficMap.png " ) ) # save traffic map
# display on map page
if ( self . radMapTraffic . get_active ( ) ) :
img_size = min ( self . alignmentMap . get_allocated_height ( ) , self . alignmentMap . get_allocated_width ( ) ) - 12
#imgMap = imgMap.resize((200,200), Image.LANCZOS) # scale map to fit window
imgMap = imgMap . resize ( ( img_size , img_size ) , Image . LANCZOS )
self . imgMap . set_from_pixbuf ( imgToPixbuf ( imgMap ) ) # convert image to pixbuf and display
if ( self . mapViewer is not None ) : self . mapViewer . updated ( 0 ) # notify map viwerer if it's open
def processWeatherOverlay ( self , fileName ) :
2021-04-08 08:46:07 -04:00
global aasDir , mapDir
2021-03-27 16:22:48 -04:00
r = re . compile ( " ^[ \ d]+_DWRO_(.*)_.*_([ \ d] {4} )([ \ d] {2} )([ \ d] {2} )_([ \ d] {2} )([ \ d] {2} )_([0-9A-Fa-f]+) \ ..*$ " ) # match file name
m = r . match ( fileName )
if ( m ) :
# get time from map tile and convert to local time
dt = datetime . datetime ( int ( m . group ( 2 ) ) , int ( m . group ( 3 ) ) , int ( m . group ( 4 ) ) , int ( m . group ( 5 ) ) , int ( m . group ( 6 ) ) , tzinfo = tz . tzutc ( ) )
t = dt . astimezone ( tz . tzlocal ( ) ) # local time
ts = dtToTs ( dt ) # unix timestamp (utc)
id = self . mapData [ " weatherID " ]
if ( m . group ( 1 ) != id ) :
if ( id == " " ) :
self . debugLog ( " Received weather overlay before metadata, ignoring... " ) ;
else :
self . debugLog ( " Received weather overlay with the wrong ID: " + m . group ( 1 ) + " (wanted " + id + " ) " )
return
if ( self . mapData [ " weatherTime " ] == ts ) :
try :
os . remove ( os . path . join ( aasDir , fileName ) ) # delete this tile, it's not needed
except :
pass
return # no need to recreate the map if it hasn't changed
self . debugLog ( " Got Weather Overlay " )
self . mapData [ " weatherTime " ] = ts # store time for current overlay
wxOlPath = os . path . join ( mapDir , " WeatherOverlay_ {:s} _ {:} .png " . format ( id , ts ) )
wxMapPath = os . path . join ( mapDir , " WeatherMap_ {:s} _ {:} .png " . format ( id , ts ) )
# move new overlay to map directory
try :
if ( os . path . exists ( wxOlPath ) ) : os . remove ( wxOlPath ) # delete old image if it exists (only necessary on windows)
shutil . move ( os . path . join ( aasDir , fileName ) , wxOlPath ) # move and rename map tile
except :
self . debugLog ( " Error moving weather overlay " , True )
self . mapData [ " weatherTime " ] = 0
# create weather map
try :
mapPath = os . path . join ( mapDir , " BaseMap_ " + id + " .png " ) # get path to base map
if ( os . path . isfile ( mapPath ) == False ) : # make sure base map exists
self . makeBaseMap ( self . mapData [ " weatherID " ] , self . mapData [ " weatherPos " ] ) # create base map if it doesn't exist
imgMap = Image . open ( mapPath ) . convert ( " RGBA " ) # open map image
posTS = ( imgMap . size [ 0 ] - 235 , imgMap . size [ 1 ] - 29 ) # calculate position to put timestamp (bottom right)
imgTS = self . mkTimestamp ( t , imgMap . size , posTS ) # create timestamp
imgRadar = Image . open ( wxOlPath ) . convert ( " RGBA " ) # open radar overlay
imgRadar = imgRadar . resize ( imgMap . size , Image . LANCZOS ) # resize radar overlay to fit the map
imgMap = Image . alpha_composite ( imgMap , imgRadar ) # overlay radar image on map
imgMap = Image . alpha_composite ( imgMap , imgTS ) # overlay timestamp
imgMap . save ( wxMapPath ) # save weather map
os . remove ( wxOlPath ) # remove overlay image
self . mapData [ " weatherNow " ] = wxMapPath
# display on map page
if ( self . radMapWeather . get_active ( ) ) :
img_size = min ( self . alignmentMap . get_allocated_height ( ) , self . alignmentMap . get_allocated_width ( ) ) - 12
#imgMap = imgMap.resize((200,200), Image.LANCZOS) # scale map to fit window
imgMap = imgMap . resize ( ( img_size , img_size ) , Image . LANCZOS ) # scale map to fit window
self . imgMap . set_from_pixbuf ( imgToPixbuf ( imgMap ) ) # convert image to pixbuf and display
self . proccessWeatherMaps ( ) # get rid of old maps and add new ones to the list
if ( self . mapViewer is not None ) : self . mapViewer . updated ( 1 ) # notify map viwerer if it's open
except :
self . debugLog ( " Error creating weather map " , True )
self . mapData [ " weatherTime " ] = 0
def proccessWeatherInfo ( self , fileName ) :
global aasDir
weatherID = None
weatherPos = None
try :
with open ( os . path . join ( aasDir , fileName ) ) as weatherInfo : # open weather info file
for line in weatherInfo : # read line by line
if ( " DWR_Area_ID= " in line ) : # look for line with "DWR_Area_ID=" in it
# get ID from line
r = re . compile ( " ^DWR_Area_ID= \" (.+) \" $ " )
m = r . match ( line )
weatherID = m . group ( 1 )
elif ( " Coordinates= " in line ) : # look for line with "Coordinates=" in it
# get coordinates from line
r = re . compile ( " ^Coordinates=.* \ ((-?[ \ d]+ \ .[ \ d]+),(-?[ \ d]+ \ .[ \ d]+) \ ).* \ ((-?[ \ d]+ \ .[ \ d]+),(-?[ \ d]+ \ .[ \ d]+) \ ).*$ " )
m = r . match ( line )
weatherPos = [ float ( m . group ( 1 ) ) , float ( m . group ( 2 ) ) , float ( m . group ( 3 ) ) , float ( m . group ( 4 ) ) ]
except :
self . debugLog ( " Error opening weather info " , True )
if ( weatherID is not None and weatherPos is not None ) : # check if ID and position were found
if ( self . mapData [ " weatherID " ] != weatherID or self . mapData [ " weatherPos " ] != weatherPos ) : # check if ID or position has changed
self . debugLog ( " Got position: ( {:n} , {:n} ) ( {:n} , {:n} ) " . format ( * weatherPos ) )
self . mapData [ " weatherID " ] = weatherID # set weather ID
self . mapData [ " weatherPos " ] = weatherPos # set weather map position
self . makeBaseMap ( weatherID , weatherPos )
self . weatherMaps = [ ]
self . proccessWeatherMaps ( )
def proccessWeatherMaps ( self ) :
global mapDir
numberOfMaps = 0
2021-03-28 20:48:01 -04:00
#r = re.compile("^map.WeatherMap_([a-zA-Z0-9]+)_([0-9]+).png")
r = re . compile ( " ^.*map.WeatherMap_([a-zA-Z0-9]+)_([0-9]+).png " )
2021-03-27 16:22:48 -04:00
now = dtToTs ( datetime . datetime . now ( tz . tzutc ( ) ) ) # get current time
files = glob . glob ( os . path . join ( mapDir , " WeatherMap_ " ) + " *.png " ) # look for weather map files
files . sort ( ) # sort files
2021-03-28 20:48:01 -04:00
#print(files)
2021-03-27 16:22:48 -04:00
for f in files :
m = r . match ( f ) # match regex
if ( m ) :
id = m . group ( 1 ) # location ID
ts = int ( m . group ( 2 ) ) # timestamp (UTC)
# remove weather maps older than 12 hours
if ( now - ts > 60 * 60 * 12 ) :
try :
2021-03-28 20:48:01 -04:00
if ( f in self . weatherMaps ) :
self . weatherMaps . pop ( self . weatherMaps . index ( f ) ) # remove from list
2021-03-27 16:22:48 -04:00
os . remove ( f ) # remove file
self . debugLog ( " Deleted old weather map: " + f )
except :
self . debugLog ( " Error Failed to Delete: " + f )
# skip if not the correct location
elif ( id == self . mapData [ " weatherID " ] ) :
2021-03-28 20:48:01 -04:00
if ( f not in self . weatherMaps ) :
self . weatherMaps . append ( f ) # add to list
2021-03-27 16:22:48 -04:00
numberOfMaps + = 1
self . debugLog ( " Found {} weather maps " . format ( numberOfMaps ) )
def getMapArea ( self , lat1 , lon1 , lat2 , lon2 ) :
from math import asinh , tan , radians
# get pixel coordinates from latitude and longitude
# calculations taken from https://github.com/KYDronePilot/hdfm
top = asinh ( tan ( radians ( 52.482780 ) ) )
lat1 = top - asinh ( tan ( radians ( lat1 ) ) )
lat2 = top - asinh ( tan ( radians ( lat2 ) ) )
x1 = ( lon1 + 130.781250 ) * 7162 / 39.34135
x2 = ( lon2 + 130.781250 ) * 7162 / 39.34135
y1 = lat1 * 3565 / ( top - asinh ( tan ( radians ( 38.898 ) ) ) )
y2 = lat2 * 3565 / ( top - asinh ( tan ( radians ( 38.898 ) ) ) )
return ( int ( round ( x1 ) ) , int ( round ( y1 ) ) , int ( round ( x2 ) ) , int ( round ( y2 ) ) )
def makeBaseMap ( self , id , pos ) :
global mapDir
mapPath = os . path . join ( mapDir , " BaseMap_ " + id + " .png " ) # get map path
if ( os . path . isfile ( self . mapFile ) ) :
if ( os . path . isfile ( mapPath ) == False ) : # check if the map has already been created for this location
self . debugLog ( " Creating new map: " + mapPath )
px = self . getMapArea ( * pos ) # convert map locations to pixel coordinates
mapImg = Image . open ( self . mapFile ) . crop ( px ) # open the full map and crop it to the coordinates
mapImg . save ( mapPath ) # save the cropped map to disk for later use
self . debugLog ( " Finished creating map " )
else :
self . debugLog ( " Error map file not found: " + self . mapFile , True )
mapImg = Image . new ( " RGBA " , ( pos [ 2 ] - pos [ 1 ] , pos [ 3 ] - pos [ 1 ] ) , " white " ) # if the full map is not available, use a blank image
mapImg . save ( mapPath )
def checkTiles ( self , t ) :
# check if all the tiles have been received
for i in range ( 0 , 3 ) :
for j in range ( 0 , 3 ) :
if ( self . mapData [ " mapTiles " ] [ i ] [ j ] != t ) :
return False
return True
def mkTimestamp ( self , t , size , pos ) :
2021-04-08 08:46:07 -04:00
global resDir
2021-03-27 16:22:48 -04:00
# create a timestamp image to overlay on the weathermap
x , y = pos
text = " {:04g} - {:02g} - {:02g} {:02g} : {:02g} " . format ( t . year , t . month , t . day , t . hour , t . minute ) # format timestamp
imgTS = Image . new ( " RGBA " , size , ( 0 , 0 , 0 , 0 ) ) # create a blank image
draw = ImageDraw . Draw ( imgTS ) # the drawing object
2021-03-30 07:07:38 -04:00
font = ImageFont . truetype ( os . path . join ( resDir , " DejaVuSansMono.ttf " ) , 24 ) # DejaVu Sans Mono 24pt font
2021-03-27 16:22:48 -04:00
draw . rectangle ( ( x , y , x + 231 , y + 25 ) , outline = " black " , fill = ( 128 , 128 , 128 , 96 ) ) # draw a box around the text
draw . text ( ( x + 3 , y ) , text , fill = " black " , font = font ) # draw the text
return imgTS # return the image
2021-04-20 13:52:52 -04:00
def checkPorts ( self , port , type ) :
result = - 1
for i in range ( 0 , 3 ) :
if ( len ( self . streams [ i ] ) > type ) :
if ( port == self . streams [ i ] [ type ] ) :
result = i
return result
2021-03-27 16:22:48 -04:00
def parseFeedback ( self , line ) :
global aasDir , mapDir
line = line . strip ( )
#print(line)
if ( self . regex [ 4 ] . match ( line ) ) :
# match title
m = self . regex [ 4 ] . match ( line )
self . streamInfo [ " Title " ] = m . group ( 1 )
elif ( self . regex [ 5 ] . match ( line ) ) :
# match artist
m = self . regex [ 5 ] . match ( line )
self . streamInfo [ " Artist " ] = m . group ( 1 )
elif ( self . regex [ 6 ] . match ( line ) ) :
# match album
m = self . regex [ 6 ] . match ( line )
self . streamInfo [ " Album " ] = m . group ( 1 )
elif ( self . regex [ 15 ] . match ( line ) ) :
# match genre
m = self . regex [ 15 ] . match ( line )
self . streamInfo [ " Genre " ] = m . group ( 1 )
elif ( self . regex [ 3 ] . match ( line ) ) :
# match audio bit rate
m = self . regex [ 3 ] . match ( line )
self . streamInfo [ " Bitrate " ] = float ( m . group ( 1 ) )
elif ( self . regex [ 8 ] . match ( line ) ) :
# match MER
m = self . regex [ 8 ] . match ( line )
self . streamInfo [ " MER " ] = [ float ( m . group ( 1 ) ) , float ( m . group ( 2 ) ) ]
elif ( self . regex [ 9 ] . match ( line ) ) :
# match BER
m = self . regex [ 9 ] . match ( line )
self . streamInfo [ " BER " ] = [ float ( m . group ( 1 ) ) , float ( m . group ( 2 ) ) , float ( m . group ( 3 ) ) , float ( m . group ( 4 ) ) ]
elif ( self . regex [ 13 ] . match ( line ) ) :
# match xhdr
m = self . regex [ 13 ] . match ( line )
2021-03-28 02:09:32 -04:00
#xhdr = [m.group(1),m.group(2)]
xhdr = m . group ( 1 )
mime = m . group ( 2 )
lot = m . group ( 3 )
2021-04-19 16:17:23 -04:00
#print("got XHDR msg xhdr:"+xhdr+" for lot:"+lot)
2021-04-20 13:52:52 -04:00
if ( xhdr != self . lastXHDR ) or ( lot != self . lastLOT ) :
#print("xhdr changed:"+xhdr+" for lot:"+lot)
2021-03-27 16:22:48 -04:00
self . lastXHDR = xhdr
2021-04-20 13:52:52 -04:00
self . lastLOT = lot
2021-03-27 16:22:48 -04:00
self . xhdrChanged = True
2021-03-28 02:09:32 -04:00
#self.debugLog("XHDR Changed: {:s} (lot {:s})".format(xhdr[0],xhdr[1]))
self . debugLog ( " XHDR Changed: {:s} (lot {:s} ) " . format ( xhdr , lot ) )
2021-03-27 16:22:48 -04:00
elif ( self . regex [ 7 ] . match ( line ) ) :
# match album art
m = self . regex [ 7 ] . match ( line )
if ( m ) :
fileName = " {} _ {} " . format ( m . group ( 2 ) , m . group ( 3 ) )
fileSize = int ( m . group ( 4 ) )
headerOffset = int ( len ( m . group ( 2 ) ) ) + 1
p = int ( m . group ( 1 ) , 16 )
2021-04-20 13:52:52 -04:00
coverStream = self . checkPorts ( p , 0 )
logoStream = self . checkPorts ( p , 1 )
2021-03-27 16:22:48 -04:00
2021-04-19 16:17:23 -04:00
#print("got LOT msg, port:"+str(p)+" lot_name:"+fileName+" size:"+str(fileSize))
2021-03-27 16:22:48 -04:00
# check file existance and size .. right now we just debug log
if ( not os . path . isfile ( os . path . join ( aasDir , fileName ) ) ) :
self . debugLog ( " Missing file: " + fileName )
else :
actualFileSize = os . path . getsize ( os . path . join ( aasDir , fileName ) )
if ( fileSize != actualFileSize ) :
self . debugLog ( " Corrupt file: " + fileName + " (expected: " + fileSize + " bytes, got " + actualFileSize + " bytes) " )
#tmp = self.streams[int(self.spinStream.get_value()-1)][0]
2021-04-20 13:52:52 -04:00
#tmp = self.streams[int(self.streamNum)][0]
2021-03-27 16:22:48 -04:00
#if (p == self.streams[int(self.spinStream.get_value()-1)][0]):
2021-04-20 13:52:52 -04:00
#if (p == self.streams[int(self.streamNum)][0]):
if ( coverStream > - 1 ) :
if coverStream == self . streamNum :
self . streamInfo [ " Cover " ] = fileName
2021-03-27 16:22:48 -04:00
self . debugLog ( " Got Album Cover: " + fileName )
2021-04-20 13:52:52 -04:00
#print("got Cover:"+fileName+" for stream "+str(coverStream))
2021-03-27 16:22:48 -04:00
#elif (p == self.streams[int(self.spinStream.get_value()-1)][1]):
2021-04-20 13:52:52 -04:00
#elif (p == self.streams[int(self.streamNum)][1]):
elif ( logoStream > - 1 ) :
if logoStream == self . streamNum :
self . streamInfo [ " Logo " ] = fileName
self . stationLogos [ self . stationStr ] [ logoStream ] = fileName # add station logo to database
self . debugLog ( " Got Station Logo: " + fileName )
#print("got Logo:"+fileName+" for stream "+str(logoStream))
2021-03-27 16:22:48 -04:00
elif ( fileName [ headerOffset : ( 5 + headerOffset ) ] == " DWRO_ " and mapDir is not None ) :
self . processWeatherOverlay ( fileName )
elif ( fileName [ headerOffset : ( 4 + headerOffset ) ] == " TMT_ " and mapDir is not None ) :
self . processTrafficMap ( fileName ) # proccess traffic map tile
elif ( fileName [ headerOffset : ( 5 + headerOffset ) ] == " DWRI_ " and mapDir is not None ) :
self . proccessWeatherInfo ( fileName )
elif ( self . regex [ 0 ] . match ( line ) ) :
# match station name
m = self . regex [ 0 ] . match ( line )
self . streamInfo [ " Callsign " ] = m . group ( 1 )
elif ( self . regex [ 2 ] . match ( line ) ) :
# match station slogan
m = self . regex [ 2 ] . match ( line )
self . streamInfo [ " Slogan " ] = m . group ( 1 )
elif ( self . regex [ 16 ] . match ( line ) ) :
# match message
m = self . regex [ 16 ] . match ( line )
self . streamInfo [ " Message " ] = m . group ( 1 )
elif ( self . regex [ 17 ] . match ( line ) ) :
# match alert
m = self . regex [ 17 ] . match ( line )
self . streamInfo [ " Alert " ] = m . group ( 1 )
elif ( self . regex [ 10 ] . match ( line ) ) :
# match gain
m = self . regex [ 10 ] . match ( line )
self . streamInfo [ " Gain " ] = float ( m . group ( 1 ) ) / 10
elif ( self . regex [ 11 ] . match ( line ) ) :
# match stream
m = self . regex [ 11 ] . match ( line )
t = m . group ( 1 ) # stream type
2021-03-28 02:09:32 -04:00
s = int ( m . group ( 2 ) , 10 ) # stream number
2021-03-27 16:22:48 -04:00
n = m . group ( 3 )
self . debugLog ( " Found Stream: Type {:s} , Number {:02X} " . format ( t , s ) )
self . lastType = t
if ( t == " audio " and s > = 1 and s < = 4 ) :
self . numStreams = s
self . streamInfo [ " Streams " ] [ s - 1 ] = n
if ( t == " data " ) :
self . streamInfo [ " Services " ] [ self . numServices ] = n
self . numServices + = 1
elif ( self . regex [ 12 ] . match ( line ) ) :
# match port and data_service_type
m = self . regex [ 12 ] . match ( line )
id = int ( m . group ( 1 ) , 10 )
p = int ( m . group ( 2 ) , 16 )
t = int ( m . group ( 3 ) , 10 )
self . debugLog ( " \t Found Port: {:03X} " . format ( p ) )
if ( self . lastType == " audio " and self . numStreams > 0 ) :
self . streams [ self . numStreams - 1 ] . append ( p )
if ( ( self . lastType == " data " ) and ( id == 0 ) and ( self . numServices > 0 ) ) :
self . streamInfo [ " SvcTypes " ] [ self . numServices - 1 ] = self . service_data_type_name ( t )
elif ( self . regex [ 18 ] . match ( line ) ) :
# match program type
m = self . regex [ 18 ] . match ( line )
id = int ( m . group ( 1 ) , 10 )
p = int ( m . group ( 2 ) , 16 )
t = int ( m . group ( 3 ) , 10 )
if ( ( self . lastType == " audio " ) and ( id == 0 ) and ( self . numStreams > 0 ) ) :
self . streamInfo [ " Programs " ] [ self . numStreams - 1 ] = self . program_type_name ( t )
elif ( self . regex [ 19 ] . match ( line ) ) :
# match synchronized
self . set_synchronization ( 1 )
elif ( self . regex [ 20 ] . match ( line ) ) :
# match lost synch
self . set_synchronization ( 0 )
elif ( self . regex [ 21 ] . match ( line ) ) :
# match lost device
self . set_synchronization ( - 1 )
2021-04-07 07:47:26 -04:00
elif ( self . regex [ 22 ] . match ( line ) ) :
# match Open device failed
self . on_btnStop_clicked ( None )
self . set_synchronization ( - 1 )
2021-03-27 16:22:48 -04:00
def getControls ( self ) :
global resDir
# setup gui
builder = Gtk . Builder ( )
builder . add_from_file ( os . path . join ( resDir , " mainForm.glade " ) )
builder . connect_signals ( self )
# Windows
self . mainWindow = builder . get_object ( " mainWindow " )
2021-04-08 08:46:07 -04:00
self . mainWindow . set_icon_from_file ( os . path . join ( resDir , " logo.png " ) )
2021-03-27 16:22:48 -04:00
self . mainWindow . connect ( " delete-event " , self . shutdown )
self . mainWindow . connect ( " destroy " , Gtk . main_quit )
self . about_dialog = None
# get controls
2021-04-08 08:46:07 -04:00
self . image1 = builder . get_object ( " image1 " )
2021-03-27 16:22:48 -04:00
self . notebookMain = builder . get_object ( " notebookMain " )
self . alignmentCover = builder . get_object ( " alignmentCover " )
self . imgCover = builder . get_object ( " imgCover " )
self . alignmentMap = builder . get_object ( " alignment_map " )
self . imgMap = builder . get_object ( " imgMap " )
self . spinFreq = builder . get_object ( " spinFreq " )
#self.spinStream = builder.get_object("spinStream")
self . spinGain = builder . get_object ( " spinGain " )
self . spinPPM = builder . get_object ( " spinPPM " )
self . spinRTL = builder . get_object ( " spinRTL " )
2021-04-22 11:39:55 -04:00
self . txtDevIP = builder . get_object ( " txtDevIP " )
2021-03-27 16:22:48 -04:00
self . cbAutoGain = builder . get_object ( " cbAutoGain " )
2021-04-22 11:39:55 -04:00
self . cbDevIP = builder . get_object ( " cbDevIP " )
2021-03-27 16:22:48 -04:00
self . cbLog = builder . get_object ( " cbLog " )
2021-04-02 15:21:18 -04:00
self . cbCovers = builder . get_object ( " cbCovers " )
2021-03-27 16:22:48 -04:00
self . btnPlay = builder . get_object ( " btnPlay " )
self . btnStop = builder . get_object ( " btnStop " )
self . btnBookmark = builder . get_object ( " btnBookmark " )
self . btnDelete = builder . get_object ( " btnDelete " )
2021-04-08 08:46:07 -04:00
self . btnMap = builder . get_object ( " btnMap " )
2021-03-27 16:22:48 -04:00
self . radMapTraffic = builder . get_object ( " radMapTraffic " )
self . radMapWeather = builder . get_object ( " radMapWeather " )
self . txtTitle = builder . get_object ( " txtTitle " )
self . txtArtist = builder . get_object ( " txtArtist " )
self . txtAlbum = builder . get_object ( " txtAlbum " )
self . txtGenre = builder . get_object ( " txtGenre " )
self . lblName = builder . get_object ( " lblName " )
self . lblSlogan = builder . get_object ( " lblSlogan " )
self . lblMessage = builder . get_object ( " lblMessage " )
self . lblAlert = builder . get_object ( " lblAlert " )
self . btnAudioPrgs0 = builder . get_object ( " btn_audio_prgs0 " )
self . btnAudioPrgs1 = builder . get_object ( " btn_audio_prgs1 " )
self . btnAudioPrgs2 = builder . get_object ( " btn_audio_prgs2 " )
self . btnAudioPrgs3 = builder . get_object ( " btn_audio_prgs3 " )
self . btnAudioLbl0 = builder . get_object ( " btn_audio_lbl0 " )
self . btnAudioLbl1 = builder . get_object ( " btn_audio_lbl1 " )
self . btnAudioLbl2 = builder . get_object ( " btn_audio_lbl2 " )
self . btnAudioLbl3 = builder . get_object ( " btn_audio_lbl3 " )
self . lblAudioPrgs0 = builder . get_object ( " lbl_audio_prgs0 " )
self . lblAudioPrgs1 = builder . get_object ( " lbl_audio_prgs1 " )
self . lblAudioPrgs2 = builder . get_object ( " lbl_audio_prgs2 " )
self . lblAudioPrgs3 = builder . get_object ( " lbl_audio_prgs3 " )
self . lblAudioSvcs0 = builder . get_object ( " lbl_audio_svcs0 " )
self . lblAudioSvcs1 = builder . get_object ( " lbl_audio_svcs1 " )
self . lblAudioSvcs2 = builder . get_object ( " lbl_audio_svcs2 " )
self . lblAudioSvcs3 = builder . get_object ( " lbl_audio_svcs3 " )
self . lblDataSvcs0 = builder . get_object ( " lbl_data_svcs0 " )
self . lblDataSvcs1 = builder . get_object ( " lbl_data_svcs1 " )
self . lblDataSvcs2 = builder . get_object ( " lbl_data_svcs2 " )
self . lblDataSvcs3 = builder . get_object ( " lbl_data_svcs3 " )
self . lblDataType0 = builder . get_object ( " lbl_data_svcs10 " )
self . lblDataType1 = builder . get_object ( " lbl_data_svcs11 " )
self . lblDataType2 = builder . get_object ( " lbl_data_svcs12 " )
self . lblDataType3 = builder . get_object ( " lbl_data_svcs13 " )
self . lblCall = builder . get_object ( " lblCall " )
self . lblGain = builder . get_object ( " lblGain " )
self . lblBitRate = builder . get_object ( " lblBitRate " )
self . lblBitRate2 = builder . get_object ( " lblBitRate2 " )
self . lblError = builder . get_object ( " lblError " )
self . lblMerLower = builder . get_object ( " lblMerLower " )
self . lblMerUpper = builder . get_object ( " lblMerUpper " )
self . lblBerNow = builder . get_object ( " lblBerNow " )
self . lblBerAvg = builder . get_object ( " lblBerAvg " )
self . lblBerMin = builder . get_object ( " lblBerMin " )
self . lblBerMax = builder . get_object ( " lblBerMax " )
self . imgNoSynch = builder . get_object ( " img_nosynch " )
self . imgSynch = builder . get_object ( " img_synchpilot " )
self . imgLostDevice = builder . get_object ( " img_lostdevice " )
self . lvBookmarks = builder . get_object ( " listviewBookmarks " )
self . lsBookmarks = Gtk . ListStore ( str , str , int )
self . lvBookmarks . set_model ( self . lsBookmarks )
self . lvBookmarks . get_selection ( ) . connect ( " changed " , self . on_lvBookmarks_selection_changed )
2021-04-08 08:46:07 -04:00
self . image1 . set_from_pixbuf ( GdkPixbuf . Pixbuf . new_from_file ( os . path . join ( resDir , " weather.png " ) ) )
self . imgNoSynch . set_from_pixbuf ( GdkPixbuf . Pixbuf . new_from_file ( os . path . join ( resDir , " nosynch.png " ) ) )
self . imgSynch . set_from_pixbuf ( GdkPixbuf . Pixbuf . new_from_file ( os . path . join ( resDir , " synchpilot.png " ) ) )
self . imgLostDevice . set_from_pixbuf ( GdkPixbuf . Pixbuf . new_from_file ( os . path . join ( resDir , " lostdevice.png " ) ) )
self . btnMap . set_icon_widget ( self . image1 )
2021-03-27 16:22:48 -04:00
self . mainWindow . connect ( " check-resize " , self . on_cover_resize )
def initStreamInfo ( self ) :
# stream information
self . streamInfo = {
" Callsign " : " " , # station callsign
" Slogan " : " " , # station slogan
" Message " : " " , # station message
" Alert " : " " , # station alert
" Title " : " " , # track title
" Album " : " " , # track album
" Genre " : " " , # track genre
" Artist " : " " , # track artist
" Cover " : " " , # filename of track cover
" Logo " : " " , # station logo
2021-03-28 02:09:32 -04:00
" Streams " : [ " " , " " , " " , " " ] , # audio stream names
" Programs " : [ " " , " " , " " , " " ] , # audio stream types
" Services " : [ " " , " " , " " , " " ] , # data service names
" SvcTypes " : [ " " , " " , " " , " " ] , # data service types
2021-03-27 16:22:48 -04:00
" Bitrate " : 0 , # current stream bit rate
" MER " : [ 0 , 0 ] , # modulation error ratio: lower, upper
" BER " : [ 0 , 0 , 0 , 0 ] , # bit error rate: current, average, min, max
" Gain " : 0 # automatic gain
}
2021-04-19 16:17:23 -04:00
#print("reset cover and logo")
2021-03-27 16:22:48 -04:00
self . streams = [ [ ] , [ ] , [ ] , [ ] ]
self . numStreams = 0
self . numServices = 0
self . lastType = 0
# clear status info
self . lblCall . set_label ( " " )
self . btnAudioLbl0 . set_label ( " " )
self . btnAudioLbl1 . set_label ( " " )
self . btnAudioLbl2 . set_label ( " " )
self . btnAudioLbl3 . set_label ( " " )
self . lblBitRate . set_label ( " " )
self . lblBitRate2 . set_label ( " " )
self . lblError . set_label ( " " )
self . lblGain . set_label ( " " )
self . txtTitle . set_text ( " " )
self . txtArtist . set_text ( " " )
self . txtAlbum . set_text ( " " )
self . txtGenre . set_text ( " " )
self . imgCover . clear ( )
self . coverImage = " "
self . lblName . set_label ( " " )
self . lblSlogan . set_label ( " " )
self . lblSlogan . set_tooltip_text ( " " )
self . lblMessage . set_label ( " " )
self . lblMessage . set_tooltip_text ( " " )
2021-04-06 16:26:20 -04:00
self . btnAudioPrgs0 . set_sensitive ( False )
self . btnAudioPrgs1 . set_sensitive ( False )
self . btnAudioPrgs2 . set_sensitive ( False )
self . btnAudioPrgs3 . set_sensitive ( False )
2021-03-27 16:22:48 -04:00
self . lblAudioPrgs0 . set_label ( " " )
2021-04-06 16:26:20 -04:00
self . lblAudioPrgs0 . set_sensitive ( False )
2021-03-27 16:22:48 -04:00
self . lblAudioPrgs1 . set_label ( " " )
2021-04-06 16:26:20 -04:00
self . lblAudioPrgs1 . set_sensitive ( False )
2021-03-27 16:22:48 -04:00
self . lblAudioPrgs2 . set_label ( " " )
2021-04-06 16:26:20 -04:00
self . lblAudioPrgs2 . set_sensitive ( False )
2021-03-27 16:22:48 -04:00
self . lblAudioPrgs3 . set_label ( " " )
2021-04-06 16:26:20 -04:00
self . lblAudioPrgs3 . set_sensitive ( False )
2021-03-27 16:22:48 -04:00
self . lblAudioSvcs0 . set_label ( " " )
2021-04-06 16:26:20 -04:00
self . lblAudioSvcs0 . set_sensitive ( False )
2021-03-27 16:22:48 -04:00
self . lblAudioSvcs1 . set_label ( " " )
2021-04-06 16:26:20 -04:00
self . lblAudioSvcs1 . set_sensitive ( False )
2021-03-27 16:22:48 -04:00
self . lblAudioSvcs2 . set_label ( " " )
2021-04-06 16:26:20 -04:00
self . lblAudioSvcs2 . set_sensitive ( False )
2021-03-27 16:22:48 -04:00
self . lblAudioSvcs3 . set_label ( " " )
2021-04-06 16:26:20 -04:00
self . lblAudioSvcs3 . set_sensitive ( False )
2021-03-27 16:22:48 -04:00
self . lblDataSvcs0 . set_label ( " " )
self . lblDataSvcs1 . set_label ( " " )
self . lblDataSvcs2 . set_label ( " " )
self . lblDataSvcs3 . set_label ( " " )
self . lblDataType0 . set_label ( " " )
self . lblDataType1 . set_label ( " " )
self . lblDataType2 . set_label ( " " )
self . lblDataType3 . set_label ( " " )
self . lblMerLower . set_label ( " " )
self . lblMerUpper . set_label ( " " )
self . lblBerNow . set_label ( " " )
self . lblBerAvg . set_label ( " " )
self . lblBerMin . set_label ( " " )
self . lblBerMax . set_label ( " " )
self . set_synchronization ( 0 )
def loadSettings ( self ) :
global aasDir , cfgDir , mapDir
# load station logos
try :
with open ( os . path . join ( cfgDir , " stationLogos.json " ) , mode = ' r ' ) as f :
self . stationLogos = json . load ( f )
except :
self . debugLog ( " Error: Unable to load station logo database " , True )
self . mainWindow . resize ( self . defaultSize [ 0 ] , self . defaultSize [ 1 ] )
# load settings
try :
with open ( os . path . join ( cfgDir , " config.json " ) , mode = ' r ' ) as f :
config = json . load ( f )
if " MapData " in config :
self . mapData = config [ " MapData " ]
if ( self . mapData [ " mapMode " ] == 0 ) :
self . radMapTraffic . set_active ( True )
self . radMapTraffic . toggled ( )
elif ( self . mapData [ " mapMode " ] == 1 ) :
self . radMapWeather . set_active ( True )
self . radMapWeather . toggled ( )
if " Width " and " Height " in config :
self . mainWindow . resize ( config [ " Width " ] , config [ " Height " ] )
else :
self . mainWindow . resize ( self . defaultSize )
self . mainWindow . move ( config [ " WindowX " ] , config [ " WindowY " ] )
self . spinFreq . set_value ( config [ " Frequency " ] )
#self.spinStream.set_value(config["Stream"])
2021-03-28 02:09:32 -04:00
self . streamNum = config [ " Stream " ] - 1
2021-03-27 16:22:48 -04:00
if ( self . streamNum < 0 ) :
2021-03-28 02:09:32 -04:00
self . streamNum = 0
2021-03-27 16:22:48 -04:00
self . set_program_btns ( )
self . spinGain . set_value ( config [ " Gain " ] )
self . cbAutoGain . set_active ( config [ " AutoGain " ] )
self . spinPPM . set_value ( config [ " PPMError " ] )
self . spinRTL . set_value ( config [ " RTL " ] )
self . cbLog . set_active ( config [ " LogToFile " ] )
2021-04-02 15:21:18 -04:00
if ( " DLoadArt " in config ) :
self . cbCovers . set_active ( config [ " DLoadArt " ] )
2021-04-22 11:39:55 -04:00
if ( " UseIP " in config ) :
self . cbDevIP . set_active ( config [ " UseIP " ] )
if ( " DevIP " in config ) :
self . txtDevIP . set_text ( config [ " DevIP " ] )
2021-03-27 16:22:48 -04:00
self . bookmarks = config [ " Bookmarks " ]
for bookmark in self . bookmarks :
self . lsBookmarks . append ( bookmark )
except :
self . debugLog ( " Error: Unable to load config " , True )
# create aas directory
if ( not os . path . isdir ( aasDir ) ) :
try :
os . mkdir ( aasDir )
except :
self . debugLog ( " Error: Unable to create AAS directory " , True )
aasDir = None
# create map directory
if ( not os . path . isdir ( mapDir ) ) :
try :
os . mkdir ( mapDir )
except :
self . debugLog ( " Error: Unable to create Map directory " , True )
mapDir = None
# open log file
try :
self . logFile = open ( " nrsc5.log " , mode = ' a ' )
except :
self . debugLog ( " Error: Unable to create log file " , True )
def shutdown ( self , * args ) :
2021-04-08 08:46:07 -04:00
global cfgDir
2021-03-27 16:22:48 -04:00
# stop map viewer animation if it's running
if ( self . mapViewer is not None and self . mapViewer . animateTimer is not None ) :
self . mapViewer . animateTimer . cancel ( )
self . mapViewer . animateStop = True
while ( self . mapViewer . animateBusy ) :
self . debugLog ( " Animation Busy - Stopping " )
if ( self . mapViewer . animateTimer is not None ) :
self . mapViewer . animateTimer . cancel ( )
time . sleep ( 0.25 )
self . playing = False
# kill nrsc5 if it's running
if ( self . nrsc5 is not None and not self . nrsc5 . poll ( ) ) :
self . nrsc5 . kill ( )
# shut down status timer if it's running
if ( self . statusTimer is not None ) :
self . statusTimer . cancel ( )
2021-04-07 07:47:26 -04:00
# wait for player thread to exit
2021-03-27 16:22:48 -04:00
#if (self.playerThread is not None and self.playerThread.isAlive()):
if ( self . playerThread is not None and self . playerThread . is_alive ( ) ) :
self . playerThread . join ( 1 )
# close log file if it's enabled
if ( self . logFile is not None ) :
self . logFile . close ( )
# save settings
try :
with open ( os . path . join ( cfgDir , " config.json " ) , mode = ' w ' ) as f :
winX , winY = self . mainWindow . get_position ( )
width , height = self . mainWindow . get_size ( )
config = {
" CfgVersion " : " 1.1.0 " ,
" WindowX " : winX ,
" WindowY " : winY ,
" Width " : width ,
" Height " : height ,
" Frequency " : self . spinFreq . get_value ( ) ,
#"Stream" : int(self.spinStream.get_value()),
2021-03-28 02:09:32 -04:00
" Stream " : int ( self . streamNum ) + 1 ,
2021-03-27 16:22:48 -04:00
" Gain " : self . spinGain . get_value ( ) ,
" AutoGain " : self . cbAutoGain . get_active ( ) ,
" PPMError " : int ( self . spinPPM . get_value ( ) ) ,
" RTL " : int ( self . spinRTL . get_value ( ) ) ,
2021-04-22 11:39:55 -04:00
" DevIP " : self . txtDevIP . get_text ( ) ,
2021-03-27 16:22:48 -04:00
" LogToFile " : self . cbLog . get_active ( ) ,
2021-04-02 15:21:18 -04:00
" DLoadArt " : self . cbCovers . get_active ( ) ,
2021-04-22 11:39:55 -04:00
" UseIP " : self . cbDevIP . get_active ( ) ,
2021-03-27 16:22:48 -04:00
" Bookmarks " : self . bookmarks ,
" MapData " : self . mapData ,
}
# sort bookmarks
config [ " Bookmarks " ] . sort ( key = lambda t : t [ 2 ] )
json . dump ( config , f , indent = 2 )
with open ( os . path . join ( cfgDir , " stationLogos.json " ) , mode = ' w ' ) as f :
json . dump ( self . stationLogos , f , indent = 2 )
except :
self . debugLog ( " Error: Unable to save config " , True )
def debugLog ( self , message , force = False ) :
if ( debugMessages or force ) :
now = datetime . datetime . now ( )
print ( now . strftime ( " % b %d % H: % M: % S : " ) + message )
class NRSC5_Map ( object ) :
def __init__ ( self , parent , callback , data ) :
2021-04-08 08:46:07 -04:00
global resDir
2021-03-27 16:22:48 -04:00
# setup gui
builder = Gtk . Builder ( )
builder . add_from_file ( os . path . join ( resDir , " mapForm.glade " ) )
2021-03-28 20:48:01 -04:00
builder . connect_signals ( self )
2021-03-27 16:22:48 -04:00
self . parent = parent # parent class
self . callback = callback # callback function
self . data = data # map data
self . animateTimer = None # timer used to animate weather maps
self . animateBusy = False
self . animateStop = False
self . weatherMaps = parent . weatherMaps # list of weather maps sorted by time
self . mapIndex = 0 # the index of the next weather map to display
# get the controls
self . mapWindow = builder . get_object ( " mapWindow " )
self . imgMap = builder . get_object ( " imgMap " )
self . radMapWeather = builder . get_object ( " radMapWeather " )
self . radMapTraffic = builder . get_object ( " radMapTraffic " )
self . chkAnimate = builder . get_object ( " chkAnimate " )
self . chkScale = builder . get_object ( " chkScale " )
self . spnSpeed = builder . get_object ( " spnSpeed " )
self . adjSpeed = builder . get_object ( " adjSpeed " )
self . imgKey = builder . get_object ( " imgKey " )
2021-04-08 08:57:44 -04:00
self . imgKey . set_from_pixbuf ( GdkPixbuf . Pixbuf . new_from_file ( os . path . join ( resDir , " radar_key.png " ) ) )
2021-03-27 16:22:48 -04:00
self . mapWindow . connect ( " delete-event " , self . on_mapWindow_delete )
self . config = data [ " viewerConfig " ] # get the map viewer config
self . mapWindow . resize ( * self . config [ " windowSize " ] ) # set the window size
self . mapWindow . move ( * self . config [ " windowPos " ] ) # set the window position
2021-03-28 20:48:01 -04:00
if ( self . config [ " mode " ] == 0 ) :
self . radMapTraffic . set_active ( True ) # set the map radio buttons
elif ( self . config [ " mode " ] == 1 ) :
self . radMapWeather . set_active ( True )
2021-03-27 16:22:48 -04:00
self . setMap ( self . config [ " mode " ] ) # display the current map
self . chkAnimate . set_active ( self . config [ " animate " ] ) # set the animation mode
self . chkScale . set_active ( self . config [ " scale " ] ) # set the scale mode
self . spnSpeed . set_value ( self . config [ " animationSpeed " ] ) # set the animation speed
def on_radMap_toggled ( self , btn ) :
if ( btn . get_active ( ) ) :
if ( btn == self . radMapTraffic ) :
self . config [ " mode " ] = 0
self . imgKey . set_visible ( False ) # hide the key for the weather radar
# stop animation if it's enabled
if ( self . animateTimer is not None ) :
self . animateTimer . cancel ( )
self . animateTimer = None
self . setMap ( 0 ) # show the traffic map
elif ( btn == self . radMapWeather ) :
self . config [ " mode " ] = 1
self . imgKey . set_visible ( True ) # show the key for the weather radar
# check if animate is enabled and start animation
if ( self . config [ " animate " ] and self . animateTimer is None ) :
self . animateTimer = Timer ( 0.05 , self . animate )
self . animateTimer . start ( )
# no animation, just show the current map
elif ( not self . config [ " animate " ] ) :
self . setMap ( 1 )
def on_chkAnimate_toggled ( self , btn ) :
self . config [ " animate " ] = self . chkAnimate . get_active ( )
if ( self . config [ " animate " ] and self . config [ " mode " ] == 1 ) :
# start animation
self . animateTimer = Timer ( self . config [ " animationSpeed " ] , self . animate ) # create the animation timer
self . animateTimer . start ( ) # start the animation timer
else :
# stop animation
if ( self . animateTimer is not None ) :
self . animateTimer . cancel ( ) # cancel the animation timer
self . animateTimer = None
self . mapIndex = len ( self . weatherMaps ) - 1 # reset the animation index
self . setMap ( self . config [ " mode " ] ) # show the most recent map
def on_chkScale_toggled ( self , btn ) :
self . config [ " scale " ] = btn . get_active ( )
if ( self . config [ " mode " ] == 1 ) :
if ( self . config [ " animate " ] ) :
2021-03-28 20:48:01 -04:00
i = len ( self . weatherMaps ) - 1 if ( self . mapIndex - 1 < 0 ) else self . mapIndex - 1 # get the index for the current map in the animation
2021-03-27 16:22:48 -04:00
self . showImage ( self . weatherMaps [ i ] , self . config [ " scale " ] ) # show the current map in the animation
else :
self . showImage ( self . data [ " weatherNow " ] , self . config [ " scale " ] ) # show the most recent map
def on_spnSpeed_value_changed ( self , spn ) :
self . config [ " animationSpeed " ] = self . adjSpeed . get_value ( ) # get the animation speed
def on_mapWindow_delete ( self , * args ) :
# cancel the timer if it's running
if ( self . animateTimer is not None ) :
self . animateTimer . cancel ( )
self . animateStop = True
# wait for animation to finish
while ( self . animateBusy ) :
self . parent . debugLog ( " Waiting for animation to finish " )
if ( self . animateTimer is not None ) :
self . animateTimer . cancel ( )
time . sleep ( 0.25 )
self . config [ " windowPos " ] = self . mapWindow . get_position ( ) # store current window position
self . config [ " windowSize " ] = self . mapWindow . get_size ( ) # store current window size
self . callback ( ) # run the callback
def animate ( self ) :
fileName = self . weatherMaps [ self . mapIndex ] if len ( self . weatherMaps ) else " "
if ( os . path . isfile ( fileName ) ) :
self . animateBusy = True # set busy to true
if ( self . config [ " scale " ] ) :
mapImg = imgToPixbuf ( Image . open ( fileName ) . resize ( ( 600 , 600 ) , Image . LANCZOS ) ) # open weather map, resize to 600x600, and convert to pixbuf
else :
mapImg = imgToPixbuf ( Image . open ( fileName ) ) # open weather map and convert to pixbuf
if ( self . config [ " animate " ] and self . config [ " mode " ] == 1 and not self . animateStop ) : # check if the viwer is set to animated weather map
self . imgMap . set_from_pixbuf ( mapImg ) # display image
self . mapIndex + = 1 # incriment image index
if ( self . mapIndex > = len ( self . weatherMaps ) ) : # check if this is the last image
self . mapIndex = 0 # reset the map index
self . animateTimer = Timer ( 2 , self . animate ) # show the last image for a longer time
else :
self . animateTimer = Timer ( self . config [ " animationSpeed " ] , self . animate ) # set the timer to the normal speed
self . animateTimer . start ( ) # start the timer
else :
self . animateTimer = None # clear the timer
self . animateBusy = False # set busy to false
else :
self . chkAnimate . set_active ( False ) # stop animation if image was not found
self . mapIndex = 0
def showImage ( self , fileName , scale ) :
if ( os . path . isfile ( fileName ) ) :
2021-03-28 20:48:01 -04:00
if ( scale ) :
mapImg = Image . open ( fileName ) . resize ( ( 600 , 600 ) , Image . LANCZOS ) # open and scale map to fit window
else :
mapImg = Image . open ( fileName ) # open map
2021-03-27 16:22:48 -04:00
self . imgMap . set_from_pixbuf ( imgToPixbuf ( mapImg ) ) # convert image to pixbuf and display
else :
#self.imgMap.set_from_stock(Gtk.STOCK_MISSING_IMAGE, Gtk.ICON_SIZE_LARGE_TOOLBAR) # display missing image if file is not found
2021-04-01 18:17:21 -04:00
#self.imgMap.set_from_stock(Gtk.STOCK_MISSING_IMAGE, Gtk.IconSize.LARGE_TOOLBAR) # display missing image if file is not found
2021-04-03 17:19:54 -04:00
self . imgMap . set_from_icon_name ( " MISSING_IMAGE " , Gtk . IconSize . DIALOG )
2021-03-27 16:22:48 -04:00
def setMap ( self , map ) :
2021-03-28 20:48:01 -04:00
global mapDir
if ( map == 0 ) :
self . showImage ( os . path . join ( mapDir , " TrafficMap.png " ) , False ) # show traffic map
elif ( map == 1 ) :
self . showImage ( self . data [ " weatherNow " ] , self . config [ " scale " ] ) # show weather map
2021-03-27 16:22:48 -04:00
def updated ( self , imageType ) :
if ( self . config [ " mode " ] == 0 ) :
self . setMap ( 0 )
elif ( self . config [ " mode " ] == 1 ) :
self . setMap ( 1 )
self . mapIndex = len ( self . weatherMaps ) - 1
def dtToTs ( dt ) :
# convert datetime to timestamp
return int ( ( dt - datetime . datetime ( 1970 , 1 , 1 , tzinfo = tz . tzutc ( ) ) ) . total_seconds ( ) )
def tsToDt ( ts ) :
# convert timestamp to datetime
return datetime . datetime . utcfromtimestamp ( ts )
def imgToPixbuf ( img ) :
# convert PIL.Image to gdk.pixbuf
#imgArr = numpy.array(img.convert("RGB"))
#return gtk.gdk.pixbuf_new_from_array(imgArr, gtk.gdk.COLORSPACE_RGB, 8)
data = GLib . Bytes . new ( img . tobytes ( ) )
return GdkPixbuf . Pixbuf . new_from_bytes ( data , GdkPixbuf . Colorspace . RGB , ' A ' in img . getbands ( ) ,
8 , img . width , img . height , len ( img . getbands ( ) ) * img . width )
if __name__ == " __main__ " :
# show main window and start main thread
nrsc5_dui = NRSC5_DUI ( )
nrsc5_dui . mainWindow . show ( )
if ( debugMessages and debugAutoStart ) :
nrsc5_dui . on_btnPlay_clicked ( nrsc5_dui )
Gtk . main ( )
