add pingpong producers consumers, emit pingpong from ws

server/docs/swagger_output.json

@@ -60,6 +60,16 @@
         }
       }
     },
+    "/api/ping": {
+      "get": {
+        "description": "",
+        "responses": {
+          "default": {
+            "description": ""
+          }
+        }
+      }
+    },
     "/api/spotify/login": {
       "get": {
         "tags": [

server/events/consumers.ts

@@ -1,7 +1,8 @@
-import { createConsumer } from '@jukebox/lib'
+import { createConsumer, logger } from '@jukebox/lib'
 
 export const registerConsumers = async () => {
   createConsumer('ping-pong', (data) => {
-    console.log('pong')
+    const logData = data ?? 'No data received.'
+    logger.info(`Pong: ${logData}`)
   })
 }

server/events/producers.ts

@@ -0,0 +1,3 @@
+import { createProducer } from '@jukebox/lib'
+
+export const producePing = createProducer('ping-pong')

server/routes/router.ts

@@ -1,13 +1,14 @@
 import { Router } from 'express'
+import { docsMiddleware } from '../middleware/docsMiddleware'
 import * as baseViews from '../views/baseViews'
 import { groupRoutes } from './groupRoutes'
 import { spotifyRouter } from './spotifyRoutes'
 import { userRouter } from './userRoutes'
-import { docsMiddleware } from '../middleware/docsMiddleware'
 
 const router = Router()
 router.get('/', baseViews.healthcheck)
 router.get('/api', baseViews.apiHelp)
+router.get('/api/ping', baseViews.pingPongView)
 
 router.use(docsMiddleware)
 router.use('/api/spotify', spotifyRouter)

server/views/baseViews.ts

@@ -1,3 +1,4 @@
+import { producePing } from 'server/events/producers'
 import { apiRequest } from 'server/utils'
 
 /**
@@ -35,3 +36,8 @@ export const apiHelp = apiRequest((req, res) => {
     documenation: `${baseUrl}/api/docs/`
   }
 })
+
+export const pingPongView = apiRequest((req, res) => {
+  const data = 'Ping from api.'
+  producePing(new Date().toLocaleTimeString(), data)
+})

tsconfig.json

@@ -38,7 +38,7 @@
       "server/*": ["./server/*"],
       "websocket/*": ["./websocket/*"],
       "common/*": ["./common/*"],
-      "*": ["./*", "./server/*", "./websocket/*", "./common/*"]
+      "*": ["./*", "./server/*", "./websocket/*",]
     } /* Specify a set of entries that re-map imports to additional lookup locations. */,
     // "rootDirs": [],                                   /* Allow multiple folders to be treated as one when resolving modules. */
     "typeRoots": [

websocket/events/consumers.ts

@@ -0,0 +1,14 @@
+/**
+ * Kafka Consumers
+ */
+
+import { createConsumer, logger } from '@jukebox/lib'
+import { socketEmit } from 'websocket/lib'
+
+export const registerKafkaConsumers = () => {
+  createConsumer('ping-pong', (data) => {
+    socketEmit('ping-pong', data)
+    const logData = data ?? 'No data received.'
+    logger.info(`Pong: ${logData}`)
+  })
+}

websocket/events/index.ts

@@ -3,4 +3,4 @@
  * @description Manage ingress and egress of data from Kafka
  * or other event driven data controllers.
  */
-export * from './kafkaConsumers'
+export * from './consumers'

websocket/events/producers.ts

@@ -0,0 +1,7 @@
+/**
+ * Kafka Producers
+ */
+
+import { createProducer } from '@jukebox/lib'
+
+export const producePing = createProducer('ping-pong')

websocket/events/socketHandlers.ts

@@ -1,8 +1,10 @@
 import { handleSocketSubscribe } from 'websocket/controllers'
 import type { CustomSocket, SocketNext } from 'websocket/types'
+import { producePing } from './producers'
 
 export const socketHandlers = (socket: CustomSocket, next: SocketNext) => {
   socket.on('subscribe', (data) => handleSocketSubscribe(socket, data))
+  socket.on('ping-pong', (data) => producePing(new Date().toLocaleTimeString(), data))
 
   next()
 }