ó ½-'Nc@sĉddlZddlZddlmZddlmZmZmZddlm Z ddl m Z ddl m Z de fd„ƒYZd efd „ƒYZd efd „ƒYZd efd„ƒYZdefd„ƒYZdS(i˙˙˙˙N(t RemoteObject(tComponentProtocoltComponentProtocolFactorytRemoteComponentConnector(tUserManagement(t ManagerPlugin(tRemoteUserMonitorConnectort UserManagercBs­eZdZddd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z d „Z d „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_port(tselft managementt shadow_file((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyt__init__s          cCsœtt|ƒj|ƒ||_td|ƒ}tjj|jj j |j dƒ}|jj j ||ƒ|_x'|jD]}|jj||jƒqxWdS(s Schedule reactor events for generic L{Plugin} callbacks, user and group management operations, and resynchronization. tobjects.sockN(tsuperRtregistert _registrytUserManagerProtocolFactorytostpathtjointregistrytconfigt sockets_pathtnametreactort listen_unixRRtregister_messaget_message_dispatch(RR$tfactorytsockett message_type((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR!s  cCs&|jr"|jjƒd|_ndS(s,Stop listening for incoming AMP connections.N(Rt stopListeningR(R((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pytstop2s  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_usernames8s  %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.pyRCOs cs ˆjƒS(N(t disconnect(tx(tuser_monitor_connector(sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pytWs(RR$R(R%tconnectt addCallbackt_perform_operationt _send_changes(RtmessageRCtresult((RRGsA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR+Gs  cCs*|d}|j|}|j|||ƒS(Nttype(Rtcall_with_operation_result(RRNRMR.tmessage_method((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRKZs   cCs|jj|dƒS(Ns operation-id(RBRC(RRNRM((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRL`sc CsE|jj|d|d|d|d|d|d|d|dƒS( sRun an C{add-user} operation.tusernameR'tpasswordsrequire-password-resetsprimary-group-nametlocations work-numbers home-number(R tadd_user(RRM((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR cscCsP|jj|dd|dd|dd|dd|dd|dd |d ƒS( sRun an C{edit-user} operation.RRRSR'RTt work_numbers work-numbert home_numbers home-numbertprimary_group_namesprimary-group-name(R tset_user_details(RRM((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR ms    cCs|jj|dƒS(sRun a C{lock-user} operation.RR(R t lock_user(RRM((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR vscCs|jj|dƒS(s Run an C{unlock-user} operation.RR(R t unlock_user(RRM((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRzscCs|jj|d|dƒS(sRun a C{remove-user} operation.RRs delete-home(R t remove_user(RRM((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(RRM((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRƒscCs|jj|d|dƒS(sRun an C{edit-group} operation.R]snew-name(R tset_group_details(RRM((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR‡scCs|jj|d|dƒS(s%Run an C{add-group-member} operation.RRR](R tadd_group_member(RRM((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRŒscCs|jj|d|dƒS(s'Run a C{remove-group-member} operation.RRR](R tremove_group_member(RRM((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR‘scCs|jj|dƒS(s!Run an C{remove-group} operation.R](R t remove_group(RRM((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR–sN(t__name__t __module__R'RRRR0RAR+RKRLR R R RRRRRRR(((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR s$             tUserManagerProtocolcBseZdZdgZRS(sDL{AMP}-based protocol for calling L{UserManager}'s methods remotely.RA(RcRdt__doc__tmethods(((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRe›sR cBseZeZRS((RcRdRetprotocol(((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyR ĦstRemoteUserManagercBseZdZRS(s"A connected remote L{UserManager}.(RcRdRf(((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRiĤstRemoteUserManagerConnectorcBseZeZeZeZRS((RcRdRR,RitremoteRt component(((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyRjŞs(R!R;tlandscape.lib.ampRt landscape.ampRRRtlandscape.user.managementRtlandscape.manager.pluginRtlandscape.monitor.usermonitorRRReR RiRj(((sA/usr/lib/python2.7/dist-packages/landscape/manager/usermanager.pyts  Ž