feat: kafka adapter

.gitignore

@@ -2,4 +2,5 @@ node_modules
 .DS_Store
 dist
 coverage
-.vscode
+.vscode
+local.env

examples/dummy - Copy/.env

@@ -0,0 +1,2 @@
+GLEE_SERVER_NAMES=mykafka
+GLEE_SERVER_CERTS=mosquitto:mosquitto.org.crt

examples/dummy - Copy/.gitignore

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

examples/dummy - Copy/README.md

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

examples/dummy - Copy/asyncapi.yaml

@@ -0,0 +1,18 @@
+asyncapi: 2.0.0
+info:
+  title: Kafka test
+  version: 1
+servers:
+  mykafka:
+    url: https://pkc-6ojv2.us-west4.gcp.confluent.cloud:443
+    protocol: kafka-secure
+channels:
+  test:
+    publish:
+      operationId: onTest
+      message:
+        payload:
+          type: object
+          properties:
+            test:
+              type: string

examples/dummy - Copy/customServer.js

@@ -0,0 +1,32 @@
+/* eslint-disable no-undef, security/detect-non-literal-fs-filename */
+
+import { fileURLToPath } from 'url'
+import path, { dirname } from 'path'
+import fs from 'fs'
+import { createServer } from 'http'
+
+const __filename = fileURLToPath(import.meta.url)
+const __dirname = dirname(__filename)
+
+const server = createServer((req, res) => {
+  let pathname
+
+  try {
+    pathname = new URL(req.url).pathname
+  } catch (e) {
+    pathname = req.url
+  }
+
+  if (pathname === '/socket.io') {
+    res.end(fs.readFileSync(path.resolve(__dirname, '../socket.io.html'), { encoding: 'utf-8' }))
+  } else if (pathname === '/') {
+    res.end(fs.readFileSync(path.resolve(__dirname, '../index.html'), { encoding: 'utf-8' }))
+  } else {
+    res.writeHead(404).end()
+  }
+}).listen(3005, (err) => {
+  if (err) throw err
+  console.log('Custom server running on http://localhost:3005')
+})
+
+export default server

examples/dummy - Copy/functions/onTest.ts

@@ -0,0 +1,3 @@
+export default async function (event) {
+  console.log(event)
+}

examples/dummy - Copy/glee.config.js

@@ -0,0 +1,15 @@
+// import customServer from './customServer.js'
+
+export default async function () {
+  return {
+    // websocket: {
+    //   httpServer: customServer,
+    //   adapter: 'native', // Default. Can also be 'socket.io' or a reference to a custom adapter.
+    // },
+    // cluster: {
+    //   adapter: 'redis',
+    //   name: 'gleeCluster',
+    //   url: 'redis://localhost:6379'
+    // }
+  }
+}

examples/dummy - Copy/index.html

@@ -0,0 +1,15 @@
+<script>
+  const serverAnnounceSocket = new WebSocket('ws://localhost:3005/ws/server/announce')
+  const userSignedUpSocket = new WebSocket('ws://localhost:3005/ws/user/signedup?salutation=Hola')
+
+  function logMessage (event) {
+    console.log(JSON.parse(event.data))
+  }
+
+  serverAnnounceSocket.addEventListener('message', logMessage)
+  userSignedUpSocket.addEventListener('message', logMessage)
+
+  userSignedUpSocket.addEventListener('open', () => {
+    //  userSignedUpSocket.send('{"displayName": "Fran Mendez", "email": "[email protected]"}')
+  })
+</script>

examples/dummy - Copy/lifecycle/announceServer.ts

@@ -0,0 +1,14 @@
+export default async function () {
+  return {
+    send: [{
+      server: 'mosquitto',
+      channel: 'server/announce',
+      payload: {
+        id: process.env.SERVER_ID || String(Date.now()),
+      }
+    }]
+  }
+}
+
+export const lifecycleEvent = 'onConnect'
+export const servers = ['mosquitto']

examples/dummy - Copy/mosquitto.org.crt

@@ -0,0 +1,24 @@
+-----BEGIN CERTIFICATE-----
+MIIEAzCCAuugAwIBAgIUBY1hlCGvdj4NhBXkZ/uLUZNILAwwDQYJKoZIhvcNAQEL
+BQAwgZAxCzAJBgNVBAYTAkdCMRcwFQYDVQQIDA5Vbml0ZWQgS2luZ2RvbTEOMAwG
+A1UEBwwFRGVyYnkxEjAQBgNVBAoMCU1vc3F1aXR0bzELMAkGA1UECwwCQ0ExFjAU
+BgNVBAMMDW1vc3F1aXR0by5vcmcxHzAdBgkqhkiG9w0BCQEWEHJvZ2VyQGF0Y2hv
+by5vcmcwHhcNMjAwNjA5MTEwNjM5WhcNMzAwNjA3MTEwNjM5WjCBkDELMAkGA1UE
+BhMCR0IxFzAVBgNVBAgMDlVuaXRlZCBLaW5nZG9tMQ4wDAYDVQQHDAVEZXJieTES
+MBAGA1UECgwJTW9zcXVpdHRvMQswCQYDVQQLDAJDQTEWMBQGA1UEAwwNbW9zcXVp
+dHRvLm9yZzEfMB0GCSqGSIb3DQEJARYQcm9nZXJAYXRjaG9vLm9yZzCCASIwDQYJ
+KoZIhvcNAQEBBQADggEPADCCAQoCggEBAME0HKmIzfTOwkKLT3THHe+ObdizamPg
+UZmD64Tf3zJdNeYGYn4CEXbyP6fy3tWc8S2boW6dzrH8SdFf9uo320GJA9B7U1FW
+Te3xda/Lm3JFfaHjkWw7jBwcauQZjpGINHapHRlpiCZsquAthOgxW9SgDgYlGzEA
+s06pkEFiMw+qDfLo/sxFKB6vQlFekMeCymjLCbNwPJyqyhFmPWwio/PDMruBTzPH
+3cioBnrJWKXc3OjXdLGFJOfj7pP0j/dr2LH72eSvv3PQQFl90CZPFhrCUcRHSSxo
+E6yjGOdnz7f6PveLIB574kQORwt8ePn0yidrTC1ictikED3nHYhMUOUCAwEAAaNT
+MFEwHQYDVR0OBBYEFPVV6xBUFPiGKDyo5V3+Hbh4N9YSMB8GA1UdIwQYMBaAFPVV
+6xBUFPiGKDyo5V3+Hbh4N9YSMA8GA1UdEwEB/wQFMAMBAf8wDQYJKoZIhvcNAQEL
+BQADggEBAGa9kS21N70ThM6/Hj9D7mbVxKLBjVWe2TPsGfbl3rEDfZ+OKRZ2j6AC
+6r7jb4TZO3dzF2p6dgbrlU71Y/4K0TdzIjRj3cQ3KSm41JvUQ0hZ/c04iGDg/xWf
++pp58nfPAYwuerruPNWmlStWAXf0UTqRtg4hQDWBuUFDJTuWuuBvEXudz74eh/wK
+sMwfu1HFvjy5Z0iMDU8PUDepjVolOCue9ashlS4EB5IECdSR2TItnAIiIwimx839
+LdUdRudafMu5T5Xma182OC0/u/xRlEm+tvKGGmfFcN0piqVl8OrSPBgIlb+1IKJE
+m/XriWr/Cq4h/JfB7NTsezVslgkBaoU=
+-----END CERTIFICATE-----