GitHub/trunk-server
1
0
Fork 0
mirror of https://github.com/openmhz/trunk-server.git synced 2026-11-13 09:17:30 -05:00
Code Issues Packages Projects Releases Wiki Activity

a saner method for loading systems

Browse Source
This commit is contained in:
Luke Berndt
2024-08-26 21:13:05 -04:00
parent cdd8fa8055
commit b9921a4a70
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
backend/controllers/systems.js
View File

@@ -2,6 +2,7 @@ var mongoose = require("mongoose");
var User = require("../models/user"); var User = require("../models/user");
var System = require("../models/system"); var System = require("../models/system");
const Mailjet = require('node-mailjet'); const Mailjet = require('node-mailjet');
var schedule = require('node-schedule');
var admin_email = process.env['REACT_APP_ADMIN_EMAIL'] != null ? process.env['REACT_APP_ADMIN_EMAIL'] : "luke@openmhz.com"; var admin_email = process.env['REACT_APP_ADMIN_EMAIL'] != null ? process.env['REACT_APP_ADMIN_EMAIL'] : "luke@openmhz.com";
var admin_server = process.env['REACT_APP_ADMIN_SERVER'] != null ? process.env['REACT_APP_ADMIN_SERVER'] : "https://admin.openmhz.com"; var admin_server = process.env['REACT_APP_ADMIN_SERVER'] != null ? process.env['REACT_APP_ADMIN_SERVER'] : "https://admin.openmhz.com";
@@ -13,7 +14,6 @@ const mailjet = new Mailjet({
}); });
var systemList = []; var systemList = [];
var systemListTime = Date.now();
exports.contact_system = async function (req, res) { exports.contact_system = async function (req, res) {
var system = await System.findOne({ var system = await System.findOne({
@@ -111,7 +111,7 @@ async function load_systems(systemClients) {
for (var result in results) { for (var result in results) {
var clientCount = 0; var clientCount = 0;
if (systemClients.hasOwnProperty(results[result].shortName)) { if (systemClients && systemClients.hasOwnProperty(results[result].shortName)) {
clientCount = systemClients[results[result].shortName]; clientCount = systemClients[results[result].shortName];
} }
var system = { var system = {
@@ -146,11 +146,12 @@ async function load_systems(systemClients) {
exports.get_systems = async function (req, res) { exports.get_systems = async function (req, res) {
/* going to use a cron job to update the system list every 2 minutes
if ((systemList.length == 0) || (systemListTime < (Date.now() - 60 * 1000 * 2))) { if ((systemList.length == 0) || (systemListTime < (Date.now() - 60 * 1000 * 2))) {
console.log("Loading Systems - systemTime: " + systemListTime + " compare to: " + (Date.now() - 60 * 1000 * 2)); console.log("Loading Systems - systemTime: " + systemListTime + " compare to: " + (Date.now() - 60 * 1000 * 2));
systemListTime = Date.now(); // set this first to prevent multiple calls to load_systems systemListTime = Date.now(); // set this first to prevent multiple calls to load_systems
await load_systems(req.systemClients); await load_systems(req.systemClients);
} }*/
res.contentType('json'); res.contentType('json');
res.send(JSON.stringify({ res.send(JSON.stringify({
@@ -193,3 +194,9 @@ exports.authorize_system = async function (req, res) {
} }
load_systems(clients);
var statSched = schedule.scheduleJob('*/5 * * * *', function() {
load_systems(clients);
});