summaryrefslogtreecommitdiff
path: root/packages/backend/src/misc/antenna-cache.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/backend/src/misc/antenna-cache.ts')
-rw-r--r--packages/backend/src/misc/antenna-cache.ts36
1 files changed, 0 insertions, 36 deletions
diff --git a/packages/backend/src/misc/antenna-cache.ts b/packages/backend/src/misc/antenna-cache.ts
deleted file mode 100644
index dcf96c1610..0000000000
--- a/packages/backend/src/misc/antenna-cache.ts
+++ /dev/null
@@ -1,36 +0,0 @@
-import { Antennas } from '@/models/index.js';
-import { Antenna } from '@/models/entities/antenna.js';
-import { subsdcriber } from '../db/redis.js';
-
-let antennasFetched = false;
-let antennas: Antenna[] = [];
-
-export async function getAntennas() {
- if (!antennasFetched) {
- antennas = await Antennas.find();
- antennasFetched = true;
- }
-
- return antennas;
-}
-
-subsdcriber.on('message', async (_, data) => {
- const obj = JSON.parse(data);
-
- if (obj.channel === 'internal') {
- const { type, body } = obj.message;
- switch (type) {
- case 'antennaCreated':
- antennas.push(body);
- break;
- case 'antennaUpdated':
- antennas[antennas.findIndex(a => a.id === body.id)] = body;
- break;
- case 'antennaDeleted':
- antennas = antennas.filter(a => a.id !== body.id);
- break;
- default:
- break;
- }
- }
-});