src/enigma_web.cpp

   1 #include <lib/system/http_dyn.h>
   2 #include <lib/dvb/service.h>
   3 #include <lib/dvb/epgcache.h>
   4 #include <lib/dvb/dvb.h>
   5 #include <lib/dvb/servicemp3.h>
   6 #include <epgwindow.h>
   7
   8 extern eString httpUnescape(const eString &string);
   9 extern eString httpEscape(const eString &string);
  10 extern std::map<eString,eString> getRequestOptions(eString opt, char delimiter = '&');
  11 extern eString ref2string(const eServiceReference &r);
  12 extern eServiceReference string2ref(const eString &service);
  13
  14 eString xmlEscape(const eString &string)
  15 {
  16         eString ret="";
  17         for (unsigned int i=0; i<string.length(); ++i)
  18         {
  19                 int c=string[i];
  20
  21                 if (c == '&')
  22                         ret+="&amp;";
  23                 else
  24                         ret+=c;
  25         }
  26         return ret;
  27 }
  28
  29
  30 static const eString xmlversion="<?xml version=\"1.0\"?>\n";
  31 static inline eString xmlstylesheet(const eString &ss)
  32 {
  33         return eString("<?xml-stylesheet type=\"text/xsl\" href=\"/stylesheets/") + ss + ".xsl\"?>\n";
  34 }
  35
  36 static eString web_root(eString request, eString dirpath, eString opts, eHTTPConnection *content)
  37 {
  38         eString ret;
  39         content->local_header["Content-Type"]="text/xml; charset=utf-8";
  40
  41         ret=xmlversion;
  42         ret+=xmlstylesheet("services");
  43         ret+="<services>\n";
  44
  45         for (int i=0; i<10; ++i)
  46                 ret+="<service><name>" + eString().sprintf("Service #%d", i) + "</name></service>\n";
  47
  48         ret+="</services>\n";
  49         return ret;
  50 }
  51
  52 class eServiceToXml: public Object
  53 {
  54         eString &result;
  55         eServiceInterface &iface;
  56 public:
  57         eServiceToXml(eString &result, eServiceInterface &iface): result(result), iface(iface)
  58         {
  59         }
  60         void addEntry(const eServiceReference &e)
  61         {
  62                 result+="<service>\n";
  63                 result+="<reference>" + ref2string(e) + "</reference>\n";
  64                 eService *service=iface.addRef(e);
  65                 if (service)
  66                 {
  67                         result+="<name>" + xmlEscape(service->service_name) + "</name>\n";
  68                         if (service->dvb)
  69                         {
  70                                 result+="<dvb><namespace>";
  71                                 result+=eString().setNum(service->dvb->dvb_namespace.get(), 0x10);
  72                                 result+="</namespace><tsid>";
  73                                 result+=eString().setNum(service->dvb->transport_stream_id.get(), 0x10);
  74                                 result+="</tsid><onid>";
  75                                 result+=eString().setNum(service->dvb->original_network_id.get(), 0x10);
  76                                 result+="</onid><sid>";
  77                                 result+=eString().setNum(service->dvb->service_id.get(), 0x10);
  78                                 result+="</sid><type>";
  79                                 result+=eString().setNum(service->dvb->service_type, 0x10);
  80                                 result+="</type><provider>";
  81                                 result+=xmlEscape(service->dvb->service_provider);
  82                                 result+="</provider><number>";
  83                                 result+=eString().setNum(service->dvb->service_number, 10);
  84                                 result+="</number></dvb>\n";
  85                         }
  86 #ifndef DISABLE_FILE
  87                         if (service->id3)
  88                         {
  89                                 std::map<eString, eString> & tags = service->id3->getID3Tags();
  90                                 result+="<id3>";
  91                                 for (std::map<eString, eString>::iterator i(tags.begin()); i != tags.end(); ++i)
  92                                         result+="<tag id=\"" + i->first + "\"><" + i->second + "<tag/>\n";
  93                                 result+="</id3>";
  94                         }
  95 #endif
  96                 }
  97                 iface.removeRef(e);
  98                 result+="</service>\n";
  99         }
 100 };
 101
 102 static eString xml_services(eString request, eString dirpath, eString opt, eHTTPConnection *content)
 103 {
 104         std::map<eString,eString> opts=getRequestOptions(opt);
 105         eString spath=opts["path"];
 106
 107         eServiceInterface *iface=eServiceInterface::getInstance();
 108
 109         if (!iface)
 110                 return "n/a\n";
 111
 112         eString current;
 113
 114         unsigned int pos;
 115         if ((pos=spath.rfind(';')) != eString::npos)
 116         {
 117                 current=spath.mid(pos+1);
 118                 spath=spath.left(pos);
 119         } else
 120         {
 121                 current=spath;
 122                 spath="";
 123         }
 124
 125         eServiceReference current_service=string2ref(current);
 126
 127         if (!opts["path"])
 128                 current_service=eServiceReference(eServiceReference::idStructure,
 129                         eServiceReference::isDirectory, 0);
 130
 131         eDebug("current_service: %s", current_service.path.c_str());
 132
 133         eString res;
 134
 135         eServiceToXml conv(res, *iface);
 136
 137         Signal1<void,const eServiceReference&> signal;
 138         signal.connect(slot(conv, &eServiceToXml::addEntry));
 139
 140         res=xmlversion;
 141         res+=xmlstylesheet("services");
 142         res+="<services>\n";
 143
 144         iface->enterDirectory(current_service, signal);
 145         iface->leaveDirectory(current_service);
 146
 147         res+="</services>\n";
 148
 149         return res;
 150 }
 151
 152 class eHTTPLog: public eHTTPDataSource, public Object
 153 {
 154         int mask, format;
 155         int ok, last;
 156         void recvMessage(int lvl, const eString &str);
 157         eString toWrite;
 158 public:
 159         eHTTPLog(eHTTPConnection *c, int mask, int format);
 160         ~eHTTPLog();
 161
 162         int doWrite(int);
 163 };
 164
 165 eHTTPLog::eHTTPLog(eHTTPConnection *c, int mask, int format):
 166         eHTTPDataSource(c), mask(mask), format(format), ok(0)
 167 {
 168         if (format == 0)
 169                 connection->local_header["Content-Type"]="text/plain";
 170         else if (format == 1)
 171                 connection->local_header["Content-Type"]="text/html";
 172         connection->code=200;
 173         connection->code_descr="OK";
 174         CONNECT(logOutput, eHTTPLog::recvMessage);
 175         last = -1;
 176         if (format == 1)
 177         {
 178                 toWrite="<html><head>"
 179                 "<link type=\"text/css\" rel=\"stylesheet\" href=\"/stylesheets/log.css\">"
 180                 "<title>Enigma Event Log</title>"
 181                 "</head><body><pre>\n";
 182         }
 183 }
 184
 185 int eHTTPLog::doWrite(int hm)
 186 {
 187         // we don't have YET data to send (but there's much to come)
 188         ok=1;
 189         if (toWrite.size())
 190         {
 191                 connection->writeBlock(toWrite.c_str(), toWrite.size());
 192                 toWrite="";
 193         }
 194         return 0;
 195 }
 196
 197 void eHTTPLog::recvMessage(int lvl, const eString &msg)
 198 {
 199         eString res;
 200         if (lvl & mask)
 201         {
 202                 if (format == 0) // text/plain
 203                 {
 204                         res=msg;
 205                         res.strReplace("\n", "\r\n");
 206                 } else
 207                 {
 208                         if (last != lvl)
 209                         {
 210                                 eString cl="unknown";
 211                                 if (lvl == lvlWarning)
 212                                         cl="warning";
 213                                 else if (lvl == lvlFatal)
 214                                         cl="fatal";
 215                                 else if (lvl == lvlDebug)
 216                                         cl="debug";
 217
 218                                 if (last != -1)
 219                                         res+="</div>";
 220                                 res+="<div class=\"" + cl + "\">";
 221                                 last=lvl;
 222                         }
 223                         res+=msg;
 224                         // res.strReplace("\n", "<br>\n");  <-- we are <pre>, so no need
 225                 }
 226                 if (ok)
 227                         connection->writeBlock(res.c_str(), res.size());
 228                 else
 229                         toWrite+=res;
 230         }
 231 }
 232
 233 eHTTPLog::~eHTTPLog()
 234 {
 235 }
 236
 237 eHTTPLogResolver::eHTTPLogResolver()
 238 {
 239 }
 240
 241 eHTTPDataSource *eHTTPLogResolver::getDataSource(eString request, eString path, eHTTPConnection *conn)
 242 {
 243         if ((path=="/log/debug") && (request=="GET"))
 244                 return new eHTTPLog(conn, -1, 0);
 245         if ((path=="/log/warn") && (request=="GET"))
 246                 return new eHTTPLog(conn, 3, 0);
 247         if ((path=="/log/crit") && (request=="GET"))
 248                 return new eHTTPLog(conn, 1, 0);
 249
 250         if ((path=="/log/debug.html") && (request=="GET"))
 251                 return new eHTTPLog(conn, -1, 1);
 252         if ((path=="/log/warn.html") && (request=="GET"))
 253                 return new eHTTPLog(conn, 3, 1);
 254         if ((path=="/log/crit.html") && (request=="GET"))
 255                 return new eHTTPLog(conn, 1, 1);
 256         return 0;
 257 }
 258
 259 extern eString filter_string(eString string);
 260
 261 class ERCServiceHandle: public Object
 262 {
 263         eString &result, search;
 264         eServiceInterface &iface;
 265 public:
 266         ERCServiceHandle(eString &result, eServiceInterface &iface, eString search): result(result), search(search.upper()), iface(iface)
 267         {
 268         }
 269         void addEntry(const eServiceReference &e)
 270         {
 271                 eService *service=iface.addRef(e);
 272                 if (service)
 273                 {
 274                         if (filter_string(service->service_name).upper().find(search) == eString::npos)
 275                                 return;
 276                         result += ref2string(e) + "\n";
 277                         result += service->service_name + "\n";
 278                         iface.removeRef(e);
 279                 }
 280         }
 281 };
 282
 283 static eString erc_services(eString request, eString dirpath, eString opt, eHTTPConnection *content)
 284 {
 285         std::map<eString,eString> opts=getRequestOptions(opt);
 286
 287         eServiceInterface *iface=eServiceInterface::getInstance();
 288         eServiceReference all_services=eServiceReference(eServiceReference::idDVB,
 289                 eServiceReference::flagDirectory|eServiceReference::shouldSort,
 290                 -2, -1, 0xFFFFFFFF);
 291
 292         if (!iface)
 293                 return "n/a\n";
 294
 295         if (opts.find("name") == opts.end())
 296                 return "-specify name=\n";
 297
 298         // search "all dvb services":
 299
 300         eString res = "+\n";
 301
 302         ERCServiceHandle conv(res, *iface, opts["name"]);
 303
 304         Signal1<void,const eServiceReference&> signal;
 305         signal.connect(slot(conv, &ERCServiceHandle::addEntry));
 306
 307         iface->enterDirectory(all_services, signal);
 308         iface->leaveDirectory(all_services);
 309
 310         return res;
 311 }
 312
 313 static void processEvent(eString &res, EITEvent *ev, const eString &search, int wantext)
 314 {
 315         eString title;
 316
 317         LocalEventData led;
 318         led.getLocalData(ev, &title);
 319
 320         if (title.find(search) != eString::npos)
 321         {
 322                 res += "I: ";
 323                 res += eString().setNum(ev->event_id, 0x10);
 324                 res += "\nB: ";
 325                 res += eString().setNum(ev->start_time);
 326                 res += "\nD: ";
 327                 res += eString().setNum(ev->duration);
 328                 res += "\nN: " + title + "\n";
 329                 LocalEventData led;
 330                 eString tmpname,tmptext;
 331                 if (!wantext)
 332                 {
 333                         led.getLocalData(ev, &tmpname);
 334                         if (!tmpname.isNull())
 335                         {
 336                                 res += "T: ";
 337                                 res += tmpname;
 338                                 res += "\n";
 339                         }
 340                 }
 341                 else
 342                 {
 343                         led.getLocalData(ev, &tmpname, 0, &tmptext);
 344                         if (!tmptext.isNull())
 345                         {
 346                                 res += "T: ";
 347                                 res += tmpname;
 348                                 res += "\n";
 349                                 res += "E: ";
 350                                 tmptext.strReplace("\n", eString("\\n"));
 351                                 res += tmptext;
 352                                 res +=" \n";
 353                         }
 354                 }
 355                 for (ePtrList<Descriptor>::const_iterator d(ev->descriptor); d != ev->descriptor.end(); ++d)
 356                 {
 357                         if (d->Tag()==DESCR_SHORT_EVENT)
 358                         {
 359                                 const ShortEventDescriptor *s=(const ShortEventDescriptor*)*d;
 360                                 res += "T: ";
 361                                 res += s->text;
 362                                 res += "\n";
 363                                 if (!wantext)
 364                                         break;
 365                         } else if (wantext && (d->Tag() == DESCR_EXTENDED_EVENT))
 366                         {
 367                                 const ExtendedEventDescriptor *e=(ExtendedEventDescriptor*)*d;
 368                                 res += "E: ";
 369                                 eString t = e->text;
 370                                 t.strReplace("\n", eString("\\n"));
 371                                 res += t;
 372                                 res +=" \n";
 373                         }
 374                 }
 375         }
 376 }
 377
 378 static eString erc_epg(eString request, eString dirpath, eString opt, eHTTPConnection *content)
 379 {
 380         std::map<eString,eString> opts=getRequestOptions(opt);
 381         time_t begin = 0;
 382         int duration = 0;
 383         eString search;
 384         eString res;
 385         int wantext;
 386         int event_id = -1;
 387
 388         if (opts.find("service") == opts.end())
 389                 return "-specify service";
 390         if ((opts.find("text") == opts.end()) && (opts.find("begin") == opts.end()) && (opts.find("event_id") == opts.end()))
 391                 return "-specify text and/or begin or event_id";
 392         eString text = opts["text"];
 393         if (opts.find("begin") != opts.end())
 394                 begin = atoi(opts["begin"].c_str());
 395         if (opts.find("duration") != opts.end())
 396                 duration = atoi(opts["duration"].c_str());
 397         search = opts["text"];
 398
 399         if (opts.find("extended") != opts.end())
 400                 wantext = 1;
 401         else
 402                 wantext = 0;
 403
 404         if (opts.find("event_id") != opts.end())
 405                 sscanf(opts["event_id"].c_str(), "%x", &event_id);
 406
 407         eEPGCache *epgcache=eEPGCache::getInstance();
 408         eServiceReference ref(opts["service"]);
 409
 410         if (event_id == -1)
 411         {
 412                 epgcache->Lock();
 413                 const timeMap *evmap = epgcache->getTimeMap((eServiceReferenceDVB&)ref);
 414                 if (!evmap)
 415                 {
 416                         epgcache->Unlock();
 417                         return "-no events for this service";
 418                 }
 419                 eServiceReferenceDVB &rref=(eServiceReferenceDVB&)ref;
 420                 timeMap::const_iterator ibegin = evmap->begin(), iend = evmap->end();
 421                 if (begin != 0)
 422                 {
 423                         ibegin = evmap->lower_bound(begin);
 424                         if ((ibegin != evmap->end()) && (ibegin != evmap->begin()))
 425                                 --ibegin;
 426                         else
 427                                 ibegin=evmap->begin();
 428
 429                         timeMap::const_iterator iend = evmap->upper_bound(begin + duration);
 430                         if (iend != evmap->end())
 431                                 ++iend;
 432                 }
 433                 int tsidonid =
 434                         (rref.getTransportStreamID().get()<<16)|rref.getOriginalNetworkID().get();
 435                 for (timeMap::const_iterator event(ibegin); event != iend; ++event)
 436                 {
 437                         EITEvent *ev = new EITEvent(*event->second, tsidonid);
 438                         processEvent(res, ev, search, wantext);
 439                         delete ev;
 440                 }
 441                 epgcache->Unlock();
 442         }
 443         else
 444         {
 445                 EITEvent *ev = epgcache->lookupEvent((eServiceReferenceDVB&)ref, event_id);
 446                 if (!ev)
 447                         return "-service or event_id invalid";
 448                 else
 449                 {
 450                         processEvent(res, ev, search, wantext);
 451                         delete ev;
 452                 }
 453         }
 454
 455         return res;
 456 }
 457
 458 void ezapInitializeWeb(eHTTPDynPathResolver *dyn_resolver)
 459 {
 460         dyn_resolver->addDyn("GET", "/dyn2/", web_root);
 461         dyn_resolver->addDyn("GET", "/dyn2/services", xml_services);
 462
 463         dyn_resolver->addDyn("GET", "/erc/services", erc_services);
 464         dyn_resolver->addDyn("GET", "/erc/epg", erc_epg);
 465 }
 466