Skip to content

Commit

Permalink
fix: resolve ViewRecordResponseType class cannot be serialized
Browse files Browse the repository at this point in the history
  • Loading branch information
pangdayuan1 committed Dec 6, 2023
1 parent 93ba6bf commit 2849460
Show file tree
Hide file tree
Showing 9 changed files with 19 additions and 18 deletions.
2 changes: 1 addition & 1 deletion arex-storage-config/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@
<parent>
<artifactId>arex-storage-service</artifactId>
<groupId>com.arextest</groupId>
<version>1.0.45</version>
<version>1.0.46</version>
</parent>

<properties>
Expand Down
2 changes: 1 addition & 1 deletion arex-storage-model/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
<parent>
<artifactId>arex-storage-service</artifactId>
<groupId>com.arextest</groupId>
<version>1.0.45</version>
<version>1.0.46</version>
</parent>

<profiles>
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package com.arextest.model.replay;

import com.arextest.model.mock.Mocker;
import com.arextest.model.mock.AREXMocker;
import com.arextest.model.response.DesensitizationResponseType;
import com.arextest.model.response.Response;
import com.arextest.model.response.ResponseStatusType;
Expand All @@ -15,5 +15,5 @@
public class ViewRecordResponseType extends DesensitizationResponseType implements Response {

private ResponseStatusType responseStatusType;
private List<Mocker> recordResult;
private List<AREXMocker> recordResult;
}
2 changes: 1 addition & 1 deletion arex-storage-web-api/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,7 @@
<parent>
<artifactId>arex-storage-service</artifactId>
<groupId>com.arextest</groupId>
<version>1.0.45</version>
<version>1.0.46</version>
</parent>

<profiles>
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package com.arextest.storage.mock;

import com.arextest.common.utils.JsonTraverseUtils;
import com.arextest.model.mock.AREXMocker;
import com.arextest.model.mock.Mocker;
import com.arextest.storage.utils.JsonUtil;
import com.fasterxml.jackson.core.JsonProcessingException;
Expand All @@ -9,9 +10,9 @@

public class MockerPostProcessor {

public static void desensitize(List<Mocker> allReadableResult)
public static void desensitize(List<AREXMocker> allReadableResult)
throws JsonProcessingException {
for (Mocker arexMocker : allReadableResult) {
for (AREXMocker arexMocker : allReadableResult) {
Mocker.Target request = arexMocker.getTargetRequest();
Mocker.Target response = arexMocker.getTargetResponse();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -133,7 +133,7 @@ public int copyTo(String srcProviderName, String srcRecordId, String targetProvi
LOGGER.warn("could not found provider for {} or {}", srcProvider, targetProvider);
return count;
}
List<Mocker> srcMockers;
List<AREXMocker> srcMockers;
Set<MockCategoryType> categoryTypes = providerFactory.getCategoryTypes();
for (MockCategoryType categoryType : categoryTypes) {
srcMockers = scheduleReplayingService.queryRecordList(srcProvider, categoryType, srcRecordId);
Expand Down Expand Up @@ -172,7 +172,7 @@ public void invalidCase(String srcProviderName, String recordId) {
removeAll(srcProviderName, recordId);
}

private List<Mocker> createTargetList(List<Mocker> srcMockers, String targetRecordId) {
private List<Mocker> createTargetList(List<AREXMocker> srcMockers, String targetRecordId) {
List<Mocker> targetList = null;
long now = System.currentTimeMillis();
for (Mocker mocker: srcMockers) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ public List<AREXMocker> queryEntryPointByRange(PagedRequestType requestType) {
return Collections.emptyList();
}

public List<Mocker> queryRecordList(ViewRecordRequestType viewRecordRequestType) {
public List<AREXMocker> queryRecordList(ViewRecordRequestType viewRecordRequestType) {
String sourceProvider = viewRecordRequestType.getSourceProvider();
String recordId = viewRecordRequestType.getRecordId();
RepositoryProvider<Mocker> repositoryReader = repositoryProviderFactory.findProvider(
Expand All @@ -111,26 +111,26 @@ public List<Mocker> queryRecordList(ViewRecordRequestType viewRecordRequestType)
if (categoryType != null) {
return queryRecordList(repositoryReader, categoryType, recordId);
}
List<Mocker> readableResult = new LinkedList<>();
List<AREXMocker> readableResult = new LinkedList<>();
for (MockCategoryType category : repositoryProviderFactory.getCategoryTypes()) {
MDCTracer.addCategory(category);
List<Mocker> mockers = queryRecordList(repositoryReader, category, recordId);
List<AREXMocker> mockers = queryRecordList(repositoryReader, category, recordId);
if (CollectionUtils.isNotEmpty(mockers)) {
readableResult.addAll(mockers);
}
}
return readableResult;
}

public List<Mocker> queryRecordList(RepositoryProvider<Mocker> repositoryReader,
public List<AREXMocker> queryRecordList(RepositoryProvider<Mocker> repositoryReader,
MockCategoryType categoryType, String recordId) {
Iterable<? extends Mocker> iterable = repositoryReader.queryRecordList(categoryType, recordId);
if (iterable == null) {
return null;
}
List<Mocker> resultList = new LinkedList<>();
List<AREXMocker> resultList = new LinkedList<>();
for (Mocker mocker : iterable) {
resultList.add(mocker);
resultList.add((AREXMocker) mocker);
}
resultList.sort(Comparator.comparing(Mocker::getCreationTime));
return resultList;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package com.arextest.storage.web.controller;

import com.arextest.model.mock.Mocker;
import com.arextest.model.mock.AREXMocker;
import com.arextest.model.replay.CountOperationCaseRequestType;
import com.arextest.model.replay.CountOperationCaseResponseType;
import com.arextest.model.replay.PagedRequestType;
Expand Down Expand Up @@ -239,7 +239,7 @@ public Response viewRecord(@RequestBody ViewRecordRequestType requestType) {
MDCTracer.addRecordId(recordId);
ViewRecordResponseType responseType = new ViewRecordResponseType();
try {
List<Mocker> allReadableResult = scheduleReplayingService.queryRecordList(requestType);
List<AREXMocker> allReadableResult = scheduleReplayingService.queryRecordList(requestType);
if (CollectionUtils.isEmpty(allReadableResult)) {
LOGGER.info("could not found any resources for request: {}", requestType);
}
Expand Down
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -408,5 +408,5 @@
<url>https://github.com/arextest/arex-storage</url>


<version>1.0.45</version>
<version>1.0.46</version>
</project>

0 comments on commit 2849460

Please sign in to comment.