feat: glee authentication using auth directory

examples/anime-http/client/.env

@@ -0,0 +1 @@
+TOKEN=arb-valueFromClientAuth

examples/anime-http/client/asyncapi.yaml

@@ -42,4 +42,4 @@ components:
  test:
  summary: ping client
  payload:
- type: object
+ type: object

examples/anime-http/client/auth/trendingAnime.js

@@ -0,0 +1,9 @@
+/* eslint-disable no-undef */
+
+export async function clientAuth({ parsedAsyncAPI, serverName }) {
+ console.log("serverName", serverName)
+
+ return {
+ token: process.env.TOKEN,
+ }
+}

examples/anime-http/client/docs/asyncapi.md

@@ -0,0 +1,128 @@
+# AsyncAPI IMDB client 1.0.0 documentation
+
+This app creates a client that subscribes to the server for getting the top 10 trending/upcoming anime.
+
+## Table of Contents
+
+* [Servers](#servers)
+ * [trendingAnime](#trendinganime-server)
+ * [testwebhook](#testwebhook-server)
+* [Operations](#operations)
+ * [PUB /test](#pub-test-operation)
+ * [PUB trendingAnime](#pub-trendinganime-operation)
+ * [SUB trendingAnime](#sub-trendinganime-operation)
+
+## Servers
+
+### `trendingAnime` Server
+
+* URL: `http://localhost:8081`
+* Protocol: `http`
+
+
+
+### `testwebhook` Server
+
+* URL: `ws://localhost:9000`
+* Protocol: `ws`
+
+
+
+## Operations
+
+### PUB `/test` Operation
+
+* Operation ID: `index`
+
+#### `ws` Channel specific information
+
+| Name | Type | Description | Value | Constraints | Notes |
+|---|---|---|---|---|---|
+| bindingVersion | - | - | `"0.1.0"` | - | - |
+
+#### Message `test`
+
+*ping client*
+
+##### Payload
+
+| Name | Type | Description | Value | Constraints | Notes |
+|---|---|---|---|---|---|
+| (root) | object | - | - | - | **additional properties are allowed** |
+
+> Examples of payload _(generated)_
+
+```json
+{}
+```
+
+
+
+### PUB `trendingAnime` Operation
+
+* Operation ID: `trendingAnimeListRecieverController`
+* Available only on servers: [trendingAnime](#trendinganime-server)
+
+#### `http` Channel specific information
+
+| Name | Type | Description | Value | Constraints | Notes |
+|---|---|---|---|---|---|
+| type | - | - | `"request"` | - | - |
+| method | - | - | `"POST"` | - | - |
+| bindingVersion | - | - | `"0.1.0"` | - | - |
+
+#### Message `<anonymous-message-2>`
+
+*Data required to populate trending anime*
+
+##### Payload
+
+| Name | Type | Description | Value | Constraints | Notes |
+|---|---|---|---|---|---|
+| (root) | object | - | - | - | **additional properties are allowed** |
+| name | string | Name of the anime. | - | - | **required** |
+| rating | string | Rating of the show. | - | - | **required** |
+| genre | string | The genre of anime. | - | - | **required** |
+| studio | string | The studio of anime. | - | - | **required** |
+
+> Examples of payload _(generated)_
+
+```json
+{
+ "name": "string",
+ "rating": "string",
+ "genre": "string",
+ "studio": "string"
+}
+```
+
+
+
+### SUB `trendingAnime` Operation
+
+* Available only on servers: [trendingAnime](#trendinganime-server)
+
+#### `http` Channel specific information
+
+| Name | Type | Description | Value | Constraints | Notes |
+|---|---|---|---|---|---|
+| type | - | - | `"request"` | - | - |
+| method | - | - | `"POST"` | - | - |
+| bindingVersion | - | - | `"0.1.0"` | - | - |
+
+#### Message `<anonymous-message-3>`
+
+##### Payload
+
+| Name | Type | Description | Value | Constraints | Notes |
+|---|---|---|---|---|---|
+| (root) | object | - | - | - | **additional properties are allowed** |
+
+> Examples of payload _(generated)_
+
+```json
+{}
+```
+
+
+

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

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

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

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

examples/anime-http/client/glee.config.js

@@ -0,0 +1,15 @@
+export default async function () {
+ return {
+ http: {
+ client: {
+ auth: async ({ serverName }) => {
+ if (serverName === "websockets") {
+ return {
+ token: process.env.TOKEN,
+ }
+ }
+ },
+ },
+ },
+ }
+}

examples/anime-http/server/asyncapi.yaml

@@ -1,12 +1,17 @@
-asyncapi: 2.4.0
+asyncapi: 2.6.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
+ url: 'http://localhost:8081'
  protocol: http
+ security:
+ - tokens: []
+ - userPass: []
+ - apiKey: []
+ - cert: []
 channels:
  trendingAnime:
  bindings:
@@ -15,13 +20,13 @@ channels:
  method: POST
  bindingVersion: 0.1.0
  query:
- $ref: "#/components/schemas/request"
+ $ref: '#/components/schemas/request'
  body:
- $ref: "#/components/schemas/request"
+ $ref: '#/components/schemas/request'
  publish:
  operationId: trendingAnimeController
  message:
- $ref: "#/components/messages/trendingAnime"
+ $ref: '#/components/messages/trendingAnime'
  subscribe:
  message:
  payload:
@@ -31,7 +36,7 @@ components:
  trendingAnime:
  summary: Data required to populate trending anime
  payload:
- $ref: "#/components/schemas/request"
+ $ref: '#/components/schemas/request'
  schemas:
  request:
  type: object
@@ -53,3 +58,17 @@ components:
  studio:
  type: string
  description: The studio of anime.
+ securitySchemes:
+ tokens:
+ type: http
+ scheme: bearer
+ bearerFormat: JWT
+ userPass:
+ type: userPassword
+ apiKey:
+ type: httpApiKey
+ name: api_key
+ in: header
+ cert:
+ type: apiKey
+ in: user

examples/anime-http/server/auth/trendingAnimeServer.ts

@@ -0,0 +1,26 @@
+// /* eslint-disable no-undef */
+
+// //@ts-ignore
+// import { Message } from "@asyncapi/glee";
+import axios from "axios"
+
+export async function serverAuth({ headers, callback: done }) {
+ await axios.get("https://jsonplaceholder.typicode.com/todos/1")
+
+ console.log("running in auth file in auth folder")
+
+ console.log("headers", headers["authentication"])
+
+ // console.log("network data", res.data)
+
+ // callback(false, 401, "Unauthorized");
+ done(true)
+}
+
+export async function clientAuth({ parsedAsyncAPI, serverName }) {
+ if (serverName === "websockets") {
+ return {
+ token: process.env.TOKEN,
+ }
+ }
+}