Fix formatting (#131)

* Fix formatting for latest black

Signed-off-by: Dustin Ingram <[email protected]>

* Add flake8 for linting

Signed-off-by: Dustin Ingram <[email protected]>

* Fix flake8 lint errors

Signed-off-by: Dustin Ingram <[email protected]>

Author: di

cloudevents/http/__init__.py

@@ -11,16 +11,14 @@
 #    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 #    License for the specific language governing permissions and limitations
 #    under the License.
-import json
-import typing
 
-from cloudevents.http.event import CloudEvent
-from cloudevents.http.event_type import is_binary, is_structured
-from cloudevents.http.http_methods import (
+from cloudevents.http.event import CloudEvent  # noqa
+from cloudevents.http.event_type import is_binary, is_structured  # noqa
+from cloudevents.http.http_methods import (  # noqa
     from_http,
     to_binary,
     to_binary_http,
     to_structured,
     to_structured_http,
 )
-from cloudevents.http.json_methods import from_json, to_json
+from cloudevents.http.json_methods import from_json, to_json  # noqa

cloudevents/http/event_type.py

@@ -7,7 +7,8 @@ def is_binary(headers: typing.Dict[str, str]) -> bool:
     """Uses internal marshallers to determine whether this event is binary
     :param headers: the HTTP headers
     :type headers: typing.Dict[str, str]
-    :returns bool: returns a bool indicating whether the headers indicate a binary event type
+    :returns bool: returns a bool indicating whether the headers indicate
+        a binary event type
     """
     headers = {key.lower(): value for key, value in headers.items()}
     content_type = headers.get("content-type", "")
@@ -19,7 +20,8 @@ def is_structured(headers: typing.Dict[str, str]) -> bool:
     """Uses internal marshallers to determine whether this event is structured
     :param headers: the HTTP headers
     :type headers: typing.Dict[str, str]
-    :returns bool: returns a bool indicating whether the headers indicate a structured event type
+    :returns bool: returns a bool indicating whether the headers indicate
+        a structured event type
     """
     headers = {key.lower(): value for key, value in headers.items()}
     content_type = headers.get("content-type", "")

cloudevents/http/http_methods.py

@@ -5,7 +5,7 @@
 
 import cloudevents.exceptions as cloud_exceptions
 from cloudevents.http.event import CloudEvent
-from cloudevents.http.event_type import is_binary, is_structured
+from cloudevents.http.event_type import is_binary
 from cloudevents.http.mappings import _marshaller_by_format, _obj_by_version
 from cloudevents.http.util import _json_or_string
 from cloudevents.sdk import converters, marshaller, types
@@ -124,7 +124,7 @@ def _to_http(
 
 
 def to_structured(
-    event: CloudEvent, data_marshaller: types.MarshallerType = None,
+    event: CloudEvent, data_marshaller: types.MarshallerType = None
 ) -> (dict, typing.Union[bytes, str]):
     """
     Returns a tuple of HTTP headers/body dicts representing this cloudevent. If
@@ -142,7 +142,7 @@ def to_structured(
 
 
 def to_binary(
-    event: CloudEvent, data_marshaller: types.MarshallerType = None,
+    event: CloudEvent, data_marshaller: types.MarshallerType = None
 ) -> (dict, typing.Union[bytes, str]):
     """
     Returns a tuple of HTTP headers/body dicts representing this cloudevent
@@ -163,13 +163,13 @@ def to_binary(
 
 @deprecated(deprecated_in="1.0.2", details="Use to_binary function instead")
 def to_binary_http(
-    event: CloudEvent, data_marshaller: types.MarshallerType = None,
+    event: CloudEvent, data_marshaller: types.MarshallerType = None
 ) -> (dict, typing.Union[bytes, str]):
     return to_binary(event, data_marshaller)
 
 
 @deprecated(deprecated_in="1.0.2", details="Use to_structured function instead")
 def to_structured_http(
-    event: CloudEvent, data_marshaller: types.MarshallerType = None,
+    event: CloudEvent, data_marshaller: types.MarshallerType = None
 ) -> (dict, typing.Union[bytes, str]):
     return to_structured(event, data_marshaller)

cloudevents/http/util.py

@@ -16,5 +16,5 @@ def _json_or_string(content: typing.Union[str, bytes]):
         return None
     try:
         return json.loads(content)
-    except (json.JSONDecodeError, TypeError) as e:
+    except (json.JSONDecodeError, TypeError):
         return content

cloudevents/sdk/converters/structured.py

@@ -27,7 +27,7 @@ class JSONHTTPCloudEventConverter(base.Converter):
     MIME_TYPE = "application/cloudevents+json"
 
     def can_read(
-        self, content_type: str, headers: typing.Dict[str, str] = {},
+        self, content_type: str, headers: typing.Dict[str, str] = {}
     ) -> bool:
         return (
             isinstance(content_type, str)

cloudevents/tests/test_base_events.py

@@ -30,4 +30,4 @@ def test_get_nonexistent_optional(event_class):
     event = event_class()
     event.SetExtensions({"ext1": "val"})
     res = event.Get("ext1")
-    assert res[0] == "val" and res[1] == True
+    assert res[0] == "val" and res[1] is True

cloudevents/tests/test_converters.py

@@ -14,7 +14,7 @@
 import pytest
 
 from cloudevents.sdk import exceptions
-from cloudevents.sdk.converters import base, binary, structured
+from cloudevents.sdk.converters import base, binary
 
 
 def test_binary_converter_raise_unsupported():

cloudevents/tests/test_data_encaps_refs.py

@@ -12,15 +12,12 @@
 #    License for the specific language governing permissions and limitations
 #    under the License.
 
-import copy
-import io
 import json
 from uuid import uuid4
 
 import pytest
 
 from cloudevents.sdk import converters, marshaller
-from cloudevents.sdk.converters import structured
 from cloudevents.sdk.event import v1, v03
 from cloudevents.tests import data
 
@@ -71,7 +68,6 @@ def test_general_binary_properties(event_class):
 
 @pytest.mark.parametrize("event_class", [v03.Event, v1.Event])
 def test_general_structured_properties(event_class):
-    copy_of_ce = copy.deepcopy(data.json_ce[event_class])
     m = marshaller.NewDefaultHTTPMarshaller()
     http_headers = {"content-type": "application/cloudevents+json"}
     event = m.FromRequest(

cloudevents/tests/test_event_from_request_converter.py

@@ -12,12 +12,11 @@
 #    License for the specific language governing permissions and limitations
 #    under the License.
 
-import io
 import json
 
 import pytest
 
-from cloudevents.sdk import exceptions, marshaller
+from cloudevents.sdk import marshaller
 from cloudevents.sdk.converters import binary, structured
 from cloudevents.sdk.event import v1, v03
 from cloudevents.tests import data

cloudevents/tests/test_event_pipeline.py

@@ -12,7 +12,6 @@
 #    License for the specific language governing permissions and limitations
 #    under the License.
 
-import io
 import json
 
 import pytest