chore: Update several packages versions and add code of conduct (#234)

* chore: Update several packages versions and add code of conduct

* fix: Review tests not passing

* fix: Fix some tests regarding chain validation

* chore: Reformat some bad formed strings

---------

Co-authored-by: jgarciai <35931740+jgarciai@users.noreply.github.com>

Author: angel-devo

CHANGELOG.md

@@ -6,11 +6,18 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/) a
 
 ## [Unreleased]
 
+### Added
+
+- Added Code of Conduct.
+
 ### Changed
 
-- Restrict insecure TLS versions in Sender and API clients to TLSv1.2 and TLSv1.3
+- Restrict insecure TLS versions in Sender and API clients to TLSv1.2 and TLSv1.3.
 - Remove disclosing information in messages about keepalive token.
 - Fix incorences in documentation about using `url` and `address` interchangeably.
+- `certifi` dependency upgraded from `certifi~=2023.7.22` to `certifi~=2023.11.17`
+- `cryptography` dependency upgraded from `cryptography~=41.0.5` to `cryptography~=41.0.7`
+- `pipdeptree` dependency upgraded from `pipdeptree~=2.13.0` to `pipdeptree~=2.13.1`
 - `pyopenssl` dependency upgraded from `pyopenssl~=23.2` to `pyopenssl~=23.3`
 - `responses` dependency upgraded from `responses~=0.22.3` to `responses~=0.24`
 

CODE_OF_CONDUCT.md

@@ -0,0 +1,132 @@
+# Contributor Covenant Code of Conduct
+
+## Our Pledge
+
+We as members, contributors, and leaders pledge to make participation in our
+community a harassment-free experience for everyone, regardless of age, body
+size, visible or invisible disability, ethnicity, sex characteristics, gender
+identity and expression, level of experience, education, socio-economic status,
+nationality, personal appearance, race, caste, color, religion, or sexual
+identity and orientation.
+
+We pledge to act and interact in ways that contribute to an open, welcoming,
+diverse, inclusive, and healthy community.
+
+## Our Standards
+
+Examples of behavior that contributes to a positive environment for our
+community include:
+
+* Demonstrating empathy and kindness toward other people
+* Being respectful of differing opinions, viewpoints, and experiences
+* Giving and gracefully accepting constructive feedback
+* Accepting responsibility and apologizing to those affected by our mistakes,
+  and learning from the experience
+* Focusing on what is best not just for us as individuals, but for the overall
+  community
+
+Examples of unacceptable behavior include:
+
+* The use of sexualized language or imagery, and sexual attention or advances of
+  any kind
+* Trolling, insulting or derogatory comments, and personal or political attacks
+* Public or private harassment
+* Publishing others' private information, such as a physical or email address,
+  without their explicit permission
+* Other conduct which could reasonably be considered inappropriate in a
+  professional setting
+
+## Enforcement Responsibilities
+
+Community leaders are responsible for clarifying and enforcing our standards of
+acceptable behavior and will take appropriate and fair corrective action in
+response to any behavior that they deem inappropriate, threatening, offensive,
+or harmful.
+
+Community leaders have the right and responsibility to remove, edit, or reject
+comments, commits, code, wiki edits, issues, and other contributions that are
+not aligned to this Code of Conduct, and will communicate reasons for moderation
+decisions when appropriate.
+
+## Scope
+
+This Code of Conduct applies within all community spaces, and also applies when
+an individual is officially representing the community in public spaces.
+Examples of representing our community include using an official email address,
+posting via an official social media account, or acting as an appointed
+representative at an online or offline event.
+
+## Enforcement
+
+Instances of abusive, harassing, or otherwise unacceptable behavior may be
+reported to the community leaders responsible for enforcement at
+[support@devo.com](support@devo.com).
+All complaints will be reviewed and investigated promptly and fairly.
+
+All community leaders are obligated to respect the privacy and security of the
+reporter of any incident.
+
+## Enforcement Guidelines
+
+Community leaders will follow these Community Impact Guidelines in determining
+the consequences for any action they deem in violation of this Code of Conduct:
+
+### 1. Correction
+
+**Community Impact**: Use of inappropriate language or other behavior deemed
+unprofessional or unwelcome in the community.
+
+**Consequence**: A private, written warning from community leaders, providing
+clarity around the nature of the violation and an explanation of why the
+behavior was inappropriate. A public apology may be requested.
+
+### 2. Warning
+
+**Community Impact**: A violation through a single incident or series of
+actions.
+
+**Consequence**: A warning with consequences for continued behavior. No
+interaction with the people involved, including unsolicited interaction with
+those enforcing the Code of Conduct, for a specified period of time. This
+includes avoiding interactions in community spaces as well as external channels
+like social media. Violating these terms may lead to a temporary or permanent
+ban.
+
+### 3. Temporary Ban
+
+**Community Impact**: A serious violation of community standards, including
+sustained inappropriate behavior.
+
+**Consequence**: A temporary ban from any sort of interaction or public
+communication with the community for a specified period of time. No public or
+private interaction with the people involved, including unsolicited interaction
+with those enforcing the Code of Conduct, is allowed during this period.
+Violating these terms may lead to a permanent ban.
+
+### 4. Permanent Ban
+
+**Community Impact**: Demonstrating a pattern of violation of community
+standards, including sustained inappropriate behavior, harassment of an
+individual, or aggression toward or disparagement of classes of individuals.
+
+**Consequence**: A permanent ban from any sort of public interaction within the
+community.
+
+## Attribution
+
+This Code of Conduct is adapted from the [Contributor Covenant][homepage],
+version 2.1, available at
+[https://www.contributor-covenant.org/version/2/1/code_of_conduct.html][v2.1].
+
+Community Impact Guidelines were inspired by
+[Mozilla's code of conduct enforcement ladder][Mozilla CoC].
+
+For answers to common questions about this code of conduct, see the FAQ at
+[https://www.contributor-covenant.org/faq][FAQ]. Translations are available at
+[https://www.contributor-covenant.org/translations][translations].
+
+[homepage]: https://www.contributor-covenant.org
+[v2.1]: https://www.contributor-covenant.org/version/2/1/code_of_conduct.html
+[Mozilla CoC]: https://github.com/mozilla/diversity
+[FAQ]: https://www.contributor-covenant.org/faq
+[translations]: https://www.contributor-covenant.org/translations

devo/api/client.py

@@ -303,9 +303,7 @@ def __init__(
             verify = verify if verify is not None else config.get("verify", True)
             retries = retries if retries is not None else config.get("retries", 0)
             timeout = timeout if timeout is not None else config.get("timeout", 300)
-            retry_delay = (
-                retry_delay if retry_delay is not None else config.get("retry_delay", 5)
-            )
+            retry_delay = retry_delay if retry_delay is not None else config.get("retry_delay", 5)
             self.config = self._from_dict(config)
 
         self.auth = auth
@@ -351,9 +349,7 @@ def __get_address_parts(self, address):
         Split the two parts of the api address
         :param address: address of the api
         """
-        return self.__verify_address_complement(
-            address.split("//")[-1].split("/", maxsplit=1)
-        )
+        return self.__verify_address_complement(address.split("//")[-1].split("/", maxsplit=1))
 
     @staticmethod
     def __verify_address_complement(address_list):
@@ -362,9 +358,7 @@ def __verify_address_complement(address_list):
         :param address_list: One or two part of the address
         """
         return (
-            address_list
-            if len(address_list) == 2
-            else [address_list[0], ADDRESS_QUERY_COMPLEMENT]
+            address_list if len(address_list) == 2 else [address_list[0], ADDRESS_QUERY_COMPLEMENT]
         )
 
     @staticmethod
@@ -464,9 +458,7 @@ def query(
             if not dates["to"]:
                 dates["to"] = "now()"
             if self.config.stream:
-                logging.warning(
-                    ERROR_MSGS["stream_mode_not_supported"] % self.config.response
-                )
+                logging.warning(ERROR_MSGS["stream_mode_not_supported"] % self.config.response)
             # If is a future query and response type is 'xls' or 'msgpack'
             # return warning because is not available.
             if self._future_queries_available(self.config.response):
@@ -476,9 +468,7 @@ def query(
                 toDate = self._toDate_parser(fromDate, default_to(dates["to"]))
 
                 if toDate > default_to("now()"):
-                    raise DevoClientException(
-                        ERROR_MSGS["future_queries_not_supported"]
-                    )
+                    raise DevoClientException(ERROR_MSGS["future_queries_not_supported"])
 
             self.config.stream = False
 
@@ -509,9 +499,7 @@ def _call(self, payload):
             # Analyse the response data to check if there are any error
             # messages within the response.
             self._error_handler(wholeResponse.text)
-            return self.config.processor(
-                self._keepalive_content_sanitize(wholeResponse.text)
-            )
+            return self.config.processor(self._keepalive_content_sanitize(wholeResponse.text))
 
     def _return_string_stream(self, payload):
         """If it's a stream call, return yield lines
@@ -557,10 +545,7 @@ def _empty_lines_sanitize(line):
         return line.strip()
 
     def _keepalive_content_sanitize(self, response):
-        if (
-            self.config.keepAliveToken == NO_KEEPALIVE_TOKEN
-            or self.config.keepAliveToken is None
-        ):
+        if self.config.keepAliveToken == NO_KEEPALIVE_TOKEN or self.config.keepAliveToken is None:
             return response
         elif self.config.keepAliveToken == DEFAULT_KEEPALIVE_TOKEN:
             if self.config.response.startswith("json"):
@@ -584,10 +569,7 @@ def _keepalive_content_sanitize(self, response):
             return response.replace(f"{self.config.keepAliveToken}", "")
 
     def _keepalive_stream_sanitize(self, line):
-        if (
-            self.config.keepAliveToken == NO_KEEPALIVE_TOKEN
-            or self.config.keepAliveToken is None
-        ):
+        if self.config.keepAliveToken == NO_KEEPALIVE_TOKEN or self.config.keepAliveToken is None:
             return line
         elif self.config.keepAliveToken == DEFAULT_KEEPALIVE_TOKEN:
             if self.config.response.startswith("json"):
@@ -641,9 +623,7 @@ def __request(self, payload):
         POST request method extracted for mocking purposes
         """
         return requests.post(
-            "{}://{}".format(
-                "http" if self.unsecure_http else "https", "/".join(self.address)
-            ),
+            "{}://{}".format("http" if self.unsecure_http else "https", "/".join(self.address)),
             data=payload,
             headers=self._get_headers(payload),
             verify=self.verify,
@@ -668,9 +648,7 @@ def _get_payload(query, query_id, dates, opts):
         date_to = default_to(dates["to"]) if dates["to"] is not None else None
 
         payload = {
-            "from": int(date_from / 1000)
-            if isinstance(date_from, (int, float))
-            else date_from,
+            "from": int(date_from / 1000) if isinstance(date_from, (int, float)) else date_from,
             "to": int(date_to / 1000) if isinstance(date_to, (int, float)) else date_to,
             "mode": {"type": opts["response"]},
         }
@@ -693,10 +671,7 @@ def _get_payload(query, query_id, dates, opts):
         if opts["destination"]:
             payload["destination"] = opts["destination"]
 
-        if (
-            opts["keepAliveToken"] is not None
-            and opts["keepAliveToken"] != NO_KEEPALIVE_TOKEN
-        ):
+        if opts["keepAliveToken"] is not None and opts["keepAliveToken"] != NO_KEEPALIVE_TOKEN:
             if opts["keepAliveToken"] == EMPTY_EVENT_KEEPALIVE_TOKEN:
                 payload["keepAlive"] = {"type": "empty"}
             elif opts["keepAliveToken"] == DEFAULT_KEEPALIVE_TOKEN:
@@ -797,25 +772,19 @@ def stop_job(self, job_id):
         """Stop one job by ID
         :param job_id: id of job
         :return: bool"""
-        return self._call_jobs(
-            "{}{}{}{}".format(self.address[0], ADDRESS_JOB, "stop/", job_id)
-        )
+        return self._call_jobs("{}{}{}{}".format(self.address[0], ADDRESS_JOB, "stop/", job_id))
 
     def start_job(self, job_id):
         """Start one job by ID
         :param job_id: id of job
         :return: bool"""
-        return self._call_jobs(
-            "{}{}{}{}".format(self.address[0], ADDRESS_JOB, "start/", job_id)
-        )
+        return self._call_jobs("{}{}{}{}".format(self.address[0], ADDRESS_JOB, "start/", job_id))
 
     def remove_job(self, job_id):
         """Remove one job by ID
         :param job_id: id of job
         :return: bool"""
-        return self._call_jobs(
-            "{}{}{}{}".format(self.address[0], ADDRESS_JOB, "remove/", job_id)
-        )
+        return self._call_jobs("{}{}{}{}".format(self.address[0], ADDRESS_JOB, "remove/", job_id))
 
     def _call_jobs(self, address):
         """
@@ -837,10 +806,7 @@ def _call_jobs(self, address):
                 raise DevoClientException(ERROR_MSGS["connection_error"]) from error
 
             if response:
-                if (
-                    response.status_code != 200
-                    or "error" in response.text[0:15].lower()
-                ):
+                if response.status_code != 200 or "error" in response.text[0:15].lower():
                     raise DevoClientRequestException(response)
                 try:
                     return json.loads(response.text)
@@ -893,9 +859,7 @@ def _fromDate_parser(fromDate, now=datetime.now()):
         elif fromDate == "today":
             return adate.timestamp() * 1000
         elif fromDate == "endday":
-            return (
-                adate + timedelta(hours=23, minutes=59, seconds=59)
-            ).timestamp() * 1000
+            return (adate + timedelta(hours=23, minutes=59, seconds=59)).timestamp() * 1000
         elif fromDate == "endmonth":
             return (
                 adate.replace(day=calendar.monthrange(adate.year, adate.month)[1])
@@ -910,15 +874,9 @@ def _toDate_parser(fromDateMillisec, toDate, now=datetime.now()):
             return toDate
 
         now = now.astimezone(pytz.UTC)
-        fromDate = datetime.fromtimestamp(fromDateMillisec / 1000).replace(
-            tzinfo=pytz.utc
-        )
-        aFromdate = datetime.strptime(str(fromDate.date()), "%Y-%m-%d").replace(
-            tzinfo=pytz.utc
-        )
-        aNowdate = datetime.strptime(str(now.date()), "%Y-%m-%d").replace(
-            tzinfo=pytz.utc
-        )
+        fromDate = datetime.fromtimestamp(fromDateMillisec / 1000).replace(tzinfo=pytz.utc)
+        aFromdate = datetime.strptime(str(fromDate.date()), "%Y-%m-%d").replace(tzinfo=pytz.utc)
+        aNowdate = datetime.strptime(str(now.date()), "%Y-%m-%d").replace(tzinfo=pytz.utc)
 
         if re.match("^[1-9]+(d|ad|h|ah|m|am|s|as)", toDate):
             date = re.split("(d|ad|h|ah|m|am|s|as)", toDate)
@@ -945,14 +903,10 @@ def _toDate_parser(fromDateMillisec, toDate, now=datetime.now()):
         elif toDate == "today":
             return aNowdate.timestamp() * 1000
         elif toDate == "endday":
-            return (
-                aFromdate + timedelta(hours=23, minutes=59, seconds=59)
-            ).timestamp() * 1000
+            return (aFromdate + timedelta(hours=23, minutes=59, seconds=59)).timestamp() * 1000
         elif toDate == "endmonth":
             return (
-                aFromdate.replace(
-                    day=calendar.monthrange(aFromdate.year, aFromdate.month)[1]
-                )
+                aFromdate.replace(day=calendar.monthrange(aFromdate.year, aFromdate.month)[1])
                 + timedelta(hours=23, minutes=59, seconds=59)
             ).timestamp() * 1000
         elif toDate == "now":

devo/api/processors.py

@@ -12,19 +12,11 @@ def proc_default():
 
 
 def proc_bytes_to_str():
-    return (
-        lambda data: data.strip()
-        if isinstance(data, str)
-        else data.strip().decode("utf-8")
-    )
+    return lambda data: data.strip() if isinstance(data, str) else data.strip().decode("utf-8")
 
 
 def proc_str_to_bytes():
-    return (
-        lambda data: data.strip()
-        if isinstance(data, bytes)
-        else data.strip().encode("utf-8")
-    )
+    return lambda data: data.strip() if isinstance(data, bytes) else data.strip().encode("utf-8")
 
 
 def proc_json():
@@ -40,9 +32,7 @@ def processor(data):
             else None
         )
         if obj and "e" in obj:
-            raise RuntimeError(
-                f"Error {obj['e'][0]} processing query: " f"{obj['e'][1]}"
-            )
+            raise RuntimeError(f"Error {obj['e'][0]} processing query: " f"{obj['e'][1]}")
         else:
             return obj