Merge branch 'main' of

https://gitea.kamma.cz/kamma/apicurio-migration-tool.git into main

src/main/java/cz/trask/migration/AbstractProcess.java

@@ -461,7 +461,7 @@ public abstract class AbstractProcess {
 		InputStream in;
 		int responseCode = con.getResponseCode();
 
-		if (responseCode == 200 || responseCode == 201) {
+		if (responseCode >= 200 || responseCode <= 299) {
 			in = con.getInputStream();
 		} else {
 			in = con.getErrorStream();

src/main/java/cz/trask/migration/impl/v45/ExportApisToWso2FromV32.java

@@ -1,6 +1,7 @@
 package cz.trask.migration.impl.v45;
 
 import java.io.ByteArrayOutputStream;
+import java.io.File;
 import java.io.FileOutputStream;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -95,11 +96,14 @@ public class ExportApisToWso2FromV32 extends AbstractProcess {
 					byte[] data = prepareApiZipFile32to45(ver, ref);
 					String fileName = api.getName() + "-" + ver.getVersion() + ".zip";
 
-					FileOutputStream fos = new FileOutputStream(fileName);
-					fos.write(data);
-					fos.flush();
-					fos.close();
-					// System.exit(0);
+					if (config.isStoreMigratedArtifacts()) {
+						File tmpFile = new File("tmp/api/", fileName);
+						log.info("   - Storing migrated Api file: {}", tmpFile.getAbsolutePath());
+						FileOutputStream fos = new FileOutputStream(tmpFile);
+						fos.write(data);
+						fos.flush();
+						fos.close();
+					}
 
 					if (data != null && data.length > 0 && fileName != null && !fileName.isEmpty()) {
 						int responseCode = publishApiToWso2(fileName, data, tokenResponse);

src/main/java/cz/trask/migration/impl/v45/ExportAppsToWso2FromV32.java

@@ -1,24 +1,35 @@
 package cz.trask.migration.impl.v45;
 
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.util.ArrayList;
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.Map.Entry;
+import java.util.UUID;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipOutputStream;
 
 import cz.trask.migration.AbstractProcess;
 import cz.trask.migration.model.HttpResponse;
 import cz.trask.migration.model.TokenResponse;
 import cz.trask.migration.model.v32.ApplicationDetail;
+<<<<<<< HEAD
+import cz.trask.migration.model.v45.ApplicationDetail45;
+=======
 import cz.trask.migration.model.v32.ApplicationDetail.KeyManagerApp;
 import cz.trask.migration.model.v45.ApplicationCreateRequest;
 import cz.trask.migration.model.v45.ApplicationCreateResponse;
 import cz.trask.migration.model.v45.ApplicationKeyMappingRequest45;
 import cz.trask.migration.model.v45.ApplicationKeyMappingResponse45;
 import cz.trask.migration.model.v45.ApplicationListResponse45;
+>>>>>>> branch 'main' of https://gitea.kamma.cz/kamma/apicurio-migration-tool.git
 import io.apicurio.registry.rest.v2.beans.ArtifactMetaData;
 import io.apicurio.registry.rest.v2.beans.ArtifactSearchResults;
 import io.apicurio.registry.rest.v2.beans.SearchedArtifact;
@@ -30,11 +41,8 @@ import lombok.extern.log4j.Log4j2;
 public class ExportAppsToWso2FromV32 extends AbstractProcess {
 
 	private static final int DEFAULT_TIMEOUT_MINUTES = 10;
-	private static final String APPLICATIONS_ENDPOINT_PATH = "/applications";
-	private static final String CHANGE_OWNER_PATH = "/change-owner";
 
 	private final AtomicInteger appCounter = new AtomicInteger(1);
-	private SearchedArtifact adminsDefaultApplication;
 
 	/**
 	 * Main entry point for the export process.
@@ -54,10 +62,6 @@ public class ExportAppsToWso2FromV32 extends AbstractProcess {
 
 			processApplications(apps, token);
 
-			if (adminsDefaultApplication != null) {
-				log.info("Found default application for admin: {}", adminsDefaultApplication.getName());
-				processApp(adminsDefaultApplication, token, 1, 1, true);
-			}
 		} catch (Exception e) {
 			log.error("Error while exporting Apps.", e);
 			throw new RuntimeException("Export failed", e);
@@ -70,7 +74,7 @@ public class ExportAppsToWso2FromV32 extends AbstractProcess {
 
 		for (SearchedArtifact app : apps.getArtifacts()) {
 			final int index = appCounter.getAndIncrement();
-			executor.submit(() -> processApp(app, token, index, apps.getCount(), false));
+			executor.submit(() -> processApp(app, token, index, apps.getCount()));
 		}
 
 		executor.shutdown();
@@ -80,8 +84,7 @@ public class ExportAppsToWso2FromV32 extends AbstractProcess {
 		log.info("Finished processing Apps.");
 	}
 
-	private void processApp(SearchedArtifact app, TokenResponse tokenResponse, int index, int total,
-			boolean createAdminApp) {
+	private void processApp(SearchedArtifact app, TokenResponse tokenResponse, int index, int total) {
 		long start = System.currentTimeMillis();
 
 		try {
@@ -91,7 +94,7 @@ public class ExportAppsToWso2FromV32 extends AbstractProcess {
 					null);
 
 			for (SearchedVersion ver : versions.getVersions()) {
-				processAppVersion(app, tokenResponse, ver, createAdminApp);
+				processAppVersion(app, tokenResponse, ver);
 			}
 
 			long end = System.currentTimeMillis();
@@ -101,8 +104,7 @@ public class ExportAppsToWso2FromV32 extends AbstractProcess {
 		}
 	}
 
-	private void processAppVersion(SearchedArtifact app, TokenResponse tokenResponse, SearchedVersion version,
-			boolean createAdminApp) {
+	private void processAppVersion(SearchedArtifact app, TokenResponse tokenResponse, SearchedVersion version) {
 		try {
 			log.info(" - Found version: {}", version.getVersion());
 
@@ -112,15 +114,31 @@ public class ExportAppsToWso2FromV32 extends AbstractProcess {
 			if (content != null && content.length > 0) {
 				ApplicationDetail appDetail = mapper.readValue(content, ApplicationDetail.class);
 
-				// Skip default admin application unless explicitly requested
-				if (DEFAULT_APPLICATION_NAME.equals(appDetail.getName()) && ADMIN_USERNAME.equals(appDetail.getOwner())
-						&& !createAdminApp) {
-					adminsDefaultApplication = app;
-					deleteWso2ApplicationIfExists(appDetail, tokenResponse);
-					log.info(" - Skipping import of admins-default-application for now.");
-					return;
+				ApplicationDetail45 yamlApp = mapFromJsonToYaml(appDetail);
+
+				byte[] data = prepareAppZipFile32to45(yamlApp);
+
+				String fileName = yamlApp.getData().getApplicationInfo().getName() + "-"
+						+ yamlApp.getData().getApplicationInfo().getOwner() + "-v45.zip";
+
+				if (config.isStoreMigratedArtifacts()) {
+					File tmpFile = new File("tmp/app/", fileName);
+					log.info("   - Storing migrated App file: {}", tmpFile.getAbsolutePath());
+					FileOutputStream fos = new FileOutputStream(tmpFile);
+					fos.write(data);
+					fos.flush();
+					fos.close();
 				}
 
+<<<<<<< HEAD
+				if (data != null && data.length > 0 && fileName != null && !fileName.isEmpty()) {
+					int responseCode = publishAppToWso2(fileName, data, tokenResponse);
+					if (responseCode == 200 || responseCode == 201) {
+						log.info("   - Application {} imported successfully with response code: {}", appDetail.getName(), responseCode);
+					} else {
+						log.warn("   - Application {} import failed with response code: {}", appDetail.getName(),
+								responseCode);
+=======
 				ApplicationCreateRequest appCreateRequest = mapAppDetailToCreateRequest(appDetail);
 				byte[] data = mapper.writeValueAsBytes(appCreateRequest);
 				log.info(" - Application {} with owner {} prepared for WSO2 export", appDetail.getName(),
@@ -172,21 +190,19 @@ public class ExportAppsToWso2FromV32 extends AbstractProcess {
 								}
 							}
 						}
+>>>>>>> branch 'main' of https://gitea.kamma.cz/kamma/apicurio-migration-tool.git
 					}
-
-					if (!createdApp.getOwner().equals(appDetail.getOwner())) {
-						log.info(" - Changing owner of Application {} to {}", createdApp.getApplicationId(),
-								appDetail.getOwner());
-						changeApplicationOwner(createdApp, appDetail.getOwner(), tokenResponse);
-					}
-
 				}
+
 			}
 		} catch (Exception e) {
 			log.error("Error processing application version: {}", e.getMessage(), e);
 		}
 	}
 
+<<<<<<< HEAD
+	public byte[] prepareAppZipFile32to45(ApplicationDetail45 yamlApp) throws Exception {
+=======
 	private ApplicationKeyMappingResponse45 generateKeysForApplication(String applicationId, String keyType, String keyManager) {
 		try {
 			String endpoint = config.getTarget().getDevPortalApiUrl() + "/v3/applications/" + applicationId
@@ -223,126 +239,161 @@ public class ExportAppsToWso2FromV32 extends AbstractProcess {
 			// Publish the application key mapping data to WSO2
 			Map<String, String> httpHeaders = createBearerAuthHeaders(tokenResponse);
 			httpHeaders.put("Content-Type", "application/json");
+>>>>>>> branch 'main' of https://gitea.kamma.cz/kamma/apicurio-migration-tool.git
 
-			String endpoint = config.getTarget().getDevPortalApiUrl() + "/v3/applications/" + applicationId
-					+ "/map-keys";
+		String baseDir = yamlApp.getData().getApplicationInfo().getOwner() + "-"
+				+ yamlApp.getData().getApplicationInfo().getName() + "/";
 
-			HttpResponse response = makeDataRequest(endpoint, httpHeaders, kmData);
+		try (ByteArrayOutputStream baos = new ByteArrayOutputStream();
+				ZipOutputStream zos = new ZipOutputStream(baos)) {
 
-			if (response.getResponseCode() == 200 || response.getResponseCode() == 201) {
-				log.info("   - Key Mapping for Application {} created successfully in WSO2", applicationId);
-			} else {
-				log.warn("   - Key Mapping for Application {} creation in WSO2 failed with response code {}",
-						applicationId, response.getResponseCode());
-			}
-		} catch (Exception e) {
-			log.error("IO error while creating Key Mapping for Application {}: {}", applicationId, e.getMessage(), e);
+			byte[] content = mapperYaml.writeValueAsBytes(yamlApp);
+			zos.putNextEntry(new ZipEntry(baseDir.concat("application.yaml")));
+			zos.write(content);
+			zos.closeEntry();
+
+			zos.finish();
+			return baos.toByteArray();
 		}
 	}
 
-	private void deleteWso2ApplicationIfExists(ApplicationDetail appDetail, TokenResponse tokenResponse) {
-		// Resolve application id by name first (WSO2 Admin API works with applicationId
-		// in paths)
-		String resolvedAppId = getExistingApplicationId(config.getTarget().getAdminApiUrl(), appDetail, tokenResponse);
+	public ApplicationDetail45 mapFromJsonToYaml(ApplicationDetail jsonApp) {
+		ApplicationDetail45 yamlApp = new ApplicationDetail45();
+		yamlApp.setType("application");
+		yamlApp.setVersion("v4.5.0");
 
-		if (resolvedAppId == null) {
-			log.warn(" - Application {} not found in WSO2, cannot delete", appDetail.getName());
-			return;
-		}
+		ApplicationDetail45.Data yamlData = new ApplicationDetail45.Data();
 
-		String endpoint = config.getTarget().getAdminApiUrl() + APPLICATIONS_ENDPOINT_PATH + "/" + resolvedAppId;
+		ApplicationDetail45.ApplicationInfo yamlAppInfo = new ApplicationDetail45.ApplicationInfo();
 
-		try {
-			Map<String, String> httpHeaders = createBearerAuthHeaders(tokenResponse);
+		yamlAppInfo.setApplicationId(jsonApp.getUuid());
+		yamlAppInfo.setName(jsonApp.getName());
+		yamlAppInfo.setThrottlingPolicy(jsonApp.getTier());
+		yamlAppInfo.setDescription(jsonApp.getDescription());
+		yamlAppInfo.setTokenType(jsonApp.getTokenType());
+		yamlAppInfo.setStatus(jsonApp.getStatus());
+		yamlAppInfo.setGroups(jsonApp.getGroupId() != null ? List.of(jsonApp.getGroupId()) : Collections.emptyList());
+		yamlAppInfo.setSubscriptionCount(jsonApp.getSubscribedAPIs() != null ? jsonApp.getSubscribedAPIs().size() : 0);
+		yamlAppInfo.setAttributes(jsonApp.getApplicationAttributes());
+		yamlAppInfo.setOwner(jsonApp.getOwner());
+		yamlAppInfo.setVisibility("PRIVATE");
+		yamlAppInfo.setCreatedTime("" + System.currentTimeMillis());
+		yamlAppInfo.setUpdatedTime("" + System.currentTimeMillis());
+		yamlAppInfo.setSubscriptionScopes(Collections.emptyList());
 
-			HttpResponse response = makeRequest("DELETE", endpoint, httpHeaders, null);
+		List<ApplicationDetail45.Key> yamlKeys = new ArrayList<>();
 
-			if (response.getResponseCode() == 200 || response.getResponseCode() == 204) {
-				log.info(" - Application {} (id={}) deleted successfully from WSO2", appDetail.getName(),
-						resolvedAppId);
-			} else {
-				log.info(" - Application {} (id={}) deletion from WSO2 returned response code {}", appDetail.getName(),
-						resolvedAppId, response.getResponseCode());
-			}
-		} catch (Exception e) {
-			log.error("IO error while deleting Application {} (id={}): {}", appDetail.getName(), resolvedAppId,
-					e.getMessage(), e);
-		}
-	}
+		if (jsonApp.getKeyManagerWiseOAuthApp() != null) {
+			for (Map.Entry<String, Map<String, ApplicationDetail.KeyManagerApp>> outerEntry : jsonApp
+					.getKeyManagerWiseOAuthApp().entrySet()) {
+				String keyType = outerEntry.getKey();
+				Map<String, ApplicationDetail.KeyManagerApp> innerMap = outerEntry.getValue();
 
-	private String getExistingApplicationId(String adminApiUrl, ApplicationDetail appDetail,
-			TokenResponse tokenResponse) {
-		try {
-			String url = adminApiUrl.concat(APPLICATIONS_ENDPOINT_PATH);
+				if (innerMap != null) {
+					for (Map.Entry<String, ApplicationDetail.KeyManagerApp> innerEntry : innerMap.entrySet()) {
+						ApplicationDetail.KeyManagerApp keyManagerApp = innerEntry.getValue();
 
-			Map<String, String> httpHeaders = createBearerAuthHeaders(tokenResponse);
-			Map<String, String> params = new HashMap<>();
+						String keyManagerType = innerEntry.getKey();
 
-			HttpResponse response = makeRequest("GET", url, httpHeaders, params);
+						ApplicationDetail45.Key yamlKey = new ApplicationDetail45.Key();
+						yamlKey.setKeyMappingId(UUID.randomUUID().toString());
+						yamlKey.setKeyManager(keyManagerType);
+						yamlKey.setConsumerKey(keyManagerApp.getClientId());
+						yamlKey.setConsumerSecret(keyManagerApp.getClientSecret());
+						String grantTypes = keyManagerApp.getParameters() != null
+								? (String) keyManagerApp.getParameters().get("grant_types")
+								: null;
+						if (grantTypes != null && !grantTypes.isEmpty()) {
+							String[] grantsArray = grantTypes.split(" ");
+							yamlKey.setSupportedGrantTypes(List.of(grantsArray));
+						} else {
+							yamlKey.setSupportedGrantTypes(List.of());
+						}
+						yamlKey.setCallbackUrl(keyManagerApp.getCallBackURL());
+						yamlKey.setKeyState("COMPLETED");
+						yamlKey.setKeyType(keyType.toUpperCase());
+						yamlKey.setMode("CREATED");
 
-			if (response.getResponseCode() != 200) {
-				log.warn("Cannot list Applications (HTTP {}). Will not attempt delete.", response.getResponseCode());
-				return null;
-			}
+						ApplicationDetail45.Token token = new ApplicationDetail45.Token();
+						token.setTokenScopes(List.of());
+						token.setValidityTime(0);
+						yamlKey.setToken(token);
 
-			ApplicationListResponse45 listOfApps = mapper.readValue(response.getResponse(),
-					ApplicationListResponse45.class);
+						Map<String, Object> additionalProps = Map.of("id_token_expiry_time", 3600,
+								"application_access_token_expiry_time", 3600, "user_access_token_expiry_time", 3600,
+								"bypassClientCredentials", false, "pkceMandatory", false, "pkceSupportPlain", false,
+								"refresh_token_expiry_time", 86400);
+						yamlKey.setAdditionalProperties(additionalProps);
 
-			if (listOfApps != null && listOfApps.getList() != null) {
-				for (ApplicationListResponse45.Application info : listOfApps.getList()) {
-					if (appDetail.getName().equals(info.getName()) && appDetail.getOwner().equals(info.getOwner())) {
-						return info.getApplicationId();
+						yamlKeys.add(yamlKey);
 					}
 				}
 			}
-		} catch (Exception e) {
-			log.error("Error while resolving Application id for name {}: {}", appDetail.getName(), e.getMessage(), e);
 		}
 
-		return null;
+		yamlAppInfo.setKeys(yamlKeys);
+
+		yamlData.setApplicationInfo(yamlAppInfo);
+
+		List<ApplicationDetail45.SubscribedAPI> yamlSubscribedAPIs = new ArrayList<>();
+
+		if (jsonApp.getSubscribedAPIs() != null) {
+			for (ApplicationDetail.SubscribedAPI jsonApi : jsonApp.getSubscribedAPIs()) {
+				ApplicationDetail45.SubscribedAPI yamlApi = new ApplicationDetail45.SubscribedAPI();
+
+				if (jsonApi.getApiId() != null) {
+					ApplicationDetail45.ApiId yamlApiId = new ApplicationDetail45.ApiId();
+					yamlApiId.setProviderName(jsonApi.getApiId().getProviderName());
+					yamlApiId.setApiName(jsonApi.getApiId().getApiName());
+					yamlApiId.setVersion(jsonApi.getApiId().getVersion());
+					yamlApiId.setUuid(jsonApi.getUuid());
+					yamlApiId.setId(jsonApi.getApiId().getId());
+					yamlApi.setApiId(yamlApiId);
+				}
+
+				if (jsonApi.getSubscriber() != null) {
+					ApplicationDetail45.Subscriber yamlSubscriber = new ApplicationDetail45.Subscriber();
+					yamlSubscriber.setName(jsonApi.getSubscriber().getName());
+					yamlSubscriber.setId(jsonApi.getSubscriber().getId());
+					yamlSubscriber.setTenantId(jsonApi.getSubscriber().getTenantId());
+					yamlApi.setSubscriber(yamlSubscriber);
+				}
+
+				yamlApi.setThrottlingPolicy(jsonApi.getTier() != null ? jsonApi.getTier().getName() : "Unlimited");
+				yamlSubscribedAPIs.add(yamlApi);
+			}
+		}
+
+		yamlData.setSubscribedAPIs(yamlSubscribedAPIs);
+
+		yamlApp.setData(yamlData);
+
+		return yamlApp;
 	}
 
-	private HttpResponse publishAppToWso2(String name, byte[] data, TokenResponse tokenResponse) throws Exception {
-		// Publish the application data to WSO2
-		Map<String, String> httpHeaders = createBasicAuthHeaders(config.getTarget().getWso2User());
-		httpHeaders.put("Content-Type", "application/json");
-
-		String endpoint = config.getTarget().getDevPortalApiUrl() + "/v3/applications";
-
-		return makeDataRequest(endpoint, httpHeaders, data);
-	}
-
-	private void changeApplicationOwner(ApplicationCreateResponse createdApp, String origOwner,
-			TokenResponse tokenResponse) {
-		String endpoint = config.getTarget().getAdminApiUrl() + APPLICATIONS_ENDPOINT_PATH + "/"
-				+ createdApp.getApplicationId() + CHANGE_OWNER_PATH + "?owner=" + origOwner;
-
+	private int publishAppToWso2(String fileName, byte[] data, TokenResponse tokenResponse) {
+		int responseCode = -1;
 		try {
-			Map<String, String> httpHeaders = createBearerAuthHeaders(tokenResponse);
+			String url = config.getTarget().getDevPortalApiUrl().concat(String.format(
+					"/v3/applications/import?preserveOwner=true&skipSubscriptions=false&skipApplicationKeys=false&update=true"));
 
-			HttpResponse response = makeRequest("POST", endpoint, httpHeaders, null);
+			log.info("App Import URL: " + url);
 
-			if (response.getResponseCode() == 200 || response.getResponseCode() == 201) {
-				log.info(" - Application {} owner changed successfully to {}", createdApp.getApplicationId(),
-						origOwner);
-			} else {
-				log.warn(" - Application {} owner change to {} failed with response code {}",
-						createdApp.getApplicationId(), origOwner, response.getResponseCode());
+			Map<String, String> httpHeaders = new HashMap<>();
+
+			httpHeaders.put("Authorization", "Bearer " + tokenResponse.getAccess_token());
+
+			HttpResponse response = makeFileRequest("POST", url, httpHeaders, data, fileName);
+
+			responseCode = response.getResponseCode();
+
+			if (response.getResponseCode() < 200 || response.getResponseCode() > 299) {
+				log.info("Cannot import App file: " + fileName + ", response code: " + response.getResponseCode());
 			}
 		} catch (Exception e) {
-			log.error("IO error while changing owner of Application {}: {}", createdApp.getApplicationId(),
-					e.getMessage(), e);
+			log.error("IO error while importing App file: " + fileName + ", error: " + e.getMessage(), e);
 		}
+		return responseCode;
 	}
 
-	private ApplicationCreateRequest mapAppDetailToCreateRequest(ApplicationDetail appDetail) {
-		ApplicationCreateRequest request = new ApplicationCreateRequest();
-		request.setName(appDetail.getName());
-		request.setDescription(appDetail.getDescription());
-		request.setThrottlingPolicy(appDetail.getTier());
-		request.setTokenType(appDetail.getTokenType());
-		request.setGroups(List.of(appDetail.getGroupId()));
-
-		return request;
-	}
 }

src/main/java/cz/trask/migration/model/ApplicationConfig.java

@@ -19,6 +19,8 @@ public class ApplicationConfig {
 	private Apicurio apicurio;
 	@JsonProperty("max_threads")
 	private int maxThreads;
+	@JsonProperty("store_migrated_artifacts")
+	private boolean storeMigratedArtifacts = false;
 
 	@Data
 	public static class TrustStore {

src/main/java/cz/trask/migration/model/v45/ApplicationCreateRequest.java

@@ -1,55 +0,0 @@
-package cz.trask.migration.model.v45;
-
-import java.util.List;
-import java.util.Map;
-
-import javax.validation.constraints.NotNull;
-import javax.validation.constraints.Pattern;
-import javax.validation.constraints.Size;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class ApplicationCreateRequest {
-
-	@NotNull
-	@Size(min = 1, max = 100)
-	private String name;
-
-	@NotNull
-	private String throttlingPolicy;
-
-	@Size(max = 512)
-	private String description;
-
-	@Pattern(regexp = "JWT|OAUTH")
-	private String tokenType = "JWT";
-
-	private List<String> groups;
-
-	private Map<String, Object> attributes;
-
-	private List<SubscriptionScope> subscriptionScopes;
-
-	@Pattern(regexp = "PRIVATE|SHARED_WITH_ORG")
-	private String visibility;
-
-	@Data
-	@AllArgsConstructor
-	@NoArgsConstructor
-	public static class SubscriptionScope {
-		@NotNull
-		private String key;
-
-		@NotNull
-		private String name;
-
-		private List<String> roles;
-
-		private String description;
-	}
-}

src/main/java/cz/trask/migration/model/v45/ApplicationCreateResponse.java

@@ -1,88 +0,0 @@
-package cz.trask.migration.model.v45;
-
-import java.util.List;
-import java.util.Map;
-
-import com.fasterxml.jackson.annotation.JsonProperty;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@NoArgsConstructor
-@AllArgsConstructor
-public class ApplicationCreateResponse {
-	@JsonProperty("applicationId")
-	private String applicationId;
-
-	@JsonProperty("name")
-	private String name;
-
-	@JsonProperty("throttlingPolicy")
-	private String throttlingPolicy;
-
-	@JsonProperty("description")
-	private String description;
-
-	@JsonProperty("tokenType")
-	private String tokenType = "JWT";
-
-	@JsonProperty("status")
-	private String status = "";
-
-	@JsonProperty("groups")
-	private List<String> groups;
-
-	@JsonProperty("subscriptionCount")
-	private Integer subscriptionCount;
-
-	@JsonProperty("keys")
-	private List<ApplicationKey> keys;
-
-	@JsonProperty("attributes")
-	private Map<String, Object> attributes;
-
-	@JsonProperty("subscriptionScopes")
-	private List<SubscriptionScope> subscriptionScopes;
-
-	@JsonProperty("owner")
-	private String owner;
-
-	@JsonProperty("hashEnabled")
-	private Boolean hashEnabled;
-
-	@JsonProperty("createdTime")
-	private String createdTime;
-
-	@JsonProperty("updatedTime")
-	private String updatedTime;
-
-	@JsonProperty("visibility")
-	private String visibility;
-
-	@Data
-	@NoArgsConstructor
-	@AllArgsConstructor
-	public static class ApplicationKey {
-		@JsonProperty("key")
-		private String key;
-
-		@JsonProperty("keyType")
-		private String keyType;
-
-		@JsonProperty("state")
-		private String state;
-	}
-
-	@Data
-	@NoArgsConstructor
-	@AllArgsConstructor
-	public static class SubscriptionScope {
-		@JsonProperty("name")
-		private String name;
-
-		@JsonProperty("description")
-		private String description;
-	}
-}

src/main/java/cz/trask/migration/model/v45/ApplicationKeyMappingRequest45.java

@@ -1,26 +0,0 @@
-package cz.trask.migration.model.v45;
-
-import com.fasterxml.jackson.annotation.JsonProperty;
-
-import lombok.Builder;
-import lombok.Data;
-
-@Data
-@Builder
-public class ApplicationKeyMappingRequest45 {
-	@JsonProperty("consumerKey")
-	private String consumerKey;
-
-	@JsonProperty("consumerSecret")
-	private String consumerSecret;
-
-	@JsonProperty("keyManager")
-	private String keyManager;
-
-	@JsonProperty("keyType")
-	private KeyType keyType;
-
-	public enum KeyType {
-		PRODUCTION, SANDBOX
-	}
-}

src/main/java/cz/trask/migration/model/v45/ApplicationKeyMappingResponse45.java

@@ -1,73 +0,0 @@
-package cz.trask.migration.model.v45;
-
-import java.util.List;
-import java.util.Map;
-
-import com.fasterxml.jackson.annotation.JsonProperty;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class ApplicationKeyMappingResponse45 {
-	@JsonProperty("keyMappingId")
-	private String keyMappingId;
-
-	@JsonProperty("keyManager")
-	private String keyManager;
-
-	@JsonProperty("consumerKey")
-	private String consumerKey;
-
-	@JsonProperty("consumerSecret")
-	private String consumerSecret;
-
-	@JsonProperty("supportedGrantTypes")
-	private List<String> supportedGrantTypes;
-
-	@JsonProperty("callbackUrl")
-	private String callbackUrl;
-
-	@JsonProperty("keyState")
-	private String keyState;
-
-	@JsonProperty("keyType")
-	private KeyType keyType;
-
-	@JsonProperty("mode")
-	private Mode mode;
-
-	@JsonProperty("groupId")
-	private String groupId;
-
-	@JsonProperty("token")
-	private Token token;
-
-	@JsonProperty("additionalProperties")
-	private Map<String, Object> additionalProperties;
-
-	@Data
-	@AllArgsConstructor
-	@NoArgsConstructor
-	public static class Token {
-		@JsonProperty("accessToken")
-		private String accessToken;
-
-		@JsonProperty("tokenScopes")
-		private List<String> tokenScopes;
-
-		@JsonProperty("validityTime")
-		private Long validityTime;
-	}
-
-	enum Mode {
-		MAPPED, CREATED
-	}
-
-	enum KeyType {
-		PRODUCTION, SANDBOX
-	}
-}

src/main/java/cz/trask/migration/model/v45/ApplicationListResponse45.java

@@ -1,37 +0,0 @@
-package cz.trask.migration.model.v45;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-public class ApplicationListResponse45 {
-
-	private int count;
-	private Application[] list;
-	private Pagination pagination;
-
-	@Data
-	@AllArgsConstructor
-	@NoArgsConstructor
-	public static class Application {
-		private String applicationId;
-		private String name;
-		private String owner;
-		private String status;
-		private String groupId;
-	}
-
-	@Data
-	@AllArgsConstructor
-	@NoArgsConstructor
-	public static class Pagination {
-		private int offset;
-		private int limit;
-		private int total;
-		private String next;
-		private String previous;
-	}
-}

src/main/resources/apicurio-migrator.yaml

@@ -28,3 +28,5 @@ apicurio:
   overwrite_existing_application: true
 
 max_threads: 1
+
+store_migrated_artifacts: true