ó ¼S]c@@s@dZddlmZddlmZmZddlmZddlZddl Z ddl m Z ddl m Z ddl mZdd lmZdd lmZd „Zd efd „ƒYZd„Zd„Zdefd„ƒYZdefd„ƒYZeƒZdeeƒfd„ƒYZdefd„ƒYZdS(s/Types related to project requirement providers.i(tabsolute_import(tABCMetatabstractmethod(tdeepcopyN(t conda_api(tlogged_subprocess(twith_metaclass(tmakedirs_ok_if_exists(t SimpleStatuscC@s%tjjtjj|jƒd|ƒS(Ntservices(tostpathtjointdirnametfilename(tlocal_state_filet relative_name((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyt_service_directorystProvideContextcB@steZdZd„Zd„Zd„Zed„ƒZed„ƒZed„ƒZ ed„ƒZ ed„ƒZ RS( sSA context passed to ``Provider.provide()`` representing state that can be modified.cC@s:||_||_||_||_||_||_dS(s`Create a ProvideContext. Args: environ (dict): environment variables to be read and modified local_state_file (LocalStateFile): to store any created state status (RequirementStatus): current status mode (str): one of PROVIDE_MODE_PRODUCTION, PROVIDE_MODE_DEVELOPMENT, PROVIDE_MODE_CHECK N(tenviront_local_state_filet_default_env_spec_namet_statust_modet _frontend(tselfRRtdefault_env_spec_nametstatustmodetfrontend((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyt__init__s     cC@s t|j|ƒ}t|ƒ|S(s7Create a directory in PROJECT_DIR/services with the given name. The name should be unique to the ServiceRequirement creating the directory, so usually the requirement's env var. Args: relative_name (str): name to distinguish this dir from other service directories (RRR(RRR ((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pytensure_service_directory.s  cC@s]|jj|ƒ}t|ƒ}||ƒ}||krY|jj||ƒ|jjƒn|S(sáRun a function which takes and potentially modifies the state of a service. If the function modifies the state it's given, the new state will be saved and passed in next time. Args: service_name (str): the name of the service, should be specific enough to uniquely identify the provider func (function): function to run, passing it the current state Returns: Whatever ``func`` returns. (Rtget_service_run_stateRtset_service_run_statetsave(Rt service_nametfunct old_statetmodifiedtresult((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyttransform_service_run_state;s   cC@s|jS(s&Get the current ``RequirementStatus``.(R(R((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRQscC@s|jS(sGet the LocalStateFile.(R(R((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRVscC@s|jS(sGet the default env spec.(R(R((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyR[scC@s|jS(sŽGet flavor of provide. Value should be ``PROVIDE_MODE_DEVELOPMENT``, ``PROVIDE_MODE_PRODUCTION``, or ``PROVIDE_MODE_CHECK``. (R(R((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyR`scC@s|jS(sGet the current ``Frontend``.(R(R((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRhs( t__name__t __module__t__doc__RRR(tpropertyRRRRR(((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRs  cC@s|jƒ}||kr/tdtdd|ƒSg}||}d|kr§|d}xO|D]D}tj|ƒ}|dkr\|jd|t|ƒ|fƒq\q\Wn|j|tƒƒ|j ƒ|rçtdt dd|d|ƒStdtdd |ƒSd S( s±Run any shutdown commands from the local state file for the given service. Also remove the shutdown commands from the file. Args: local_state_file (LocalStateFile): local state service_name (str): the name of the service, usually a variable name, should be specific enough to uniquely identify the provider Returns: a `Status` instance potentially containing errors tsuccesst descriptionsNothing to do to shut down %s.tshutdown_commandsis1Shutting down %s, command %s failed with code %d.s Shutdown commands failed for %s.terrorssSuccessfully shut down %s.N( tget_all_service_run_statesRtTrueRtcalltappendtreprR!tdictR"tFalse(RR#t run_statesR0tstatetcommandstcommandtcode((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pytshutdown_service_run_statens"       * cC@slt||ƒ}ytjd|ƒWntk r6nXytjtjj|ƒƒWntk rgnXdS(s{Delete a directory in PROJECT_DIR/services with the given name. The name should be unique to the ServiceRequirement creating the directory, so usually the requirement's env var. IF this fails, it does so silently (returns no errors). Args: relative_name (str): name to distinguish this dir from other service directories Returns: None R N(RtshutiltrmtreetOSErrorR trmdirR R (RRR ((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pytdelete_service_directory“s  tProviderAnalysiscB@sDeZdZd„Zed„ƒZed„ƒZed„ƒZRS(s¼A Provider's preflight check snapshotting the state prior to ``provide()``. Instances of this class are immutable, and are usually created as part of a ``RequirementStatus``. cC@s%t|ƒ|_||_||_dS(sCreate a ProviderAnalysis.N(Rt_configt_missing_env_vars_to_configuret_missing_env_vars_to_provide(Rtconfigtmissing_env_vars_to_configuretmissing_env_vars_to_provide((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRµs cC@s|jS(s5Get the configuration dict from the time of analysis.(RD(R((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRG»scC@s|jS(sRGet the env vars we were missing in order to configure, from the time of analysis.(RE(R((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRHÀscC@s|jS(sPGet the env vars we were missing in order to provide, from the time of analysis.(RF(R((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRIÅs(R)R*R+RR,RGRHRI(((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRC®s  t ProvideResultcB@sDeZdZdd„Zdd„Zed„ƒZed„ƒZ RS(s‡A Provider's results from the ``provide()`` call. Instances of this class are immutable, and are returned from ``provide()``. cC@s"|dkrg}n||_dS(sCreate a ProvideResult.N(tNonet_errors(RR0((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRÑs  cC@sC|dkrg}nt|ƒdkr+|Std|j|ƒSdS(s.Copy this result, appending additional errors.iR0N(RKtlenRJRL(RR0((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pytcopy_with_additions×s   cC@s|jS(sGGet any fatal errors that occurred during provide() preventing success.(RL(R((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyR0áscC@stS(sMGet an empty ProvideResult (currently a singleton since these are immutable).(t_empty_provide_result(tcls((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pytemptyæsN( R)R*R+RKRRNR,R0t classmethodRQ(((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRJËs   tProvidercB@sneZdZed„ƒZed„ƒZed„ƒZd„Zd„Zed„ƒZ edd„ƒZ RS( s6A Provider can take some action to meet a Requirement.cC@sdS(sHGet a list of unset environment variable names that must be set before configuring this provider. Args: requirement (Requirement): requirement instance we are providing for environ (dict): current environment variable dict local_state_file (LocalStateFile): local state file N((Rt requirementRR((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRHós cC@sdS(s@Get a list of unset environment variable names that must be set before calling provide(). Args: requirement (Requirement): requirement instance we are providing for environ (dict): current environment variable dict local_state_file (LocalStateFile): local state file N((RRTRR((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRIþs cC@sdS(s7Read a config dict from the local state file for the given requirement. You can think of this as the GET returning a web form for configuring the provider. And in fact it was once used for that, though we deleted the html stuff now. The returned 'config' has a 'source' field which was essentially a selected radio option for where to get the requirement, and other fields are entry boxes underneath each radio option. This method still exists in the code in case we want to do a textual version (or a new HTML version, but probably outside of the anaconda-project codebase). See also UI_MODE_TEXT_ASK_QUESTIONS in the cli code. Args: requirement (Requirement): the requirement we're providing environ (dict): current environment variables local_state_file (LocalStateFile): file to read from default_env_spec_name (str): the fallback env spec name overrides (UserConfigOverrides): user-supplied forced config N((RRTRRRt overrides((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyt read_config scC@sdS(s¾Set some config values in the state file (should not save the file). You can think of this as the POST submitting a web form for configuring the provider. And in fact it was once used for that, though we deleted the html stuff now. Args: requirement (Requirement): the requirement we're providing environ (dict): current environment variables local_state_file (LocalStateFile): file to save to default_env_spec_name (str): default env spec name for this prepare overrides (UserConfigOverrides): if any values in here change, delete the override values (dict): dict from string to string N((RRTRRRRUtvalues((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pytset_config_values_as_strings%sc C@s^|j|||||ƒ}|j|||ƒ}|j|||ƒ}td|d|d|ƒS(s)Analyze whether and how we'll be able to provide the requirement. This is used to show the situation in the UI, and also to consolidate all IO-type work in one place (inside Requirement.check_status()). Returns: A ``ProviderAnalysis`` instance. RGRHRI(RVRHRIRC( RRTRRRRURGtmissing_to_configuretmissing_to_provide((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pytanalyze8s cC@sdS(sŸExecute the provider, fulfilling the requirement. The implementation should read and modify the passed-in ``environ`` rather than accessing the OS environment directly. Args: requirement (Requirement): requirement we want to meet context (ProvideContext): context containing project state Returns: a ``ProvideResult`` instance N((RRTtcontext((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pytprovideJscC@sdS(sŽUndo the provide, cleaning up any files or processes we created. The requirement may still be met after this, if our providing wasn't really needed. Args: requirement (Requirement): requirement we want to de-provide environ (dict): current env vars, often from a previous prepare local_state_file (LocalStateFile): the local state overrides (UserConfigOverrides): overrides to state requirement_status (RequirementStatus or None): requirement status if available Returns: a `Status` instance describing the (non)success of the unprovision N((RRTRRRUtrequirement_status((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyt unprovide\sN( R)R*R+RRHRIRVRXR[R]RKR_(((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRSðs    tEnvVarProvidercB@steZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z d d „ZRS( sEMeets a requirement for an env var by letting people set it manually.cC@s|jd|jgddƒS(Nt variablestdefault(t get_valuetenv_varRK(RRTR((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyt_local_state_overridesscC@s|jd|jgddƒS(Ntdisabled_variablesRb(RcRdRK(RRTR((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyt_disabled_local_state_overridevscC@s*|j|ƒdk rdStjƒfSdS(s*Override superclass to require env prefix.N((t_get_env_prefixRKRtconda_prefix_variable(RRTRR((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRHyscC@s|j|||ƒS(s*Override superclass to require env prefix.(RH(RRTRR((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRI€scC@s|jtjƒdƒS(N(tgetRRiRK(RR((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyRh„sc C@sJtƒ}d}|jrfddljj}|j|ƒ} | dkrNd}qf|j| |jƒ}n|dkr‡|j ||ƒ}n|j ||ƒ} |dko®| dk } | rÀ| }n|dk rÙ||dd|j krð|j d}|dk rð||j|jtanaconda_project.internalRRt#anaconda_project.internal.metaclassRt"anaconda_project.internal.makedirsRt'anaconda_project.internal.simple_statusRRtobjectRR=RBRCRJRORSR`(((sNlib/python2.7/site-packages/anaconda_project/requirements_registry/provider.pyts&   S % " €