@j6UdZddlmZddlZddlZddlZddlZddlZddlZ ddl m Z m Z ddl m Z dZdZdZd Zd Zd Zd Zd ZdZej.Zdaded<daddZddZdddZddZddZ ddZ!dd dZ"y)!zLocal utility outage providers for the NWAL Scanner platform. Normalizes Florence Electricity and Sheffield Utilities into the county-shaped JSON payload expected by the existing broadcast display. ) annotationsN)datetimetimezone)Anyz5http://68.208.116.30:7576/data/outageSummary.json?v=2zAhttps://ebill.sheffieldutils.org/maps/Outage_Web_Map/maps/GWT.rpcz https://ebill.sheffieldutils.orgz5https://ebill.sheffieldutils.org/maps/Outage_Web_Map/z:https://ebill.sheffieldutils.org/maps/Outage_Web_Map/maps/ 1D9BF682AF8D25FA7709856C83E9910Fz7|0|4|https://ebill.sheffieldutils.org/maps/Outage_Web_Map/maps/|612278413EC26C34D54A3907AA0CDFD8|coop.nisc.oms.webmap.services.RpcCombinedOutageDetailsService|getCombinedOutageDetails|1|2|3|4|0|<izdict[str, Any] | None_cachegctjtjj j ddS)N+00:00Z)rnowrutc isoformatreplace0/opt/nwal-platform/app/current/outage_sources.py _utc_now_isor(s+ << % / / 1 9 9(C HHrc |sy tjt|jdd}|j |jt j }tdttjt j |jt j z jS#t$rYywxYw)Nr r )tzinfor) r fromisoformatstrrrrrmaxintr astimezone total_seconds Exception)valuedts r_parse_iso_age_secondsr ,s   # #CJ$6$6sH$E F 99 8<<0B1c8<< 5 hll8SSbbdeff sB=C CCctj}tjj |||5}|j cdddS#1swYyxYw)N)timeoutcontext)sslcreate_default_contexturllibrequesturlopenread)r'r"r#responses r _fetch_bytesr+8sI((*G   '  Jh}}s AActjjtdddddd}t |}t j |jd}t|jdxsd }t|jd xsd }|jd xs|jd xs t}t|}d dd||t|jdxs |d kDrdnd |ddt|duxr |tkD||jd|jd|jddd S)Nz!application/json, text/plain, */*no-cachezhttp://68.208.116.30:7576/z/NWALScannerPlatform/018 (+local outage adapter))Accept Cache-ControlPragmaReferer User-Agent)headers utf-8-sigcustomersOutNowrcustomersServed updateTime lastUpdated01077 LauderdaleAL outageCountFlorence Electricityz!Florence Electricity service areacustomersAffectedcustomersRestoredstreetsAffected)r?r@rA) US_Full_FIPS CountyName StateAbbrCustomersTracked CustomersOut OutageEventsLastUpdatedDateTime ProviderName ProviderArea SourceURLStale AgeSeconds RawSummary) r&r'Request FLORENCE_URLr+jsonloadsdecodergetrr STALE_AFTER_SECONDS)r'rawpayload customers_outcustomers_servedupdatedages rfetch_florencer\>s>nn$$9' 3K  % G w CjjK01G $56;!Q?kk,'W7;;}+EWG  )C ",%GKK 6Y PQ@Q1WXZ&.;!D>S+>%>!(-@!A!(-@!A&{{+<=  rc |jds tdtj|dd}t |t r!t |dkst |dt s td|dd}|d}|Dcgc]*}t |trtjd|r|,}}g}g}tdtdt |dz D]} ||d z||d z||d z||dzf\} } } } t | ttfrtt| d kDr| d k(rt | ttfrytt| d kDrb| d k(r]||dz} t | trEd| cxkrdkr:nn7|j| |jt| t| dg}g}t%}t'||D]G\} }|d|df}||vr|j)||j| |j|It+dt-|Dd}t+dt-|Dd}t+dt-|Dd}t-|Dcic]1\}}t |trtjd|r|d z|3}}}i}i}||rt-|D]\}}||vr |d zt |k\r| ||d z|k7r+| ||d z|k7r9||}d}d}|dk\rU||d z |k(rJ||d z }t |tr|dk\r|}||d z |k(r]||dz }t |trE|dk\r@|}n=|d k\r8||d z | k(r,d}||d z |k(r||d z }t |tr|dk\r|}||||<||||<|rt/|j1nd}||} d}!n|r|st |} d}!n t/|} d}!| tt |t |||||||!dScc}w#t t"tf$rYlwxYwcc}}w)Nz//OKz(Sheffield returned a non-OK GWT responsez'Unexpected Sheffield GWT response shapez\d{6,}r r=i7 i@B)xyrerfc3nK|]-\}}t|tr|jdr|dz/yw)zjava.lang.Integer/r=N isinstancer startswith.0iitems r z-_decode_sheffield_response..s7\'!T%dC0T__EY5ZA\35c3nK|]-\}}t|tr|jdr|dz/yw)z+cc.nisc.oms.clientandserver.v2.pojo.Region/r=Nrhrks rroz-_decode_sheffield_response..s7zwq$ *4 5$//Jw:xUzrpc36K|]\}}|dk(r|dzyw)zZip Code Regionsr=Nrrks rroz-_decode_sheffield_response..s(;ga#'99E;sz\d{5}zcustomers-summary-by-zipzevent-count-fallbackzdecoded-marker-counts-fallback)rX outage_events outage_idscustomer_counts zip_outageszip_customers_served coordinates parse_quality)rj ValueErrorrQrRrilistlenrre fullmatchrangerrfloatabsappend IndexError TypeErrorsetzipaddnext enumeratesumvalues)"textstreamrstringsrnrtrurxrmrex_typerfy_typecount dedup_counts dedup_coords seen_coordscoordkey integer_refregion_class_refregion_name_refzip_refsrvrwrzip_code outage_count served_count possible_outpossible_served summary_totalrXrys" r_decode_sheffield_responserfs ??6 "CDD ZZQR !F fd #s6{QjPRUY>ZBCC CR[FRjG ! dC R\\)T%B J"$O*,K 1c!S[2-. / #)!a%=&Q-APVWX[\W\P]#] Avq&1sEl+E!H 0FbLq3,/CaMF4JbLq1u eS)a5.EI.E#**51&&U1XE!H'EF"!L+-L,/EKO[9# uSz5:& +  E"E" #(\Yw-?\]acKz)G2Dz{A;71C;<@BO+4W+=K4dC(R\\(D-IAt KHK#%K+-8!&)# >HAuH$1uF #*va!e}/O+q1u AQ0QHLLAv&Q-;6%a!e} lC0\Q5F#/L!a%=K/&,QUmO!/37OqJ2=C **,-$M  % 2 LJ . L) 8 'S_c,.?@ '" 4#&  i2Iz2   BKs?/P&C$P+6Q+QQc tjjttj ddddddt tdttdd }t|d }|jd d }t|}t}idddddddddt|ddt|dd|ddddd td!d"d#dd$|d%d&|d'd(|d)d*|jd+id,|jd-iS).Nzutf-8POSTz*/*r-ztext/x-gwt-rpc; charset=UTF-8z#Mozilla/5.0 NWALScannerPlatform/018mv) r.r/r0z Content-TypeOriginr1r2zX-GWT-Module-BasezX-GWT-Permutationz!coop.nisc.outagewebmap.configName)datamethodr3 )r"r4r)errorsrB01033rCColbertrDr;rErrFrXrGrsrHrISheffield UtilitiesrJz)Sheffield Utilities electric service arearKrLFrM ParseQualityry OutageIDsrtCustomerCountsru ZipOutagesrvZipCustomersServedrw)r&r'rO SHEFFIELD_URLSHEFFIELD_BODYencodeSHEFFIELD_ORIGINSHEFFIELD_REFERERSHEFFIELD_MODULE_BASESHEFFIELD_PERMUTATIONr+rSrrrrT)r'rVrdecodedrZs rfetch_sheffieldrsnn$$  " "7 +' ;&(?!6!615  %G" w +C ::k): 4D(.GnG  i  T  A   GO45   GO45   w  -  C  ]    a  0  W\*  '"34  gkk-4! " gkk*@"E# rc tj}t5|s.t(|tz tkrt tcdddSt}dddg}g}dt fdtffD]}\}} |}|j||j|d|jdd|jdd|jdt|jdd rt|jdtrb|D chc]} | jd} } |dD]<} | jd| vst | } d| d<d| d<|j| >ddd|j!fdt|dt#||t%d|Dt%d|Dd} t5| atjadddt | S#1swYxYw#t$r<}|j|d t|d td |d |dYd}~d}~wwxYwcc} w#1swYt | SxYw)Nr>rTrFrrGrHrL)providerok customersOut outageEventsrZstaleF)rrerrorz [OUTAGES] z fetch failed: )flushcountiesrIFallbackr=)r9rcZjt|jdddS)NrBc)rTr)corders rz#get_local_outages..Os" #aeeNB.G*H" Mr)rzlocal-utility-aggregatorc3XK|]"}t|jdxsd$yw)rFrNrrTrlrs rroz$get_local_outages..W# SQQUU>%:%?a!@ S(*c3XK|]"}t|jdxsd$yw)rGrNrrs rroz$get_local_outages..Xrr)successsource generatedAtr providerstotalCustomersOuttotalOutageEvents)time _cache_lockr _cache_time CACHE_SECONDSdictr\rrrTboolrrprintrir{sortrr)forcer previousrprovider_status provider_namefetchercountyexcr current_namesoldfallbackresultrs @rget_local_outagesrs^ ))+C +k0AM0Q< &(H,.O 0 0#P w PYF OOF #  " ") & >1 = & >1 =!::&;<fjj12 $ P4Jx||J7>8@A1~.A AJ' *Cww~&m;9$(!'+$)  *! $E MMMMN>,#~$ S( SS S( SSF "iik " <w. P  " ")S$  J}o_SEB$ O O  PB*" <s<'G7 G76A7HI  I7H I  1II I$)returnr)rrrz int | None)r`)r'zurllib.request.Requestr"rrbytes)rdict[str, Any])rrrr)F)rrrr)#__doc__ __future__rrQr}r$ threadingrurllib.requestr&rrtypingrrPrrrrrrrrULockrr __annotations__rrr r+r\rrrrrrrs #  'F S 5KT:* inn $$ I  %PJZ)X?r