diff --git a/config.yaml b/config.yaml index f48daed..ac1b11d 100644 --- a/config.yaml +++ b/config.yaml @@ -49,10 +49,8 @@ pt_sandbox: # Отключать проверку SSL-сертификата (для самоподписанных сертификатов) verify_ssl: true - # Endpoint для загрузки файла во временное хранилище - upload_endpoint: "/api/v1/storage/uploadScanFile" - # Endpoint для запуска проверки загруженного файла - scan_endpoint: "/api/v1/analysis/createScanTask" + # Endpoint для загрузки + запуска проверки одним запросом (соответствует лицензии) + upload_endpoint: "/api/v1/scan/checkFile" # Заголовок и значение для авторизации в Sandbox auth_header: "X-API-Key" diff --git a/main.py b/main.py index 31ffe51..d244b80 100644 --- a/main.py +++ b/main.py @@ -355,8 +355,7 @@ class PTSandboxClient: def __init__(self, cfg: dict): sb_cfg = cfg["pt_sandbox"] self.base_url = sb_cfg["base_url"].rstrip("/") - self.upload_endpoint = sb_cfg.get("upload_endpoint", "/api/v1/storage/uploadScanFile") - self.scan_endpoint = sb_cfg.get("scan_endpoint", "/api/v1/analysis/createScanTask") + self.upload_endpoint = sb_cfg.get("upload_endpoint", "/api/v1/scan/checkFile") self.auth_header = sb_cfg.get("auth_header", "X-API-Key") self.api_key = sb_cfg.get("api_key", "") self.file_field_name = sb_cfg.get("file_field_name", "file") @@ -378,93 +377,46 @@ class PTSandboxClient: self._session.mount("https://", InsecureSslAdapter()) logger.warning("Проверка SSL-сертификата отключена для PT Sandbox") - def _request(self, method: str, url: str, **kwargs) -> requests.Response: - """Выполнить HTTP-запрос к API PT Sandbox.""" - try: - resp = self._session.request(method, url, **kwargs) - if resp.status_code == 401: - logger.error("Sandbox 401: неверный или неактивный токен доступа") - return resp - resp.raise_for_status() - return resp - except requests.exceptions.RequestException as exc: - logger.error("Ошибка запроса Sandbox %s: %s", url, exc) - raise - def upload_file(self, file_path: Path) -> Optional[str]: - """ - Двухшаговый流程: загрузить файл в Sandbox, затем запустить проверку. - Возвращает scan_id или None при ошибке. - """ - # Шаг 1: загрузка файла - upload_url = f"{self.base_url}{self.upload_endpoint}" - logger.info("Шаг 1/2: загрузка файла %s в Sandbox", file_path.name) + """Отправить файл в PT Sandbox на анализ (загрузка + запуск проверки одним запросом). + Возвращает scan_id или None при ошибке.""" + params = { + "file_name": file_path.name, + "async_result": "true", + } + url = f"{self.base_url}{self.upload_endpoint}" + logger.info("Отправка файла в Sandbox: %s", file_path.name) try: with open(file_path, "rb") as fh: files = {self.file_field_name: (file_path.name, fh)} resp = self._session.post( - upload_url, files=files, + url, params=params, files=files, timeout=(self.timeout_connect, self.timeout_read), verify=self.verify_ssl, ) if resp.status_code not in (200, 201, 202): - logger.error("Sandbox ошибка загрузки: %s: %s", + logger.error("Sandbox вернул %s: %s", resp.status_code, resp.text[:500]) return None - upload_data = resp.json().get("data", {}) - file_uri = upload_data.get("file_uri") - if not file_uri: - logger.error("Sandbox: не получен file_uri в ответе на загрузку") - return None - logger.debug("Файл загружен, file_uri=%s", file_uri) - - except requests.RequestException as exc: - logger.error("Ошибка загрузки файла %s в Sandbox: %s", - file_path.name, exc) - return None - except OSError as exc: - logger.error("Ошибка чтения файла %s: %s", file_path.name, exc) - return None - - # Шаг 2: запуск проверки - scan_url = f"{self.base_url}{self.scan_endpoint}" - logger.info("Шаг 2/2: запуск проверки файла %s", file_path.name) - - try: - body = { - "file_uri": file_uri, - "file_name": file_path.name, - "async_result": True, - "short_result": True, - } - resp = self._session.post( - scan_url, json=body, - timeout=(self.timeout_connect, self.timeout_read), - verify=self.verify_ssl, - ) - - if resp.status_code not in (200, 201, 202): - logger.error("Sandbox ошибка запуска проверки: %s: %s", - resp.status_code, resp.text[:500]) - return None - - scan_data = resp.json().get("data", {}) - scan_id = scan_data.get("scan_id") or scan_data.get("id") + data = resp.json().get("data", {}) + scan_id = data.get("scan_id") or data.get("id") if scan_id: logger.info("Файл %s принят Sandbox. scan_id=%s", file_path.name, scan_id) return str(scan_id) - logger.error("Sandbox: не получен scan_id в ответе") return None - except requests.RequestException as exc: - logger.error("Ошибка запуска проверки %s в Sandbox: %s", + except requests.exceptions.RequestException as exc: + logger.error("Ошибка отправки файла %s в Sandbox: %s", file_path.name, exc) return None + except OSError as exc: + logger.error("Ошибка чтения файла %s: %s", file_path.name, exc) + return None # ─────────────────────────────────────────────────────────