From adef5e25a095d18f631b4bcfa95b7cc7e815c3ad Mon Sep 17 00:00:00 2001
From: r350178982 <32759763+r350178982@users.noreply.github.com>
Date: Tue, 2 Jul 2024 17:34:48 +0800
Subject: [PATCH] code-optimize

---
 seahub/api2/endpoints/repo_trash.py | 10 +++-------
 seahub/utils/__init__.py            |  8 +++++++-
 2 files changed, 10 insertions(+), 8 deletions(-)

diff --git a/seahub/api2/endpoints/repo_trash.py b/seahub/api2/endpoints/repo_trash.py
index b974a507ec4..fc924ac6aa7 100644
--- a/seahub/api2/endpoints/repo_trash.py
+++ b/seahub/api2/endpoints/repo_trash.py
@@ -15,6 +15,7 @@
 from seahub.api2.utils import api_error
 
 from seahub.signals import clean_up_repo_trash
+from seahub.utils import get_trash_records
 from seahub.utils.timeutils import timestamp_to_isoformat_timestr
 from seahub.utils.repo import get_repo_owner, is_repo_admin
 from seahub.views import check_folder_permission
@@ -382,17 +383,12 @@ def post(self, request, repo_id, format=None):
             show_time = show_days
 
         try:
-            from seahub.utils import SeafEventsSession, seafevents_api
-            session = SeafEventsSession()
-            deleted_entries = seafevents_api.get_delete_records(session, repo_id, show_time, path)
-            session.close()
+            deleted_entries = get_trash_records(repo_id, show_time, path)
         except Exception as e:
             logger.error(e)
             error_msg = 'Internal Server Error'
             return api_error(status.HTTP_500_INTERNAL_SERVER_ERROR, error_msg)
-        except ImportError:
-            pass
-
+        
         items = []
         if len(deleted_entries) >= 1:
             # sort entry by delete time
diff --git a/seahub/utils/__init__.py b/seahub/utils/__init__.py
index 6110c4fda3a..6cb2a7094c4 100644
--- a/seahub/utils/__init__.py
+++ b/seahub/utils/__init__.py
@@ -812,6 +812,11 @@ def get_user_traffic_by_month(username, month):
 
     def get_file_history_suffix():
         return seafevents_api.get_file_history_suffix(parsed_events_conf)
+    
+    def get_trash_records(repo_id, show_time, path):
+        with _get_seafevents_session() as session:
+            res = seafevents_api.get_delete_records(session, repo_id, show_time, path)
+        return res
 
 else:
     parsed_events_conf = None
@@ -874,6 +879,8 @@ def get_file_scan_record():
         pass
     def get_user_activities_by_timestamp():
         pass
+    def get_trash_records():
+        pass
 
 
 def calc_file_path_hash(path, bits=12):
@@ -881,7 +888,6 @@ def calc_file_path_hash(path, bits=12):
         path = path.encode('UTF-8')
 
     path_hash = hashlib.md5(urllib.parse.quote(path)).hexdigest()[:bits]
-
     return path_hash
 
 def get_service_url():