ó ÍÿŠTc@s˜ddlZddlmZddlmZmZmZddlmZddl m Z ddl m Z de fd„ƒYZ d efd „ƒYZdS( iÿÿÿÿN(tencode_dict_if_needed(tComponentConnectortComponentPublishertremote(tUserManagement(t ManagerPlugin(tRemoteUserMonitorConnectort UserManagercBs³eZdZddd„Zd„Zd„Zed„ƒZd„Z d„Z d„Z d „Z d „Z d „Zd „Zd „Zd„Zd„Zd„Zd„Zd„ZRS(t usermanagers /etc/shadowcCs•|p tƒ|_||_i |jd6|jd6|jd6|jd6|jd6|jd6|j d6|j d6|j d 6|j d 6|_ d|_dS( Nsadd-users edit-users lock-users unlock-users remove-users add-groups edit-groups remove-groupsadd-group-membersremove-group-member(Rt _managementt _shadow_filet _add_usert _edit_usert _lock_usert _unlock_usert _remove_usert _add_groupt _edit_groupt _remove_groupt_add_group_membert_remove_group_membert_message_typestNonet _publisher(tselft managementt shadow_file((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyt__init__s          cCs{tt|ƒj|ƒ||_t||jj|jjƒ|_|jj ƒx'|j D]}|jj ||j ƒqWWdS(s Schedule reactor events for generic L{Plugin} callbacks, user and group management operations, and resynchronization. N( tsuperRtregistert _registryRtregistrytreactortconfigRtstartRtregister_messaget_message_dispatch(RRt message_type((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRs   cCs&|jr"|jjƒd|_ndS(s,Stop listening for incoming AMP connections.N(RtstopR(R((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR&/s  cCsµg}|jr±yxt|jdƒ}x_|D]W}|jdƒ}t|ƒdkr+|djdƒr‚|j|djƒƒq‚q+q+WWq±tk r­}tj d|ƒq±Xn|S(s7Return a list of usernames with locked system accounts.trt:it!isError reading shadow file. %s( R topentsplittlent startswithtappendtstriptIOErrortloggingterror(Rt locked_usersRtlinetpartste((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pytget_locked_usernames5s  %csƒtˆjjˆjjƒ‰‡fd†}ˆjƒ}|j|ƒ|jˆj|ƒ|jˆj|ƒ|j‡fd†ƒ|S(s„Dispatch the given user-change request to the correct handler. @param message: The request we got from the server. cs|ˆ_|jƒS(N(t _user_monitortdetect_changes(t user_monitor(R(sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR9Ms cs ˆjƒS(N(t disconnect(tx(tuser_monitor_connector(sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pytUs(RRR R!tconnectt addCallbackt_perform_operationt _send_changes(RtmessageR9tresult((RR=sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR$Es  cCs6|d}|j|}t|ƒ}|j|||ƒS(Nttype(RRtcall_with_operation_result(RRDRCR%tmessage_method((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRAXs     cCs|jj|dƒS(Ns operation-id(R8R9(RRDRC((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRB_sc CsE|jj|d|d|d|d|d|d|d|dƒS( sRun an C{add-user} operation.tusernametnametpasswordsrequire-password-resetsprimary-group-nametlocations work-numbers home-number(R tadd_user(RRC((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR bscCsP|jj|dd|dd|dd|dd|dd|dd |d ƒS( sRun an C{edit-user} operation.RHRJRIRKt work_numbers work-numbert home_numbers home-numbertprimary_group_namesprimary-group-name(R tset_user_details(RRC((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR ls    cCs|jj|dƒS(sRun a C{lock-user} operation.RH(R t lock_user(RRC((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR uscCs|jj|dƒS(s Run an C{unlock-user} operation.RH(R t unlock_user(RRC((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRyscCs|jj|d|dƒS(sRun a C{remove-user} operation.RHs delete-home(R t remove_user(RRC((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR}scCs|jj|dƒS(sRun an C{add-group} operation.t groupname(R t add_group(RRC((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR‚scCs|jj|d|dƒS(sRun an C{edit-group} operation.RTsnew-name(R tset_group_details(RRC((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR†scCs|jj|d|dƒS(s%Run an C{add-group-member} operation.RHRT(R tadd_group_member(RRC((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR‹scCs|jj|d|dƒS(s'Run a C{remove-group-member} operation.RHRT(R tremove_group_member(RRC((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRscCs|jj|dƒS(s!Run an C{remove-group} operation.RT(R t remove_group(RRC((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR•sN(t__name__t __module__RIRRRR&RR7R$RARBR R R RRRRRRR(((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR s$            tRemoteUserManagerConnectorcBseZeZRS((RZR[Rt component(((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR\šs(R1tlandscape.lib.encodingRt landscape.ampRRRtlandscape.user.managementRtlandscape.manager.pluginRtlandscape.monitor.usermonitorRRR\(((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyts