feat: add http adapter support for glee

.gitignore

@@ -4,4 +4,4 @@ dist
 coverage
 .vscode
 .glee
-.next
+.next

docs/config-file.md

@@ -21,7 +21,8 @@ export default async function () {
  kafka: {},
  websocket: {},
  mqtt: {},
- cluster: {}
+ cluster: {},
+ http: {}
  }
 }
 
@@ -69,6 +70,24 @@ export default async function () {
  }
  }
  }
+ },
+ http: {
+ server: {
+ httpServer: customServer, // A custom HTTP server of your own.
+ adapter: 'native', 
+ port: process.env.PORT,
+ },
+ client: {
+ auth: {
+ token: process.env.TOKEN
+ },
+ query: {
+ foo: 'bar'
+ },
+ body: {
+ foo: 'bar'
+ }
+ }
  }
  };
 }
@@ -137,6 +156,19 @@ These configurations apply to Glee itself, rather than any specific protocol.
 |kafka.auth.username| The username to use during authentication.
 |kafka.auth.password| The password to use during authentication.
 
+### HTTP Server
+
+|Field|Description|
+|--|--|
+|http.server|HTTP server-specific configurations|
+|http.client|HTTP client-specific configurations|
+|http.server.adapter| The Glee adapter to use for the HTTP server. Defaults to a "native" HTTP implementation.|
+|websocket.server.port| The port to use when binding the HTTP server. This is useful when your server is behind a proxy and the port exposed for consumption is not the same as the port your application should be bound to. Defaults to the port specified in the selected AsyncAPI server.|
+|http.client.auth| Authentication/Authorization configuration for the client|
+|http.client.auth.token| HTTP Authentication header|
+|http.client.query| Query object for the client to send|
+|http.client.body| Body object for the client to send
+
 
 ### Auth Config
 

examples/anime-http/client/asyncapi.yaml

@@ -0,0 +1,45 @@
+asyncapi: 2.4.0
+info:
+ title: AsyncAPI IMDB client
+ version: 1.0.0
+ description: This app creates a client that subscribes to the server for getting the top 10 trending/upcoming anime.
+servers:
+ trendingAnime:
+ url: http://localhost:8081
+ protocol: http
+ testwebhook:
+ url: ws://localhost:9000
+ protocol: ws
+x-remoteServers:
+ - trendingAnime
+channels:
+ /test:
+ bindings:
+ ws:
+ bindingVersion: 0.1.0
+ publish:
+ operationId: index
+ message:
+ $ref: '#/components/messages/test'
+ trendingAnime:
+ bindings:
+ http:
+ type: request
+ method: POST
+ bindingVersion: 0.1.0
+ servers:
+ - trendingAnime
+ publish:
+ operationId: trendingAnimeListRecieverController
+ message:
+ $ref: "../server/asyncapi.yaml#/components/messages/trendingAnime"
+ subscribe:
+ message:
+ payload:
+ type: object
+components:
+ messages:
+ test:
+ summary: ping client
+ payload:
+ type: object

examples/anime-http/client/functions/index.ts

@@ -0,0 +1,25 @@
+export default async function () {
+ const payload = {
+ body: {
+ name: 'test12',
+ rating: '5',
+ studio: 'teststudio',
+ genre: 'testgenre',
+ },
+ query: {
+ name: 'test34',
+ rating: '5',
+ studio: 'teststudio',
+ genre: 'testgenre',
+ }
+ }
+ return {
+ send: [
+ {
+ server: 'trendingAnime',
+ payload: payload.body,
+ query: payload.query
+ },
+ ],
+ }
+}

examples/anime-http/client/functions/trendingAnimeListRecieverController.ts

@@ -0,0 +1,3 @@
+export default async function (event) {
+ console.log('Trending Anime Payload:', event.payload)
+}

examples/anime-http/client/package.json

@@ -0,0 +1,18 @@
+{
+ "name": "simple",
+ "version": "1.0.0",
+ "description": "",
+ "main": "index.js",
+ "type": "module",
+ "scripts": {
+ "test": "echo \"Error: no test specified\" && exit 1",
+ "start": "glee start",
+ "dev": "glee dev"
+ },
+ "keywords": [],
+ "author": "",
+ "license": "ISC",
+ "dependencies": {
+ "@asyncapi/glee": "file:../../.."
+ }
+}

examples/anime-http/client/tsconfig.json

@@ -0,0 +1,10 @@
+{
+ "compilerOptions": {
+ "allowJs": true,
+ "target": "es6",
+ "esModuleInterop": true,
+ "moduleResolution": "node",
+ "module": "es2020",
+ "resolveJsonModule": true,
+ }
+}

examples/anime-http/server/asyncapi.yaml

@@ -0,0 +1,55 @@
+asyncapi: 2.4.0
+info:
+ title: AsyncAPI IMDB server
+ version: 1.0.0
+ description: This app is a dummy server that would stream the trending/upcoming anime.
+servers:
+ trendingAnimeServer:
+ url: http://localhost:8081
+ protocol: http
+channels:
+ trendingAnime:
+ bindings:
+ http:
+ type: request
+ method: POST
+ bindingVersion: 0.1.0
+ query:
+ $ref: "#/components/schemas/request"
+ body:
+ $ref: "#/components/schemas/request"
+ publish:
+ operationId: trendingAnimeController
+ message:
+ $ref: "#/components/messages/trendingAnime"
+ subscribe:
+ message:
+ payload:
+ type: object
+components:
+ messages:
+ trendingAnime:
+ summary: Data required to populate trending anime
+ payload:
+ $ref: "#/components/schemas/request"
+ schemas:
+ request:
+ type: object
+ required:
+ - name
+ - rating
+ - genre
+ - studio
+ properties:
+ name:
+ type: string
+ description: Name of the anime.
+ rating:
+ type: string
+ description: Rating of the show.
+ genre:
+ type: string
+ description: The genre of anime.
+ studio:
+ type: string
+ description: The studio of anime.

examples/anime-http/server/functions/trendingAnimeController.ts

@@ -0,0 +1,12 @@
+export default async function (event) {
+ const replyPayload = event.payload
+ const replyQuery = event.query
+ return {
+ reply: [
+ {
+ payload: replyPayload,
+ query: replyQuery
+ },
+ ],
+ }
+}

examples/anime-http/server/package.json

@@ -0,0 +1,18 @@
+{
+ "name": "simple",
+ "version": "1.0.0",
+ "description": "",
+ "main": "index.js",
+ "type": "module",
+ "scripts": {
+ "test": "echo \"Error: no test specified\" && exit 1",
+ "start": "glee start",
+ "dev": "glee dev"
+ },
+ "keywords": [],
+ "author": "",
+ "license": "ISC",
+ "dependencies": {
+ "@asyncapi/glee": "file:../../.."
+ }
+}

examples/anime-http/server/tsconfig.json

@@ -0,0 +1,9 @@
+{
+ "compilerOptions": {
+ "allowJs": true,
+ "target": "es6",
+ "esModuleInterop": true,
+ "moduleResolution": "node",
+ "module":"es2020"
+ }
+}

examples/crypto-websockets/client/asyncapi.yaml

@@ -31,4 +31,3 @@ components:
  type: number
  price:
  type: number
-

package.json

@@ -53,6 +53,7 @@
  "emojis": "^1.0.10",
  "eslint-plugin-github": "^4.3.5",
  "eslint-plugin-security": "^1.4.0",
+ "got": "^12.5.3",
  "kafkajs": "^2.2.3",
  "mqtt": "^4.2.6",
  "path-to-regexp": "^6.2.0",

src/adapters/http/client.ts

@@ -0,0 +1,63 @@
+import Adapter from '../../lib/adapter.js'
+import GleeMessage from '../../lib/message.js'
+import got from 'got'
+import { HttpAuthConfig, HttpAdapterConfig } from '../../lib/index.js'
+import http from 'http'
+class HttpClientAdapter extends Adapter {
+
+ name(): string {
+ return 'HTTP client'
+ }
+ async connect(): Promise<this> {
+ this.emit('connect', {
+ name: this.name(),
+ adapter: this,
+ connection: http,
+ channel: this.channelNames,
+ })
+ return this
+ }
+
+ async send(message: GleeMessage): Promise<void> {
+ const headers = {}
+ const config: HttpAdapterConfig = await this.resolveProtocolConfig('http')
+ const auth: HttpAuthConfig = await this.getAuthConfig(config.client.auth)
+ headers['Authentication'] = auth?.token
+ const serverUrl = this.serverUrlExpanded
+ this.channelNames.forEach(async (channelName) => {
+ const channelInfo = this.parsedAsyncAPI.channel(channelName)
+ const httpChannelBinding = channelInfo.binding('http')
+ const channelServers = channelInfo.servers()
+ const isChannelServers = !channelServers.length || channelServers.includes(message.serverName)
+ if (
+ httpChannelBinding && isChannelServers
+ ) {
+ const method = httpChannelBinding.method
+ const url = `${serverUrl}/${channelName}`
+ const body:any = message.payload
+ const query: { [key: string]: string } | { [key: string]: string[] } = message.query
+ got({
+ method,
+ url,
+ json: body,
+ searchParams: JSON.parse(JSON.stringify(query)),
+ })
+ .then((res) => {
+ const msg = this.createMessage(channelName, res.body)
+ this.emit('message', msg, http)
+ })
+ .catch((err) => {
+ this.emit('error', err)
+ })
+ }
+ })
+ }
+ private createMessage(channelName: string, payload: any) {
+ return new GleeMessage({
+ payload: JSON.parse(JSON.stringify(payload)),
+ channel: channelName,
+ })
+ }
+}
+
+export default HttpClientAdapter