forked from loafle/openapi-generator-original
test kotlin vertx in pom.xml (#3890)
This commit is contained in:
William Cheng
GitHub
parent
667a6097b5
commit
a8826816fb
@ -66,7 +66,7 @@ OpenAPI Generator allows generation of API client libraries (SDK generation), se
|
|||||||
| | Languages/Frameworks |
|
| | Languages/Frameworks |
|
||||||
|-|-|
|
|-|-|
|
||||||
**API clients** | **ActionScript**, **Ada**, **Apex**, **Bash**, **C**, **C#** (.net 2.0, 3.5 or later, .NET Standard 1.3 - 2.0, .NET Core 2.0), **C++** (cpp-restsdk, Qt5, Tizen), **Clojure**, **Dart (1.x, 2.x)**, **Elixir**, **Elm**, **Eiffel**, **Erlang**, **Go**, **Groovy**, **Haskell** (http-client, Servant), **Java** (Jersey1.x, Jersey2.x, OkHttp, Retrofit1.x, Retrofit2.x, Feign, RestTemplate, RESTEasy, Vertx, Google API Client Library for Java, Rest-assured, Spring 5 Web Client), **Kotlin**, **Lua**, **Nim**, **Node.js/JavaScript** (ES5, ES6, AngularJS with Google Closure Compiler annotations, Flow types), **Objective-C**, **OCaml**, **Perl**, **PHP**, **PowerShell**, **Python**, **R**, **Ruby**, **Rust** (rust, rust-server), **Scala** (akka, http4s, scalaz, swagger-async-httpclient), **Swift** (2.x, 3.x, 4.x), **Typescript** (AngularJS, Angular (2.x - 8.x), Aurelia, Axios, Fetch, Inversify, jQuery, Node, Rxjs)
|
**API clients** | **ActionScript**, **Ada**, **Apex**, **Bash**, **C**, **C#** (.net 2.0, 3.5 or later, .NET Standard 1.3 - 2.0, .NET Core 2.0), **C++** (cpp-restsdk, Qt5, Tizen), **Clojure**, **Dart (1.x, 2.x)**, **Elixir**, **Elm**, **Eiffel**, **Erlang**, **Go**, **Groovy**, **Haskell** (http-client, Servant), **Java** (Jersey1.x, Jersey2.x, OkHttp, Retrofit1.x, Retrofit2.x, Feign, RestTemplate, RESTEasy, Vertx, Google API Client Library for Java, Rest-assured, Spring 5 Web Client), **Kotlin**, **Lua**, **Nim**, **Node.js/JavaScript** (ES5, ES6, AngularJS with Google Closure Compiler annotations, Flow types), **Objective-C**, **OCaml**, **Perl**, **PHP**, **PowerShell**, **Python**, **R**, **Ruby**, **Rust** (rust, rust-server), **Scala** (akka, http4s, scalaz, swagger-async-httpclient), **Swift** (2.x, 3.x, 4.x), **Typescript** (AngularJS, Angular (2.x - 8.x), Aurelia, Axios, Fetch, Inversify, jQuery, Node, Rxjs)
|
||||||
**Server stubs** | **Ada**, **C#** (ASP.NET Core, NancyFx), **C++** (Pistache, Restbed, Qt5 QHTTPEngine), **Erlang**, **F#** (Giraffe), **Go** (net/http, Gin), **Haskell** (Servant), **Java** (MSF4J, Spring, Undertow, JAX-RS: CDI, CXF, Inflector, Jersey, RestEasy, Play Framework, [PKMST](https://github.com/ProKarma-Inc/pkmst-getting-started-examples)), **Kotlin** (Spring Boot, Ktor), **PHP** (Laravel, Lumen, Slim, Silex, [Symfony](https://symfony.com/), [Zend Expressive](https://github.com/zendframework/zend-expressive)), **Python** (Flask), **NodeJS**, **Ruby** (Sinatra, Rails5), **Rust** (rust-server), **Scala** ([Finch](https://github.com/finagle/finch), [Lagom](https://github.com/lagom/lagom), [Play](https://www.playframework.com/), Scalatra)
|
**Server stubs** | **Ada**, **C#** (ASP.NET Core, NancyFx), **C++** (Pistache, Restbed, Qt5 QHTTPEngine), **Erlang**, **F#** (Giraffe), **Go** (net/http, Gin), **Haskell** (Servant), **Java** (MSF4J, Spring, Undertow, JAX-RS: CDI, CXF, Inflector, Jersey, RestEasy, Play Framework, [PKMST](https://github.com/ProKarma-Inc/pkmst-getting-started-examples)), **Kotlin** (Spring Boot, Ktor, Vertx), **PHP** (Laravel, Lumen, Slim, Silex, [Symfony](https://symfony.com/), [Zend Expressive](https://github.com/zendframework/zend-expressive)), **Python** (Flask), **NodeJS**, **Ruby** (Sinatra, Rails5), **Rust** (rust-server), **Scala** ([Finch](https://github.com/finagle/finch), [Lagom](https://github.com/lagom/lagom), [Play](https://www.playframework.com/), Scalatra)
|
||||||
**API documentation generators** | **HTML**, **Confluence Wiki**, **Asciidoc**
|
**API documentation generators** | **HTML**, **Confluence Wiki**, **Asciidoc**
|
||||||
**Configuration files** | [**Apache2**](https://httpd.apache.org/)
|
**Configuration files** | [**Apache2**](https://httpd.apache.org/)
|
||||||
**Others** | **GraphQL**, **JMeter**, **MySQL Schema**, **Protocol Buffer**
|
**Others** | **GraphQL**, **JMeter**, **MySQL Schema**, **Protocol Buffer**
|
||||||
@ -748,6 +748,7 @@ Here is a list of template creators:
|
|||||||
* JAX-RS RestEasy (JBoss EAP): @jfiala
|
* JAX-RS RestEasy (JBoss EAP): @jfiala
|
||||||
* Kotlin: @jimschubert [:heart:](https://www.patreon.com/jimschubert)
|
* Kotlin: @jimschubert [:heart:](https://www.patreon.com/jimschubert)
|
||||||
* Kotlin (Spring Boot): @dr4ke616
|
* Kotlin (Spring Boot): @dr4ke616
|
||||||
|
* Kotlin (Vertx): @Wooyme
|
||||||
* NodeJS Express: @YishTish
|
* NodeJS Express: @YishTish
|
||||||
* PHP Laravel: @renepardon
|
* PHP Laravel: @renepardon
|
||||||
* PHP Lumen: @abcsun
|
* PHP Lumen: @abcsun
|
||||||
|
|||||||
@ -95,7 +95,7 @@ The following generators are available:
|
|||||||
* [jaxrs-spec](generators/jaxrs-spec)
|
* [jaxrs-spec](generators/jaxrs-spec)
|
||||||
* [kotlin-server](generators/kotlin-server)
|
* [kotlin-server](generators/kotlin-server)
|
||||||
* [kotlin-spring](generators/kotlin-spring)
|
* [kotlin-spring](generators/kotlin-spring)
|
||||||
* [kotlin-vertx](generators/kotlin-vertx)
|
* [kotlin-vertx (beta)](generators/kotlin-vertx)
|
||||||
* [nodejs-express-server (beta)](generators/nodejs-express-server)
|
* [nodejs-express-server (beta)](generators/nodejs-express-server)
|
||||||
* [nodejs-server-deprecated (deprecated)](generators/nodejs-server-deprecated)
|
* [nodejs-server-deprecated (deprecated)](generators/nodejs-server-deprecated)
|
||||||
* [php-laravel](generators/php-laravel)
|
* [php-laravel](generators/php-laravel)
|
||||||
|
|||||||
@ -19,6 +19,8 @@ package org.openapitools.codegen.languages;
|
|||||||
import org.openapitools.codegen.CodegenConstants;
|
import org.openapitools.codegen.CodegenConstants;
|
||||||
import org.openapitools.codegen.CodegenType;
|
import org.openapitools.codegen.CodegenType;
|
||||||
import org.openapitools.codegen.SupportingFile;
|
import org.openapitools.codegen.SupportingFile;
|
||||||
|
import org.openapitools.codegen.meta.GeneratorMetadata;
|
||||||
|
import org.openapitools.codegen.meta.Stability;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
@ -51,6 +53,10 @@ public class KotlinVertxServerCodegen extends AbstractKotlinCodegen {
|
|||||||
public KotlinVertxServerCodegen() {
|
public KotlinVertxServerCodegen() {
|
||||||
super();
|
super();
|
||||||
|
|
||||||
|
generatorMetadata = GeneratorMetadata.newBuilder(generatorMetadata)
|
||||||
|
.stability(Stability.BETA)
|
||||||
|
.build();
|
||||||
|
|
||||||
outputFolder = "generated-code" + File.separator + "kotlin-vertx";
|
outputFolder = "generated-code" + File.separator + "kotlin-vertx";
|
||||||
modelTemplateFiles.put("model.mustache", ".kt");
|
modelTemplateFiles.put("model.mustache", ".kt");
|
||||||
|
|
||||||
@ -61,7 +67,7 @@ public class KotlinVertxServerCodegen extends AbstractKotlinCodegen {
|
|||||||
apiTemplateFiles.clear();
|
apiTemplateFiles.clear();
|
||||||
apiTemplateFiles.put("api.mustache", ".kt");
|
apiTemplateFiles.put("api.mustache", ".kt");
|
||||||
apiTemplateFiles.put("apiProxy.mustache", "VertxProxyHandler.kt");
|
apiTemplateFiles.put("apiProxy.mustache", "VertxProxyHandler.kt");
|
||||||
apiTemplateFiles.put("api_verticle.mustache","Verticle.kt");
|
apiTemplateFiles.put("api_verticle.mustache", "Verticle.kt");
|
||||||
|
|
||||||
embeddedTemplateDir = templateDir = "kotlin-vertx-server";
|
embeddedTemplateDir = templateDir = "kotlin-vertx-server";
|
||||||
apiPackage = rootPackage + ".verticle";
|
apiPackage = rootPackage + ".verticle";
|
||||||
@ -78,8 +84,4 @@ public class KotlinVertxServerCodegen extends AbstractKotlinCodegen {
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public String escapeReservedWord(String name) {
|
|
||||||
return name;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
1
pom.xml
1
pom.xml
@ -1166,6 +1166,7 @@
|
|||||||
<module>samples/server/petstore/scala-play-server</module>
|
<module>samples/server/petstore/scala-play-server</module>
|
||||||
<module>samples/server/petstore/scalatra</module>
|
<module>samples/server/petstore/scalatra</module>
|
||||||
<module>samples/server/petstore/scala-finch</module>
|
<module>samples/server/petstore/scala-finch</module>
|
||||||
|
<module>samples/server/petstore/kotlin/vertx</module>
|
||||||
<module>samples/server/petstore/kotlin-springboot</module>
|
<module>samples/server/petstore/kotlin-springboot</module>
|
||||||
</modules>
|
</modules>
|
||||||
</profile>
|
</profile>
|
||||||
|
|||||||
@ -0,0 +1,23 @@
|
|||||||
|
# OpenAPI Generator Ignore
|
||||||
|
# Generated by openapi-generator https://github.com/openapitools/openapi-generator
|
||||||
|
|
||||||
|
# Use this file to prevent files from being overwritten by the generator.
|
||||||
|
# The patterns follow closely to .gitignore or .dockerignore.
|
||||||
|
|
||||||
|
# As an example, the C# client generator defines ApiClient.cs.
|
||||||
|
# You can make changes and tell OpenAPI Generator to ignore just this file by uncommenting the following line:
|
||||||
|
#ApiClient.cs
|
||||||
|
|
||||||
|
# You can match any string of characters against a directory, file or extension with a single asterisk (*):
|
||||||
|
#foo/*/qux
|
||||||
|
# The above matches foo/bar/qux and foo/baz/qux, but not foo/bar/baz/qux
|
||||||
|
|
||||||
|
# You can recursively match patterns against a directory, file or extension with a double asterisk (**):
|
||||||
|
#foo/**/qux
|
||||||
|
# This matches foo/bar/qux, foo/baz/qux, and foo/bar/baz/qux
|
||||||
|
|
||||||
|
# You can also negate patterns with an exclamation (!).
|
||||||
|
# For example, you can ignore all files in a docs folder with the file extension .md:
|
||||||
|
#docs/*.md
|
||||||
|
# Then explicitly reverse the ignore rule for a single file:
|
||||||
|
#!docs/README.md
|
||||||
@ -0,0 +1 @@
|
|||||||
|
4.1.3-SNAPSHOT
|
||||||
81
samples/server/petstore/kotlin/vertx/README.md
Normal file
81
samples/server/petstore/kotlin/vertx/README.md
Normal file
@ -0,0 +1,81 @@
|
|||||||
|
# org.openapitools - Kotlin Server library for OpenAPI Petstore
|
||||||
|
|
||||||
|
## Requires
|
||||||
|
|
||||||
|
* Kotlin 1.3.10
|
||||||
|
* Maven 3.3
|
||||||
|
|
||||||
|
## Build
|
||||||
|
|
||||||
|
```
|
||||||
|
mvn clean package
|
||||||
|
```
|
||||||
|
|
||||||
|
This runs all tests and packages the library.
|
||||||
|
|
||||||
|
## Features/Implementation Notes
|
||||||
|
|
||||||
|
* Supports JSON inputs/outputs and Form inputs.
|
||||||
|
* Supports collection formats for query parameters: csv, tsv, ssv, pipes.
|
||||||
|
* Some Kotlin and Java types are fully qualified to avoid conflicts with types defined in OpenAPI definitions.
|
||||||
|
|
||||||
|
<a name="documentation-for-api-endpoints"></a>
|
||||||
|
## Documentation for API Endpoints
|
||||||
|
|
||||||
|
All URIs are relative to *http://petstore.swagger.io/v2*
|
||||||
|
|
||||||
|
Class | Method | HTTP request | Description
|
||||||
|
------------ | ------------- | ------------- | -------------
|
||||||
|
*PetApi* | [**addPet**](docs/PetApi.md#addpet) | **POST** /pet | Add a new pet to the store
|
||||||
|
*PetApi* | [**deletePet**](docs/PetApi.md#deletepet) | **DELETE** /pet/{petId} | Deletes a pet
|
||||||
|
*PetApi* | [**findPetsByStatus**](docs/PetApi.md#findpetsbystatus) | **GET** /pet/findByStatus | Finds Pets by status
|
||||||
|
*PetApi* | [**findPetsByTags**](docs/PetApi.md#findpetsbytags) | **GET** /pet/findByTags | Finds Pets by tags
|
||||||
|
*PetApi* | [**getPetById**](docs/PetApi.md#getpetbyid) | **GET** /pet/{petId} | Find pet by ID
|
||||||
|
*PetApi* | [**updatePet**](docs/PetApi.md#updatepet) | **PUT** /pet | Update an existing pet
|
||||||
|
*PetApi* | [**updatePetWithForm**](docs/PetApi.md#updatepetwithform) | **POST** /pet/{petId} | Updates a pet in the store with form data
|
||||||
|
*PetApi* | [**uploadFile**](docs/PetApi.md#uploadfile) | **POST** /pet/{petId}/uploadImage | uploads an image
|
||||||
|
*StoreApi* | [**deleteOrder**](docs/StoreApi.md#deleteorder) | **DELETE** /store/order/{orderId} | Delete purchase order by ID
|
||||||
|
*StoreApi* | [**getInventory**](docs/StoreApi.md#getinventory) | **GET** /store/inventory | Returns pet inventories by status
|
||||||
|
*StoreApi* | [**getOrderById**](docs/StoreApi.md#getorderbyid) | **GET** /store/order/{orderId} | Find purchase order by ID
|
||||||
|
*StoreApi* | [**placeOrder**](docs/StoreApi.md#placeorder) | **POST** /store/order | Place an order for a pet
|
||||||
|
*UserApi* | [**createUser**](docs/UserApi.md#createuser) | **POST** /user | Create user
|
||||||
|
*UserApi* | [**createUsersWithArrayInput**](docs/UserApi.md#createuserswitharrayinput) | **POST** /user/createWithArray | Creates list of users with given input array
|
||||||
|
*UserApi* | [**createUsersWithListInput**](docs/UserApi.md#createuserswithlistinput) | **POST** /user/createWithList | Creates list of users with given input array
|
||||||
|
*UserApi* | [**deleteUser**](docs/UserApi.md#deleteuser) | **DELETE** /user/{username} | Delete user
|
||||||
|
*UserApi* | [**getUserByName**](docs/UserApi.md#getuserbyname) | **GET** /user/{username} | Get user by user name
|
||||||
|
*UserApi* | [**loginUser**](docs/UserApi.md#loginuser) | **GET** /user/login | Logs user into the system
|
||||||
|
*UserApi* | [**logoutUser**](docs/UserApi.md#logoutuser) | **GET** /user/logout | Logs out current logged in user session
|
||||||
|
*UserApi* | [**updateUser**](docs/UserApi.md#updateuser) | **PUT** /user/{username} | Updated user
|
||||||
|
|
||||||
|
|
||||||
|
<a name="documentation-for-models"></a>
|
||||||
|
## Documentation for Models
|
||||||
|
|
||||||
|
- [org.openapitools.server.api.model.ApiResponse](docs/ApiResponse.md)
|
||||||
|
- [org.openapitools.server.api.model.Category](docs/Category.md)
|
||||||
|
- [org.openapitools.server.api.model.Order](docs/Order.md)
|
||||||
|
- [org.openapitools.server.api.model.Pet](docs/Pet.md)
|
||||||
|
- [org.openapitools.server.api.model.Tag](docs/Tag.md)
|
||||||
|
- [org.openapitools.server.api.model.User](docs/User.md)
|
||||||
|
|
||||||
|
|
||||||
|
<a name="documentation-for-authorization"></a>
|
||||||
|
## Documentation for Authorization
|
||||||
|
|
||||||
|
<a name="api_key"></a>
|
||||||
|
### api_key
|
||||||
|
|
||||||
|
- **Type**: API key
|
||||||
|
- **API key parameter name**: api_key
|
||||||
|
- **Location**: HTTP header
|
||||||
|
|
||||||
|
<a name="petstore_auth"></a>
|
||||||
|
### petstore_auth
|
||||||
|
|
||||||
|
- **Type**: OAuth
|
||||||
|
- **Flow**: implicit
|
||||||
|
- **Authorization URL**: http://petstore.swagger.io/api/oauth/dialog
|
||||||
|
- **Scopes**:
|
||||||
|
- write:pets: modify pets in your account
|
||||||
|
- read:pets: read your pets
|
||||||
|
|
||||||
190
samples/server/petstore/kotlin/vertx/pom.xml
Normal file
190
samples/server/petstore/kotlin/vertx/pom.xml
Normal file
@ -0,0 +1,190 @@
|
|||||||
|
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||||
|
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
|
||||||
|
<modelVersion>4.0.0</modelVersion>
|
||||||
|
|
||||||
|
<groupId>org.openapitools</groupId>
|
||||||
|
<artifactId>openapi-kotlin-vertx-server</artifactId>
|
||||||
|
<version>1.0.0-SNAPSHOT</version>
|
||||||
|
<packaging>jar</packaging>
|
||||||
|
|
||||||
|
<name>OpenAPI Petstore</name>
|
||||||
|
|
||||||
|
<properties>
|
||||||
|
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||||
|
<java.version>1.8</java.version>
|
||||||
|
<kotlin.version>1.3.10</kotlin.version>
|
||||||
|
<kotlin.compiler.incremental>true</kotlin.compiler.incremental>
|
||||||
|
<junit.version>4.12</junit.version>
|
||||||
|
<vertx.version>3.4.1</vertx.version>
|
||||||
|
<maven-compiler-plugin.version>3.3</maven-compiler-plugin.version>
|
||||||
|
<vertx-openapi-router.version>1.0.2</vertx-openapi-router.version>
|
||||||
|
<maven-shade-plugin.version>2.3</maven-shade-plugin.version>
|
||||||
|
<jackson-datatype-jsr310.version>2.7.4</jackson-datatype-jsr310.version>
|
||||||
|
<vertx.version>3.6.0</vertx.version>
|
||||||
|
</properties>
|
||||||
|
|
||||||
|
<dependencies>
|
||||||
|
<dependency>
|
||||||
|
<groupId>junit</groupId>
|
||||||
|
<artifactId>junit</artifactId>
|
||||||
|
<version>${junit.version}</version>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>io.vertx</groupId>
|
||||||
|
<artifactId>vertx-unit</artifactId>
|
||||||
|
<version>${vertx.version}</version>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>com.github.wooyme</groupId>
|
||||||
|
<artifactId>vertx-openapi-router</artifactId>
|
||||||
|
<version>${vertx-openapi-router.version}</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>com.google.code.gson</groupId>
|
||||||
|
<artifactId>gson</artifactId>
|
||||||
|
<version>2.8.5</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>javax.annotation</groupId>
|
||||||
|
<artifactId>javax.annotation-api</artifactId>
|
||||||
|
<version>1.2</version>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.jetbrains.kotlin</groupId>
|
||||||
|
<artifactId>kotlin-stdlib</artifactId>
|
||||||
|
<version>${kotlin.version}</version>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.jetbrains.kotlinx</groupId>
|
||||||
|
<artifactId>kotlinx-coroutines-core</artifactId>
|
||||||
|
<version>RELEASE</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>io.vertx</groupId>
|
||||||
|
<artifactId>vertx-core</artifactId>
|
||||||
|
<version>${vertx.version}</version>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>io.vertx</groupId>
|
||||||
|
<artifactId>vertx-web</artifactId>
|
||||||
|
<version>${vertx.version}</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>io.vertx</groupId>
|
||||||
|
<artifactId>vertx-lang-kotlin</artifactId>
|
||||||
|
<version>${vertx.version}</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>io.vertx</groupId>
|
||||||
|
<artifactId>vertx-lang-kotlin-coroutines</artifactId>
|
||||||
|
<version>${vertx.version}</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>io.swagger.parser.v3</groupId>
|
||||||
|
<artifactId>swagger-parser</artifactId>
|
||||||
|
<version>2.0.5</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>io.vertx</groupId>
|
||||||
|
<artifactId>vertx-web-api-contract</artifactId>
|
||||||
|
<version>${vertx.version}</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>io.vertx</groupId>
|
||||||
|
<artifactId>vertx-service-proxy</artifactId>
|
||||||
|
<version>${vertx.version}</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>io.vertx</groupId>
|
||||||
|
<artifactId>vertx-web-api-service</artifactId>
|
||||||
|
<version>${vertx.version}</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
</dependencies>
|
||||||
|
|
||||||
|
<build>
|
||||||
|
<plugins>
|
||||||
|
<plugin>
|
||||||
|
<artifactId>kotlin-maven-plugin</artifactId>
|
||||||
|
<groupId>org.jetbrains.kotlin</groupId>
|
||||||
|
<version>${kotlin.version}</version>
|
||||||
|
<executions>
|
||||||
|
<execution>
|
||||||
|
<id>compile</id>
|
||||||
|
<goals>
|
||||||
|
<goal>compile</goal>
|
||||||
|
</goals>
|
||||||
|
<configuration>
|
||||||
|
<sourceDirs>
|
||||||
|
<sourceDir>${project.basedir}/src/main/kotlin</sourceDir>
|
||||||
|
<sourceDir>${project.basedir}/src/main/java</sourceDir>
|
||||||
|
</sourceDirs>
|
||||||
|
<jvmTarget>1.8</jvmTarget>
|
||||||
|
</configuration>
|
||||||
|
</execution>
|
||||||
|
<execution>
|
||||||
|
<id>test-compile</id>
|
||||||
|
<goals>
|
||||||
|
<goal>test-compile</goal>
|
||||||
|
</goals>
|
||||||
|
<configuration>
|
||||||
|
<sourceDirs>
|
||||||
|
<sourceDir>${project.basedir}/src/test/kotlin</sourceDir>
|
||||||
|
<sourceDir>${project.basedir}/src/test/java</sourceDir>
|
||||||
|
</sourceDirs>
|
||||||
|
<jvmTarget>1.8</jvmTarget>
|
||||||
|
</configuration>
|
||||||
|
</execution>
|
||||||
|
</executions>
|
||||||
|
</plugin>
|
||||||
|
|
||||||
|
<plugin>
|
||||||
|
<artifactId>maven-compiler-plugin</artifactId>
|
||||||
|
<version>${maven-compiler-plugin.version}</version>
|
||||||
|
<configuration>
|
||||||
|
<source>${java.version}</source>
|
||||||
|
<target>${java.version}</target>
|
||||||
|
</configuration>
|
||||||
|
</plugin>
|
||||||
|
|
||||||
|
<plugin>
|
||||||
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
|
<artifactId>maven-shade-plugin</artifactId>
|
||||||
|
<version>${maven-shade-plugin.version}</version>
|
||||||
|
<executions>
|
||||||
|
<execution>
|
||||||
|
<phase>package</phase>
|
||||||
|
<goals>
|
||||||
|
<goal>shade</goal>
|
||||||
|
</goals>
|
||||||
|
<configuration>
|
||||||
|
<transformers>
|
||||||
|
<transformer
|
||||||
|
implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
|
||||||
|
<manifestEntries>
|
||||||
|
<Main-Class>org.openapitools.server.api.verticle.DefaultApiVerticleKt</Main-Class>
|
||||||
|
</manifestEntries>
|
||||||
|
</transformer>
|
||||||
|
</transformers>
|
||||||
|
<artifactSet />
|
||||||
|
<outputFile>${project.build.directory}/${project.artifactId}-${project.version}-fat.jar</outputFile>
|
||||||
|
</configuration>
|
||||||
|
</execution>
|
||||||
|
</executions>
|
||||||
|
</plugin>
|
||||||
|
</plugins>
|
||||||
|
</build>
|
||||||
|
</project>
|
||||||
@ -0,0 +1,34 @@
|
|||||||
|
/**
|
||||||
|
* OpenAPI Petstore
|
||||||
|
* This is a sample server Petstore server. For this sample, you can use the api key `special-key` to test the authorization filters.
|
||||||
|
*
|
||||||
|
* The version of the OpenAPI document: 1.0.0
|
||||||
|
*
|
||||||
|
*
|
||||||
|
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
|
||||||
|
* https://openapi-generator.tech
|
||||||
|
* Do not edit the class manually.
|
||||||
|
*/
|
||||||
|
package org.openapitools.server.api.model
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
import com.google.gson.annotations.SerializedName
|
||||||
|
import com.fasterxml.jackson.annotation.JsonIgnoreProperties
|
||||||
|
import com.fasterxml.jackson.annotation.JsonInclude
|
||||||
|
/**
|
||||||
|
* Describes the result of uploading an image resource
|
||||||
|
* @param code
|
||||||
|
* @param type
|
||||||
|
* @param message
|
||||||
|
*/
|
||||||
|
@JsonInclude(JsonInclude.Include.NON_NULL)
|
||||||
|
@JsonIgnoreProperties(ignoreUnknown = true)
|
||||||
|
data class ApiResponse (
|
||||||
|
var code: kotlin.Int? = null,
|
||||||
|
var type: kotlin.String? = null,
|
||||||
|
var message: kotlin.String? = null
|
||||||
|
) {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
@ -0,0 +1,32 @@
|
|||||||
|
/**
|
||||||
|
* OpenAPI Petstore
|
||||||
|
* This is a sample server Petstore server. For this sample, you can use the api key `special-key` to test the authorization filters.
|
||||||
|
*
|
||||||
|
* The version of the OpenAPI document: 1.0.0
|
||||||
|
*
|
||||||
|
*
|
||||||
|
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
|
||||||
|
* https://openapi-generator.tech
|
||||||
|
* Do not edit the class manually.
|
||||||
|
*/
|
||||||
|
package org.openapitools.server.api.model
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
import com.google.gson.annotations.SerializedName
|
||||||
|
import com.fasterxml.jackson.annotation.JsonIgnoreProperties
|
||||||
|
import com.fasterxml.jackson.annotation.JsonInclude
|
||||||
|
/**
|
||||||
|
* A category for a pet
|
||||||
|
* @param id
|
||||||
|
* @param name
|
||||||
|
*/
|
||||||
|
@JsonInclude(JsonInclude.Include.NON_NULL)
|
||||||
|
@JsonIgnoreProperties(ignoreUnknown = true)
|
||||||
|
data class Category (
|
||||||
|
var id: kotlin.Long? = null,
|
||||||
|
var name: kotlin.String? = null
|
||||||
|
) {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
@ -0,0 +1,55 @@
|
|||||||
|
/**
|
||||||
|
* OpenAPI Petstore
|
||||||
|
* This is a sample server Petstore server. For this sample, you can use the api key `special-key` to test the authorization filters.
|
||||||
|
*
|
||||||
|
* The version of the OpenAPI document: 1.0.0
|
||||||
|
*
|
||||||
|
*
|
||||||
|
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
|
||||||
|
* https://openapi-generator.tech
|
||||||
|
* Do not edit the class manually.
|
||||||
|
*/
|
||||||
|
package org.openapitools.server.api.model
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
import com.google.gson.annotations.SerializedName
|
||||||
|
import com.fasterxml.jackson.annotation.JsonIgnoreProperties
|
||||||
|
import com.fasterxml.jackson.annotation.JsonInclude
|
||||||
|
/**
|
||||||
|
* An order for a pets from the pet store
|
||||||
|
* @param id
|
||||||
|
* @param petId
|
||||||
|
* @param quantity
|
||||||
|
* @param shipDate
|
||||||
|
* @param status Order Status
|
||||||
|
* @param complete
|
||||||
|
*/
|
||||||
|
@JsonInclude(JsonInclude.Include.NON_NULL)
|
||||||
|
@JsonIgnoreProperties(ignoreUnknown = true)
|
||||||
|
data class Order (
|
||||||
|
var id: kotlin.Long? = null,
|
||||||
|
var petId: kotlin.Long? = null,
|
||||||
|
var quantity: kotlin.Int? = null,
|
||||||
|
var shipDate: java.time.LocalDateTime? = null,
|
||||||
|
/* Order Status */
|
||||||
|
var status: Order.Status? = null,
|
||||||
|
var complete: kotlin.Boolean? = null
|
||||||
|
) {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Order Status
|
||||||
|
* Values: placed,approved,delivered
|
||||||
|
*/
|
||||||
|
enum class Status(val value: kotlin.String){
|
||||||
|
|
||||||
|
placed("placed"),
|
||||||
|
|
||||||
|
approved("approved"),
|
||||||
|
|
||||||
|
delivered("delivered");
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
@ -0,0 +1,61 @@
|
|||||||
|
/**
|
||||||
|
* OpenAPI Petstore
|
||||||
|
* This is a sample server Petstore server. For this sample, you can use the api key `special-key` to test the authorization filters.
|
||||||
|
*
|
||||||
|
* The version of the OpenAPI document: 1.0.0
|
||||||
|
*
|
||||||
|
*
|
||||||
|
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
|
||||||
|
* https://openapi-generator.tech
|
||||||
|
* Do not edit the class manually.
|
||||||
|
*/
|
||||||
|
package org.openapitools.server.api.model
|
||||||
|
|
||||||
|
import org.openapitools.server.api.model.Category
|
||||||
|
import org.openapitools.server.api.model.Tag
|
||||||
|
|
||||||
|
|
||||||
|
import com.google.gson.annotations.SerializedName
|
||||||
|
import com.fasterxml.jackson.annotation.JsonIgnoreProperties
|
||||||
|
import com.fasterxml.jackson.annotation.JsonInclude
|
||||||
|
/**
|
||||||
|
* A pet for sale in the pet store
|
||||||
|
* @param id
|
||||||
|
* @param category
|
||||||
|
* @param name
|
||||||
|
* @param photoUrls
|
||||||
|
* @param tags
|
||||||
|
* @param status pet status in the store
|
||||||
|
*/
|
||||||
|
@JsonInclude(JsonInclude.Include.NON_NULL)
|
||||||
|
@JsonIgnoreProperties(ignoreUnknown = true)
|
||||||
|
data class Pet (
|
||||||
|
@SerializedName("name") private var _name: kotlin.String?,
|
||||||
|
@SerializedName("photoUrls") private var _photoUrls: kotlin.Array<kotlin.String>?,
|
||||||
|
var id: kotlin.Long? = null,
|
||||||
|
var category: Category? = null,
|
||||||
|
var tags: kotlin.Array<Tag>? = null,
|
||||||
|
/* pet status in the store */
|
||||||
|
var status: Pet.Status? = null
|
||||||
|
) {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* pet status in the store
|
||||||
|
* Values: available,pending,sold
|
||||||
|
*/
|
||||||
|
enum class Status(val value: kotlin.String){
|
||||||
|
|
||||||
|
available("available"),
|
||||||
|
|
||||||
|
pending("pending"),
|
||||||
|
|
||||||
|
sold("sold");
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
var name get() = _name ?: throw IllegalArgumentException("name is required")
|
||||||
|
set(value){ _name = value }
|
||||||
|
var photoUrls get() = _photoUrls ?: throw IllegalArgumentException("photoUrls is required")
|
||||||
|
set(value){ _photoUrls = value }
|
||||||
|
}
|
||||||
|
|
||||||
@ -0,0 +1,32 @@
|
|||||||
|
/**
|
||||||
|
* OpenAPI Petstore
|
||||||
|
* This is a sample server Petstore server. For this sample, you can use the api key `special-key` to test the authorization filters.
|
||||||
|
*
|
||||||
|
* The version of the OpenAPI document: 1.0.0
|
||||||
|
*
|
||||||
|
*
|
||||||
|
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
|
||||||
|
* https://openapi-generator.tech
|
||||||
|
* Do not edit the class manually.
|
||||||
|
*/
|
||||||
|
package org.openapitools.server.api.model
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
import com.google.gson.annotations.SerializedName
|
||||||
|
import com.fasterxml.jackson.annotation.JsonIgnoreProperties
|
||||||
|
import com.fasterxml.jackson.annotation.JsonInclude
|
||||||
|
/**
|
||||||
|
* A tag for a pet
|
||||||
|
* @param id
|
||||||
|
* @param name
|
||||||
|
*/
|
||||||
|
@JsonInclude(JsonInclude.Include.NON_NULL)
|
||||||
|
@JsonIgnoreProperties(ignoreUnknown = true)
|
||||||
|
data class Tag (
|
||||||
|
var id: kotlin.Long? = null,
|
||||||
|
var name: kotlin.String? = null
|
||||||
|
) {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
@ -0,0 +1,45 @@
|
|||||||
|
/**
|
||||||
|
* OpenAPI Petstore
|
||||||
|
* This is a sample server Petstore server. For this sample, you can use the api key `special-key` to test the authorization filters.
|
||||||
|
*
|
||||||
|
* The version of the OpenAPI document: 1.0.0
|
||||||
|
*
|
||||||
|
*
|
||||||
|
* NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
|
||||||
|
* https://openapi-generator.tech
|
||||||
|
* Do not edit the class manually.
|
||||||
|
*/
|
||||||
|
package org.openapitools.server.api.model
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
import com.google.gson.annotations.SerializedName
|
||||||
|
import com.fasterxml.jackson.annotation.JsonIgnoreProperties
|
||||||
|
import com.fasterxml.jackson.annotation.JsonInclude
|
||||||
|
/**
|
||||||
|
* A User who is purchasing from the pet store
|
||||||
|
* @param id
|
||||||
|
* @param username
|
||||||
|
* @param firstName
|
||||||
|
* @param lastName
|
||||||
|
* @param email
|
||||||
|
* @param password
|
||||||
|
* @param phone
|
||||||
|
* @param userStatus User Status
|
||||||
|
*/
|
||||||
|
@JsonInclude(JsonInclude.Include.NON_NULL)
|
||||||
|
@JsonIgnoreProperties(ignoreUnknown = true)
|
||||||
|
data class User (
|
||||||
|
var id: kotlin.Long? = null,
|
||||||
|
var username: kotlin.String? = null,
|
||||||
|
var firstName: kotlin.String? = null,
|
||||||
|
var lastName: kotlin.String? = null,
|
||||||
|
var email: kotlin.String? = null,
|
||||||
|
var password: kotlin.String? = null,
|
||||||
|
var phone: kotlin.String? = null,
|
||||||
|
/* User Status */
|
||||||
|
var userStatus: kotlin.Int? = null
|
||||||
|
) {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
@ -0,0 +1,70 @@
|
|||||||
|
package org.openapitools.server.api.verticle
|
||||||
|
|
||||||
|
import org.openapitools.server.api.model.ApiResponse
|
||||||
|
import org.openapitools.server.api.model.Pet
|
||||||
|
import io.vertx.core.Vertx
|
||||||
|
import io.vertx.core.json.JsonObject
|
||||||
|
import io.vertx.core.json.JsonArray
|
||||||
|
import com.github.wooyme.openapi.Response
|
||||||
|
import io.vertx.ext.web.api.OperationRequest
|
||||||
|
import io.vertx.kotlin.ext.web.api.contract.openapi3.OpenAPI3RouterFactory
|
||||||
|
import io.vertx.serviceproxy.ServiceBinder
|
||||||
|
import io.vertx.ext.web.handler.CookieHandler
|
||||||
|
import io.vertx.ext.web.handler.SessionHandler
|
||||||
|
import io.vertx.ext.web.sstore.LocalSessionStore
|
||||||
|
import java.util.List
|
||||||
|
import java.util.Map
|
||||||
|
|
||||||
|
|
||||||
|
interface PetApi {
|
||||||
|
fun init(vertx:Vertx,config:JsonObject)
|
||||||
|
/* addPet
|
||||||
|
* Add a new pet to the store */
|
||||||
|
suspend fun addPet(body:Pet?,context:OperationRequest):Response<Void>
|
||||||
|
/* deletePet
|
||||||
|
* Deletes a pet */
|
||||||
|
suspend fun deletePet(petId:kotlin.Long?,apiKey:kotlin.String?,context:OperationRequest):Response<Void>
|
||||||
|
/* findPetsByStatus
|
||||||
|
* Finds Pets by status */
|
||||||
|
suspend fun findPetsByStatus(status:kotlin.Array<kotlin.String>?,context:OperationRequest):Response<kotlin.Array<Pet>>
|
||||||
|
/* findPetsByTags
|
||||||
|
* Finds Pets by tags */
|
||||||
|
suspend fun findPetsByTags(tags:kotlin.Array<kotlin.String>?,context:OperationRequest):Response<kotlin.Array<Pet>>
|
||||||
|
/* getPetById
|
||||||
|
* Find pet by ID */
|
||||||
|
suspend fun getPetById(petId:kotlin.Long?,context:OperationRequest):Response<Pet>
|
||||||
|
/* updatePet
|
||||||
|
* Update an existing pet */
|
||||||
|
suspend fun updatePet(body:Pet?,context:OperationRequest):Response<Void>
|
||||||
|
/* updatePetWithForm
|
||||||
|
* Updates a pet in the store with form data */
|
||||||
|
suspend fun updatePetWithForm(petId:kotlin.Long?,name:kotlin.String?,status:kotlin.String?,context:OperationRequest):Response<Void>
|
||||||
|
/* uploadFile
|
||||||
|
* uploads an image */
|
||||||
|
suspend fun uploadFile(petId:kotlin.Long?,additionalMetadata:kotlin.String?,file:kotlin.collections.List<java.io.File>?,context:OperationRequest):Response<ApiResponse>
|
||||||
|
companion object {
|
||||||
|
const val address = "PetApi-service"
|
||||||
|
suspend fun createRouterFactory(vertx: Vertx,path:String): io.vertx.ext.web.api.contract.openapi3.OpenAPI3RouterFactory {
|
||||||
|
val routerFactory = OpenAPI3RouterFactory.createAwait(vertx,path)
|
||||||
|
routerFactory.addGlobalHandler(CookieHandler.create())
|
||||||
|
routerFactory.addGlobalHandler(SessionHandler.create(LocalSessionStore.create(vertx)))
|
||||||
|
routerFactory.setExtraOperationContextPayloadMapper{
|
||||||
|
JsonObject().put("files",JsonArray(it.fileUploads().map { it.uploadedFileName() }))
|
||||||
|
}
|
||||||
|
val opf = routerFactory::class.java.getDeclaredField("operations")
|
||||||
|
opf.isAccessible = true
|
||||||
|
val operations = opf.get(routerFactory) as Map<String, Any>
|
||||||
|
for (m in PetApi::class.java.methods) {
|
||||||
|
val methodName = m.name
|
||||||
|
val op = operations[methodName]
|
||||||
|
if (op != null) {
|
||||||
|
val method = op::class.java.getDeclaredMethod("mountRouteToService",String::class.java,String::class.java)
|
||||||
|
method.isAccessible = true
|
||||||
|
method.invoke(op,address,methodName)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
routerFactory.mountServiceInterface(PetApi::class.java, address)
|
||||||
|
return routerFactory
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,19 @@
|
|||||||
|
package org.openapitools.server.api.verticle
|
||||||
|
import io.vertx.core.Vertx
|
||||||
|
import io.vertx.core.AbstractVerticle
|
||||||
|
import io.vertx.serviceproxy.ServiceBinder
|
||||||
|
|
||||||
|
fun main(){
|
||||||
|
Vertx.vertx().deployVerticle(PetApiVerticle())
|
||||||
|
}
|
||||||
|
|
||||||
|
class PetApiVerticle:AbstractVerticle() {
|
||||||
|
|
||||||
|
override fun start() {
|
||||||
|
val instance = (javaClass.classLoader.loadClass("org.openapitools.server.api.verticle.PetApiImpl").newInstance() as PetApi)
|
||||||
|
instance.init(vertx,config())
|
||||||
|
ServiceBinder(vertx)
|
||||||
|
.setAddress(PetApi.address)
|
||||||
|
.register(PetApi::class.java,instance)
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,214 @@
|
|||||||
|
package org.openapitools.server.api.verticle
|
||||||
|
|
||||||
|
import io.vertx.core.Vertx
|
||||||
|
import io.vertx.core.eventbus.Message
|
||||||
|
import io.vertx.core.json.JsonObject
|
||||||
|
import io.vertx.ext.web.api.OperationRequest
|
||||||
|
import io.vertx.ext.web.api.OperationResponse
|
||||||
|
import io.vertx.ext.web.api.generator.ApiHandlerUtils
|
||||||
|
import io.vertx.serviceproxy.ProxyHandler
|
||||||
|
import io.vertx.serviceproxy.ServiceException
|
||||||
|
import io.vertx.serviceproxy.ServiceExceptionMessageCodec
|
||||||
|
import kotlinx.coroutines.GlobalScope
|
||||||
|
import kotlinx.coroutines.launch
|
||||||
|
import io.vertx.kotlin.coroutines.dispatcher
|
||||||
|
import io.vertx.core.json.Json
|
||||||
|
import io.vertx.core.json.JsonArray
|
||||||
|
import com.google.gson.reflect.TypeToken
|
||||||
|
import com.google.gson.Gson
|
||||||
|
import org.openapitools.server.api.model.ApiResponse
|
||||||
|
import org.openapitools.server.api.model.Pet
|
||||||
|
|
||||||
|
class PetApiVertxProxyHandler(private val vertx: Vertx, private val service: PetApi, topLevel: Boolean, private val timeoutSeconds: Long) : ProxyHandler() {
|
||||||
|
private val timerID: Long
|
||||||
|
private var lastAccessed: Long = 0
|
||||||
|
init {
|
||||||
|
try {
|
||||||
|
this.vertx.eventBus().registerDefaultCodec(ServiceException::class.java,
|
||||||
|
ServiceExceptionMessageCodec())
|
||||||
|
} catch (ex: IllegalStateException) {}
|
||||||
|
|
||||||
|
if (timeoutSeconds != (-1).toLong() && !topLevel) {
|
||||||
|
var period = timeoutSeconds * 1000 / 2
|
||||||
|
if (period > 10000) {
|
||||||
|
period = 10000
|
||||||
|
}
|
||||||
|
this.timerID = vertx.setPeriodic(period) { this.checkTimedOut(it) }
|
||||||
|
} else {
|
||||||
|
this.timerID = -1
|
||||||
|
}
|
||||||
|
accessed()
|
||||||
|
}
|
||||||
|
private fun checkTimedOut(id: Long) {
|
||||||
|
val now = System.nanoTime()
|
||||||
|
if (now - lastAccessed > timeoutSeconds * 1000000000) {
|
||||||
|
close()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
override fun close() {
|
||||||
|
if (timerID != (-1).toLong()) {
|
||||||
|
vertx.cancelTimer(timerID)
|
||||||
|
}
|
||||||
|
super.close()
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun accessed() {
|
||||||
|
this.lastAccessed = System.nanoTime()
|
||||||
|
}
|
||||||
|
override fun handle(msg: Message<JsonObject>) {
|
||||||
|
try {
|
||||||
|
val json = msg.body()
|
||||||
|
val action = msg.headers().get("action") ?: throw IllegalStateException("action not specified")
|
||||||
|
accessed()
|
||||||
|
val contextSerialized = json.getJsonObject("context") ?: throw IllegalStateException("Received action $action without OperationRequest \"context\"")
|
||||||
|
val context = OperationRequest(contextSerialized)
|
||||||
|
when (action) {
|
||||||
|
|
||||||
|
"addPet" -> {
|
||||||
|
val params = context.params
|
||||||
|
val bodyParam = ApiHandlerUtils.searchJsonObjectInJson(params,"body")
|
||||||
|
if (bodyParam == null) {
|
||||||
|
throw IllegalArgumentException("body is required")
|
||||||
|
}
|
||||||
|
val body = Gson().fromJson(bodyParam.encode(), Pet::class.java)
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.addPet(body,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"deletePet" -> {
|
||||||
|
val params = context.params
|
||||||
|
val petId = ApiHandlerUtils.searchLongInJson(params,"petId")
|
||||||
|
if(petId == null){
|
||||||
|
throw IllegalArgumentException("petId is required")
|
||||||
|
}
|
||||||
|
val apiKey = ApiHandlerUtils.searchStringInJson(params,"api_key")
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.deletePet(petId,apiKey,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"findPetsByStatus" -> {
|
||||||
|
val params = context.params
|
||||||
|
val statusParam = ApiHandlerUtils.searchJsonArrayInJson(params,"status")
|
||||||
|
if(statusParam == null){
|
||||||
|
throw IllegalArgumentException("status is required")
|
||||||
|
}
|
||||||
|
val status:kotlin.Array<kotlin.String> = Gson().fromJson(statusParam.encode()
|
||||||
|
, object : TypeToken<kotlin.collections.List<kotlin.String>>(){}.type)
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.findPetsByStatus(status,context)
|
||||||
|
val payload = JsonArray(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"findPetsByTags" -> {
|
||||||
|
val params = context.params
|
||||||
|
val tagsParam = ApiHandlerUtils.searchJsonArrayInJson(params,"tags")
|
||||||
|
if(tagsParam == null){
|
||||||
|
throw IllegalArgumentException("tags is required")
|
||||||
|
}
|
||||||
|
val tags:kotlin.Array<kotlin.String> = Gson().fromJson(tagsParam.encode()
|
||||||
|
, object : TypeToken<kotlin.collections.List<kotlin.String>>(){}.type)
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.findPetsByTags(tags,context)
|
||||||
|
val payload = JsonArray(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"getPetById" -> {
|
||||||
|
val params = context.params
|
||||||
|
val petId = ApiHandlerUtils.searchLongInJson(params,"petId")
|
||||||
|
if(petId == null){
|
||||||
|
throw IllegalArgumentException("petId is required")
|
||||||
|
}
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.getPetById(petId,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"updatePet" -> {
|
||||||
|
val params = context.params
|
||||||
|
val bodyParam = ApiHandlerUtils.searchJsonObjectInJson(params,"body")
|
||||||
|
if (bodyParam == null) {
|
||||||
|
throw IllegalArgumentException("body is required")
|
||||||
|
}
|
||||||
|
val body = Gson().fromJson(bodyParam.encode(), Pet::class.java)
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.updatePet(body,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"updatePetWithForm" -> {
|
||||||
|
val params = context.params
|
||||||
|
val petId = ApiHandlerUtils.searchLongInJson(params,"petId")
|
||||||
|
if(petId == null){
|
||||||
|
throw IllegalArgumentException("petId is required")
|
||||||
|
}
|
||||||
|
val name = ApiHandlerUtils.searchStringInJson(params,"name")
|
||||||
|
val status = ApiHandlerUtils.searchStringInJson(params,"status")
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.updatePetWithForm(petId,name,status,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"uploadFile" -> {
|
||||||
|
val params = context.params
|
||||||
|
val petId = ApiHandlerUtils.searchLongInJson(params,"petId")
|
||||||
|
if(petId == null){
|
||||||
|
throw IllegalArgumentException("petId is required")
|
||||||
|
}
|
||||||
|
val additionalMetadata = ApiHandlerUtils.searchStringInJson(params,"additionalMetadata")
|
||||||
|
val fileParam = context.extra.getJsonArray("files")
|
||||||
|
val file = fileParam?.map{ java.io.File(it as String) }
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.uploadFile(petId,additionalMetadata,file,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}catch (t: Throwable) {
|
||||||
|
msg.reply(ServiceException(500, t.message))
|
||||||
|
throw t
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,57 @@
|
|||||||
|
package org.openapitools.server.api.verticle
|
||||||
|
|
||||||
|
import org.openapitools.server.api.model.Order
|
||||||
|
import io.vertx.core.Vertx
|
||||||
|
import io.vertx.core.json.JsonObject
|
||||||
|
import io.vertx.core.json.JsonArray
|
||||||
|
import com.github.wooyme.openapi.Response
|
||||||
|
import io.vertx.ext.web.api.OperationRequest
|
||||||
|
import io.vertx.kotlin.ext.web.api.contract.openapi3.OpenAPI3RouterFactory
|
||||||
|
import io.vertx.serviceproxy.ServiceBinder
|
||||||
|
import io.vertx.ext.web.handler.CookieHandler
|
||||||
|
import io.vertx.ext.web.handler.SessionHandler
|
||||||
|
import io.vertx.ext.web.sstore.LocalSessionStore
|
||||||
|
import java.util.List
|
||||||
|
import java.util.Map
|
||||||
|
|
||||||
|
|
||||||
|
interface StoreApi {
|
||||||
|
fun init(vertx:Vertx,config:JsonObject)
|
||||||
|
/* deleteOrder
|
||||||
|
* Delete purchase order by ID */
|
||||||
|
suspend fun deleteOrder(orderId:kotlin.String?,context:OperationRequest):Response<Void>
|
||||||
|
/* getInventory
|
||||||
|
* Returns pet inventories by status */
|
||||||
|
suspend fun getInventory(context:OperationRequest):Response<kotlin.collections.Map<kotlin.String, kotlin.Int>>
|
||||||
|
/* getOrderById
|
||||||
|
* Find purchase order by ID */
|
||||||
|
suspend fun getOrderById(orderId:kotlin.Long?,context:OperationRequest):Response<Order>
|
||||||
|
/* placeOrder
|
||||||
|
* Place an order for a pet */
|
||||||
|
suspend fun placeOrder(body:Order?,context:OperationRequest):Response<Order>
|
||||||
|
companion object {
|
||||||
|
const val address = "StoreApi-service"
|
||||||
|
suspend fun createRouterFactory(vertx: Vertx,path:String): io.vertx.ext.web.api.contract.openapi3.OpenAPI3RouterFactory {
|
||||||
|
val routerFactory = OpenAPI3RouterFactory.createAwait(vertx,path)
|
||||||
|
routerFactory.addGlobalHandler(CookieHandler.create())
|
||||||
|
routerFactory.addGlobalHandler(SessionHandler.create(LocalSessionStore.create(vertx)))
|
||||||
|
routerFactory.setExtraOperationContextPayloadMapper{
|
||||||
|
JsonObject().put("files",JsonArray(it.fileUploads().map { it.uploadedFileName() }))
|
||||||
|
}
|
||||||
|
val opf = routerFactory::class.java.getDeclaredField("operations")
|
||||||
|
opf.isAccessible = true
|
||||||
|
val operations = opf.get(routerFactory) as Map<String, Any>
|
||||||
|
for (m in StoreApi::class.java.methods) {
|
||||||
|
val methodName = m.name
|
||||||
|
val op = operations[methodName]
|
||||||
|
if (op != null) {
|
||||||
|
val method = op::class.java.getDeclaredMethod("mountRouteToService",String::class.java,String::class.java)
|
||||||
|
method.isAccessible = true
|
||||||
|
method.invoke(op,address,methodName)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
routerFactory.mountServiceInterface(StoreApi::class.java, address)
|
||||||
|
return routerFactory
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,19 @@
|
|||||||
|
package org.openapitools.server.api.verticle
|
||||||
|
import io.vertx.core.Vertx
|
||||||
|
import io.vertx.core.AbstractVerticle
|
||||||
|
import io.vertx.serviceproxy.ServiceBinder
|
||||||
|
|
||||||
|
fun main(){
|
||||||
|
Vertx.vertx().deployVerticle(StoreApiVerticle())
|
||||||
|
}
|
||||||
|
|
||||||
|
class StoreApiVerticle:AbstractVerticle() {
|
||||||
|
|
||||||
|
override fun start() {
|
||||||
|
val instance = (javaClass.classLoader.loadClass("org.openapitools.server.api.verticle.StoreApiImpl").newInstance() as StoreApi)
|
||||||
|
instance.init(vertx,config())
|
||||||
|
ServiceBinder(vertx)
|
||||||
|
.setAddress(StoreApi.address)
|
||||||
|
.register(StoreApi::class.java,instance)
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,125 @@
|
|||||||
|
package org.openapitools.server.api.verticle
|
||||||
|
|
||||||
|
import io.vertx.core.Vertx
|
||||||
|
import io.vertx.core.eventbus.Message
|
||||||
|
import io.vertx.core.json.JsonObject
|
||||||
|
import io.vertx.ext.web.api.OperationRequest
|
||||||
|
import io.vertx.ext.web.api.OperationResponse
|
||||||
|
import io.vertx.ext.web.api.generator.ApiHandlerUtils
|
||||||
|
import io.vertx.serviceproxy.ProxyHandler
|
||||||
|
import io.vertx.serviceproxy.ServiceException
|
||||||
|
import io.vertx.serviceproxy.ServiceExceptionMessageCodec
|
||||||
|
import kotlinx.coroutines.GlobalScope
|
||||||
|
import kotlinx.coroutines.launch
|
||||||
|
import io.vertx.kotlin.coroutines.dispatcher
|
||||||
|
import io.vertx.core.json.Json
|
||||||
|
import io.vertx.core.json.JsonArray
|
||||||
|
import com.google.gson.reflect.TypeToken
|
||||||
|
import com.google.gson.Gson
|
||||||
|
import org.openapitools.server.api.model.Order
|
||||||
|
|
||||||
|
class StoreApiVertxProxyHandler(private val vertx: Vertx, private val service: StoreApi, topLevel: Boolean, private val timeoutSeconds: Long) : ProxyHandler() {
|
||||||
|
private val timerID: Long
|
||||||
|
private var lastAccessed: Long = 0
|
||||||
|
init {
|
||||||
|
try {
|
||||||
|
this.vertx.eventBus().registerDefaultCodec(ServiceException::class.java,
|
||||||
|
ServiceExceptionMessageCodec())
|
||||||
|
} catch (ex: IllegalStateException) {}
|
||||||
|
|
||||||
|
if (timeoutSeconds != (-1).toLong() && !topLevel) {
|
||||||
|
var period = timeoutSeconds * 1000 / 2
|
||||||
|
if (period > 10000) {
|
||||||
|
period = 10000
|
||||||
|
}
|
||||||
|
this.timerID = vertx.setPeriodic(period) { this.checkTimedOut(it) }
|
||||||
|
} else {
|
||||||
|
this.timerID = -1
|
||||||
|
}
|
||||||
|
accessed()
|
||||||
|
}
|
||||||
|
private fun checkTimedOut(id: Long) {
|
||||||
|
val now = System.nanoTime()
|
||||||
|
if (now - lastAccessed > timeoutSeconds * 1000000000) {
|
||||||
|
close()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
override fun close() {
|
||||||
|
if (timerID != (-1).toLong()) {
|
||||||
|
vertx.cancelTimer(timerID)
|
||||||
|
}
|
||||||
|
super.close()
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun accessed() {
|
||||||
|
this.lastAccessed = System.nanoTime()
|
||||||
|
}
|
||||||
|
override fun handle(msg: Message<JsonObject>) {
|
||||||
|
try {
|
||||||
|
val json = msg.body()
|
||||||
|
val action = msg.headers().get("action") ?: throw IllegalStateException("action not specified")
|
||||||
|
accessed()
|
||||||
|
val contextSerialized = json.getJsonObject("context") ?: throw IllegalStateException("Received action $action without OperationRequest \"context\"")
|
||||||
|
val context = OperationRequest(contextSerialized)
|
||||||
|
when (action) {
|
||||||
|
|
||||||
|
"deleteOrder" -> {
|
||||||
|
val params = context.params
|
||||||
|
val orderId = ApiHandlerUtils.searchStringInJson(params,"orderId")
|
||||||
|
if(orderId == null){
|
||||||
|
throw IllegalArgumentException("orderId is required")
|
||||||
|
}
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.deleteOrder(orderId,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"getInventory" -> {
|
||||||
|
}
|
||||||
|
|
||||||
|
"getOrderById" -> {
|
||||||
|
val params = context.params
|
||||||
|
val orderId = ApiHandlerUtils.searchLongInJson(params,"orderId")
|
||||||
|
if(orderId == null){
|
||||||
|
throw IllegalArgumentException("orderId is required")
|
||||||
|
}
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.getOrderById(orderId,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"placeOrder" -> {
|
||||||
|
val params = context.params
|
||||||
|
val bodyParam = ApiHandlerUtils.searchJsonObjectInJson(params,"body")
|
||||||
|
if (bodyParam == null) {
|
||||||
|
throw IllegalArgumentException("body is required")
|
||||||
|
}
|
||||||
|
val body = Gson().fromJson(bodyParam.encode(), Order::class.java)
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.placeOrder(body,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}catch (t: Throwable) {
|
||||||
|
msg.reply(ServiceException(500, t.message))
|
||||||
|
throw t
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,69 @@
|
|||||||
|
package org.openapitools.server.api.verticle
|
||||||
|
|
||||||
|
import org.openapitools.server.api.model.User
|
||||||
|
import io.vertx.core.Vertx
|
||||||
|
import io.vertx.core.json.JsonObject
|
||||||
|
import io.vertx.core.json.JsonArray
|
||||||
|
import com.github.wooyme.openapi.Response
|
||||||
|
import io.vertx.ext.web.api.OperationRequest
|
||||||
|
import io.vertx.kotlin.ext.web.api.contract.openapi3.OpenAPI3RouterFactory
|
||||||
|
import io.vertx.serviceproxy.ServiceBinder
|
||||||
|
import io.vertx.ext.web.handler.CookieHandler
|
||||||
|
import io.vertx.ext.web.handler.SessionHandler
|
||||||
|
import io.vertx.ext.web.sstore.LocalSessionStore
|
||||||
|
import java.util.List
|
||||||
|
import java.util.Map
|
||||||
|
|
||||||
|
|
||||||
|
interface UserApi {
|
||||||
|
fun init(vertx:Vertx,config:JsonObject)
|
||||||
|
/* createUser
|
||||||
|
* Create user */
|
||||||
|
suspend fun createUser(body:User?,context:OperationRequest):Response<Void>
|
||||||
|
/* createUsersWithArrayInput
|
||||||
|
* Creates list of users with given input array */
|
||||||
|
suspend fun createUsersWithArrayInput(body:kotlin.Array<User>?,context:OperationRequest):Response<Void>
|
||||||
|
/* createUsersWithListInput
|
||||||
|
* Creates list of users with given input array */
|
||||||
|
suspend fun createUsersWithListInput(body:kotlin.Array<User>?,context:OperationRequest):Response<Void>
|
||||||
|
/* deleteUser
|
||||||
|
* Delete user */
|
||||||
|
suspend fun deleteUser(username:kotlin.String?,context:OperationRequest):Response<Void>
|
||||||
|
/* getUserByName
|
||||||
|
* Get user by user name */
|
||||||
|
suspend fun getUserByName(username:kotlin.String?,context:OperationRequest):Response<User>
|
||||||
|
/* loginUser
|
||||||
|
* Logs user into the system */
|
||||||
|
suspend fun loginUser(username:kotlin.String?,password:kotlin.String?,context:OperationRequest):Response<kotlin.String>
|
||||||
|
/* logoutUser
|
||||||
|
* Logs out current logged in user session */
|
||||||
|
suspend fun logoutUser(context:OperationRequest):Response<Void>
|
||||||
|
/* updateUser
|
||||||
|
* Updated user */
|
||||||
|
suspend fun updateUser(username:kotlin.String?,body:User?,context:OperationRequest):Response<Void>
|
||||||
|
companion object {
|
||||||
|
const val address = "UserApi-service"
|
||||||
|
suspend fun createRouterFactory(vertx: Vertx,path:String): io.vertx.ext.web.api.contract.openapi3.OpenAPI3RouterFactory {
|
||||||
|
val routerFactory = OpenAPI3RouterFactory.createAwait(vertx,path)
|
||||||
|
routerFactory.addGlobalHandler(CookieHandler.create())
|
||||||
|
routerFactory.addGlobalHandler(SessionHandler.create(LocalSessionStore.create(vertx)))
|
||||||
|
routerFactory.setExtraOperationContextPayloadMapper{
|
||||||
|
JsonObject().put("files",JsonArray(it.fileUploads().map { it.uploadedFileName() }))
|
||||||
|
}
|
||||||
|
val opf = routerFactory::class.java.getDeclaredField("operations")
|
||||||
|
opf.isAccessible = true
|
||||||
|
val operations = opf.get(routerFactory) as Map<String, Any>
|
||||||
|
for (m in UserApi::class.java.methods) {
|
||||||
|
val methodName = m.name
|
||||||
|
val op = operations[methodName]
|
||||||
|
if (op != null) {
|
||||||
|
val method = op::class.java.getDeclaredMethod("mountRouteToService",String::class.java,String::class.java)
|
||||||
|
method.isAccessible = true
|
||||||
|
method.invoke(op,address,methodName)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
routerFactory.mountServiceInterface(UserApi::class.java, address)
|
||||||
|
return routerFactory
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,19 @@
|
|||||||
|
package org.openapitools.server.api.verticle
|
||||||
|
import io.vertx.core.Vertx
|
||||||
|
import io.vertx.core.AbstractVerticle
|
||||||
|
import io.vertx.serviceproxy.ServiceBinder
|
||||||
|
|
||||||
|
fun main(){
|
||||||
|
Vertx.vertx().deployVerticle(UserApiVerticle())
|
||||||
|
}
|
||||||
|
|
||||||
|
class UserApiVerticle:AbstractVerticle() {
|
||||||
|
|
||||||
|
override fun start() {
|
||||||
|
val instance = (javaClass.classLoader.loadClass("org.openapitools.server.api.verticle.UserApiImpl").newInstance() as UserApi)
|
||||||
|
instance.init(vertx,config())
|
||||||
|
ServiceBinder(vertx)
|
||||||
|
.setAddress(UserApi.address)
|
||||||
|
.register(UserApi::class.java,instance)
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,202 @@
|
|||||||
|
package org.openapitools.server.api.verticle
|
||||||
|
|
||||||
|
import io.vertx.core.Vertx
|
||||||
|
import io.vertx.core.eventbus.Message
|
||||||
|
import io.vertx.core.json.JsonObject
|
||||||
|
import io.vertx.ext.web.api.OperationRequest
|
||||||
|
import io.vertx.ext.web.api.OperationResponse
|
||||||
|
import io.vertx.ext.web.api.generator.ApiHandlerUtils
|
||||||
|
import io.vertx.serviceproxy.ProxyHandler
|
||||||
|
import io.vertx.serviceproxy.ServiceException
|
||||||
|
import io.vertx.serviceproxy.ServiceExceptionMessageCodec
|
||||||
|
import kotlinx.coroutines.GlobalScope
|
||||||
|
import kotlinx.coroutines.launch
|
||||||
|
import io.vertx.kotlin.coroutines.dispatcher
|
||||||
|
import io.vertx.core.json.Json
|
||||||
|
import io.vertx.core.json.JsonArray
|
||||||
|
import com.google.gson.reflect.TypeToken
|
||||||
|
import com.google.gson.Gson
|
||||||
|
import org.openapitools.server.api.model.User
|
||||||
|
|
||||||
|
class UserApiVertxProxyHandler(private val vertx: Vertx, private val service: UserApi, topLevel: Boolean, private val timeoutSeconds: Long) : ProxyHandler() {
|
||||||
|
private val timerID: Long
|
||||||
|
private var lastAccessed: Long = 0
|
||||||
|
init {
|
||||||
|
try {
|
||||||
|
this.vertx.eventBus().registerDefaultCodec(ServiceException::class.java,
|
||||||
|
ServiceExceptionMessageCodec())
|
||||||
|
} catch (ex: IllegalStateException) {}
|
||||||
|
|
||||||
|
if (timeoutSeconds != (-1).toLong() && !topLevel) {
|
||||||
|
var period = timeoutSeconds * 1000 / 2
|
||||||
|
if (period > 10000) {
|
||||||
|
period = 10000
|
||||||
|
}
|
||||||
|
this.timerID = vertx.setPeriodic(period) { this.checkTimedOut(it) }
|
||||||
|
} else {
|
||||||
|
this.timerID = -1
|
||||||
|
}
|
||||||
|
accessed()
|
||||||
|
}
|
||||||
|
private fun checkTimedOut(id: Long) {
|
||||||
|
val now = System.nanoTime()
|
||||||
|
if (now - lastAccessed > timeoutSeconds * 1000000000) {
|
||||||
|
close()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
override fun close() {
|
||||||
|
if (timerID != (-1).toLong()) {
|
||||||
|
vertx.cancelTimer(timerID)
|
||||||
|
}
|
||||||
|
super.close()
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun accessed() {
|
||||||
|
this.lastAccessed = System.nanoTime()
|
||||||
|
}
|
||||||
|
override fun handle(msg: Message<JsonObject>) {
|
||||||
|
try {
|
||||||
|
val json = msg.body()
|
||||||
|
val action = msg.headers().get("action") ?: throw IllegalStateException("action not specified")
|
||||||
|
accessed()
|
||||||
|
val contextSerialized = json.getJsonObject("context") ?: throw IllegalStateException("Received action $action without OperationRequest \"context\"")
|
||||||
|
val context = OperationRequest(contextSerialized)
|
||||||
|
when (action) {
|
||||||
|
|
||||||
|
"createUser" -> {
|
||||||
|
val params = context.params
|
||||||
|
val bodyParam = ApiHandlerUtils.searchJsonObjectInJson(params,"body")
|
||||||
|
if (bodyParam == null) {
|
||||||
|
throw IllegalArgumentException("body is required")
|
||||||
|
}
|
||||||
|
val body = Gson().fromJson(bodyParam.encode(), User::class.java)
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.createUser(body,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"createUsersWithArrayInput" -> {
|
||||||
|
val params = context.params
|
||||||
|
val bodyParam = ApiHandlerUtils.searchJsonArrayInJson(params,"body")
|
||||||
|
if(bodyParam == null){
|
||||||
|
throw IllegalArgumentException("body is required")
|
||||||
|
}
|
||||||
|
val body:kotlin.Array<User> = Gson().fromJson(bodyParam.encode()
|
||||||
|
, object : TypeToken<kotlin.collections.List<User>>(){}.type)
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.createUsersWithArrayInput(body,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"createUsersWithListInput" -> {
|
||||||
|
val params = context.params
|
||||||
|
val bodyParam = ApiHandlerUtils.searchJsonArrayInJson(params,"body")
|
||||||
|
if(bodyParam == null){
|
||||||
|
throw IllegalArgumentException("body is required")
|
||||||
|
}
|
||||||
|
val body:kotlin.Array<User> = Gson().fromJson(bodyParam.encode()
|
||||||
|
, object : TypeToken<kotlin.collections.List<User>>(){}.type)
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.createUsersWithListInput(body,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"deleteUser" -> {
|
||||||
|
val params = context.params
|
||||||
|
val username = ApiHandlerUtils.searchStringInJson(params,"username")
|
||||||
|
if(username == null){
|
||||||
|
throw IllegalArgumentException("username is required")
|
||||||
|
}
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.deleteUser(username,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"getUserByName" -> {
|
||||||
|
val params = context.params
|
||||||
|
val username = ApiHandlerUtils.searchStringInJson(params,"username")
|
||||||
|
if(username == null){
|
||||||
|
throw IllegalArgumentException("username is required")
|
||||||
|
}
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.getUserByName(username,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"loginUser" -> {
|
||||||
|
val params = context.params
|
||||||
|
val username = ApiHandlerUtils.searchStringInJson(params,"username")
|
||||||
|
if(username == null){
|
||||||
|
throw IllegalArgumentException("username is required")
|
||||||
|
}
|
||||||
|
val password = ApiHandlerUtils.searchStringInJson(params,"password")
|
||||||
|
if(password == null){
|
||||||
|
throw IllegalArgumentException("password is required")
|
||||||
|
}
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.loginUser(username,password,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
"logoutUser" -> {
|
||||||
|
}
|
||||||
|
|
||||||
|
"updateUser" -> {
|
||||||
|
val params = context.params
|
||||||
|
val username = ApiHandlerUtils.searchStringInJson(params,"username")
|
||||||
|
if(username == null){
|
||||||
|
throw IllegalArgumentException("username is required")
|
||||||
|
}
|
||||||
|
val bodyParam = ApiHandlerUtils.searchJsonObjectInJson(params,"body")
|
||||||
|
if (bodyParam == null) {
|
||||||
|
throw IllegalArgumentException("body is required")
|
||||||
|
}
|
||||||
|
val body = Gson().fromJson(bodyParam.encode(), User::class.java)
|
||||||
|
GlobalScope.launch(vertx.dispatcher()){
|
||||||
|
val result = service.updateUser(username,body,context)
|
||||||
|
val payload = JsonObject(Json.encode(result.payload)).toBuffer()
|
||||||
|
val res = OperationResponse(result.statusCode,result.statusMessage,payload,result.headers)
|
||||||
|
msg.reply(res.toJson())
|
||||||
|
}.invokeOnCompletion{
|
||||||
|
it?.let{ throw it }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}catch (t: Throwable) {
|
||||||
|
msg.reply(ServiceException(500, t.message))
|
||||||
|
throw t
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
Loading…
x
Reference in New Issue
Block a user