/usr/lib/python3/dist-packages/twisted/conch/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/conch/__pycache__/unix.cpython-310.pyc (16939B)
o
b@ @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
m Z ddl m
Z
ddlmZ ddlmZ ddlmZmZmZ ddlmZ dd lmZmZmZ dd
l m Z m Z m Z m Z m!Z!m"Z" dd l#m$Z$ dd l%m&Z& dd
l'm(Z( ddl)m*Z* ddl+m,Z, zddl-Z-W n e.y dZ-Y nw e e$j/G dd dZ0G dd deZ1e eG dd dZ2e eG dd dZ3e eG dd dZ4G dd dZ5e*6e3e1ej e*6e2e1ej dS ) z
A UNIX SSH server.
N) implementer)ttymodes) ConchUser)
ConchError)ISession ISFTPFile ISFTPServer)lsLine) filetransfer
forwardingsession)
FXF_APPEND FXF_CREATFXF_EXCLFXF_READ FXF_TRUNC FXF_WRITE)portal)ProcessExitedAlready)Logger)
components) nativeStringc @ s e Zd Zdd ZdS ) UnixSSHRealmc G s t |}|d ||jfS Nr )
UnixConchUserlogout)selfusernamemind
interfacesuser r! 4/usr/lib/python3/dist-packages/twisted/conch/unix.py
requestAvatar0 s zUnixSSHRealm.requestAvatarN)__name__
__module__ __qualname__r# r! r! r! r" r . s r c @ sT e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
dd Z dS )r c C s t | || _t| j| _| jd g}t D ]\}}}}||v r(|| q|| _ i | _
| j t
jtjd | j dtji d S )N )s sessions direct-tcpips sftp)r __init__r pwdgetpwnampwdDatagrpgetgrallappend otherGroups listeners
channelLookupupdater
SSHSessionr openConnectForwardingClientsubsystemLookupr
FileTransferServer)r r l groupnamepasswordgiduserlistr! r! r" r( 6 s
zUnixConchUser.__init__c C s | j dd S )N r+ r r! r! r" getUserGroupIdI s z UnixConchUser.getUserGroupIdc C s | j S N)r/ r? r! r! r" getOtherGroupsL s z UnixConchUser.getOtherGroupsc C
| j d S )N r> r? r! r! r"
getHomeDirO
zUnixConchUser.getHomeDirc C rC )N r> r? r! r! r" getShellR rF zUnixConchUser.getShellc C s t |\}}ddlm} z| j|j|t | j||ft j|d}W n
t y, Y dS w || j
||f< |dkrF| d }dt
d|fS dS )Nr reactor) interfacer< z>L)r unpackGlobal_tcpip_forwardtwisted.internetrJ
_runAsUser listenTCPSSHListenForwardingFactoryconn SSHListenServerForwardingChannel
BaseExceptionr0 getHoststructpack)r data
hostToBind
portToBindrJ listenerr! r! r" global_tcpip_forwardU s*
z"UnixConchUser.global_tcpip_forwardc C sD t |\}}| j||fd }|sdS | j||f= | |j dS )Nr rL )r rM r0 getrO
stopListening)r rX rY rZ r[ r! r! r" global_cancel_tcpip_forwardn s z)UnixConchUser.global_cancel_tcpip_forwardc C s: | j D ]}| |j q| jjd| jt| j d d S )Nz,avatar {username} logging out ({nlisteners}))r
nlisteners)r0 valuesrO r^ _loginfor len)r r[ r! r! r" r w s
zUnixConchUser.logoutc O sD t }t }t }| \}}t d t d t | t | t | zt |}W n t
yB |||fg}Y nw zD|D ]%} | d }
t | dkrV| d pWd}t | dkrb| d pci }|
|i |} qFW t d t d t | t | t | | S t d t d t | t | t | w )Nr rL r! r< ) osgeteuidgetegid getgroupsr@ setegidseteuid setgroupsrB iter TypeErrorrd ) r fargskweuidegidgroupsuidr: ifuncrr! r! r" rO s@
zUnixConchUser._runAsUserN) r$ r% r& r( r@ rB rE rH r\ r_ r rO r! r! r! r" r 5 s
r c @ sn e Zd Ze ZdddZdddZdd Zd d
Zd d Z d
d Z
dd Z dd Z dd Z
dd Zdd ZdS )SSHSessionForUnixConchUserNc C s: |du r
ddl m} || _|| _ddi| _d| _d| _dS )a
Construct an C{SSHSessionForUnixConchUser}.
@param avatar: The L{UnixConchUser} for whom this is an SSH session.
@param reactor: An L{IReactorProcess} used to handle shell and exec
requests. Uses the default reactor if None.
Nr rI PATHz /bin:/usr/bin:/usr/local/bin)rN rJ _reactoravatarenvironptyptyTuple)r r{ rJ r! r! r" r( s
z#SSHSessionForUnixConchUser.__init__rL c C s t sd S | jjjj j}tdt |\}| j
d dd }t }t |}t || d }t
}|r9t jp;t j|_| jj|_||_|dd |_||f|_|rg| jj|_t|d |_|dddf|_t t j } | | | t t j }
|
| |
d S )NLr< rD g .Ar )!utmpr{ rR transportgetPeerhostrV unpacksocket inet_atonr~ timeint UtmpEntry USER_PROCESS DEAD_PROCESSut_typer} pidut_pidut_lineut_idut_tvr ut_user
gethostbyaddrut_host
ut_addr_v6
UtmpRecord UTMP_FILE pututlineendutent WTMP_FILE) r loggedIn ipAddresspackedIpttyNamett1t2entryabr! r! r" addUTMPEntry s0
z'SSHSessionForUnixConchUser.addUTMPEntryc C sF || j d< || _|| _t \}}t|}|| j d< |||f| _d S )NTERMSSH_TTY)r| winSizemodesr} openptyre ttynamer~ )r term
windowSizer masterslaver r! r! r" getPty s
z!SSHSessionForUnixConchUser.getPtyc
C sB | j s
| jd td| j \}}| j }| j }| jj| j d< || j d< || j d< t
j |}| jj
jj }| jj
jj }|j d|j d|j | j d< | | jj||d| g| j |||| j d | _| t| j tj t j d
g| j R | j r| ! |jj"| _#| j$|j_"| jj
jj%d d S ) Nz'tried to get shell without pty, failingzno ptyUSERHOMESHELL
SSH_CLIENT-usePTY4HrL )&r~ rb errorr r{ r@ rE rH r r| re pathbasenamerR r r rU r portgetPtyOwnershiprz spawnProcessr} r fcntlioctlfilenotty
TIOCSWINSZrV rW r r setModeswriteoldWrite
_writeHack
setTcpNoDelay) r protort r: homeDirshell shellExecpeerr r! r! r" openShell s>
&
z$SSHSessionForUnixConchUser.openShellc
C s | j \}}| j }| j pd}|| jd< |d|f}| j jjj }| j jjj } |j d|j
d| j
| jd< | j rD| | j
j|||| j|||| j pSdd| _| j re| | jre| | j jjjd d S ) Nz/bin/shr z-cr r r r rL )r{ r@ rE rH r| rR r r rU r r r~ r rz r r} r r r r )
r r cmdrt r: r r commandr r r! r! r" execCommand s2
z&SSHSessionForUnixConchUser.execCommandc C s t | jd d }| j \}}t t }}t d t d zt | jd || W t | t | d S t | t | w )Nr< rD r )
re statr~ r{ r@ rf rg ri rj chown)r ttyGidrt r: rq rr r! r! r" r s
z*SSHSessionForUnixConchUser.getPtyOwnershipc C s | j }t| }| jD ]n\}}|tjvrq
tj| }t|dkrF|\}}tt|s,q
t t|}|r<|| |B ||< q
|| | @ ||< q
|dkrVt td| |tj
< q
|dkrft td| |tj < q
tt|slq
t t|}t |f|tj
|< q
t| tj| d S )Nr< OSPEEDBISPEED)r} r tcgetattrr r r TTYMODESrd hasattrgetattrr r bytesCC tcsetattrTCSANOW) r r} attrmode modeValuettyModeflagttyAttrttyvalr! r! r" r s.
z#SSHSessionForUnixConchUser.setModesc C s | j r
| j d S d S rA )r}
closeStdinr? r! r! r" eofReceived8 s z&SSHSessionForUnixConchUser.eofReceivedc C s | j r tj| j d r t| j d d }t| j d d| | jrAz| jd W n tt fy6 Y nw | j
| d | j
d d S )Nr< rD r HUPz shell closed)r~ re r existsr r r}
signalProcessOSErrorr loseConnectionr rb rc )r ttyGIDr! r! r" closed< s
z!SSHSessionForUnixConchUser.closedc C s0 || _ t| j tjtjdg| j R d S )Nr ) r r r r} r r r rV rW )r r r! r! r"
windowChangedI s *z(SSHSessionForUnixConchUser.windowChangedc C s\ | j dur't| j d }|tj@ s'|tj@ r'| jjj ddt
| | | dS )zF
Hack to send ignore messages when we aren't echoing.
Nr' ) r} r r r ECHOICANONr{ rR r
sendIgnorerd r )r rX r r! r! r" r M s
z%SSHSessionForUnixConchUser._writeHackrA )rL )r$ r% r& r rb r( r r r r r r r r r r r! r! r! r" rx s
!
rx c @ s e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
dd Z dd Z dd Z
dd Zdd Zdd Zd d Zd d Zd!d" Zd#S )$SFTPServerForUnixConchUserc C s
|| _ d S rA )r{ )r r{ r! r! r" r( Z rF z#SFTPServerForUnixConchUser.__init__c C sr d|v rd|v rt ||d |d d|v r t ||d d|v r5d|v r7t ||d |d f dS dS dS )zl
NOTE: this function assumes it runs as the logged-in user:
i.e. under _runAsUser()
rt r: permissionsatimemtimeN)re r chmodutimer r attrsr! r! r" _setAttrs] s z$SFTPServerForUnixConchUser._setAttrsc C s& |j |j|j|jt|jt|jdS )N)sizert r: r r r )st_sizest_uidst_gidst_moder st_atimest_mtimer sr! r! r" _getAttrsi s z$SFTPServerForUnixConchUser._getAttrsc C s" | j }tjt|jt|S rA )r{ rE re r joinr )r r homer! r! r" _absPaths s
z#SFTPServerForUnixConchUser._absPathc C s i S rA r! )r otherVersionextDatar! r! r"
gotVersionw z%SFTPServerForUnixConchUser.gotVersionc C s t | | |||S rA ) UnixSFTPFiler
)r filenameflagsr r! r! r" openFilez z#SFTPServerForUnixConchUser.openFilec C | |}| jtj|S rA )r
r{ rO re remove)r r r! r! r"
removeFile}
z%SFTPServerForUnixConchUser.removeFilec C s& | |}| |}| jtj||S rA )r
r{ rO re rename)r oldpathnewpathr! r! r"
renameFile
z%SFTPServerForUnixConchUser.renameFilec C s, | |}| jtj|ff| j||ffgS rA )r
r{ rO re mkdirr r r! r! r"
makeDirectory s
z(SFTPServerForUnixConchUser.makeDirectoryc C s | |}| jtj| d S rA )r
r{ rO re rmdirr r r! r! r" removeDirectory s
z*SFTPServerForUnixConchUser.removeDirectoryc C s t | | |S rA )UnixSFTPDirectoryr
r# r! r! r"
openDirectory s z(SFTPServerForUnixConchUser.openDirectoryc C s: | |}|r| jtj|}n| jtj|}| |S rA )r
r{ rO re r lstatr
)r r followLinksr r! r! r" getAttrs s
z#SFTPServerForUnixConchUser.getAttrsc C s | |}| j| j|| d S rA )r
r{ rO r r r! r! r" setAttrs s
z#SFTPServerForUnixConchUser.setAttrsc C r rA )r
r{ rO re readlinkr# r! r! r" readLink r z#SFTPServerForUnixConchUser.readLinkc C s& | |}| |}| jtj||S rA )r
r{ rO re symlink)r linkPath
targetPathr! r! r" makeLink r z#SFTPServerForUnixConchUser.makeLinkc C s t j| |S rA )re r realpathr
r# r! r! r" realPath s z#SFTPServerForUnixConchUser.realPathc C t rA NotImplementedError)r extNamer r! r! r" extendedRequest r z*SFTPServerForUnixConchUser.extendedRequestN)r$ r% r& r( r r
r
r r r r r! r$ r& r) r* r, r0 r2 r7 r! r! r! r" r X s$
r c @ s< e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
S )r c C s || _ d}|t@ tkr|t@ dkrtj}|t@ tkr#|t@ dkr#tj}|t@ tkr2|t@ tkr2tj}|t@ tkr=|tjO }|t @ t krH|tj
O }|t @ t krS|tj O }|t
@ t
kr^|tjO }d|v rj|d }|d= nd}|jtj|||}|r|j|j|| || _d S )Nr r i )serverr r re O_RDONLYO_WRONLYO_RDWRr
O_APPENDr O_CREATr O_TRUNCr O_EXCLr{ rO openr fd)r r8 r r r openFlagsr rA r! r! r" r( s0
zUnixSFTPFile.__init__c C s | j jtj| jS rA )r8 r{ rO re closerA r? r! r! r" rC r zUnixSFTPFile.closec C , | j jtj| j|dfftj| j|ffgS r )r8 r{ rO re lseekrA read)r offsetlengthr! r! r" readChunk zUnixSFTPFile.readChunkc C rD r )r8 r{ rO re rE rA r )r rG rX r! r! r"
writeChunk rJ zUnixSFTPFile.writeChunkc C s | j jtj| j}| j |S rA )r8 r{ rO re fstatrA r
r r! r! r" r) s zUnixSFTPFile.getAttrsc C r3 rA r4 )r r r! r! r" r* r zUnixSFTPFile.setAttrsN) r$ r% r& r( rC rI rK r) r* r! r! r! r" r s r c @ s0 e Zd Zdd Zdd Zdd ZeZdd Zd S )
r% c C s" || _ |jtj|| _|| _d S rA )r8 r{ rO re listdirfilesdir)r r8 directoryr! r! r" r( s
zUnixSFTPDirectory.__init__c C s | S rA r! r? r! r! r" __iter__ r zUnixSFTPDirectory.__iter__c C sb z| j d}W n ty tw | jjtjtj
| j |}t ||}| j
|}|||fS r )rN pop
IndexError
StopIterationr8 r{ rO re r' r r rO r r
)r rn r longnamer r! r! r" __next__ s
zUnixSFTPDirectory.__next__c C s
g | _ d S rA )rN r? r! r! r" rC rF zUnixSFTPDirectory.closeN)r$ r% r& r( rQ rV nextrC r! r! r! r" r% s r% )7__doc__r r, re r} r) r rV r r zope.interfacer
twisted.conchr twisted.conch.avatarr twisted.conch.errorr twisted.conch.interfacesr r r twisted.conch.lsr twisted.conch.sshr
r r twisted.conch.ssh.filetransferr
r r r r r twisted.credr twisted.internet.errorr twisted.loggerr twisted.pythonr twisted.python.compatr r ImportErrorIRealmr r rx r r r% registerAdapterr! r! r! r"
sV i :V1