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

Fixed structuredToEvent test 

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
This commit is contained in:
slinkydeveloper 2020-04-21 18:49:51 +02:00 committed by Francesco Guardiani
parent 92c205a941
commit d207ecc311
2 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
api/src/test/java/io/cloudevents/message/EventMessageRoundtripTest.java
View File

@ -11,15 +11,25 @@ import static org.assertj.core.api.Assertions.assertThat;
public class EventMessageRoundtripTest {
/**
* This test doesn't test extensions in event because the CSVFormat doesn't support it
*
* @param input
*/
@ParameterizedTest()
@MethodSource("io.cloudevents.test.Data#allEvents")
@MethodSource("io.cloudevents.test.Data#allEventsWithoutExtensions")
void structuredToEvent(CloudEvent input) {
assertThat(input.asStructuredMessage(CSVFormat.INSTANCE).toEvent())
.isEqualTo(input);
}
/**
* This test doesn't test extensions in event because the CSVFormat doesn't support it
*
* @param input
*/
@ParameterizedTest()
@MethodSource("io.cloudevents.test.Data#allEvents")
@MethodSource("io.cloudevents.test.Data#allEventsWithoutExtensions")
void structuredToMockStructuredMessageToEvent(CloudEvent input) {
assertThat(input.asStructuredMessage(CSVFormat.INSTANCE).visit(new MockStructuredMessage()).toEvent())
.isEqualTo(input);

4
api/src/test/java/io/cloudevents/test/Data.java
View File

@ -78,6 +78,10 @@ public class Data {
return Stream.concat(v1Events(), v03Events());
}
public static Stream<CloudEvent> allEventsWithoutExtensions() {
return Stream.concat(v1Events(), v03Events()).filter(e -> e.getExtensions().isEmpty());
}
public static Stream<CloudEvent> v1Events() {
return Stream.of(
Data.V1_MIN,