fix: review suggestions

Souvikns · Oct 12, 2023 · 893a03b · 893a03b
1 parent 4f48945
commit 893a03b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/adapters/mqtt/index.ts b/src/adapters/mqtt/index.ts
@@ -46,7 +46,7 @@ class MqttAdapter extends Adapter {
     let userAndPasswordSecurityReq
     let X509SecurityReq
 
-    const securityRequirements = this.AsyncAPIServer.security().map(e => e.map(e => e.scheme()))
+    const securityRequirements = this.AsyncAPIServer.security().map(e => e.all().map(e => e.scheme()))
 
     securityRequirements.forEach(security => {
       for (const sec of security) {

diff --git a/src/index.ts b/src/index.ts
@@ -84,7 +84,7 @@ export default async function GleeAppInitializer() {
 
       if (operationId) {
         const schema = {
-          oneOf: operation.messages().filterByReceive().map(m => m.payload())
+          oneOf: operation.messages().filterByReceive().map(m => m.payload().json())
         } as any
         app.use(channelName, validate(schema), (event, next) => {
           triggerFunction({
@@ -98,7 +98,7 @@ export default async function GleeAppInitializer() {
 
     channel.operations().filterBySend().forEach(operation => {
       const schema = {
-        oneOf: operation.messages().filterBySend().map(m => m.payload())
+        oneOf: operation.messages().filterBySend().map(m => m.payload().json())
       } as any
       app.useOutbound(channelName, validate(schema), json2string)
     })