From 4a8302d8c1c55b36570e2e225568629686970104 Mon Sep 17 00:00:00 2001 From: cccs-kevin <59843993+cccs-kevin@users.noreply.github.com> Date: Fri, 11 Dec 2020 09:05:45 -0500 Subject: [PATCH] Adding logs for REST calls, giving MD some time to breathe (#5) --- metadefender.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/metadefender.py b/metadefender.py index 98b2108..147c206 100644 --- a/metadefender.py +++ b/metadefender.py @@ -124,6 +124,7 @@ def _get_version_map(self, node: str): url = urljoin(node, 'stat/engines') try: + self.log.debug(f"_get_version_map: GET {url}") r = self.session.get(url=url, timeout=self.timeout) engines = r.json() @@ -209,6 +210,7 @@ def get_scan_results_by_data_id(self, data_id: str): url = urljoin(self.current_node, f"file/{data_id}") try: + self.log.debug(f"get_scan_results_by_data_id: GET {url}") return self.session.get(url=url, headers=self.headers, timeout=self.timeout) except requests.exceptions.Timeout: self.new_node(force=True, reset_queue=True) @@ -261,6 +263,7 @@ def scan_file(self, filename: str): data = f.read() try: + self.log.debug(f"scan_file: POST {url}") r = self.session.post(url=url, data=data, headers=self.headers, timeout=self.timeout) except requests.exceptions.Timeout: self.new_node(force=True, reset_queue=True) @@ -274,6 +277,8 @@ def scan_file(self, filename: str): if r.status_code == requests.codes.ok: data_id = r.json()['data_id'] + # Give MD some time to scan it! + time.sleep(1) while True: r = self.get_scan_results_by_data_id(data_id=data_id) if r.status_code != requests.codes.ok: