Update app.py

app.py

@@ -34,7 +34,7 @@ tokens = [
 
 
 async def download_png(url: str, folder: str, client: AsyncClient, retries: int = 5) -> Path:
-    logger.info(f'загрузка изображения: {url}')
+    print(f'загрузка изображения: {url}')
     for attempt in range(retries):
         try:
             response = await client.get(url)
@@ -52,12 +52,11 @@ async def download_png(url: str, folder: str, client: AsyncClient, retries: int
 
 async def download_pngs(urls: str | list[str]) -> list[Any]:
     urls = [urls] if isinstance(urls, str) else urls
-    logger.info(f'скачивается список список из {len(urls)}: {urls}')
     print(f'скачивается список список из {len(urls)}: {urls}')
     # бот coze имеет баг, и из воркфлоу прибавляет предыдущий ответ к ссылкам, если включен контекст чата:
     valid_urls = [url for url in urls if url and '\n' not in url and '\\n' not in url and url.strip() != '']
     if len(valid_urls) != len(urls):
-        logger.warning(f'некорректные ссылки удалены из списка: {set(urls) - set(valid_urls)}')
+        print(f'некорректные ссылки удалены из списка: {set(urls) - set(valid_urls)}')
     async with AsyncClient(verify=False, follow_redirects=True, timeout=30.0) as client:
         tasks = [download_png(url, str(uuid4()), client) for url in valid_urls]
         return list(await gather(*tasks))
@@ -65,7 +64,7 @@ async def download_pngs(urls: str | list[str]) -> list[Any]:
 
 async def optimize_png(image_path: Path, retries: int = 3) -> None:
     command = f'{oxipng_bin.resolve()} --opt 2 --strip safe --out {image_path} {image_path}'
-    logger.info(f'оптимизация картинки {image_path}')
+    print(f'оптимизация картинки {image_path}')
     for attempt in range(retries):
         try:
             process = await create_subprocess_shell(command, stdout=PIPE, stderr=PIPE)
@@ -75,7 +74,7 @@ async def optimize_png(image_path: Path, retries: int = 3) -> None:
             else:
                 raise CalledProcessError(process.returncode, command, output=stdout, stderr=stderr)
         except CalledProcessError as e:
-            logger.error(f'ошибка при оптимизации {image_path}')
+            print(f'ошибка при оптимизации {image_path}')
             if attempt < retries - 1:
                 await sleep(2 ** attempt)
             else:
@@ -83,7 +82,7 @@ async def optimize_png(image_path: Path, retries: int = 3) -> None:
 
 
 async def convert_to_jpeg(image_path: Path) -> Path:
-    logger.info(f'конвертируется {image_path}')
+    print(f'конвертируется {image_path}')
     try:
         image = Image.open(image_path)
         output_path = image_path.with_suffix('.jpg')
@@ -91,20 +90,20 @@ async def convert_to_jpeg(image_path: Path) -> Path:
         image_path.unlink(missing_ok=True)
         return output_path
     except:
-        logger.error(f'ошибка при конвертации {image_path}')
+        print(f'ошибка при конвертации {image_path}')
         return image_path
 
 
 async def convert_to_jpegs(image_paths: list[str | Path] | str | Path) -> tuple[Path]:
     image_paths = [Path(image_file) for image_file in ([image_paths] if not isinstance(image_paths, list) else image_paths)]
-    logger.info(f'оптимизируется список список из {len(image_paths)}: {image_paths}')
+    print(f'оптимизируется список список из {len(image_paths)}: {image_paths}')
     tasks = [convert_to_jpeg(image_path) for image_path in image_paths]
     return await gather(*tasks)
 
 
 async def optimize_pngs(image_paths: list[str | Path] | str | Path) -> None:
     image_paths = [Path(image_file) for image_file in ([image_paths] if not isinstance(image_paths, list) else image_paths)]
-    logger.info(f'оптимизируется список список из {len(image_paths)}: {image_paths}')
+    print(f'оптимизируется список список из {len(image_paths)}: {image_paths}')
     tasks = [optimize_png(image_path) for image_path in image_paths]
     await gather(*tasks)
 
@@ -132,7 +131,7 @@ async def upload_image(file_path: Path | str, file_type: str = 'png') -> str | N
 
 async def optimize_and_upload(images_urls: list[str] | str, convert: bool = False) -> list[str]:
     images_urls = [images_urls] if isinstance(images_urls, str) else images_urls
-    logger.info(f'принятые ссылки в обработку ({len(images_urls)}): {images_urls}')
+    print(f'принятые ссылки в обработку ({len(images_urls)}): {images_urls}')
     images_paths = await download_pngs(images_urls)
     if not convert:
         await optimize_pngs(images_paths)
@@ -142,16 +141,16 @@ async def optimize_and_upload(images_urls: list[str] | str, convert: bool = Fals
         new_url = await upload_image(image_path, 'png' if not convert else 'jpeg')
         if new_url:
             new_images_urls.append(new_url)
-        logger.info(f'загружено изображение {image_path} в {new_url}')
+        print(f'загружено изображение {image_path} в {new_url}')
         try:
             image_path.unlink()
         except Exception as e:
-            logger.error(f'не удалось удалить файл {image_path}: {e}')
-    logger.info(f'новые ссылки: ({len(new_images_urls)}): {new_images_urls}')
+            print(f'не удалось удалить файл {image_path}: {e}')
+    print(f'новые ссылки: ({len(new_images_urls)}): {new_images_urls}')
     try:
         rmtree(images_paths[0].parent)
     except Exception as e:
-        logger.error(f'не удалось удалить файл {images_paths[0].parent}: {e}')
+        print(f'не удалось удалить файл {images_paths[0].parent}: {e}')
     return new_images_urls