notification update

src/controllers/EquipmentController.ts

@@ -5,7 +5,7 @@ import { sequelize } from '../database'
 import { networkError } from './Error'
 import { Site } from '../database/models/Site'
 import { EquipmentData } from '../database/models/EquipmentData'
-import { sendAlarm } from '../firebase'
+import { sendUpdateRequest } from '../firebase'
 
 class EquipmentController {
   async getEquipments(req: Request, res: Response) {
@@ -67,15 +67,12 @@ class EquipmentController {
         statusId = 3
         break
 
-      case 'SOS':
-        statusId = 3
-
       default:
         statusId = 1
         break
     }
 
-    EquipmentData.create({
+    await EquipmentData.create({
       ap_id: req.body.APID,
       aid_id: req.body.AidID,
       beacon_id: req.body.Baecon,
@@ -85,6 +82,8 @@ class EquipmentController {
       longitude: req.body.GPS_Lon
     })
 
+    sendUpdateRequest()
+
     res.json({ message: 'ok' })
   }
 }

src/firebase.ts

@@ -9,6 +9,25 @@ export function initializeFirebase() {
   })
 }
 
+export function sendUpdateRequest() {
+  var message: admin.messaging.Message = {
+    data: {
+      type: 'update request'
+    },
+    topic: 'maa'
+  }
+
+  admin
+    .messaging()
+    .send(message)
+    .then(response => {
+      console.log('Message sent', response)
+    })
+    .catch(error => {
+      console.log('Message error ', error)
+    })
+}
+
 export function sendAlarm(equipmentName: string, alarmType: string) {
   var message: admin.messaging.Message = {
     data: {