home *** CD-ROM | disk | FTP | other *** search
/ Usenet 1994 October / usenetsourcesnewsgroupsinfomagicoctober1994disk2.iso / misc / volume30 / radio2.0 / part02 / ttytuner.py < prev   
Encoding:
Python Source  |  1992-06-29  |  6.8 KB  |  267 lines
  1. #!/usr/local/python
  2.  
  3. # /***********************************************************
  4. # Copyright 1991, 1992 by Stichting Mathematisch Centrum, Amsterdam, The
  5. # Netherlands.
  6. # 
  7. #                         All Rights Reserved
  8. # 
  9. # Permission to use, copy, modify, and distribute this software and its 
  10. # documentation for any purpose and without fee is hereby granted, 
  11. # provided that the above copyright notice appear in all copies and that
  12. # both that copyright notice and this permission notice appear in 
  13. # supporting documentation, and that the names of Stichting Mathematisch
  14. # Centrum or CWI not be used in advertising or publicity pertaining to
  15. # distribution of the software without specific, written prior permission.
  16. # 
  17. # STICHTING MATHEMATISCH CENTRUM DISCLAIMS ALL WARRANTIES WITH REGARD TO
  18. # THIS SOFTWARE, INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND
  19. # FITNESS, IN NO EVENT SHALL STICHTING MATHEMATISCH CENTRUM BE LIABLE
  20. # FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
  21. # WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
  22. # ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT
  23. # OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  24. # 
  25. # ******************************************************************/
  26.  
  27. # A tuner to control radio programs, by Jack Jansen.
  28.  
  29. import sys
  30. import os
  31. import time
  32. import socket
  33. import time
  34. import string
  35. import getopt
  36. from stat import ST_MTIME
  37.  
  38.  
  39. RADIOCTLPORT=54320
  40. TRANSMITTERCTLPORT=54319
  41. CTLWS=socket.gethostname()
  42.  
  43. # The list of networks to broadcast on, when looking for radio
  44. # stations. This should somehow be gotten differently.
  45. #
  46. MCASTLIST = ['192.16.184.0', '192.16.191.0', '192.16.201.255']
  47. # MCASTLIST = ['192.16.201.255']
  48.  
  49. class struct(): pass
  50. info = struct()
  51.  
  52. #
  53. # sendsock - send a message (and get optional reply)
  54. #
  55. def sendsock(host, port, msg, needrepl):
  56.     try:
  57.     host = socket.gethostbyname(host)
  58.     s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
  59.     s.sendto(msg, (host,port))
  60.     if needrepl:
  61.         # Loop for max. 2.5 seconds waiting for a reply
  62.         i = 0
  63.         while i < 5 and not s.avail():
  64.         time.millisleep(500)
  65.         i = i + 1
  66.         if not s.avail():
  67.         print 'Radio program not responding'
  68.         return ''
  69.         return s.recv(500)
  70.     except socket.error:
  71.     print 'Incorrect radio settings'
  72.     if needrepl:
  73.         return ''
  74.     else:
  75.         return
  76. #
  77. # sendmulti - send a multicast message (and get replies)
  78. #
  79. def sendmulti(mcastlist, port, msg):
  80.     rv = []
  81.     try:
  82.     s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
  83.     s.allowbroadcast(1)
  84.     for host in mcastlist:
  85.         s.sendto(msg, (host,port))
  86.     # Loop for max. 2.5 seconds waiting for a reply
  87.     i = 0
  88.     while i < 25:
  89.         time.millisleep(100)
  90.         i = i + 1
  91.         if s.avail():
  92.         rv.append(s.recv(500))
  93.     except socket.error:
  94.     print 'Incorrect mcast settings'
  95.     return rv
  96. #
  97. # getstationinfo - Return playlist, current and playing time (in minutes).
  98. # Returns a triple (playlist-filename, current record, playing time)
  99. #
  100. def getstationinfo(info):
  101.     name = info[0]
  102.     if len(info) > 3:
  103.     playlist = info[3]
  104.     else:
  105.     playlist = '/ufs/' + name + '/CDlog'
  106.     if len(info) > 5:
  107.     since = eval(info[4])
  108.     cur = string.joinfields(info[5:], ':')
  109.     else:
  110.     curfn = '/ufs/' + name + '/CD'
  111.     try:
  112.         curf = open(curfn,'r')
  113.         cur = curf.readline()
  114.         curf.close()
  115.     except IOError:
  116.         cur = '???'
  117.     if cur[-1:] == '\n':
  118.         cur = cur[:-1]
  119.     try:
  120.         sb = os.stat(curfn)
  121.         since = time.time() - sb[ST_MTIME]
  122.     except os.error:
  123.         since = -1
  124.     if since >= 0: since = since / 60 # Convert to minutes
  125.     if since < 0:
  126.     str = '??'
  127.     elif since < 60:
  128.     str = `since` + ' mins'
  129.     else:
  130.     since = since / 60
  131.     if since < 24:
  132.         str = `since` + ' hrs'
  133.     else:
  134.         str = `since / 24` + ' days'
  135.     return playlist, cur, str
  136.  
  137. #
  138. # updateinfo - Update one of the views with info on station 'name'
  139. #
  140. def printinfo(info):
  141.     name = info[0]
  142.     print 'Station '+ name + ':'
  143.     print '\tPort               ' + `info[1]`
  144.     if name == '' or name[:3] == '???':
  145.     print '\tNo information on station'
  146.     else:
  147.     try:
  148.         p, c, t = getstationinfo(info)
  149.     except IOError:
  150.         return
  151.     if c <> '' and c <> '???':
  152.         print '\tCurrently playing: ' + c
  153.     if t <> '??':
  154.         print '\tSince:             ' + t
  155.     if p <> '':
  156.         print '\tPlaylist in file:  ' + p
  157.  
  158. #
  159. # getstations - Return an array of (stationname, stationport)
  160. # listing all available stations.
  161. #
  162. def getstations():
  163.     stations = []
  164.     raw = sendmulti(MCASTLIST, TRANSMITTERCTLPORT, 'radio:s')
  165.     for i in raw:
  166.     if i[:7] == 'radio:S':
  167.         fields = string.splitfields(i,':')[2:]
  168.         fields[1] = string.atoi(fields[1])
  169.         stations.append(fields)
  170.     else:
  171.         print 'Funny reply from transmitter:', i[:7]
  172.     return stations
  173.  
  174. #
  175. # getcurstation - Return (name,port) for station to which radio
  176. # on workstation ws is currently tuned to.
  177. #
  178. def getcurstation(stationlist, ws, port):
  179.     rv = sendsock(ws, port, 'radio:i', 1)
  180.     if rv == '':
  181.     return ('',0)
  182.     if rv[0:8] <> 'radio:I:':
  183.     print 'Illegal reply from radio:',rv
  184.     return ('',0)
  185.     # Remove optional pause field
  186.     rv = rv[8:]
  187.     rv = string.splitfields(rv,':')
  188.     rv = rv[len(rv)-1]
  189.     tport = string.atoi(rv)
  190.     for i in stationlist:
  191.     if i[1] == tport:
  192.         return i
  193.     return ('???(port '+`tport`+')' ,tport)
  194.  
  195. def main():
  196.     radio_port = RADIOCTLPORT
  197.     radio_ws = CTLWS
  198.     try:
  199.     optlist, args = getopt.getopt(sys.argv[1:], 'w:p:lLcPC')
  200.     mode = ''
  201.     for o, a in optlist:
  202.         if o == '-w':
  203.         radio_ws = a
  204.         elif o == '-p':
  205.         radio_port = string.atoi(a)
  206.         elif mode == '':
  207.         mode = o[1]
  208.         else:
  209.         raise getopt.error
  210.     if len(args) + len(mode) <> 1:
  211.         raise getopt.error
  212.     except getopt.error:
  213.     print 'Usage: '+sys.argv[0]+' [options] command'
  214.     print 'Options:'
  215.     print '\t-w ws\tControl radio on workstation ws'
  216.     print '\t-p port\tControl radio on port port'
  217.     print 'Command:'
  218.     print '\t-l\tList names of active stations'
  219.     print '\t-L\tList names and info of active stations'
  220.     print '\t-c\tList info on current station'
  221.     print '\t-P\tTemporarily suspend radio, freeing port'
  222.     print '\t-C\tContinue radio'
  223.     print '\tstation\tTune to new station'
  224.     sys.exit(1)
  225.     
  226.     #
  227.     # First, do pause/continue command.
  228.     #
  229.     if mode == 'P':
  230.     sendsock(radio_ws, radio_port, 'radio:0', 0)
  231.     sys.exit(0)
  232.     if mode == 'C':
  233.     sendsock(radio_ws, radio_port, 'radio:1', 0)
  234.     sys.exit(0)
  235.     #
  236.     # And list of new stations
  237.     #
  238.     stations = getstations()
  239.     #
  240.     # Set info for current station
  241.     #
  242.     if mode == '' or mode == 'c':
  243.     cn = getcurstation(stations,radio_ws, radio_port)
  244.     if mode == 'l':
  245.     for i in stations:
  246.         print i[0]
  247.     elif mode == 'L':
  248.     for i in stations:
  249.         printinfo(i)
  250.     elif mode == 'c':
  251.     printinfo(cn)
  252.     else:
  253.     for i in range(len(stations)):
  254.         if stations[i][0] == args[0]:
  255.         sendsock(radio_ws, radio_port, \
  256.                 'radio:t:' + `stations[i][1]`, 0)
  257.         sys.exit(0)
  258.     print 'No such station: ', args[0]
  259.     
  260.     
  261.  
  262. main()
  263.  
  264. # Local variables:
  265. # py-indent-offset: 4
  266. # end:
  267.