diff --git a/filemgr/filemgr.py b/filemgr/filemgr.py index 04a7423..16956d5 100644 --- a/filemgr/filemgr.py +++ b/filemgr/filemgr.py @@ -5,6 +5,8 @@ from ahserver.auth_api import get_session_userinfo from sqlor.dbpools import DBPools from appPublic.uniqueID import getID from appPublic.log import debug, error, exception +from appPublic.registerfunction import RegisterFunction +from appPublic.worker import awaitify from ahserver.filestorage import FileStorage import hashlib @@ -52,6 +54,9 @@ class FileMgr: "hashvalue": hashvalue } await sor.C('file', ns) + if len(recs) == 0: + rf = RegisterFunction() + await rf.exe('fileuploaded', ns) return True return False @@ -67,6 +72,8 @@ class FileMgr: remain = sor.R('file', {'hashvalue':delrec.hashvalue}) if not remain: os.unlink(delrec.realpath) + rf = RegisterFunction() + await rf.exe('filedeleted', delrec) async def has_sub(self, request, sor, folderid): sql = """select unique a.* from folder a