2 #include <lib/dvb/db.h>
3 #include <lib/dvb/dvb.h>
4 #include <lib/dvb/frontend.h>
5 #include <lib/dvb/epgcache.h>
6 #include <lib/base/eerror.h>
7 #include <lib/base/estring.h>
8 #include <dvbsi++/service_description_section.h>
9 #include <dvbsi++/descriptor_tag.h>
10 #include <dvbsi++/service_descriptor.h>
11 #include <dvbsi++/satellite_delivery_system_descriptor.h>
13 DEFINE_REF(eDVBService);
15 RESULT eBouquet::addService(const eServiceReference &ref, eServiceReference before)
18 std::find(m_services.begin(), m_services.end(), ref);
19 if ( it != m_services.end() )
23 it = std::find(m_services.begin(), m_services.end(), before);
24 m_services.insert(it, ref);
27 m_services.push_back(ref);
31 RESULT eBouquet::removeService(const eServiceReference &ref)
34 std::find(m_services.begin(), m_services.end(), ref);
35 if ( it == m_services.end() )
41 RESULT eBouquet::moveService(const eServiceReference &ref, unsigned int pos)
43 if ( pos < 0 || pos >= m_services.size() )
46 list::iterator source=m_services.end();
47 list::iterator dest=m_services.end();
49 for (list::iterator it(m_services.begin()); it != m_services.end(); ++it)
51 if (dest == m_services.end() && !--pos)
58 if (dest != m_services.end() && source != m_services.end())
61 if (dest == m_services.end() || source == m_services.end() || source == dest)
63 while (source != dest)
66 std::iter_swap(source++, source);
68 std::iter_swap(source--, source);
73 RESULT eBouquet::flushChanges()
75 FILE *f=fopen((CONFIGDIR"/enigma2/"+m_filename).c_str(), "w");
78 if ( fprintf(f, "#NAME %s\r\n", m_bouquet_name.c_str()) < 0 )
80 for (list::iterator i(m_services.begin()); i != m_services.end(); ++i)
82 eServiceReference tmp = *i;
83 std::string str = tmp.path;
84 if ( i->flags&eServiceReference::canDescent )
86 unsigned int p1 = str.find("FROM BOUQUET \"");
87 if (p1 == std::string::npos)
89 eDebug("doof... kaputt");
94 if (p1 == std::string::npos)
96 eDebug("doof2... kaputt");
102 if ( fprintf(f, "#SERVICE %s\r\n", tmp.toString().c_str()) < 0 )
104 if ( i->name.length() )
105 if ( fprintf(f, "#DESCRIPTION %s\r\n", i->name.c_str()) < 0 )
112 eDebug("couldn't write file %s", m_filename.c_str());
116 RESULT eBouquet::setListName(const std::string &name)
118 m_bouquet_name = name;
122 eDVBService::eDVBService()
123 :m_cache(0), m_flags(0)
127 eDVBService::~eDVBService()
132 eDVBService &eDVBService::operator=(const eDVBService &s)
134 m_service_name = s.m_service_name;
135 m_service_name_sort = s.m_service_name_sort;
136 m_provider_name = s.m_provider_name;
139 copyCache(s.m_cache);
143 void eDVBService::genSortName()
145 m_service_name_sort = removeDVBChars(m_service_name);
146 makeUpper(m_service_name_sort);
147 while ((!m_service_name_sort.empty()) && m_service_name_sort[0] == ' ')
148 m_service_name_sort.erase(0, 1);
150 /* put unnamed services at the end, not at the beginning. */
151 if (m_service_name_sort.empty())
152 m_service_name_sort = "\xFF";
155 RESULT eDVBService::getName(const eServiceReference &ref, std::string &name)
157 if (!ref.name.empty())
158 name = ref.name; // use renamed service name..
159 else if (!m_service_name.empty())
160 name = m_service_name;
166 RESULT eDVBService::getEvent(const eServiceReference &ref, ePtr<eServiceEvent> &ptr, time_t start_time)
168 return eEPGCache::getInstance()->lookupEventTime(ref, start_time, ptr);
171 int eDVBService::isPlayable(const eServiceReference &ref, const eServiceReference &ignore)
173 ePtr<eDVBResourceManager> res_mgr;
174 if ( eDVBResourceManager::getInstance( res_mgr ) )
175 eDebug("isPlayble... no res manager!!");
178 eDVBChannelID chid, chid_ignore;
179 ((const eServiceReferenceDVB&)ref).getChannelID(chid);
180 ((const eServiceReferenceDVB&)ignore).getChannelID(chid_ignore);
181 return res_mgr->canAllocateChannel(chid, chid_ignore);
186 int eDVBService::checkFilter(const eServiceReferenceDVB &ref, const eDVBChannelQuery &query)
189 switch (query.m_type)
191 case eDVBChannelQuery::tName:
192 res = m_service_name_sort.find(query.m_string) != std::string::npos;
194 case eDVBChannelQuery::tProvider:
195 res = m_provider_name.find(query.m_string) != std::string::npos;
197 case eDVBChannelQuery::tType:
198 res = ref.getServiceType() == query.m_int;
200 case eDVBChannelQuery::tBouquet:
203 case eDVBChannelQuery::tSatellitePosition:
204 res = ((unsigned int)ref.getDVBNamespace().get())>>16 == (unsigned int)query.m_int;
206 case eDVBChannelQuery::tFlags:
207 res = (m_flags & query.m_int) == query.m_int;
209 case eDVBChannelQuery::tChannelID:
212 ref.getChannelID(chid);
213 res = chid == query.m_channelid;
216 case eDVBChannelQuery::tAND:
217 res = checkFilter(ref, *query.m_p1) && checkFilter(ref, *query.m_p2);
219 case eDVBChannelQuery::tOR:
220 res = checkFilter(ref, *query.m_p1) || checkFilter(ref, *query.m_p2);
222 case eDVBChannelQuery::tAny:
233 bool eDVBService::cacheEmpty()
236 for (int i=0; i < cacheMax; ++i)
237 if (m_cache[i] != -1)
242 void eDVBService::initCache()
244 m_cache = new int[cacheMax];
245 memset(m_cache, -1, sizeof(int) * cacheMax);
248 void eDVBService::copyCache(int *source)
253 m_cache = new int[cacheMax];
254 memcpy(m_cache, source, cacheMax * sizeof(int));
263 int eDVBService::getCacheEntry(cacheID id)
265 if (id >= cacheMax || !m_cache)
270 void eDVBService::setCacheEntry(cacheID id, int pid)
280 /* THIS CODE IS BAD. it should be replaced by somethine better. */
281 void eDVBDB::reloadServicelist()
283 eDebug("---- opening lame channel db");
284 FILE *f=fopen(CONFIGDIR"/enigma2/lamedb", "rt");
288 if ( !stat("lamedb", &s) )
290 if ( !stat(CONFIGDIR"/enigma2", &s) )
292 rename("lamedb", CONFIGDIR"/enigma2/lamedb" );
299 if ((!fgets(line, 256, f)) || strncmp(line, "eDVB services", 13))
301 eDebug("not a servicefile");
305 eDebug("reading services");
306 if ((!fgets(line, 256, f)) || strcmp(line, "transponders\n"))
308 eDebug("services invalid, no transponders");
313 // clear all transponders
317 if (!fgets(line, 256, f))
319 if (!strcmp(line, "end\n"))
321 int dvb_namespace=-1, transport_stream_id=-1, original_network_id=-1;
322 sscanf(line, "%x:%x:%x", &dvb_namespace, &transport_stream_id, &original_network_id);
323 if (original_network_id == -1)
325 eDVBChannelID channelid = eDVBChannelID(
326 eDVBNamespace(dvb_namespace),
327 eTransportStreamID(transport_stream_id),
328 eOriginalNetworkID(original_network_id));
330 ePtr<eDVBFrontendParameters> feparm = new eDVBFrontendParameters;
334 if (!strcmp(line, "/\n"))
338 eDVBFrontendParametersSatellite sat;
339 int frequency, symbol_rate, polarisation, fec, orbital_position, inversion,
340 system=eDVBFrontendParametersSatellite::System::DVB_S,
341 modulation=eDVBFrontendParametersSatellite::Modulation::QPSK,
342 rolloff=eDVBFrontendParametersSatellite::RollOff::alpha_auto;
343 sscanf(line+2, "%d:%d:%d:%d:%d:%d:%d:%d:%d", &frequency, &symbol_rate, &polarisation, &fec, &orbital_position, &inversion, &system, &modulation, &rolloff);
344 sat.frequency = frequency;
345 sat.symbol_rate = symbol_rate;
346 sat.polarisation = polarisation;
348 sat.orbital_position =
349 orbital_position < 0 ? orbital_position + 3600 : orbital_position;
350 sat.inversion = inversion;
352 sat.modulation = modulation;
353 sat.roll_off = rolloff;
354 feparm->setDVBS(sat);
355 } else if (line[1]=='t')
357 eDVBFrontendParametersTerrestrial ter;
358 int frequency, bandwidth, code_rate_HP, code_rate_LP, modulation, transmission_mode, guard_interval, hierarchy, inversion;
359 sscanf(line+2, "%d:%d:%d:%d:%d:%d:%d:%d:%d", &frequency, &bandwidth, &code_rate_HP, &code_rate_LP, &modulation, &transmission_mode, &guard_interval, &hierarchy, &inversion);
360 ter.frequency = frequency;
361 ter.bandwidth = bandwidth;
362 ter.code_rate_HP = code_rate_HP;
363 ter.code_rate_LP = code_rate_LP;
364 ter.modulation = modulation;
365 ter.transmission_mode = transmission_mode;
366 ter.guard_interval = guard_interval;
367 ter.hierarchy = hierarchy;
368 ter.inversion = inversion;
369 feparm->setDVBT(ter);
370 } else if (line[1]=='c')
372 eDVBFrontendParametersCable cab;
373 int frequency, symbol_rate,
374 inversion=eDVBFrontendParametersCable::Inversion::Unknown,
375 modulation=eDVBFrontendParametersCable::Modulation::Auto,
376 fec_inner=eDVBFrontendParametersCable::FEC::fAuto;
377 sscanf(line+2, "%d:%d:%d:%d:%d", &frequency, &symbol_rate, &inversion, &modulation, &fec_inner);
378 cab.frequency = frequency;
379 cab.fec_inner = fec_inner;
380 cab.inversion = inversion;
381 cab.symbol_rate = symbol_rate;
382 cab.modulation = modulation;
383 feparm->setDVBC(cab);
386 addChannelToList(channelid, feparm);
389 if ((!fgets(line, 256, f)) || strcmp(line, "services\n"))
391 eDebug("services invalid, no services");
395 // clear all services
401 if (!fgets(line, 256, f))
403 if (!strcmp(line, "end\n"))
406 int service_id=-1, dvb_namespace, transport_stream_id=-1, original_network_id=-1, service_type=-1, service_number=-1;
407 sscanf(line, "%x:%x:%x:%x:%d:%d", &service_id, &dvb_namespace, &transport_stream_id, &original_network_id, &service_type, &service_number);
408 if (service_number == -1)
410 ePtr<eDVBService> s = new eDVBService;
411 eServiceReferenceDVB ref =
412 eServiceReferenceDVB(
413 eDVBNamespace(dvb_namespace),
414 eTransportStreamID(transport_stream_id),
415 eOriginalNetworkID(original_network_id),
416 eServiceID(service_id),
421 line[strlen(line)-1]=0;
423 s->m_service_name = line;
428 line[strlen(line)-1]=0;
429 std::string str=line;
431 if (str[1]!=':') // old ... (only service_provider)
433 s->m_provider_name=line;
435 while ((!str.empty()) && str[1]==':') // new: p:, f:, c:%02d...
437 unsigned int c=str.find(',');
440 if (c == std::string::npos)
446 v=str.substr(2, c-2);
449 // eDebug("%c ... %s", p, v.c_str());
451 s->m_provider_name=v;
454 sscanf(v.c_str(), "%x", &s->m_flags);
458 sscanf(v.c_str(), "%02d%x", &cid, &val);
459 s->setCacheEntry((eDVBService::cacheID)cid,val);
463 sscanf(v.c_str(), "%04x", &val);
464 s->m_ca.push_front((uint16_t)val);
470 eDebug("loaded %d services", count);
475 void eDVBDB::saveServicelist()
477 eDebug("---- saving lame channel db");
478 FILE *f=fopen(CONFIGDIR"/enigma2/lamedb", "w");
479 int channels=0, services=0;
481 eFatal("couldn't save lame channel db!");
482 fprintf(f, "eDVB services /3/\n");
483 fprintf(f, "transponders\n");
484 for (std::map<eDVBChannelID, channel>::const_iterator i(m_channels.begin());
485 i != m_channels.end(); ++i)
487 const eDVBChannelID &chid = i->first;
488 const channel &ch = i->second;
490 fprintf(f, "%08x:%04x:%04x\n", chid.dvbnamespace.get(),
491 chid.transport_stream_id.get(), chid.original_network_id.get());
492 eDVBFrontendParametersSatellite sat;
493 eDVBFrontendParametersTerrestrial ter;
494 eDVBFrontendParametersCable cab;
495 if (!ch.m_frontendParameters->getDVBS(sat))
497 if (sat.system == eDVBFrontendParametersSatellite::System::DVB_S2)
499 fprintf(f, "\ts %d:%d:%d:%d:%d:%d:%d:%d:%d\n",
500 sat.frequency, sat.symbol_rate,
501 sat.polarisation, sat.fec,
502 sat.orbital_position > 1800 ? sat.orbital_position - 3600 : sat.orbital_position,
510 fprintf(f, "\ts %d:%d:%d:%d:%d:%d\n",
511 sat.frequency, sat.symbol_rate,
512 sat.polarisation, sat.fec,
513 sat.orbital_position > 1800 ? sat.orbital_position - 3600 : sat.orbital_position,
517 if (!ch.m_frontendParameters->getDVBT(ter))
519 fprintf(f, "\tt %d:%d:%d:%d:%d:%d:%d:%d:%d\n",
520 ter.frequency, ter.bandwidth, ter.code_rate_HP,
521 ter.code_rate_LP, ter.modulation, ter.transmission_mode,
522 ter.guard_interval, ter.hierarchy, ter.inversion);
524 if (!ch.m_frontendParameters->getDVBC(cab))
526 fprintf(f, "\tc %d:%d:%d:%d:%d\n",
527 cab.frequency, cab.symbol_rate, cab.inversion, cab.modulation, cab.fec_inner);
532 fprintf(f, "end\nservices\n");
534 for (std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator i(m_services.begin());
535 i != m_services.end(); ++i)
537 const eServiceReferenceDVB &s = i->first;
538 fprintf(f, "%04x:%08x:%04x:%04x:%d:%d\n",
539 s.getServiceID().get(), s.getDVBNamespace().get(),
540 s.getTransportStreamID().get(),s.getOriginalNetworkID().get(),
544 fprintf(f, "%s\n", i->second->m_service_name.c_str());
546 fprintf(f, "p:%s", i->second->m_provider_name.c_str());
549 for (int x=0; x < eDVBService::cacheMax; ++x)
551 int entry = i->second->getCacheEntry((eDVBService::cacheID)x);
553 fprintf(f, ",c:%02d%04x", x, entry);
556 // write cached ca pids
557 for (CAID_LIST::const_iterator ca(i->second->m_ca.begin());
558 ca != i->second->m_ca.end(); ++ca)
559 fprintf(f, ",C:%04x", *ca);
561 if (i->second->m_flags)
562 fprintf(f, ",f:%x", i->second->m_flags);
567 fprintf(f, "end\nHave a lot of bugs!\n");
568 eDebug("saved %d channels and %d services!", channels, services);
572 void eDVBDB::loadBouquet(const char *path)
574 std::string bouquet_name = path;
575 if (!bouquet_name.length())
577 eDebug("Bouquet load failed.. no path given..");
580 unsigned int pos = bouquet_name.rfind('/');
581 if ( pos != std::string::npos )
582 bouquet_name.erase(0, pos+1);
583 if (bouquet_name.empty())
585 eDebug("Bouquet load failed.. no filename given..");
588 eBouquet &bouquet = m_bouquets[bouquet_name];
589 bouquet.m_filename = bouquet_name;
590 std::list<eServiceReference> &list = bouquet.m_services;
593 std::string p = CONFIGDIR"/enigma2/";
595 eDebug("loading bouquet... %s", p.c_str());
596 FILE *fp=fopen(p.c_str(), "rt");
601 if ( !stat(path, &s) )
603 rename(path, p.c_str() );
607 eDebug("failed to open.");
608 if ( strstr(path, "bouquets.tv") )
610 eDebug("recreate bouquets.tv");
611 bouquet.m_bouquet_name="Bouquets (TV)";
612 bouquet.flushChanges();
614 else if ( strstr(path, "bouquets.radio") )
616 eDebug("recreate bouquets.radio");
617 bouquet.m_bouquet_name="Bouquets (Radio)";
618 bouquet.flushChanges();
623 bool read_descr=false;
624 eServiceReference *e = NULL;
627 if (!fgets(line, 256, fp))
629 line[strlen(line)-1]=0;
630 if (strlen(line) && line[strlen(line)-1]=='\r')
631 line[strlen(line)-1]=0;
636 if (!strncmp(line, "#SERVICE ", 9) || !strncmp(line, "#SERVICE: ", 10))
638 int offs = line[8] == ':' ? 10 : 9;
639 eServiceReference tmp(line+offs);
640 if (tmp.type != eServiceReference::idDVB)
642 eDebug("only DVB Bouquets supported");
645 if ( tmp.flags&eServiceReference::canDescent )
647 unsigned int pos = tmp.path.rfind('/');
648 if ( pos != std::string::npos )
649 tmp.path.erase(0, pos+1);
650 if (tmp.path.empty())
652 eDebug("Bouquet load failed.. no filename given..");
655 loadBouquet(tmp.path.c_str());
657 snprintf(buf, 256, "(type == %d) FROM BOUQUET \"%s\" ORDER BY bouquet", tmp.data[0], tmp.path.c_str());
665 else if (read_descr && !strncmp(line, "#DESCRIPTION ", 13))
670 else if (!strncmp(line, "#NAME ", 6))
671 bouquet.m_bouquet_name=line+6;
676 eDebug("%d entries in Bouquet %s", entries, bouquet_name.c_str());
679 void eDVBDB::reloadBouquets()
682 loadBouquet("groups.tv");
683 loadBouquet("groups.radio");
684 loadBouquet("bouquets.tv");
685 loadBouquet("bouquets.radio");
686 // create default bouquets when missing
687 if ( m_bouquets.find("userbouquet.favourites.tv") == m_bouquets.end() )
689 eBouquet &b = m_bouquets["userbouquet.favourites.tv"];
690 b.m_filename = "userbouquet.favourites.tv";
691 b.m_bouquet_name = "Favourites (TV)";
693 eServiceReference ref;
694 memset(ref.data, 0, sizeof(ref.data));
698 ref.path="(type == 1) FROM BOUQUET \"userbouquet.favourites.tv\" ORDER BY bouquet";
699 eBouquet &parent = m_bouquets["bouquets.tv"];
700 parent.m_services.push_back(ref);
701 parent.flushChanges();
703 if ( m_bouquets.find("userbouquet.favourites.radio") == m_bouquets.end() )
705 eBouquet &b = m_bouquets["userbouquet.favourites.radio"];
706 b.m_filename = "userbouquet.favourites.radio";
707 b.m_bouquet_name = "Favourites (Radio)";
709 eServiceReference ref;
710 memset(ref.data, 0, sizeof(ref.data));
714 ref.path="(type == 2) FROM BOUQUET \"userbouquet.favourites.radio\" ORDER BY bouquet";
715 eBouquet &parent = m_bouquets["bouquets.radio"];
716 parent.m_services.push_back(ref);
717 parent.flushChanges();
721 eDVBDB *eDVBDB::instance;
734 RESULT eDVBDB::removeService(const eServiceReference &ref)
736 if (ref.type == eServiceReference::idDVB)
738 eServiceReferenceDVB &service = (eServiceReferenceDVB&)ref;
739 std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator it(m_services.find(service));
740 if (it != m_services.end())
742 m_services.erase(it);
749 RESULT eDVBDB::removeServices(int dvb_namespace, int tsid, int onid, unsigned int orb_pos)
751 return removeServices(eDVBChannelID(eDVBNamespace(dvb_namespace), eTransportStreamID(tsid), eOriginalNetworkID(onid)), orb_pos);
754 RESULT eDVBDB::removeServices(eDVBChannelID chid, unsigned int orbpos)
758 eTransportStreamID eTsid;
759 eOriginalNetworkID eOnid;
760 std::map<eDVBChannelID, channel>::iterator it(m_channels.begin());
761 std::set<eDVBChannelID> removed_chids;
762 while (it != m_channels.end())
764 const eDVBChannelID &ch = it->first;
767 it->second.m_frontendParameters->getSystem(system);
768 if ( orbpos != 0xFFFFFFFF && system == iDVBFrontend::feSatellite )
770 eDVBFrontendParametersSatellite sat;
771 it->second.m_frontendParameters->getDVBS(sat);
772 if ((unsigned int)sat.orbital_position != orbpos)
775 if ( remove && chid.dvbnamespace != eNs && chid.dvbnamespace != ch.dvbnamespace )
777 if ( remove && chid.original_network_id != eOnid && chid.original_network_id != ch.original_network_id )
779 if ( remove && chid.transport_stream_id != eTsid && chid.transport_stream_id != ch.transport_stream_id )
783 eDebug("remove %08x %04x %04x",
784 ch.dvbnamespace.get(),
785 ch.original_network_id.get(),
786 ch.transport_stream_id.get());
787 removed_chids.insert(it->first);
788 m_channels.erase(it++);
793 if (!removed_chids.empty())
795 std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator service(m_services.begin());
796 while(service != m_services.end())
799 service->first.getChannelID(chid);
800 std::set<eDVBChannelID>::iterator it(removed_chids.find(chid));
801 if (it != removed_chids.end())
802 m_services.erase(service++);
811 RESULT eDVBDB::addFlag(const eServiceReference &ref, unsigned int flagmask)
813 if (ref.type == eServiceReference::idDVB)
815 eServiceReferenceDVB &service = (eServiceReferenceDVB&)ref;
816 std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator it(m_services.find(service));
817 if (it != m_services.end())
818 it->second->m_flags |= ~flagmask;
824 RESULT eDVBDB::removeFlag(const eServiceReference &ref, unsigned int flagmask)
826 if (ref.type == eServiceReference::idDVB)
828 eServiceReferenceDVB &service = (eServiceReferenceDVB&)ref;
829 std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator it(m_services.find(service));
830 if (it != m_services.end())
831 it->second->m_flags &= ~flagmask;
837 RESULT eDVBDB::removeFlags(unsigned int flagmask, int dvb_namespace, int tsid, int onid, unsigned int orb_pos)
839 return removeFlags(flagmask, eDVBChannelID(eDVBNamespace(dvb_namespace), eTransportStreamID(tsid), eOriginalNetworkID(onid)), orb_pos);
842 RESULT eDVBDB::removeFlags(unsigned int flagmask, eDVBChannelID chid, unsigned int orbpos)
845 eTransportStreamID eTsid;
846 eOriginalNetworkID eOnid;
847 std::map<eDVBChannelID, channel>::iterator it(m_channels.begin());
848 std::set<eDVBChannelID> removed_chids;
849 while (it != m_channels.end())
851 const eDVBChannelID &ch = it->first;
854 it->second.m_frontendParameters->getSystem(system);
855 if ( orbpos != 0xFFFFFFFF && system == iDVBFrontend::feSatellite )
857 eDVBFrontendParametersSatellite sat;
858 it->second.m_frontendParameters->getDVBS(sat);
859 if ((unsigned int)sat.orbital_position != orbpos)
862 if ( remove && chid.dvbnamespace != eNs && chid.dvbnamespace != ch.dvbnamespace )
864 if ( remove && chid.original_network_id != eOnid && chid.original_network_id != ch.original_network_id )
866 if ( remove && chid.transport_stream_id != eTsid && chid.transport_stream_id != ch.transport_stream_id )
869 removed_chids.insert(it->first);
872 if (!removed_chids.empty())
874 std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator service(m_services.begin());
875 while(service != m_services.end())
878 service->first.getChannelID(chid);
879 std::set<eDVBChannelID>::iterator it(removed_chids.find(chid));
880 if (it != removed_chids.end())
881 service->second->m_flags &= ~flagmask;
888 RESULT eDVBDB::addChannelToList(const eDVBChannelID &id, iDVBFrontendParameters *feparm)
892 ch.m_frontendParameters = feparm;
893 m_channels.insert(std::pair<eDVBChannelID, channel>(id, ch));
897 RESULT eDVBDB::removeChannel(const eDVBChannelID &id)
899 m_channels.erase(id);
903 RESULT eDVBDB::getChannelFrontendData(const eDVBChannelID &id, ePtr<iDVBFrontendParameters> &parm)
905 std::map<eDVBChannelID, channel>::iterator i = m_channels.find(id);
906 if (i == m_channels.end())
911 parm = i->second.m_frontendParameters;
915 RESULT eDVBDB::addService(const eServiceReferenceDVB &serviceref, eDVBService *service)
917 std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator it(m_services.find(serviceref));
918 if (it == m_services.end())
919 m_services.insert(std::pair<eServiceReferenceDVB, ePtr<eDVBService> >(serviceref, service));
923 RESULT eDVBDB::getService(const eServiceReferenceDVB &reference, ePtr<eDVBService> &service)
925 std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator i;
926 i = m_services.find(reference);
927 if (i == m_services.end())
936 RESULT eDVBDB::flush()
942 RESULT eDVBDB::getBouquet(const eServiceReference &ref, eBouquet* &bouquet)
944 std::string str = ref.path;
947 eDebug("getBouquet failed.. no path given!");
950 unsigned int pos = str.find("FROM BOUQUET \"");
951 if ( pos != std::string::npos )
953 str.erase(0, pos+14);
955 if ( pos != std::string::npos )
962 eDebug("getBouquet failed.. couldn't parse bouquet name");
965 std::map<std::string, eBouquet>::iterator i =
966 m_bouquets.find(str);
967 if (i == m_bouquets.end())
972 bouquet = &i->second;
976 RESULT eDVBDB::startQuery(ePtr<iDVBChannelListQuery> &query, eDVBChannelQuery *q, const eServiceReference &source)
978 if ( source.path.find("FROM") != std::string::npos )
980 if ( source.path.find("BOUQUET") != std::string::npos )
981 query = new eDVBDBBouquetQuery(this, source, q);
982 else if ( source.path.find("SATELLITES") != std::string::npos )
983 query = new eDVBDBSatellitesQuery(this, source, q);
984 else if ( source.path.find("PROVIDERS") != std::string::npos )
985 query = new eDVBDBProvidersQuery(this, source, q);
987 eFatal("invalid query %s", source.toString().c_str());
990 query = new eDVBDBQuery(this, source, q);
994 eServiceReference eDVBDB::searchReference(int tsid, int onid, int sid)
997 eTransportStreamID Tsid(tsid);
998 eOriginalNetworkID Onid(onid);
999 for (std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator sit(m_services.begin());
1000 sit != m_services.end(); ++sit)
1002 if (sit->first.getTransportStreamID() == Tsid &&
1003 sit->first.getOriginalNetworkID() == Onid &&
1004 sit->first.getServiceID() == Sid)
1007 return eServiceReference();
1010 DEFINE_REF(eDVBDBQueryBase);
1012 eDVBDBQueryBase::eDVBDBQueryBase(eDVBDB *db, const eServiceReference &source, eDVBChannelQuery *query)
1013 :m_db(db), m_query(query), m_source(source)
1017 int eDVBDBQueryBase::compareLessEqual(const eServiceReferenceDVB &a, const eServiceReferenceDVB &b)
1019 ePtr<eDVBService> a_service, b_service;
1020 int sortmode = m_query ? m_query->m_sort : eDVBChannelQuery::tName;
1022 if ((sortmode == eDVBChannelQuery::tName) || (sortmode == eDVBChannelQuery::tProvider))
1024 if (a.name.empty() && m_db->getService(a, a_service))
1026 if (b.name.empty() && m_db->getService(b, b_service))
1032 case eDVBChannelQuery::tName:
1036 return a_service->m_service_name_sort < b_service->m_service_name_sort;
1039 std::string str = b.name;
1041 return a_service->m_service_name_sort < str;
1046 std::string str = a.name;
1048 return str < b_service->m_service_name_sort;
1052 std::string aa = a.name, bb = b.name;
1057 case eDVBChannelQuery::tProvider:
1058 return a_service->m_provider_name < b_service->m_provider_name;
1059 case eDVBChannelQuery::tType:
1060 return a.getServiceType() < b.getServiceType();
1061 case eDVBChannelQuery::tBouquet:
1063 case eDVBChannelQuery::tSatellitePosition:
1064 return (a.getDVBNamespace().get() >> 16) < (b.getDVBNamespace().get() >> 16);
1071 eDVBDBQuery::eDVBDBQuery(eDVBDB *db, const eServiceReference &source, eDVBChannelQuery *query)
1072 :eDVBDBQueryBase(db, source, query)
1074 m_cursor = m_db->m_services.begin();
1077 RESULT eDVBDBQuery::getNextResult(eServiceReferenceDVB &ref)
1079 while (m_cursor != m_db->m_services.end())
1081 ref = m_cursor->first;
1083 int res = (!m_query) || m_cursor->second->checkFilter(ref, *m_query);
1091 ref.type = eServiceReference::idInvalid;
1096 eDVBDBBouquetQuery::eDVBDBBouquetQuery(eDVBDB *db, const eServiceReference &source, eDVBChannelQuery *query)
1097 :eDVBDBQueryBase(db, source, query), m_cursor(db->m_bouquets[query->m_bouquet_name].m_services.begin())
1101 RESULT eDVBDBBouquetQuery::getNextResult(eServiceReferenceDVB &ref)
1103 eBouquet &bouquet = m_db->m_bouquets[m_query->m_bouquet_name];
1104 std::list<eServiceReference> &list = bouquet.m_services;
1105 while (m_cursor != list.end())
1107 ref = *((eServiceReferenceDVB*)&(*m_cursor));
1109 std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator it =
1110 m_db->m_services.find(ref);
1112 int res = (!m_query) || it == m_db->m_services.end() || it->second->checkFilter(ref, *m_query);
1120 ref.type = eServiceReference::idInvalid;
1125 eDVBDBListQuery::eDVBDBListQuery(eDVBDB *db, const eServiceReference &source, eDVBChannelQuery *query)
1126 :eDVBDBQueryBase(db, source, query), m_cursor(m_list.end())
1130 RESULT eDVBDBListQuery::getNextResult(eServiceReferenceDVB &ref)
1132 if (m_cursor != m_list.end())
1137 ref.type = eServiceReference::idInvalid;
1141 int eDVBDBListQuery::compareLessEqual(const eServiceReferenceDVB &a, const eServiceReferenceDVB &b)
1143 if ( m_query->m_sort == eDVBChannelQuery::tSatellitePosition )
1145 int x = (a.getDVBNamespace().get() >> 16);
1146 int y = (b.getDVBNamespace().get() >> 16);
1153 std::string aa = a.name, bb = b.name;
1159 eDVBDBSatellitesQuery::eDVBDBSatellitesQuery(eDVBDB *db, const eServiceReference &source, eDVBChannelQuery *query)
1160 :eDVBDBListQuery(db, source, query)
1162 std::set<unsigned int> found;
1163 for (std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator it(m_db->m_services.begin());
1164 it != m_db->m_services.end(); ++it)
1166 int res = it->second->checkFilter(it->first, *query);
1169 unsigned int dvbnamespace = it->first.getDVBNamespace().get()&0xFFFF0000;
1170 if (found.find(dvbnamespace) == found.end())
1172 found.insert(dvbnamespace);
1173 eServiceReferenceDVB ref;
1174 ref.setDVBNamespace(dvbnamespace);
1175 ref.flags=eServiceReference::flagDirectory;
1177 snprintf(buf, 128, "(satellitePosition == %d) && ", dvbnamespace>>16);
1179 ref.path=buf+source.path;
1180 unsigned int pos=ref.path.find("FROM");
1181 ref.path.erase(pos);
1182 ref.path+="ORDER BY name";
1183 // eDebug("ref.path now %s", ref.path.c_str());
1184 m_list.push_back(ref);
1186 ref.path=buf+source.path;
1187 pos=ref.path.find("FROM");
1188 ref.path.erase(pos+5);
1189 ref.path+="PROVIDERS ORDER BY name";
1190 // eDebug("ref.path now %s", ref.path.c_str());
1191 m_list.push_back(ref);
1193 snprintf(buf, 128, "(satellitePosition == %d) && (flags == %d) && ", dvbnamespace>>16, eDVBService::dxNewFound);
1194 ref.path=buf+source.path;
1195 pos=ref.path.find("FROM");
1196 ref.path.erase(pos);
1197 ref.path+="ORDER BY name";
1198 // eDebug("ref.path now %s", ref.path.c_str());
1199 m_list.push_back(ref);
1203 m_cursor=m_list.begin();
1206 eDVBDBProvidersQuery::eDVBDBProvidersQuery(eDVBDB *db, const eServiceReference &source, eDVBChannelQuery *query)
1207 :eDVBDBListQuery(db, source, query)
1209 std::set<std::string> found;
1210 for (std::map<eServiceReferenceDVB, ePtr<eDVBService> >::iterator it(m_db->m_services.begin());
1211 it != m_db->m_services.end(); ++it)
1213 int res = it->second->checkFilter(it->first, *query);
1216 const char *provider_name = it->second->m_provider_name.length() ?
1217 it->second->m_provider_name.c_str() :
1219 if (found.find(std::string(provider_name)) == found.end())
1221 found.insert(std::string(provider_name));
1222 eServiceReferenceDVB ref;
1224 ref.name=provider_name;
1225 snprintf(buf, 64, "(provider == \"%s\") && ", provider_name);
1226 ref.path=buf+source.path;
1227 unsigned int pos = ref.path.find("FROM");
1228 ref.flags=eServiceReference::flagDirectory;
1229 ref.path.erase(pos);
1230 ref.path+="ORDER BY name";
1231 // eDebug("ref.path now %s", ref.path.c_str());
1232 m_list.push_back(ref);
1236 m_cursor=m_list.begin();
1239 /* (<name|provider|type|bouquet|satpos|chid> <==|...> <"string"|int>)[||,&& (..)] */
1241 static int decodeType(const std::string &type)
1244 return eDVBChannelQuery::tName;
1245 else if (type == "provider")
1246 return eDVBChannelQuery::tProvider;
1247 else if (type == "type")
1248 return eDVBChannelQuery::tType;
1249 else if (type == "bouquet")
1250 return eDVBChannelQuery::tBouquet;
1251 else if (type == "satellitePosition")
1252 return eDVBChannelQuery::tSatellitePosition;
1253 else if (type == "channelID")
1254 return eDVBChannelQuery::tChannelID;
1255 else if (type == "flags")
1256 return eDVBChannelQuery::tFlags;
1261 /* never, NEVER write a parser in C++! */
1262 RESULT parseExpression(ePtr<eDVBChannelQuery> &res, std::list<std::string>::const_iterator begin, std::list<std::string>::const_iterator end)
1264 std::list<std::string>::const_iterator end_of_exp;
1268 eDebug("empty expression!");
1275 while (end_of_exp != end)
1276 if (*end_of_exp == ")")
1281 if (end_of_exp == end)
1283 eDebug("expression parse: end of expression while searching for closing brace");
1288 // begin..end_of_exp
1289 int r = parseExpression(res, begin, end_of_exp);
1294 /* we had only one sub expression */
1295 if (end_of_exp == end)
1297 // eDebug("only one sub expression");
1301 /* otherwise we have an operator here.. */
1303 ePtr<eDVBChannelQuery> r2 = res;
1304 res = new eDVBChannelQuery();
1310 if (*end_of_exp == "||")
1311 res->m_type = eDVBChannelQuery::tOR;
1312 else if (*end_of_exp == "&&")
1313 res->m_type = eDVBChannelQuery::tAND;
1316 eDebug("found operator %s, but only && and || are allowed!", end_of_exp->c_str());
1323 return parseExpression(res->m_p2, end_of_exp, end);
1326 // "begin" <op> "end"
1327 std::string type, op, val;
1329 res = new eDVBChannelQuery();
1333 while (begin != end)
1347 eDebug("malformed query: got '%s', but expected only <type> <op> <val>", begin->c_str());
1356 eDebug("malformed query: missing stuff");
1361 res->m_type = decodeType(type);
1363 if (res->m_type == -1)
1365 eDebug("malformed query: invalid type %s", type.c_str());
1372 else if (op == "!=")
1376 eDebug("invalid operator %s", op.c_str());
1381 res->m_string = val;
1382 res->m_int = atoi(val.c_str());
1383 // res->m_channelid = eDVBChannelID(val);
1388 RESULT eDVBChannelQuery::compile(ePtr<eDVBChannelQuery> &res, std::string query)
1390 std::list<std::string> tokens;
1392 std::string current_token;
1393 std::string bouquet_name;
1395 // eDebug("splitting %s....", query.c_str());
1397 const char *splitchars="()";
1398 int quotemode = 0, lastsplit = 0, lastalnum = 0;
1399 while (i <= query.size())
1401 int c = (i < query.size()) ? query[i] : ' ';
1404 int issplit = !!strchr(splitchars, c);
1405 int isaln = isalnum(c);
1406 int iswhite = c == ' ';
1407 int isquot = c == '\"';
1411 iswhite = issplit = 0;
1415 if (issplit || iswhite || isquot || lastsplit || (lastalnum != isaln))
1417 if (current_token.size())
1418 tokens.push_back(current_token);
1419 current_token.clear();
1422 if (!(iswhite || isquot))
1426 quotemode = !quotemode;
1427 lastsplit = issplit;
1431 // for (std::list<std::string>::const_iterator a(tokens.begin()); a != tokens.end(); ++a)
1433 // printf("%s\n", a->c_str());
1436 int sort = eDVBChannelQuery::tName;
1437 /* check for "ORDER BY ..." */
1439 std::list<std::string>::iterator it = tokens.begin();
1440 while (it != tokens.end())
1445 if (it != tokens.end() && *it == "BY")
1448 sort = decodeType(*it);
1453 else if (*it == "FROM")
1456 if (it != tokens.end() && *it == "BOUQUET")
1462 else if (it != tokens.end() && *it == "SATELLITES")
1464 else if (it != tokens.end() && *it == "PROVIDERS")
1468 eDebug("FROM unknown %s", (*it).c_str());
1478 eWarning("ORDER BY .. string invalid.");
1483 // eDebug("sort by %d", sort);
1485 /* now we recursivly parse that. */
1486 int r = parseExpression(res, tokens.begin(), tokens.end());
1488 /* we have an empty (but valid!) expression */
1491 res = new eDVBChannelQuery();
1493 res->m_type = eDVBChannelQuery::tAny;
1499 res->m_bouquet_name = bouquet_name;
1502 // eDebug("return: %d", r);
1506 DEFINE_REF(eDVBChannelQuery);