"j8 dZddlZddlZddlZddlZddlZddlZddlmZmZm Z ddl m Z e ejdrejjde ejdrejjdddlZddlmZmZmZej*ej,d d ej.ejg ej0eZe d Zd ZdZdeedee dedeefdZ!dedefdZ"dede fdZ#de dedzfdZ$dededeefdZ%deede fdZ&dZ'dZ(d Z)ed!k(re)yy)"u EPG Bot — Main orchestrator. Fetches the complete daily EPG at midnight (or on startup) and saves it to epg_daily.json. Then, runs a local loop every 60 seconds to extract currently airing programs and saves them to epg.json in real-time. Usage: python epg_bot.py # Run continuously (updates epg.json every 1 min) python epg_bot.py --once # Single scrape + generate epg.json once, then exit N)datedatetime timedelta)ZoneInfo reconfigureutf-8encoding RaiScraperMediasetScraper SkyScraperz'%(asctime)s [%(levelname)s] %(message)sz%Y-%m-%d %H:%M:%S)levelformatdatefmthandlersz Europe/Romezepg_daily.jsonc<tttgS)zInitialize all scrapers.r @C:\Users\Claud\Documents\Epg General Channel - Simple\epg_bot.pycreate_scrapersr/s    rentriesexpected_channels target_datereturnc |Dcic]}|g}}|D]5}|jd}||vr||j|-|s0|g||<7t|j|j|j dddt }|tdz}g} |jD]\}} | s6| jdd||j|jdd d ?g} | D];} tj| jd d} | j| | f=| jd |}| D]\}}||tdzkDr5| jdd||j|jdd d | j||jd}|r# tj|}t||}t||tdz}||tdz ks[| jdd||j|tdzjdd d | Scc}w#t$rYpwxYw#t$rt||tdz}YDwxYw)zGFill schedule gaps with a default 'Nessun Programma Disponibile' event.channelr)tzinfo)dayszNessun Programma Disponibilez9Nessuna programmazione disponibile per l'intera giornata.Intrattenimento)titleimagerstartend descriptioncategoryr%c |dS)Nrr)xs rzfill_epg_gaps..^sqtrkey)minutesz;Nessuna programmazione disponibile in questa fascia oraria.r&hours)getappendryearmonthdayROME_TZritems isoformat fromisoformat Exceptionsortmax)rrrchchannel_programsprogr start_of_day end_of_dayfilled_entriesprogs valid_progspdt current_time prog_startend_strprog_ends r fill_epg_gapsrM8s):;):2B):;((9% & & W % , ,T 2 )- W % K,,k.?.?RSUVXYbijL q 11JN*002  ! !7"%//1!++-Z-#   A ++AEE'2,>?""B7+ ^,$ + JL9Q+???%%;&)335%//1#` 1'  ! !$ 'hhuoGV'55g>H#&|X#>L #<ia>P1PQ 3!,8 *y';; ;  ! !7"%//1$yq'99DDF\-# q3D a>+;*EEWE W E!%W%9%9%;%B%B%D E ,-=?PR]^ #3Jx !"23E(O KK!H:Z4D0E/FF[\ ]!. KK6( KK67 E ;;=% b)*"UG:>? ) KK*UG:./ / F LL1XJ&LQCP Q#%Jx E(O s+AFFA.FF G%%GGdata output_filect|dd5}tj||dddddtj d|y#1swY"xYw) z%Save daily EPG database to JSON file.wrr F ensure_asciiindentNu#💾 Guida giornaliera salvata in: )openjsondumprXrYrmrnfs rsave_daily_epgrzsD k3 1Q $a8 2 KK5k]CD 2 1s A  A input_filectjj|sy t|dd5}t j |cdddS#1swYyxYw#t $r%}tjd|d|Yd}~yd}~wwxYw)z4Load daily EPG database from JSON file if it exists.Nrrr u⚠️ Impossibile caricare rU) ospathexistsrurvloadr<rXwarning)r{ryris rload_daily_epgrsk 77>>* % *cG 499Q<5 4 4 6zl"QCHIs4AA AAAA B $BB rcrIci}dD]Z}|j|g}|D]A}|jd}|s||vrg||<||j|jC\g}|jD]\}}|j dt t |D]} || }|jdr| dzt |kr|| dzjdd|d<G tj|d} | td z} | j|d<|D]}|jdd} |jdd} | r| s- tj| } tj| } | |cxkr| krnn|jd d}|r*d |vr&d |jvrd|jvrd}|sY|jdd}|jjddjdd}d|vrd}n|dk(rd}d|d|d <|j|ǐ|j d|S#t$rYwxYw#t$rYJwxYw)zZ Extract currently airing program for each channel from the daily guide database. )rPrQrRrc&|jddS)Nr%r!r3rGs rr+z&get_current_programs..sw!3rr,r&rr%r!rqr0r$zguidatv.sky.itchecksummd5 _+plus sky_sport_25 sky_sport sky_tv8_hdtv8z3https://addictedbytheproject.nl/epg_general/assets/z.pngc&|jddS)Nrr!rrs rr+z&get_current_programs..si(>(B/Dhhy)G..,. ) W % , ,TYY[ 9/*002 3 4s5z"A8D88E?q53u:%"'A,"2"27B"?DK#+#9#9$w-#H!)IA,>!>&,&6&6&8U #D"-Ihhub)GG #11)<!//8|4f4((7B/C/36:SYY[;X]bjmjsjsju]u #xx 26"jjl223<DDS&Q)S0"-C L0"'C*]^a]bbf(gW $++D1=)3n<= Q%F  s%*:IC"I& I#"I#& I32I3ct|dd5}tj||dddddtj d|d t |d y#1swY/xYw) z3Save active EPG list to real-time output JSON file.rprr FrqrrNu 💾 EPG in onda aggiornato in: z (z canali attivi))rurvrwrXrYr`rxs rsave_current_epgrsP k3 1Q $a8 2 KK2;-r#d)O\] 2 1s AA ctjt}|j}tj d|j dtj d|j dt||}t|tt||}t|tjtj dy)zRExecute a single network scrape, then write daily and current EPG files, and exit.u$🚀 Avvio raccolta EPG singola — z%d/%m/%Y %H:%M:%Su📅 Data target: z%d/%m/%Yu*✅ Ciclo singolo completato con successo!N)rnowr8rrXrYrVrlrzDAILY_EPG_FILErrconfig OUTPUT_FILE)rbrtodayrcrs rrun_oncer%s ,,w C HHJE KK6s||DW7X6YZ[ KK$U^^J%?$@AB)(E:J:~.+J<%v'9'9: KK<>rcftjdd} tjt}|j d}||j d|k7rtjd|dtt}||j d|k7r@tjdt||j}t|tntjd t||}t|tjtjd  t'j(d'#t $rtjd Yyt"$r$}tj%d |d Yd}~td}~wwxYw#t $rtjd YywxYw)zPRun EPG bot continuously with daily network scraping and minutely local updates.uC🔄 Modalità continua — Aggiornamento real-time ogni 60 secondiNTrOru+📅 Verifica EPG giornaliero per la data: rSu=📂 File locale assente o scaduto. Avvio scraping di rete...uR📂 EPG giornaliero valido caricato con successo da file locale! (0 chiamate API)u"⏹️ Bot arrestato dall'utente.u!❌ Errore nel ciclo principale: )exc_infouG⏳ In attesa del prossimo minuto per aggiornare i programmi in onda...<)rXrYrrr8rVr3rrrlrrzrrrrKeyboardInterruptr<ratimesleep)rbrcr today_strrris rrun_continuousr6sl KKUVJ  Q,,w'C Z0I!Z^^F%;y%H I)TWXY,N; %)?9)LKK _`!9(CHHJ!OJ":~>KK tu 4JD  -v/A/A B  ]^  JJrNA .!  KK< =  Q LLrs   .. 3::}%JJG, 3::}%JJG, <<  ,, 4 cjj)    8 $ = !!R4:R$s)RRVR[_`d[eRj,D,T,^EECE s td{ LTLLd4jL^^4:^C^?")X!B zFr