kamma/apicurio-migration-tool
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: kamma:27e1a13b7cee37fe62286ebda1393c7afbb8c804
Branches Tags
kamma:main
..
compare: kamma:46cf8b116db772b156a18565eab57514c78cb6ec
Branches Tags
kamma:main

No commits in common. "27e1a13b7cee37fe62286ebda1393c7afbb8c804" and "46cf8b116db772b156a18565eab57514c78cb6ec" have entirely different histories.
27e1a13b7c ... 46cf8b116d

2 changed files with 9 additions and 12 deletions
Show Stats Expand all files Collapse all files

8
src/main/java/cz/trask/migration/impl/v45/ExportApisToWso2FromV32.java
View File

@ -68,12 +68,13 @@ public class ExportApisToWso2FromV32 extends AbstractProcess {
int maxThreads = config.getMaxThreads(); int maxThreads = config.getMaxThreads();
// ExecutorService executor = Executors.newFixedThreadPool(maxThreads); // ExecutorService executor = Executors.newFixedThreadPool(maxThreads);
int skipCount = 722; // AutosweepIntegrationPPE/AutosweepIntegrationPPE/v1
int skipCount = 31;
for (SearchedArtifact api : sortedArtifacts) { for (SearchedArtifact api : sortedArtifacts) {
final int index = apiCounter.getAndIncrement(); final int index = apiCounter.getAndIncrement();
if (index <= skipCount) { if (index <= skipCount) {
log.info("Skipping API {} of {}: {}", index, apis.getCount(), api.getId()); log.info("Skipping API {} of {}: {}", index, apis.getCount(), api.getName());
continue; continue;
} }
// executor.submit(() -> processApi(api, token, index, apis.getCount())); // executor.submit(() -> processApi(api, token, index, apis.getCount()));
@ -320,7 +321,6 @@ public class ExportApisToWso2FromV32 extends AbstractProcess {
data.setApplicableFlows(new ArrayList<>()); data.setApplicableFlows(new ArrayList<>());
data.getApplicableFlows().add("request"); data.getApplicableFlows().add("request");
data.getApplicableFlows().add("response"); data.getApplicableFlows().add("response");
data.getApplicableFlows().add("fault");
data.setSupportedGateways(new ArrayList<>()); data.setSupportedGateways(new ArrayList<>());
data.getSupportedGateways().add("Synapse"); data.getSupportedGateways().add("Synapse");
data.setSupportedApiTypes(new ArrayList<>()); data.setSupportedApiTypes(new ArrayList<>());

13
src/main/java/cz/trask/migration/mapper/ApiDefinitionMapper32to45.java
View File

@ -195,15 +195,15 @@ public class ApiDefinitionMapper32to45 {
} }
} }
if (endpointProd != null && endpointProd.containsKey("url") && endpointProd.get("url") != null) { if (endpointProd != null && endpointProd.containsKey("url") && endpointProd.get("url") != null) {
String url = endpointProd.get("url").toString().trim().replaceAll("\\p{Cf}", ""); String url = endpointProd.get("url").toString();
try { try {
URL u = new URL(url); URL u = new URL(url);
} catch (Exception e) { } catch (Exception e) {
url = url.replaceAll("\\{\\{.*?\\}\\}", ""); url = url.replaceAll("\\{\\{.*?\\}\\}", "");
if (!url.startsWith("http")) if (!url.startsWith("http"))
url = "http://" + url; url = "http://" + url;
endpointProd.put("url", url);
} }
endpointProd.put("url", url);
} }
} }
@ -217,15 +217,15 @@ public class ApiDefinitionMapper32to45 {
} }
} }
if (endpointSand != null && endpointSand.containsKey("url") && endpointSand.get("url") != null) { if (endpointSand != null && endpointSand.containsKey("url") && endpointSand.get("url") != null) {
String url = endpointSand.get("url").toString().trim().replaceAll("\\p{Cf}", ""); String url = endpointSand.get("url").toString();
try { try {
URL u = new URL(url); URL u = new URL(url);
} catch (Exception e) { } catch (Exception e) {
url = url.replaceAll("\\{\\{.*?\\}\\}", ""); url = url.replaceAll("\\{\\{.*?\\}\\}", "");
if (!url.startsWith("http")) if (!url.startsWith("http"))
url = "http://" + url; url = "http://" + url;
endpointSand.put("url", url);
} }
endpointSand.put("url", url);
} }
} }
@ -456,10 +456,7 @@ public class ApiDefinitionMapper32to45 {
op.setTarget(path); op.setTarget(path);
op.setVerb(verb); op.setVerb(verb);
op.setAuthType(methodDef.path("x-auth-type").asText("")); op.setAuthType(methodDef.path("x-auth-type").asText(""));
JsonNode throttlingNode = methodDef.path("x-throttling-tier"); op.setThrottlingPolicy(methodDef.path("x-throttling-tier").asText(""));
if (!throttlingNode.isMissingNode() && !throttlingNode.asText().isEmpty() && !throttlingNode.asText().equalsIgnoreCase("null")) {
op.setThrottlingPolicy(throttlingNode.asText());
}
op.setScopes(new ArrayList<>()); op.setScopes(new ArrayList<>());
op.setUsedProductIds(new ArrayList<>()); op.setUsedProductIds(new ArrayList<>());