git.maemo.org Git - watersofshiloah/blob - src/windows/radio.py

   1 import datetime
   2 import logging
   3
   4 import gobject
   5 import gtk
   6
   7 import hildonize
   8 import util.misc as misc_utils
   9 import util.time_utils as time_utils
  10 import util.go_utils as go_utils
  11 import banners
  12 import presenter
  13
  14 import windows
  15
  16
  17 _moduleLogger = logging.getLogger(__name__)
  18
  19
  20 class RadioWindow(windows._base.BasicWindow):
  21
  22         def __init__(self, app, player, store, node):
  23                 windows._base.BasicWindow.__init__(self, app, player, store)
  24                 self._node = node
  25                 self._childNode = None
  26
  27                 self.connect_auto(self._player, "state-change", self._on_player_state_change)
  28                 self.connect_auto(self._player, "title-change", self._on_player_title_change)
  29
  30                 self._loadingBanner = banners.GenericBanner()
  31
  32                 headerPath = self._store.STORE_LOOKUP["radio_header"]
  33                 self._header = self._store.get_image_from_store(headerPath)
  34                 self._headerNavigation = presenter.NavigationBox()
  35                 self._headerNavigation.toplevel.add(self._header)
  36                 self._headerNavigation.connect("action", self._on_nav_action)
  37                 self._headerNavigation.connect("navigating", self._on_navigating)
  38
  39                 self._programmingModel = gtk.ListStore(
  40                         gobject.TYPE_STRING,
  41                         gobject.TYPE_STRING,
  42                 )
  43
  44                 textrenderer = gtk.CellRendererText()
  45                 timeColumn = gtk.TreeViewColumn("Time")
  46                 textrenderer.set_property("scale", 0.75)
  47                 timeColumn.set_property("sizing", gtk.TREE_VIEW_COLUMN_FIXED)
  48                 timeColumn.set_property("fixed-width", 80)
  49                 timeColumn.pack_start(textrenderer, expand=True)
  50                 timeColumn.add_attribute(textrenderer, "text", 0)
  51
  52                 textrenderer = gtk.CellRendererText()
  53                 titleColumn = gtk.TreeViewColumn("Program")
  54                 titleColumn.set_property("sizing", gtk.TREE_VIEW_COLUMN_FIXED)
  55                 titleColumn.pack_start(textrenderer, expand=True)
  56                 titleColumn.add_attribute(textrenderer, "text", 1)
  57
  58                 self._treeView = gtk.TreeView()
  59                 self._treeView.set_property("fixed-height-mode", True)
  60                 self._treeView.set_headers_visible(False)
  61                 self._treeView.set_model(self._programmingModel)
  62                 self._treeView.append_column(timeColumn)
  63                 self._treeView.append_column(titleColumn)
  64                 self._treeView.get_selection().connect("changed", self._on_row_changed)
  65
  66                 self._viewport = gtk.Viewport()
  67                 self._viewport.add(self._treeView)
  68
  69                 self._treeScroller = gtk.ScrolledWindow()
  70                 self._treeScroller.add(self._viewport)
  71                 self._treeScroller.set_policy(gtk.POLICY_NEVER, gtk.POLICY_AUTOMATIC)
  72                 self._treeScroller = hildonize.hildonize_scrollwindow(self._treeScroller)
  73
  74                 self._presenter = presenter.StreamMiniPresenter(self._store)
  75                 self._presenterNavigation = presenter.NavigationBox()
  76                 self._presenterNavigation.toplevel.add(self._presenter.toplevel)
  77                 self._presenterNavigation.connect("action", self._on_nav_action)
  78                 self._presenterNavigation.connect("navigating", self._on_navigating)
  79
  80                 self._radioLayout = gtk.VBox(False)
  81                 self._radioLayout.pack_start(self._headerNavigation.toplevel, False, False)
  82                 self._radioLayout.pack_start(self._treeScroller, True, True)
  83                 self._radioLayout.pack_start(self._presenterNavigation.toplevel, False, True)
  84
  85                 self._layout.pack_start(self._loadingBanner.toplevel, False, False)
  86                 self._layout.pack_start(self._radioLayout, True, True)
  87
  88                 self._dateShown = datetime.datetime.now(tz=time_utils.Mountain)
  89                 self._currentTime = self._dateShown
  90                 self._update_title()
  91
  92                 self._continualUpdate = go_utils.Timeout(self._on_continual_update, once = False)
  93                 self._continualUpdate.start(seconds=60)
  94
  95         def show(self):
  96                 windows._base.BasicWindow.show(self)
  97
  98                 self._errorBanner.toplevel.hide()
  99                 self._loadingBanner.toplevel.hide()
 100
 101                 self._refresh()
 102
 103         def jump_to(self, node):
 104                 _moduleLogger.info("Only 1 channel, nothing to jump to")
 105
 106         def _update_time(self, newTime):
 107                 oldTime = self._dateShown
 108                 self._dateShown = newTime
 109                 if newTime.date() == oldTime.date():
 110                         self._select_row()
 111                 else:
 112                         self._update_title()
 113                         self._refresh()
 114
 115         def _update_title(self):
 116                 self._window.set_title("%s - %s" % (self._node.title, self._dateShown.strftime("%m/%d")))
 117
 118         @property
 119         def _active(self):
 120                 return self._player.node is self._childNode
 121
 122         def _set_context(self, state):
 123                 if state == self._player.STATE_PLAY:
 124                         if self._active:
 125                                 self._presenter.set_state(self._store.STORE_LOOKUP["pause"])
 126                         else:
 127                                 self._presenter.set_state(self._store.STORE_LOOKUP["play"])
 128                 elif state == self._player.STATE_PAUSE:
 129                         self._presenter.set_state(self._store.STORE_LOOKUP["play"])
 130                 elif state == self._player.STATE_STOP:
 131                         self._presenter.set_state(self._store.STORE_LOOKUP["play"])
 132                 else:
 133                         _moduleLogger.info("Unhandled player state %s" % state)
 134                         self._presenter.set_state(self._store.STORE_LOOKUP["play"])
 135
 136         def _show_loading(self):
 137                 animationPath = self._store.STORE_LOOKUP["loading"]
 138                 animation = self._store.get_pixbuf_animation_from_store(animationPath)
 139                 self._loadingBanner.show(animation, "Loading...")
 140
 141         def _hide_loading(self):
 142                 self._loadingBanner.hide()
 143
 144         def _refresh(self):
 145                 self._show_loading()
 146                 self._programmingModel.clear()
 147                 self._node.get_children(
 148                         self._on_channels,
 149                         self._on_load_error,
 150                 )
 151                 self._set_context(self._player.state)
 152
 153         def _get_current_row(self):
 154                 nowTime = self._dateShown.strftime("%H:%M:%S")
 155                 i = 0
 156                 for i, row in enumerate(self._programmingModel):
 157                         if nowTime < row[0]:
 158                                 if i == 0:
 159                                         return 0
 160                                 else:
 161                                         return i - 1
 162                 else:
 163                         return i
 164
 165         @misc_utils.log_exception(_moduleLogger)
 166         def _on_continual_update(self, *args):
 167                 if self._isDestroyed:
 168                         return False
 169                 newTime = datetime.datetime.now(tz=time_utils.Mountain)
 170                 oldTime = self._currentTime
 171                 shownTime = self._dateShown
 172
 173                 self._currentTime = newTime
 174                 if shownTime.date() == oldTime.date():
 175                         _moduleLogger.info("Today selected, updating selection")
 176                         self._update_time(newTime)
 177                 return True
 178
 179         @misc_utils.log_exception(_moduleLogger)
 180         def _on_player_state_change(self, player, newState):
 181                 if self._headerNavigation.is_active() or self._presenterNavigation.is_active():
 182                         return
 183
 184                 self._set_context(newState)
 185
 186         @misc_utils.log_exception(_moduleLogger)
 187         def _on_player_title_change(self, player, node):
 188                 if node is not self._childNode or node is None:
 189                         _moduleLogger.info("Player title magically changed to %s" % player.title)
 190                         return
 191
 192         @misc_utils.log_exception(_moduleLogger)
 193         def _on_navigating(self, widget, navState):
 194                 if navState == "clicking":
 195                         if self._player.state == self._player.STATE_PLAY:
 196                                 if self._active:
 197                                         imageName = "pause_pressed"
 198                                 else:
 199                                         imageName = "play_pressed"
 200                         elif self._player.state == self._player.STATE_PAUSE:
 201                                 imageName = "play_pressed"
 202                         elif self._player.state == self._player.STATE_STOP:
 203                                 imageName = "play_pressed"
 204                         else:
 205                                 imageName = "play_pressed"
 206                                 _moduleLogger.info("Unhandled player state %s" % self._player.state)
 207                 elif navState == "down":
 208                         imageName = "home"
 209                 else:
 210                         if self._player.state == self._player.STATE_PLAY:
 211                                 imageName = "pause"
 212                         else:
 213                                 imageName = "play"
 214
 215                 self._presenter.set_state(self._store.STORE_LOOKUP[imageName])
 216
 217         @misc_utils.log_exception(_moduleLogger)
 218         def _on_nav_action(self, widget, navState):
 219                 self._set_context(self._player.state)
 220
 221                 if navState == "clicking":
 222                         if self._player.state == self._player.STATE_PLAY:
 223                                 if self._active:
 224                                         self._player.pause()
 225                                 else:
 226                                         self._player.set_piece_by_node(self._childNode)
 227                                         self._player.play()
 228                         elif self._player.state == self._player.STATE_PAUSE:
 229                                 self._player.play()
 230                         elif self._player.state == self._player.STATE_STOP:
 231                                 self._player.set_piece_by_node(self._childNode)
 232                                 self._player.play()
 233                         else:
 234                                 _moduleLogger.info("Unhandled player state %s" % self._player.state)
 235                 elif navState == "down":
 236                         self.window.destroy()
 237                 elif navState == "up":
 238                         pass
 239                 elif navState == "left":
 240                         self._update_time(self._dateShown + datetime.timedelta(days=1))
 241                 elif navState == "right":
 242                         self._update_time(self._dateShown - datetime.timedelta(days=1))
 243
 244         @misc_utils.log_exception(_moduleLogger)
 245         def _on_channels(self, channels):
 246                 if self._isDestroyed:
 247                         _moduleLogger.info("Download complete but window destroyed")
 248                         return
 249
 250                 channels = channels
 251                 if 1 < len(channels):
 252                         _moduleLogger.warning("More channels now available!")
 253                 self._childNode = channels[0]
 254                 self._childNode.get_programming(
 255                         self._dateShown,
 256                         self._on_channel,
 257                         self._on_load_error,
 258                 )
 259
 260         @misc_utils.log_exception(_moduleLogger)
 261         def _on_channel(self, programs):
 262                 if self._isDestroyed:
 263                         _moduleLogger.info("Download complete but window destroyed")
 264                         return
 265
 266                 self._hide_loading()
 267                 for program in programs:
 268                         row = program["time"], program["title"]
 269                         self._programmingModel.append(row)
 270
 271                 currentDate = self._currentTime
 272                 if currentDate.date() != self._dateShown.date():
 273                         self._treeView.get_selection().set_mode(gtk.SELECTION_NONE)
 274                 else:
 275                         self._treeView.get_selection().set_mode(gtk.SELECTION_SINGLE)
 276                         self._select_row()
 277                         go_utils.Async(self._on_delay_scroll).start()
 278
 279         @misc_utils.log_exception(_moduleLogger)
 280         def _on_delay_scroll(self, *args):
 281                 self._scroll_to_row()
 282
 283         @misc_utils.log_exception(_moduleLogger)
 284         def _on_load_error(self, exception):
 285                 self._hide_loading()
 286                 self._errorBanner.push_message(str(exception))
 287
 288         @misc_utils.log_exception(_moduleLogger)
 289         def _on_row_changed(self, selection):
 290                 if len(self._programmingModel) == 0:
 291                         return
 292
 293                 # Undo the user's changing of the selection
 294                 self._select_row()
 295
 296         def _select_row(self):
 297                 rowIndex = self._get_current_row()
 298                 if rowIndex < 0:
 299                         return
 300                 path = (rowIndex, )
 301                 if not self._treeView.get_selection().path_is_selected(path):
 302                         self._treeView.get_selection().select_path(path)
 303
 304         def _scroll_to_row(self):
 305                 if self._isDestroyed:
 306                         return
 307                 rowIndex = self._get_current_row()
 308                 if rowIndex < 0:
 309                         return
 310
 311                 path = (rowIndex, )
 312                 self._treeView.scroll_to_cell(path)
 313
 314                 treeViewHeight = self._treeView.get_allocation().height
 315                 viewportHeight = self._viewport.get_allocation().height
 316
 317                 viewsPerPort = treeViewHeight / float(viewportHeight)
 318                 maxRows = len(self._programmingModel)
 319                 percentThrough = rowIndex / float(maxRows)
 320                 dxByIndex = int(viewsPerPort * percentThrough * viewportHeight)
 321
 322                 dxMax = max(treeViewHeight - viewportHeight, 0)
 323
 324                 dx = min(dxByIndex, dxMax)
 325                 adjustment = self._treeScroller.get_vadjustment()
 326                 adjustment.value = dx
 327
 328
 329 gobject.type_register(RadioWindow)