FINERACT-2181: CommandProcessingResult serialization optimisation
This commit is contained in:
+2
-1
@@ -19,6 +19,7 @@
|
|||||||
package org.apache.fineract.infrastructure.core.api;
|
package org.apache.fineract.infrastructure.core.api;
|
||||||
|
|
||||||
import com.google.gson.JsonElement;
|
import com.google.gson.JsonElement;
|
||||||
|
import com.google.gson.JsonNull;
|
||||||
import com.google.gson.JsonPrimitive;
|
import com.google.gson.JsonPrimitive;
|
||||||
import com.google.gson.JsonSerializationContext;
|
import com.google.gson.JsonSerializationContext;
|
||||||
import com.google.gson.JsonSerializer;
|
import com.google.gson.JsonSerializer;
|
||||||
@@ -35,7 +36,7 @@ public class ExternalIdAdapter implements JsonSerializer<ExternalId> {
|
|||||||
@SuppressWarnings("unused")
|
@SuppressWarnings("unused")
|
||||||
public JsonElement serialize(ExternalId src, Type typeOfSrc, JsonSerializationContext context) {
|
public JsonElement serialize(ExternalId src, Type typeOfSrc, JsonSerializationContext context) {
|
||||||
if (src == null || src.isEmpty()) {
|
if (src == null || src.isEmpty()) {
|
||||||
return null;
|
return JsonNull.INSTANCE;
|
||||||
}
|
}
|
||||||
return new JsonPrimitive(src.getValue());
|
return new JsonPrimitive(src.getValue());
|
||||||
}
|
}
|
||||||
|
|||||||
+8
-4
@@ -31,7 +31,7 @@ import org.apache.fineract.infrastructure.core.domain.ExternalId;
|
|||||||
@Getter
|
@Getter
|
||||||
public class CommandProcessingResult implements Serializable {
|
public class CommandProcessingResult implements Serializable {
|
||||||
|
|
||||||
private Long commandId;
|
private final Long commandId;
|
||||||
private Long officeId;
|
private Long officeId;
|
||||||
private final Long groupId;
|
private final Long groupId;
|
||||||
private final Long clientId;
|
private final Long clientId;
|
||||||
@@ -72,9 +72,9 @@ public class CommandProcessingResult implements Serializable {
|
|||||||
this.creditBureauReportData = creditBureauReportData;
|
this.creditBureauReportData = creditBureauReportData;
|
||||||
this.rollbackTransaction = rollbackTransaction;
|
this.rollbackTransaction = rollbackTransaction;
|
||||||
this.subResourceId = subResourceId;
|
this.subResourceId = subResourceId;
|
||||||
this.resourceExternalId = resourceExternalId;
|
this.resourceExternalId = setExternalIdOrNull(resourceExternalId);
|
||||||
this.subResourceExternalId = subResourceExternalId;
|
this.subResourceExternalId = setExternalIdOrNull(subResourceExternalId);
|
||||||
this.loanExternalId = loanExternalId;
|
this.loanExternalId = setExternalIdOrNull(loanExternalId);
|
||||||
}
|
}
|
||||||
|
|
||||||
protected CommandProcessingResult(final Long resourceId, final Long officeId, final Long commandId, final Map<String, Object> changes,
|
protected CommandProcessingResult(final Long resourceId, final Long officeId, final Long commandId, final Map<String, Object> changes,
|
||||||
@@ -161,4 +161,8 @@ public class CommandProcessingResult implements Serializable {
|
|||||||
public void setRollbackTransaction(Boolean rollbackTransaction) {
|
public void setRollbackTransaction(Boolean rollbackTransaction) {
|
||||||
this.rollbackTransaction = rollbackTransaction;
|
this.rollbackTransaction = rollbackTransaction;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private ExternalId setExternalIdOrNull(ExternalId externalId) {
|
||||||
|
return externalId == null || externalId.isEmpty() ? null : externalId;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
-18
@@ -37,7 +37,6 @@ import java.util.List;
|
|||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
import org.apache.commons.io.IOUtils;
|
import org.apache.commons.io.IOUtils;
|
||||||
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.HttpHeaders;
|
||||||
import org.springframework.http.HttpOutputMessage;
|
|
||||||
import org.springframework.http.MediaType;
|
import org.springframework.http.MediaType;
|
||||||
import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
|
import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
|
||||||
import org.springframework.http.converter.json.MappingJacksonInputMessage;
|
import org.springframework.http.converter.json.MappingJacksonInputMessage;
|
||||||
@@ -96,21 +95,4 @@ public class JerseyJacksonObjectArgumentHandler<T> implements MessageBodyReader<
|
|||||||
converter.write(t, genericType, MediaType.APPLICATION_JSON, new SimpleHttpOutputMessage(entityStream, headers));
|
converter.write(t, genericType, MediaType.APPLICATION_JSON, new SimpleHttpOutputMessage(entityStream, headers));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
private static final class SimpleHttpOutputMessage implements HttpOutputMessage {
|
|
||||||
|
|
||||||
private final OutputStream outputStream;
|
|
||||||
private final HttpHeaders headers;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public OutputStream getBody() throws IOException {
|
|
||||||
return outputStream;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public HttpHeaders getHeaders() {
|
|
||||||
return headers;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
+42
@@ -0,0 +1,42 @@
|
|||||||
|
/**
|
||||||
|
* Licensed to the Apache Software Foundation (ASF) under one
|
||||||
|
* or more contributor license agreements. See the NOTICE file
|
||||||
|
* distributed with this work for additional information
|
||||||
|
* regarding copyright ownership. The ASF licenses this file
|
||||||
|
* to you 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
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* 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 org.apache.fineract.infrastructure.core.jersey;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.io.OutputStream;
|
||||||
|
import lombok.RequiredArgsConstructor;
|
||||||
|
import org.springframework.http.HttpHeaders;
|
||||||
|
import org.springframework.http.HttpOutputMessage;
|
||||||
|
|
||||||
|
@RequiredArgsConstructor
|
||||||
|
public final class SimpleHttpOutputMessage implements HttpOutputMessage {
|
||||||
|
|
||||||
|
private final OutputStream outputStream;
|
||||||
|
private final HttpHeaders headers;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public OutputStream getBody() throws IOException {
|
||||||
|
return outputStream;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public HttpHeaders getHeaders() {
|
||||||
|
return headers;
|
||||||
|
}
|
||||||
|
}
|
||||||
+64
@@ -0,0 +1,64 @@
|
|||||||
|
/**
|
||||||
|
* Licensed to the Apache Software Foundation (ASF) under one
|
||||||
|
* or more contributor license agreements. See the NOTICE file
|
||||||
|
* distributed with this work for additional information
|
||||||
|
* regarding copyright ownership. The ASF licenses this file
|
||||||
|
* to you 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
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* 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 org.apache.fineract.infrastructure.core.jersey;
|
||||||
|
|
||||||
|
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||||
|
|
||||||
|
import com.google.gson.Gson;
|
||||||
|
import java.io.ByteArrayOutputStream;
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.nio.charset.Charset;
|
||||||
|
import java.util.Map;
|
||||||
|
import org.apache.fineract.TestConfiguration;
|
||||||
|
import org.apache.fineract.infrastructure.core.data.CommandProcessingResult;
|
||||||
|
import org.apache.fineract.infrastructure.core.domain.ExternalId;
|
||||||
|
import org.junit.jupiter.api.Test;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.boot.test.context.SpringBootTest;
|
||||||
|
import org.springframework.http.HttpHeaders;
|
||||||
|
import org.springframework.http.MediaType;
|
||||||
|
import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
|
||||||
|
import org.springframework.test.context.ContextConfiguration;
|
||||||
|
|
||||||
|
@SpringBootTest
|
||||||
|
@ContextConfiguration(classes = TestConfiguration.class)
|
||||||
|
public class CommandProcessingResultSerializationTest {
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private MappingJackson2HttpMessageConverter converter;
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testCommandProcessingResultSerialization() throws IOException {
|
||||||
|
ByteArrayOutputStream os = new ByteArrayOutputStream();
|
||||||
|
HttpHeaders headers = new HttpHeaders();
|
||||||
|
headers.setContentType(MediaType.APPLICATION_JSON);
|
||||||
|
CommandProcessingResult commandProcessingResult = CommandProcessingResult.fromDetails(1L, null, null, null, null, null,
|
||||||
|
"resourceIdentifier", null, null, null, null, null, null, null, Boolean.TRUE, null, new ExternalId("externalId"),
|
||||||
|
ExternalId.empty(), null);
|
||||||
|
SimpleHttpOutputMessage outputMessage = new SimpleHttpOutputMessage(os, headers);
|
||||||
|
converter.write(commandProcessingResult, MediaType.APPLICATION_JSON, outputMessage);
|
||||||
|
Map<String, Object> result = new Gson().fromJson(os.toString(Charset.defaultCharset()), Map.class);
|
||||||
|
assertEquals(4, result.size());
|
||||||
|
assertEquals("resourceIdentifier", result.get("resourceIdentifier"));
|
||||||
|
assertEquals("externalId", result.get("resourceExternalId"));
|
||||||
|
assertEquals(1.0, result.get("commandId"));
|
||||||
|
assertEquals(true, result.get("rollbackTransaction"));
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user