BinaryONe commited on
Commit
0a9a39c
·
1 Parent(s): 2ed5135

Changes in Database

Browse files
FileStream/Database/database.py CHANGED
@@ -280,6 +280,7 @@ class Database:
280
  {"$set": {
281
  "file_ids": file_ids
282
  }})
 
283
  elif privacy_type=="TEMPORARY":
284
  await self.tfiles.update_one({"_id": ObjectId(_id)},
285
  {"$set": {
 
280
  {"$set": {
281
  "file_ids": file_ids
282
  }})
283
+
284
  elif privacy_type=="TEMPORARY":
285
  await self.tfiles.update_one({"_id": ObjectId(_id)},
286
  {"$set": {
FileStream/utils/FileProcessors/file_properties.py CHANGED
@@ -89,7 +89,7 @@ async def get_file_ids(client: Client | bool, db_id: str, message) -> Optional[F
89
  log_msg = await send_file(FileStream, db_id, file_info, message, source)
90
  #updated_info = update_file_info(log_msg)
91
  await db.update_file_info(db_id, update_file_info(log_msg), file_info['privacy_type'])
92
- await db.update_file_ids(db_id, await update_file_id(await db.get_file(db_id),MULTI_CLIENTS), file_info['privacy_type'])
93
 
94
  logging.debug("Stored file_id of all clients in DB")
95
  if not client:
 
89
  log_msg = await send_file(FileStream, db_id, file_info, message, source)
90
  #updated_info = update_file_info(log_msg)
91
  await db.update_file_info(db_id, update_file_info(log_msg), file_info['privacy_type'])
92
+ await db.update_file_ids(db_id, await update_file_id(await db.GetFileByDBName(db_id, file_info['privacy_type']),MULTI_CLIENTS), file_info['privacy_type'])
93
 
94
  logging.debug("Stored file_id of all clients in DB")
95
  if not client: