Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: support AsyncAPI spec v3 (#193)
- Loading branch information
1 parent
6d0336a
commit bc259ae
Showing
14 changed files
with
962 additions
and
318 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,94 +1,19 @@ | ||
// eslint-disable-next-line @typescript-eslint/no-var-requires | ||
const { Optimizer } = require('../lib/Optimizer') | ||
|
||
const yaml = ` | ||
asyncapi: 2.0.0 | ||
info: | ||
title: Streetlights API | ||
version: '1.0.0' | ||
channels: | ||
smartylighting/event/{streetlightId}/lighting/measured: | ||
parameters: | ||
#this parameter is duplicated. it can be moved to components and ref-ed from here. | ||
streetlightId: | ||
schema: | ||
type: string | ||
subscribe: | ||
operationId: receiveLightMeasurement | ||
traits: | ||
- bindings: | ||
kafka: | ||
clientId: my-app-id | ||
message: | ||
name: lightMeasured | ||
title: Light measured | ||
contentType: application/json | ||
traits: | ||
- headers: | ||
type: object | ||
properties: | ||
my-app-header: | ||
type: integer | ||
minimum: 0 | ||
maximum: 100 | ||
payload: | ||
type: object | ||
properties: | ||
lumens: | ||
type: integer | ||
minimum: 0 | ||
#full form is used, we can ref it to: #/components/schemas/sentAt | ||
sentAt: | ||
type: string | ||
format: date-time | ||
smartylighting/action/{streetlightId}/turn/on: | ||
parameters: | ||
streetlightId: | ||
schema: | ||
type: string | ||
publish: | ||
operationId: turnOn | ||
traits: | ||
- bindings: | ||
kafka: | ||
clientId: my-app-id | ||
message: | ||
name: turnOnOff | ||
title: Turn on/off | ||
traits: | ||
- headers: | ||
type: object | ||
properties: | ||
my-app-header: | ||
type: integer | ||
minimum: 0 | ||
maximum: 100 | ||
payload: | ||
type: object | ||
properties: | ||
sentAt: | ||
$ref: "#/components/schemas/sentAt" | ||
components: | ||
messages: | ||
#libarary should be able to find and delete this message, because it is not used anywhere. | ||
unusedMessage: | ||
name: unusedMessage | ||
title: This message is not used in any channel. | ||
schemas: | ||
#this schema is ref-ed in one channel and used full form in another. library should be able to identify and ref the second channel as well. | ||
sentAt: | ||
type: string | ||
format: date-time` | ||
const optimizer = new Optimizer(yaml) | ||
// read input.yaml file synconously and store it as an string | ||
const input = require('fs').readFileSync('./examples/input.yaml', 'utf8') | ||
const optimizer = new Optimizer(input) | ||
optimizer.getReport().then((report) => { | ||
//console.log(JSON.stringify(report)) | ||
console.log(JSON.stringify(report)) | ||
const optimizedDocument = optimizer.getOptimizedDocument({ | ||
output: 'YAML', | ||
rules: { | ||
reuseComponents: true, | ||
removeComponents: true, | ||
moveToComponents: true, | ||
}, | ||
}) | ||
console.log(optimizedDocument) | ||
//store optimizedDocument as to output.yaml | ||
require('fs').writeFileSync('./examples/output.yaml', optimizedDocument) | ||
}) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,253 @@ | ||
asyncapi: 3.0.0 | ||
info: | ||
title: Streetlights MQTT API | ||
version: 1.0.0 | ||
description: "The Smartylighting Streetlights API allows you to remotely manage the city lights.\n\n### Check out its awesome features:\n\n* Turn a specific streetlight on/off \U0001F303\n* Dim a specific streetlight \U0001F60E\n* Receive real-time information about environmental lighting conditions \U0001F4C8\n" | ||
license: | ||
name: Apache 2.0 | ||
url: 'https://www.apache.org/licenses/LICENSE-2.0' | ||
defaultContentType: application/json | ||
servers: | ||
production: | ||
host: 'test.mosquitto.org:{port}' | ||
protocol: mqtt | ||
description: Test broker | ||
variables: | ||
port: | ||
description: Secure connection (TLS) is available through port 8883. | ||
default: '1883' | ||
enum: | ||
- '1883' | ||
- '8883' | ||
security: | ||
- $ref: '#/components/securitySchemes/apiKey' | ||
- type: oauth2 | ||
description: Flows to support OAuth 2.0 | ||
flows: | ||
implicit: | ||
authorizationUrl: 'https://authserver.example/auth' | ||
availableScopes: | ||
'streetlights:on': Ability to switch lights on | ||
'streetlights:off': Ability to switch lights off | ||
'streetlights:dim': Ability to dim the lights | ||
password: | ||
tokenUrl: 'https://authserver.example/token' | ||
availableScopes: | ||
'streetlights:on': Ability to switch lights on | ||
'streetlights:off': Ability to switch lights off | ||
'streetlights:dim': Ability to dim the lights | ||
clientCredentials: | ||
tokenUrl: 'https://authserver.example/token' | ||
availableScopes: | ||
'streetlights:on': Ability to switch lights on | ||
'streetlights:off': Ability to switch lights off | ||
'streetlights:dim': Ability to dim the lights | ||
authorizationCode: | ||
authorizationUrl: 'https://authserver.example/auth' | ||
tokenUrl: 'https://authserver.example/token' | ||
refreshUrl: 'https://authserver.example/refresh' | ||
availableScopes: | ||
'streetlights:on': Ability to switch lights on | ||
'streetlights:off': Ability to switch lights off | ||
'streetlights:dim': Ability to dim the lights | ||
scopes: | ||
- 'streetlights:on' | ||
- 'streetlights:off' | ||
- 'streetlights:dim' | ||
- $ref: '#/components/securitySchemes/openIdConnectWellKnown' | ||
tags: | ||
- name: 'env:production' | ||
description: This environment is meant for production use case | ||
- name: 'kind:remote' | ||
description: This server is a remote server. Not exposed by the application | ||
- name: 'visibility:public' | ||
description: This resource is public and available to everyone | ||
channels: | ||
lightingMeasured: | ||
address: 'smartylighting/streetlights/1/0/event/{streetlightId}/lighting/measured' | ||
messages: | ||
lightMeasured: | ||
$ref: '#/components/messages/lightMeasured' | ||
description: The topic on which measured values may be produced and consumed. | ||
parameters: | ||
streetlightId: | ||
$ref: '#/components/parameters/streetlightId' | ||
lightTurnOn: | ||
address: 'smartylighting/streetlights/1/0/action/{streetlightId}/turn/on' | ||
messages: | ||
turnOn: | ||
$ref: '#/components/messages/turnOnOff' | ||
parameters: | ||
streetlightId: | ||
$ref: '#/components/parameters/streetlightId' | ||
lightTurnOff: | ||
address: 'smartylighting/streetlights/1/0/action/{streetlightId}/turn/off' | ||
messages: | ||
turnOff: | ||
$ref: '#/components/messages/turnOnOff' | ||
parameters: | ||
streetlightId: | ||
$ref: '#/components/parameters/streetlightId' | ||
lightsDim: | ||
address: 'smartylighting/streetlights/1/0/action/{streetlightId}/dim' | ||
messages: | ||
dimLight: | ||
$ref: '#/components/messages/dimLight' | ||
parameters: | ||
streetlightId: | ||
$ref: '#/components/parameters/streetlightId' | ||
operations: | ||
receiveLightMeasurement: | ||
action: receive | ||
channel: | ||
$ref: '#/channels/lightingMeasured' | ||
summary: >- | ||
Inform about environmental lighting conditions of a particular | ||
streetlight. | ||
traits: | ||
- $ref: '#/components/operationTraits/mqtt' | ||
messages: | ||
- $ref: '#/channels/lightingMeasured/messages/lightMeasured' | ||
turnOn: | ||
action: send | ||
channel: | ||
$ref: '#/channels/lightTurnOn' | ||
traits: | ||
- $ref: '#/components/operationTraits/mqtt' | ||
messages: | ||
- $ref: '#/channels/lightTurnOn/messages/turnOn' | ||
turnOff: | ||
action: send | ||
channel: | ||
$ref: '#/channels/lightTurnOff' | ||
traits: | ||
- $ref: '#/components/operationTraits/mqtt' | ||
messages: | ||
- $ref: '#/channels/lightTurnOff/messages/turnOff' | ||
dimLight: | ||
action: send | ||
channel: | ||
$ref: '#/channels/lightsDim' | ||
traits: | ||
- $ref: '#/components/operationTraits/mqtt' | ||
messages: | ||
- $ref: '#/channels/lightsDim/messages/dimLight' | ||
components: | ||
messages: | ||
lightMeasured: | ||
name: lightMeasured | ||
title: Light measured | ||
summary: >- | ||
Inform about environmental lighting conditions of a particular | ||
streetlight. | ||
contentType: application/json | ||
traits: | ||
- $ref: '#/components/messageTraits/commonHeaders' | ||
payload: | ||
$ref: '#/components/schemas/lightMeasuredPayload' | ||
turnOnOff: | ||
name: turnOnOff | ||
title: Turn on/off | ||
summary: Command a particular streetlight to turn the lights on or off. | ||
traits: | ||
- $ref: '#/components/messageTraits/commonHeaders' | ||
payload: | ||
$ref: '#/components/schemas/turnOnOffPayload' | ||
dimLight: | ||
name: dimLight | ||
title: Dim light | ||
summary: Command a particular streetlight to dim the lights. | ||
traits: | ||
- $ref: '#/components/messageTraits/commonHeaders' | ||
payload: | ||
$ref: '#/components/schemas/dimLightPayload' | ||
schemas: | ||
lightMeasuredPayload: | ||
type: object | ||
properties: | ||
lumens: | ||
type: integer | ||
minimum: 0 | ||
description: Light intensity measured in lumens. | ||
sentAt: | ||
$ref: '#/components/schemas/sentAt' | ||
turnOnOffPayload: | ||
type: object | ||
properties: | ||
command: | ||
type: string | ||
enum: | ||
- 'on' | ||
- 'off' | ||
description: Whether to turn on or off the light. | ||
sentAt: | ||
$ref: '#/components/schemas/sentAt' | ||
dimLightPayload: | ||
type: object | ||
properties: | ||
percentage: | ||
type: integer | ||
description: Percentage to which the light should be dimmed to. | ||
minimum: 0 | ||
maximum: 100 | ||
sentAt: | ||
$ref: '#/components/schemas/sentAt' | ||
sentAt: | ||
type: string | ||
format: date-time | ||
description: Date and time when the message was sent. | ||
securitySchemes: | ||
apiKey: | ||
type: apiKey | ||
in: user | ||
description: Provide your API key as the user and leave the password empty. | ||
supportedOauthFlows: | ||
type: oauth2 | ||
description: Flows to support OAuth 2.0 | ||
flows: | ||
implicit: | ||
authorizationUrl: 'https://authserver.example/auth' | ||
availableScopes: | ||
'streetlights:on': Ability to switch lights on | ||
'streetlights:off': Ability to switch lights off | ||
'streetlights:dim': Ability to dim the lights | ||
password: | ||
tokenUrl: 'https://authserver.example/token' | ||
availableScopes: | ||
'streetlights:on': Ability to switch lights on | ||
'streetlights:off': Ability to switch lights off | ||
'streetlights:dim': Ability to dim the lights | ||
clientCredentials: | ||
tokenUrl: 'https://authserver.example/token' | ||
availableScopes: | ||
'streetlights:on': Ability to switch lights on | ||
'streetlights:off': Ability to switch lights off | ||
'streetlights:dim': Ability to dim the lights | ||
authorizationCode: | ||
authorizationUrl: 'https://authserver.example/auth' | ||
tokenUrl: 'https://authserver.example/token' | ||
refreshUrl: 'https://authserver.example/refresh' | ||
availableScopes: | ||
'streetlights:on': Ability to switch lights on | ||
'streetlights:off': Ability to switch lights off | ||
'streetlights:dim': Ability to dim the lights | ||
openIdConnectWellKnown: | ||
type: openIdConnect | ||
openIdConnectUrl: 'https://authserver.example/.well-known' | ||
parameters: | ||
streetlightId: | ||
description: The ID of the streetlight. | ||
messageTraits: | ||
commonHeaders: | ||
headers: | ||
type: object | ||
properties: | ||
my-app-header: | ||
type: integer | ||
minimum: 0 | ||
maximum: 100 | ||
operationTraits: | ||
mqtt: | ||
bindings: | ||
mqtt: | ||
qos: 1 |
Oops, something went wrong.