
    gh                     @   d dl Z d dlZd dlZd dlZd dlmZ d dlmZmZm	Z	m
Z
mZmZ d dlmZmZmZmZmZmZmZmZmZmZ d dlmZ d dlmZmZmZ d dlmZ  ej@                         Z! ejD                   ejF                  e$            Z%dZ& G d	 d
ejN                        Z(y)    N)exists)AnyDictListOptionalTupleUnion)
apiaptcontractevent_logger
exceptionshttpmessagessecret_managersystemutil)base)ApplicationStatusCanDisableFailureCanDisableFailureReason)status_cache_filez<^linux-image-([\d]+[.-][\d]+[.-][\d]+-[\d]+-[A-Za-z0-9_-]+)$c            	           e Zd ZdZdZdZdZdZdZdZ	e
deeedf   fd       Ze
defd	       Ze
defd
       Ze
dee   fd       Ze
dee   fd       Ze
dee   fd       Ze
dee   fd       ZdefdZdefdZe
ej6                  defd              Z	 d+dedeeee   f   f fdZdefdZ de!jD                  defdZ#defdZ$de!jD                  fdZ%de!jD                  fdZ&de!jD                  fdZ'd Z(d Z)dee*ee+jX                     f   fdZ-d Z.	 d+de/ee0f   d e/ee0f   d!edef fd"Z1	 	 d,de!jD                  d#eee      d$eddfd%Z2de!jD                  ddfd&Z3	 d-d'eee      fd(Z4	 d.de!jD                  d)efd*Z5 xZ6S )/RepoEntitlementz1/etc/apt/sources.list.d/ubuntu-{name}.{extension}z$/etc/apt/preferences.d/ubuntu-{name}z	{}/ubuntuNFTreturnc                      y N selfs    </usr/lib/python3/dist-packages/uaclient/entitlements/repo.pyrepo_pin_priorityz!RepoEntitlement.repo_pin_priority7   s        c                     d}t        j                         j                  }|t        j                  v rd}| j
                  j                  | j                  |      S )Nsourceslist)name	extension)r   get_release_infoseriesr   SERIES_NOT_USING_DEB822repo_file_tmplformatr'   )r    r(   r*   s      r!   	repo_filezRepoEntitlement.repo_file;   sN    	((*11S000I""))tyyI)NNr#   c                      | j                   dz   S )Nz {})repo_url_tmplr   s    r!   repo_policy_check_tmplz&RepoEntitlement.repo_policy_check_tmplC   s    !!E))r#   c                     g }| j                   j                  di       }|r9|j                  di       }t        j                  |j                  dg             }|}|S )zdebs to install on enablemententitlement
directivesadditionalPackages)entitlement_cfggetcopy)r    packagesr3   r4   additional_packagess        r!   r9   zRepoEntitlement.packagesG   s^     **..}bA$r:J"&))3R8# +Hr#   c                 x    | j                   j                  di       j                  di       j                  d      S )Nr3   r4   aptURLr6   r7   r   s    r!   apt_urlzRepoEntitlement.apt_urlX   4       $$]B7Sr"S]	
r#   c                 z    | j                   j                  di       j                  di       j                  dg       S )Nr3   r4   aptSnapshotURLsr=   r   s    r!   snapshot_urlszRepoEntitlement.snapshot_urls`   s8       $$]B7Sr"S"B'	
r#   c                 x    | j                   j                  di       j                  di       j                  d      S )Nr3   r4   suitesr=   r   s    r!   
apt_suiteszRepoEntitlement.apt_suitesh   r?   r#   c                    | j                   j                  d      }|s| j                  j                  d   }| j                   d   j                  di       }|j                  d      sNt	        j
                  | j                        }|j                  || j                        }|r|j                  d      }|s"|}t        j                  d| j                         |S )NresourceTokenmachineTokenr3   obligationsenableByDefaultzWNo resourceToken present in contract for service %s. Using machine token as credentials)r6   r7   machine_token_filemachine_tokenr   UAContractClientcfgget_resource_machine_accessr'   LOGwarningtitle)r    tokenrL   rI   clientmachine_accesss         r!   get_resource_tokenz"RepoEntitlement.get_resource_tokenp   s    $$((9 33AAM ..}=AArK ??#45 "22488<!'!C!C!499" "*..?E%:JJ
 r#   c                     t        j                  t        | j                              }t        j                  |       |S )z%Check if system needs to be rebooted.)installed_pkgs)r   should_rebootsetr9   eventneeds_reboot)r    reboot_requireds     r!   _check_for_rebootz!RepoEntitlement._check_for_reboot   s4     ..t}}-
 	?+r#   c                      y r   r   r   s    r!   repo_key_filezRepoEntitlement.repo_key_file   s     	r#   ignore_dependent_servicesc                    t         |   |      \  }}|du r||fS | j                  s[| j                  rOdt	        t
        j                  t        j                  j                  | j                  | j                              fS ||fS )N)ra   Fentitlement_namerR   )supercan_disableoriginpurger   r   NO_PURGE_WITHOUT_ORIGINr   REPO_PURGE_FAIL_NO_ORIGINr-   rR   )r    ra   resultreason	__class__s       r!   rf   zRepoEntitlement.can_disable   s     ,&? - 
 U?6>!{{tzz!+CC66==)-4:: >   v~r#   c                 r    | j                   d uxr t        | j                         dkD  }| j                  s|syy)Nr         )r9   lenaccess_only)r    will_installs     r!   enable_stepszRepoEntitlement.enable_steps   s8    }}D0KS5G!5K<  r#   progressc                    |j                  t        j                  j                  | j                               | j                  |       | j                  rn| j                  rbt        | j                        dkD  rI|j                  dt        j                  j                  dj                  | j                                     y| j                  |       y)zEnable specific entitlement.

        @return: True on success, False otherwise.
        @raises: UbuntuProError on failure to install suggested packages
        servicer   info r9   T)ru   r   CONFIGURING_APT_ACCESSr-   rR   setup_apt_configsupports_access_onlyrr   rq   r9   emitSKIPPING_INSTALLING_PACKAGESjoininstall_packages)r    ru   s     r!   _perform_enablezRepoEntitlement._perform_enable   s     	++224::2F	
 	h'$$)9)94==!A%99@@!$$--!8 A   !!(+r#   c                     | j                   syy)Nro   rp   )rh   r   s    r!   disable_stepszRepoEntitlement.disable_steps   s    zz  r#   c                    | j                   r| j                  r|j                  dt        j                         |j                  dd       t        j                  | j                        }| j                  ||      syg }g }|D ]S  }t        j                  || j                        }|r|j                  |t        |      f       C|j                  |       U | j                  |||      syt        | d      r| j                          | j                  |       | j                   rg| j                  r[|j                  t        j                   j#                  | j$                               | j'                         | j)                         y)Nry    F)exclude_originremove_packagesrR   T)rh   rg   r   r   PURGE_EXPERIMENTALr    get_installed_packages_by_originpurge_kernel_checkget_remote_versions_for_packageappendmaxprompt_for_purgehasattrr   remove_apt_configru   PURGING_PACKAGESr-   rR   execute_reinstallexecute_removal)r    ru   repo_origin_packagespackages_to_reinstallpackages_to_removepackagealternativess          r!   _perform_disablez RepoEntitlement._perform_disable   s`   ::$++MM&("="=>MM&"%#&#G#G$  **+?J$&!!#/ 7"BBDKK    *00 #l"34 '--g67 (("$98 4*+  "x(::$++))00tzz0B ""#89  !34r#   c                 H   g }|D ]I  }t        j                  t        |j                        }|s*|j	                  |j                  d             K |rJ|j                         st        j                         |j                  dt        j                  j                  | j                               |j                  ddj                  |             t        j                          j"                  }|j                  dt        j$                  j                  |             t        j&                         }|D cg c]  }||vr|
 }	}|	s!|j                  dt        j(                         y|j                  dt*        j,                  dt        j.                  ifg       y	c c}w )
a*  
        Checks if the purge operation involves a kernel.

        When package called 'linux-image-*' is in the package list, warn the
        user that a kernel is being removed. Then, show the user what the
        current kernel is.

        If the current kernel is to be removed, and there are no other valid
        Ubuntu Kernels installed in the system, return False to abort the
        operation.

        If there is another Ubuntu kernel - besides the one installed - then
        prompt the user for confirmation before proceeding.
           ry   rw   rz   )kernel_versionFmessage_operationmsgT)researchRE_KERNEL_PKGr'   r   groupis_interactiver   #NonInteractiveKernelPurgeDisallowedr   r   PURGE_KERNEL_REMOVALr-   rR   r   r   get_kernel_infouname_releasePURGE_CURRENT_KERNELget_installed_ubuntu_kernelsPURGE_NO_ALTERNATIVE_KERNELr   prompt_for_confirmationPURGE_KERNEL_CONFIRMATION)
r    package_listru   linux_image_versionsr   mcurrent_kernelinstalled_kernelsversionalternative_kernelss
             r!   r   z"RepoEntitlement.purge_kernel_check  s}     "# 	8G		-6A$++AGGAJ7	8   **, DDFFMM--44TZZ4H MM&#((+?"@A#335CCNMM--44#1 5  !' C C E  1#"66 # # 'fh&J&JKMM# 44 B BC )#s   9Fc                    d}|r_|j                  dt        j                         |j                  dt        j                  |D cg c]  }|j
                   c}             d}|rd|j                  dt        j                         |j                  dt        j                  |D cg c]  \  }}|j
                   c}}             d}|r3|j                  dt        j                  dt        j                  ifg       yc c}w c c}}w )NFry   Tr   r   )	r   r   WARN_PACKAGES_REMOVALr   create_package_list_strr'   WARN_PACKAGES_REINSTALLr   PROCEED_YES_NO)r    r   r   ru   promptr   _s          r!   r   z RepoEntitlement.prompt_for_purgeF  s     MM&("@"@AMM,,1CDgW\\D F MM&("B"BCMM,,6KLlwW\\L FMM# 44 7 78 3 E Ms   D &Dc                     t        j                         }|D cg c]  }|j                  |v r|j                   }}|r5t        j                  |t        j
                  j                  |             y y c c}w )Nr{   )r   get_installed_packages_namesr'   purge_packagesr   UNINSTALLING_PACKAGES_FAILEDr-   )r    r   installed_packagesr   	to_removes        r!   r   zRepoEntitlement.execute_removalm  s    
 !==? .
||11 LL
	 

 55<<& =  
s   !A4c                     t        j                         }|D cg c]9  \  }}|j                  |v r&dj                  |j                  |j                        ; }}}|rt        j
                  |       y y c c}}w )Nz{}={})r   r   r'   r-   ver_strreinstall_packages)r    r   r   r   r   to_reinstalls         r!   r   z!RepoEntitlement.execute_reinstall  ss     !==? '<
"'||11 NN7<<9
 

 ""<0 
s   >A4c                    t         j                  t        j                  j	                  | j
                        f}| j                  }|j                  di       j                  di       }|j                  d      }|s:t         j                  t        j                  j	                  | j
                        fS |j                  d      }|s:t         j                  t        j                  j	                  | j
                        fS t        j                  t        j                        }|D ]p  }t        j                  | j                  j	                  ||      |      }|s6t         j                   t        j"                  j	                  | j
                        f} n | j$                  rc| j&                  D ]T  }	t        j(                  |	      rt         j                  t        j*                  j	                  | j,                  |	      fc S  |S )Nr   r3   r4   r<   rD   )	error_msg)rx   r   )r   DISABLEDr   SERVICE_NOT_CONFIGUREDr-   rR   r6   r7   NO_APT_URL_FOR_SERVICENO_SUITES_FOR_SERVICEr   get_apt_cache_policyAPT_POLICY_FAILEDr   r   r1   ENABLEDSERVICE_IS_ACTIVEcheck_packages_are_installedr9   is_installed SERVICE_DISABLED_MISSING_PACKAGEr'   )
r    current_statusr6   r4   repo_urlrepo_suitespolicysuiteservice_matchr   s
             r!   application_statusz"RepoEntitlement.application_status  s    &&++222D

 ..$((;??"

 >>(+!**//66TZZ6H  !nnX.!**..55DJJ5G 
 ))H4N4NO  		EII++228UCVM %--..55DJJ5G" 		 ,,== ''0)22 AAHH$(IIw I   r#   c                     | j                   }t        d t        j                  |      j	                         j                  d      D              ry|syt        |t        j                  |      v       S )zCheck if apt url delta should be applied.

        :param apt_url: string containing the apt url to be used.

        :return: False if apt url is already found on the source file.
                 True otherwise.
        c              3   >   K   | ]  }|j                  d         yw)#N)
startswith).0lines     r!   	<genexpr>z<RepoEntitlement._check_apt_url_is_applied.<locals>.<genexpr>  s!      
 OOC 
s   
FT)r.   allr   	load_filestripsplitbool)r    r>   apt_files      r!   _check_apt_url_is_appliedz)RepoEntitlement._check_apt_url_is_applied  sm     >>  
((288:@@F
 
   Gv//99::r#   orig_accessdeltasallow_enablec                    t         |   |||      ry|j                  di       }|j                  di       }|j                  d      }|j                  d      }t        j                         }|r|r| j                         }	n| j                         \  }	}
|	t        j                  k(  ry| j                  |      st        j                  d| j                  |       t        j                  t        j                  j!                  | j                               |j                  di       }|j                  di       j                  d      }|r+t#        j$                  | j&                  || j(                         | j+                  t-        j.                                | j1                  t-        j.                                |r}t        j                  d	|       t        j                  t        j2                  j!                  d
j5                  |                   | j7                  t-        j.                         |       y)a1  Process any contract access deltas for this entitlement.

        :param orig_access: Dictionary containing the original
            resourceEntitlement access details.
        :param deltas: Dictionary which contains only the changed access keys
        and values.
        :param allow_enable: Boolean set True if allowed to perform the enable
            operation. When False, a message will be logged to inform the user
            about the recommended enabled service.

        :return: True when delta operations are processed; False when noop.
        Tr3   r4   r<   r5   Fz.New aptURL, updating %s apt sources list to %srw   z%New additionalPackages, installing %r, r{   )r   )re   process_contract_deltasr7   r   read"_check_application_status_on_cacher   r   r   r   rP   ry   r'   r[   r   REPO_UPDATING_APT_SOURCESr-   r   remove_auth_apt_repor.   rB   r   r
   ProgressWrapperr}    REPO_REFRESH_INSTALLING_PACKAGESr   r   )r    r   r   r   delta_entitlementdelta_directivesdelta_apt_urldelta_packagesstatus_cacher   r   orig_entitlementold_urlrm   s                r!   r   z'RepoEntitlement.process_contract_deltas  s   $ 7*;M"JJ}b9,00rB(,,X6)--.BC(--/!%!H!H!J$($;$;$=!!2!;!;;--m<HH@		
 JJ2299$))9L  +}bA&**<<@@JG((NNGT-?-? ""3#6#6#89!!#"5"5"78HH<nMJJ99@@!YY~6 A 
 !!##%N "  r#   r   cleanup_on_failurec                    |s| j                   }|sy|j                  d| j                  j                  d             	 | j	                  |       |j                  t        j                  j                  | j                               | j                  r	ddi}g d}nd}g }	 t!        j"                  |||       y# t
        j                  $ r' |r#| j                  t        j                                 w xY w# t
        j                  $ rU |rQt$        j'                  d	j                  | j(                               | j                  t        j                                 w xY w)
zInstall contract recommended packages for the entitlement.

        :param package_list: Optional package list to use instead of
            self.packages.
        :param cleanup_on_failure: Cleanup apt files if apt install fails.
        Nr   pre_installr   DEBIAN_FRONTENDnoninteractive)z--allow-downgradesz$-o Dpkg::Options::="--force-confdef"z$-o Dpkg::Options::="--force-confold")r9   apt_optionsoverride_env_varsz.Apt install failed, removing apt config for {})r9   r   	messagingr7   _update_sources_listr   UbuntuProErrorr   r
   r   ru   r   INSTALLING_SERVICE_PACKAGESr-   rR   apt_noninteractiver   run_apt_install_commandrP   ry   r'   )r    ru   r   r   r  r  s         r!   r   z RepoEntitlement.install_packages  sC    ==L)4>>+=+=m+LM	%%h/ 	0077djj7I	
 ""!24D EK !%K	''%'"3+ (( 	!&&s':':'<=	4 (( 	!DKK		
 &&s':':'<=	s   B; "C8 ;:C58A(E c                 p	   d}d}d}| j                   j                  s| j                   j                  rt        j                  d| j                   j                  t        j
                        }t        j                  d| j                   j                  t        j                        }t        j                  j                  }n| j                   j                  s| j                   j                  rt        j                  d| j                   j                  t        j
                        }t        j                  d| j                   j                  t        j                        }t        j                  j                  }t        j                  |||       | j                  }| j                  }|d   j!                  di       }| j#                         }|j!                  d      }	|	s t%        j&                  | j(                        |j!                  d	      }
|
s t%        j*                  | j(                        |j!                  d
      }|s t%        j,                  | j(                        | j.                  r| j0                  s+t%        j2                  | j(                  | j4                        | j6                  j9                  | j(                        }t        j:                  ||
| j0                  | j.                         g }t=        t        j>                        s|jA                  d       t=        t        jB                        s|jA                  d       |rV|jE                  dtF        jH                  j9                  djK                  |                   	 t        jL                  |       t        jV                  || jX                  j9                  |
      ||| jZ                  | j\                         |j_                  tF        j`                  j9                  | j4                               	 t        jb                  |       y# t$        jN                  $ r% | jQ                  tS        jT                                 w xY w# t$        jN                  $ r' | jQ                  tS        jT                         d        w xY w)zSetup apt config based on the resourceToken and directives.
        Also sets up apt proxy if necessary.

        :raise UbuntuProError: on failure to setup any aspect of this apt
           configuration
        Nr   https)
http_proxyhttps_proxyproxy_scoper3   r4   aptKeyrd   r<   rD   rc   r'   zapt-transport-httpszca-certificatesry   r   r{   F)run_apt_update)2rN   global_apt_http_proxyglobal_apt_https_proxyr   validate_proxyPROXY_VALIDATION_APT_HTTP_URLPROXY_VALIDATION_APT_HTTPS_URLr   AptProxyScopeGLOBALua_apt_http_proxyua_apt_https_proxyUACLIENTsetup_apt_proxyr.   r6   r7   rV   r   RepoNoAptKeyr'   MissingAptURLDirectiveRepoNoSuitesr"   rg   RepoPinFailNoOriginrR   repo_pref_file_tmplr-   add_ppa_pinningr   APT_METHOD_HTTPS_FILEr   CA_CERTIFICATES_FILEr   r   INSTALLING_PACKAGESr   r
  r  r   r
   r   add_auth_apt_repor0   r`   rB   ru   APT_UPDATING_LISTupdate_sources_list)r    ru   r  r  scoperepo_filenameresource_cfgr4   rS   r  r   r   repo_pref_fileprerequisite_pkgss                 r!   r}   z RepoEntitlement.setup_apt_configX  s    
88))TXX-L-L,,..22J
 --//33K
 %%,,EXX''488+F+F,,**22J
 --++33K
 %%..E!{	
 ++!-044\2F
''))))499EE>>(+33TYYOO nnX.))499EE!!;; 44%)YY**  "55<<$))<LN&&	 c//0$$%:;c../$$%67MM,,33!YY'89 4 ++5FG 	%%h/	
 	(44;;;LM	##M2# ,, &&s':':'<=$ (( 	""3#6#6#8"O	s   Q  *Q;  8Q8;:R5override_snapshot_urlsc                    ||}n| j                   }| j                         }| j                  j                  di       j                  di       j                  d      }| j                  j                  |      }	 |j                  d      \  }}t        j                  j                  |       |g|z   D ]  }|st        j                  |||        y # t        $ r d}|}Y Tw xY w)Nr3   r4   r<   :bearer)rB   rV   r6   r7   r0   r-   r   
ValueErrorr   secrets
add_secretr   add_apt_auth_conf_entry)r    r0  rB   credentialsr   usernamepasswordurls           r!   update_apt_authzRepoEntitlement.update_apt_auth  s     "-2M ..M--/  $$]B7Sr"S] 	
 %%,,X6	#!,!2!23!7Hh 	))(3:- 	EC++C8D	E	  	#H"H	#s   9C C"!C"r  c                 v   t        j                         j                  }| j                  }| j                  j                         | j                     j                  di       }|j                  di       }|j                  d      }|s t        j                  | j                        | j                  j                  |      }|j                  t        j                  j                  | j                               t!        j"                  ||| j$                  | j&                         t!        j(                  ||       | j*                  r;| j,                  j                  | j                        }t        j.                  |       |r4|j                  t        j0                         t!        j2                          yy)zRemove any repository apt configuration files.

        :param run_apt_update: If after removing the apt update
            command after removing the apt files.
        r3   r4   r<   r  r   r  N)r   r)   r*   r.   rK   entitlementsr'   r7   r   r   r0   r-   ru   r   REMOVING_APT_CONFIGURATIONrR   r   r   rB   r`   remove_apt_list_filesr"   r#  ensure_file_absentAPT_UPDATING_LISTSrun_apt_update_command)	r    ru   r  r*   r,  r3   access_directivesr   r.  s	            r!   r   z!RepoEntitlement.remove_apt_config  s[    ((*11--::<TYYGKK2
 (OOL"=$((233TYYOO%%,,X6//66TZZ6H	
 	  8T%7%79K9K	
 	!!(F3!!!55<<$))<LN%%n5h99:&&( r#   )F)NTr   )T)7__name__
__module____qualname__r,   r#  r0   rg   r	  r   supports_purgepropertyr	   intstrr"   r.   r1   r   r9   r   r>   rB   rE   rV   r   r^   abcabstractmethodr`   r   r   rf   rt   r
   r   r   r   r   r   r   r   r   r   r   NamedMessager   r   r   r   r   r   r}   r<  r   __classcell__)rm   s   @r!   r   r   $   s   HN@M F  $)  N 5c4#8   O3 O O * * * $s)    
# 
 
 
tCy 
 
 
HSM 
 
C 84  s    16)-	tX/00	1,c (;(;  .s *)<)< *X?9L9L ?B% %%	%N&1/	 (8+@+@"AA	B/b;< #	C#s(^C S#XC 	C
 
CP -1#'	9%%9 tCy)9 !	9
 
9vd)<)< d dN =AE&.tCy&9E6  $$)%%$) $)r#   r   ))rL  r8   loggingr   os.pathr   typingr   r   r   r   r   r	   uaclientr
   r   r   r   r   r   r   r   r   r   uaclient.entitlementsr   (uaclient.entitlements.entitlement_statusr   r   r   uaclient.files.state_filesr   get_event_loggerr[   	getLoggerreplace_top_level_logger_namerE  rP   r   UAEntitlementr   r   r#   r!   <module>r[     s    
   	  : :   ' 
 9%%%'g:::8DE PV)d(( V)r#   