zjamnik/UPnPMapper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: zjamnik/UPnPMapper:49435277bbd90eab9d07f52cab4c47771218a993
Branches Tags
zjamnik/UPnPMapper:main
...
compare: zjamnik/UPnPMapper:main
Branches Tags
zjamnik/UPnPMapper:main

10 Commits
49435277bb ... main

Author SHA1 Message Date
zjamnik ebf5479250 added instance sftp port 2026-02-13 12:51:45 +01:00
zjamnik 11f3d01a55 cleanup fix variables mixup 2025-11-27 22:04:30 +01:00
zjamnik b0c9a10da8 cleanup fix 2025-11-27 22:00:25 +01:00
zjamnik 502957a3e7 switch to infinite lease and clenaup 2025-11-27 21:37:50 +01:00
zjamnik 1bdd45660e logging fix 2025-11-27 14:59:34 +01:00
zjamnik e2f2074cea error handling 2025-11-27 14:49:43 +01:00
zjamnik df6b97b679 ip var fix 2025-11-27 14:38:24 +01:00
zjamnik 5fcb7d316f rename execute 2025-11-27 14:37:29 +01:00
zjamnik b14ca0b7be should be working 2025-11-27 14:34:40 +01:00
zjamnik 73f58a62b6 exec check platform test 2025-11-27 14:16:29 +01:00
1 changed files with 97 additions and 135 deletions
Expand all files Collapse all files
upnpMapper.js
+97 -135
View File
@@ -3,7 +3,6 @@ const path = require('path');
const exec = require("child_process").execSync;
var config = null;
const leaseTime = 3600;
function clone(obj) {
return JSON.parse(JSON.stringify(obj));
@@ -48,6 +47,7 @@ async function readFile(file, { format = 'utf8' } = {}) {
async function loadConfig({ configPath = __dirname, configName = 'config.json' } = {}) {
let configDefault = {
"instancesPath": "",
"ip": ""
};
try {
@@ -66,155 +66,117 @@ async function saveConfig({ configPath = __dirname, configName = 'config.json' }
await writeFile(cleanPath(configPath), cleanPath(configName), JSON.stringify(config, null, 4));
}
function getPorts(instancesJSON) {
portList = [];
instances = JSON.parse(instancesJSON);
for (const instance of instances) {
if (instance.DeploymentArgs['GenericModule.App.Ports'] != undefined) {
instancePorts = JSON.parse(instance.DeploymentArgs['GenericModule.App.Ports']);
// 0 - TCP; 1 = UDP; 2 - Both
for (const instancePort of instancePorts) {
switch (instancePort.Protocol) {
case 0:
portList.push({
Name: `${instance.FriendlyName} ${instancePort.Name}`,
Protocol: "TCP",
Number: instancePort.Port
});
break;
case 1:
portList.push({
Name: `${instance.FriendlyName} ${instancePort.Name}`,
Protocol: "UDP",
Number: instancePort.Port
});
break;
case 2:
portList.push({
Name: `${instance.FriendlyName} ${instancePort.Name}`,
Protocol: "TCP",
Number: instancePort.Port
});
portList.push({
Name: `${instance.FriendlyName} ${instancePort.Name}`,
Protocol: "UDP",
Number: instancePort.Port
});
break;
default:
break;
}
}
}
}
return portList;
}
function getUPnPPorts(){
let convertOutput = exec(`upnpc -l`, function (error, stdout, stderr) {
function run(command, consoleOutput = false) {
let convertOutput = exec(command, function (error, stdout, stderr) {
if (error) {
log(`error: ${error.message}`);
if (consoleOutput) {
console.log(`error: ${error.message}`);
}
return;
}
if (stderr) {
log(`stderr: ${stderr}`);
if (consoleOutput) {
console.log(`stderr: ${stderr}`);
}
return;
}
log(`stdout: ${stdout}`);
if (consoleOutput) {
console.log(`stdout: ${stdout}`);
}
});
log(convertOutput.toString());
return `upnpc: miniupnpc library test client, version 2.2.8.
(c) 2005-2024 Thomas Bernard.
More information at https://miniupnp.tuxfamily.org/ or http://miniupnp.free.fr/
List of UPNP devices found on the network :
desc: http://192.168.0.10:80/description.xml
st: urn:schemas-upnp-org:device:basic:1
desc: http://192.168.0.10:80/description.xml
st: uuid:2f402f80-da50-11e1-9b23-001788a03071
desc: http://192.168.0.10:80/description.xml
st: upnp:rootdevice
desc: http://192.168.0.1:1900/rootDesc.xml
st: urn:schemas-upnp-org:device:InternetGatewayDevice:1
Found valid IGD : http://192.168.0.1:1900/ctl/IPConn
Local LAN ip address : 192.168.0.107
Connection Type : IP_Routed
Status : Connected, uptime=572779s, LastConnectionError : ERROR_NONE
Time started : Thu Nov 20 23:02:36 2025
MaxBitRateDown : 8388608 bps (8.3 Mbps) MaxBitRateUp 4194304 bps (4.1 Mbps)
ExternalIPAddress = 78.9.235.162
i protocol exPort->inAddr:inPort description remoteHost leaseTime
0 TCP 11342->192.168.0.69:32400 'Plex Media Server' '' 380785
1 TCP 41341->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
2 UDP 47097->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
3 TCP 11343->192.168.0.150:32400 'Plex Media Server' '' 454675
4 TCP 11344->192.168.0.69:32400 'Plex Media Server' '' 454708
5 TCP 11345->192.168.0.150:32400 'Plex Media Server' '' 454764
6 TCP 11346->192.168.0.69:32400 'Plex Media Server' '' 454769
7 TCP 11347->192.168.0.150:32400 'Plex Media Server' '' 455502
8 TCP 49808->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
9 UDP 44219->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
10 TCP 11348->192.168.0.69:32400 'Plex Media Server' '' 458461
11 TCP 47632->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
12 UDP 43787->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
13 TCP 11349->192.168.0.150:32400 'Plex Media Server' '' 459603
14 TCP 11350->192.168.0.69:32400 'Plex Media Server' '' 459617
15 TCP 43654->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
16 UDP 45931->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
17 TCP 11353->192.168.0.150:32400 'Plex Media Server' '' 496311
18 TCP 44341->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
19 UDP 46373->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
20 TCP 11354->192.168.0.69:32400 'Plex Media Server' '' 496317
21 TCP 30000->192.168.0.107:30000 'Empyrion' '' 0
22 UDP 30000->192.168.0.107:30000 'Empyrion' '' 0
23 UDP 30001->192.168.0.107:30001 'Empyrion' '' 0
24 UDP 30002->192.168.0.107:30002 'Empyrion' '' 0
25 UDP 30003->192.168.0.107:30003 'Empyrion' '' 0
26 TCP 30001->192.168.0.107:30001 'Empyrion' '' 0
27 TCP 30002->192.168.0.107:30002 'Empyrion' '' 0
28 TCP 41655->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
29 UDP 46348->192.168.0.150:63077 'qBittorrent/5.1.4' '' 0
30 TCP 11355->192.168.0.150:32400 'NAT-PMP 11355 tcp' '' 18608
31 TCP 11356->192.168.0.69:32400 'Plex Media Server' '' 537039
32 TCP 11357->192.168.0.150:32400 'Plex Media Server' '' 537058
33 TCP 11358->192.168.0.69:32400 'Plex Media Server' '' 537065
34 UDP 41642->192.168.0.110:41641 'NAT-PMP 41642 udp' '' 5043
35 UDP 41641->192.168.0.69:41641 'NAT-PMP 41641 udp' '' 5288
36 UDP 22437->192.168.0.69:22437 'Parsec' '' 1434
37 UDP 22438->192.168.0.69:22438 'Parsec' '' 1434
38 UDP 22439->192.168.0.69:22439 'Parsec' '' 1434
39 UDP 22440->192.168.0.69:22440 'Parsec' '' 1434
40 UDP 31437->192.168.0.69:31437 'Parsec' '' 1445
41 TCP 11361->192.168.0.20:11361 'NAT-PMP 11361 tcp' '' 3158
42 UDP 11361->192.168.0.20:11361 'NAT-PMP 11361 udp' '' 3158
43 TCP 63077->192.168.0.69:63077 'NAT-PMP 63077 tcp' '' 3361
44 UDP 63077->192.168.0.69:63077 'NAT-PMP 63077 udp' '' 3361
45 TCP 36439->192.168.0.69:36439 'NAT-PMP 36439 tcp' '' 3504
46 UDP 36439->192.168.0.69:36439 'NAT-PMP 36439 udp' '' 3503
47 TCP 30003->192.168.0.107:30003 'Empyrion' '' 69`
return convertOutput.toString();
}
async function main() {
await loadConfig();
portList = getPorts(await readFile(config.instancesPath));
console.log(portList);
const instancesJSON = await readFile(config.instancesPath);
let instancesPorts = "";
const upnpPortList = run('upnpc -l');
// console.log(upnpPortList);
upnpPorts = getUPnPPorts()
for (const instance of JSON.parse(instancesJSON)) {
if (instance.DeploymentArgs['GenericModule.App.Ports'] != undefined) {
// 0 - TCP; 1 = UDP; 2 - Both
for (const instancePort of JSON.parse(instance.DeploymentArgs['GenericModule.App.Ports'])) {
let Name = `AMP ${instance.FriendlyName} ${instancePort.Name}`;
let Number = instancePort.Port;
instancesPorts += `${Name}\n`;
if (!upnpPortList.includes(Name)) {
switch (instancePort.Protocol) {
case 0:
try {
run(`upnpc -e "${Name}" -a ${config.ip} ${Number} ${Number} TCP`);
console.log(`Port added: "${Name}" ${Number} TCP`);
} catch {
console.log(`Port failed: "${Name}" ${Number} TCP`);
}
break;
case 1:
try {
run(`upnpc -e "${Name}" -a ${config.ip} ${Number} ${Number} UDP`);
console.log(`Port added: "${Name}" ${Number} UDP`);
} catch {
console.log(`Port failed: "${Name}" ${Number} UDP`);
}
break;
case 2:
try {
run(`upnpc -e "${Name}" -a ${config.ip} ${Number} ${Number} TCP`);
console.log(`Port added: "${Name}" ${Number} TCP`);
} catch {
console.log(`Port failed: "${Name}" ${Number} TCP`);
}
try {
run(`upnpc -e "${Name}" -a ${config.ip} ${Number} ${Number} UDP`);
console.log(`Port added: "${Name}" ${Number} UDP`);
} catch {
console.log(`Port failed: "${Name}" ${Number} UDP`);
}
break;
default:
break;
}
}
}
}
if (instance.DeploymentArgs['FileManagerPlugin.SFTP.SFTPPortNumber'] != undefined) {
let Name = `AMP ${instance.FriendlyName} SFTP`;
let Number = instance.DeploymentArgs['FileManagerPlugin.SFTP.SFTPPortNumber'];
instancesPorts += `${Name}\n`;
if (!upnpPortList.includes(Name)) {
try {
run(`upnpc -e "${Name}" -a ${config.ip} ${Number} ${Number} TCP`);
console.log(`Port added: "${Name}" ${Number} TCP`);
} catch (error) {
console.log(`Port failed: "${Name}" ${Number} TCP`);
}
}
}
}
// Delete all AMP
// for (const portMap of upnpPortList.split('\n')) {
// if (portMap.includes("AMP")) {
// let found = portMap.match(/ *\d+ +(\w+) +(\d+).*/);
// run(`upnpc -d ${found[2]} ${found[1]}`);
// }
// }
for (const portMap of upnpPortList.split('\n')) {
if (portMap.includes("AMP") && !instancesPorts.includes(portMap.split("'")[1])) {
let found = portMap.match(/ *\d+ +(\w+) +(\d+).*/);
console.log(`Remove ${found[2]} ${found[1]}`);
run(`upnpc -d ${found[2]} ${found[1]}`);
}
}
}
main();