Commit 3dac5d8b authored by guillecxb's avatar guillecxb
Browse files

add timeout for requests

parent d11a3517
Loading
Loading
Loading
Loading
Loading
+4 −0
Original line number Original line Diff line number Diff line
@@ -219,6 +219,7 @@ class capif_invoker_connector:
                url,
                url,
                cert=(self.signed_key_crt_path, self.private_key_path),
                cert=(self.signed_key_crt_path, self.private_key_path),
                verify=self.pathca,
                verify=self.pathca,
                timeout=60,
            )
            )
            response.raise_for_status()
            response.raise_for_status()
            self.logger.info("Invoker offboarded successfully")
            self.logger.info("Invoker offboarded successfully")
@@ -306,6 +307,7 @@ class capif_invoker_connector:
                auth=HTTPBasicAuth(self.capif_username,
                auth=HTTPBasicAuth(self.capif_username,
                                   self.capif_invoker_password),
                                   self.capif_invoker_password),
                verify=False,
                verify=False,
                timeout=60,
            )
            )


            response.raise_for_status()
            response.raise_for_status()
@@ -350,6 +352,7 @@ class capif_invoker_connector:
                headers=headers,
                headers=headers,
                data=payload,
                data=payload,
                verify=self.pathca,
                verify=self.pathca,
                timeout=60,
            )
            )
            response.raise_for_status()
            response.raise_for_status()
            response_payload = json.loads(response.text)
            response_payload = json.loads(response.text)
@@ -455,6 +458,7 @@ class capif_invoker_connector:
                data=payload,
                data=payload,
                cert=(self.signed_key_crt_path, self.private_key_path),
                cert=(self.signed_key_crt_path, self.private_key_path),
                verify=self.pathca,
                verify=self.pathca,
                timeout=60,
            )
            )


            response.raise_for_status()
            response.raise_for_status()
+2 −1
Original line number Original line Diff line number Diff line
@@ -525,7 +525,8 @@ class service_discoverer:
                "POST",
                "POST",
                url,
                url,
                headers=headers,
                headers=headers,
                json=payload
                json=payload,
                timeout=60
            )
            )


            response.raise_for_status()
            response.raise_for_status()
+3 −1
Original line number Original line Diff line number Diff line
@@ -39,6 +39,7 @@ def __log_to_capif(variables):
            headers={"Content-Type": "application/json"},
            headers={"Content-Type": "application/json"},
            auth=HTTPBasicAuth(variables["capif_register_username"], variables["capif_register_password"]),
            auth=HTTPBasicAuth(variables["capif_register_username"], variables["capif_register_password"]),
            verify=False,
            verify=False,
            timeout=60,
        )
        )
        response.raise_for_status()
        response.raise_for_status()
        response_payload = json.loads(response.text)
        response_payload = json.loads(response.text)
@@ -64,7 +65,8 @@ def de_register_from_capif(admin_token, variables):
        url,
        url,
        headers=headers,
        headers=headers,
        data=None,
        data=None,
        verify=False
        verify=False,
        timeout=60
    )
    )
    response.raise_for_status()
    response.raise_for_status()
    logger.info("User deleted")
    logger.info("User deleted")
+2 −1
Original line number Original line Diff line number Diff line
@@ -35,6 +35,7 @@ def __log_to_capif(variables):
            headers={"Content-Type": "application/json"},
            headers={"Content-Type": "application/json"},
            auth=HTTPBasicAuth(variables["capif_register_username"], variables["capif_register_password"]),
            auth=HTTPBasicAuth(variables["capif_register_username"], variables["capif_register_password"]),
            verify=False,
            verify=False,
            timeout=60,
        )
        )
        response.raise_for_status()
        response.raise_for_status()
        response_payload = json.loads(response.text)
        response_payload = json.loads(response.text)
@@ -64,7 +65,7 @@ def __create_user(admin_token, variables):
        }
        }


        response = requests.request(
        response = requests.request(
            "POST", url, headers=headers, data=json.dumps(payload), verify=False
            "POST", url, headers=headers, data=json.dumps(payload), verify=False, timeout=60
        )
        )
        response.raise_for_status()
        response.raise_for_status()
        response_payload = json.loads(response.text)
        response_payload = json.loads(response.text)