release: версия 1.4.2 — многопоточная загрузка, --only-new, логирование времени

- Реализована многопоточная загрузка файлов (параметр --threads)
- Добавлена опция --only-new для загрузки только новых файлов без проверки размера
- Добавлено логирование времени на каждый файл при загрузке
- Улучшена производительность синхронизации
- Обновлены README.md и CHANGELOG.md

Author: mueqee

CONTRIBUTING.md

@@ -11,4 +11,3 @@
     Сообщения пишем **на русском языке**.
 5.  Отправьте изменения в свой форк (`git push origin feature/AmazingFeature`).
 6.  Создайте Pull Request.
-- Начиная с версии 1.4.0, sync поддерживает рекурсивное создание директорий в облаке при загрузке (push).

build/lib/api.py

@@ -0,0 +1,48 @@
+from network import get_client
+
+
+def list_files(path: str = "/") -> list[str]:
+    """Возвращает список файлов/папок в указанной директории.
+    Работает через WebDAV.
+    """
+    client = get_client()
+    try:
+        return client.list(path)  # type: ignore[arg-type]
+    except Exception as exc:
+        print(f"Ошибка при получении списка файлов: {exc}")
+    return [] 
+
+
+# --- Дополнительные операции ---------------------------------------------------
+
+
+def delete_file(remote_path: str) -> bool:
+    """Удаляет файл или папку *remote_path* в облаке."""
+    client = get_client()
+    try:
+        client.clean(remote_path)  # type: ignore[arg-type]
+        return True
+    except Exception as exc:
+        print(f"Ошибка удаления: {exc}")
+        return False
+
+
+def move_file(src_path: str, dst_path: str) -> bool:
+    """Переименовывает/перемещает ресурс в облаке."""
+    client = get_client()
+    try:
+        client.move(src_path, dst_path)  # type: ignore[arg-type]
+        return True
+    except Exception as exc:
+        print(f"Ошибка перемещения: {exc}")
+        return False
+
+
+def file_info(remote_path: str) -> dict:
+    """Возвращает словарь информации о файле (size, modified и т.п.)."""
+    client = get_client()
+    try:
+        return client.info(remote_path)  # type: ignore[arg-type]
+    except Exception as exc:
+        print(f"Ошибка info: {exc}")
+        return {} 

build/lib/auth.py

@@ -0,0 +1,49 @@
+# mailrucloud/auth.py
+"""Модуль авторизации для WebDAV-доступа к Облаку Mail.ru.
+Схема проста: сохраняем в файл email и *пароль для внешнего приложения*.
+Никаких сетевых запросов при логине не требуется – WebDAV обрабатывает
+Basic-авторизацию самостоятельно.
+"""
+
+import json
+from pathlib import Path
+from typing import Optional
+
+CRED_FILE = Path.home() / ".mailru_token.json"
+
+
+def login(username: str, app_password: str) -> bool:
+    """Сохраняет учётные данные в файл.
+
+    Parameters
+    ----------
+    username : str
+        Полный e-mail пользователя (например, `user@mail.ru`).
+    app_password : str
+        Пароль для внешнего приложения, созданный в настройках безопасности
+        Mail.ru. *Не* обычный пароль от почты!
+    """
+    if "@" not in username:
+        print("❌ Введите полный e-mail, например user@mail.ru")
+        return False
+
+    data = {"email": username, "password": app_password}
+    try:
+        CRED_FILE.write_text(json.dumps(data))
+        print(f"✅ Данные сохранены в {CRED_FILE}")
+        return True
+    except OSError as exc:
+        print(f"❌ Не удалось сохранить файл учётных данных: {exc}")
+        return False
+
+
+def load_credentials() -> Optional[dict]:
+    """Читает файл учётных данных и возвращает словарь с ключами
+    `email` и `password`. Если файл отсутствует – ``None``.
+    """
+    if not CRED_FILE.exists():
+        return None
+    try:
+        return json.loads(CRED_FILE.read_text())
+    except (OSError, json.JSONDecodeError):
+    return None

build/lib/cli.py

@@ -0,0 +1,180 @@
+import click
+from auth import login
+from api import list_files, delete_file, move_file, file_info
+from upload import upload_file
+from download import download_file
+from sync import sync_directories
+
+@click.group()
+def cli():
+    """mailru-cloud: неофициальный Python-клиент для Mail.ru Облака"""
+    pass
+
+@cli.command()
+@click.option("--username", prompt=True)
+@click.option("--password", prompt=True, hide_input=True)
+def login_cmd(username, password):
+    """Авторизация в Mail.ru Cloud"""
+    success = login(username, password)
+    if success:
+        click.echo("✅ Успешная авторизация.")
+    else:
+        click.echo("❌ Ошибка авторизации.")
+
+
+@cli.command()
+@click.argument('remote_dir', default='/', required=False)
+def ls(remote_dir):
+    """Показать содержимое каталога в облаке (по умолчанию «/»)."""
+    files = list_files(remote_dir)
+    for f in files:
+        click.echo(f)
+
+
+@cli.command()
+@click.argument('local_path', type=click.Path(exists=True))
+@click.option('--remote-path', default=None, help='Целевой путь в облаке (по умолчанию /<имя_файла>)')
+def upload(local_path, remote_path):
+    """
+    Загрузка одного файла в облако.
+
+    LOCAL_PATH - путь к файлу на вашем компьютере.
+    """
+    target = remote_path or f"/(auto)"
+    click.echo(f"⏳ Загружаю {local_path} → {target}")
+    success = upload_file(local_path, remote_path)
+    if success:
+        click.secho("✅ Файл успешно загружен.", fg="green")
+    else:
+        click.secho("❌ Ошибка при загрузке файла.", fg="red")
+
+
+@cli.command()
+@click.argument('remote_path')
+@click.argument('local_path', required=False)
+def download(remote_path, local_path):
+    """Скачивание файла из облака.
+
+    REMOTE_PATH – путь в облаке (например /docs/report.pdf).
+    LOCAL_PATH – куда сохранить (по умолчанию тек. каталог и исходное имя).
+    """
+    dst = local_path or '(текущая папка)'
+    click.echo(f"⏳ Скачиваю {remote_path} → {dst}")
+    success = download_file(remote_path, local_path)
+    if success:
+        click.secho("✅ Файл скачан.", fg="green")
+    else:
+        click.secho("❌ Ошибка скачивания.", fg="red")
+
+
+@cli.command()
+@click.argument('local_dir', default='.')
+@click.argument('remote_dir', default='/')
+@click.option('--direction', '-d', type=click.Choice(['push', 'pull', 'both'], case_sensitive=False),
+              default='both', show_default=True,
+              help="Направление: push (локальное → облако), pull (облако → локальное), both (двусторонняя)")
+def sync(local_dir, remote_dir, direction):
+    """Синхронизация каталогов LOCAL_DIR и REMOTE_DIR."""
+    arrow = {
+        'push': '→',
+        'pull': '←',
+        'both': '↔',
+    }[direction.lower()]
+    click.echo(f"⏳ Синхронизация {local_dir} {arrow} {remote_dir} (mode: {direction})")
+    sync_directories(local_dir, remote_dir, direction.lower())
+    click.secho("✅ Синхронизация завершена.", fg="green")
+
+
+@cli.command(name='rm')
+@click.argument('remote_path')
+def cmd_rm(remote_path):
+    """Удалить файл/папку в облаке."""
+    click.echo(f"⏳ Удаляю {remote_path} …")
+    if delete_file(remote_path):
+        click.secho("✅ Удалено.", fg="green")
+    else:
+        click.secho("❌ Ошибка удаления.", fg="red")
+
+
+@cli.command(name='mv')
+@click.argument('src_path')
+@click.argument('dst_path')
+def cmd_mv(src_path, dst_path):
+    """Переименовать/переместить файл в облаке."""
+    click.echo(f"⏳ Перемещаю {src_path} → {dst_path}")
+    if move_file(src_path, dst_path):
+        click.secho("✅ Готово.", fg="green")
+    else:
+        click.secho("❌ Ошибка перемещения.", fg="red")
+
+
+@cli.command()
+@click.argument('remote_path')
+def info(remote_path):
+    """Показать информацию о файле (size, modified и т.п.)."""
+    data = file_info(remote_path)
+    if not data:
+        click.secho("❌ Не удалось получить информацию.", fg="red")
+        return
+    for k, v in data.items():
+        click.echo(f"{k}: {v}")
+
+
+@cli.command()
+def start():
+    """Запустить фоновую синхронизацию каталога ~/Mail.Cloud ↔ /."""
+    import subprocess
+    import sys
+    import os
+    from pathlib import Path
+
+    local_dir = Path.home() / "Mail.Cloud"
+    local_dir.mkdir(parents=True, exist_ok=True)
+
+    pid_file = Path.home() / ".mailrucloud-daemon.pid"
+    # Проверяем, не запущен ли демон уже
+    if pid_file.exists():
+        try:
+            pid = int(pid_file.read_text().strip())
+            os.kill(pid, 0)  # Проверка существования процесса
+            click.secho("⚠️  Демон уже запущен.", fg="yellow")
+            return
+        except (ProcessLookupError, ValueError):
+            # PID-файл устарел – удаляем
+            pid_file.unlink(missing_ok=True)
+        except PermissionError:
+            click.secho("❌ Нет прав проверить состояние демона.", fg="red")
+            return
+
+    daemon_script = Path(__file__).with_name("sync_daemon.py")
+    try:
+        subprocess.Popen(
+            [sys.executable, str(daemon_script)],
+            stdout=subprocess.DEVNULL,
+            stderr=subprocess.DEVNULL,
+            start_new_session=True,
+        )
+        click.secho("✅ Демон синхронизации запущен в фоне.", fg="green")
+    except Exception as exc:
+        click.secho(f"❌ Не удалось запустить демон: {exc}", fg="red")
+
+
+@cli.command()
+def stop():
+    """Остановить фоновый демон синхронизации."""
+    import os
+    import signal
+    from pathlib import Path
+    pid_file = Path.home() / ".mailrucloud-daemon.pid"
+    if not pid_file.exists():
+        click.secho("❌ PID-файл не найден. Демон не запущен?", fg="red")
+        return
+    try:
+        with open(pid_file) as f:
+            pid = int(f.read().strip())
+        os.kill(pid, signal.SIGTERM)
+        click.secho(f"✅ Отправлен сигнал SIGTERM процессу {pid}.", fg="green")
+        # Удаляем PID-файл сразу, система всё равно отдаст сигнал процессу
+        pid_file.unlink(missing_ok=True)
+    except Exception as exc:
+        click.secho(f"❌ Не удалось остановить демон: {exc}", fg="red")

build/lib/download.py

@@ -0,0 +1,53 @@
+from pathlib import Path
+from network import get_client
+
+
+def download_file(remote_path: str, local_path: str | None = None) -> bool:
+    """Скачивает файл `remote_path` из облака.
+
+    Параметры
+    ---------
+    remote_path : str
+        Путь к файлу в облаке (например, "/docs/report.pdf").
+    local_path : str | None
+        Куда сохранить файл на диске. Если *None*, используется имя файла
+        из `remote_path` и текущий каталог.
+    """
+    if local_path is None:
+        local_path = Path(remote_path).name
+
+    client = get_client()
+    try:
+        # Основной путь: штатная реализация библиотеки
+        client.download_sync(remote_path=remote_path, local_path=str(local_path))
+        print(f"Файл сохранён в: {local_path}")
+        return True
+    except Exception as exc:
+        # Для некоторых (особенно пустых или очень маленьких) файлов у облака
+        # отсутствует заголовок ``Content-Length``.  Штатная реализация
+        # `webdavclient3` в таком случае падает с KeyError.  Пытаемся обойти
+        # проблему: скачиваем файл «вручную» тем же клиентом, но напрямую через
+        # низкоуровневый `execute_request`, игнорируя прогресс.
+
+        if "content-length" in str(exc).lower():
+            try:
+                from webdav3.urn import Urn  # импорт здесь, чтобы избежать лишней зависимости при обычной работе
+
+                # Получаем поток ответа на GET.
+                response = client.execute_request(action="download", path=Urn(remote_path).quote())
+
+                # Стримингом пишем в файл.
+                with open(local_path, "wb") as fp:
+                    for chunk in response.iter_content(chunk_size=client.chunk_size):
+                        if chunk:  # пропускаем keep-alive
+                            fp.write(chunk)
+
+                print(f"Файл сохранён в: {local_path} (fallback)")
+                return True
+            except Exception as exc_fallback:
+                print(f"Ошибка скачивания (fallback): {exc_fallback}")
+                return False
+
+        # Иная ошибка – просто выводим и возвращаем False
+        print(f"Ошибка скачивания: {exc}")
+        return False

build/lib/main.py

@@ -0,0 +1,4 @@
+from cli import cli
+
+if __name__ == "__main__":
+    cli()

build/lib/network.py

@@ -0,0 +1,36 @@
+"""mailrucloud/network.py
+Поставщик WebDAV-клиента, настроенного с учётными данными из auth.py.
+Использует библиотеку `webdavclient3`.
+"""
+
+from typing import Optional
+from webdav3.client import Client  # type: ignore
+from auth import load_credentials
+
+
+_cached_client: Optional[Client] = None  # Singleton, чтобы не создавать несколько раз
+
+
+def get_client() -> Client:
+    """Возвращает настроенный экземпляр WebDAV-клиента.
+
+    Raises
+    ------
+    RuntimeError
+        Если учётные данные отсутствуют.
+    """
+    global _cached_client
+    if _cached_client is not None:
+        return _cached_client
+
+    creds = load_credentials()
+    if creds is None:
+        raise RuntimeError("Учётные данные не найдены. Выполните команду login сначала.")
+
+    options = {
+        "webdav_hostname": "https://webdav.cloud.mail.ru",
+        "webdav_login": creds["email"],
+        "webdav_password": creds["password"],
+    }
+    _cached_client = Client(options)
+    return _cached_client