index.js

@@ -1,120 +1,81 @@
-const blocked = [
+require("dotenv").config({quiet: true});
-	'0',
+const exec = require("child_process").exec;
-	'0000',
+const Discord = require("discord.js");
-	'9998',
-	'9999'
-];
-
-import dotenv from 'dotenv';
-dotenv.config({ quiet: true })
-import AMISocket from 'ami';
-const sock = new AMISocket({
-	connect: {
-		host: '127.0.0.1',
-		port: 5038
-	},
-	credentials: {
-		username: process.env.AMI_USER,
-		secret: process.env.AMI_SECRET
-	},
-	events: true
-})
-import Discord from 'discord.js';
 const hook = new Discord.WebhookClient({ url: process.env.DISCORD_WEBHOOK_URL });
 
 const cfTypes = {
-	CF: "Unconditional",
+    CF: "Unconditional",
-	CFB: "Busy",
+    CFB: "Busy",
-	CFU: "Unavailable",
+    CFU: "Unavailable",
 }
 
-const main = () => {
+const main = async () => {
-	var respData = [];
+    const runAsterisk = (command) =>
-	console.log('checking')
+        new Promise((resolve) =>
-	// getList for CF, CFB, CFU
+            exec(command, (error, stdout, stderr) => resolve({ error, stdout, stderr }))
-	sock.getList({
+        );
-		action: 'DBGetTree',
-		family: 'CF'
-	}).then(async (response) => {
-		// Responses are an array of objects. The first should always have eventlist: 'start', and last should have eventlist: 'complete'. Remove these, make an array of objects {key, val} based on the rest of the response objects.
-		let entries = response.filter(r => r.eventlist !== 'start' && r.eventlist !== 'Complete').map(r => ({ key: r.key, val: r.val }));
-		for (let entry of entries) {
-			let stuff = entry.key.split('/');
-			let type = stuff[1];
-			let ext = stuff[2];
-			console
-			respData.push({
-				extension: ext,
-				type: type,
-				target: entry.val
-			});
-		}
 
-	}).then(() => {
+    try {
-		sock.getList({
+        var forwards = {};
-			action: 'DBGetTree',
+        const commands = [
-			family: 'CFB'
+            'asterisk -x "database show CF"',
-		}).then(async (response) => {
+            'asterisk -x "database show CFB"',
-			let entries = response.filter(r => r.eventlist !== 'start' && r.eventlist !== 'Complete').map(r => ({ key: r.key, val: r.val }));
+            'asterisk -x "database show CFU"',
-			for (let entry of entries) {
+        ];
-				let stuff = entry.key.split('/');
+        for (const command of commands) {
-				let type = stuff[1];
+            const { error, stdout, stderr } = await runAsterisk(command);
-				let ext = stuff[2];
+            if (error) {
-				console
+                console.error(`Error executing command "${command}": ${error}`);
-				respData.push({
+                continue;
-					extension: ext,
+            }
-					type: type,
+
-					target: entry.val
+            const lines = stdout.split('\n');
-				});
+            for (const line of lines) {
-			}
+                const match = line.match(/^\/(CF|CFB|CFU)\/(\d+)\s+:\s+(.+)$/);
-		}).then(() => {
+                if (match) {
-			sock.getList({
+                    const type = match[1];
-				action: 'DBGetTree',
+                    const extension = match[2];
-				family: 'CFU'
+                    const target = match[3];
-			}).then(async (response) => {
+
-				let entries = response.filter(r => r.eventlist !== 'start' && r.eventlist !== 'Complete').map(r => ({ key: r.key, val: r.val }));
+                    forwards[`${type}/${extension}`] = target.replace(/\s+$/, '');
-				for (let entry of entries) {
+                }
-					let stuff = entry.key.split('/');
+            }
-					let type = stuff[1];
+        }
-					let ext = stuff[2];
+        
-					console
+        // Search all forwards for any target that is between 700 and 800. If it exists, log to console and run `asterisk -x "database del CF[U/B] <ext>"` to delete it
-					respData.push({
+        for (const [key, target] of Object.entries(forwards)) {
-						extension: ext,
+            const targetExt = parseInt(target, 10);
-						type: type,
+            if ((targetExt >= 700 && targetExt < 800) || targetExt === 0) { // Also block forwards to 0 (operator line)
-						target: entry.val
+                console.log(`Deleting forward ${key} to target ${target}`);
-					});
+                await hook.send(`Fuckass with extension ${key.split('/')[1]} tried to forward to ${target}. ${cfTypes[key.split('/')[0]]} Forward has been deleted.`);
-				}
+                const delCommand = `asterisk -x "database del ${key.replace('/', ' ')}"`;
-			}).then(() => {
+                const { error, stdout, stderr } = await runAsterisk(delCommand);
-				console.log(`Found ${respData.length} call forwards.`);
+                if (error) {
-				for (let cf of respData) {
+                    console.error(`Error executing command "${delCommand}": ${error}`);
-					// Check if forward target is anything in the 700-800 range, or is a number in the blocked list
+                } else {
-					if ((cf.target >= 700 && cf.target < 800) || blocked.includes(cf.target)) {
+                    console.log(`Successfully deleted forward ${key}`);
-						// Violation. Remove call forward from db.
+                }
-						console.log(`---> Violation found on extension ${cf.extension}. Removing call forward to ${cf.target}`);
+            }
-						sock.send({
+        }
-							action: 'DBDel',
+    } catch (err) {
-							family: cf.type,
+        console.error(`Unexpected error: ${err}`);
-							key: cf.extension
+    }
-						}).then((resp) => {
+    setTimeout(main, process.env.CHECK_INTERVAL * 1000); // Run every CHECK_INTERVAL seconds
-							console.log(`-----> Call forward removed successfully.`);
+};
-							hook.send(`:no_entry: **Call Forward Removed** :no_entry:\nExtension **${cf.extension}** had a **${cfTypes[cf.type]}** call forward to **${cf.target}** The call forward has been removed.`);
-						})
-					}
-				};
-				setTimeout(main, 5000); // Repeat every 60 seconds
-			});
-		});
-	})
-}
 
 const startup = async () => {
-	sock.connect().then(() => {
+    // Run `asterisk -x "core show version"` to get the Asterisk version. If it fails, wait 10 seconds before running main again
-		console.log(sock.amiVersion)
+    exec('asterisk -x "core show version"', (error, stdout, stderr) => {
-		main();
+        if (error) {
-	}).catch((err) => {
+            console.error(`Error executing command: ${error}`);
-		console.error('Error connecting to AMI:', err);
+            console.log("Asterisk is not running. Retrying in 10 seconds...");
-		setTimeout(startup, 10000); // Retry after 10 seconds
+            setTimeout(startup, 10000);
-	});
+            return;
+        }
+        const version = stdout.trim();
+        console.log(`Asterisk version: ${version}`);
+        main();
+    });
 }
 
-startup(); 
+startup();

package-lock.json

@@ -9,7 +9,6 @@
       "version": "1.0.0",
       "license": "ISC",
       "dependencies": {
-        "ami": "^1.0.0",
         "discord.js": "^14.24.0",
         "dotenv": "^17.2.3"
       }
@@ -202,15 +201,6 @@
         "npm": ">=7.0.0"
       }
     },
-    "node_modules/ami": {
-      "version": "1.0.0",
-      "resolved": "https://registry.npmjs.org/ami/-/ami-1.0.0.tgz",
-      "integrity": "sha512-wkuxJl8ahQ4FYVwXvtJpQ7wuRUAqD30ueVpeJ1t5UyYqjzh+GtmrnaeHrXzzp+KO3ukhHZoMrsZlKB0j91oAlw==",
-      "license": "MIT",
-      "engines": {
-        "node": ">=14.0.0"
-      }
-    },
     "node_modules/discord-api-types": {
       "version": "0.38.31",
       "resolved": "https://registry.npmjs.org/discord-api-types/-/discord-api-types-0.38.31.tgz",

package.json

@@ -9,9 +9,8 @@
   "keywords": [],
   "author": "",
   "license": "ISC",
-  "type": "module",
+  "type": "commonjs",
   "dependencies": {
-    "ami": "^1.0.0",
     "discord.js": "^14.24.0",
     "dotenv": "^17.2.3"
   }