]F @ s d d l Z d d l Z d d l Z d d l Z d d l Z y d d l Z Wn e k
rf d Z Yn Xd Z d d l m Z
d d l m Z d d d d d
d d d
g Z d Z
Gd d d e Z Gd d d e Z Gd d d e Z Gd d
d
e Z Gd d d e Z Gd d d e Z d Z d Z d d d d d d d d d d d! d" h Z d# d$ d% d& d' d( d) g Z d* d( d+ d) i Z d, Z e j d- d. d/ d0 d1 g Z e j d2 d3 d4 d+ g Z d5 d
Z d6 d7 Z d d8 d9 Z d d: d; Z d d< d= Z! e r.d> d? Z" Gd@ dA dA Z# GdB d d e# Z$ e rGdC dD dD e# Z% e j& dD e' dE k rd d l( Z( e( j) dF dG Z* e* j+ dH dI dJ dK dL dM e* j+ dN dO dJ dP dL dQ e* j+ dR dS dJ dT dU e, dL dV e e f e* j+ dW dX dJ dY dU e, dL dZ e* j+ d[ d\ d] d^ dJ d dL d_ e* j- Z. e. j/ Z/ e. j re/ dT k re Z/ e$ d` e. j0 da e/ Z1 n+ e/ dT k re Z/ e% d` e. j0 da e/ Z1 e1 j2 Z3 db e3 k re1 j4 e1 j5 e. j5 \ Z6 Z7 Z8 Z9 Z: e; dc e: dd e7 de e8 df e9 dg dh Z< e= e, e9 e. j> dT Z8 e1 j? e8 e9 \ Z6 Z@ x e@ D]z \ ZA ZB e eB d$ jC di dT d ZD e eB d# ZE e, eB d) ZF e; dj jG eA e< eD dk e< eE dl eF quWe1 jH d S)m NFT)
decode_header)_GLOBAL_DEFAULT_TIMEOUTNNTP NNTPErrorNNTPReplyErrorNNTPTemporaryErrorNNTPPermanentErrorNNTPProtocolError
NNTPDataErrorr i c @ s e Z d Z d d Z d S)r c G sC t j | | y | d | _ Wn t k
r> d | _ Yn Xd S)Nr zNo response given) Exception__init__response
IndexError)selfargs r ,/opt/alt/python35/lib64/python3.5/nntplib.pyr b s
zNNTPError.__init__N)__name__
__module__ __qualname__r r r r r r ` s c @ s e Z d Z d S)r N)r r r r r r r r i s c @ s e Z d Z d S)r N)r r r r r r r r m s c @ s e Z d Z d S)r N)r r r r r r r r q s c @ s e Z d Z d S)r N)r r r r r r r r u s c @ s e Z d Z d S)r
N)r r r r r r r r
y s w i3 Z100Z101211215Z220Z221Z222Z224Z225Z230Z231Z282subjectfromdatez
message-idZ
referencesz:bytesz:linesbytesliness
GroupInfogrouplastfirstflag ArticleInfoZnumber
message_idc C sk g } xU t | D]G \ } } t | t rM | j | j | pC d q | j | q Wd j | S)Nascii )_email_decode_header
isinstancer appenddecodejoin)Z
header_strpartsvencr r r r s c C s g } x | D] } | d d k rR | d d j d \ } } } d | } n | j d \ } } } | j } t j | | } | j | q
Wt } t | t | k r t d | d t | | k r t d | S)Nr : z$LIST OVERVIEW.FMT response too shortz*LIST OVERVIEW.FMT redefines default fields) partitionlower_OVERVIEW_FMT_ALTERNATIVESgetr) _DEFAULT_OVERVIEW_FMTlenr
)r fmtlinename_suffixdefaultsr r r _parse_overview_fmt s
"
r= c C s- t t } g } x| D] } i } | j d ^ } } t | } x t | D] \ } }
| t | k rt qS | | } | j d } | | k r | r | d }
|
r |
d t |
j |
k r t d |
r |
t |
d n d }
|
| | | d? Z# d@ dA Z$ d dB dC Z% d d' d dD dE Z& d d' d dF dG Z' d d' d dH dI Z( dJ dK Z) d' d dL dM Z* d' d dN dO Z+ d' d dP dQ Z, d' d dR dS Z- dT dU Z. dV dW Z/ dX dY Z0 dZ d[ Z1 d\ d] Z2 d^ d_ Z3 d` da Z4 d d d db dc Z5 dd de Z6 e7 rd df dg Z8 d S)h _NNTPBasezutf-8surrogateescapeNc C s | | _ | | _ d | _ | j | _ d | _ | j d | _ | r d | j k r | j | j s d | _ | j d | _ d | _
d S)Nr FREADER) hostfile debugging_getrespwelcome_capsgetcapabilitiesreadermode_afterauth_setreadermodetls_on
authenticated)r rb ra
readermodetimeoutr r r r 8 s
z_NNTPBase.__init__c C s | S)Nr )r r r r __enter__g s z_NNTPBase.__enter__c sc f d d } | r_ z- y j Wn t t f k
rF Yn XWd | r^ j Xd S)Nc s
t d S)Nrb )hasattrr )r r r k s z$_NNTPBase.__exit__..)quitOSErrorEOFError_close)r r Z is_connectedr )r r __exit__j s z_NNTPBase.__exit__c C s& | j r t d t | j | j S)Nz *welcome*)rc printreprre )r r r r
getwelcomeu s z_NNTPBase.getwelcomec
C s | j d k r d | _ d | _ y | j \ } } Wn! t t f k
rZ i | _ YnT X| | _ d | k r t t t | d | _ d | k r d j | d | _ | j S)Nr0 VERSIONZIMPLEMENTATION )
rf nntp_versionZnntp_implementation capabilitiesr r maxmapr@ r+ )r respcapsr r r rg ~ s z_NNTPBase.getcapabilitiesc C s
| | _ d S)N)rc )r levelr r r set_debuglevel s z_NNTPBase.set_debuglevelc C sM | t } | j d k r, t d t | | j j | | j j d S)Nr0 z*put*)_CRLFrc rv rw rb writeflush)r r8 r r r _putline s
z_NNTPBase._putlinec C sE | j r t d t | | j | j | j } | j | d S)Nz*cmd*)rc rv rw encodeencodingerrorsr )r r8 r r r _putcmd s z_NNTPBase._putcmdTc C s | j j t d } t | t k r4 t d | j d k rV t d t | | sb t | r | d d t k r | d d } n& | d d t k r | d d } | S) Nr0 z
line too longz*get*rJ rO rO r )
rb readline_MAXLINEr6 r
rc rv rw rs r )r Z
strip_crlfr8 r r r _getline s z_NNTPBase._getlinec C s | j } | j r( t d t | | j | j | j } | d d } | d k rh t | | d k r t | | d k r t | | S)Nz*resp*r0 45Z123)
r rc rv rw r* r r r r r )r r cr r r rd s z_NNTPBase._getrespc
C sD d } z t | t t f r1 t | d } } | j } | d d t k r_ t | g } | d k r d t d f } x | j d } | | k r P| j d r | d d } | j
| q WnR d } xI | j } | | k r P| j d r| d d } | j | q WWd | r9| j X| | f S)Nwb .s .
Fs ..r0 )
r( strr openrd _LONGRESPr r r rB r r) close)r rb Z
openedFiler r Z terminatorsr8
terminatorr r r _getlongresp s8 z_NNTPBase._getlongrespc C s | j | | j S)N)r rd )r r8 r r r _shortcmd s
z_NNTPBase._shortcmdc C s | j | | j | S)N)r r )r r8 rb r r r _longcmd s
z_NNTPBase._longcmdc s? j | j | \ } } | f d d | D f S)Nc s( g | ] } | j j j q Sr )r* r r ).0r8 )r r r
s z,_NNTPBase._longcmdstring..)r r )r r8 rb r listr )r r _longcmdstring s
z_NNTPBase._longcmdstringc C sw y | j SWn t k
r Yn Xy | j d \ } } Wn" t k
r] t d d } Yn
Xt | } | | _ | S)NzLIST OVERVIEW.FMT)Z_cachedoverviewfmtAttributeErrorr r r5 r= )r r r r7 r r r _getoverviewfmt s
z_NNTPBase._getoverviewfmtc C s d d | D S)Nc S s" g | ] } t | j q Sr )r r? )r r8 r r r r $ s z(_NNTPBase._grouplist..r )r r r r r
_grouplist" s z_NNTPBase._grouplistc C sR i } | j d \ } } x* | D]" } | j ^ } } | | | [^ ]+)[ ]+(.*)$zLIST NEWSGROUPS r zXGTITLE r0 rJ r& )recompiler rB searchstripr ) r r Z
return_allline_patr r groupsraw_linematchr9 Zdescr r r _getdescriptionsc s
z_NNTPBase._getdescriptionsc C s | j | d S)NF)r )r r r r r descriptionz s z_NNTPBase.descriptionc C s | j | d S)NT)r )r r r r r descriptions s z_NNTPBase.descriptionsc C s | j d | } | j d s. t | | j } d } } } t | } | d k r | d } | d k r | d } | d k r | d } | d k r | d j } | t | t | t | | f S)NzGROUP r r r0 rJ r rK )r rB r r? r6 r2 r@ )r r9 r wordscountr! r nr r r r s
z_NNTPBase.groupc C s | j d | S)NZHELP)r )r rb r r r help s z_NNTPBase.helpc C sN | j d s t | | j } t | d } | d } | | | f S)NZ22r0 rJ )rB r r? r@ )r r r art_numr$ r r r
_statparse s
z_NNTPBase._statparsec C s | j | } | j | S)N)r r )r r8 r r r r _statcmd s z_NNTPBase._statcmdc C s- | r | j d j | S| j d Sd S)NzSTAT {0}ZSTAT)r rU )r message_specr r r stat s z_NNTPBase.statc C s
| j d S)NZNEXT)r )r r r r next s z_NNTPBase.nextc C s
| j d S)NZLAST)r )r r r r r s z_NNTPBase.lastc C sF | j | | \ } } | j | \ } } } | t | | | f S)N)r r r# )r r8 rb r r r r$ r r r _artcmd s z_NNTPBase._artcmdc C s4 | d k r d j | } n d } | j | | S)NzHEAD {0}ZHEAD)rU r )r r rb r r r r head s z_NNTPBase.headc C s4 | d k r d j | } n d } | j | | S)NzBODY {0}ZBODY)rU r )r r rb r r r r body s z_NNTPBase.bodyc C s4 | d k r d j | } n d } | j | | S)Nz ARTICLE {0}ZARTICLE)rU r )r r rb r r r r article s z_NNTPBase.articlec C s
| j d S)NZSLAVE)r )r r r r slave s z_NNTPBase.slavec sb t j d | j d j | | | \ } } f d d | f d d | D f S)Nz^([0-9]+) ?(.*)
?z XHDR {0} {1}c s) j | } | r% | j d d S| S)Nr0 rJ )r r )r8 m)patr r
remove_number s z%_NNTPBase.xhdr..remove_numberc s g | ] } | q Sr r )r r8 )r r r r s z"_NNTPBase.xhdr..)r r r rU )r Zhdrr rb r r r )r r r xhdr
s $z_NNTPBase.xhdrc C sC | j d j | | | \ } } | j } | t | | f S)Nz
XOVER {0}-{1})r rU r rH )r startendrb r r r7 r r r xover s z_NNTPBase.xoverc C s d | j k r d n d } t | t t f r[ | \ } } | d j | | pQ d 7} n | d k ru | d | } | j | | \ } } | j } | t | | f S)NZOVERZXOVERz {0}-{1}r& rz )rf r( tupler rU r r rH ) r r rb r r r r r r7 r r r over( s z_NNTPBase.overc C s t j d t d t j d } | j d | | \ } } g } xB | D]: } | j | j } | rK | j | j d d qK W| | f S)NzFThe XGTITLE extension is not actively used, use descriptions() insteadrJ z^([^ ]+)[ ]+(.*)$zXGTITLE r0 )
warningswarnDeprecationWarningr r r r r r) r ) r r rb r r Z raw_linesr r r r r r xgtitleC s
z_NNTPBase.xgtitlec C s t j d t d | j d j | } | j d sF t | y | j \ } } Wn t k
r| t | Yn X| | f Sd S)Nz(The XPATH extension is not actively usedrJ z XPATH {0}Z223) r r r r rU rB r r?
ValueError)r idr Zresp_numpathr r r xpathU s
z_NNTPBase.xpathc C s | j d } | j d s* t | | j } t | d k rT t | | d } t | d k r| t | | t | d f S)NZDATEZ111rJ r0 )r rB r r? r6 r
rT )r r elemr r r r r i s
z_NNTPBase.datec C s | j | } | j d s* t | t | t t f rK | j } xY | D]Q } | j t sz | j d t } | j d r d | } | j
j | qR W| j
j d | j
j | j
S)N3s
r s .
)r rB r r( r bytearray
splitlinesendswithr rstriprb r r rd )r r fr r8 r r r _postz s
z_NNTPBase._postc C s | j d | S)NZPOST)r )r datar r r post s z_NNTPBase.postc C s | j d j | | S)Nz IHAVE {0})r rU )r r$ r r r r ihave s z_NNTPBase.ihavec C s | j j | ` d S)N)rb r )r r r r rt s
z_NNTPBase._closec
C s% z | j d } Wd | j X| S)NZQUIT)r rt )r r r r r rq s z_NNTPBase.quitc C sT | j r t d | r/ | r/ t d yU | r | r d d l } | j } | j | j } | r | d } | d } Wn t k
r Yn X| s d S| j d | } | j d r| s t | n. | j d | } | j d st | d | _
| j | j rPd | j
k rP| j
d | _
| j d S)
NzAlready logged in.z7At least one of `user` and `usenetrc` must be specifiedr rJ zauthinfo user Z381zauthinfo pass Z281r` )rk r netrcZauthenticatorsra rr r rB r r rf rg rh ri )r userpasswordusenetrcr Z credentialsZauthr r r r login s<
z_NNTPBase.loginc C st y | j d | _ WnW t k
r* YnF t k
ro } z& | j j d rZ d | _ n WYd d } ~ Xn Xd S)Nz mode readerZ480T)r re r r r
rB rh )r er r r ri s
z_NNTPBase._setreadermodec C s | j r t d | j r* t d | j d } | j d r | j j t | j | | j | _ | j j
d | _ d | _ d | _ | j n t
d d S)NzTLS is already enabled.z+TLS cannot be started after authentication.STARTTLSZ382rwbTzTLS failed to start.)rj r rk r rB rb r r] rZ ra makefilerf rg r )r r[ r r r r starttls s
z_NNTPBase.starttls)9r r r r r r r rn ru rx rg r debugr r r rd r r r r r r r| r r r r r r r r r r r r r r r r r r r r r r r r r r r rt rq r ri _have_sslr r r r r r^ ( sj
. .
)
r^ c @ s: e Z d Z e d d d d e d d Z d d Z d S)r NFc C s | | _ | | _ t j | | f | | _ d } yN | j j d } t j | | | | | | sm | r | j | | | Wn( | r | j | j j Yn Xd S)Nr )
ra portsocketcreate_connectionrZ r r^ r r r ) r ra r r r rl r rm rb r r r r s
z
NNTP.__init__c
C s& z t j | Wd | j j Xd S)N)r^ rt rZ r )r r r r rt ! s z NNTP._close)r r r NNTP_PORTr r rt r r r r r s "c @ s= e Z d Z e d d d d d e d d Z d d Z d S)NNTP_SSLNFc
C s t j | | f | | _ d } yl t | j | | | _ | j j d } t j | | | d | d | | sy | r | j | | | Wn( | r | j | j j Yn Xd S)Nr rl rm ) r r rZ r] r r^ r r r )
r ra r r r Z ssl_contextrl r rm rb r r r r + s
zNNTP_SSL.__init__c
C s& z t j | Wd | j j Xd S)N)r^ rt rZ r )r r r r rt A s zNNTP_SSL._close)r r r
NNTP_SSL_PORTr r rt r r r r r ) s
r __main__r zJ nntplib built-in demo - display the latest articles in a newsgroupz-gz--groupdefaultzgmane.comp.python.generalr z3group to fetch messages from (default: %(default)s)z-sz--serverznews.gmane.orgz+NNTP server hostname (default: %(default)s)z-pz--portr0 typez#NNTP port number (default: %s / %s)z-nz
--nb-articles
z2number of articles to fetch (default: %(default)s)z-Sz--sslaction
store_truezuse NNTP over SSLra r r ZGroupZhaszarticles, rangeZtoc C s. t | | k r* | d | d d } | S)NrK z...)r6 )sZlimr r r cutl s r B s
-
! )