without rename

This commit is contained in:
2025-02-16 12:54:03 +03:00
parent 774ed92ca2
commit bb07faa322

View File

@ -19,7 +19,6 @@ class JsonConverter(BaseSession):
banned_dir: Path, banned_dir: Path,
proxy: str, proxy: str,
json_write: bool = True, json_write: bool = True,
rename: bool = False,
): ):
""" """
Конвертер сессий в json Конвертер сессий в json
@ -28,13 +27,10 @@ class JsonConverter(BaseSession):
banned_dir: директория куда перемещать забаненные сессии banned_dir: директория куда перемещать забаненные сессии
proxy: прокси для подключения формат: http:ip:port:user:pswd proxy: прокси для подключения формат: http:ip:port:user:pswd
json_write: записывать в json файл информацию о string_session + proxy? json_write: записывать в json файл информацию о string_session + proxy?
rename: переименование сессий в формат phone.json и phone.session,
где ключ phone - берет из json файла, а также записывает в json файл
номер телефона в строку ключ session_file
""" """
super().__init__(base_dir, errors_dir, banned_dir) super().__init__(base_dir, errors_dir, banned_dir)
self.__api_id, self.__api_hash = 2040, "b18441a1ff607e10a989891a5462e627" self.__api_id, self.__api_hash = 2040, "b18441a1ff607e10a989891a5462e627"
self.__json_write, self.__rename = json_write, rename self.__json_write = json_write
self.__proxy = ProxyParser(proxy).asdict_thon self.__proxy = ProxyParser(proxy).asdict_thon
def _main( def _main(
@ -60,16 +56,15 @@ class JsonConverter(BaseSession):
loop.close() loop.close()
json_data["proxy"] = self.__proxy json_data["proxy"] = self.__proxy
json_data["string_session"] = string_session json_data["string_session"] = string_session
if self.__rename: # if phone := json_data.get("phone"):
if phone := json_data.get("phone"): # for char in ["+", " ", "-", "(", ")"]:
for char in ["+", " ", "-", "(", ")"]: # phone = phone.replace(char, "")
phone = phone.replace(char, "") # if phone.isdigit():
if phone.isdigit(): # json_file.rename(self.base_dir / f"{phone}.json")
json_file.rename(self.base_dir / f"{phone}.json") # item.rename(self.base_dir / f"{phone}.session")
item.rename(self.base_dir / f"{phone}.session") # json_data["session_file"] = phone
json_data["session_file"] = phone # if not self.__json_write:
if not self.__json_write: # json_write_sync(json_file, json_data)
json_write_sync(json_file, json_data)
if self.__json_write: if self.__json_write:
json_write_sync(json_file, json_data) json_write_sync(json_file, json_data)
return item, json_file, json_data return item, json_file, json_data