feat: function para consolidar mensagens do hub

Author: 1cadumagalhaes

functions/hub-receive-message/index.js

@@ -0,0 +1,9 @@
+/**
+ * Triggered from a message on a Cloud Pub/Sub topic.
+ *
+ * @param {!Object} event Event payload.
+ * @param {!Object} context Metadata for the event.
+ */
+
+const { receiveMessage } = require('./hub.js')
+exports.receiveMessage = receiveMessage;

functions/hub-receive-message/package.json

@@ -0,0 +1,13 @@
+{
+    "name": "hub-receive-message",
+    "version": "1.0.0",
+    "main": "index.js",
+    "author": "DP6",
+    "license": "ISC",
+    "description": "",
+    "dependencies": {
+        "@google-cloud/bigquery": "^5.5.0",
+        "@google-cloud/firestore": "^4.9.8",
+        "@google-cloud/pubsub": "^2.10.0"
+    }
+}

gulpfile.js

@@ -54,6 +54,18 @@ function zipExtract() {
         .pipe(dest('dist'))
 }
 
+//Receive hub messages
+function moveHub() {
+    return src('src/hub.js').pipe(dest('functions/hub-receive-message/'));
+}
+
+function zipHubMessage() {
+    return src('functions/hub-receive-message')
+        .pipe(zip('hub-receive-message.zip'))
+        .pipe(dest('dist'))
+}
+
+
 function test() {
     return src(['test/*.js']).pipe(mocha());
 }
@@ -62,7 +74,7 @@ function test() {
 
 exports.build = series(
     test,
-    parallel(extractJson, convertHub, convertFirestore),
+    parallel(extractJson, convertHub, convertFirestore, moveHub),
     parallel(saveFile, extractEvents, formatEvents, extractHub, extractFirestore),
-    parallel(zipConvert, zipExtract)
+    parallel(zipConvert, zipExtract, zipHubMessage)
 );