721aeecda3507154c9505d1202882c0c103a9c4f
[watersofshiloah] / src / windows / _base.py
1 from __future__ import with_statement
2
3 import ConfigParser
4 import logging
5
6 import gobject
7 import gtk
8
9 import constants
10 import hildonize
11 import util.misc as misc_utils
12 import util.go_utils as go_utils
13
14 import stream_index
15 import banners
16 import playcontrol
17 import presenter
18
19
20 _moduleLogger = logging.getLogger(__name__)
21
22
23 class BasicWindow(gobject.GObject, go_utils.AutoSignal):
24
25         __gsignals__ = {
26                 'quit' : (
27                         gobject.SIGNAL_RUN_LAST,
28                         gobject.TYPE_NONE,
29                         (),
30                 ),
31                 'home' : (
32                         gobject.SIGNAL_RUN_LAST,
33                         gobject.TYPE_NONE,
34                         (),
35                 ),
36                 'jump-to' : (
37                         gobject.SIGNAL_RUN_LAST,
38                         gobject.TYPE_NONE,
39                         (gobject.TYPE_PYOBJECT, ),
40                 ),
41                 'rotate' : (
42                         gobject.SIGNAL_RUN_LAST,
43                         gobject.TYPE_NONE,
44                         (gobject.TYPE_BOOLEAN, ),
45                 ),
46                 'fullscreen' : (
47                         gobject.SIGNAL_RUN_LAST,
48                         gobject.TYPE_NONE,
49                         (gobject.TYPE_BOOLEAN, ),
50                 ),
51         }
52
53         def __init__(self, app, player, store):
54                 gobject.GObject.__init__(self)
55                 self._isDestroyed = False
56
57                 self._app = app
58                 self._player = player
59                 self._store = store
60
61                 self._clipboard = gtk.clipboard_get()
62                 self._windowInFullscreen = False
63
64                 self._errorBanner = banners.StackingBanner()
65
66                 self._layout = gtk.VBox()
67                 self._layout.pack_start(self._errorBanner.toplevel, False, True)
68
69                 self._window = gtk.Window()
70                 go_utils.AutoSignal.__init__(self, self.window)
71                 self._window.add(self._layout)
72                 self._window = hildonize.hildonize_window(self._app, self._window)
73
74                 self._window.set_icon(self._store.get_pixbuf_from_store(self._store.STORE_LOOKUP["icon"]))
75                 self._window.connect("key-press-event", self._on_key_press)
76                 self._window.connect("window-state-event", self._on_window_state_change)
77                 self._window.connect("destroy", self._on_destroy)
78
79         @property
80         def window(self):
81                 return self._window
82
83         def show(self):
84                 hildonize.window_to_portrait(self._window)
85                 self._window.show_all()
86
87         def save_settings(self, config, sectionName):
88                 config.add_section(sectionName)
89                 config.set(sectionName, "fullscreen", str(self._windowInFullscreen))
90
91         def load_settings(self, config, sectionName):
92                 try:
93                         self._windowInFullscreen = config.getboolean(sectionName, "fullscreen")
94                 except ConfigParser.NoSectionError, e:
95                         _moduleLogger.info(
96                                 "Settings file %s is missing section %s" % (
97                                         constants._user_settings_,
98                                         e.section,
99                                 )
100                         )
101
102                 if self._windowInFullscreen:
103                         self._window.fullscreen()
104                 else:
105                         self._window.unfullscreen()
106
107         def jump_to(self, node):
108                 raise NotImplementedError("On %s" % self)
109
110         @misc_utils.log_exception(_moduleLogger)
111         def _on_destroy(self, *args):
112                 self._isDestroyed = True
113
114         @misc_utils.log_exception(_moduleLogger)
115         def _on_window_state_change(self, widget, event, *args):
116                 if event.new_window_state & gtk.gdk.WINDOW_STATE_FULLSCREEN:
117                         self._windowInFullscreen = True
118                 else:
119                         self._windowInFullscreen = False
120                 self.emit("fullscreen", self._windowInFullscreen)
121
122         @misc_utils.log_exception(_moduleLogger)
123         def _on_key_press(self, widget, event, *args):
124                 RETURN_TYPES = (gtk.keysyms.Return, gtk.keysyms.ISO_Enter, gtk.keysyms.KP_Enter)
125                 isCtrl = bool(event.get_state() & gtk.gdk.CONTROL_MASK)
126                 if (
127                         event.keyval == gtk.keysyms.F6 or
128                         event.keyval in RETURN_TYPES and isCtrl
129                 ):
130                         # The "Full screen" hardware key has been pressed
131                         if self._windowInFullscreen:
132                                 self._window.unfullscreen ()
133                         else:
134                                 self._window.fullscreen ()
135                         return True
136                 elif (
137                         event.keyval in (gtk.keysyms.w, ) and
138                         event.get_state() & gtk.gdk.CONTROL_MASK
139                 ):
140                         self._window.destroy()
141                 elif (
142                         event.keyval in (gtk.keysyms.q, ) and
143                         event.get_state() & gtk.gdk.CONTROL_MASK
144                 ):
145                         self.emit("quit")
146                 elif event.keyval == gtk.keysyms.l and event.get_state() & gtk.gdk.CONTROL_MASK:
147                         with open(constants._user_logpath_, "r") as f:
148                                 logLines = f.xreadlines()
149                                 log = "".join(logLines)
150                                 self._clipboard.set_text(str(log))
151                         return True
152
153         @misc_utils.log_exception(_moduleLogger)
154         def _on_home(self, *args):
155                 self.emit("home")
156                 self._window.destroy()
157
158         @misc_utils.log_exception(_moduleLogger)
159         def _on_jump(self, source, node):
160                 raise NotImplementedError("On %s" % self)
161
162         @misc_utils.log_exception(_moduleLogger)
163         def _on_quit(self, *args):
164                 self.emit("quit")
165                 self._window.destroy()
166
167
168 class ListWindow(BasicWindow):
169
170         def __init__(self, app, player, store, node):
171                 BasicWindow.__init__(self, app, player, store)
172                 self._node = node
173
174                 self.connect_auto(self._player, "title-change", self._on_player_title_change)
175
176                 self._loadingBanner = banners.GenericBanner()
177
178                 modelTypes, columns = zip(*self._get_columns())
179
180                 self._model = gtk.ListStore(*modelTypes)
181
182                 self._treeView = gtk.TreeView()
183                 self._treeView.connect("row-activated", self._on_row_activated)
184                 self._treeView.set_property("fixed-height-mode", True)
185                 self._treeView.set_headers_visible(False)
186                 self._treeView.set_model(self._model)
187                 for column in columns:
188                         if column is not None:
189                                 self._treeView.append_column(column)
190
191                 viewport = gtk.Viewport()
192                 viewport.add(self._treeView)
193
194                 self._treeScroller = gtk.ScrolledWindow()
195                 self._treeScroller.add(viewport)
196                 self._treeScroller.set_policy(gtk.POLICY_NEVER, gtk.POLICY_AUTOMATIC)
197                 self._treeScroller = hildonize.hildonize_scrollwindow(self._treeScroller)
198
199                 self._separator = gtk.HSeparator()
200                 self._playcontrol = playcontrol.NavControl(self._player, self._store)
201                 self._playcontrol.connect("home", self._on_home)
202                 self._playcontrol.connect("jump-to", self._on_jump)
203
204                 self._contentLayout = gtk.VBox(False)
205                 self._contentLayout.pack_start(self._treeScroller, True, True)
206                 self._contentLayout.pack_start(self._separator, False, True)
207                 self._contentLayout.pack_start(self._playcontrol.toplevel, False, True)
208
209                 self._layout.pack_start(self._loadingBanner.toplevel, False, False)
210                 self._layout.pack_start(self._contentLayout, True, True)
211
212         def show(self):
213                 BasicWindow.show(self)
214
215                 self._errorBanner.toplevel.hide()
216                 self._loadingBanner.toplevel.hide()
217
218                 self._refresh()
219                 self._playcontrol.refresh()
220
221         @classmethod
222         def _get_columns(cls):
223                 raise NotImplementedError("")
224
225         def _get_current_row(self):
226                 if self._player.node is None:
227                         return -1
228                 ancestors, current, descendants = stream_index.common_paths(self._player.node, self._node)
229                 if not descendants:
230                         return -1
231                 activeChild = descendants[0]
232                 for i, row in enumerate(self._model):
233                         if activeChild is row[0]:
234                                 return i
235                 else:
236                         return -1
237
238         def jump_to(self, node):
239                 ancestors, current, descendants = stream_index.common_paths(node, self._node)
240                 if current is None:
241                         raise RuntimeError("Cannot jump to node %s" % node)
242                 if not descendants:
243                         _moduleLogger.info("Current node is the target")
244                         return
245                 child = descendants[0]
246                 window = self._window_from_node(child)
247                 window.jump_to(node)
248
249         def _window_from_node(self, node):
250                 raise NotImplementedError("")
251
252         @misc_utils.log_exception(_moduleLogger)
253         def _on_row_activated(self, view, path, column):
254                 itr = self._model.get_iter(path)
255                 node = self._model.get_value(itr, 0)
256                 self._window_from_node(node)
257
258         @misc_utils.log_exception(_moduleLogger)
259         def _on_player_title_change(self, player, node):
260                 self._select_row()
261
262         @misc_utils.log_exception(_moduleLogger)
263         def _on_jump(self, source, node):
264                 ancestors, current, descendants = stream_index.common_paths(node, self._node)
265                 if current is None:
266                         _moduleLogger.info("%s is not the target, moving up" % self._node)
267                         self.emit("jump-to", node)
268                         self._window.destroy()
269                         return
270                 if not descendants:
271                         _moduleLogger.info("Current node is the target")
272                         return
273                 child = descendants[0]
274                 window = self._window_from_node(child)
275                 window.jump_to(node)
276
277         def _show_loading(self):
278                 animationPath = self._store.STORE_LOOKUP["loading"]
279                 animation = self._store.get_pixbuf_animation_from_store(animationPath)
280                 self._loadingBanner.show(animation, "Loading...")
281
282         def _hide_loading(self):
283                 self._loadingBanner.hide()
284
285         def _refresh(self):
286                 self._show_loading()
287                 self._model.clear()
288
289         def _select_row(self):
290                 rowIndex = self._get_current_row()
291                 if rowIndex < 0:
292                         return
293                 path = (rowIndex, )
294                 self._treeView.scroll_to_cell(path)
295                 self._treeView.get_selection().select_path(path)
296
297
298 class PresenterWindow(BasicWindow):
299
300         def __init__(self, app, player, store, node):
301                 BasicWindow.__init__(self, app, player, store)
302                 self._node = node
303                 self._playerNode = self._player.node
304                 self._nextSearch = None
305                 self._updateSeek = None
306
307                 self.connect_auto(self._player, "state-change", self._on_player_state_change)
308                 self.connect_auto(self._player, "title-change", self._on_player_title_change)
309                 self.connect_auto(self._player, "error", self._on_player_error)
310
311                 self._loadingBanner = banners.GenericBanner()
312
313                 self._presenter = presenter.StreamPresenter(self._store)
314                 self._presenter.set_context(
315                         self._get_background(),
316                         self._node.title,
317                         self._node.subtitle,
318                 )
319                 self._presenterNavigation = presenter.NavigationBox()
320                 self._presenterNavigation.toplevel.add(self._presenter.toplevel)
321                 self._presenterNavigation.connect("action", self._on_nav_action)
322                 self._presenterNavigation.connect("navigating", self._on_navigating)
323
324                 self._seekbar = hildonize.create_seekbar()
325                 self._seekbar.connect("change-value", self._on_user_seek)
326
327                 self._layout.pack_start(self._loadingBanner.toplevel, False, False)
328                 self._layout.pack_start(self._presenterNavigation.toplevel, True, True)
329                 self._layout.pack_start(self._seekbar, False, False)
330
331                 self._window.set_title(self._node.title)
332
333         def _get_background(self):
334                 raise NotImplementedError()
335
336         def show(self):
337                 BasicWindow.show(self)
338                 self._window.show_all()
339                 self._errorBanner.toplevel.hide()
340                 self._loadingBanner.toplevel.hide()
341                 self._set_context(self._player.state)
342                 self._seekbar.hide()
343
344         def jump_to(self, node):
345                 assert self._node is node
346
347         @property
348         def _active(self):
349                 return self._playerNode is self._node
350
351         def _show_loading(self):
352                 animationPath = self._store.STORE_LOOKUP["loading"]
353                 animation = self._store.get_pixbuf_animation_from_store(animationPath)
354                 self._loadingBanner.show(animation, "Loading...")
355
356         def _hide_loading(self):
357                 self._loadingBanner.hide()
358
359         def _set_context(self, state):
360                 if state == self._player.STATE_PLAY:
361                         if self._active:
362                                 self._presenter.set_state(self._store.STORE_LOOKUP["pause"])
363                         else:
364                                 self._presenter.set_state(self._store.STORE_LOOKUP["play"])
365                 elif state == self._player.STATE_PAUSE:
366                         self._presenter.set_state(self._store.STORE_LOOKUP["play"])
367                 elif state == self._player.STATE_STOP:
368                         self._presenter.set_state(self._store.STORE_LOOKUP["play"])
369                 else:
370                         _moduleLogger.info("Unhandled player state %s" % state)
371
372         @misc_utils.log_exception(_moduleLogger)
373         def _on_user_seek(self, widget, scroll, value):
374                 self._player.seek(value / 100.0)
375
376         @misc_utils.log_exception(_moduleLogger)
377         def _on_player_update_seek(self):
378                 if self._isDestroyed:
379                         return False
380                 self._seekbar.set_value(self._player.percent_elapsed * 100)
381                 return True
382
383         @misc_utils.log_exception(_moduleLogger)
384         def _on_player_state_change(self, player, newState):
385                 if self._active and self._player.state == self._player.STATE_PLAY:
386                         self._seekbar.show()
387                         assert self._updateSeek is None
388                         self._updateSeek = go_utils.Timeout(self._on_player_update_seek, once=False)
389                         self._updateSeek.start(seconds=1)
390                 else:
391                         self._seekbar.hide()
392                         if self._updateSeek is not None:
393                                 self._updateSeek.cancel()
394                                 self._updateSeek = None
395
396                 if not self._presenterNavigation.is_active():
397                         self._set_context(newState)
398
399         @misc_utils.log_exception(_moduleLogger)
400         def _on_player_title_change(self, player, node):
401                 if not self._active or node in [None, self._node]:
402                         self._playerNode = player.node
403                         return
404                 self._playerNode = player.node
405                 self.emit("jump-to", node)
406                 self._window.destroy()
407
408         @misc_utils.log_exception(_moduleLogger)
409         def _on_player_error(self, player, err, debug):
410                 _moduleLogger.error("%r - %r" % (err, debug))
411
412         @misc_utils.log_exception(_moduleLogger)
413         def _on_navigating(self, widget, navState):
414                 if navState == "clicking":
415                         if self._player.state == self._player.STATE_PLAY:
416                                 if self._active:
417                                         imageName = "pause_pressed"
418                                 else:
419                                         imageName = "play_pressed"
420                         elif self._player.state == self._player.STATE_PAUSE:
421                                 imageName = "play_pressed"
422                         elif self._player.state == self._player.STATE_STOP:
423                                 imageName = "play_pressed"
424                         else:
425                                 _moduleLogger.info("Unhandled player state %s" % self._player.state)
426                 elif navState == "down":
427                         imageName = "home"
428                 elif navState == "up":
429                         if self._player.state == self._player.STATE_PLAY:
430                                 if self._active:
431                                         imageName = "pause"
432                                 else:
433                                         imageName = "play"
434                         elif self._player.state == self._player.STATE_PAUSE:
435                                 imageName = "play"
436                         elif self._player.state == self._player.STATE_STOP:
437                                 imageName = "play"
438                         else:
439                                 _moduleLogger.info("Unhandled player state %s" % self._player.state)
440                 elif navState == "left":
441                         imageName = "next"
442                 elif navState == "right":
443                         imageName = "prev"
444
445                 self._presenter.set_state(self._store.STORE_LOOKUP[imageName])
446
447         @misc_utils.log_exception(_moduleLogger)
448         def _on_nav_action(self, widget, navState):
449                 self._set_context(self._player.state)
450
451                 if navState == "clicking":
452                         if self._player.state == self._player.STATE_PLAY:
453                                 if self._active:
454                                         self._player.pause()
455                                 else:
456                                         self._player.set_piece_by_node(self._node)
457                                         self._player.play()
458                         elif self._player.state == self._player.STATE_PAUSE:
459                                 self._player.play()
460                         elif self._player.state == self._player.STATE_STOP:
461                                 self._player.set_piece_by_node(self._node)
462                                 self._player.play()
463                         else:
464                                 _moduleLogger.info("Unhandled player state %s" % self._player.state)
465                 elif navState == "down":
466                         self.emit("home")
467                         self._window.destroy()
468                 elif navState == "up":
469                         pass
470                 elif navState == "left":
471                         if self._active:
472                                 self._player.next()
473                         else:
474                                 assert self._nextSearch is None
475                                 self._nextSearch = stream_index.AsyncWalker(stream_index.get_next)
476                                 self._nextSearch.start(self._node, self._on_next_node, self._on_node_search_error)
477                 elif navState == "right":
478                         if self._active:
479                                 self._player.back()
480                         else:
481                                 assert self._nextSearch is None
482                                 self._nextSearch = stream_index.AsyncWalker(stream_index.get_previous)
483                                 self._nextSearch.start(self._node, self._on_next_node, self._on_node_search_error)
484
485         @misc_utils.log_exception(_moduleLogger)
486         def _on_next_node(self, node):
487                 self._nextSearch = None
488                 self.emit("jump-to", node)
489                 self._window.destroy()
490
491         @misc_utils.log_exception(_moduleLogger)
492         def _on_node_search_error(self, e):
493                 self._nextSearch = None
494                 self._errorBanner.push_message(str(e))