annotate bin/ascoltami2 @ 1917:713e56e8e2b9

rdfdb load tester Ignore-this: ca714a9f84b3c0f0aa05b3805cd7344b
author Drew Perttula <drewp@bigasterisk.com>
date Sat, 01 Jun 2019 20:07:27 +0000
parents 3c523c71da29
children a745bee5c419
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
686
a301a0039c66 buildout and rdflib updates
Drew Perttula <drewp@bigasterisk.com>
parents: 674
diff changeset
1 #!bin/python
868
224d6cd7e1e4 asco use colored logs
Drew Perttula <drewp@bigasterisk.com>
parents: 793
diff changeset
2 from run_local import log
1011
78690efc866c fix ascoltami import
drewp@bigasterisk.com
parents: 938
diff changeset
3 from twisted.internet import reactor
1866
3c523c71da29 pyflakes cleanups and some refactors
Drew Perttula <drewp@bigasterisk.com>
parents: 1861
diff changeset
4 import sys, optparse, logging
529
1156d3531327 new ascoltami2, using gstreamer
drewp@bigasterisk.com
parents:
diff changeset
5 from rdflib import URIRef
1533
c962f19c7328 pin gtk version in asco
Drew Perttula <drewp@bigasterisk.com>
parents: 1026
diff changeset
6 import gi
c962f19c7328 pin gtk version in asco
Drew Perttula <drewp@bigasterisk.com>
parents: 1026
diff changeset
7 gi.require_version('Gst', '1.0')
c962f19c7328 pin gtk version in asco
Drew Perttula <drewp@bigasterisk.com>
parents: 1026
diff changeset
8 gi.require_version('Gtk', '3.0')
c962f19c7328 pin gtk version in asco
Drew Perttula <drewp@bigasterisk.com>
parents: 1026
diff changeset
9
529
1156d3531327 new ascoltami2, using gstreamer
drewp@bigasterisk.com
parents:
diff changeset
10 from light9.ascoltami.player import Player
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
11 from light9.ascoltami.playlist import Playlist, NoSuchSong
788
8d87a3528369 go button support
drewp@bigasterisk.com
parents: 686
diff changeset
12 from light9.ascoltami.webapp import makeWebApp, songUri, songLocation
529
1156d3531327 new ascoltami2, using gstreamer
drewp@bigasterisk.com
parents:
diff changeset
13 from light9 import networking, showconfig
1156d3531327 new ascoltami2, using gstreamer
drewp@bigasterisk.com
parents:
diff changeset
14
1866
3c523c71da29 pyflakes cleanups and some refactors
Drew Perttula <drewp@bigasterisk.com>
parents: 1861
diff changeset
15 from gi.repository import GObject, Gst
673
865532790e62 asco don't log every web request. too much "GET /time"
Drew Perttula <drewp@bigasterisk.com>
parents: 623
diff changeset
16
1858
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
17
907
cca75951554a port ascoltami to Gst 1.0, work around the missing message signals
Drew Perttula <drewp@bigasterisk.com>
parents: 868
diff changeset
18 class App(object):
1858
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
19
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
20 def __init__(self, graph, show):
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
21 self.graph = graph
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
22 self.player = Player(onEOS=self.onEOS)
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
23 self.show = show
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
24 self.playlist = Playlist.fromShow(graph, show)
529
1156d3531327 new ascoltami2, using gstreamer
drewp@bigasterisk.com
parents:
diff changeset
25
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
26 def onEOS(self, song):
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
27 self.player.pause()
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
28 self.player.seek(0)
529
1156d3531327 new ascoltami2, using gstreamer
drewp@bigasterisk.com
parents:
diff changeset
29
788
8d87a3528369 go button support
drewp@bigasterisk.com
parents: 686
diff changeset
30 thisSongUri = songUri(graph, URIRef(song))
8d87a3528369 go button support
drewp@bigasterisk.com
parents: 686
diff changeset
31
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
32 try:
788
8d87a3528369 go button support
drewp@bigasterisk.com
parents: 686
diff changeset
33 nextSong = self.playlist.nextSong(thisSongUri)
1858
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
34 except NoSuchSong: # we're at the end of the playlist
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
35 return
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
36
788
8d87a3528369 go button support
drewp@bigasterisk.com
parents: 686
diff changeset
37 self.player.setSong(songLocation(graph, nextSong), play=False)
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
38
1858
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
39
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
40 if __name__ == "__main__":
907
cca75951554a port ascoltami to Gst 1.0, work around the missing message signals
Drew Perttula <drewp@bigasterisk.com>
parents: 868
diff changeset
41 GObject.threads_init()
cca75951554a port ascoltami to Gst 1.0, work around the missing message signals
Drew Perttula <drewp@bigasterisk.com>
parents: 868
diff changeset
42 Gst.init(None)
529
1156d3531327 new ascoltami2, using gstreamer
drewp@bigasterisk.com
parents:
diff changeset
43
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
44 parser = optparse.OptionParser()
1858
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
45 parser.add_option(
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
46 '--show',
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
47 help='show URI, like http://light9.bigasterisk.com/show/dance2008',
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
48 default=showconfig.showUri())
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
49 parser.add_option("-v",
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
50 "--verbose",
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
51 action="store_true",
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
52 help="logging.DEBUG")
1858
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
53 parser.add_option("--twistedlog",
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
54 action="store_true",
938
c2faa69099e6 asco: display update frequency and dim when updates stop. run slower updates on tablets and phones
drewp@bigasterisk.com
parents: 907
diff changeset
55 help="twisted logging")
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
56 (options, args) = parser.parse_args()
529
1156d3531327 new ascoltami2, using gstreamer
drewp@bigasterisk.com
parents:
diff changeset
57
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
58 log.setLevel(logging.DEBUG if options.verbose else logging.INFO)
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
59
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
60 if not options.show:
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
61 raise ValueError("missing --show http://...")
1858
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1533
diff changeset
62
617
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
63 graph = showconfig.getGraph()
94039df5cdd9 create Playlist class which is now used in wavecurve, musicPad, and ascoltami2.
David McClosky <dmcc@bigasterisk.com>
parents: 536
diff changeset
64 app = App(graph, URIRef(options.show))
938
c2faa69099e6 asco: display update frequency and dim when updates stop. run slower updates on tablets and phones
drewp@bigasterisk.com
parents: 907
diff changeset
65 if options.twistedlog:
c2faa69099e6 asco: display update frequency and dim when updates stop. run slower updates on tablets and phones
drewp@bigasterisk.com
parents: 907
diff changeset
66 from twisted.python import log as twlog
c2faa69099e6 asco: display update frequency and dim when updates stop. run slower updates on tablets and phones
drewp@bigasterisk.com
parents: 907
diff changeset
67 twlog.startLogging(sys.stderr)
907
cca75951554a port ascoltami to Gst 1.0, work around the missing message signals
Drew Perttula <drewp@bigasterisk.com>
parents: 868
diff changeset
68 reactor.listenTCP(networking.musicPlayer.port, makeWebApp(app))
cca75951554a port ascoltami to Gst 1.0, work around the missing message signals
Drew Perttula <drewp@bigasterisk.com>
parents: 868
diff changeset
69 log.info("listening on %s" % networking.musicPlayer.port)
cca75951554a port ascoltami to Gst 1.0, work around the missing message signals
Drew Perttula <drewp@bigasterisk.com>
parents: 868
diff changeset
70 reactor.run()