X-Git-Url: http://code.vuplus.com/gitweb/?p=vuplus_dvbapp;a=blobdiff_plain;f=lib%2Fservice%2Fevent.cpp;h=949e150a7a4e1a562262bf43d9c5d074165ade44;hp=482527cc5d45d5a5a5a28c7f6a1aaaa5af9b6d93;hb=0a62b65175152c42976d4cb04fb7026d9f910915;hpb=4269ecde13580077c4d234b21784f704bf43e8fc diff --git a/lib/service/event.cpp b/lib/service/event.cpp index 482527c..949e150 100644 --- a/lib/service/event.cpp +++ b/lib/service/event.cpp @@ -1,30 +1,299 @@ #include #include -#include -#include -#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include +#include + +// static members / methods +std::string eServiceEvent::m_language = "de_DE"; + +void eServiceEvent::setEPGLanguage( const std::string language ) +{ + m_language = language; +} +/////////////////////////// DEFINE_REF(eServiceEvent); +DEFINE_REF(eComponentData); + +const char MAX_LANG = 37; +/* OSD language (see /share/locales/locales) to iso639 conversion table */ +std::string ISOtbl[MAX_LANG][2] = +{ + {"ar_AE","ara"}, + {"C","eng"}, + {"cs_CZ","ces"}, /* or 'cze' */ + {"cs_CZ","cze"}, + {"da_DK","dan"}, + {"de_DE","deu"}, /* also 'ger' is valid iso639 code!! */ + {"de_DE","ger"}, + {"el_GR","gre"}, /* also 'ell' is valid */ + {"el_GR","ell"}, + {"es_ES","esl"}, /* also 'spa' is ok */ + {"es_ES","spa"}, + {"et_EE","est"}, + {"fi_FI","fin"}, + {"fr_FR","fra"}, + {"hr_HR","hrv"}, /* or 'scr' */ + {"hr_HR","scr"}, + {"hu_HU","hun"}, + {"is_IS","isl"}, /* or 'ice' */ + {"is_IS","ice"}, + {"it_IT","ita"}, + {"lt_LT","lit"}, + {"nl_NL","nld"}, /* or 'dut' */ + {"nl_NL","dut"}, + {"no_NO","nor"}, + {"pl_PL","pol"}, + {"pt_PT","por"}, + {"ro_RO","ron"}, /* or 'rum' */ + {"ro_RO","rum"}, + {"ru_RU","rus"}, + {"sk_SK","slk"}, /* or 'slo' */ + {"sk_SK","slo"}, + {"sl_SI","slv"}, + {"sr_YU","srp"}, /* or 'scc' */ + {"sr_YU","scc"}, + {"sv_SE","swe"}, + {"tr_TR","tur"}, + {"ur_IN","urd"} +}; -RESULT eServiceEvent::parseFrom(Event *evt) +/* search for the presence of language from given EIT event descriptors*/ +bool eServiceEvent::loadLanguage(Event *evt, std::string lang, int tsidonid) { - m_begin = 0; // ich bin FAUL - m_duration = (evt->getDuration() & 0xFF) + ((evt->getDuration() >> 8) & 0xFF) * 60 + ((evt->getDuration() >> 16) & 0xFF) * 24 * 60; - + bool retval=0; for (DescriptorConstIterator desc = evt->getDescriptors()->begin(); desc != evt->getDescriptors()->end(); ++desc) { switch ((*desc)->getTag()) { - case SHORT_EVENT_DESCRIPTOR: - { - const ShortEventDescriptor *sed = (ShortEventDescriptor*)*desc; - m_event_name = convertDVBUTF8(sed->getEventName()); - m_description = convertDVBUTF8(sed->getText()); - break; + case LINKAGE_DESCRIPTOR: + m_linkage_services.clear(); + break; + case SHORT_EVENT_DESCRIPTOR: + { + const ShortEventDescriptor *sed = (ShortEventDescriptor*)*desc; + const std::string &cc = sed->getIso639LanguageCode(); + int table=encodingHandler.getCountryCodeDefaultMapping(cc); + if (lang.empty()) + lang = cc; // use first found language + if (cc == lang) + { + m_event_name = convertDVBUTF8(replace_all(replace_all(sed->getEventName(), "\n", " "), "\t", " "), table, tsidonid); + m_short_description = convertDVBUTF8(sed->getText(), table, tsidonid); + retval=1; + } + break; + } + case EXTENDED_EVENT_DESCRIPTOR: + { + const ExtendedEventDescriptor *eed = (ExtendedEventDescriptor*)*desc; + const std::string &cc = eed->getIso639LanguageCode(); + int table=encodingHandler.getCountryCodeDefaultMapping(cc); + if (lang.empty()) + lang = cc; // use first found language + if (cc == lang) + { + m_extended_description += convertDVBUTF8(eed->getText(), table, tsidonid); + retval=1; + } +#if 0 + const ExtendedEventList *itemlist = eed->getItems(); + for (ExtendedEventConstIterator it = itemlist->begin(); it != itemlist->end(); ++it) + { + m_extended_description += '\n'; + m_extended_description += convertDVBUTF8((*it)->getItemDescription()); + m_extended_description += ' '; + m_extended_description += convertDVBUTF8((*it)->getItem()); + } +#endif + break; + } + default: + break; } + } + if ( retval == 1 ) + { + for (DescriptorConstIterator desc = evt->getDescriptors()->begin(); desc != evt->getDescriptors()->end(); ++desc) + { + switch ((*desc)->getTag()) + { + case COMPONENT_DESCRIPTOR: + { + const ComponentDescriptor *cp = (ComponentDescriptor*)*desc; + eComponentData data; + data.m_streamContent = cp->getStreamContent(); + data.m_componentType = cp->getComponentType(); + data.m_componentTag = cp->getComponentTag(); + data.m_iso639LanguageCode = cp->getIso639LanguageCode(); + int table=encodingHandler.getCountryCodeDefaultMapping(data.m_iso639LanguageCode); + data.m_text = convertDVBUTF8(cp->getText(),table,tsidonid); + m_component_data.push_back(data); + break; + } + case LINKAGE_DESCRIPTOR: + { + const LinkageDescriptor *ld = (LinkageDescriptor*)*desc; + if ( ld->getLinkageType() == 0xB0 ) + { + eServiceReference ref; + ref.type = eServiceReference::idDVB; + eServiceReferenceDVB &dvb_ref = (eServiceReferenceDVB&) ref; + dvb_ref.setServiceType(1); + dvb_ref.setTransportStreamID(ld->getTransportStreamId()); + dvb_ref.setOriginalNetworkID(ld->getOriginalNetworkId()); + dvb_ref.setServiceID(ld->getServiceId()); + const PrivateDataByteVector *privateData = ld->getPrivateDataBytes(); + dvb_ref.name = convertDVBUTF8((const unsigned char*)&((*privateData)[0]), privateData->size(), 1, tsidonid); + m_linkage_services.push_back(ref); + } + break; + } + } } } + if ( m_extended_description.find(m_short_description) == 0 ) + m_short_description=""; + return retval; +} + +RESULT eServiceEvent::parseFrom(Event *evt, int tsidonid) +{ + uint16_t stime_mjd = evt->getStartTimeMjd(); + uint32_t stime_bcd = evt->getStartTimeBcd(); + uint32_t duration = evt->getDuration(); + m_begin = parseDVBtime( + stime_mjd >> 8, + stime_mjd&0xFF, + stime_bcd >> 16, + (stime_bcd >> 8)&0xFF, + stime_bcd & 0xFF + ); + m_event_id = evt->getEventId(); + m_duration = fromBCD(duration>>16)*3600+fromBCD(duration>>8)*60+fromBCD(duration); + for (int i=0; i < MAX_LANG; i++) + if (m_language==ISOtbl[i][0]) + if (loadLanguage(evt, ISOtbl[i][1], tsidonid)) + return 0; + if (loadLanguage(evt, "eng", tsidonid)) + return 0; + if (loadLanguage(evt, std::string(), tsidonid)) + return 0; return 0; } +RESULT eServiceEvent::parseFrom(const std::string filename, int tsidonid) +{ + if (!filename.empty()) + { + int fd = ::open( filename.c_str(), O_RDONLY ); + if ( fd > -1 ) + { + __u8 buf[4096]; + int rd = ::read(fd, buf, 4096); + ::close(fd); + if ( rd > 12 /*EIT_LOOP_SIZE*/ ) + { + Event ev(buf); + parseFrom(&ev, tsidonid); + return 0; + } + } + } + return -1; +} + +std::string eServiceEvent::getBeginTimeString() const +{ + tm t; + localtime_r(&m_begin, &t); + char tmp[13]; + snprintf(tmp, 13, "%02d.%02d, %02d:%02d", + t.tm_mday, t.tm_mon+1, + t.tm_hour, t.tm_min); + return std::string(tmp, 12); +} + +RESULT eServiceEvent::getComponentData(ePtr &dest, int tagnum) const +{ + std::list::const_iterator it = + m_component_data.begin(); + for(;it != m_component_data.end(); ++it) + { + if ( it->m_componentTag == tagnum ) + { + dest=new eComponentData(*it); + return 0; + } + } + dest=0; + return -1; +} + +PyObject *eServiceEvent::getComponentData() const +{ + ePyObject ret = PyList_New(m_component_data.size()); + int cnt=0; + for (std::list::const_iterator it(m_component_data.begin()); it != m_component_data.end(); ++it) + { + ePyObject tuple = PyTuple_New(5); + PyTuple_SET_ITEM(tuple, 0, PyInt_FromLong(it->m_componentTag)); + PyTuple_SET_ITEM(tuple, 1, PyInt_FromLong(it->m_componentType)); + PyTuple_SET_ITEM(tuple, 2, PyInt_FromLong(it->m_streamContent)); + PyTuple_SET_ITEM(tuple, 3, PyString_FromString(it->m_iso639LanguageCode.c_str())); + PyTuple_SET_ITEM(tuple, 4, PyString_FromString(it->m_text.c_str())); + PyList_SET_ITEM(ret, cnt++, tuple); + } + return ret; +} + +RESULT eServiceEvent::getLinkageService(eServiceReference &service, eServiceReference &parent, int num) const +{ + std::list::const_iterator it = + m_linkage_services.begin(); + while( it != m_linkage_services.end() && num-- ) + ++it; + if ( it != m_linkage_services.end() ) + { + service = *it; + eServiceReferenceDVB &subservice = (eServiceReferenceDVB&) service; + eServiceReferenceDVB ¤t = (eServiceReferenceDVB&) parent; + subservice.setDVBNamespace(current.getDVBNamespace()); + if ( current.getParentTransportStreamID().get() ) + { + subservice.setParentTransportStreamID( current.getParentTransportStreamID() ); + subservice.setParentServiceID( current.getParentServiceID() ); + } + else + { + subservice.setParentTransportStreamID( current.getTransportStreamID() ); + subservice.setParentServiceID( current.getServiceID() ); + } + if ( subservice.getParentTransportStreamID() == subservice.getTransportStreamID() && + subservice.getParentServiceID() == subservice.getServiceID() ) + { + subservice.setParentTransportStreamID( eTransportStreamID(0) ); + subservice.setParentServiceID( eServiceID(0) ); + } + return 0; + } + service.type = eServiceReference::idInvalid; + return -1; +} + +void setServiceEventLanguage(const std::string language) +{ + eServiceEvent::setEPGLanguage(language); +} + DEFINE_REF(eDebugClass);