loafle/openapi-generator
3
0
Fork 0
forked from loafle/openapi-generator-original
Code Pull Requests Activity

Expose getter/setter for serverPort to facilitate testing (#7480)

Browse Source
This commit is contained in:
ccozzolino 2018-01-23 22:31:20 -06:00 committed by William Cheng
parent fe22472634
commit 0b2d805699
1 changed files with 21 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
modules/swagger-codegen/src/main/resources/JavaVertXServer/MainApiVerticle.mustache
View File

@ -19,10 +19,19 @@ import io.vertx.core.Vertx;
import io.vertx.ext.web.Router; import io.vertx.ext.web.Router;
public class MainApiVerticle extends AbstractVerticle { public class MainApiVerticle extends AbstractVerticle {
final static Logger LOGGER = LoggerFactory.getLogger(MainApiVerticle.class); final static Logger LOGGER = LoggerFactory.getLogger(MainApiVerticle.class);
private int serverPort = {{serverPort}};
protected Router router; protected Router router;
public int getServerPort() {
return serverPort;
}
public void setServerPort(int serverPort) {
this.serverPort = serverPort;
}
@Override @Override
public void init(Vertx vertx, Context context) { public void init(Vertx vertx, Context context) {
super.init(vertx, context); super.init(vertx, context);
@ -37,13 +46,18 @@ public class MainApiVerticle extends AbstractVerticle {
if (readFile.succeeded()) { if (readFile.succeeded()) {
Swagger swagger = new SwaggerParser().parse(readFile.result().toString(Charset.forName("utf-8"))); Swagger swagger = new SwaggerParser().parse(readFile.result().toString(Charset.forName("utf-8")));
Router swaggerRouter = SwaggerRouter.swaggerRouter(router, swagger, vertx.eventBus(), new OperationIdServiceIdResolver()); Router swaggerRouter = SwaggerRouter.swaggerRouter(router, swagger, vertx.eventBus(), new OperationIdServiceIdResolver());
deployVerticles(startFuture); deployVerticles(startFuture);
vertx.createHttpServer() vertx.createHttpServer()
.requestHandler(swaggerRouter::accept) .requestHandler(swaggerRouter::accept)
.listen({{serverPort}}); .listen(serverPort, h -> {
startFuture.complete(); if (h.succeeded()) {
startFuture.complete();
} else {
startFuture.fail(h.cause());
}
});
} else { } else {
startFuture.fail(readFile.cause()); startFuture.fail(readFile.cause());
} }