wip add serializer and deserializer for avro

Signed-off-by: Ning Sun <[email protected]>

Author: sunng87

formats/avro/src/main/java/io/cloudevents/avro/AvroDeserializer.java

@@ -0,0 +1,32 @@
+/*
+ * Copyright 2018-Present The CloudEvents Authors
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * <p>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p>
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package io.cloudevents.avro;
+
+import io.cloudevents.CloudEvent;
+import io.cloudevents.SpecVersion;
+import io.cloudevents.AvroCloudEvent;
+import io.cloudevents.AvroCloudEventData;
+import io.cloudevents.core.builder.CloudEventBuilder;
+
+public class AvroDeserializer {
+
+    public static CloudEvent fromAvro(AvroCloudEvent avroCloudEvent) {
+
+    }
+
+}

formats/avro/src/main/java/io/cloudevents/avro/AvroFormat.java

@@ -0,0 +1,68 @@
+/*
+ * Copyright 2018-Present The CloudEvents Authors
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * <p>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p>
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package io.cloudevents.avro;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+
+import io.cloudevents.CloudEvent;
+import io.cloudevents.CloudEventData;
+import io.cloudevents.AvroCloudEvent;
+import io.cloudevents.core.format.EventDeserializationException;
+import io.cloudevents.core.format.EventFormat;
+import io.cloudevents.core.format.EventSerializationException;
+import io.cloudevents.rw.CloudEventDataMapper;
+
+public class AvroFormat implements EventFormat {
+
+    public static final String AVRO_CONTENT_TYPE = "application/avro";
+
+    @Override
+    public byte[] serialize(CloudEvent event) throws EventSerializationException {
+        AvroCloudEvent avroCloudEvent = AvroSerializer.toAvro(event);
+        ByteArrayOutputStream output = new ByteArrayOutputStream();
+
+        try {
+            AvroCloudEvent.getEncoder().encode(avroCloudEvent, output);
+        } catch (IOException e) {
+            throw new EventSerializationException(e);
+        }
+
+        return output.toByteArray();
+    }
+
+    @Override
+    public CloudEvent deserialize(byte[] bytes, CloudEventDataMapper<? extends CloudEventData> mapper)
+        throws EventDeserializationException {
+        ByteArrayInputStream input = new ByteArrayInputStream(bytes);
+
+         try {
+             AvroCloudEvent avroCloudEvent = AvroCloudEvent.getDecoder().decode(input);
+
+             return AvroDeserializer.fromAvro(avroCloudEvent);
+         } catch (IOException e) {
+             throw new EventDeserializationException(e);
+         }
+    }
+
+    @Override
+    public String serializedContentType() {
+        return AVRO_CONTENT_TYPE;
+    }
+}

formats/avro/src/main/java/io/cloudevents/avro/AvroSerializer.java

@@ -0,0 +1,54 @@
+/*
+ * Copyright 2018-Present The CloudEvents Authors
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * <p>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p>
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package io.cloudevents.avro;
+
+import java.util.Map;
+import java.util.HashMap;
+
+import io.cloudevents.CloudEvent;
+import io.cloudevents.CloudEventData;
+import io.cloudevents.AvroCloudEvent;
+import io.cloudevents.AvroCloudEventData;
+
+public class AvroSerializer {
+
+    public static final AvroCloudEvent toAvro(CloudEvent e) {
+        AvroCloudEvent avroCloudEvent = new AvroCloudEvent();
+
+        Map<CharSequence, Object> attrs = new HashMap<>();
+
+        attrs.put("type", e.getType());
+        attrs.put("specversion", e.getSpecVersion().toString());
+        attrs.put("id", e.getId());
+        attrs.put("source", e.getSource());
+        attrs.put("time", e.getTime());
+        attrs.put("dataschema", e.getDataSchema());
+        attrs.put("contenttype", AvroFormat.AVRO_CONTENT_TYPE);
+        attrs.put("datacontenttype", e.getDataContentType());
+
+        avroCloudEvent.setAttribute(attrs);
+
+        // check datacontenttype
+        CloudEventData cloudEventData = e.getData();
+        if (cloudEventData != null) {
+            avroCloudEvent.setData(cloudEventData.toBytes());
+        }
+
+        return avroCloudEvent;
+    }
+}