Added RECORDING_CREATED event

zmilan · Jul 29, 2020 · f938dd7 · f938dd7
1 parent 5684d7d
commit f938dd7
Show file tree

Hide file tree

Showing 4 changed files with 24 additions and 1 deletion.
diff --git a/mods/voice/package.json b/mods/voice/package.json
@@ -35,6 +35,7 @@
   },
   "dependencies": {
     "@fonos/logger": "^0.0.29",
+    "@fonos/events": "^0.0.29",
     "@fonos/tts": "^0.0.29",
     "objectid": "^3.2.1"
   }

diff --git a/mods/voice/src/events.ts b/mods/voice/src/events.ts
@@ -0,0 +1,16 @@
+import { EventsSender } from '@fonos/events'
+import logger from '@fonos/logger'
+
+let instance: any
+
+try {
+  if (!process.env.EVENTS_BROKERS)
+    throw 'core.common.events [environment variable EVENTS_BROKERS not set]'
+  const brokers = process.env.EVENTS_BROKERS.split(',')
+  instance = new EventsSender(brokers, process.env.EVENTS_QUEUE)
+  instance.connect()
+} catch (e) {
+  logger.error(e)
+}
+
+export default instance
diff --git a/mods/voice/src/record.ts b/mods/voice/src/record.ts
@@ -1,4 +1,5 @@
 import Verb from './verb'
+import events from './events'
 
 const objectid = require('objectid')
 
@@ -68,6 +69,10 @@ class Record extends Verb {
       this.config.bucket
     )
 
+    events.sendToQ('RECORDING_CREATED', {
+      filename
+    })
+
     return {
       keyPressed: res.attributes.result,
       recordingUri,

diff --git a/mods/voice/tsconfig.json b/mods/voice/tsconfig.json
@@ -6,7 +6,8 @@
   },
   "references": [
     { "path":  "../tts" },
-    { "path":  "../logger" }
+    { "path":  "../logger" },
+    { "path":  "../events" }
   ],   
   "exclude": [
     "node_modules",