o
0i? @ s< d dl Z d dlZd dlZd dlZd dlZzd dlZW n ey& dZY nw 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 dYd&d'Z dZd(d)Z!erd*d+ Z"G d,d- d-Z#erG d.d/ d/e#Z$e %d/ e&d0krd 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>kreZ.e#e-j/e.dJZ0ne.d>kr%eZ.e$e-j/e.dJZ0e01 Z2dKe2v r9e03 e04e-j4\Z5Z6Z7Z8Z9e:dLe9dMe6dNe7dOe8 dPdQ Z;ee7e8\Z5Z?e?D ]-\Z@ZAe eAdS BdTdRd ZCe eAdU ZDe+eAd ZEe:dVFe@e;eCdWe;eDdXeE qhe0G dS dS )[ NFT)
decode_header)_GLOBAL_DEFAULT_TIMEOUT)NNTP NNTPErrorNNTPReplyErrorNNTPTemporaryErrorNNTPPermanentErrorNNTPProtocolError
NNTPDataErrorr i c @ s e Zd Z dd ZdS )r c G s> t j| g|R z|d | _W d S ty d| _Y d S w )Nr zNo response given) Exception__init__response
IndexError)selfargs r ./opt/alt/python310/lib64/python3.10/nntplib.pyr b s zNNTPError.__init__N)__name__
__module__ __qualname__r r r r r r ` s r c @ e Zd Z dS )r Nr r r r r r r r i r c @ r )r Nr r r r r r m r r c @ r )r Nr r r r r r q r r c @ r )r Nr r r r r r u r r c @ r )r
Nr r r r r r
y r r
w i3 > Z230Z222215Z282Z224Z221Z100Z231Z220211Z225Z101)subjectfromdatez
message-idZ
references:bytes:linesr r )byteslines
GroupInfo)grouplastfirstflag ArticleInfo)Znumber
message_idr" c C sL g }t | D ]\}}t|tr|||pd q|| qd|S )Nascii )_email_decode_header
isinstancer! appenddecodejoin)Z
header_strpartsvencr r r r s
r c C s g }| D ]0}|d dkr |dd d\}}}d| }n| d\}}}| }t||}|| qt}t|t|k rDtd|d t| |krRtd|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
rC c C s t t}g }| D ]]}i }|d^}}t|}t|D ]B\} }
| t |kr'q || } | d} | |krX| sX| d }
|
rL|
d t |
|
krLtd|
rV|
t |
d nd }
|
||| < q |||f q |S )N r5 z: z?OVER/XOVER response doesn't include names of additional headers) r< r; splitint enumerate
startswithr8 r
r/ )r" r= Zdata_process_funcZ
n_defaultsZoverviewr> ZfieldsZarticle_numbertokensitokenZ
field_nameZ is_metadatahr r r _parse_overview s(
rM c C s |d u r| dd }| d d } t |d d }t |dd }t |dd }t | d d }t | dd }t | dd }|dk rJ|d7 }n|dk rR|d 7 }t||||||S )
Ni F i d il )rF datetime)date_strtime_strZhoursZminutesZsecondsyearZmonthZdayr r r _parse_datetime s
rX c C sX t | tjs
d}nd| }| j}|r"|d }d|| }||fS d|| }||fS )NZ000000z({0.hour:02d}{0.minute:02d}{0.second:02d}rS z {0:02d}{1.month:02d}{1.day:02d}z {0:04d}{1.month:02d}{1.day:02d})r. rT formatrW )ZdtZlegacyrV yrU r r r _unparse_datetime s
r[ c C s |d u r t }|j| |dS )N)Zserver_hostname)sslZ_create_stdlib_contextZ wrap_socket)sockcontextZhostnamer r r _encrypt_on s r_ 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! Zdjd"d#Zdjd$d%Zd&d' Zd(d) Zd*d+ Zdd,d-d.Zdd,d/d0Z djdd,d1d2Z d3d4 Z d5d6 Z d7d8 Z d9d: Z!dd,d;d<Z"d=d> Z#d?d@ Z$djdAdBZ%dCdD Z&dEdF Z'djdGdHZ(djdd,dIdJZ)djdd,dKdLZ*djdd,dMdNZ+dOdP Z,dd,dQdRZ-dd,dSdTZ.dd,dUdVZ/dWdX Z0dYdZ Z1d[d\ Z2d]d^ Z3d_d` Z4dadb Z5dkdcddZ6dedf Z7e8rdjdgdhZ9dS dS )lr zutf-8surrogateescapeNFc C s~ || _ || _| || _d | _z | jd| _| | |s!|r+| ||| W d S W d S | jr9| j | j )Nrwb) hostport_create_socketr] filemakefile
_base_initloginclose)r rb rc userpassword
readermodeusenetrctimeoutr r r r 8 s
z
NNTP.__init__c C s` d| _ | | _d | _| d| _|r(d| jvr(| | js(d | _| d| _d| _d S )Nr FREADER) debugging_getrespwelcome_capsgetcapabilitiesreadermode_afterauth_setreadermodetls_on
authenticated)r rl r r r rg [ s
zNNTP._base_initc C s | S Nr r r r r __enter__} s zNNTP.__enter__c sf fdd}| r1z z W n ttfy Y nw W | r& d S d S | r0 w w d S )Nc s
t dS )Nre )hasattrr rz r r s
z NNTP.__exit__..)quitOSErrorEOFError_close)r r Z is_connectedr rz r __exit__ s
z
NNTP.__exit__c C s< |d ur
|s
t dtd| | j| j t| j| jf|S )Nz0Non-blocking socket (timeout=0) is not supportedznntplib.connect)
ValueErrorsysauditrb rc socketZcreate_connection)r rn r r r rd s zNNTP._create_socketc C s | j r tdt| j | jS )Nz *welcome*)rp printreprrr rz r r r
getwelcome s zNNTP.getwelcomec C s | j d u rBd| _d | _z| \}}W n ttfy$ i | _ Y | j S w || _ d|v r6ttt|d | _d|v rBd |d | _| j S )Nr6 ZVERSIONZIMPLEMENTATION )
rs nntp_versionZnntp_implementation capabilitiesr r maxmaprF r1 )r respcapsr r r rt s
zNNTP.getcapabilitiesc C s || _ d S ry )rp )r levelr r r set_debuglevel s
zNNTP.set_debuglevelc C sJ t d| | |t }| jdkrtdt| | j| | j d S )Nznntplib.putliner6 z*put*) r r _CRLFrp r r re writeflushr r> r r r _putline s z
NNTP._putlinec C s4 | j r tdt| || j| j}| | d S )Nz*cmd*)rp r r encodeencodingerrorsr r r r r _putcmd s z NNTP._putcmdTc C s | j td }t|tkrtd| jdkr tdt| |s#t|rC|dd t kr5|d d }|S |dd t v rC|d d }|S )Nr6 z
line too longz*get*rQ )
re readline_MAXLINEr< r
rp r r r r )r Z
strip_crlfr> r r r _getline s
z
NNTP._getlinec C sn | }| jrtdt| || j| j}|d d }|dkr%t||dkr-t||dvr5t ||S )Nz*resp*r6 45Z123)
r rp r r r0 r r r r r )r r cr r r rq s z
NNTP._getrespc C s d }zot |ttfrt|d }}| }|d d tvr"t|g }|d urKdt df} | d}||v r9n| drD|dd }|
| q/n d} | }||krWn| drb|dd }| | qNW |ro| ||fS |rz| w w )Nwb .s .
r6 Fs ..)
r. strr! openrq _LONGRESPr r r rH r r/ ri )r re Z
openedFiler r" Z terminatorsr>
terminatorr r r _getlongresp sH
zNNTP._getlongrespc C s | | | S ry )r rq r r r r _shortcmd s
zNNTP._shortcmdc C s | | | |S ry r r )r r> re r r r _longcmd s
z
NNTP._longcmdc s0 | |\}}| fdd|D fS )Nc s g | ]
}| j jqS r )r0 r r .0r> rz r r
+ s z'NNTP._longcmdstring..r )r r> re r listr rz r _longcmdstring$ s
zNNTP._longcmdstringc C sb z| j W S ty Y nw z | d\}}W n ty' td d }Y nw t|}|| _ |S )NzLIST OVERVIEW.FMT)Z_cachedoverviewfmtAttributeErrorr r r; rC )r r r" r= r r r _getoverviewfmt. s zNNTP._getoverviewfmtc C s dd |D S )Nc S s g | ]}t | qS r )r$ rE r r r r r A s z#NNTP._grouplist..r )r r" r r r
_grouplist? s zNNTP._grouplistc C s: i }| d\}}|D ] }| ^}}|||< q ||fS )NZ CAPABILITIES)r rE )r r r r" r> r? rI r r r r C s
zNNTP.capabilities)re c C sd t |tjtjfstd|jjt|| jdk \}}d||}| ||\}}||
|fS )NAthe date parameter must be a date or datetime object, not '{:40}'rN zNEWGROUPS {0} {1}) r. rT r TypeErrorrY __class__r r[ r r r )r r re rU rV cmdr r" r r r newgroupsQ s
zNNTP.newgroupsc C sT t |tjtjfstd|jjt|| jdk \}}d|||}| ||S )Nr rN zNEWNEWS {0} {1} {2})
r. rT r r rY r r r[ r r )r r% r re rU rV r r r r newnewsa s
z NNTP.newnewsc C s6 |d ur
d| }nd}| ||\}}|| |fS )Nz LIST ACTIVE ZLIST)r r )r
group_patternre commandr r" r r r r q s
z NNTP.listc C s t d}| d| \}}|ds | d| \}}i }|D ] }|| }|r=|dd\} }
|s9|
S |
|| < q |rD||fS dS )Nz ^(?P[^ ]+)[ ]+(.*)$zLIST NEWSGROUPS r zXGTITLE r6 rN r, )recompiler rH searchstripr% ) r r Z
return_allZline_patr r" groupsZraw_linematchr? Zdescr r r _getdescriptions s
zNNTP._getdescriptionsc C | |dS )NFr )r r% r r r description s
zNNTP.descriptionc C r )NTr )r r r r r descriptions s zNNTP.descriptionsc C s | d| }|dst|| }d } }}t|}|dkrA|d }|dkrA|d }|dkrA|d }|dkrA|d }|t|t|t||fS )NzGROUP r r r6 rN r rO )r rH r rE r< r8 rF )r r? r wordscountr' r& nr r r r% s
z
NNTP.groupc C | d|S )NZHELP)r )r re r r r help s z NNTP.helpc C s: | ds
t|| }t|d }|d }|||fS )NZ22r6 rN )rH r rE rF )r r r art_numr* r r r
_statparse s
zNNTP._statparsec C s | |}| |S ry )r r )r r> r r r r _statcmd s
z
NNTP._statcmdc C s |r | d|S | dS )NzSTAT {0}ZSTAT)r rY )r message_specr r r stat s
z NNTP.statc C | dS )NZNEXTr rz r r r next
z NNTP.nextc C r )NZLASTr rz r r r r& r z NNTP.lastc C s2 | ||\}}| |\}}}|t|||fS ry )r r r) )r r> re r r" r r* r r r _artcmd s z NNTP._artcmdc C & |d ur d |}nd}| ||S )NzHEAD {0}ZHEADrY r r r re r r r r head
z NNTP.headc C r )NzBODY {0}ZBODYr r r r r body r z NNTP.bodyc C r )Nz ARTICLE {0}ZARTICLEr r r r r article r z NNTP.articlec C r )NZSLAVE)r rz r r r slave! s
z
NNTP.slavec sF t d | d|||\}} fdd|fdd|D fS )Nz^([0-9]+) ?(.*)
?z XHDR {0} {1}c s | }|r
|ddS | S )Nr6 rN )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 s z NNTP.xhdr..)r r r rY )r Zhdrr re r r" r )r r r xhdr' s
z NNTP.xhdrc C s0 | d|||\}}| }|t||fS )Nz
XOVER {0}-{1})r rY r rM )r startendre r r" r= r r r xover7 s z
NNTP.xoverc C sz d| j v rdnd}t|ttfr |\}}|d||p d7 }n
|d ur*|d | }| ||\}}| }|t||fS )NZOVERZXOVERz {0}-{1}r, r )rs r. tupler rY r r rM ) r r re r r r r r" r= r r r overE s z NNTP.overc C sd | d}|dst|| }t|dkr t||d }t|dkr+t||t|d fS )NZDATEZ111rN r6 )r rH r rE r< r
rX )r r elemr r r r r ` s
z NNTP.datec C s | |}|dst|t|ttfr| }|D ] }|ts)| dt }|dr2d| }| j
| q| j
d | j
|
S )N3r# r s .
)r rH r r. r! bytearray
splitlinesendswithr rstripre r r rq )r r fr r> r r r _postq s
z
NNTP._postc C r )NZPOST)r )r datar r r post s z NNTP.postc C s | d||S )Nz IHAVE {0})r rY )r r* r r r r ihave s z
NNTP.ihavec C sB z| j r| j | ` W | j d S W | j d S | j w ry )re ri r] rz r r r r s
z NNTP._closec C s& z | d}W | |S | w )NZQUIT)r r )r r r r r r~ s
z NNTP.quitc C s | j rtd|s|stdz |r,|s,dd l}| }|| j}|r,|d }|d }W n ty6 Y nw |s;d S | d| }|dr]|sMt|| d| }|ds]t |d | _
| | j ryd | j
vr{|
d | _
| d S d S d S )
NzAlready logged in.z7At least one of `user` and `usenetrc` must be specifiedr rN zauthinfo user Z381zauthinfo pass Z281ro )rx r netrcZauthenticatorsrb r r rH r r rs rt ru rv )r rj rk rm r Z credentialsZauthr r r r rh sD
z
NNTP.loginc
C sb z | d| _W d S ty Y d S ty0 } z|jdr$d| _n W Y d }~d S d }~ww )Nz mode readerZ480T)r rr r r r
rH ru )r er r r rv s zNNTP._setreadermodec C s| | j rtd| jrtd| d}|dr:| j t| j|| j | _| j
d| _d| _ d | _ | d S t
d)NzTLS is already enabled.z+TLS cannot be started after authentication.STARTTLSZ382ra TzTLS failed to start.)rw r rx r rH re ri r_ r] rb rf rs rt r )r r^ r r r r starttls s
z
NNTP.starttls)Try )NNT):r r r r r NNTP_PORTr r rg r{ r rd r rt r debugr r r rq 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~ rh rv _have_sslr r r r r r ( st
#"
.
)
r c s8 e Zd Zedddddef fdd Z fddZ ZS )NNTP_SSLNFc s$ || _ t ||||||| d S ry ) ssl_contextsuperr ) r rb rc rj rk r rl rm rn r r r r s
zNNTP_SSL.__init__c s4 t |}z t|| j| j}W |S | ry )r rd r_ r rb ri )r rn r] r r r rd s zNNTP_SSL._create_socket)r r r
NNTP_SSL_PORTr r rd
__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 )rb rc r ZGroupZhaszarticles, rangetoc C s$ t | |kr| d |d d } | S )NrO z...)r< )sZlimr r r cut3 s r
r6 r s A
S