a
i? @ s: d dl Z d dlZd dlZd dlZd dlZz d dlZW n eyJ dZY n0 dZd dlm Z
d dlm Z g dZ dZ
G dd d eZG d
d d eZG d d
d
eZG dd deZG dd deZG dd deZdZdZh dZg dZdddZdZed g d Z ed g d Z d d! Z d"d# Z dYd$d%Z dZd&d'Z d[d(d)Z!erVd*d+ Z"G d,d- d-Z#erG d.d/ d/e#Z$e %d/ e&d0kr6d dl'Z'e'j(d1d2Z)e)j*d3d4d5d6d7 e)j*d8d9d:d;d7 e)j*de+d?eef d@ e)j*dAdBdCe+dDd@ e)j*dEdFdGddHdI e), Z-e-j.Z.e-js>e.d>kr.eZ.e#e-j/e.dJZ0n e.d>krLeZ.e$e-j/e.dJZ0e01 Z2dKe2v rte03 e04e-j4\Z5Z6Z7Z8Z9e:dLe9dMe6dNe7dOe8 dPdQ Z;ee7e8\Z5Z?e?D ]Z\Z@ZAe eAdS BdTdRd ZCe eAdU ZDe+eAd ZEe:dVFe@e;eCdWe;eDdXeE qe0G dS )\ NFT)
decode_header)_GLOBAL_DEFAULT_TIMEOUT)NNTP NNTPErrorNNTPReplyErrorNNTPTemporaryErrorNNTPPermanentErrorNNTPProtocolError
NNTPDataErrorr i c @ s e Zd Zdd ZdS )r c G s> t j| g|R z|d | _W n ty8 d| _Y n0 d S )Nr zNo response given) Exception__init__response
IndexError)selfargs r /usr/lib64/python3.9/nntplib.pyr b s
zNNTPError.__init__N)__name__
__module__ __qualname__r r r r r r ` s r c @ s e Zd ZdS )r Nr r r r r r r r i s r c @ s e Zd ZdS )r Nr r r r r r m s r c @ s e Zd ZdS )r Nr r r r r r q s r c @ s e Zd ZdS )r Nr r r r r r u s r c @ s e Zd ZdS )r
Nr r r r r r
y s r
w i3 > Z222Z231Z224211Z230Z101Z220Z100Z282215Z221Z225)subjectfromdatez
message-idZ
references:bytes:linesr r )byteslines
GroupInfo)grouplastfirstflag ArticleInfo)number
message_idr c C sJ g }t | D ]2\}}t|tr4|||p,d q || q d|S )Nascii )_email_decode_header
isinstancer appenddecodejoin)Z
header_strpartsvencr r r r s
r c C s g }| D ]`}|d dkr:|dd d\}}}d| }n| d\}}}| }t||}|| qt}t|t|k rtd|d t| |krtd|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
rB c C s t t}g }| D ]}i }|d^}}t|}t|D ]\} }
| t |krLq6|| } | d} | |kr| s| d }
|
r|
d t |
|
krtd|
r|
t |
d nd }
|
||| < q6|||f q|S )N r4 z: z?OVER/XOVER response doesn't include names of additional headers) r; r: splitint enumerate
startswithr7 r
r. )r r< Zdata_process_funcZ
n_defaultsZoverviewr= fieldsZarticle_numbertokensitoken
field_nameZ is_metadatahr r r _parse_overview s&
rN c C s |d u r | dd }| d d } t |d d }t |dd }t |dd }t | d d }t | dd }t | dd }|dk r|d7 }n|dk r|d 7 }t||||||S )
Ni F i d il )rE datetime)date_strtime_strZhoursZminutesZsecondsyearZmonthZdayr r r _parse_datetime s
rY c C sP t | tjsd}n
d| }| j}|r<|d }d|| }n d|| }||fS )NZ000000z({0.hour:02d}{0.minute:02d}{0.second:02d}rT z {0:02d}{1.month:02d}{1.day:02d}z {0:04d}{1.month:02d}{1.day:02d})r- rU formatrX )ZdtlegacyrW yrV r r r _unparse_datetime s
r] c C s |d u rt }|j| |dS )N)Zserver_hostname)sslZ_create_stdlib_contextZ wrap_socket)sockcontexthostnamer r r _encrypt_on s rb c @ s e Zd ZdZdZeddddefddZdd Zd d
Z d d Z
d
d Z dd Z dd Z
dd ZeZdd Zdd ZdiddZd d Zdjd d Zd d! Zdkd"d#Zdld$d%Zd&d' Zd(d) Zd*d+ Zdd,d-d.Zdd,d/d0Z dmdd,d1d2Z d3d4 Z d5d6 Z d7d8 Z d9d: Z!dd,d;d<Z"d=d> Z#d?d@ Z$dndAdBZ%dCdD Z&dEdF Z'dodGdHZ(dpdd,dIdJZ)dqdd,dKdLZ*drdd,dMdNZ+dOdP Z,dd,dQdRZ-dd,dSdTZ.dd,dUdVZ/dWdX Z0dYdZ Z1d[d\ Z2d]d^ Z3d_d` Z4dadb Z5dsdcddZ6dedf Z7e8rdtdgdhZ9dS )ur zutf-8surrogateescapeNFc C s~ || _ || _| || _d | _z2| jd| _| | |s@|rN| ||| W n( | jrh| j | j Y n0 d S )Nrwb) hostport_create_socketr_ filemakefile
_base_initloginclose)r re rf userpassword
readermodeusenetrctimeoutr r r r 8 s
z
NNTP.__init__c C s^ d| _ | | _d | _| d| _|rNd| jvrN| | jsNd | _| d| _d| _d S )Nr FREADER) debugging_getrespwelcome_capsgetcapabilitiesreadermode_afterauth_setreadermodetls_on
authenticated)r ro r r r rj [ s
zNNTP._base_initc C s | S Nr r r r r __enter__} s zNNTP.__enter__c s^ fdd}| rZz6z W n ttfy6 Y n0 W | rZ n| rX 0 d S )Nc s
t dS )Nrh )hasattrr r} r r z NNTP.__exit__..)quitOSErrorEOFError_close)r r Z is_connectedr r} r __exit__ s
z
NNTP.__exit__c C s< |d ur|st dtd| | j| j t| j| jf|S )Nz0Non-blocking socket (timeout=0) is not supportedznntplib.connect)
ValueErrorsysauditre rf socketcreate_connection)r rq r r r rg s zNNTP._create_socketc C s | j rtdt| j | jS )Nz *welcome*)rs printreprru r} r r r
getwelcome s zNNTP.getwelcomec C s | j d u r~d| _d | _z| \}}W n ttfyB i | _ Y n<0 || _ d|v rfttt|d | _d|v r~d |d | _| j S )Nr5 VERSIONZIMPLEMENTATION )
rv nntp_versionZnntp_implementation capabilitiesr r maxmaprE r0 )r respcapsr r r rw s
zNNTP.getcapabilitiesc C s
|| _ d S r| )rs )r levelr r r set_debuglevel s zNNTP.set_debuglevelc C sH t d| | |t }| jdkr.tdt| | j| | j d S )Nznntplib.putliner5 z*put*) r r _CRLFrs r r rh writeflushr r= r r r _putline s
z
NNTP._putlinec C s2 | j rtdt| || j| j}| | d S )Nz*cmd*)rs r r encodeencodingerrorsr r r r r _putcmd s z NNTP._putcmdTc C s | j td }t|tkr$td| jdkr+ s z'NNTP._longcmdstring..r )r r= rh r listr r} r _longcmdstring$ s
zNNTP._longcmdstringc C s` z| j W S ty Y n0 z| d\}}W n tyL td d }Y n
0 t|}|| _ |S )NzLIST OVERVIEW.FMT)Z_cachedoverviewfmtAttributeErrorr r r: rB )r r r r< r r r _getoverviewfmt. s zNNTP._getoverviewfmtc C s dd |D S )Nc S s g | ]}t | qS r )r" rD r r r r r A r z#NNTP._grouplist..r )r r r r r
_grouplist? s zNNTP._grouplistc C s8 i }| d\}}|D ]}| ^}}|||< q||fS )NZ CAPABILITIES)r rD )r r r r r= r> rI r r r r C s
zNNTP.capabilities)rh c C sb t |tjtjfs$td|jjt|| jdk \}}d||}| ||\}}||
|fS )NAthe date parameter must be a date or datetime object, not '{:40}'rO zNEWGROUPS {0} {1}) r- rU r TypeErrorrZ __class__r r] r r r )r r rh rV rW cmdr r r r r newgroupsQ s zNNTP.newgroupsc C sR t |tjtjfs$td|jjt|| jdk \}}d|||}| ||S )Nr rO zNEWNEWS {0} {1} {2})
r- rU r r rZ r r r] r r )r r# r rh rV rW r r r r newnewsa s z NNTP.newnewsc C s4 |d urd| }nd}| ||\}}|| |fS )Nz LIST ACTIVE LIST)r r )r
group_patternrh commandr r r r r r q s
z NNTP.listc C s t d}| d| \}}|ds8| d| \}}i }|D ]:}|| }|r@|dd\} }
|sr|
S |
|| < q@|r||fS dS d S )Nz ^(?P[^ ]+)[ ]+(.*)$zLIST NEWSGROUPS r zXGTITLE r5 rO r+ )recompiler rG searchstripr# ) r r Z
return_allZline_patr r groupsZraw_linematchr> Zdescr r r _getdescriptions s
zNNTP._getdescriptionsc C s | |dS )NFr )r r# r r r description s zNNTP.descriptionc C s | |dS )NTr )r r r r r descriptions s zNNTP.descriptionsc C s | d| }|ds t|| }d } }}t|}|dkr|d }|dkr|d }|dkr|d }|dkr|d }|t|t|t||fS )NzGROUP r r r5 rO r rP )r rG r rD r; r7 rE )r r> r wordscountr% r$ nr r r r# s
z
NNTP.groupc C s | d|S )NZHELP)r )r rh r r r help s z NNTP.helpc C s8 | dst|| }t|d }|d }|||fS )NZ22r5 rO )rG r rD rE )r r r art_numr) r r r
_statparse s
zNNTP._statparsec C s | |}| |S r| )r r )r r= r r r r _statcmd s
z
NNTP._statcmdc C s" |r| d|S | dS d S )NzSTAT {0}ZSTAT)r rZ )r message_specr r r stat s z NNTP.statc C s
| dS )NZNEXTr r} r r r next s z NNTP.nextc C s
| dS )NZLASTr r} r r r r$ s z NNTP.lastc C s0 | ||\}}| |\}}}|t|||fS r| )r r r' )r r= rh r r r r) r r r _artcmd s z NNTP._artcmdc C s$ |d urd |}nd}| ||S )NzHEAD {0}ZHEADrZ r r r rh r r r r head s z NNTP.headc C s$ |d urd |}nd}| ||S )NzBODY {0}ZBODYr r r r r body s z NNTP.bodyc C s$ |d urd |}nd}| ||S )Nz ARTICLE {0}ZARTICLEr r r r r article s z NNTP.articlec C s
| dS )NZSLAVE)r r} r r r slave! s z
NNTP.slavec sD t d | d|||\}} fdd|fdd|D fS )Nz^([0-9]+) ?(.*)
?z XHDR {0} {1}c s | }|r|ddS | S )Nr5 rO )r r# )r= m)patr r
remove_number2 s
z NNTP.xhdr..remove_numberc s g | ] } |qS r r r )r r r r 5 r z NNTP.xhdr..)r r r rZ )r Zhdrr rh r r r )r r r xhdr' s
z NNTP.xhdrc C s. | d|||\}}| }|t||fS )Nz
XOVER {0}-{1})r rZ r rN )r startendrh r r r< r r r xover7 s
z
NNTP.xoverc C sx d| j v rdnd}t|ttfr>|\}}|d||p6d7 }n|d urR|d | }| ||\}}| }|t||fS )NZOVERZXOVERz {0}-{1}r+ r )rv r- tupler rZ r r rN ) r r rh r r r r r r< r r r overE s z NNTP.overc C sb | d}|ds t|| }t|dkr8t||d }t|dkrTt||t|d fS )NZDATEZ111rO r5 )r rG r rD r; r
rY )r r elemr r r r r ` s
z NNTP.datec C s | |}|ds t|t|ttfr2| }|D ]:}|tsR| dt }|drdd| }| j
| q6| j
d | j
|
S )N3r! r s .
)r rG r r- r bytearray
splitlinesendswithr rstriprh r r rt )r r fr r= r r r _postq s
z
NNTP._postc C s | d|S )NZPOST)r )r datar r r post s z NNTP.postc C s | d||S )Nz IHAVE {0})r rZ )r r) r r r r ihave s z
NNTP.ihavec C s4 z"| j r| j | ` W | j n | j 0 d S r| )rh rl r_ r} r r r r s
z NNTP._closec C s& z| d}W | n
| 0 |S )NZQUIT)r r )r r r r r r s z NNTP.quitc C s | j rtd|s |s tdz<|rX|sXdd l}| }|| j}|rX|d }|d }W n tyl Y n0 |svd S | d| }|dr|st|n | d| }|dst |d | _
| | j rd | j
vr|
d | _
| d S )
NzAlready logged in.z7At least one of `user` and `usenetrc` must be specifiedr rO zauthinfo user Z381zauthinfo pass Z281rr )r{ r netrcZauthenticatorsre r r rG r r rv rw rx ry )r rm rn rp r Z credentialsZauthr r r r rk s>
z
NNTP.loginc
C s` z| d| _W nJ ty" Y n: tyZ } z"|jdrDd| _n W Y d }~n
d }~0 0 d S )Nz mode readerZ480T)r ru r r r
rG rx )r er r r ry s zNNTP._setreadermodec C s| | j rtd| jr td| d}|drp| j t| j|| j | _| j
d| _d| _ d | _ | nt
dd S )NzTLS is already enabled.z+TLS cannot be started after authentication.STARTTLSZ382rd TzTLS failed to start.)rz r r{ r rG rh rl rb r_ re ri rv rw r )r r` r r r r starttls s
z
NNTP.starttls)T)N)N)N)N)N)N)N)N)N)NNT)N):r r r r r NNTP_PORTr r rj r~ r rg r rw r debugr r r rt 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 rk ry _have_sslr r r r r r ( sp
#"
.
)
r c s8 e Zd Zedddddef fdd Z fddZ ZS )NNTP_SSLNFc s" || _ t ||||||| d S r| ) ssl_contextsuperr ) r re rf rm rn r ro rp rq r r r r s zNNTP_SSL.__init__c s@ t |}zt|| j| j}W n | Y n0 |S d S r| )r rg rb r re rl )r rq r_ r r r rg s zNNTP_SSL._create_socket)r r r
NNTP_SSL_PORTr r rg
__classcell__r r r r r s 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 z#NNTP port number (default: %s / %s))r typer z-nz
--nb-articles
z2number of articles to fetch (default: %(default)s)z-Sz--ssl
store_truezuse NNTP over SSL)actionr r )re rf r ZGroupZhaszarticles, rangetoc C s$ t | |kr | d |d d } | S )NrP z...)r; )sZlimr r r cut3 s r r5 r r r r Z nb_articlesr Z overviewsZartnumr rD Zauthorr r rZ r r r r r B s
S