File manager

3

�fJ)�@szdd
lm
Z

ddlmZ
ddlmZmZ
ddlZddlZddlZddl	Z	ddl
Z
Gdd�dej�ZGdd�dej
j�ZdS)	�)
�absolute_import)
�unicode_literals)�
_�loggerNcs eZ
dZd
Z�f
dd�Z�ZS)�
RepoManage�
repomanagecs,tt
|�j|
|�
|dkrdS|jt�

dS)
N)�superr�__init__Zregister_command�RepoManageCommand)�self�base�cli)
�	__class__�� /usr/lib/python3.6/repomanage.pyr	$s



zRepoManage.__init__)�__name__�
__module__�__qualname__�namer	�
__classcell__rr)
rrr src@s\eZ
dZdZed�
Zdd�Zdd�Zdd�Ze	d	d
��
Z
e	dd��
Zd
d�Ze	dd��
Z
dS)r
rz"Manage a directory of rpm packagesc

Cs,|jj
r(|jjr(|jjtjtjd
�
dS)N)�stdout�stderr)�opts�verbose�quietr
Zredirect_logger�loggingZWARNING�INFO)
rrrr�
pre_configure/s

zRepoManageCommand.pre_configurec
Cs0|jj
r|jjr|jj�
|jj}
d
|
_dS)NT)rrrr
Zredirect_repo_progress�demandsZsack_activation)rrrrr�	configure3s




zRepoManageCommand.configurec
"s@�jj
r �jjr tjjtd
�
�
�
�jj
r@�jjr@tjjtd�
�
�
�jjr`�jjr`tjjtd�
�
�
�jjr|�jjr|d�j_
i}
i}i}t�}t	�jj
�
}y�d}�jjj
|�jj�jjg
d�}|jj�
�jj|�

tjj�
r>�jj�
�jjj�}xH|D]@}	|	j�|kr�|j|	j��

|j|	j�i�j|	j�g�j|	�

q�WWn�tjjk
�
r�


g}
�j�jjd�}
t |
�
dk�
r�tjjtd	�
�
�
�jj!ddd
�
�jj"ddd�
y�jj#|
�jj$j%d
�
Wn0t&k
�
r�


t'j(td�
j)dj*|
�
�
�

YnXYnX�jj+j,t-j.d�
j/�}dd�|j0|j0|d�
d�
j/�D�
}|j1�
x�|D]~}
|
j2|
j3f}||k�rx|
||k�r�||j|
�

n
|
g
||<�j4|
�
}||
k�r�|
|j�j5|
�
�

n�j5|
�
g
|
|<�q@Wg}t�}�jj
�r�xh|j6�D]\\}}|||f}||d�}x6|D].}�j4|�
}x|
|D]}|j|�

�q W�qW�q�Wxb|j7�D]V}t8|j6��
}||d�}x4|D],}x$||D]}|jt|j��
�

�q|W�qnW�qJW�jj�r|xh|j6�D]\\}}|||f}|d|�}x6|D].}�j4|�
}x|
|D]}|j|�

�q�W�q�W�q�Wxb|j7�D]V}t8|j6��
}|d|�}x4|D],}x$||D]}|jt|j��
�

�qTW�qFW�q"W�jj�r�xh|j6�D]\\}}|||f}|d|�}x6|D].}�j4|�
}x|
|D]}|j|�

�q�W�q�W�q�Wt�}xb|j7�D]V}t8|j6��
}||d�}x4|D],}x$||D]}|jt|j��
�

�q2W�q$W�qWxx|j7�D]l}t8|j6��
}|d|�}xJ|D]B}x:||D].}x&|j�D]} | |k�r�|j9| �

�q�W�q�W�q�W�qdW�f
dd�|j0|j0|d�
d�
j/�D�
}!||!}|j1�
�jj:�r$t;dj*|�
�

nx|D]}
t;|
�

�q*WdS)Nz%Pass either --old or --new, not both!z)Pass either --oldonly or --new, not both!z)Pass either --old or --oldonly, not both!TZrepomanage_repo)
Zbaseurlz.rpmr
zNo files to process)�sack�reposF)Zload_system_repoZload_available_repos)
�progresszCould not open {}z, )
�flagsc
Ssg|]}
|
�qSrr)�.0�
xrrr�
<listcomp>osz)RepoManageCommand.run.<locals>.<listcomp>)
Znevra_strict)
Zpkg__neqc
sg|]}
�j|
�
�qSr)
�_package_to_path)r$r%)
rrrr&�s)
Zpkg__eq�
 )<r�new�old�dnf�
exceptions�ErrorrZoldonly�set�intZkeeprr!Zadd_new_repoZconf�pathZ_repoZexpireZ_add_repo_to_sackZWITH_MODULESZ_setup_modular_excludesZ_moduleContainerZgetModulePackagesZ	getRepoID�updateZgetArtifacts�
setdefaultZ
getNameStreamZ
getVersionNum�appendZ	RepoError�_get_file_list�len�resetZ	fill_sackZadd_remote_rpms�outputr"�IOErrorrZwarning�format�joinr �query�hawkeyZIGNORE_MODULAR_EXCLUDESZ	available�filter�sortr�arch�_package_to_nevrar'�keys�values�sorted�addZspace�print)"rZverfileZpkgdictZmodule_dictZall_modular_artifactsZkeepnumZREPOMANAGE_REPOIDZ	repo_confZmodule_packagesZmodule_packageZrpm_listr;Zpackages�pkgZnaZnevraZoutputpackagesZkeepnum_latest_stream_artifacts�
n�
aZevrlistZnewevrs�packageZfpkgZstreams_by_versionZsorted_stream_versionsZnew_sorted_stream_versions�
i�streamZoldevrsZold_sorted_stream_versionsZkeepnum_newer_stream_artifactsZartifactZmodular_packagesr)
rr�run9s�































&
"






















$










$










$






"&






zRepoManageCommand.runc

	Cs�|jd
ddt
d�
d�
|jdddt
d�
d�
|jd	d
dt
d�
d�
|jdd
dt
d�
d�
|jddddt
d�
dtd�
|jddt
d�
d�
dS)Nz-oz--old�
store_truezPrint the older packages)�action�helpz-Oz	--oldonlyz6Print the older packages. Exclude the newest packages.z-nz--newzPrint the newest packagesz-sz--spacez#Space separated output, not newlinez-kz--keepZstoreZKEEPz)Newest N packages to keep - defaults to 1�
)rN�metavarrO�default�typer0zPath to directory)�add_argumentrr/)
�parserrrr�
set_argparser�s
















zRepoManageCommand.set_argparsercCs`g}xVtj
|�
D]H\}}}x<|D]4}tjj|�
d
j�t|
�
kr |jtjj||��

q WqW|S)zJReturn all files in path matching ext

        return list object
        rP)�os�walkr0�splitext�lower�strr3r:)r0ZextZfilelist�root�dirs�files�
frrrr4�s




z RepoManageCommand._get_file_listcCs*t|j
j�
r tjj|jj|
j�S|
jSdS)
N)r5rr!rWr0r:r�location)rrFrrrr'�s

z"RepoManageCommand._package_to_pathc

Cs|j|j
|j|j|jfS)
N)rZepoch�version�releaser?)
rFrrrr@
sz#RepoManageCommand._package_to_nevraN)
r)rrr�aliasesrZsummaryrrrL�staticmethodrVr4r'r@rrrrr
+s

$r
)Z
__future__rrZdnfpluginscorerrr+Zdnf.clirrWr<ZPluginrr
ZCommandr
rrrr�<module>s