U #sg(@s\ddlmZmZddlmZddlZdZdZGdddeZ e Z GdddeZ e Z dS) )seafserv_threaded_rpcccnet_threaded_rpc) SearpcErrorNc@seZdZddZdKddZddZdd Zd d Zd d ZddZ ddZ ddZ ddZ ddZ ddZdLddZdMddZdNd!d"Zd#d$Zd%d&ZdOd(d)Zd*d+Zd,d-Zd.d/Zd0d1Zd2d3ZdPd4d5Zd6d7Zd8d9Zd:d;ZdddZ?ddZ@ddZAddZBddZCddZDdZddZEddZFddZGddZHddZIddZJddZKddZLddZMddZNddZOddZPd[ddZQddZRddZSd\ddZTddZUddZVddZWd]ddZXddZYddZZddZ[ddZ\ddZ]dd„Z^d^ddĄZ_ddƄZ`ddȄZaddʄZbd_dd̄Zcdd΄ZdddЄZedd҄ZfddԄZgddքZhdd؄ZiddڄZjdd܄ZkddބZlddZmddZnddZoddZpddZqddZrddZsddZtddZuddZvddZwddZxddZyddZzddZ{ddZ|ddZ}ddZ~ddZddZddZd d Zd d Zd dZddZd`ddZddZdaddZddZddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.Zd/d0Zd1d2Zd3d4Zd5d6Zd7d8Zd9d:Zd;d<Zd=d>Zd?d@ZdbdAdBZdCdDZdEdFZdGdHZdIdJZdS(c SeafileAPIcCsdSNselfrr_/opt/seafile-pro-server-build/seafile-server/seafile/lib/python3.8/site-packages/seaserv/api.py__init__szSeafileAPI.__init__TcCs"t|r dnd}t|||||S)a1Generate token for access file/dir in fileserver op: the operation, can be 'view', 'download', 'download-dir', 'downloadblks', 'upload', 'update', 'upload-blks-api', 'upload-blks-aj', 'update-blks-api', 'update-blks-aj' Return: the access token in string rr)boolrZweb_get_access_token)r repo_idZobj_idopusernameZ use_onetimeZonetimerrr get_fileserver_access_tokens  z&SeafileAPI.get_fileserver_access_tokencCs t|S)zGet the WebAccess object token: the access token in string Return: the WebAccess object (lib/webaccess.vala) )rZweb_query_access_tokenr tokenrrr query_fileserver_access_token'sz(SeafileAPI.query_fileserver_access_tokencCs t|S)zQuery zip progress for download-dir, download-multi token: obtained by get_fileserver_access_token Return: json formated string `{"zipped":, "total":}`, otherwise None. )rquery_zip_progressrrrr r0szSeafileAPI.query_zip_progresscCs t|Sr)rcancel_zip_taskrrrr r7szSeafileAPI.cancel_zip_taskcCs t||Sz7 Return non-zero if True, otherwise 0. )rZ is_passwd_setr rrrrr is_password_set<szSeafileAPI.is_password_setcCs t||S)z< Return: a CryptKey object (lib/crypt.vala) )rget_decrypt_keyrrrr rBszSeafileAPI.get_decrypt_keycCst||||Sr)rchange_repo_passwd)r rZ old_passwdZ new_passwduserrrr rHszSeafileAPI.change_repo_passwdcCs t||Sr)r check_passwd)r rmagicrrr rKszSeafileAPI.check_passwdcCst|||Sr)r set_passwd)r rrpasswdrrr rNszSeafileAPI.set_passwdcCs t||Sr)r unset_passwdr rrrrr r!QszSeafileAPI.unset_passwdcCst|||Sr)rgenerate_magic_and_random_key)r enc_versionrpasswordrrr r#Tsz(SeafileAPI.generate_magic_and_random_keyNc Cst|||||||Sr)r create_repo) r namedescrr r$Z storage_id pwd_hash_algopwd_hash_paramsrrr r'YszSeafileAPI.create_repoc Cst||||||||| | | Sr)rcreate_enc_repo) r rr(r)rrZ random_keyZsaltr$Zpwd_hashr*r+rrr r,\szSeafileAPI.create_enc_repocCst|||S0 Return: a list of Repo objects )rget_repos_by_id_prefix)r Z id_prefixstartlimitrrr r0_sz!SeafileAPI.get_repos_by_id_prefixcCs t|S)z7 Return: a Repo object (lib/repo.vala) )rget_repor rrrr r3eszSeafileAPI.get_repocCs t|Sr)r remove_repor4rrr r5kszSeafileAPI.remove_repoFcCst||||rdndS)z@ Return: a list of Repo objects (lib/repo.vala) rr)r get_repo_list)r r1r2Zorder_byZ ret_virt_reporrr r6nszSeafileAPI.get_repo_listcCstSr)r count_reposr rrr r7tszSeafileAPI.count_reposcCst||||Sr)r edit_repo)r rr(Z descriptionrrrr r8wszSeafileAPI.edit_repocCs t||S)z0 Return 1 if True, otherwise 0. )r is_repo_owner)r rrrrr r9zszSeafileAPI.is_repo_ownercCs t||Sr)rset_repo_owner)r emailrrrr r:szSeafileAPI.set_repo_ownercCs t|S)z. Return: repo owner in string )rget_repo_ownerr4rrr r<szSeafileAPI.get_repo_ownercCst||rdnd||S)r/rr)rZlist_owned_repos)r rZ ret_corruptedr1r2rrr get_owned_repo_lists  zSeafileAPI.get_owned_repo_listcCs t|Sr)rsearch_repos_by_name)r r(rrr r>szSeafileAPI.search_repos_by_namecCstSr)rget_orphan_repo_listr rrr r?szSeafileAPI.get_orphan_repo_listcCs t|Sr)rZserver_repo_sizer4rrr get_repo_sizeszSeafileAPI.get_repo_sizecCst|||Sr)rZrevert_on_server)r r commit_idrrrr revert_reposzSeafileAPI.revert_reporcCst||||S)zE Return: a list of DiffEntry objects (lib/repo.vala) )rZget_diff)r rZ old_commitZ new_commitZ fold_dir_diffrrr diff_commitsszSeafileAPI.diff_commitscCst|||S)zD Return: a list of Commit objects (lib/commit.vala) )rget_commit_list)r roffsetr2rrr rDszSeafileAPI.get_commit_listcCs0zt|||}Wntk r*d}YnX|S)z Get a commit. N)r get_commitr)r rZ repo_versionZcmt_idretrrr rFs  zSeafileAPI.get_commitcCstSr)rget_system_default_repo_idr rrr rHsz%SeafileAPI.get_system_default_repo_idcCs t|Sr)rget_org_id_by_repo_idr4rrr rIsz SeafileAPI.get_org_id_by_repo_idcCs t||Sr)rset_repo_status)r rstatusrrr rJszSeafileAPI.set_repo_statuscCs t|Sr)rget_repo_statusr4rrr rLszSeafileAPI.get_repo_statuscCs t||S)z3 Return: 0 on invalid; 1 on valid. )ris_valid_filename)r rfilenamerrr rMszSeafileAPI.is_valid_filenamecCst|||Sr)r get_file_size)r store_idversionfile_idrrr rOszSeafileAPI.get_file_sizecCst|||S)z Return the size of a dir. It needs to recursively calculate the size of the dir. It can cause great delay before returning. Use with caution! )r get_dir_size)r rPrQdir_idrrr rSszSeafileAPI.get_dir_sizecCs t||S)z` Returns None if path not found. Only raise exception on parameter or IO error. )rget_file_id_by_pathr rpathrrr rUszSeafileAPI.get_file_id_by_pathcCst|||Sr)rget_file_id_by_commit_and_pathr rrArWrrr rXsz)SeafileAPI.get_file_id_by_commit_and_pathcCs t||S)z; Return: a Dirent object (lib/dirent.vala) )rget_dirent_by_pathrVrrr rZszSeafileAPI.get_dirent_by_pathcCst||||SrrZlist_file_blocksr rrRrEr2rrr list_file_by_file_idszSeafileAPI.list_file_by_file_idcCst||||S)zw list block ids of a file. Return: a string containing block list. Each id is seperated by ' ' r[r\rrr list_blocks_by_file_idsz!SeafileAPI.list_blocks_by_file_idcCs t||Sr)rget_dir_id_by_pathrVrrr r_szSeafileAPI.get_dir_id_by_pathcCst||||S)z Return: a list of Dirent objects. The objects are sorted as follows: - Directories are always before files - Entries are sorted by names in ascending order )rlist_dir)r rrTrEr2rrr list_dir_by_dir_idszSeafileAPI.list_dir_by_dir_idcCs(t||}|dkrdSt||||Sr)rr_r`)r rrWrEr2rTrrr list_dir_by_paths zSeafileAPI.list_dir_by_pathcCs*t|||}|dkrdSt||||Sr)rget_dir_id_by_commit_and_pathr`)r rrArWrEr2rTrrr list_dir_by_commit_and_pathsz&SeafileAPI.list_dir_by_commit_and_pathcCst|||Sr)rrcrYrrr rcsz(SeafileAPI.get_dir_id_by_commit_and_pathcCst||||||Sr)rlist_dir_with_perm)r rdir_pathrTrrEr2rrr reszSeafileAPI.list_dir_with_permcCst||||Sr)rmkdir_with_parents)r r parent_dir relative_pathrrrr rg szSeafileAPI.mkdir_with_parentscCs t||Sr)rget_file_count_info_by_pathrVrrr rj sz&SeafileAPI.get_file_count_info_by_pathcCstSr)rget_total_storager rrr rkszSeafileAPI.get_total_storagecCstSr)rget_total_file_numberr rrr rlsz SeafileAPI.get_total_file_numbercCst|||||S)zAdd a file to a directory)r post_file)r r tmp_file_pathrhrNrrrr rms zSeafileAPI.post_filecCst||||Sr)rpost_empty_filer rrhrNrrrr roszSeafileAPI.post_empty_filecCst||||||S)zYUpdate an existing file head_id: the original commit id of the old file )rput_file)r rrnrhrNrZhead_idrrr rq s  zSeafileAPI.put_filecCst||||Sr)rdel_filerprrr rr,szSeafileAPI.del_filecCst|||Sr)rbatch_del_files)r rZ filepathsrrrr rs/szSeafileAPI.batch_del_filesrc Cst||||||||| Sr)r copy_file) r src_reposrc_dir src_filenamedst_repodst_dir dst_filenamer need_progress synchronousrrr rt7s zSeafileAPI.copy_filec Cst||||||||| | Sr)r move_file) r rurvrwrxryrzreplacerr{r|rrr r}=s zSeafileAPI.move_filecCs t|Sr)r get_copy_taskr Ztask_idrrr rCszSeafileAPI.get_copy_taskcCs t|Sr)rcancel_copy_taskrrrr rFszSeafileAPI.cancel_copy_taskcCst|||||Sr)r rename_file)r rrhZoldnameZnewnamerrrr rIs zSeafileAPI.rename_filecCst||||S)zAdd a directory)rpost_dir)r rrhdirnamerrrr rMszSeafileAPI.post_dircCst||||Sr)r revert_filer rrArWrrrr rQszSeafileAPI.revert_filecCst||||Sr)r revert_dirrrrr rTszSeafileAPI.revert_dir/dcCst|||||S)a Get list of deleted paths. @show_days: return deleted path in the last @show_days @path: return deleted files under this path. The path will be recursively traversed. @scan_stat: An opaque status returned by the last call. In the first call, None must be passed. The last entry of the result list contains a 'scan_stat' attribute. In the next call, pass in the returned 'scan_stat'. @limit: Advisory maximum number of commits to traverse. Sometimes more than @limit commits will be traversed. Return a list of DeletedEntry objects (lib/repo.vala). If no more deleted entries can be returned within the given time frame (specified by @show_days) or all deleted entries in the history have been returned, a list with a single entry will be returned. The 'scan_stat' attribute of this entry is set to None. )r get_deleted)r rZ show_daysrWZ scan_statr2rrr rWszSeafileAPI.get_deletedcCst||||S)a Get revisions of a file. @commit_id: start traversing from this commit @limit: maximum number of commits to traverse when looking for revisions Return a list of Commit objects (lib/commit.vala) related to the revisions. A few special attributes are added to the commit object: @rev_file_id: id of the file revision @rev_file_size: size of the file revision @rev_renamed_old_path: set if this revision is made by a rename operation. It's set to the old path before rename. @next_start_commit: commit_id for next page. An extra commit which only contains @next_start_commit will be appended to the list. )rZlist_file_revisions)r rrArWr2rrr get_file_revisionskszSeafileAPI.get_file_revisionscCst|||S)zkGet last modification time for files in a dir limit: the max number of commits to analyze )rZcalc_files_last_modified)r rrhr2rrr get_files_last_modified~sz"SeafileAPI.get_files_last_modifiedcCs t|S)zR Return repo history limit in days. Returns -1 if it's unlimited. )rget_repo_history_limitr4rrr rsz!SeafileAPI.get_repo_history_limitcCs t||S)zN Set repo history limit in days. Pass -1 if set to unlimited. )rset_repo_history_limit)r rZdaysrrr rsz!SeafileAPI.set_repo_history_limitcCs t||Sr)rset_repo_valid_since)r rZ timestamprrr rszSeafileAPI.set_repo_valid_sincecCs t||Sr)rcheck_repo_blocks_missing)r rZblklistrrr rsz$SeafileAPI.check_repo_blocks_missingcCs t||Sr)rget_upload_tmp_file_offset)r r file_pathrrr rsz%SeafileAPI.get_upload_tmp_file_offsetcCsdS)zH Always return 0 since CE doesn't support file locking. rrr rrWrrrr check_file_lockszSeafileAPI.check_file_lockcCst||||Sr)rZ add_sharer r from_username to_username permissionrrr share_reposzSeafileAPI.share_repocCst|||Sr)r remove_share)r rrrrrr rszSeafileAPI.remove_sharecCst||||Sr)rset_share_permissionrrrr rszSeafileAPI.set_share_permissioncCst||||||Sr)rshare_subdir_to_user)r rrWowner share_userrr rrr rs  zSeafileAPI.share_subdir_to_usercCst||||Sr)runshare_subdir_for_user)r rrWrrrrr rs z"SeafileAPI.unshare_subdir_for_usercCst|||||Sr)r!update_share_subdir_perm_for_user)r rrWrrrrrr rs z,SeafileAPI.update_share_subdir_perm_for_usercCst||||rdndSz If path is NULL, 'repo_id' represents for the repo we want, otherwise, 'repo_id' represents for the origin repo, return virtual repo rr)rget_shared_repo_by_path)r rrWZ shared_tois_orgrrr rsz"SeafileAPI.get_shared_repo_by_pathcCst|d||S)z[ Get repo list shared by this user. Return: a list of Repo objects Z from_emailrZlist_share_reposr rr1r2rrr get_share_out_repo_listsz"SeafileAPI.get_share_out_repo_listcCst|d||S)z4 Get repo list shared to this user. Zto_emailrrrrr get_share_in_repo_listsz!SeafileAPI.get_share_in_repo_listcCs t||S)zt Get user list this repo is shared to. Return: a list of SharedUser objects (lib/repo.vala) )rlist_repo_shared_tor from_userrrrr rszSeafileAPI.list_repo_shared_tocCst||rdndrdSdS)NrrTF)rrepo_has_been_shared)r rZincluding_groupsrrr rszSeafileAPI.repo_has_been_sharedcCst||||Srrgroup_share_repor rgroup_idrrrrr rszSeafileAPI.group_share_repocCst||||Srrrrrr set_group_reposzSeafileAPI.set_group_repocCst|||Srrgroup_unshare_repor rrrrrr rszSeafileAPI.group_unshare_repocCst|||Srrrrrr unset_group_reposzSeafileAPI.unset_group_repocCs:t|}|sgSg}|dD]}|s*q ||q |SN )rget_shared_groups_by_reposplitappend)r r group_idsrGrrrr get_shared_group_ids_by_repos  z'SeafileAPI.get_shared_group_ids_by_repocCs t||Srrlist_repo_shared_grouprrrr rsz!SeafileAPI.list_repo_shared_groupcCst||||rdndSr)rget_group_shared_repo_by_path)r rrWrrrrr rsz(SeafileAPI.get_group_shared_repo_by_pathcCs t|S)zO Return all the repos in all groups that the @user belongs to. )rget_group_repos_by_user)r rrrr rsz"SeafileAPI.get_group_repos_by_usercCs t||Sr)rget_org_group_repos_by_user)r rorg_idrrr r sz&SeafileAPI.get_org_group_repos_by_usercCs t||S)zG Return: a list of SharedGroup objects (lib/repo.vala) rrrrr list_repo_shared_group_by_usersz)SeafileAPI.list_repo_shared_group_by_usercCst||||||Sr)rshare_subdir_to_group)r rrWr share_grouprr rrr rs  z SeafileAPI.share_subdir_to_groupcCst||||Sr)runshare_subdir_for_group)r rrWrrrrr rs z#SeafileAPI.unshare_subdir_for_groupcCst|||||Sr)r"update_share_subdir_perm_for_group)r rrWrrrrrr rs z-SeafileAPI.update_share_subdir_perm_for_groupcCs>t|}|sgSg}|dD]}|dkr.q ||q |S)z3 Return the list of group repo ids rr)rget_group_repoidsrr)r rZrepo_idslrrrr r!s  zSeafileAPI.get_group_repoidscCs6g}||D]"}||}|dkr&q||q|Sr)rr3r)r rrGrrrrr get_group_repo_list/s  zSeafileAPI.get_group_repo_listcCs t|Sr.)rget_repos_by_groupr rrrr r9szSeafileAPI.get_repos_by_groupcCs t|S)z` Get all repos a user share to any group Return: a list of Repo objects )rget_group_repos_by_ownerr rrrr r?sz#SeafileAPI.get_group_repos_by_ownercCs t||S)z= Unshare all repos a user shared to a group. rZremove_repo_group)r rrrrr remove_group_repos_by_ownerFsz&SeafileAPI.remove_group_repos_by_ownercCs t|dS)zT Remove all repos under group. Return: 0 success; -1 failed Nrrrrr remove_group_reposLszSeafileAPI.remove_group_reposcCst|||Sr)rset_group_repo_permission)r rrrrrr rSsz$SeafileAPI.set_group_repo_permissioncCst|||S)zb Get all users a path is shared to. Return: a list of SharedUser objects. )rget_shared_users_for_subdirr rrWrrrr rWsz&SeafileAPI.get_shared_users_for_subdircCst|||S)zd Get all groups a path is shared to. Return: a list of SharedGroup objects. )rget_shared_groups_for_subdirrrrr r^sz'SeafileAPI.get_shared_groups_for_subdirc Csg}t|}|D]}||jqt|}|s6|Sg}|dD]}|sNqD|t|qDt|}t |} | D]}|j |krv||j qv|Sr) rget_shared_users_by_reporrrrintjsondumpsrget_groups_members user_name) r rusers shared_usersrridsrjson_ids group_usersrrr res$     z#SeafileAPI.get_shared_users_by_repocCs t||Sr)rZset_inner_pub_repo)r rrrrr add_inner_pub_reposzSeafileAPI.add_inner_pub_repocCs t|Sr)rZunset_inner_pub_repor4rrr remove_inner_pub_reposz SeafileAPI.remove_inner_pub_repocCstSz1 Return: a list of Repo objects. )rZlist_inner_pub_reposr rrr get_inner_pub_repo_listsz"SeafileAPI.get_inner_pub_repo_listcCs t|Sr)rlist_inner_pub_repos_by_owner)r Z repo_ownerrrr rsz(SeafileAPI.list_inner_pub_repos_by_ownercCstSr)rcount_inner_pub_reposr rrr rsz SeafileAPI.count_inner_pub_reposcCs t|Sr)ris_inner_pub_repor4rrr rszSeafileAPI.is_inner_pub_repocCs t||S)z Check repo share permissions. Only check user share, group share and inner-pub shares. Return: 'r', 'rw', or None )rcheck_permissionr"rrr rszSeafileAPI.check_permissioncCst|||S)a Check both repo share permission and sub-folder access permissions. This function should be used when updating file/folder in a repo. In CE, this function is equivalent to check_permission. Return: 'r', 'rw', or None )rcheck_permission_by_pathrrrr rsz#SeafileAPI.check_permission_by_pathcCsdS)zB Check if the permission of the repo is syncable. z{"is_syncable":true}r)r rr repo_permrrr is_repo_syncableszSeafileAPI.is_repo_syncablecCsdS)a4 Check if the permission of the dir is downloadable. {"is_downloadable": false, "undownloadable_path":"path"} - is_downloadable: true if the dir is downloadable, false if not. - undownloadable_path: the undownloadable path of the repo if the path is not downloadable. z{"is_downloadable":true}r)r rrfrrrrr is_dir_downloadableszSeafileAPI.is_dir_downloadablecCs t||S)z)Generate a token for sync a repo )rgenerate_repo_tokenrrrr rszSeafileAPI.generate_repo_tokencCst|||Sr)rdelete_repo_token)r rrrrrr rszSeafileAPI.delete_repo_tokencCs t|S)z: Return: a list of RepoTokenInfo objects. )rlist_repo_tokensr4rrr rszSeafileAPI.list_repo_tokenscCs t|Sr)rlist_repo_tokens_by_emailrrrr rsz$SeafileAPI.list_repo_tokens_by_emailcCs t||Sr)rdelete_repo_tokens_by_peer_id)r r;Zpeer_idrrr rsz(SeafileAPI.delete_repo_tokens_by_peer_idcCs t|Sr)rdelete_repo_tokens_by_emailr r;rrr rsz&SeafileAPI.delete_repo_tokens_by_emailcCs t|S)z&Get the sum of repos' size of the user)rZget_user_quota_usagerrrr get_user_self_usageszSeafileAPI.get_user_self_usagecCs t|Sr)rget_user_share_usagerrrr rszSeafileAPI.get_user_share_usagecCs t|S)zT Return: -2 if quota is unlimited; otherwise it must be number > 0. )rget_user_quotarrrr rszSeafileAPI.get_user_quotacCs t||Sr)rset_user_quotar rZquotarrr rszSeafileAPI.set_user_quotacCsdS)Nrrrrr get_user_share_quotaszSeafileAPI.get_user_share_quotacCsdSrrrrrr set_user_share_quotaszSeafileAPI.set_user_share_quotacCs t||Sr)r check_quota)r rZdeltarrr rszSeafileAPI.check_quotacCstSr)rlist_user_quota_usager rrr rsz SeafileAPI.list_user_quota_usagecCst||||||Sr)rcreate_virtual_repo)r Zorigin_repo_idrWZ repo_nameZ repo_descrr rrr rszSeafileAPI.create_virtual_repocCs t|Sr)rget_virtual_repos_by_ownerr rrrr rsz%SeafileAPI.get_virtual_repos_by_ownercCst|||Sr)rget_virtual_repo)r Z origin_reporWrrrr rszSeafileAPI.get_virtual_repocCs t||Sr)rclean_up_repo_history)r rZ keep_daysrrr rsz SeafileAPI.clean_up_repo_historycCs t||Sr)rget_trash_repo_listr r1r2rrr rszSeafileAPI.get_trash_repo_listcCs t|Sr)rdel_repo_from_trashr4rrr rszSeafileAPI.del_repo_from_trashcCs t|Sr)rrestore_repo_from_trashr4rrr r sz"SeafileAPI.restore_repo_from_trashcCs t|Sr)rget_trash_repos_by_ownerrrrr rsz#SeafileAPI.get_trash_repos_by_ownercCs t|Sr)rget_trash_repo_ownerr4rrr r szSeafileAPI.get_trash_repo_ownercCstSr)rempty_repo_trashr rrr r szSeafileAPI.empty_repo_trashcCs t|Sr)rempty_repo_trash_by_ownerrrrr r sz$SeafileAPI.empty_repo_trash_by_ownercCs t||Sr)rget_server_config_intr groupkeyrrr r sz SeafileAPI.get_server_config_intcCst|||Sr)rset_server_config_intr rrvaluerrr rsz SeafileAPI.set_server_config_intcCs t||Sr)rget_server_config_int64r rrr r!sz"SeafileAPI.get_server_config_int64cCst|||Sr)rset_server_config_int64rrrr r$sz"SeafileAPI.set_server_config_int64cCs t||Sr)rget_server_config_stringr rrr r'sz#SeafileAPI.get_server_config_stringcCst|||Sr)rset_server_config_stringrrrr r*sz#SeafileAPI.set_server_config_stringcCstt||Sr)r rget_server_config_booleanr rrr r-sz$SeafileAPI.get_server_config_booleancCst|r dnd}t|||SNrr)r rset_server_config_boolean)r rrrZi_valuerrr r0sz$SeafileAPI.set_server_config_booleancCst|||dSr)rdel_org_group_repo)r rrrrrr r4szSeafileAPI.del_org_group_repoc Csg}t||}|D]}||jqt||}|s:|Sg}|dD]}|sRqH|t|qHt|} t | } | D]}|j |krz||j qz|Sr) rorg_get_shared_users_by_reporrZget_org_groups_by_reporrrrrrr) r rrrrrrrrrrrrr r7s$     z'SeafileAPI.org_get_shared_users_by_repocCs t|Sr)rlist_org_inner_pub_reposr rrrr rRsz#SeafileAPI.list_org_inner_pub_reposcCst||||rdndSr)rconvert_repo_path)r rrWrrrrr rUszSeafileAPI.convert_repo_pathcCs t||Sr)r publish_event)r channelZcontentrrr rXszSeafileAPI.publish_eventcCs t|Sr)r pop_event)r r rrr r![szSeafileAPI.pop_eventcCs t||Sr)r search_files)r r search_strrrr r"^szSeafileAPI.search_filescCst|||Sr)rsearch_files_by_path)r rrWr#rrr r$aszSeafileAPI.search_files_by_path)T)Nr&NNN)NNN)r-r-)NF)Fr-r-)r)r-r-)r-r-)r-r-)r-r-)r-r-)r-r-)r)r)rNr)r)F)F)F)r)r)r)F)__name__ __module__ __qualname__r rrrrrrrrrr!r#r'r,r0r3r5r6r7r8r9r:r<r=r>r?r@rBrCrDrFrHrIrJrLrMrOrSrUrXrZr]r^r_rarbrdrcrergrjrkrlrmrorqrrrsrtr}rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr r r r rrrrrrrrrrrrr!r"r$rrrr rsH                                                              rc@s(eZdZddZddZddZddZd d Zd d Zd dZ dddZ ddZ ddZ ddZ dddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.Zd/d0Zdd2d3Zdd4d5Zd6d7Zd8d9Zd:d;Zdd?Z d@dAZ!dBdCZ"ddDdEZ#ddFdGZ$dHdIZ%ddKdLZ&ddMdNZ'ddOdPZ(dQdRZ)ddTdUZ*dVdWZ+dXdYZ,dZd[Z-d\d]Z.d^d_Z/d`daZ0dbdcZ1dddeZ2dfdgZ3dhdiZ4djdkZ5dldmZ6dndoZ7dpdqZ8drdsZ9dtduZ:dvdwZ;dxdyZd~dZ?ddZ@ddZAddZBddZCdS)CcnetAPIcCsdSrrr rrr r hszCcnetAPI.__init__cCst||||Sr)r add_emailuser)r r;r is_staff is_activerrr r)lszCcnetAPI.add_emailusercCs t||S)z source can be 'DB' or 'LDAP'. - 'DB': remove a user created in local database - 'LDAP': remove a user imported from LDAP )rremove_emailuser)r sourcer;rrr r,oszCcnetAPI.remove_emailusercCs t||S)z Verify user's password on login. Can be used to verify DB and LDAP users. The function first verify password with LDAP, then local database. )rvalidate_emailuser)r r;r rrr r.wszCcnetAPI.validate_emailusercCs t|S)a} Only return local database user or imported LDAP user. It first lookup user from local database, if not found, lookup imported LDAP user. Return: a list of EmailUser objects (ccnet/lib/ccnetobj.vala) The 'source' attribute of EmailUser object is set to 'LDAPImport' for LDAP imported user, and 'DB' for local database user. )r get_emailuserrrrr r/~s zCcnetAPI.get_emailusercCs t|S)zo The same as get_emailuser() but import the user from LDAP if it was not imported yet. )rget_emailuser_with_importrrrr r0sz"CcnetAPI.get_emailuser_with_importcCs t|S)zF Get a user from local database with the db index id. )rget_emailuser_by_id)r user_idrrr r1szCcnetAPI.get_emailuser_by_idNcCs0|dkrd}n|dkrd}nd}t||||S)a source: - 'DB': return local db users - 'LDAPImport': return imported LDAP users - 'LDAP': retrieve users directly from LDAP server start: offset to start retrieving, -1 to start from the beginning limit: number of users to get, -1 to get all user from start is_active: True to return only active users; False to return inactive users; None to return all users. Return: a list of EmailUser objects. TZactiveFZinactiver)rget_emailusers)r r-r1r2r+rKrrr r3s zCcnetAPI.get_emailuserscCst||||S)z Search for users whose name contains @email_patt. source: 'DB' for local db users; 'LDAP' for imported LDAP users. This function cannot search LDAP users directly in LDAP server. )rsearch_emailusers)r r-Z email_pattr1r2rrr r4szCcnetAPI.search_emailuserscCst|||S)zD Search for groups whose name contains @group_patt. )r search_groups)r Z group_pattr1r2rrr r5szCcnetAPI.search_groupscCs t||Sr)rsearch_group_members)r rpatternrrr r6szCcnetAPI.search_group_membersFcCst|r dndSr)rget_top_groups)r Z including_orgrrr r8szCcnetAPI.get_top_groupscCs t|Sr)rget_child_groupsrrrr r9szCcnetAPI.get_child_groupscCs t|Sr)rget_descendants_groupsrrrr r:szCcnetAPI.get_descendants_groupscCs t|Sr)rget_ancestor_groupsrrrr r;szCcnetAPI.get_ancestor_groupscCst|||S)zZ Search for users whose name contains @keyword directly from LDAP server. )rsearch_ldapusers)r keywordr1r2rrr r<szCcnetAPI.search_ldapuserscCs t|S)z Return the number of active users by source. source: 'DB' for local db users; 'LDAP' for imported LDAP users. )rcount_emailusersr r-rrr r>szCcnetAPI.count_emailuserscCs t|S)z Return the number of inactive users by source. source: 'DB' for local db users; 'LDAP' for imported LDAP users. )rcount_inactive_emailusersr?rrr r@sz"CcnetAPI.count_inactive_emailuserscCst|||||S)a] source: 'DB' for local db user; 'LDAP' for imported LDAP user. user_id: usually not changed. password: new password in plain text. Only effective for DB users. If '!' is passed, the password won't be updated. is_staff: change superuser status is_active: activate or deactivate user )rupdate_emailuser)r r-r2r%r*r+rrr rAs zCcnetAPI.update_emailusercCs t||Sr)rupdate_role_emailuser)r r;Zrolerrr rBszCcnetAPI.update_role_emailusercCstS)z6 Return: a list of EmailUser objects. )rget_superusersr rrr rCszCcnetAPI.get_superuserscCs t||S)z^ @source: 'DB' or 'LDAP' @user_list: json '[user1, user2, user3,...]' )rget_emailusers_in_list)r r-Z user_listrrr rDszCcnetAPI.get_emailusers_in_listcCs t||Sr)rupdate_emailuser_id)r Z old_emailZ new_emailrrr rEszCcnetAPI.update_emailuser_idrcCst||||S)zF For CE, gtype is not used and should always be None. )r create_group)r group_namerZgtypeparent_group_idrrr rFszCcnetAPI.create_groupcCst||||Sr)rcreate_org_group)r rrGrrHrrr rIszCcnetAPI.create_org_groupcCs t|S)zO permission check should be done before calling this function. )r remove_grouprrrr rJszCcnetAPI.remove_groupcCst|||Sz$ user_name: unused. )rgroup_add_memberr rr member_namerrr rL szCcnetAPI.group_add_membercCst|||SrK)rgroup_remove_memberrMrrr rOszCcnetAPI.group_remove_membercCs t||Sz? No effect if member_name is not in the group. )rgroup_set_adminr rrNrrr rQszCcnetAPI.group_set_admincCs t||SrP)rgroup_unset_adminrRrrr rSszCcnetAPI.group_unset_admincCs t||Sr)rset_group_name)r rrGrrr rT"szCcnetAPI.set_group_namecCs t||Sr)r quit_groupr rrrrr rU%szCcnetAPI.quit_groupcCst||rdndS)zw Get all groups the user belongs to. Return: a list of Group objects (ccnet/lib/ccnetobj.vala) rr)r get_groups)r rZreturn_ancestorsrrr rW(szCcnetAPI.get_groupscCst|||S)zH For CE, source is not used and should alwasys be None. )rget_all_groups)r r1r2r-rrr rX/szCcnetAPI.get_all_groupscCs t|Sr)r get_grouprrrr rY5szCcnetAPI.get_groupr-cCst|||S)zN Return a list of GroupUser objects (ccnet/lib/ccnetobj.vala) )rget_group_members)r rr1r2rrr rZ8szCcnetAPI.get_group_memberscCs t||S)z4 Return a list of GroupUser objects )rget_members_with_prefix)r rprefixrrr r[>sz CcnetAPI.get_members_with_prefixcCst|||rdndS)z> Return non-zero value if true, 0 if not true rr)rcheck_group_staff)r rr in_structurerrr r]DszCcnetAPI.check_group_staffcCs t|Sr)rremove_group_userrrrr r_JszCcnetAPI.remove_group_userTcCst|||rdndS)z Return non-zero value if true, 0 if not true If @in_structure is true, return whether user is in descendants groups and @group_id it self rr)r is_group_user)r rrr^rrr r`MszCcnetAPI.is_group_usercCs t||Sr)rset_group_creatorrVrrr raTszCcnetAPI.set_group_creatorcCst|||Sr)r create_org)r org_name url_prefixZcreatorrrr rbXszCcnetAPI.create_orgcCs t|Sr)r remove_orgrrrr re[szCcnetAPI.remove_orgcCs t||S)zQ Return a list of Organization objects (ccnet/lib/ccnetobj.vala) )r get_all_orgsrrrr rf^szCcnetAPI.get_all_orgscCstSr)r count_orgsr rrr rgdszCcnetAPI.count_orgscCs t|S)z/ Return an Organizaion object. )rget_org_by_url_prefix)r rdrrr rhgszCcnetAPI.get_org_by_url_prefixcCs t|Sr)r get_org_by_idrrrr rimszCcnetAPI.get_org_by_idcCst|||Sr)r add_org_user)r rr;r*rrr rjpszCcnetAPI.add_org_usercCs t||Sr)rremove_org_userr rr;rrr rksszCcnetAPI.remove_org_usercCs t|Sr)rget_orgs_by_userrrrr rmvszCcnetAPI.get_orgs_by_usercCst|||S)z5 Return a list of EmailUser objects. )rget_org_emailusers)r rdr1r2rrr rnyszCcnetAPI.get_org_emailuserscCs t||Sr)r add_org_groupr rrrrr roszCcnetAPI.add_org_groupcCs t||Sr)rremove_org_grouprprrr rqszCcnetAPI.remove_org_groupcCs t|Sr)r is_org_grouprrrr rrszCcnetAPI.is_org_groupcCs t|Sr)rget_org_id_by_grouprrrr rsszCcnetAPI.get_org_id_by_groupcCst|||S)z= Return a list of int, each int is group id. )rget_org_groups)r rr1r2rrr rtszCcnetAPI.get_org_groupscCs t|Sr)rget_org_top_groupsrrrr ruszCcnetAPI.get_org_top_groupscCs t||Sr)rorg_user_existsrlrrr rvszCcnetAPI.org_user_existscCs t||Sr)r is_org_staffr rrrrr rwszCcnetAPI.is_org_staffcCs t||Sr)r set_org_staffrxrrr ryszCcnetAPI.set_org_staffcCs t||Sr)runset_org_staffrxrrr rzszCcnetAPI.unset_org_staffcCs t||Sr)r set_org_name)r rrcrrr r{szCcnetAPI.set_org_namecCs t|Sr)rget_primary_idrrrr r|szCcnetAPI.get_primary_idcCs t||Sr)rset_reference_id)r Z primary_idZ reference_idrrr r}szCcnetAPI.set_reference_idcCs t|S)z8 @group_ids: json '[id1, id2, id3,...]' )rr)r rrrr rszCcnetAPI.get_groups_members)N)F)Nr)r)F)N)r-r-)N)F)T)Dr%r&r'r r)r,r.r/r0r1r3r4r5r6r8r9r:r;r<r>r@rArBrCrDrErFrIrJrLrOrQrSrTrUrWrXrYrZr[r]r_r`rarbrerfrgrhrirjrkrmrnrorqrrrsrtrurvrwryrzr{r|r}rrrrr r(fs            r() ZservicerrZpysearpcrrZREPO_STATUS_NORMALZREPO_STATUS_READ_ONLYobjectrZ seafile_apir(Z ccnet_apirrrr s   WT