֦i d dl Z d dlZd dlZd dlZd dlZd dlZ d dlZdZd dl m
Z d dlm Z g dZ
ej ed d Z G d
d e Z G d d
e Z G d de Z G d de Z G d de Z G d de ZdZdZh dZg dZddd Z d Z ej< d g d Z ej< d g d! Z d" Z
d# Z!dVd$Z"dVd%Z#dWd&Z$erd' Z% G d( d) Z&er G d* d+e& Z'e
jQ d+ ed,k( rd dl)Z) e)jT d-. Z+e+jY d/d0d1d23 e+jY d4d5d6d73 e+jY d8d9d:e-d;ed e+jY d?d@dAe-dB> e+jY dCdDdEddFG e+j] Z/e/j` Z0e/j s e0d:k( reZ0 e&e/jb e0H Z2ne0d:k( reZ0 e'e/jb e0H Z2e2jg Z4dIe4v re2jk e2jm e/jl \ Z7Z8Z9Z:Z; e e-e: e/j~ z
dOz Z9e2j e9e: \ Z7ZAeAD ]a \ ZBZC e
eCdP j dQdO d ZE e
eCdR ZF e-eCd ZG e 100101211215220221222224225230231282)subjectfromdatez
message-id
references:bytes:linesr5 r6 )byteslines
GroupInfo)grouplastfirstflag ArticleInfo)number
message_idr8 c g }t | D ]K \ }}t |t r%|j |j |xs d ;|j | M dj | S )Nascii )_email_decode_header
isinstancer7 appenddecodejoin)
header_strpartsvencs r r r s^ @ E&z23 a LL#.1 2 LLO 3
775>r c g }| D ]t }|d dk( r |dd j d \ }}}d|z }n|j d \ }}}|j }t j || }|j | v t
}t
| t
| k r t d |d t
| |k7 r t d |S )Nr : z$LIST OVERVIEW.FMT response too shortz*LIST OVERVIEW.FMT redefines default fields) partitionlower_OVERVIEW_FMT_ALTERNATIVESgetrG _DEFAULT_OVERVIEW_FMTlenr )r8 fmtlinename_suffixdefaultss r _parse_overview_fmtr] s $
C 7c> "12h 0 0 5OD!V:D #nnS 1OD!Vzz|)--dD9
4 %H
3x#h- BCC
>CMh& HII Jr c t t }g }| D ] }i }|j d ^}}t | }t | D ]| \ } }
| t | k\ r|| } | j d } | |k\ rE| sC| dz }
|
r*|
d t |
j
|
k7 r t d |
r|
t |
d nd }
|
||| < ~ |j ||f |S )N rO z: z?OVER/XOVER response doesn't include names of additional headers) rV rU splitint enumerate
startswithrR r rG )r8 rW data_process_func
n_defaultsoverviewrX fieldsarticle_numbertokensitoken
field_name is_metadatahs r _parse_overviewro s *+JH"&**T"2 ^,!&)HAuCH} QJ$//4KJ{ %U7CF^ 1 1 3q 8' )F G G*/c!fgT "F3q6N! *" 01+ , Or c " |
| dd }| d d } t |d d }t |dd }t |dd }t | d d }t | dd }t | dd }|dk r|dz
}n
|dk r|d z
}t j |||||| S )
Ni F i d il )ra datetime)date_strtime_strhoursminutessecondsyearmonthdays r _parse_datetimer s BC=CR= ! E(1Q- G(12, G x} D B E
hrsm
C by
T5#ugw GGr c t | t j sd}ndj | }| j }|r|dz }dj || }||fS dj || }||fS )N000000z({0.hour:02d}{0.minute:02d}{0.second:02d}rv z {0:02d}{1.month:02d}{1.day:02d}z {0:04d}{1.month:02d}{1.day:02d})rF rw formatr} )dtlegacyry yrx s r _unparse_datetimer s b(++ ,=DDRH
A
G4;;ArB X 5;;ArB X r c V |t j }|j | | S )N)server_hostname)ssl_create_stdlib_context wrap_socket)sockcontexthostnames r _encrypt_onr s2 ?002G""4"BBr c e Zd ZdZdZeddddefdZd Zd Z d Z
d Z d
Z d Z
d ZeZd
Zd Zd7dZd Zd8dZd Zd8dZd8dZd Zd Zd ZdddZdddZ d8dddZ d Z d Z d Z d Z!ddd Z"d! Z#d" Z$d8d#Z%d$ Z&d% Z'd8d&Z(d8ddd'Z)d8ddd(Z*d8ddd)Z+d* Z,ddd+Z-ddd,Z.ddd-Z/d. Z0d/ Z1d0 Z2d1 Z3d2 Z4d3 Z5d9d4Z6d5 Z7e8rd8d6Z9yy):r zutf-8surrogateescapeNFc | || _ || _ | j | | _ d | _ | j j d | _ | j
| |s|r| j ||| y y # | j r| j j | j j xY w)Nrwb) hostport_create_socketr filemakefile
_base_initloginclose)r r r userpassword
readermodeusenetrctimeouts r r z
NNTP.__init__; s " ''0 **51DI OOJ 'x
484 yy ! IIOO s
AA8 8AB;c d| _ | j | _ d | _ | j d| _ |rAd| j vr3| j
| j
sd | _ | j d| _ d| _ y )Nr FREADER) debugging_getrespwelcome_capsgetcapabilitiesreadermode_afterauth_setreadermodetls_on
authenticated)r r s r r zNNTP._base_init^ s }}
%*! ($**4 !,, !
$$&
#r c | S Nr r s r __enter__zNNTP.__enter__ s r c fd} | r* j | r j y y y # t t f$ r Y +w xY w# | r j w w xY w)Nc t d S )Nr )hasattrr s r z NNTP.__exit__.. s wtV 4r )quitOSErrorEOFError_close)r r is_connecteds ` r __exit__z
NNTP.__exit__ sd 4 >
" >KKM "
X&
>KKM "s! 9 A A
A A A(c |
|s t d t j d| | j | j t j | j | j f| S )Nz0Non-blocking socket (timeout=0) is not supportedznntplib.connect)
ValueErrorsysauditr r socketcreate_connection)r r s r r zNNTP._create_socket sQ w OP P #T499dii@''DII(>HHr c r | j r t dt | j | j S )Nz *welcome*)r printreprr r s r
getwelcomezNNTP.getwelcome s, .
>>5d4<<.@A||r c p | j wd| _ d | _ | j \ }}|| _ d|v r!t t t |d | _ d|v rdj |d | _ | j S | j S # t t f$ r i | _ Y | j S w xY w)NrP VERSIONIMPLEMENTATION )
r nntp_versionnntp_implementation capabilitiesmaxmapra rI r r )r respcapss r r zNNTP.getcapabilities s :: !D '+D $
P ! . . 0
d
"
$ ),CT)_,E(FD%#t+/2xx=M8N/OD,zztzz '(:;
zz
s B B54B5c || _ y r )r )r levels r set_debuglevelzNNTP.set_debuglevel s H
r c t j d| | |t z }| j dkD rt dt | | j j | | j j y )Nznntplib.putlinerP z*put*) r r _CRLFr r r r writeflushr rX s r _putlinez
NNTP._putline sX 3 #T40e| >>A uWd4j 9 r c | j rt dt | |j | j | j
}| j
| y )Nz*cmd*)r r r encodeencodingerrorsr r s r _putcmdz NNTP._putcmd s? 0 >>5$t*5{{4==$++6
dr c ( | j j t dz }t | t kD r t d | j
dkD rt
dt | |st |r#|dd t k( r|d d }|S |dd t v r|d d }|S )NrP z
line too longz*get*rt )
r readline_MAXLINErV r r r r r r )r
strip_crlfrX s r _getlinez
NNTP._getline s # yy!!(A+. t9x 0 0 >>A '4: &8^ BCyE!CRy bce#CRy r c | j }| j rt dt | |j | j
| j }|d d }|dk( r t | |dk( r t | |dvr t | |S )Nz*resp*rP 45123)
r r r r rH r r r r r
)r r cs r r z
NNTP._getresp s % }} >>54:6{{4==$++6 !H 8$T* * 8$T* * E>#D) ) r c d } t |t t f rt |d x}}| j }|d d t
vr t
| g }|Jdt z df} | j d }||v rni|j d r|dd }|j | >d} | j }||k( rn(|j d r|dd }|j | >|r|j ||fS # |r|j w w xY w)Nwbr .s .
rP Fs ..)
rF strr7 openr _LONGRESPr r r rc r rG r )r r
openedFiler r8 terminatorsrX
terminators r _getlongrespzNNTP._getlongresp s.
#$e -$(t$44
T==?DBQxy($T**E #e|V 4 ==/D{* u- #ABxJJt$
"
==?Dz) u- #ABxLL&
"U{ " s CC4 4D c F | j | | j S r )r r r s r _shortcmdzNNTP._shortcmd s , T}} r c H | j | | j | S r )r r )r rX r s r _longcmdz
NNTP._longcmd! s$ 0 T &&r c | j | | j | \ }}||D cg c]( }|j | j | j * c}fS c c}w r )r r rH r r )r rX r r lists r _longcmdstringzNNTP._longcmdstring' si
T&&t,
d"&("&$ kk$--="&( ( ( (s -A c | j S # t $ r Y nw xY w | j d \ }}t | }n# t $ r t
d d }Y nw xY w|| _ |S )NzLIST OVERVIEW.FMT)_cachedoverviewfmtAttributeErrorr r] r rU )r r r8 rW s r _getoverviewfmtzNNTP._getoverviewfmt1 sz 8 ** * - --.ABKD%
&e,C " +'*C +
#&
s ? AAc T |D cg c] }t |j c}S c c}w r )r: r` )r r8 rX s r
_grouplistzNNTP._grouplistB s% 5:;UT 4::<(U;;;s %c t i }| j d \ }}|D ] }|j ^}}|||< ||fS )N CAPABILITIES)r r` )r r r r8 rX rY ri s r r zNNTP.capabilitiesF sP )).9 eD JJLMD6 DJ Tzr )r c ` t |t j t j f s.t dj |j
j t || j dk \ }}dj || }| j || \ }}|| j | fS )NAthe date parameter must be a date or datetime object, not '{:40}'rq zNEWGROUPS {0} {1}) rF rw r3 TypeErrorr __class__r r r r r )r r3 r rx ry cmdr r8 s r newgroupszNNTP.newgroupsT s $
>? $fT^^%<%< =?
? /tT5F5F5J K(!((8<))#t4 eT__U+++r c 6 t |t j t j f s.t dj |j
j t || j dk \ }}dj ||| }| j || S )Nr rq zNEWNEWS {0} {1} {2})
rF rw r3 r r r r r r r )r r; r3 r rx ry r s r newnewsz NNTP.newnewsd s $
>? $fT^^%<%< =?
? /tT5F5F5J K(#**5(HE""3--r c h |d|z }nd}| j || \ }}|| j | fS )Nz LIST ACTIVE LIST)r r )r
group_patternr commandr r8 s r r z NNTP.listt sH $$}4G G))'48 eT__U+++r c N t j d }| j d|z \ }}|j d s| j d|z \ }}i }|D ]D }|j |j }|s%|j
dd \ } }
|s|
c S |
|| < F |r||fS y)Nz ^(?P[^ ]+)[ ]+(.*)$zLIST NEWSGROUPS r( zXGTITLE rP rq rD )recompiler rc searchstripr; ) r r
return_allline_patr r8 groupsraw_linematchrY descs r _getdescriptionszNNTP._getdescriptions s :: >?))*<}*LM eu% --j=.HIKD% H OOHNN$45E "[[A .
d! K #t
< r c ( | j |d S )NFr )r r; s r descriptionzNNTP.description s 7 $$UE22r c ( | j |d S )NTr )r r s r descriptionszNNTP.descriptions s 5$$]D99r c V | j d|z }|j d s t | |j }dx}x}}t | }|dkD r1|d }|dkD r'|d }|dkD r |d }|dkD r|d j }|t
| t
| t
| |fS )NzGROUP r' r rP rq r rr )r rc r r` rV rR ra )r rY r wordscountr= r< ns r r; z
NNTP.group s ~~ho.u% & &
J q5!HE1u aq5 8D1u $Qx~~ /SZUSY< r c T |dj | }nd}| j || S )Nz ARTICLE {0}ARTICLEr; r< s r articlez NNTP.article s5 # &&|4CC||C&&r c & | j d S )NSLAVE)r r s r slavez
NNTP.slave$ s ~~g&&r c t j d | j dj || | \ }}fd}||D cg c]
} || c}fS c c}w )Nz^([0-9]+) ?(.*)
?z XHDR {0} {1}c R j | }|r|j dd S | S )NrP rq )r r; )rX mpats r
remove_numberz NNTP.xhdr..remove_number5 s' $A$%1771a= /4 /r )r r r r ) r hdrr r r r8 rL rX rK s @r xhdrz NNTP.xhdr* se jj-.)).*?*?S*I4P e 0 e % %Aw t9? % %_T4000r c | j | }|j d s t | t |t t
f r|j
}|D ]` }|j t s|j d t z }|j d rd|z }| j j | b | j j d | j j | j S )N3r9 r s .
)r rc r rF r7 bytearray
splitlinesendswithr rstripr r r r )r r
fr rX s r _postz
NNTP._postt s ~~g&s# & & a%+ , A
D=='{{7+e3t$d{ IIOOD !
! }} r c ( | j d| S )NPOST)rd )r datas r postz NNTP.post s 1 zz&$''r c F | j dj | | S )Nz IHAVE {0})rd r )r rA rg s r ihavez
NNTP.ihave s& O zz+,,Z8$??r c | j r | j j | ` | j j y # | j j w xY wr )r r r r s r r z NNTP._close s> yy !I IIOO DIIOO s (A A!c v | j d }| j |S # | j w xY w)NQUIT)r r )r r s r r z NNTP.quit s5 1 >>&)D KKM
KKMs & 8c l | j r t d |s
|s t d |r=|s;dd l}|j }|j | j }|r
|d }|d }|sy | j
d|z }|j d r=|s t | | j
d|z }|j d s t | d | _
| j | j r7d | j vr(| j d | _
| j y y y # t
$ r Y w xY w)
NzAlready logged in.z7At least one of `user` and `usenetrc` must be specifiedr rq zauthinfo user 381zauthinfo pass 281r )r r netrcauthenticatorsr r r rc r r r r r r )r r r r rq credentialsauthr s r r z
NNTP.login s5 12 2H IK
K
#kkm "11$))< 7D #AwH ~~ . 56 ??5 !$T**~~&6&ABu-,T22
$ $)C ! DJ " *D $% s ?D' ' D32D3c | j d | _ y # t $ r Y y t $ r.}|j j d rd| _ n Y d }~y d }~ww xY w)Nz mode reader480T)r r r r r rc r )r es r r zNNTP._setreadermode sT
>>-8DL! ! zz$$U+,0) * s AA$AAc | j r t d | j r t d | j d }|j d r| j
j
t | j || j | _ | j j d | _ d| _ d | _ | j y t d )NzTLS is already enabled.z+TLS cannot be started after authentication.STARTTLS382r TzTLS failed to start.)r r r r rc r r r r r r r r r )r r r s r starttlsz
NNTP.starttls s
{{ !:;;!! !NOO>>*-Du% ! ' 7DII F II . .u 5 " "
$$& 677r )Tr )NNT):r r r r r NNTP_PORTr r r r r r r r r debugr r r r r r r r r r r r r r r r r r; r% r) r+ r/ r3 r< r8 r= rA rD rG rN rR rW r3 rd rh rj r r r r _have_sslr{ r r r r r + sc H
F"+$ 50!F #D "I ,
E " ,\ ' ("< '+ , ,0 .
,t
, . 3:=4 1)%
) %%= 'd ' 'd ' ' ' ' &* = )- 1 *. 161" *(@ '#R 8 r r c 8 e Zd Zedddddef fd Z fdZ xZS )NNTP_SSLNFc @ || _ t | ||||||| y r ) ssl_contextsuperr )
r r r r r r r r r r s
r r zNNTP_SSL.__init__ s.
+D G T4x %w
0r c t | | } t || j | j }|S # |j xY wr )r r r r r r )r r r r s r r zNNTP_SSL._create_socket sI 7)'2D
"4)9)9499E
s !5 A)r r r
NNTP_SSL_PORTr r r
__classcell__)r s @r r r s$ &3 $ #e 3 0 r r __main__zJ nntplib built-in demo - display the latest articles in a newsgroup)r z-gz--groupzgmane.comp.python.generalz3group to fetch messages from (default: %(default)s))defaultr% z-sz--serverz
news.gmane.ioz+NNTP server hostname (default: %(default)s)z-pz--portr zNNTP port number (default: z / ))r typer% z-nz
--nb-articles
z2number of articles to fetch (default: %(default)s)z-Sz--ssl
store_truezuse NNTP over SSL)actionr r% )r r ry Grouphaszarticles, rangetoc 8 t | |kD r | d |dz
dz } | S )Nrr z...)rV )slims r cutr 6 s& q6C<(37 e#Ar rP r2 r s B
I > *
Xg . 0 0 Y I
O
"K " ";#E
G %k$$]%FH
2:H, 4
C K 8 K 8\
4 . NN: z
$X
$
$ 2N OF
i1L R T
j/ J L
hFOQ^ _ a
or Q S
glE 0 2 D 99D 88 2: D dkk - 2: D $++D 1 DT
%&WWTZZ%8"D%d '4'8%tL
D D , ,,q0 1EggeT*OD)! tF|,223:1= Y0DN#
%,,c&"os7B'7@ " FFHa U Is K6 6L L