1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
|
# Copyright (C) 2006 Adam Olsen
#
# 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 1, 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, write to the Free Software
# Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
import gtk, subprocess, os, time, gst
from gettext import gettext as _
from xl import common, media, xlmisc
import xl.plugins as plugins
import xl.path
PLUGIN_NAME = _("Streamripper!")
PLUGIN_AUTHORS = ['Adam Olsen <arolsen@gmail.com>']
PLUGIN_VERSION = '0.1.4'
PLUGIN_DESCRIPTION = _(r"""Allows you to record streams with
streamripper\n\nRequires the command line version of streamripper to be
installed""")
PLUGIN_ENABLED = False
button = gtk.Button()
PLUGIN_ICON = button.render_icon('gtk-media-record', gtk.ICON_SIZE_MENU)
button.destroy()
PLUGIN = None
APP = None
BUTTON = None
STREAMRIPPER_PID = None
STREAMRIPPER_OUT = None
CURRENT_TRACK = None
CONS = plugins.SignalContainer()
def configure():
"""
Shows the configuration dialog for streamripper
"""
exaile = APP
dialog = plugins.PluginConfigDialog(exaile.window, PLUGIN_NAME)
table = gtk.Table(2, 2)
table.set_row_spacings(2)
bottom = 0
label = gtk.Label(_("Save Location: "))
label.set_alignment(0.0, 0.0)
table.attach(label, 0, 1, bottom, bottom + 1)
location = exaile.settings.get_str("save_location", plugin=plugins.name(__file__),
default=os.getenv("HOME"))
save_loc = gtk.FileChooserButton(_("Location"))
save_loc.set_action(gtk.FILE_CHOOSER_ACTION_SELECT_FOLDER)
save_loc.set_current_folder(location)
table.attach(save_loc, 1, 2, bottom, bottom + 1)
bottom += 1
label = gtk.Label(_("Relay Port:"))
label.set_alignment(0.0, 0.0)
table.attach(label, 0, 1, bottom, bottom + 1)
port = exaile.settings.get_str("relay_port", plugin=plugins.name(__file__), default='8000')
port_entry = gtk.Entry()
port_entry.set_text(port)
port_entry.set_max_length(6)
table.attach(port_entry, 1, 2, bottom, bottom + 1, gtk.SHRINK)
dialog.child.pack_start(table)
dialog.show_all()
result = dialog.run()
dialog.hide()
if result == gtk.RESPONSE_OK:
exaile.settings.set_str("save_location", save_loc.get_current_folder(),
plugin=plugins.name(__file__))
exaile.settings.set_str("relay_port", port_entry.get_text(),
plugin=plugins.name(__file__))
def toggle_record(widget, event=None):
"""
Toggles streamripper
"""
global STREAMRIPPER_PID, STREAMRIPPER_OUT, CURRENT_TRACK
track = APP.player.current
if not STREAMRIPPER_PID:
if not track: return True
if not track.type == 'stream':
common.error(APP.window, _("You can only record streams"))
widget.set_active(False)
return True
savedir = SETTINGS.get_str('save_location',
plugin=plugins.name(__file__),
default=os.getenv("HOME"))
port = SETTINGS.get_int('relay_port', plugin=plugins.name(__file__),
default=8000)
outfile = xl.path.get_config('streamripper.log')
STREAMRIPPER_OUT = open(outfile, "w+", 0)
STREAMRIPPER_OUT.write("Streamripper log file started: %s\n" %
time.strftime("%c", time.localtime()))
STREAMRIPPER_OUT.write(
"-------------------------------------------------\n\n\n")
APP.player.playbin.set_state(gst.STATE_NULL)
xlmisc.log('real location: %s' %
APP.player.playbin.get_property('uri'))
sub = subprocess.Popen(['streamripper',
APP.player.playbin.get_property('uri'), '-r',
str(port), '-d', savedir], stderr=STREAMRIPPER_OUT)
ret = sub.poll()
xlmisc.log("Streamripper return value was %s" % ret)
xlmisc.log("Using streamripper to play location: %s" % track.loc)
APP.status.set_first("Streamripping location: %s..." %
track.loc, 4000)
if ret != None:
common.error(APP.window, _("There was an error"
" executing streamripper."))
return True
STREAMRIPPER_PID = sub.pid
xlmisc.log('Proxy location: http://localhost:%d' % port)
APP.player.playbin.set_property('uri', "http://localhost:%d" % port)
time.sleep(1)
APP.player.playbin.set_state(gst.STATE_PLAYING)
CURRENT_TRACK = track
return False
else:
if not STREAMRIPPER_PID:
common.error(APP.window, _("Streamripper is not running."))
os.system("kill -9 %d" % STREAMRIPPER_PID)
APP.player.playbin.set_state(gst.STATE_READY)
CURRENT_TRACK = None
APP.player.play_track(track)
STREAMRIPPER_PID = None
return False
def stop():
"""
Stops streamripper by killing it if it's still running, and closes the
log file
"""
global STREAMRIPPER_OUT, STREAMRIPPER_PID
if BUTTON:
BUTTON.set_active(False)
if STREAMRIPPER_OUT:
try:
STREAMRIPPER_OUT.close()
except OSError:
pass
STREAMRIPPER_OUT = None
if STREAMRIPPER_PID:
os.system("kill -9 %d" % STREAMRIPPER_PID)
STREAMRIPPER_PID = None
def stop_track(exaile, track):
"""
Called when playback has stopped on a track
"""
stop()
def initialize():
"""
Checks for streamripper, initializes the plugin
"""
global APP, SETTINGS, BUTTON
exaile = APP
try:
subprocess.call(['streamripper'], stdout=-1, stderr=-1)
except OSError:
raise plugins.PluginInitException("Streamripper is not available, "
"disabling streamripper plugin")
return False
APP = exaile
SETTINGS = exaile.settings
BUTTON = gtk.ToggleButton()
BUTTON.connect('button-release-event', toggle_record)
image = gtk.Image()
image.set_from_stock('gtk-media-record', gtk.ICON_SIZE_SMALL_TOOLBAR)
BUTTON.set_image(image)
toolbar = APP.xml.get_widget('play_toolbar')
toolbar.pack_start(BUTTON, False, False)
toolbar.reorder_child(BUTTON, 3)
CONS.connect(APP.player, 'stop-track', stop_track)
BUTTON.show()
return True
def destroy():
"""
Called when the plugin is disabled. If streamripper is currently
running, kill it and restart the track without using streamripper
"""
global BUTTON, CURRENT_TRACK
stop()
if CURRENT_TRACK:
CURRENT_TRACK.stream_url = None
if CURRENT_TRACK.is_playing():
CURRENT_TRACK.stop()
CURRENT_TRACK.play(APP.on_next)
CURRENT_TRACK = None
if not BUTTON: return
toolbar = APP.xml.get_widget('play_toolbar')
toolbar.remove(BUTTON)
BUTTON.hide()
BUTTON.destroy()
BUTTON = None
CONS.disconnect_all()
|
