Skip to content

Commit

Permalink
refs #305 - fixes server url and add options
Browse files Browse the repository at this point in the history
  • Loading branch information
frantuma committed Aug 27, 2019
1 parent a06919f commit df56646
Show file tree
Hide file tree
Showing 2 changed files with 93 additions and 13 deletions.
88 changes: 75 additions & 13 deletions src/main/java/io/swagger/oas/inflector/OpenAPIInflector.java
Original file line number Diff line number Diff line change
Expand Up @@ -44,18 +44,27 @@
import io.swagger.v3.parser.core.models.SwaggerParseResult;
import io.swagger.v3.core.util.Json;
import io.swagger.v3.core.util.Yaml;
import io.swagger.v3.parser.util.ClasspathHelper;
import io.swagger.v3.parser.util.RemoteUrl;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang3.StringUtils;
import org.glassfish.jersey.media.multipart.MultiPartFeature;
import org.glassfish.jersey.server.ResourceConfig;
import org.glassfish.jersey.server.model.Resource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.net.ssl.SSLHandshakeException;
import javax.servlet.ServletContext;
import javax.ws.rs.HttpMethod;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.ext.ContextResolver;
import java.net.URI;
import java.nio.file.Files;
import java.nio.file.LinkOption;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
Expand Down Expand Up @@ -155,6 +164,9 @@ protected void init(Configuration configuration) {
}
if (b.length() > 0) {
openAPI.getServers().get(0).setUrl(b.toString());
if (configuration.getExposedSpecOptions().isMergeRootPath()) {
exposedAPI.getServers().get(0).setUrl(b.toString());
}
}

Map<String, PathItem> paths = openAPI.getPaths();
Expand Down Expand Up @@ -375,19 +387,6 @@ else if (Configuration.Environment.PRODUCTION.equals(configuration.getEnvironmen
}
}

private OpenAPI getExposedAPI(Configuration config) {
ExposedSpecOptions exposedSpecOptions = config.getExposedSpecOptions();
boolean hideExtension = exposedSpecOptions.isHideInflectorExtensions();
SwaggerParseResult exposedSwaggerParseResult = new OpenAPIV3Parser().readLocation(config.getSwaggerUrl(), null, exposedSpecOptions.getParseOptions());
OpenAPI exposedAPI = exposedSwaggerParseResult.getOpenAPI();
if (hideExtension) {
new ExtensionsUtil().removeExtensions(exposedAPI);
} else {
new ExtensionsUtil().addExtensions(exposedAPI);
}
return exposedAPI;
}

public static String basePath(String basePath, String path) {
if(StringUtils.isBlank(basePath)) {
basePath = "/";
Expand Down Expand Up @@ -507,4 +506,67 @@ private void addConsumesToResource(String mediaType, Resource.Builder builder, S
builder.addMethod(method).handledBy(controller);
}
}

private OpenAPI getExposedAPI(Configuration config) {
ExposedSpecOptions exposedSpecOptions = config.getExposedSpecOptions();
boolean hideExtension = exposedSpecOptions.isHideInflectorExtensions();
OpenAPI exposedAPI = null;
if (exposedSpecOptions.isUseOriginalNotParsed()) {
exposedAPI = deserializeSpec(config.getSwaggerUrl());
}
if (exposedAPI == null) {
SwaggerParseResult exposedSwaggerParseResult = new OpenAPIV3Parser().readLocation(config.getSwaggerUrl(), null, exposedSpecOptions.getParseOptions());
exposedAPI = exposedSwaggerParseResult.getOpenAPI();
}
if (hideExtension) {
new ExtensionsUtil().removeExtensions(exposedAPI);
} else {
new ExtensionsUtil().addExtensions(exposedAPI);
}
return exposedAPI;
}

// deserialize with swagger-core
private OpenAPI deserializeSpec(String swaggerUrl) {
OpenAPI exposedAPI = null;
String location = config.getSwaggerUrl().replaceAll("\\\\", "/");
try {
String data = null;
if (location.toLowerCase().startsWith("http")) {
data = RemoteUrl.urlToString(location, null);
} else {
String fileScheme = "file:";
Path path;
if (location.toLowerCase().startsWith("file:")) {
path = Paths.get(URI.create(location));
} else {
path = Paths.get(location);
}

if (Files.exists(path, new LinkOption[0])) {
data = FileUtils.readFileToString(path.toFile(), "UTF-8");
} else {
data = ClasspathHelper.loadFileFromClasspath(location);
}
exposedAPI = getRightMapper(data).readValue(data, OpenAPI.class);
}
} catch (SSLHandshakeException e) {
LOGGER.error("unable to read location `" + location + "` due to a SSL configuration error. It is possible that the server SSL certificate is invalid, self-signed, or has an untrusted Certificate Authority.", e);
} catch (Exception e1) {
LOGGER.error("unable to read location `" + location + "`", e1);
}
return exposedAPI;
}

private ObjectMapper getRightMapper(String data) {
ObjectMapper mapper;
if (data.trim().startsWith("{")) {
mapper = Json.mapper();
} else {
mapper = Yaml.mapper();
}

return mapper;
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,8 @@
public class ExposedSpecOptions {
private ParseOptions parseOptions;
private boolean hideInflectorExtensions = true;
private boolean useOriginalNotParsed = false;
private boolean mergeRootPath = true;

public ExposedSpecOptions() {
this.parseOptions = new ParseOptions();
Expand All @@ -25,4 +27,20 @@ public boolean isHideInflectorExtensions() {
public void setHideInflectorExtensions(boolean hideInflectorExtensions) {
this.hideInflectorExtensions = hideInflectorExtensions;
}

public boolean isUseOriginalNotParsed() {
return useOriginalNotParsed;
}

public void setUseOriginalNotParsed(boolean useOriginalNotParsed) {
this.useOriginalNotParsed = useOriginalNotParsed;
}

public boolean isMergeRootPath() {
return mergeRootPath;
}

public void setMergeRootPath(boolean mergeRootPath) {
this.mergeRootPath = mergeRootPath;
}
}

0 comments on commit df56646

Please sign in to comment.