dapr
/
java-sdk
mirror of https://github.com/dapr/java-sdk.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Unit test to deserialize CloudEvent. (#480)

This commit is contained in:
Artur Souza 2021-02-04 14:11:39 -08:00 committed by GitHub
parent 717480d804
commit a66337aa4b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 152 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

152
sdk/src/test/java/io/dapr/client/CloudEventTest.java Normal file
View File

@ -0,0 +1,152 @@
/*
* Copyright (c) Microsoft Corporation.
* Licensed under the MIT License.
*/
package io.dapr.client;
import com.fasterxml.jackson.databind.ObjectMapper;
import io.dapr.client.domain.CloudEvent;
import org.junit.Test;
import static org.junit.Assert.assertArrayEquals;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;
public class CloudEventTest {
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
public static class MyClass {
public int id;
public String name;
}
@Test
public void deserializeObjectClass() throws Exception {
String content = "{\n" +
" \"specversion\" : \"1.0\",\n" +
" \"type\" : \"com.github.pull_request.opened\",\n" +
" \"source\" : \"https://github.com/cloudevents/spec/pull\",\n" +
" \"subject\" : \"123\",\n" +
" \"id\" : \"A234-1234-1234\",\n" +
" \"time\" : \"2018-04-05T17:31:00Z\",\n" +
" \"comexampleextension1\" : \"value\",\n" +
" \"comexampleothervalue\" : 5,\n" +
" \"datacontenttype\" : \"application/json\",\n" +
" \"data\" : {\"id\": 1, \"name\": \"hello world\"}\n" +
"}";
MyClass expected = new MyClass() {{
this.id = 1;
this.name = "hello world";
}};
CloudEvent cloudEvent = CloudEvent.deserialize(content.getBytes());
assertEquals("application/json", cloudEvent.getDatacontenttype());
MyClass myObject = OBJECT_MAPPER.convertValue(cloudEvent.getData(), MyClass.class);
assertEquals(expected.id, myObject.id);
assertEquals(expected.name, myObject.name);
}
@Test
public void deserializeNullData() throws Exception {
String content = "{\n" +
" \"specversion\" : \"1.0\",\n" +
" \"type\" : \"com.github.pull_request.opened\",\n" +
" \"source\" : \"https://github.com/cloudevents/spec/pull\",\n" +
" \"subject\" : \"123\",\n" +
" \"id\" : \"A234-1234-1234\",\n" +
" \"time\" : \"2018-04-05T17:31:00Z\",\n" +
" \"comexampleextension1\" : \"value\",\n" +
" \"comexampleothervalue\" : 5,\n" +
" \"datacontenttype\" : \"application/json\"\n" +
"}";
CloudEvent cloudEvent = CloudEvent.deserialize(content.getBytes());
assertEquals("application/json", cloudEvent.getDatacontenttype());
assertNull(cloudEvent.getData());
}
@Test
public void deserializeInteger() throws Exception {
String content = "{\n" +
" \"specversion\" : \"1.0\",\n" +
" \"type\" : \"com.github.pull_request.opened\",\n" +
" \"source\" : \"https://github.com/cloudevents/spec/pull\",\n" +
" \"subject\" : \"123\",\n" +
" \"id\" : \"A234-1234-1234\",\n" +
" \"time\" : \"2018-04-05T17:31:00Z\",\n" +
" \"comexampleextension1\" : \"value\",\n" +
" \"comexampleothervalue\" : 5,\n" +
" \"datacontenttype\" : \"application/json\",\n" +
" \"data\" : 1\n" +
"}";
CloudEvent cloudEvent = CloudEvent.deserialize(content.getBytes());
assertEquals("application/json", cloudEvent.getDatacontenttype());
assertEquals(1, cloudEvent.getData());
}
@Test
public void deserializeString() throws Exception {
String content = "{\n" +
" \"specversion\" : \"1.0\",\n" +
" \"type\" : \"com.github.pull_request.opened\",\n" +
" \"source\" : \"https://github.com/cloudevents/spec/pull\",\n" +
" \"subject\" : \"123\",\n" +
" \"id\" : \"A234-1234-1234\",\n" +
" \"time\" : \"2018-04-05T17:31:00Z\",\n" +
" \"comexampleextension1\" : \"value\",\n" +
" \"comexampleothervalue\" : 5,\n" +
" \"datacontenttype\" : \"text/plain\",\n" +
" \"data\" : \"hello world\"\n" +
"}";
CloudEvent cloudEvent = CloudEvent.deserialize(content.getBytes());
assertEquals("text/plain", cloudEvent.getDatacontenttype());
assertEquals("hello world", cloudEvent.getData());
}
@Test
public void deserializeXML() throws Exception {
String content = "{\n" +
" \"specversion\" : \"1.0\",\n" +
" \"type\" : \"com.github.pull_request.opened\",\n" +
" \"source\" : \"https://github.com/cloudevents/spec/pull\",\n" +
" \"subject\" : \"123\",\n" +
" \"id\" : \"A234-1234-1234\",\n" +
" \"time\" : \"2018-04-05T17:31:00Z\",\n" +
" \"comexampleextension1\" : \"value\",\n" +
" \"comexampleothervalue\" : 5,\n" +
" \"datacontenttype\" : \"text/xml\",\n" +
" \"data\" : \"<root/>\"\n" +
"}";
CloudEvent cloudEvent = CloudEvent.deserialize(content.getBytes());
assertEquals("text/xml", cloudEvent.getDatacontenttype());
assertEquals("<root/>", cloudEvent.getData());
}
@Test
public void deserializeBytes() throws Exception {
String content = "{\n" +
" \"specversion\" : \"1.0\",\n" +
" \"type\" : \"com.github.pull_request.opened\",\n" +
" \"source\" : \"https://github.com/cloudevents/spec/pull\",\n" +
" \"subject\" : \"123\",\n" +
" \"id\" : \"A234-1234-1234\",\n" +
" \"time\" : \"2018-04-05T17:31:00Z\",\n" +
" \"comexampleextension1\" : \"value\",\n" +
" \"comexampleothervalue\" : 5,\n" +
" \"datacontenttype\" : \"application/json\",\n" +
" \"data\" : \"AQI=\"\n" +
"}";
byte[] expected = new byte[]{ 0x1, 0x2 };
CloudEvent cloudEvent = CloudEvent.deserialize(content.getBytes());
assertEquals("application/json", cloudEvent.getDatacontenttype());
assertEquals("AQI=", cloudEvent.getData());
assertArrayEquals(expected, OBJECT_MAPPER.convertValue(cloudEvent.getData(), byte[].class));
}
}