Aj UddlZddlZddlZddlZddlZddlmZddlmZe ee jjjdz dz Z dZdZde fd Zd e d eefd Zde d efd Zde fdZdZdefdZd efdZd efdZded eefdZded eefdZde d efdZde ded efdZded eefdZd efdZ ddedee dee deed ef dZ!d eefdZ"ded eefdZ#ded eed eefd!Z$d"ed e%eeffd#Z&d$Z'd%Z(dd&e d'ee d ee fd(Z)d&e d)e d dfd*Z*d e+fd+Z,d,e+d e+fd-Z-ded e+fd.Z.ddd/ded0e+d1e dee d2eed e+f d3Z/d e0efd4Z1de d,e+d dfd5Z2de d dfd6Z3ded efd7Z4dede d efd8Z5d9e+d e0efd:Z6de d;ed efd<Z7d=e d>e d efd?Z8de d@e fdAZ9de d@e d efdBZ:de fdCZ;de d e d efdDZde fdHZ?de dIe d efdJZ@de fdKZAde dLe d efdMZBde fdNZCde dOe d efdPZDde fdQZEde dRe+d efdSZFde fdTZGde dUe+d efdVZHde fdWZIde dXe+d efdYZJde fdZZKde d[e d efd\ZLde fd]ZMde d^e d efd_ZNde fd`ZOde daed efdbZPde fdcZQde dde d efdeZRdfZSdgdhdidjZTd e fdkZUdIe d e fdlZVdme d e fdnZWd efdoZXd efdpZYd efdqZZddmee d e0fdrZ[d e+fdsZ\dtddudvedwee d eefdxZ]dde dIe dye d)ed ef dzZ^da_ee`eead{<d e`efd|Zbd e0efd}Zcd efd~Zdded efdZeded efdZfdZgdaheeead<d efdZid e fdZjd eefdZkd efdZld efdZmded efdZndaoee0e ead<dapee`e ead<daqee0ead<dZrd ee fdZsd e0e fdZtde0e d dfdZud e0e fdZvd e0e fdZwd e d efdZxd e d ee fdZyd e d efdZzde de d efdZ{y)N)Path)Optionaldatabasezozpay.dbcttjjddt dtt j t}t j|_|j}|jd|jd|jDchc]}|d }}d|vr|jdd |vr|jd d |vr|jd d |vr|jdd|vr|jdd|vr|jd|jd|jd|jDchc]}|d }}d|vr|jdd|vr|jd|jd|jd|jd|jd|j|Scc}wcc}w)NT)parentsexist_okz[db_api] opening DB: z CREATE TABLE IF NOT EXISTS accounts ( device TEXT PRIMARY KEY, ip TEXT, port INTEGER, number TEXT, password TEXT, name TEXT, balance REAL, income REAL, outcome REAL, cards TEXT, blocked INTEGER DEFAULT 0 ) zPRAGMA table_info(accounts)blockedz9ALTER TABLE accounts ADD COLUMN blocked INTEGER DEFAULT 0 card_flagsz/ALTER TABLE accounts ADD COLUMN card_flags TEXTtg_idz-ALTER TABLE accounts ADD COLUMN tg_id INTEGER leased_atz.ALTER TABLE accounts ADD COLUMN leased_at REAL lease_pricez0ALTER TABLE accounts ADD COLUMN lease_price REAL blocked_atz/ALTER TABLE accounts ADD COLUMN blocked_at REALz CREATE TABLE IF NOT EXISTS app_users ( tg_id INTEGER PRIMARY KEY, is_admin INTEGER DEFAULT 0, username TEXT, first_name TEXT, seen_at TEXT ) zPRAGMA table_info(app_users) usd_balancez;ALTER TABLE app_users ADD COLUMN usd_balance REAL DEFAULT 0 sms_chat_idz4ALTER TABLE app_users ADD COLUMN sms_chat_id INTEGERzZ CREATE TABLE IF NOT EXISTS app_settings ( key TEXT PRIMARY KEY, value TEXT ) zl CREATE TABLE IF NOT EXISTS panel_workers ( tg_id INTEGER PRIMARY KEY, added_at REAL NOT NULL ) z` CREATE TABLE IF NOT EXISTS ip_bans ( ip TEXT PRIMARY KEY, added_at REAL NOT NULL ) z CREATE TABLE IF NOT EXISTS balance_ops ( id INTEGER PRIMARY KEY AUTOINCREMENT, tg_id INTEGER NOT NULL, amount REAL NOT NULL, reason TEXT NOT NULL, device TEXT, admin_id INTEGER, created_at REAL NOT NULL ) ) rDB_PATHparentmkdirprintsqlite3connectRow row_factorycursorexecutefetchallcommit)conncurrowcols user_colss ,/var/www/oz-panel.ru/ozpay-pub/api/db_api.pyget_connr$sgD48 wi() KK {{}" *+<<>*CQ** T++IJ++?@ 4++=>t++>?++@A++?@  +, #  /c!f / /"++KL"++DE   I +20s / G=/ Hct}|j}|jd|j|j y)Nz CREATE TABLE IF NOT EXISTS accounts ( device TEXT PRIMARY KEY, ip TEXT, port INTEGER, number TEXT, password TEXT, name TEXT, balance REAL, income REAL, outcome REAL, cards TEXT ) )r$rrrclose)rrs r#init_dbr'os9  {{}  devicec tt}|j}|jd||j d|j d|j d|j d|j d|j d|j d|j d |j d f |j |j y ) z=Create a device row. Pass any of the columns as keyword args.z}INSERT INTO accounts (device, ip, port, number, password, name, balance, income, outcome, cards) VALUES (?,?,?,?,?,?,?,?,?,?)ipportnumberpasswordnamebalanceincomeoutcomecardsN)r'r$rrgetrr&)r)fieldsrrs r# create_devicer6s  {{}B  ::d ::f ::h ::j ::f ::i ::h ::i ::g r(r+returnc |r|dvry t|}t}|j }|j d||f|j }|j|syt|S#ttf$rYywxYw)NNz0SELECT * FROM accounts WHERE ip = ? AND port = ?) int TypeError ValueErrorr$rrfetchoner&dict)r+r,rrr s r#find_device_by_ip_portr@s dj  T$   {{} ?"dL ||~  S  J s A00BBct}|j}|jd|f|j|j}|j |dkDS)Nz%DELETE FROM accounts WHERE device = ?rr$rrrrowcountr&)r)rrchangeds r# delete_devicerEsJ  {{} 4vi@ <<! r(ct}|j}|jd|f|j}|j |syt |S)Nz'SELECT * FROM accounts WHERE device = ?)r$rrr>r&r?)r)rrr s r# get_devicerGsI  {{} 6 B ||~  S r(ct}|j}|jd|j}|j |Dcgc] }t |c}Scc}w)NzSELECT * FROM accounts)r$rrrr&r?)rrrowsrs r# list_devicesrKsM  {{} %& QasA%r ct}|j}|jdt|f|j }|j |Dcgc] }t |c}Scc}w)Nz&SELECT * FROM accounts WHERE tg_id = ?)r$rrr;rr&r?)r rrrIrJs r#list_devices_by_tgrMsU  {{} 5E }E QasA0c|duxs:t|jdk(xst|jdk(S)Nr:0)strstripvalues r# _is_blankrTs:  NU))+r1NSZ5E5E5G35NNr(ct}|j}|jd|jd}|j t |S)Nzv SELECT COUNT(*) FROM accounts WHERE (number IS NULL OR TRIM(number) = '') AND (tg_id IS NULL OR tg_id = 0) rr$rrr>r&r;rrns r#count_free_slotsrYsI  {{} \\^A Ar(ct}|j}|jdt|f|j }|j |syt |S)Nzx SELECT * FROM accounts WHERE tg_id = ? AND (number IS NULL OR TRIM(number) = '') ORDER BY device LIMIT 1 r$rrr;r>r&r?r rrr s r#find_unlinked_ownedr]sV  {{}u:-  ||~  S r(ct|}t|}|r|St}d} |j}|j d|j d|j }|s"|j  |jy|d}|j d||f|j |j|r t|SdS#t$r|j wxYw#|jwxYw)unЗанять свободный слот под пользователя. Атомарно, без гонки.NBEGIN IMMEDIATEz SELECT device FROM accounts WHERE (number IS NULL OR TRIM(number) = '') AND (tg_id IS NULL OR tg_id = 0) ORDER BY device LIMIT 1 r)z.UPDATE accounts SET tg_id = ? WHERE device = ?) r;r]r$rrr>rollbackr&r ExceptionrG)r ownedrr)rr s r#claim_free_devicercs U U # ,   #++ ++ # ==? **, x=&++>P++- **,$ 6.$. --/**,sAC)CC22C55Dcpt|}|syt|jdsyt|ddiS)udСнять владельца, если ЛК ещё не привязан (отмена входа).Fr-r N)rGrTr4 update_device)r)r s r#release_device_ownerrf s7& #''(#$ fwo..r(c0t|dt|iS)Nr )rer;)r)r s r#bind_device_ownerrh*sfwE 344r(ct}|j}|jdt|f|j }|j |syt |S)N'SELECT * FROM app_users WHERE tg_id = ?r[r\s r# get_app_userrk.sM  {{} 6U F ||~  S r(ct}|j}|jd|jd}|j t |S)Nz1SELECT COUNT(*) FROM app_users WHERE is_admin = 1rrVrWs r# count_adminsrm9sC  {{} @A\\^A Ar(username first_nameis_admincddlm}m}t|}t}|j }|j d|f|j }|j|jj} |r#|d} |durd} |j d||| | |fn|rdnd} |j d|| ||| f|j|jt|S) Nr)datetimetimezonerjrpTr z UPDATE app_users SET username = COALESCE(?, username), first_name = COALESCE(?, first_name), is_admin = ?, seen_at = ? WHERE tg_id = ? zh INSERT INTO app_users (tg_id, is_admin, username, first_name, seen_at) VALUES (?, ?, ?, ?, ?) ) rrrsr;r$rrr>nowutc isoformatrr&rk) r rnrorprrrsrrexistingrt admin_vals r#upsert_app_userryBs ) U  {{} 6A LLN||HLL!++- z") 9++ j)S%0 a)++ 9h C0 Ur(c|dvry tt|j}|dk(ry|S#ttf$rYywxYw)N)Nr:rrOr)r;rPrQr<r=)rSchat_ids r#parse_sms_chat_idr|msT   E   " #' qL  J s"1AAcdtt|}|syt|jdS)Nr)rkr;r|r4r r s r#get_sms_chat_idrys*CJ #''-011r(r{ct|}t|t|}||k(rd}t}|j }|j d||f|j |j|S)Nz4UPDATE app_users SET sms_chat_id = ? WHERE tg_id = ?)r;ryr|r$rrrr&)r r{parsedrrs r#set_sms_chat_idrse U G $ eO &  {{} Cfe_Ur( owner_tg_idcBt|}t|}||dfS|dfS)NFT)r;r)rownercustoms r#resolve_sms_destinationrs/ [  %  N  r(slot_price_usdg4@keydefaultct}|j}|jdt|f|j }|j |r|d|St|dSNz,SELECT value FROM app_settings WHERE key = ?r)r$rrrPr>r&)rrrrr s r#get_app_settingrs[  {{} ;c#h[I ||~ s1v~ . CF r(rSct}|j}|jdt|t|f|j |j y)NiINSERT INTO app_settings (key, value) VALUES (?, ?) ON CONFLICT(key) DO UPDATE SET value = excluded.value)r$rrrPrr&)rrSrrs r#set_app_settingrsG  {{}ms8SZr(ctt}|dvrtS tt |j ddj dd}tdt|dS#t tf$r tcYSwxYw)Nr9,. r:) rSLOT_PRICE_KEYDEFAULT_SLOT_PRICEfloatrPreplacer<r=maxround)rawprices r#get_slot_pricersx~&:  C  c*223; <% Cua!! J s4A%%A=<A=rctt|d}|dkr tdttt ||S)Nrru<Цена не может быть отрицательной)rrr=rrrP)rrSs r#set_slot_pricers8 uU|Q  AIQRRU, r(ctt|}|sy tt|j dxsddS#t t f$rYywxYw)Nrrrr)rkr;rrr4r<r=r~s r#get_usd_balancersRCJ  uSWW]+0q11 55 J  s'AAA)r)admin_idamountreasonrc t|}tt|d}|dk(r t|St |t } |j }|jd|jd|f|j}d}|r|ddvr t|d}t||zd} | dkr|jtd|jd | |f|jd ||t|xsd dd ||tjf|j |j!| S#ttf$rd}YwxYw#t$r|jwxYw#|j!wxYw) Nrrr_1SELECT usd_balance FROM app_users WHERE tg_id = ?rr9g-C6u'Недостаточно средств4UPDATE app_users SET usd_balance = ? WHERE tg_id = ?zr INSERT INTO balance_ops (tg_id, amount, reason, device, admin_id, created_at) VALUES (?, ?, ?, ?, ?, ?) r:()r;rrrryr$rrr>r<r=r`rPtimerrar&) r rrr)rrrr current new_balances r#adjust_usd_balancersy U f q ! aK    #++ ++AE8L # 'SV: %CFmGg&*+7==? = >>++D{TYFZ[++ 63v|$Sb)68TYY[I ++- **,) j !G --/**,s>AEE%B EEEEEE77E::F ct}|j}|jd|jDcgc] }t |}}|j |Scc}w)Nzq SELECT tg_id, username, first_name, is_admin, usd_balance, seen_at FROM app_users ORDER BY seen_at DESC )r$rrrr?r&)rrr rIs r#list_app_usersrsW  {{}"lln-sc--  .sA$c lt|tjtt|ddy)Nrr r)rerrr)r)rs r#_mark_device_leasedr s#vTYY[uU|UVAWXYr(cdt|}|sy t|jdxsd} t |jdxsd}|r%|dkDr |jdrt ||d|t|dddy#ttf$rd}YiwxYw#ttf$rd}YawxYw) Nr rrrr refundrr)r)rGr;r4r<r=rrre)r)r r rs r#refund_client_leasers&  cggg#! $%  &+! ,% eaiCGGK0UE(6BvT$?@ J %  J %s"BBBBB/.B/c t|}t}t|t}d} |j }|j d|j d|f|j }|r0|dr+|jt||jS|j d|f|j }d}|r|ddvr t|d}|r|d}nC|j d |j }|s|jtd |d}|dkDr,|d z|kr$|jtd |d d|d d|dkDrt||z dn t|d} |dkDr?|j d| |f|j d|| d|dtjf|j d|tj||f|j |jt#|} | s td | S#ttf$rd}YWwxYw#t $r|jwxYw#|jwxYw)Nr_z~ SELECT * FROM accounts WHERE tg_id = ? AND (number IS NULL OR TRIM(number) = '') ORDER BY device LIMIT 1 r rrrr9r)z SELECT device FROM accounts WHERE (number IS NULL OR TRIM(number) = '') AND (tg_id IS NULL OR tg_id = 0) ORDER BY device LIMIT 1 u&Нет свободных слотовg-C6?4Недостаточно средств. Нужно .2f $, на балансе  $rrzu INSERT INTO balance_ops (tg_id, amount, reason, device, admin_id, created_at) VALUES (?, ?, ?, ?, ?, ?) rentzNUPDATE accounts SET tg_id = ?, leased_at = ?, lease_price = ? WHERE device = ?)r;rryr$rrr>rr?r&rr<r=r`rrrarG) r rrr)rrbbal_rowr0freerr s r#start_client_leaserse U    @ #++ ++ 8  ,,.% u[!;;= u+`**,_++AE8L LLN' ' :-GAJG (O6;; ,,.4 MMO = >> N6 QY7V#e+==? J5QT+Umnuvymzz|} ~~-2QYgoq)E'1t|}|s td|jdr|St}|dkDr t t || d|t||t|xs|S#t$r#}td|ddt |dd |d}~wwxYw) Nu(Устройство не найденоr rrrrrrr)rGr=r4rrr;rr)r r)r rexcs r#ensure_client_leaserls& =>>GGK *   AIc%j5&G VU#6!c!  :5+E]^mns^tux]yy{|  sA00 B9BB after_secondsctjt|z }t}|j}|j d|f|j Dcgc] }t |}}|j|Scc}w)Nz SELECT * FROM accounts WHERE blocked = 1 AND leased_at IS NOT NULL AND blocked_at IS NOT NULL AND blocked_at <= ? AND number IS NOT NULL AND TRIM(number) != '' ORDER BY blocked_at )rrr$rrrr?r&)rcutoffrrr rIs r#list_lock_logout_duer~ss ))+m, ,  {{} ) "lln-sc--  .s Bdatacgd}g}g}|jD]/\}}||vs |j|d|j|1|sy|j|t}|j}|j ddj |d||j |j} |j| dkDS)z=Generic update by device. `data` keys should be column names.)r+r,r-r.r/r0r1r2r3r r r r rrz = ?FUPDATE accounts SET z, z WHERE device = ?r) itemsappendr$rrjoinrrCr&) r)rallowed set_partsparamskvrrrDs r#reres m   ZZ\TQ'\ qcJ ==  v  {{}#DIIi$8#99J KVT <<! r(oldnewcx|xsdj}|xsdj}|r|r||k(ryt}|j} |jd||f|j |j }|j|dkDS#t j$r|jYywxYw)Nr:Fz/UPDATE accounts SET device = ? WHERE device = ?r) rQr$rrrrCrIntegrityErrorr&)rrrrrDs r# rename_devicers r r 3#*   {{}++?#sL++- LL'!  **, s0B#B98B9fieldct}|j}|jd|d|f|j}|j |sy|dS)NzSELECT z FROM accounts WHERE device = ?r)r$rrr>r&)r)rrrr s r# _get_fieldrsQ  {{}wug< =yI ||~  Ar(ct}|j}|jd|d||f|j|j}|j |dkDS)Nrz = ? WHERE device = ?rrB)r)rrSrrrDs r# _update_fieldrsV  {{}#E7*? @5&/R <<! r(ct|dSNr+rr)s r#get_iprs64  r(ct|d|Srr)r)r+s r# update_iprsfdB''r(ct|dSNr,rrs r#get_portr66""r(r,ct|d|Srr)r)r,s r# update_portrffd++r(ct|dSNr-rrs r# get_numberr68$$r(r-ct|d|Srr)r)r-s r# update_numberrfh//r(ct|SN)rrs r# get_phoners 6r(phonect||Sr)r)r)rs r# update_phonersfe$$r(ct|dSNr/rrs r#get_namerrr(r/ct|d|Srr)r)r/s r# update_namerrr(ct|dSNr0rrs r# get_balancer69%%r(r0ct|d|Srr)r)r0s r#update_balancerfi11r(ct|dSNr1rrs r# get_incomerrr(r1ct|d|Srr)r)r1s r# update_incomer  rr(ct|dSNr2rrs r# get_outcomer rr(r2ct|d|Sr r)r)r2s r#update_outcomerrr(ct|dSNr3rrs r# get_cardsrs67##r(r3ct|d|Srr)r)r3s r# update_cardsrsfgu--r(ct|dSNr rrs r#get_card_flagsr"s6<((r(r ct|d|Srr)r)r s r#update_card_flagsr&sflJ77r(ct|dS)Nr rrs r# get_blockedr+rr(r ctt|}t|}|sytt|jd}d|i}|r|st j|d<n|sd|d<t ||S)NFr r)r;boolrGr4rre)r)r r waspayloads r#update_blockedr/sq tG} &  4 " #$ w  C))+', ',fg&&r(ct|dSNr.rrs r# get_passwordr">s6:&&r(r.ct|d|Sr!r)r)r.s r#update_passwordr$Bsfj(33r()beelineyapaymtsr&r%r')uяuбuмcJtjddt|xsdS)Nz\Dr:)resubrPrRs r# _card_digitsr+Js ub#ekr*++r(c t|s|xsdSdjfdtdtdDS)Nr:rc3.K|] }||dzyw)N).0idigitss r# z&_format_card_number..RsCQ!a%Csrr.)r+rrangelen)r-r2s @r#_format_card_numberr6Ns< v  2 C%3v;*BCCCr(rc6|xsdj}|sytjd|rt|dkDr|ddS|St |}t|dk(r>|ddj rt |ddnd}d|cxkrdkrny|ddd |ddSy) Nr:z(0[1-9]|1[0-2])/\d{2}(?:\d{2})?r.rrr /)rQr) fullmatchr5r+isdigitr;)rtextr2months r#_format_expiryr?Us  LL3T:Y]bq,, t K1#BQZ//1#fRaj/q%%2 BQZL&* && r(c6tDcic]}|dc}Scc}wNF)CARD_FLAG_KEYS)rs r# _empty_flagsrCcs-.e...s c t|ts tStDcic]}|t |j |c}Scc}wr) isinstancer?rCrBrr4)rSrs r#_flags_from_valuerFgs:5$ .<=sd599S>" "===s"Ac<|siSt|tr|}n tj|}t|tsiSi}|jD]!\}}t|}|st|||<#|S#tt tj f$ricYSwxYwr) rEr?jsonloadsr<r=JSONDecodeErrorrr+rF)rrflagsrrSr2s r#parse_card_flagsrLms )sD $ **S/4 4 ) ::<+ZS%  &  #E*%- +  Z!5!5 6 9 sA88 BBc t|}|sgSg}t|jdD]}|j}|s|jd}|r|dnd}t |dkDr|dnd}t |dkDr|dnd}t |} t |} | r | | ddk(rd} n t |} |j| xs t} t|| |d } | j| |j| |S) uicards в БД: number/expiry/cvv, карты через ':'. Старый формат: number/last4/cvv.:r:rr:r rN)r-expirycvv) rLrPsplitrQr5r+r?r4rCr6updater)r flags_raw flags_mapr3chunkpartsr-middlerQ number_digits middle_digitsrPrKcards r# parse_cardsr\s  i ( ) #hnnS!U ++-%  ++c %58"&5zA~582&JNa#v&-v&-} bc(:: 6 6 "6 -- & 8,.%  (   $ ++e,,t+, r(c6||dk(ryt|ttfr t|St|j ddj ddj dd}t j dd|} |r t|SdS#t$rYywxYw)Nr:r rrrz[^\d.])rEr;rrPrr)r*r=)rSr=s r# _to_balancer_s MUb[ usEl# u E 63'//R8@@cJ y"d# t%#%  s= B B BBT)smallersystemr`rac | |tvryg}tD]}|jdrt|jd}|jdxsd}t |jd|jdD]}t |jd}|s |r|j|r4|j ||jd xsdj||jdxsd||jd xsd|jd xsd|d |sy|jd | |dS)uКарта со всей панели: min/max баланс аккаунта, без галочки выбранной системы.Nr r0r)r:r3r r-r/rPrQ)r)r/r0r-rYrPrQrac|d|d|dfS)Nr0r)rYr/)items r#zpick_card..sDOT(^T/5JKr()rreverser) rBrKr4r_r\r+rrQsort)r`ra candidatesr r0 device_idr[rYs r# pick_cardrjsF 67  NSWWY  * +'ggh%2)#'''*CGGL,ABd 23=   &!   WWV_ " ) ) +hhx &B"hhx &B 88E? b    *   K+ 1 r(flagcz|tvryt|}|syt|jd}t |}|sy|j|xs t t ||<tfdtDr||<n|j|dt|tj|dS)NFr c3@K|]}j|ywr)r4)r0rrs r#r3z set_card_flag..s3S C3s ensure_ascii) rBrGrLr4r+rCranypoprrHdumps)r)r-rkrSr rKr2rs @r# set_card_flagrss &  #'',/ 0 v   99V  . e3N33%-))FD&$**U"GHHr(_panel_workers_cachec4t}|j}|jdt}|j D](}|r|d |j t |d*|j|a |S#ttf$rYPwxYw)NzSELECT tg_id FROM panel_workersr) r$rrsetraddr;r<r=r&rt)rridsr s r#_load_panel_workersrys  {{} ./ u LLN S A  773s1v;    Z    sBBBc@t tttSr)rtrysortedr/r(r#list_panel_workersr|s #$$r(ct t|}t t |tvS#ttf$rYywxYwrA)r;r<r=rtry)r uids r#is_panel_workerrsC E #  ### J s %77c^ t|}|dkryt}|j }|j d|t j f|j|jt tytj|y#ttf$rYywxYw)NFrzCINSERT OR IGNORE INTO panel_workers (tg_id, added_at) VALUES (?, ?)T) r;r<r=r$rrrrr&rtryrw)r r~rrs r#add_panel_workerr s E #1H   {{}G   3 # J s BB,+B,cN t|}t}|j }|j d|f|j |jdkD}|jt t|Stj||S#ttf$rYywxYw)NFz)DELETE FROM panel_workers WHERE tg_id = ?r) r;r<r=r$rrrrCr&rtrydiscard)r r~rrrDs r#remove_panel_workerr"s E #   {{} 83&A <r&r)rrr rs r#get_watch_settingsrs DJJ|, --  {{} ;>P=RS ||~c!f6 4::d#$$r(rct}t|tsi}d|vr|dn|dd|vr|dn|dd|vr|dn|dd|vr|dn|dd}t|}t }|j }|j dttj|df|j|j|a tjtj|S) NrrrrrrFrn)rrEr?rr$rrrrHrrrr&rrI)rrmergedrrrs r#save_watch_settingsrs  7D! '#,#7WY WY=O%/7%:gj! @S&'177 ww7G/>'/I7?+wWfOg   f%  {{}mtzz$U;< 4::d#$$r(_ip_bans_cache _ip_ban_exact _ip_ban_netsict|xsdj}|sy|jddk(rd|vr|jdd} d|vr2t j |d}|j dk7ryt|St j|}|j dk7ryt|S#t$rYywxYw) Nr:rrr:Fstrictr.) rPrQcountr ipaddress ip_networkversion ip_addressr=)rSr=netaddrs r#normalize_ip_banrs EKR  JJsOqS_ c3 $ D[   d5 13 kkQ  c(?   d #$ \\Q  T s$ *B27 B2$B2' B22 B>=B>cHt|xsd}g}t}tjd|D]m}|j j d}|s%t |}|r||vr7|j ||j|t|tk\sl|S|S)Nr:z[\s;]+r) rPrvr)rRrQrrwrr5 MAX_IP_BANS)rr=foundrpartr+s r#parse_ip_ban_inputsrs CI2% XXi &  T   C $  " rTz ((2,,,rZ;    r(ipsct|at}g}|D]?}d|vr( |jt j |d/|j|A|a|a y#t $rYRwxYw)Nr:Fr) listrrvrrrr=rwrr)rexactnetsrds r#_set_ip_ban_cachersxs)5  TD[ KK $$T%89 99T?    s&A!! A-,A-ct}|j}|jdg}|jD],}|r|ds t |d}|s|j |.|j t||S)Nz"SELECT ip FROM ip_bans ORDER BY ipr)r$rrrrrr&r)rrrr r+s r# _load_ip_bansrs{  {{} 12  LLNS CF A"::b>  3 r(c@t tttSr)rrrr/r(r# list_ip_bansrs/ ^r(czt|xsdj}|jdr|dd}dt|} t j |xs|jdk7ryt tttxsdvrytfdtxsdDS#t $rYywxYw) Nr:z::ffff:Fr.r/Tc3&K|]}|v ywrr/)r0rrs r#r3zis_ip_banned..s 8CDCK 8s) rPrQ startswithrrrr=rrrrrpr)r+ candidate normalizedrs @r# is_ip_bannedrs r] " #m) y)   j5I 6$ LLA /I-%2&  8L$6B 888  sB.. B:9B:ct|}|syt}||vrt|tk\ryt }|j }|j d|tjf|j|jt t|S|tvrtt|gz}t||S)Nz:INSERT OR IGNORE INTO ip_bans (ip, added_at) VALUES (?, ?))rrr5rr$rrrrr&rrr{r)r+rrrrupdateds r# add_ip_banrsr" >g#g,+"=   {{}> tyy{/ & >ZL0 1'Gr(cRt|}|syt}|j}|jd|f|j |j dkD}|j t t|S|r#ttDcgc] }||k7s | c}|Scc}w)NFz DELETE FROM ip_bans WHERE ip = ?r) rr$rrrrCr&rrr)r+rrrrDrds r# remove_ip_banr,sr"   {{} /*? <ss 9 %d    f %$D[ )&&tE: :: Td  s1A A A)(A))NNNr)T)|rrHr)rrpathlibrtypingrrP__file__resolverrr$r'r6r?r@rrErGrKr;rMrTrYr]rcrfrhrkrmryr|rrtuplerrrrrrrrrrrrrrrrrrerrrrrrrrrrrrrrrrr r rrrrrrrr"r$rB SYSTEM_BY_ARGr+r6r?rCrFrLr\r_rjrsrtrv__annotations__ryr|rrrrrrrrrrrrrrrrrrrrrrrrr/r(r#rs   d8n$$&--44zAJN O] @.#0sXd^"#$s  c OO # sx~( /S /Xd^ /F///5c5#5$5c ! ( ( C=(c]( D> (  (V  2328C=2 3 # 8C= sDy1A"x} ST""%E 3 5  + + + + # + C= + +\  T  ZZEZdZAAA"J cJ dJ Z"s"C"D"$  $t* *#Td*s*s3#cT!3!(c(s(t( #S#,,3,4, %s%0#0s0t0c%%S%T% #S#,,3,4, &&232242 %s%0#0u00 &&232242 $c$..S.T.)3)8c8s8t8 && '3 ' ' '''4C43444-iu= ,3,DDD      /d/>> T*Xc]t>  %  "&t $ x} QU FI#IsI#IdIdI&,0hs3x(/ SX $%DI%$d$ C D .st&%# htn#+s+ FHTN F. $. b %D %%%$%0'+c#*$( xC!(# htn# x}(S $49"  tCy  d3i9S9T9(38C=0cd$ # # $ r(