feat: add request/reply support

examples/slack-reaction-listener/.gitignore

@@ -0,0 +1,2 @@
+node_modules
+.glee

examples/slack-reaction-listener/README.md

@@ -0,0 +1,3 @@
+# Dummy
+
+This is a dummy example mainly used to test functionalities.

examples/slack-reaction-listener/asyncapi.yaml

@@ -0,0 +1,147 @@
+asyncapi: 3.0.0
+info:
+  title: Slack Websocket API
+  version: 1.0.0
+servers:
+  OpenAI:
+    host: api.openai.com
+    protocol: https
+  Slack:
+    host: wss-primary.slack.com
+    protocol: wss
+  Slack_HTTP:
+    host:  slack.com
+    protocol: https
+channels:
+  slackResponse:
+    bindings:
+      http:
+        method: post
+    address: /api/chat.postMessage
+    servers:
+      - $ref: "#/servers/Slack_HTTP"
+    messages:
+      slackResponse:
+        $ref: "#/components/messages/slackResponse"
+  OpenAISent:
+    bindings:
+      http:
+        method: post
+    servers:
+      - $ref: "#/servers/OpenAI"
+    address: /v1/chat/completions
+    messages:
+      OpenAIRequest: 
+        $ref: "#/components/messages/OpenAIRequest"
+  slackReceive:
+    servers:
+      - $ref: "#/servers/Slack"
+    address: /link/?ticket={ticket}&app_id={app_id}
+    parameters:
+      ticket:
+        default: 35338c0f-ffcc-4325-b8d4-7c9e556c0ecf
+      app_id:
+        default: b02112d9364cb2fee8a0ee048a920b8b4b0103cb03fab023b4e30f6ee2efb98f
+    messages:
+      reactionAdded:
+        $ref: "#/components/messages/reactionAdded"
+      error:
+        $ref: "#/components/messages/error"
+operations:
+  slackResponse:
+
+    action: send
+    channel: 
+      $ref: "#/channels/OpenAISent"
+    messages:
+      - $ref: "#/components/messages/slackResponse"
+  openAIResponse:
+    action: receive
+    channel:
+      $ref: "#/channels/OpenAISent"
+    messages:
+      - $ref: "#/components/messages/OpenAIResponse"
+    reply:
+      channel:
+        $ref: "#/channels/slackResponse"
+  reactionAdded:
+    reply:
+      channel: 
+        $ref: "#/channels/OpenAISent"
+    action: receive
+    channel:
+      $ref: "#/channels/slackReceive"
+    messages:
+      - $ref: "#/components/messages/reactionAdded"
+      - $ref: "#/components/messages/error"
+
+components:
+  messages:
+    slackResponse:
+      payload:
+        type: object
+        properties:
+          channel:
+            type: string
+          text:
+            type: string
+    OpenAIRequest:
+      payload:
+        type: object
+        properties:
+          model:
+            type: string
+            enum: ["gpt-3.5-turbo", "gpt-3.5-turbo-16k", "text-davinci-002"]
+          messages:
+            type: array
+            items:
+              type: object
+              properties:
+                role:
+                  type: string
+                  enum: ["user"]
+                content:
+                  type: string
+          temperature:
+            type: number
+            minimum: 0.0
+            maximum: 1.0
+        required:
+          - model
+          - messages
+          - temperature
+    OpenAIResponse:
+      payload:
+        type: object
+        properties:
+          choices:
+            type: array
+            items:
+              type: object
+              properties:
+                finish_reason:
+                  type: string
+                  enum: ['stop']
+                message:
+                  type: object
+                  properties:
+                    content:
+                      type: string
+                    role:
+                      type: string
+                      enum: ['assistant']
+              required:
+                - finish_reason
+                - message
+        required:
+          - choices
+    reactionAdded:
+      payload:
+        type: object
+    error:
+      payload:
+        type: string
+x-remoteServers: 
+  - Slack_HTTP
+  - Slack
+  - OpenAI

examples/slack-reaction-listener/functions/openAIResponse.ts

@@ -0,0 +1,25 @@
+import { GleeFunction } from "@asyncapi/glee"
+
+const myFunction: GleeFunction = async (event) => {
+  const { payload } = event.request.request;
+  const slack_event = payload?.payload?.event
+
+  if (!slack_event) return
+
+  const thread_ts = slack_event.item.ts
+  const channel = slack_event.item.channel
+  const text = event.payload.choices[0].message.content
+
+
+  return {
+    payload: {
+      channel, thread_ts, text
+    },
+    headers: {
+      Authorization: `Bearer ${process.env.SLACK_HTTP}`,
+    }
+  }
+
+}
+
+export default myFunction

examples/slack-reaction-listener/functions/reactionAdded.ts

@@ -0,0 +1,24 @@
+import { GleeFunction } from "@asyncapi/glee"
+enum EVENT_TYPE {
+  EVENTS_API = "events_api",
+  CONNECTED = "hello"
+}
+const myFunction: GleeFunction = async ({ payload }) => {
+  const reaction = payload?.payload?.event?.reaction
+  if (!reaction) return
+  return {
+    headers: {
+      'Authorization': `Bearer ${process.env.CHAT_API}`
+    },
+
+    payload: {
+      model: "gpt-3.5-turbo",
+      messages: [{ "role": "user", "content": `Someone reacted with "${reaction}" to my message on Slack, write something fun and short to them.` }],
+      temperature: 0.7
+    }
+  }
+
+
+}
+
+export default myFunction

examples/slack-reaction-listener/glee.config.js

@@ -0,0 +1,7 @@
+export default async function () {
+  return {
+    docs: {
+      enabled: false
+    }
+  }
+}