lib/dvb/serviceexternal.cpp

   1 #include <stdio.h>
   2 #include <sys/stat.h>
   3
   4 #include <lib/gui/ewindow.h>
   5 #include <lib/gui/elabel.h>
   6 #include <lib/gui/ebutton.h>
   7 #include <lib/gui/emessage.h>
   8 #include <lib/gui/listbox.h>
   9 #include <lib/dvb/servicefile.h>
  10 #include <lib/gdi/lcd.h>
  11 #include <lib/system/init.h>
  12 #include <lib/system/init_num.h>
  13 #include <lib/system/info.h>
  14 #include <lib/dvb/serviceexternal.h>
  15
  16 /*
  17  * In order to register an external (media)player to a file extension (e.g. ".xyz", place
  18  * a .cfg file in the plugin directory, with contents:
  19  *
  20  *              type=5
  21  *              pattern=.xyz
  22  *              command=/usr/bin/xzyplay
  23  *              needrc=1 (if your player needs the rc)
  24  *              needlcd=1 (if your player needs the lcd)
  25  *              needfb=1 (if your player needs the framebuffer)
  26  *
  27  * Now when a file "filename.xyz" is selected in filemode, the external player will be started:
  28  *
  29  *              /usr/bin/xyzplay /path/to/file/filename.xyz
  30  *
  31  * In order to register an external (media)player to a directory, we need to match a certain
  32  * file inside the directory (e.g. 'dirname/special.file'). Place a .cfg file in the plugin
  33  * directory, with contents:
  34  *
  35  *              type=5
  36  *              dirpattern=filename.xyz
  37  *              command=/usr/bin/xyzplay
  38  *              needrc=1 (if your player needs the rc)
  39  *              needlcd=1 (if your player needs the lcd)
  40  *              needfb=1 (if your player needs the framebuffer)
  41  *
  42  * Now at the same level as 'dirname', an entry 'Start player' will be shown in filemode.
  43  * When this entry is selected, the player will be started with the command:
  44  *
  45  *              /usr/bin/xyzplay /path/to/dir/dirname
  46  *
  47  *
  48  * Only one 'pattern' is allowed per type 5 plugin. Also, only one 'dirpattern' is allowed
  49  * per type 5 plugin.
  50  * However, it is allowed to have both a 'pattern' and a 'dirpattern' in the same cfg file.
  51  *
  52  */
  53
  54 eServiceHandlerExternal *eServiceHandlerExternal::instance = NULL;
  55
  56 eServiceHandlerExternal::eServiceHandlerExternal(): eServiceHandler(0x0fff)
  57 {
  58         if (eServiceInterface::getInstance()->registerHandler(id, this) < 0)
  59         {
  60                 eFatal("couldn't register eServiceHandlerExternal %d", id);
  61         }
  62         instance = this;
  63         CONNECT(eServiceFileHandler::getInstance()->fileHandlers, eServiceHandlerExternal::addFile);
  64         CONNECT(eServiceFileHandler::getInstance()->directoryHandlers, eServiceHandlerExternal::addDirectory);
  65         eDebug("eServiceHandlerExternal registered");
  66 }
  67
  68 eServiceHandlerExternal::~eServiceHandlerExternal()
  69 {
  70         eServiceInterface::getInstance()->unregisterHandler(id);
  71 }
  72
  73 void eServiceHandlerExternal::addFileHandler(const eString &pattern, const eString &command, int needfb, int needrc, int needlcd)
  74 {
  75         FileExtensionScriptInfo info;
  76         info.needfb = needfb;
  77         info.needrc = needrc;
  78         info.needlcd = needlcd;
  79         info.command = command;
  80         info.pattern = pattern;
  81         extensionFileList.push_back(info);
  82 }
  83
  84 void eServiceHandlerExternal::addDirectoryHandler(const eString &pattern, const eString &command, int needfb, int needrc, int needlcd)
  85 {
  86         FileExtensionScriptInfo info;
  87         info.needfb = needfb;
  88         info.needrc = needrc;
  89         info.needlcd = needlcd;
  90         info.command = command;
  91         info.pattern = pattern;
  92         /*
  93          * make sure we have a trailing slash in our pattern,
  94          * as this is how we'll get offered our directory names
  95          */
  96         if (info.pattern.right(1) != "/") info.pattern += "/";
  97         extensionDirectoryList.push_back(info);
  98 }
  99
 100 void eServiceHandlerExternal::addFile(void *node, const eString &filename)
 101 {
 102         for (unsigned int i = 0; i < extensionFileList.size(); i++)
 103         {
 104                 int matchsize = extensionFileList[i].pattern.length();
 105                 if (filename.right(matchsize).upper() == extensionFileList[i].pattern.upper())
 106                 {
 107                         eServiceReference ref(id, 0, filename);
 108                         eString filenamestripped = filename;
 109
 110                         uint i = filename.find_last_of('/');
 111                         if (i != eString::npos)
 112                         {
 113                                 filenamestripped = filename.mid(i + 1, filename.length());
 114                         }
 115                         ref.descr = filenamestripped.c_str();
 116                         eServiceFileHandler::getInstance()->addReference(node, ref);
 117                         eDebug("Add file: %s", filename.c_str());
 118                         return;
 119                 }
 120         }
 121 }
 122
 123 void eServiceHandlerExternal::addDirectory(void *node, const eString &filename)
 124 {
 125         for (unsigned int i = 0; i < extensionDirectoryList.size(); i++)
 126         {
 127                 int matchsize = extensionDirectoryList[i].pattern.length();
 128                 if (filename.right(matchsize).upper() == extensionDirectoryList[i].pattern.upper())
 129                 {
 130                         eServiceReference ref(id, 0, filename);
 131                         ref.descr = _("Start player");
 132                         eServiceFileHandler::getInstance()->addReference(node, ref);
 133                         eDebug("Add directory: %s", filename.c_str());
 134                         return;
 135                 }
 136         }
 137 }
 138
 139 int eServiceHandlerExternal::play(const eServiceReference &service, int workaround)
 140 {
 141         if (service.path)
 142         {
 143                 struct stat64 s;
 144                 if (::stat64(service.path.c_str(), &s))
 145                 {
 146                         eDebug("file %s does not exist.. don't play", service.path.c_str() );
 147                         return -1;
 148                 }
 149         }
 150         else
 151         {
 152                 return -1;
 153         }
 154
 155         if (service.path.right(1) == "/")
 156         {
 157                 /* trailing slash: service is a directory */
 158                 for (unsigned int i = 0; i < extensionDirectoryList.size(); i++)
 159                 {
 160                         int matchsize = extensionDirectoryList[i].pattern.length();
 161                         if (service.path.right(matchsize).upper() == extensionDirectoryList[i].pattern.upper())
 162                         {
 163                                 eString command = extensionDirectoryList[i].command + " \"" + service.path + "\"";
 164                                 eDebug("play command %s\n", command.c_str());
 165                                 ePlayerThread *p = new ePlayerThread(command, extensionDirectoryList[i].needfb, extensionDirectoryList[i].needrc, extensionDirectoryList[i].needlcd);
 166                                 p->start();
 167                                 return 0;
 168                         }
 169                 }
 170         }
 171         else
 172         {
 173                 /* service is a normal file */
 174                 for (unsigned int i = 0; i < extensionFileList.size(); i++)
 175                 {
 176                         int matchsize = extensionFileList[i].pattern.length();
 177                         if (service.path.right(matchsize).upper() == extensionFileList[i].pattern.upper())
 178                         {
 179                                 eString command = extensionFileList[i].command + " \"" + service.path + "\"";
 180                                 eDebug("play command %s\n", command.c_str());
 181                                 ePlayerThread *p = new ePlayerThread(command, extensionFileList[i].needfb, extensionFileList[i].needrc, extensionFileList[i].needlcd);
 182                                 p->start();
 183                                 return 0;
 184                         }
 185                 }
 186         }
 187         return -1;
 188 }
 189
 190 int eServiceHandlerExternal::stop(int workaround)
 191 {
 192         eDebug("Stop file\n");
 193         return 0;
 194 }
 195
 196 eService *eServiceHandlerExternal::addRef(const eServiceReference &service)
 197 {
 198         return eServiceFileHandler::getInstance()->addRef(service);
 199 }
 200
 201 void eServiceHandlerExternal::removeRef(const eServiceReference &service)
 202 {
 203         return eServiceFileHandler::getInstance()->removeRef(service);
 204 }
 205
 206 void ePlayerThread::start()
 207 {
 208         if (!thread_running())
 209         {
 210                 if (needrc)
 211                 {
 212                         eRCInput::getInstance()->lock();
 213                 }
 214
 215                 if (needfb)
 216                 {
 217                         fbClass::getInstance()->lock();
 218                 }
 219
 220 #ifndef DISABLE_LCD
 221                 if (needlcd && eSystemInfo::getInstance()->hasLCD())
 222                 {
 223                         eDBoxLCD::getInstance()->lock();
 224                 }
 225 #endif
 226
 227                 run();
 228         }
 229         else
 230         {
 231                 eDebug("don't start player.. another one is running");
 232         }
 233 }
 234
 235 void ePlayerThread::thread()
 236 {
 237         if (thread_running())
 238         {
 239                 eDebug("player thread running.. start player now");
 240         }
 241         else
 242         {
 243                 eDebug("start player now");
 244         }
 245         system(command.c_str());
 246         eDebug("player finished");
 247 }
 248
 249 void ePlayerThread::recv_msg(const int &)
 250 {
 251         finalize_player();
 252 }
 253
 254 void ePlayerThread::thread_finished()
 255 {
 256         message.send(1);
 257 }
 258
 259 void ePlayerThread::finalize_player()
 260 {
 261         if (needfb)
 262         {
 263                 fbClass::getInstance()->unlock();
 264         }
 265
 266 #ifndef DISABLE_LCD
 267         if (needlcd && eSystemInfo::getInstance()->hasLCD())
 268         {
 269                 eDBoxLCD::getInstance()->unlock();
 270         }
 271 #endif
 272
 273         if (needrc)
 274         {
 275                 eRCInput::getInstance()->unlock();
 276         }
 277         delete this;
 278 }
 279
 280 eAutoInitP0<eServiceHandlerExternal> i_eServiceHandlerExternal(eAutoInitNumbers::service + 2, "eServiceHandlerExternal");