dddlZddlmZddlmZddlmZddlmZGdde Z Gdd e Z Gd d eZ Gd d e Z Gdde Zy)N)logger) AgentGlobals) AgentError)textutilceZdZdZdZdZy)GoalStateChannel WireServer HostGAPluginEmptyN)__name__ __module__ __qualname__r r r W/usr/lib/python3/dist-packages/azurelinuxagent/common/protocol/extensions_goal_state.pyrrsJ!L ErrceZdZdZdZdZy)GoalStateSourceFabric FastTrackr N)r r rrrr rrrrr s FI Errc$eZdZdZdfd ZxZS)VmSettingsParseErrorz8 Error raised when the VmSettings are malformed cJtt| ||||_||_yN)superr__init__etagvm_settings_text)selfmessagerrinner __class__s rrzVmSettingsParseError.__init__*s$ "D27EB 0rr)r r r__doc__r __classcell__r!s@rrr&s11rrcLeZdZdZdZedZedZejdZedZ edZ edZ ed Z ed Z ed Zed Zed ZdZedZedZedZedZdZdZedZedZy)ExtensionsGoalStatea ExtensionsGoalState represents the extensions information in the goal state; that information can originate from ExtensionsConfig when the goal state is retrieved from the WireServe or from vmSettings when it is retrieved from the HostGAPlugin. NOTE: This is an abstract class. The corresponding concrete classes can be instantiated using the ExtensionsGoalStateFactory. cd|_yNF _is_outdatedrs rrzExtensionsGoalState.__init__8s !rct)z Returns a string that includes the incarnation number if the ExtensionsGoalState was created from ExtensionsConfig, or the etag if it was created from vmSettings. NotImplementedErrorr+s ridzExtensionsGoalState.id;s "##rc|jS)a  A goal state can be outdated if, for example, the VM Agent is using Fast Track and support for it stops (e.g. the VM is migrated to a node with an older version of the HostGAPlugin) and now the Agent is fetching goal states via the WireServer. r)r+s r is_outdatedzExtensionsGoalState.is_outdatedCs    rc||_yrr)rvalues rr1zExtensionsGoalState.is_outdatedKs !rctrr-r+s rsvd_sequence_numberz'ExtensionsGoalState.svd_sequence_numberO !##rctrr-r+s r activity_idzExtensionsGoalState.activity_idSr7rctrr-r+s rcorrelation_idz"ExtensionsGoalState.correlation_idWr7rctrr-r+s rcreated_on_timestampz(ExtensionsGoalState.created_on_timestamp[r7rct)z^ Whether the goal state was retrieved from the WireServer or the HostGAPlugin r-r+s rchannelzExtensionsGoalState.channel_ "##rct)zM Whether the goal state originated from Fabric or Fast Track r-r+s rsourcezExtensionsGoalState.sourcefr@rctrr-r+s rstatus_upload_blobz&ExtensionsGoalState.status_upload_blobmr7rctrr-r+s rstatus_upload_blob_typez+ExtensionsGoalState.status_upload_blob_typeqr7rctrr-r3s r_set_status_upload_blob_typez0ExtensionsGoalState._set_status_upload_blob_typeus !##rctrr-r+s rrequired_featuresz%ExtensionsGoalState.required_featuresxr7rctrr-r+s ron_holdzExtensionsGoalState.on_hold|r7rctrr-r+s ragent_familiesz"ExtensionsGoalState.agent_familiesr7rctrr-r+s r extensionszExtensionsGoalState.extensionsr7rct)z Returns the raw text (either the ExtensionsConfig or the vmSettings) with any confidential data removed, or an empty string for empty goal states. r-r+s rget_redacted_textz%ExtensionsGoalState.get_redacted_texts "##rc|jdvr2tjd|j|j dyy)zL Does validations common to vmSettings and ExtensionsConfig ) BlockBlobPageBlobz7Status Blob type '{0}' is not valid, assuming BlockBlobrTN)rFrinforDrHr+s r_do_common_validationsz*ExtensionsGoalState._do_common_validationss=  ' '/H H KKQSWSjSj k  - -k : Irctjddddd}|}|dvr> tjjtjt|dz z}t||}|jt jjS#t$r3}t j dtj|Yd}~ld}~wwxYw) z Takes 'ticks', a string indicating the number of ticks since midnight 0001-01-01 00:00:00, and returns a UTC timestamp (every tick is 1/10000000 of a second). ilrNi)secondszCan't parse ticks: {0}N) datetimemin timedeltafloat Exceptionrverboserformat_exceptionmaxstrftimeLoggerLogTimeFormatInUTC) ticks_stringminimum as_date_time exceptions r_ticks_to_utc_timestampz+ExtensionsGoalState._ticks_to_utc_timestamps ##D!Q15 z ) _'0044x7I7IRWXdRehoRo7pp <1 $$V]]%E%EFF  _79R9RS\9]^^ _s=B C)C  Cc.|dvrtjS|S)z Takes 'id', a string indicating an ID, and returns a null GUID if the string is None or empty; otherwise return 'id' unchanged rZr GUID_ZERO) id_strings r _string_to_idz!ExtensionsGoalState._string_to_ids  ")) )rN)r r rr"rpropertyr/r1setterr6r9r;r=r?rBrDrFrHrJrLrNrPrRrW staticmethodrlrqrrrr&r&0sw"$$!!""$$$$$$$$$$ $$ $$$$$$$$$$$$$$ ;GG rr&c eZdZfdZedZedZedZedZedZ edZ edZ ed Z ed Z ed Zd Zed ZedZedZedZdZxZS)EmptyExtensionsGoalStatecdtt| dj||_||_y)Nzincarnation_{0})rrvrformat_id _incarnation)r incarnationr!s rrz!EmptyExtensionsGoalState.__init__s+ &68$++K8'rc|jSr)ryr+s rr/zEmptyExtensionsGoalState.ids xxrc|jSrrzr+s rr{z$EmptyExtensionsGoalState.incarnation   rc|jSrr~r+s rr6z,EmptyExtensionsGoalState.svd_sequence_numberrrc"tjSrrnr+s rr9z$EmptyExtensionsGoalState.activity_id%%%rc"tjSrrnr+s rr;z'EmptyExtensionsGoalState.correlation_idrrc6tjjSr)r]r^r+s rr=z-EmptyExtensionsGoalState.created_on_timestamps  $$$rc"tjSr)rr r+s rr?z EmptyExtensionsGoalState.channels%%%rc"tjSr)rr r+s rrBzEmptyExtensionsGoalState.sources$$$rcyrrr+s rrDz+EmptyExtensionsGoalState.status_upload_blobrcyrrr+s rrFz0EmptyExtensionsGoalState.status_upload_blob_typerrctd)NzXEmptyExtensionsGoalState is immutable; cannot change the value of the status upload blob) TypeErrorr3s rrHz5EmptyExtensionsGoalState._set_status_upload_blob_typesrssrcgSrrr+s rrJz*EmptyExtensionsGoalState.required_features rcyr(rr+s rrLz EmptyExtensionsGoalState.on_holdsrcgSrrr+s rrNz'EmptyExtensionsGoalState.agent_familiesrrcgSrrr+s rrPz#EmptyExtensionsGoalState.extensionsrrcyrZrr+s rrRz*EmptyExtensionsGoalState.get_redacted_textsr)r r rrrrr/r{r6r9r;r=r?rBrDrFrHrJrLrNrPrRr#r$s@rrvrvs+( !!!!&&&&%%&&%%trrv)r]azurelinuxagent.commonr#azurelinuxagent.common.AgentGlobalsr azurelinuxagent.common.exceptionrazurelinuxagent.common.utilsrobjectrrrr&rvrrrrsX$)<71v f 1:1&DB2Br