File tree 2 files changed +5
-15
lines changed
main/java/ai/chronon/service/handlers
test/java/ai/chronon/service/handlers
2 files changed +5
-15
lines changed Original file line number Diff line number Diff line change @@ -42,18 +42,10 @@ public void handle(RoutingContext ctx) {
42
42
}
43
43
44
44
JavaJoinSchemaResponse joinSchemaResponse = joinSchemaResponseTry .getValue ();
45
- JsonObject joinSchemaObj = new JsonObject ()
46
- .put ("joinName" , joinSchemaResponse .joinName )
47
- .put ("keySchema" , joinSchemaResponse .keySchema )
48
- .put ("valueSchema" , joinSchemaResponse .valueSchema );
49
-
50
- JsonObject response =
51
- new JsonObject ()
52
- .put ("joinSchema" , joinSchemaObj )
53
- .put ("schemaHash" , joinSchemaResponse .schemaHash );
45
+
54
46
ctx .response ()
55
47
.setStatusCode (200 )
56
48
.putHeader ("content-type" , "application/json" )
57
- .end (response .encode ());
49
+ .end (JsonObject . mapFrom ( joinSchemaResponse ) .encode ());
58
50
}
59
51
}
Original file line number Diff line number Diff line change @@ -84,15 +84,13 @@ public void testSuccessfulRequest(TestContext context) {
84
84
String schemaHash = actualResponse .getString ("schemaHash" );
85
85
context .assertEquals (schemaHash , "fakeschemaHash" );
86
86
87
- JsonObject returnedJoinSchema = actualResponse .getJsonObject ("joinSchema" );
88
-
89
- String returnedJoinName = returnedJoinSchema .getString ("joinName" );
87
+ String returnedJoinName = actualResponse .getString ("joinName" );
90
88
context .assertEquals (returnedJoinName , "user_join" );
91
89
92
- String keySchema = returnedJoinSchema .getString ("keySchema" );
90
+ String keySchema = actualResponse .getString ("keySchema" );
93
91
context .assertEquals (keySchema , avroSchemaString );
94
92
95
- String valueSchema = returnedJoinSchema .getString ("valueSchema" );
93
+ String valueSchema = actualResponse .getString ("valueSchema" );
96
94
context .assertEquals (valueSchema , avroSchemaString );
97
95
98
96
// confirm we can parse the avro schema fine
You can’t perform that action at this time.
0 commit comments