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

refactor - format, imports

Browse Source
This commit is contained in:
Radek Davidek 2025-10-23 14:21:00 +02:00
parent cf9ba95e87
commit ee7e16244a
7 changed files with 338 additions and 349 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/cz/trask/migration/impl/v32/ZipUtils.java
View File

@ -3,24 +3,16 @@ package cz.trask.migration.impl.v32;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;
import java.util.zip.ZipOutputStream;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import cz.trask.migration.mapper.ApiDefinitionMapper;
import cz.trask.migration.model.ApiDefinition32;
import cz.trask.migration.model.FileType;
import cz.trask.migration.model.ZipEntryData;
import io.apicurio.registry.rest.client.RegistryClient;
import io.apicurio.registry.rest.v2.beans.ArtifactMetaData;
import io.apicurio.registry.rest.v2.beans.ArtifactReference;
import io.apicurio.registry.rest.v2.beans.SearchedVersion;
public class ZipUtils {

1
src/main/java/cz/trask/migration/impl/v45/ExportToWso2FromV32.java
View File

@ -1,7 +1,6 @@
package cz.trask.migration.impl.v45;
import java.io.ByteArrayOutputStream;
import java.io.FileOutputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

262
src/main/java/cz/trask/migration/model/ApiDefinition32.java
View File

@ -27,149 +27,147 @@ public class ApiDefinition32 {
}
}
private IdSection id;
private String uuid;
private String type;
private String context;
private String contextTemplate;
private List<String> tags;
private List<Object> documents;
private String lastUpdated;
private List<Tier> availableTiers;
private List<Object> availableSubscriptionLevelPolicies;
private List<Object> uriTemplates;
private boolean apiHeaderChanged;
private boolean apiResourcePatternsChanged;
private String status;
private String visibility;
private List<Object> gatewayLabels;
private boolean endpointSecured;
private boolean endpointAuthDigest;
private String transports;
private String inSequence;
private String outSequence;
private String faultSequence;
private String oldInSequence;
private String oldOutSequence;
private String oldFaultSequence;
private boolean advertiseOnly;
private String subscriptionAvailability;
private CorsConfiguration corsConfiguration;
@JsonDeserialize(using = EndpointConfigDeserializer.class)
private EndpointConfig endpointConfig;
private String responseCache;
private int cacheTimeout;
private String implementation;
private String authorizationHeader;
private List<Object> scopes;
private boolean isDefaultVersion;
private boolean isPublishedDefaultVersion;
private List<String> keyManagers;
private List<String> environments;
private String createdTime;
private Map<String, Object> additionalProperties;
private Map<String, Object> monetizationProperties;
private boolean isMonetizationEnabled;
private List<String> environmentList;
private String apiSecurity;
private List<Object> endpoints;
private boolean enableSchemaValidation;
private List<Object> apiCategories;
private boolean enableStore;
private String accessControl;
private double rating;
private boolean isLatest;
private IdSection id;
private String uuid;
private String type;
private String context;
private String contextTemplate;
private List<String> tags;
private List<Object> documents;
private String lastUpdated;
private List<Tier> availableTiers;
private List<Object> availableSubscriptionLevelPolicies;
private List<Object> uriTemplates;
private boolean apiHeaderChanged;
private boolean apiResourcePatternsChanged;
private String status;
private String visibility;
private List<Object> gatewayLabels;
private boolean endpointSecured;
private boolean endpointAuthDigest;
private String transports;
private String inSequence;
private String outSequence;
private String faultSequence;
private String oldInSequence;
private String oldOutSequence;
private String oldFaultSequence;
private boolean advertiseOnly;
private String subscriptionAvailability;
private CorsConfiguration corsConfiguration;
@JsonDeserialize(using = EndpointConfigDeserializer.class)
private EndpointConfig endpointConfig;
private String responseCache;
private int cacheTimeout;
private String implementation;
private String authorizationHeader;
private List<Object> scopes;
private boolean isDefaultVersion;
private boolean isPublishedDefaultVersion;
private List<String> keyManagers;
private List<String> environments;
private String createdTime;
private Map<String, Object> additionalProperties;
private Map<String, Object> monetizationProperties;
private boolean isMonetizationEnabled;
private List<String> environmentList;
private String apiSecurity;
private List<Object> endpoints;
private boolean enableSchemaValidation;
private List<Object> apiCategories;
private boolean enableStore;
private String accessControl;
private double rating;
private boolean isLatest;
// -------------------- inner classes --------------------
// -------------------- inner classes --------------------
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class IdSection {
private String providerName;
private String apiName;
private String version;
private int id;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class IdSection {
private String providerName;
private String apiName;
private String version;
private int id;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class Tier {
private String name;
private String displayName;
private String description;
private int requestsPerMin;
private int requestCount;
private int unitTime;
private String timeUnit;
private String tierPlan;
private boolean stopOnQuotaReached;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class Tier {
private String name;
private String displayName;
private String description;
private int requestsPerMin;
private int requestCount;
private int unitTime;
private String timeUnit;
private String tierPlan;
private boolean stopOnQuotaReached;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class CorsConfiguration {
private boolean corsConfigurationEnabled;
private List<String> accessControlAllowOrigins;
private boolean accessControlAllowCredentials;
private List<String> accessControlAllowHeaders;
private List<String> accessControlAllowMethods;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class CorsConfiguration {
private boolean corsConfigurationEnabled;
private List<String> accessControlAllowOrigins;
private boolean accessControlAllowCredentials;
private List<String> accessControlAllowHeaders;
private List<String> accessControlAllowMethods;
}
// ----------- typový objekt endpointConfig -----------
// ----------- typový objekt endpointConfig -----------
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointConfig {
@JsonProperty("endpoint_type")
private String endpointType;
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointConfig {
@JsonProperty("endpoint_type")
private String endpointType;
@JsonProperty("sandbox_endpoints")
private Endpoint sandboxEndpoints;
@JsonProperty("sandbox_endpoints")
private Endpoint sandboxEndpoints;
@JsonProperty("production_endpoints")
private Endpoint productionEndpoints;
@JsonProperty("production_endpoints")
private Endpoint productionEndpoints;
@JsonProperty("endpoint_security")
private EndpointSecurity endpointSecurity;
}
@JsonProperty("endpoint_security")
private EndpointSecurity endpointSecurity;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class Endpoint {
private String url;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class Endpoint {
private String url;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointSecurity {
private SecurityEnvironment sandbox;
private SecurityEnvironment production;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointSecurity {
private SecurityEnvironment sandbox;
private SecurityEnvironment production;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class SecurityEnvironment {
private String tokenUrl;
private String clientId;
private String clientSecret;
private String password;
private String username;
private String type;
private String grantType;
private boolean enabled;
private String customParameters;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class SecurityEnvironment {
private String tokenUrl;
private String clientId;
private String clientSecret;
private String password;
private String username;
private String type;
private String grantType;
private boolean enabled;
private String customParameters;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class ProxyConfigs {
private boolean proxyEnabled;
private String proxyPort;
private String proxyProtocol;
private String proxyUsername;
private String proxyPassword;
private String proxyHost;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class ProxyConfigs {
private boolean proxyEnabled;
private String proxyPort;
private String proxyProtocol;
private String proxyUsername;
private String proxyPassword;
private String proxyHost;
}
}

356
src/main/java/cz/trask/migration/model/ApiDefinition45.java
View File

@ -1,204 +1,204 @@
package cz.trask.migration.model;
import java.util.List;
import java.util.Map;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;
import java.util.List;
import java.util.Map;
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public class ApiDefinition45 {
private String type;
private String version;
private DataSection data;
private String type;
private String version;
private DataSection data;
@lombok.Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class DataSection {
private String id;
private String name;
private String description;
private String context;
private String version;
private String provider;
private String lifeCycleStatus;
private boolean responseCachingEnabled;
private int cacheTimeout;
private boolean hasThumbnail;
@JsonProperty("isDefaultVersion")
private boolean defaultVersion;
@JsonProperty("isRevision")
private boolean revision;
private int revisionId;
private boolean enableSchemaValidation;
private boolean enableSubscriberVerification;
private String type;
private List<String> audiences;
private List<String> transport;
private List<String> tags;
private List<String> policies;
private List<Object> organizationPolicies;
private String authorizationHeader;
private String apiKeyHeader;
private List<String> securityScheme;
private String visibility;
private List<String> visibleRoles;
private List<String> visibleTenants;
private List<String> visibleOrganizations;
private List<Object> mediationPolicies;
private ApiPolicies apiPolicies;
private String subscriptionAvailability;
private List<String> subscriptionAvailableTenants;
private List<Object> additionalProperties;
private Map<String, Object> additionalPropertiesMap;
private String accessControl;
private List<String> accessControlRoles;
private Map<String, Object> businessInformation;
private CorsConfiguration corsConfiguration;
private WebsubSubscriptionConfiguration websubSubscriptionConfiguration;
private String createdTime;
private String lastUpdatedTimestamp;
private String lastUpdatedTime;
private EndpointConfig endpointConfig;
private String endpointImplementationType;
private SubtypeConfiguration subtypeConfiguration;
private List<Object> scopes;
private List<Operation> operations;
private List<Object> categories;
private List<String> keyManagers;
private AdvertiseInfo advertiseInfo;
private String gatewayVendor;
private String gatewayType;
private List<Object> asyncTransportProtocols;
private boolean egress;
private String organizationId;
}
@lombok.Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class DataSection {
private String id;
private String name;
private String description;
private String context;
private String version;
private String provider;
private String lifeCycleStatus;
private boolean responseCachingEnabled;
private int cacheTimeout;
private boolean hasThumbnail;
@JsonProperty("isDefaultVersion")
private boolean defaultVersion;
@JsonProperty("isRevision")
private boolean revision;
private int revisionId;
private boolean enableSchemaValidation;
private boolean enableSubscriberVerification;
private String type;
private List<String> audiences;
private List<String> transport;
private List<String> tags;
private List<String> policies;
private List<Object> organizationPolicies;
private String authorizationHeader;
private String apiKeyHeader;
private List<String> securityScheme;
private String visibility;
private List<String> visibleRoles;
private List<String> visibleTenants;
private List<String> visibleOrganizations;
private List<Object> mediationPolicies;
private ApiPolicies apiPolicies;
private String subscriptionAvailability;
private List<String> subscriptionAvailableTenants;
private List<Object> additionalProperties;
private Map<String, Object> additionalPropertiesMap;
private String accessControl;
private List<String> accessControlRoles;
private Map<String, Object> businessInformation;
private CorsConfiguration corsConfiguration;
private WebsubSubscriptionConfiguration websubSubscriptionConfiguration;
private String createdTime;
private String lastUpdatedTimestamp;
private String lastUpdatedTime;
private EndpointConfig endpointConfig;
private String endpointImplementationType;
private SubtypeConfiguration subtypeConfiguration;
private List<Object> scopes;
private List<Operation> operations;
private List<Object> categories;
private List<String> keyManagers;
private AdvertiseInfo advertiseInfo;
private String gatewayVendor;
private String gatewayType;
private List<Object> asyncTransportProtocols;
private boolean egress;
private String organizationId;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class ApiPolicies {
private List<Policy> request;
private List<Policy> response;
private List<Policy> fault;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class ApiPolicies {
private List<Policy> request;
private List<Policy> response;
private List<Policy> fault;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class Policy {
private String policyName;
private String policyVersion;
private String policyType;
private String policyId;
private Map<String, Object> parameters;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class Policy {
private String policyName;
private String policyVersion;
private String policyType;
private String policyId;
private Map<String, Object> parameters;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class CorsConfiguration {
private boolean corsConfigurationEnabled;
private List<String> accessControlAllowOrigins;
private boolean accessControlAllowCredentials;
private List<String> accessControlAllowHeaders;
private List<String> accessControlAllowMethods;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class CorsConfiguration {
private boolean corsConfigurationEnabled;
private List<String> accessControlAllowOrigins;
private boolean accessControlAllowCredentials;
private List<String> accessControlAllowHeaders;
private List<String> accessControlAllowMethods;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class WebsubSubscriptionConfiguration {
private boolean enable;
private String secret;
private String signingAlgorithm;
private String signatureHeader;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class WebsubSubscriptionConfiguration {
private boolean enable;
private String secret;
private String signingAlgorithm;
private String signatureHeader;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointConfig {
private String endpoint_type;
private EndpointGroup sandbox_endpoints;
private EndpointGroup production_endpoints;
private EndpointSecurity endpoint_security;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointConfig {
private String endpoint_type;
private EndpointGroup sandbox_endpoints;
private EndpointGroup production_endpoints;
private EndpointSecurity endpoint_security;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointGroup {
private String url;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointGroup {
private String url;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointSecurity {
private SecurityEnv sandbox;
private SecurityEnv production;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointSecurity {
private SecurityEnv sandbox;
private SecurityEnv production;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class SecurityEnv {
private String tokenUrl;
private String clientId;
private int connectionTimeoutDuration;
private String type;
private int socketTimeoutDuration;
private boolean enabled;
private ProxyConfigs proxyConfigs;
private String password;
private String clientSecret;
private Map<String, Object> customParameters;
private Map<String, Object> additionalProperties;
private String grantType;
private int connectionRequestTimeoutDuration;
private String username;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class SecurityEnv {
private String tokenUrl;
private String clientId;
private int connectionTimeoutDuration;
private String type;
private int socketTimeoutDuration;
private boolean enabled;
private ProxyConfigs proxyConfigs;
private String password;
private String clientSecret;
private Map<String, Object> customParameters;
private Map<String, Object> additionalProperties;
private String grantType;
private int connectionRequestTimeoutDuration;
private String username;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class ProxyConfigs {
private boolean proxyEnabled;
private String proxyPort;
private String proxyProtocol;
private String proxyUsername;
private String proxyPassword;
private String proxyHost;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class ProxyConfigs {
private boolean proxyEnabled;
private String proxyPort;
private String proxyProtocol;
private String proxyUsername;
private String proxyPassword;
private String proxyHost;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class SubtypeConfiguration {
private String subtype;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class SubtypeConfiguration {
private String subtype;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class Operation {
private String id;
private String target;
private String verb;
private String authType;
private String throttlingPolicy;
private List<String> scopes;
private List<String> usedProductIds;
private OperationPolicies operationPolicies;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class Operation {
private String id;
private String target;
private String verb;
private String authType;
private String throttlingPolicy;
private List<String> scopes;
private List<String> usedProductIds;
private OperationPolicies operationPolicies;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class OperationPolicies {
private List<Policy> request;
private List<Policy> response;
private List<Policy> fault;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class OperationPolicies {
private List<Policy> request;
private List<Policy> response;
private List<Policy> fault;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class AdvertiseInfo {
private boolean advertised;
private String apiOwner;
private String vendor;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class AdvertiseInfo {
private boolean advertised;
private String apiOwner;
private String vendor;
}
}

22
src/main/java/cz/trask/migration/model/EndpointCertificates45.java
View File

@ -10,17 +10,17 @@ import lombok.Data;
@JsonIgnoreProperties(ignoreUnknown = true)
public class EndpointCertificates45 {
private String type;
private String version;
private String type;
private String version;
private List<EndpointCertificate> data;
private List<EndpointCertificate> data;
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointCertificate {
private String alias;
private String endpoint;
private String certificate;
private int tenantId;
}
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class EndpointCertificate {
private String alias;
private String endpoint;
private String certificate;
private int tenantId;
}
}

32
src/main/java/cz/trask/migration/model/OperationPolicySpecification45.java
View File

@ -11,25 +11,25 @@ import lombok.Data;
@JsonIgnoreProperties(ignoreUnknown = true)
public class OperationPolicySpecification45 {
private String type;
private String version;
private Data data;
private String type;
private String version;
private Data data;
@lombok.Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class Data {
@lombok.Data
@JsonIgnoreProperties(ignoreUnknown = true)
public static class Data {
private String category;
private String name;
private String version; // version of the policy itself
private String displayName;
private String description;
private String category;
private String name;
private String version; // version of the policy itself
private String displayName;
private String description;
private List<String> applicableFlows;
private List<String> supportedGateways;
private List<String> supportedApiTypes;
private List<String> applicableFlows;
private List<String> supportedGateways;
private List<String> supportedApiTypes;
private List<Object> policyAttributes = new ArrayList<>();
private List<Object> policyAttributes = new ArrayList<>();
}
}
}