Improved configuration file management with advanced features

- Added send2trash library for safer file deletion
- Implemented folder and file moving functionality in ConfigSelectorWindow
- Created FolderSelectorDialog for moving files to a folder
- Improved file and folder renaming with improved error handling
- Added emoji icons for better visual representation of actions
- Updated requirements.txt to include send2trash library
- Removed drag-and-drop support. Postponed for future

.gitignore

@@ -1,9 +1,6 @@
 app.log
 Settings/settings.json
-Configs/Eltex MES2424 AC - Сеть FTTB 2G, доп.txt
+Configs/
-Configs/конфиг доп 3750-52 с айпи 172.17.141.133 .txt
-DALL·E 2024-12-29 01.01.02 - Square vector logo_ A clean and minimalistic app icon for serial port management software. The design prominently features a simplified rectangular CO.ico
-test.py
 __pycache__/
 Firmware/1.jpg
 Firmware/2

README.md

@@ -0,0 +1,44 @@
+# ComConfigCopy
+
+Программа для копирования конфигураций на коммутаторы.
+
+## Описание
+
+ComConfigCopy - это утилита, разработанная для автоматизации процесса копирования конфигураций на сетевые коммутаторы. Программа предоставляет удобный графический интерфейс для управления процессом копирования и настройки параметров подключения.
+
+## Основные возможности
+
+- Копирование конфигураций на коммутаторы через COM-порт
+- Поддержка различных скоростей подключения
+- Автоматическое определение доступных COM-портов
+- Возможность сохранения и загрузки настроек
+- Автоматическое обновление через GitHub
+
+## Системные требования
+
+- Windows 7/8/10/11
+- Python 3.8 или выше
+- Доступ к COM-портам
+
+## Установка
+
+1. Скачайте последнюю версию программы из [репозитория](https://gitea.filow.ru/LowaSC/ComConfigCopy/releases)
+2. Распакуйте архив в удобное место
+3. Запустите файл `ComConfigCopy.exe`
+
+## Использование
+
+1. Выберите COM-порт из списка доступных
+2. Настройте параметры подключения (скорость, биты данных и т.д.)
+3. Выберите файл конфигурации для отправки
+4. Нажмите кнопку "Отправить" для начала процесса копирования
+
+## Контакты
+
+- Email: SPRF555@gmail.com
+- Telegram: [@LowaSC](https://t.me/LowaSC)
+- Репозиторий: [ComConfigCopy](https://gitea.filow.ru/LowaSC/ComConfigCopy)
+
+## Лицензия
+
+Этот проект распространяется под лицензией MIT. Подробности смотрите в файле [LICENSE](LICENSE). 

TFTPServer.py

@@ -224,6 +224,8 @@ class TFTPServer:
         Передача файла клиенту по протоколу TFTP.
         """
         BLOCK_SIZE = 512
+        MAX_RETRIES = 5
+        TIMEOUT = 2.0
         transfer_socket = None
         try:
             if not os.path.exists(file_path):
@@ -249,124 +251,99 @@ class TFTPServer:
                     'start_time': start_time
                 }
             
-            self.log(f"[INFO] Начало передачи файла '{file_basename}' клиенту {client_addr}. Размер файла: {filesize} байт.")
+            # Создаем новый сокет для передачи данных
-            
-            # Создаем отдельный сокет для передачи файла
             transfer_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
-            transfer_socket.settimeout(5.0)  # Таймаут ожидания ACK
+            transfer_socket.settimeout(TIMEOUT)
             
-            # Добавляем сокет в множество активных сокетов
             with self.lock:
                 self.transfer_sockets.add(transfer_socket)
             
-            block_num = 1
+            self.log(f"[INFO] Начало передачи файла '{file_basename}' клиенту {client_addr}. Размер файла: {filesize} байт.")
-            bytes_sent = 0
-            last_progress_time = time.time()
 
-            try:
+            with open(file_path, 'rb') as file:
-                with open(file_path, "rb") as f:
+                block_number = 1
-                    while self.running:  # Проверяем флаг running
+                last_successful_block = 0
-                        try:
-                            data_block = f.read(BLOCK_SIZE)
-                            if not data_block:  # Достигнут конец файла
-                                break
                 
-                            # Проверяем флаг running перед отправкой блока
+                while True:
-                            if not self.running:
+                    # Читаем блок данных
-                                raise Exception("Передача прервана: сервер остановлен")
+                    data = file.read(BLOCK_SIZE)
                     
-                            # Формируем TFTP пакет данных
+                    # Формируем и отправляем пакет данных
-                            packet = struct.pack("!HH", 3, block_num) + data_block
+                    packet = struct.pack('!HH', 3, block_number) + data
-                            attempts = 0
-                            ack_received = False
-
-                            # Попытка отправки текущего блока (до 3 повторных попыток)
-                            while attempts < 3 and not ack_received and self.running:
-                                if transfer_socket is None:
-                                    raise Exception("Сокет передачи закрыт")
                     
+                    retries = 0
+                    while retries < MAX_RETRIES:
                         try:
                             transfer_socket.sendto(packet, client_addr)
                             
-                                    # Логируем прогресс каждую секунду
-                                    current_time = time.time()
-                                    if current_time - last_progress_time >= 1.0:
-                                        elapsed_time = current_time - start_time
-                                        remaining = filesize - bytes_sent
-                                        self.log(f"[STATUS] Клиент: {client_addr} | Файл: {file_basename} | "
-                                               f"Отправлено: {bytes_sent}/{filesize} байт | "
-                                               f"Осталось: {remaining} байт | "
-                                               f"Время: {elapsed_time:.2f} сек.")
-                                        last_progress_time = current_time
-
                             # Ожидаем подтверждение
-                                    ack_data, addr = transfer_socket.recvfrom(4)
+                            while True:
-                                    if addr == client_addr:
+                                try:
-                                        ack_opcode, ack_block = struct.unpack("!HH", ack_data)
+                                    ack_data, ack_addr = transfer_socket.recvfrom(4)
-                                        if ack_opcode == 4 and ack_block == block_num:
+                                    if ack_addr == client_addr and len(ack_data) >= 4:
-                                            ack_received = True
+                                        opcode, ack_block = struct.unpack('!HH', ack_data)
-                                            bytes_sent += len(data_block)
+                                        if opcode == 4:  # ACK
+                                            if ack_block == block_number:
+                                                # Успешное подтверждение
+                                                last_successful_block = block_number
+                                                bytes_sent = min((block_number * BLOCK_SIZE), filesize)
+                                                
+                                                # Обновляем информацию о прогрессе
                                                 with self.lock:
                                                     if client_addr in self.active_transfers:
                                                         self.active_transfers[client_addr]['bytes_sent'] = bytes_sent
-                                        else:
+                                                
-                                            self.log(f"[WARN] Неверный ACK от {client_addr}. "
+                                                # Логируем статус каждую секунду
-                                                   f"Ожидался блок {block_num}, получен {ack_block}.")
+                                                current_time = time.time()
+                                                if current_time - start_time >= 1.0:
+                                                    bytes_remaining = filesize - bytes_sent
+                                                    elapsed_time = current_time - start_time
+                                                    self.log(f"[STATUS] Клиент: {client_addr} | Файл: {file_basename} | "
+                                                           f"Отправлено: {bytes_sent}/{filesize} байт | "
+                                                           f"Осталось: {bytes_remaining} байт | "
+                                                           f"Время: {elapsed_time:.2f} сек.")
+                                                
+                                                break
+                                            elif ack_block < block_number:
+                                                # Получен старый ACK, игнорируем
+                                                continue
                                 except socket.timeout:
-                                    attempts += 1
+                                    break
-                                    self.log(f"[WARN] Таймаут ожидания ACK для блока {block_num} "
+                            
-                                           f"от {client_addr}. Попытка {attempts+1}.")
+                            if last_successful_block == block_number:
-                                except socket.error as e:
+                                break
-                                    if not self.running:
+                            else:
-                                        raise Exception("Передача прервана: сервер остановлен")
+                                retries += 1
-                                    self.log(f"[ERROR] Ошибка сокета при отправке блока {block_num}: {str(e)}")
+                                self.log(f"[WARN] Таймаут ожидания ACK для блока {block_number} от {client_addr}. "
-                                    attempts += 1
+                                       f"Попытка {retries + 1}.")
                         except Exception as e:
-                                    if not self.running:
+                            retries += 1
-                                        raise Exception("Передача прервана: сервер остановлен")
+                            self.log(f"[ERROR] Ошибка при передаче блока {block_number}: {str(e)}")
-                                    self.log(f"[ERROR] Ошибка при отправке блока {block_num}: {str(e)}")
-                                    attempts += 1
                     
-                            if not ack_received:
+                    if retries >= MAX_RETRIES:
-                                raise Exception(f"Не удалось получить подтверждение для блока {block_num}")
+                        self.log(f"[ERROR] Превышено максимальное количество попыток для блока {block_number}")
+                        return
                     
-                            block_num = (block_num + 1) % 65536
+                    block_number += 1
+                    
+                    # Если отправили меньше BLOCK_SIZE байт, это был последний блок
+                    if len(data) < BLOCK_SIZE:
+                        break
+
+            self.log(f"[INFO] Передача файла '{file_basename}' клиенту {client_addr} завершена успешно")
 
         except Exception as e:
-                            if not self.running:
+            self.log(f"[ERROR] Ошибка при передаче файла: {str(e)}")
-                                raise Exception("Передача прервана: сервер остановлен")
-                            raise
-
-                if bytes_sent == filesize:
-                    elapsed_time = time.time() - start_time
-                    self.log(f"[INFO] Передача файла '{file_basename}' клиенту {client_addr} "
-                            f"завершена за {elapsed_time:.2f} сек. Всего отправлено {bytes_sent} байт.")
-            except Exception as e:
-                if not self.running:
-                    self.log(f"[INFO] Передача файла '{file_basename}' клиенту {client_addr} прервана: сервер остановлен")
-                raise
-
-        except Exception as e:
-            if not self.running:
-                return  # Не логируем повторно о прерывании передачи
-            self.log(f"[ERROR] Ошибка при передаче файла '{os.path.basename(file_path)}' "
-                    f"клиенту {client_addr}: {str(e)}")
-            try:
-                self.send_error(client_addr, 0, str(e))
-            except:
-                pass
         finally:
-            # Закрываем сокет передачи
+            # Очищаем информацию о передаче
-            if transfer_socket:
-                try:
-                    with self.lock:
-                        self.transfer_sockets.discard(transfer_socket)
-                    transfer_socket.close()
-                    transfer_socket = None
-                except:
-                    pass
-            
-            # Удаляем информацию о передаче
             with self.lock:
                 if client_addr in self.active_transfers:
                     del self.active_transfers[client_addr]
+                if transfer_socket in self.transfer_sockets:
+                    self.transfer_sockets.remove(transfer_socket)
+            
+            if transfer_socket:
+                try:
+                    transfer_socket.close()
+                except:
+                    pass 

about_window.py

@@ -2,19 +2,22 @@
 # -*- coding: utf-8 -*-
 
 import tkinter as tk
-from tkinter import ttk, BOTH, X, BOTTOM
+from tkinter import ttk, BOTH, X, BOTTOM, END
 import webbrowser
 
 class AboutWindow(tk.Toplevel):
     def __init__(self, parent):
         super().__init__(parent)
         self.title("О программе")
-        self.geometry("400x300")
+        self.geometry("600x500")
         self.resizable(False, False)
         
-        # Создаем фрейм
+        # Сохраняем ссылку на родительское окно
+        self.parent = parent
+        
+        # Создаем фрейм для содержимого
         about_frame = ttk.Frame(self, padding="20")
-        about_frame.pack(fill=BOTH, expand=True)
+        about_frame.pack(fill=BOTH, expand=True, padx=10, pady=10)
         
         # Заголовок
         ttk.Label(
@@ -33,7 +36,7 @@ class AboutWindow(tk.Toplevel):
         # Версия
         ttk.Label(
             about_frame,
-            text="Версия 1.0",
+            text=f"Версия {getattr(parent, 'VERSION', '1.0.0')}",
             font=("Segoe UI", 10)
         ).pack(pady=(0, 20))
         
@@ -66,7 +69,7 @@ class AboutWindow(tk.Toplevel):
         
         ttk.Label(
             contact_frame,
-            text="Email: LowaWorkMail@gmail.com"
+            text="Email: SPRF555@gmail.com"
         ).pack(anchor="w")
         
         telegram_link = ttk.Label(
@@ -80,10 +83,10 @@ class AboutWindow(tk.Toplevel):
         
         # Кнопка закрытия
         ttk.Button(
-            about_frame,
+            self,
             text="Закрыть",
             command=self.destroy
-        ).pack(side=BOTTOM, pady=(20, 0))
+        ).pack(side=BOTTOM, pady=10)
         
         # Центрируем окно
         self.center_window()

requirements.txt

@@ -1 +1,5 @@
 tftpy>=0.8.0
+pyserial>=3.5
+requests>=2.31.0
+packaging>=23.2
+send2trash>=1.8.0 

update_checker.py

@@ -0,0 +1,165 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+import logging
+import requests
+import threading
+import re
+from packaging import version
+import xml.etree.ElementTree as ET
+import html
+
+class UpdateCheckError(Exception):
+    """Исключение для ошибок проверки обновлений"""
+    pass
+
+class ReleaseType:
+    """Типы релизов"""
+    STABLE = "stable"
+    PRERELEASE = "prerelease"
+
+class UpdateChecker:
+    """Класс для проверки обновлений программы"""
+    
+    def __init__(self, current_version, repo_url, include_prereleases=False):
+        self.current_version = current_version
+        self.repo_url = repo_url
+        self.include_prereleases = include_prereleases
+        self.rss_url = f"{repo_url}/releases.rss"
+        self.release_info = None
+
+    def _clean_html(self, html_text):
+        """Очищает HTML-разметку и форматирует текст"""
+        if not html_text:
+            return ""
+        text = re.sub(r'<[^>]+>', '', html_text)
+        text = html.unescape(text)
+        text = re.sub(r'\n\s*\n', '\n\n', text)
+        return '\n'.join(line.strip() for line in text.splitlines()).strip()
+
+    def _parse_release_info(self, item):
+        """Извлекает информацию о релизе из RSS item"""
+        title = item.find('title').text if item.find('title') is not None else ''
+        link = item.find('link').text if item.find('link') is not None else ''
+        description = item.find('description').text if item.find('description') is not None else ''
+        content = item.find('{http://purl.org/rss/1.0/modules/content/}encoded')
+        content_text = content.text if content is not None else ''
+        
+        # Извлекаем версию и проверяем тип релиза из тега
+        version_match = re.search(r'/releases/tag/(?:pre-)?v?(\d+\.\d+(?:\.\d+)?)', link)
+        if not version_match:
+            return None
+            
+        version_str = version_match.group(1)
+        # Проверяем наличие префикса pre- в теге
+        is_prerelease = 'pre-' in link.lower()
+        
+        # Форматируем название релиза
+        formatted_title = title
+        if title == version_str or not title.strip():
+            # Если заголовок пустой или совпадает с версией, создаем стандартное название
+            release_type = "Пре-релиз" if is_prerelease else "Версия"
+            formatted_title = f"{release_type} {version_str}"
+        elif not re.search(version_str, title):
+            # Если версия не указана в заголовке, добавляем её
+            formatted_title = f"{title} ({version_str})"
+            
+        # Форматируем описание
+        formatted_description = self._clean_html(content_text or description)
+        if not formatted_description.strip():
+            formatted_description = "Нет описания"
+            
+        # Добавляем метку типа релиза в начало описания
+        release_type_label = "[Пре-релиз] " if is_prerelease else ""
+        formatted_description = f"{release_type_label}{formatted_description}"
+        
+        return {
+            'title': formatted_title,
+            'link': link,
+            'description': formatted_description,
+            'version': version_str,
+            'type': ReleaseType.PRERELEASE if is_prerelease else ReleaseType.STABLE
+        }
+
+    def check_updates(self, callback=None):
+        """Проверяет наличие обновлений в асинхронном режиме"""
+        def check_worker():
+            try:
+                logging.info(f"Текущая версия программы: {self.current_version}")
+                logging.info(f"Проверка пре-релизов: {self.include_prereleases}")
+                logging.info(f"Запрос RSS ленты: {self.rss_url}")
+                
+                response = requests.get(self.rss_url, timeout=10)
+                response.raise_for_status()
+                
+                root = ET.fromstring(response.content)
+                items = root.findall('.//item')
+                if not items:
+                    raise UpdateCheckError("Релизы не найдены")
+                
+                logging.info(f"Найдено {len(items)} релизов")
+                
+                latest_version = None
+                latest_info = None
+                
+                for item in items:
+                    release_info = self._parse_release_info(item)
+                    if not release_info:
+                        continue
+                        
+                    is_prerelease = release_info['type'] == ReleaseType.PRERELEASE
+                    logging.info(
+                        f"Проверка релиза: {release_info['title']}, "
+                        f"версия: {release_info['version']}, "
+                        f"тип: {'пре-релиз' if is_prerelease else 'стабильная'}"
+                    )
+                    
+                    # Пропускаем пре-релизы если они не включены
+                    if is_prerelease and not self.include_prereleases:
+                        logging.info(f"Пропуск пре-релиза: {release_info['version']}")
+                        continue
+                    
+                    # Сравниваем версии
+                    try:
+                        current_ver = version.parse(latest_version or "0.0.0")
+                        new_ver = version.parse(release_info['version'].split('-')[0])  # Убираем суффикс для сравнения
+                        
+                        if new_ver > current_ver:
+                            latest_version = release_info['version']
+                            latest_info = release_info
+                            logging.info(f"Новая версия: {latest_version}")
+                            
+                    except version.InvalidVersion as e:
+                        logging.warning(f"Некорректный формат версии {release_info['version']}: {e}")
+                        continue
+                
+                if not latest_info:
+                    raise UpdateCheckError("Не найдены подходящие версии")
+                
+                self.release_info = latest_info
+                
+                # Сравниваем с текущей версией
+                current_ver = version.parse(self.current_version)
+                latest_ver = version.parse(latest_version.split('-')[0])
+                update_available = latest_ver > current_ver
+                
+                logging.info(f"Сравнение версий: текущая {current_ver} <-> последняя {latest_ver}")
+                logging.info(f"Доступно обновление: {update_available}")
+                
+                if callback:
+                    callback(update_available, None)
+                    
+            except UpdateCheckError as e:
+                logging.error(str(e))
+                if callback:
+                    callback(False, str(e))
+            except Exception as e:
+                logging.error(f"Ошибка при проверке обновлений: {e}", exc_info=True)
+                if callback:
+                    callback(False, str(e))
+
+        threading.Thread(target=check_worker, daemon=True).start()
+    
+    def get_release_notes(self):
+        """Возвращает информацию о последнем релизе"""
+        return self.release_info