]> git.vomp.tv Git - vompclient-marten.git/blob - vradiorec.cc
Fix back out of jpeg due to new Boxstack code
[vompclient-marten.git] / vradiorec.cc
1 /*
2     Copyright 2004-2006 Chris Tallon
3
4     This file is part of VOMP.
5
6     VOMP is free software; you can redistribute it and/or modify
7     it under the terms of the GNU General Public License as published by
8     the Free Software Foundation; either version 2 of the License, or
9     (at your option) any later version.
10
11     VOMP is distributed in the hope that it will be useful,
12     but WITHOUT ANY WARRANTY; without even the implied warranty of
13     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14     GNU General Public License for more details.
15
16     You should have received a copy of the GNU General Public License
17     along with VOMP; if not, write to the Free Software
18     Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
19 */
20
21 #include "vradiorec.h"
22
23 #include "command.h"
24 #include "osd.h"
25 #include "player.h"
26 #include "wsymbol.h"
27 #include "recording.h"
28 #include "message.h"
29 #include "vdr.h"
30 #include "video.h"
31 #include "timers.h"
32 #include "playerradio.h"
33 #include "boxstack.h"
34 #include "remote.h"
35 #include "vinfo.h"
36 #include "i18n.h"
37
38 VRadioRec::VRadioRec(Recording* rec)
39 {
40   boxstack = BoxStack::getInstance();
41   vdr = VDR::getInstance();
42   video = Video::getInstance();
43   timers = Timers::getInstance();
44   myRec = rec;
45   playing = false;
46   startMargin = 0;
47   endMargin = 0;
48
49   player = new PlayerRadio(Command::getInstance(), this);
50
51   char* cstartMargin = vdr->configLoad("Timers", "Start margin");
52   char* cendMargin = vdr->configLoad("Timers", "End margin");
53   if (!cstartMargin)
54   {
55     startMargin = 300; // 5 mins default
56   }
57   else
58   {
59     startMargin = atoi(cstartMargin) * 60;
60     delete[] cstartMargin;
61   }
62
63   if (!cendMargin)
64   {
65     endMargin = 300; // 5 mins default
66   }
67   else
68   {
69     endMargin = atoi(cendMargin) * 60;
70     delete[] cendMargin;
71   }
72
73   Log::getInstance()->log("VRadioRec", Log::DEBUG, "SM: %u EM: %u", startMargin, endMargin);
74
75   setSize(video->getScreenWidth(), video->getScreenHeight());
76   createBuffer();
77   setPosition(0, 0);
78
79   barRegion.x = 0;
80   barRegion.y = video->getScreenHeight() - 58;   // FIXME, need to be - 1? and below?
81   barRegion.w = video->getScreenWidth();
82   barRegion.h = 58;
83
84   clocksRegion.x = barRegion.x + 140;
85   clocksRegion.y = barRegion.y + 12;
86   clocksRegion.w = 170;
87   clocksRegion.h = surface->getFontHeight();
88
89
90   barBlue.set(0, 0, 150, 150);
91
92   barShowing = false;
93 }
94
95 VRadioRec::~VRadioRec()
96 {
97   if (playing) stopPlay();
98
99   timers->cancelTimer(this, 1);
100   timers->cancelTimer(this, 2);
101
102   // kill recInfo in case resumePoint has changed (likely)
103   myRec->dropRecInfo();
104   // FIXME - do this properly - save the resume point back to the server manually and update
105   // rec->recInfo->resumePoint - this will fix the ~10s offset problem as well
106 }
107
108 void VRadioRec::draw()
109 {
110   fillColour(Colour::BLACK);
111 }
112
113 void VRadioRec::go()
114 {
115   Log::getInstance()->log("VRadioRec", Log::DEBUG, "Starting stream: %s", myRec->getFileName());
116   ULONG lengthFrames = 0;
117   ULLONG lengthBytes = vdr->streamRecording(myRec->getFileName(), &lengthFrames);
118
119   bool cantStart = false;
120
121   if (!lengthBytes) cantStart = true;
122   else if (!player->init(lengthBytes, lengthFrames)) cantStart = true;
123   else
124   {
125     doBar(0);
126   //  player->setStartBytes(startBytes);
127     player->play();
128     playing = true;
129   }
130
131   if (cantStart)
132   {
133     stopPlay(); // clean up
134
135     if (!vdr->isConnected())
136     {
137       Command::getInstance()->connectionLost();
138       return;
139     }
140
141     Message* m = new Message();
142     m->message = Message::CLOSE_ME;
143     m->from = this;
144     m->to = boxstack;
145     Command::getInstance()->postMessageNoLock(m);
146
147     VInfo* vi = new VInfo();
148     vi->setSize(400, 150);
149     vi->createBuffer();
150     if (video->getFormat() == Video::PAL)
151       vi->setPosition(170, 200);
152     else
153       vi->setPosition(160, 150);
154     vi->setExitable();
155     vi->setBorderOn(1);
156     vi->setTitleBarOn(0);
157     vi->setOneLiner(tr("Error playing recording"));
158     vi->draw();
159
160     m = new Message();
161     m->message = Message::ADD_VIEW;
162     m->to = boxstack;
163     m->parameter = (ULONG)vi;
164     Command::getInstance()->postMessageNoLock(m);
165   }
166 }
167
168 int VRadioRec::handleCommand(int command)
169 {
170   switch(command)
171   {
172     case Remote::PLAY:
173     {
174       player->play();
175       doBar(0);
176       return 2;
177     }
178
179     case Remote::STOP:
180     case Remote::BACK:
181     case Remote::MENU:
182     {
183       if (playing) stopPlay();
184       return 4;
185     }
186     case Remote::PAUSE:
187     {
188       player->pause();
189       doBar(0);
190       return 2;
191     }
192     case Remote::SKIPFORWARD:
193     {
194       doBar(3);
195       player->skipForward(60);
196       return 2;
197     }
198     case Remote::SKIPBACK:
199     {
200       doBar(4);
201       player->skipBackward(60);
202       return 2;
203     }
204     case Remote::YELLOW:
205     {
206       doBar(2);
207       player->skipBackward(10);
208       return 2;
209     }
210     case Remote::BLUE:
211     {
212       doBar(1);
213       player->skipForward(10);
214       return 2;
215     }
216     case Remote::OK:
217     {
218       if (barShowing) removeBar();
219       else doBar(0);
220       return 2;
221     }
222
223     case Remote::ZERO:  player->jumpToPercent(0);  doBar(0);  return 2;
224     case Remote::ONE:   player->jumpToPercent(10); doBar(0);  return 2;
225     case Remote::TWO:   player->jumpToPercent(20); doBar(0);  return 2;
226     case Remote::THREE: player->jumpToPercent(30); doBar(0);  return 2;
227     case Remote::FOUR:  player->jumpToPercent(40); doBar(0);  return 2;
228     case Remote::FIVE:  player->jumpToPercent(50); doBar(0);  return 2;
229     case Remote::SIX:   player->jumpToPercent(60); doBar(0);  return 2;
230     case Remote::SEVEN: player->jumpToPercent(70); doBar(0);  return 2;
231     case Remote::EIGHT: player->jumpToPercent(80); doBar(0);  return 2;
232     case Remote::NINE:  player->jumpToPercent(90); doBar(0);  return 2;
233
234 #ifdef DEV
235     case Remote::RED:
236     {
237       //player->test1();
238
239       return 2;
240     }
241     case Remote::GREEN:
242     {
243       //player->test2();
244       return 2;
245     }
246 #endif
247
248   }
249
250   return 1;
251 }
252
253 void VRadioRec::processMessage(Message* m)
254 {
255   if (m->message == Message::MOUSE_LBDOWN)
256   {
257     int x=(m->parameter>>16)-(int)getScreenX();
258     int y=(m->parameter&0xFFFF)-(int)getScreenY();
259     if (!barShowing)
260     {
261       boxstack->handleCommand(Remote::OK); //simulate rok press
262     }
263     else if ((int)barRegion.x<=x && (int)barRegion.y<=y && ((int)barRegion.x+(int)barRegion.w)>=x
264              &&  ((int)barRegion.y+(int)barRegion.h)>=y)
265     {
266       int progBarXbase = barRegion.x + 300;
267       if (x>=(int)barRegion.x + progBarXbase + 24
268         && x<=(int)barRegion.x + progBarXbase + 4 + 302
269         && y>=(int)barRegion.y + 12 - 2
270         && y<=(int)barRegion.y + 12 - 2+28)
271       {
272         int cx=x-(barRegion.x + progBarXbase + 4);
273         double percent=((double)cx)/302.*100.;
274         player->jumpToPercent(percent);
275         doBar(3);
276         return;
277         //  int progressWidth = 302 * currentFrameNum / lengthFrames;
278         //  rectangle(barRegion.x + progBarXbase + 4, barRegion.y + 16, progressWidth, 16, Colour::SELECTHIGHLIGHT);
279       }
280     }
281     else
282     {
283       boxstack->handleCommand(Remote::OK); //simulate rok press
284     }
285   }
286   else if (m->message == Message::PLAYER_EVENT)
287   {
288     if (m->from != player) return;
289
290     Log::getInstance()->log("VRadioRec", Log::DEBUG, "Message received");
291
292     switch(m->parameter)
293     {
294       case Player::CONNECTION_LOST: // connection lost detected
295       {
296         // I can't handle this, send it to command
297         Message* m2 = new Message();
298         m2->to = Command::getInstance();
299         m2->message = Message::CONNECTION_LOST;
300         Command::getInstance()->postMessageNoLock(m2);
301         break;
302       }
303       case Player::STOP_PLAYBACK:
304       {
305         // FIXME Obselete ish - improve this
306         Message* m2 = new Message(); // Must be done after this thread finishes, and must break into master mutex
307         m2->to = Command::getInstance();
308         m2->message = Message::STOP_PLAYBACK;
309         Command::getInstance()->postMessageNoLock(m2);
310         break;
311       }
312     }
313   }
314 }
315
316 void VRadioRec::stopPlay()
317 {
318   Log::getInstance()->log("VRadioRec", Log::DEBUG, "Pre stopPlay");
319
320   removeBar();
321   player->stop();
322   vdr->stopStreaming();
323   delete player;
324
325   playing = false;
326
327   if (!vdr->isConnected()) { Command::getInstance()->connectionLost(); return; }
328   Log::getInstance()->log("VRadioRec", Log::DEBUG, "Post stopPlay");
329 }
330
331 void VRadioRec::doBar(int action)
332 {
333   barShowing = true;
334
335   rectangle(barRegion, barBlue);
336
337   /* Work out what to display - choices:
338
339   Playing  >
340   Paused   ||
341
342   Specials, informed by parameter
343
344   Skip forward 10s    >|
345   Skip backward 10s   |<
346   Skip forward 1m     >>|
347   Skip backward 1m    |<<
348
349   */
350
351   WSymbol w;
352   TEMPADD(&w);
353   w.nextSymbol = 0;
354   w.setPosition(barRegion.x + 66, barRegion.y + 16);
355
356   UCHAR playerState = 0;
357
358   if (action)
359   {
360     if (action == 1)       w.nextSymbol = WSymbol::SKIPFORWARD;
361     else if (action == 2)  w.nextSymbol = WSymbol::SKIPBACK;
362     else if (action == 3)  w.nextSymbol = WSymbol::SKIPFORWARD2;
363     else if (action == 4)  w.nextSymbol = WSymbol::SKIPBACK2;
364   }
365   else
366   {
367     playerState = player->getState();
368     if (playerState == Player::S_PAUSE_P)      w.nextSymbol = WSymbol::PAUSE;
369     else if (playerState == Player::S_PAUSE_I) w.nextSymbol = WSymbol::PAUSE;
370     else                                       w.nextSymbol = WSymbol::PLAY;
371   }
372
373   w.draw();
374
375   drawBarClocks();
376
377   BoxStack::getInstance()->update(this, &barRegion);
378
379   timers->setTimerD(this, 1, 4); // only set the getridofbar timer if not ffwd/fbwd
380   timers->setTimerD(this, 2, 0, 200000000);
381 }
382
383 void VRadioRec::timercall(int clientReference)
384 {
385   switch(clientReference)
386   {
387     case 1:
388     {
389       // Remove bar
390       removeBar();
391       break;
392     }
393     case 2:
394     {
395       // Update clock
396       if (!barShowing) break;
397       drawBarClocks();
398       boxstack->update(this, &barRegion);
399       
400       timers->setTimerD(this, 2, 0, 200000000);
401       break;
402     }
403   }
404 }
405
406 void VRadioRec::drawBarClocks()
407 {
408   Log* logger = Log::getInstance();
409   logger->log("VRadioRec", Log::DEBUG, "Draw bar clocks");
410
411   // Draw RTC
412   // Blank the area first
413   rectangle(barRegion.x + 624, barRegion.y + 12, 60, 30, barBlue);
414   char timeString[20];
415   time_t t;
416   time(&t);
417   struct tm* tms = localtime(&t);
418   strftime(timeString, 19, "%H:%M", tms);
419   drawText(timeString, barRegion.x + 624, barRegion.y + 12, Colour::LIGHTTEXT);
420
421   // Draw clocks
422
423   rectangle(clocksRegion, barBlue);
424
425 /*
426   ULONG currentFrameNum = player->getCurrentFrameNum();
427   ULONG lengthFrames;
428   if (myRec->recInfo->timerEnd > time(NULL))
429   {
430     // chasing playback
431     // Work out an approximate length in frames (good to 1s...)
432     lengthFrames = (myRec->recInfo->timerEnd - myRec->recInfo->timerStart) * video->getFPS();
433   }
434   else
435   {
436 //    lengthFrames = player->getLengthFrames();
437     lengthFrames = 0;
438   }
439
440   hmsf currentFrameHMSF = video->framesToHMSF(currentFrameNum);
441   hmsf lengthHMSF = video->framesToHMSF(lengthFrames);
442
443   char buffer[100];
444   if (currentFrameNum >= lengthFrames)
445   {
446     strcpy(buffer, "-:--:-- / -:--:--");
447   }
448   else
449   {
450     SNPRINTF(buffer, 99, "%01i:%02i:%02i / %01i:%02i:%02i", currentFrameHMSF.hours, currentFrameHMSF.minutes, currentFrameHMSF.seconds, lengthHMSF.hours, lengthHMSF.minutes, lengthHMSF.seconds);
451     logger->log("VRadioRec", Log::DEBUG, buffer);
452   }
453 */
454
455   ULONG currentSeconds = player->getCurrentSeconds();
456   ULONG lengthSeconds = player->getLengthSeconds();
457   char buffer[100];
458
459   if (lengthSeconds && (currentSeconds < lengthSeconds))
460   {
461     ULONG dcurrentSeconds = currentSeconds;
462     ULONG dlengthSeconds = lengthSeconds;
463
464     ULONG currentHours = dcurrentSeconds / 3600;
465     dcurrentSeconds %= 3600;
466     ULONG currentMinutes = dcurrentSeconds / 60;
467     dcurrentSeconds %= 60;
468
469     ULONG lengthHours = dlengthSeconds / 3600;
470     dlengthSeconds %= 3600;
471     ULONG lengthMinutes = dlengthSeconds / 60;
472     dlengthSeconds %= 60;
473
474     SNPRINTF(buffer, 99, "%01lu:%02lu:%02lu / %01lu:%02lu:%02lu", currentHours, currentMinutes, dcurrentSeconds, lengthHours, lengthMinutes, dlengthSeconds);
475     logger->log("VRadioRec", Log::DEBUG, buffer);
476   }
477   else
478   {
479     strcpy(buffer, "-:--:-- / -:--:--");
480   }
481
482   drawText(buffer, clocksRegion.x, clocksRegion.y, Colour::LIGHTTEXT);
483
484   // Draw progress bar
485   int progBarXbase = barRegion.x + 300;
486
487   rectangle(barRegion.x + progBarXbase, barRegion.y + 12, 310, 24, Colour::LIGHTTEXT);
488   rectangle(barRegion.x + progBarXbase + 2, barRegion.y + 14, 306, 20, barBlue);
489
490   if (currentSeconds > lengthSeconds) return;
491   if (lengthSeconds == 0) return;
492
493   // Draw yellow portion
494   int progressWidth = 302 * currentSeconds / lengthSeconds;
495   rectangle(barRegion.x + progBarXbase + 4, barRegion.y + 16, progressWidth, 16, Colour::SELECTHIGHLIGHT);
496 /*
497
498   if (myRec->recInfo->timerEnd > time(NULL)) // if chasing
499   {
500     int nrWidth = (int)(302 * ((double)(lengthFrames - 0) / lengthFrames)); // 0 inserted instead of getlengthframes
501
502     Log::getInstance()->log("GVASDF", Log::DEBUG, "Length Frames: %lu", lengthFrames);
503 //    Log::getInstance()->log("GVASDF", Log::DEBUG, "Player lf: %lu", player->getLengthFrames());
504     Log::getInstance()->log("GVASDF", Log::DEBUG, "NR WDITH: %i", nrWidth);
505     rectangle(barRegion.x + progBarXbase + 4 + 302 - nrWidth, barRegion.y + 16, nrWidth, 16, Colour::RED);
506   }
507 */
508
509   logger->log("VRadioRec", Log::DEBUG, "blips");
510
511   // Now calc position for start margin blips
512   int posPix;
513
514   posPix = 302 * startMargin / lengthSeconds;
515   logger->log("VRadioRec", Log::DEBUG, "posPix %i", posPix);
516
517   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 - 2, 2, 2, Colour::LIGHTTEXT);
518   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 + 24, 2, 2, Colour::LIGHTTEXT);
519
520   posPix = 302 * (lengthSeconds - endMargin) / lengthSeconds;
521
522   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 - 2, 2, 2, Colour::LIGHTTEXT);
523   rectangle(barRegion.x + progBarXbase + 2 + posPix, barRegion.y + 12 + 24, 2, 2, Colour::LIGHTTEXT);
524 }
525
526 void VRadioRec::removeBar()
527 {
528   if (!barShowing) return;
529   timers->cancelTimer(this, 2);
530   barShowing = false;
531   rectangle(barRegion, Colour::BLACK);
532   boxstack->update(this, &barRegion);
533 }
534