alias: send sync message to web server

package.json

@@ -1,6 +1,6 @@
 {
   "name": "dm-manager",
-  "version": "1.9.1",
+  "version": "1.9.2",
   "private": true,
   "dependencies": {
     "@babel/core": "^7.16.0",

server/config.js

@@ -45,7 +45,7 @@ class Options {
             UNIPI_TOKEN: "",
             UNIPI_TOKENARPI: "",
             UNIPI_TOKENARPILINK: "",
-
+            WEB_PAGES_SERVER_UPDATE_URL: "http://web.cdc:8000/alias/reload",
         }
         Object.entries(options).forEach(([key, val]) => {
             this[key] = process.env[key] || val

server/controllers/processes/urls.js

@@ -1,13 +1,18 @@
 const express = require('express')
 const assert = require('assert')
 const { ObjectId } = require('mongoose').Types
+const axios = require('axios')
 
 const Url = require('../../models/Url')
 const { log } = require('../middleware')
 
 const router = express.Router()
 module.exports = router
 
+const config = require('../../config')
+const { sync } = require('resolve')
+
+
 router.get('/', async (req, res) => {    
     if (!req.user) {
         res.status(401).json({
@@ -23,6 +28,20 @@ router.get('/', async (req, res) => {
     res.json({ data })
 })
 
+async function sync_web_server() {
+    // make a GET request to http://web.cdc:8000/alias/reload
+    // and check for error code
+    const url = config.WEB_PAGES_SERVER_UPDATE_URL
+    try {
+        const response = await axios.get(url)
+        console.log(`sync_web_server: ${response.status} ${response.statusText}`)
+        return true
+    } catch(error) {
+        console.error(`sync_web_server: ${error}`)
+        return false
+    }
+}
+
 router.delete('/:id', async (req, res) => {
     console.log(`my DELETE ${req.params.id}`)
     try {
@@ -40,6 +59,9 @@ router.delete('/:id', async (req, res) => {
                 error: "Cannot delete urls created by other users"
             })
         }
+
+        if (!await sync_web_server()) return res.status(500).json({error: "web server sync failed"})
+
     } catch(error) {
         res.status(400).json({
             error: error.message
@@ -157,6 +179,9 @@ router.patch('/:id', async (req, res) => {
         await url.save()
 //        await notifySeminar(seminar)
         await log(req, was, payload)
+
+        if (!await sync_web_server()) return res.status(500).json({error: "web server sync failed"})
+
         res.send({})
     }
     catch (error) {
@@ -186,6 +211,9 @@ router.put('/', async (req, res) => {
         await url.save()
 //        await notifySeminar(seminar)
         await log(req, {}, payload)
+
+        if (!await sync_web_server()) return res.status(500).json({error: "web server sync failed"})
+
         res.send({})
     }
     catch (error) {