fix small bug with extensions (#25)

* Add a failing test

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

* fix small bug with extensions

Signed-off-by: ryandawsonuk <[email protected]>

Co-authored-by: Dustin Ingram <[email protected]>

Author: ryandawsonuk

cloudevents/sdk/event/base.py

@@ -154,7 +154,7 @@ def MarshalBinary(
                 if value is not None:
                     headers["ce-{0}".format(key)] = value
 
-        for key, value in props.get("extensions"):
+        for key, value in props.get("extensions").items():
             headers["ce-{0}".format(key)] = value
 
         data, _ = self.Get("data")

cloudevents/tests/test_event_pipeline.py

@@ -37,6 +37,7 @@ def test_event_pipeline_upstream():
     )
     m = marshaller.NewDefaultHTTPMarshaller()
     new_headers, body = m.ToRequest(event, converters.TypeBinary, lambda x: x)
+
     assert new_headers is not None
     assert "ce-specversion" in new_headers
     assert "ce-type" in new_headers
@@ -48,6 +49,20 @@ def test_event_pipeline_upstream():
     assert data.body == body
 
 
+def test_extensions_are_set_upstream():
+    extensions = {'extension-key': 'extension-value'}
+    event = (
+        v02.Event()
+        .SetExtensions(extensions)
+    )
+
+    m = marshaller.NewDefaultHTTPMarshaller()
+    new_headers, body = m.ToRequest(event, converters.TypeBinary, lambda x: x)
+
+    assert event.Extensions() == extensions
+    assert "ce-extension-key" in new_headers
+
+
 def test_event_pipeline_v01():
     event = (
         v01.Event()