From 70e3b6681b4e9a486d3b64a3a4649bd8fe37055e Mon Sep 17 00:00:00 2001
From: Jim Crossley <jim@crossleys.org>
Date: Tue, 14 Dec 2021 20:01:45 -0500
Subject: [PATCH] Fix TryFrom<Data> impl for Vec<u8>

Fixes #163

Signed-off-by: Jim Crossley <jim@crossleys.org>
---
 src/binding/warp/filter.rs | 13 +++++++++----
 src/event/data.rs          |  2 +-
 2 files changed, 10 insertions(+), 5 deletions(-)

diff --git a/src/binding/warp/filter.rs b/src/binding/warp/filter.rs
index 0d75ad4..1ddb686 100644
--- a/src/binding/warp/filter.rs
+++ b/src/binding/warp/filter.rs
@@ -45,12 +45,11 @@ async fn create_event(headers: HeaderMap, body: bytes::Bytes) -> Result<Event, R
 
 #[cfg(test)]
 mod tests {
-    use warp_lib as warp;
-
     use super::to_event;
-    use warp::test;
-
     use crate::test::fixtures;
+    use std::convert::TryInto;
+    use warp::test;
+    use warp_lib as warp;
 
     #[tokio::test]
     async fn test_request() {
@@ -114,6 +113,12 @@ mod tests {
             .await
             .unwrap();
 
+        let mut event = result.clone();
+        let (_datacontenttype, _dataschema, data) = event.take_data();
+        let actual_payload: Vec<u8> = data.unwrap().try_into().unwrap();
+        let expected_payload: Vec<u8> = serde_json::to_vec(&fixtures::json_data()).unwrap();
+        assert_eq!(expected_payload, actual_payload);
+
         assert_eq!(expected, result);
     }
 }
diff --git a/src/event/data.rs b/src/event/data.rs
index 6cb26cc..6d36290 100644
--- a/src/event/data.rs
+++ b/src/event/data.rs
@@ -60,7 +60,7 @@ impl TryFrom<Data> for Vec<u8> {
 
     fn try_from(value: Data) -> Result<Self, Self::Error> {
         match value {
-            Data::Binary(v) => Ok(serde_json::from_slice(&v)?),
+            Data::Binary(v) => Ok(v),
             Data::Json(v) => Ok(serde_json::to_vec(&v)?),
             Data::String(s) => Ok(s.into_bytes()),
         }