mirror of
https://github.com/nymurbd/MikroTik-scripts.git
synced 2025-08-02 17:24:36 +02:00
rename scripts and add file extension ".rsc"
No functional change for the user... The migration is done automatically.
This commit is contained in:
Christian Hesse
parent
1e6e0646e2
commit
a832fd04ef
125 changed files with 5622 additions and 5175 deletions
|
|
@ -1,65 +1,3 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/bridge-port-to
|
||||
# Copyright (c) 2013-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
#
|
||||
# reset bridge ports to default bridge
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/doc/mod/bridge-port-to.md
|
||||
|
||||
:global BridgePortTo;
|
||||
|
||||
:set BridgePortTo do={
|
||||
:local BridgePortTo [ :tostr $1 ];
|
||||
|
||||
:global IfThenElse;
|
||||
:global LogPrintExit2;
|
||||
:global ParseKeyValueStore;
|
||||
|
||||
:local InterfaceReEnable ({});
|
||||
:foreach BridgePort in=[ /interface/bridge/port/find where !(comment=[]) ] do={
|
||||
:local BridgePortVal [ /interface/bridge/port/get $BridgePort ];
|
||||
:foreach Config,BridgeDefault in=[ $ParseKeyValueStore ($BridgePortVal->"comment") ] do={
|
||||
:if ($Config = $BridgePortTo) do={
|
||||
:local DHCPClient [ /ip/dhcp-client/find where interface=$BridgePortVal->"interface" comment="toggle with bridge port" ];
|
||||
|
||||
:if ($BridgeDefault = "dhcp-client") do={
|
||||
:if ([ :len $DHCPClient ] != 1) do={
|
||||
$LogPrintExit2 warning $0 ([ $IfThenElse ([ :len $DHCPClient ] = 0) "Missing" "Duplicate" ] . \
|
||||
" dhcp client configuration for interface " . $BridgePortVal->"interface" . "!") true;
|
||||
}
|
||||
:local DHCPClientDisabled [ /ip/dhcp-client/get $DHCPClient disabled ];
|
||||
|
||||
:if ($BridgePortVal->"disabled" = false || $DHCPClientDisabled = true) do={
|
||||
$LogPrintExit2 info $0 ("Disabling bridge port for interface " . $BridgePortVal->"interface" . ", enabling dhcp client.") false;
|
||||
/interface/bridge/port/disable $BridgePort;
|
||||
:delay 200ms;
|
||||
/ip/dhcp-client/enable $DHCPClient;
|
||||
}
|
||||
} else={
|
||||
:if ($BridgePortVal->"disabled" = true || $BridgeDefault != $BridgePortVal->"bridge") do={
|
||||
$LogPrintExit2 info $0 ("Enabling bridge port for interface " . $BridgePortVal->"interface" . ", changing to " . $BridgePortTo . \
|
||||
" bridge " . $BridgeDefault . ", disabling dhcp client.") false;
|
||||
:if ([ :len $DHCPClient ] = 1) do={
|
||||
/ip/dhcp-client/disable $DHCPClient;
|
||||
:delay 200ms;
|
||||
}
|
||||
:local Disable [ /interface/ethernet/find where name=$BridgePortVal->"interface" ];
|
||||
:if ([ :len $Disable ] > 0) do={
|
||||
/interface/ethernet/disable $Disable;
|
||||
:set InterfaceReEnable ($InterfaceReEnable, $Disable);
|
||||
}
|
||||
/interface/bridge/port/set disabled=no bridge=$BridgeDefault $BridgePort;
|
||||
} else={
|
||||
$LogPrintExit2 debug $0 ("Interface " . $BridgePortVal->"interface" . " already connected to " . $BridgePortTo . \
|
||||
" bridge " . $BridgeDefault . ".") false;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
:if ([ :len $InterfaceReEnable ] > 0) do={
|
||||
:delay 2s;
|
||||
$LogPrintExit2 info $0 ("Re-enabling interfaces...") false;
|
||||
/interface/ethernet/enable $InterfaceReEnable;
|
||||
}
|
||||
}
|
||||
# dummy for migration
|
||||
|
|
|
|||
65
mod/bridge-port-to.rsc
Normal file
65
mod/bridge-port-to.rsc
Normal file
|
|
@ -0,0 +1,65 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/bridge-port-to
|
||||
# Copyright (c) 2013-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
#
|
||||
# reset bridge ports to default bridge
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/doc/mod/bridge-port-to.md
|
||||
|
||||
:global BridgePortTo;
|
||||
|
||||
:set BridgePortTo do={
|
||||
:local BridgePortTo [ :tostr $1 ];
|
||||
|
||||
:global IfThenElse;
|
||||
:global LogPrintExit2;
|
||||
:global ParseKeyValueStore;
|
||||
|
||||
:local InterfaceReEnable ({});
|
||||
:foreach BridgePort in=[ /interface/bridge/port/find where !(comment=[]) ] do={
|
||||
:local BridgePortVal [ /interface/bridge/port/get $BridgePort ];
|
||||
:foreach Config,BridgeDefault in=[ $ParseKeyValueStore ($BridgePortVal->"comment") ] do={
|
||||
:if ($Config = $BridgePortTo) do={
|
||||
:local DHCPClient [ /ip/dhcp-client/find where interface=$BridgePortVal->"interface" comment="toggle with bridge port" ];
|
||||
|
||||
:if ($BridgeDefault = "dhcp-client") do={
|
||||
:if ([ :len $DHCPClient ] != 1) do={
|
||||
$LogPrintExit2 warning $0 ([ $IfThenElse ([ :len $DHCPClient ] = 0) "Missing" "Duplicate" ] . \
|
||||
" dhcp client configuration for interface " . $BridgePortVal->"interface" . "!") true;
|
||||
}
|
||||
:local DHCPClientDisabled [ /ip/dhcp-client/get $DHCPClient disabled ];
|
||||
|
||||
:if ($BridgePortVal->"disabled" = false || $DHCPClientDisabled = true) do={
|
||||
$LogPrintExit2 info $0 ("Disabling bridge port for interface " . $BridgePortVal->"interface" . ", enabling dhcp client.") false;
|
||||
/interface/bridge/port/disable $BridgePort;
|
||||
:delay 200ms;
|
||||
/ip/dhcp-client/enable $DHCPClient;
|
||||
}
|
||||
} else={
|
||||
:if ($BridgePortVal->"disabled" = true || $BridgeDefault != $BridgePortVal->"bridge") do={
|
||||
$LogPrintExit2 info $0 ("Enabling bridge port for interface " . $BridgePortVal->"interface" . ", changing to " . $BridgePortTo . \
|
||||
" bridge " . $BridgeDefault . ", disabling dhcp client.") false;
|
||||
:if ([ :len $DHCPClient ] = 1) do={
|
||||
/ip/dhcp-client/disable $DHCPClient;
|
||||
:delay 200ms;
|
||||
}
|
||||
:local Disable [ /interface/ethernet/find where name=$BridgePortVal->"interface" ];
|
||||
:if ([ :len $Disable ] > 0) do={
|
||||
/interface/ethernet/disable $Disable;
|
||||
:set InterfaceReEnable ($InterfaceReEnable, $Disable);
|
||||
}
|
||||
/interface/bridge/port/set disabled=no bridge=$BridgeDefault $BridgePort;
|
||||
} else={
|
||||
$LogPrintExit2 debug $0 ("Interface " . $BridgePortVal->"interface" . " already connected to " . $BridgePortTo . \
|
||||
" bridge " . $BridgeDefault . ".") false;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
:if ([ :len $InterfaceReEnable ] > 0) do={
|
||||
:delay 2s;
|
||||
$LogPrintExit2 info $0 ("Re-enabling interfaces...") false;
|
||||
/interface/ethernet/enable $InterfaceReEnable;
|
||||
}
|
||||
}
|
||||
|
|
@ -1,73 +1,3 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/bridge-port-vlan
|
||||
# Copyright (c) 2013-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
#
|
||||
# manage VLANs on bridge ports
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/doc/mod/bridge-port-vlan.md
|
||||
|
||||
:global BridgePortVlan;
|
||||
|
||||
:global BridgePortVlan do={
|
||||
:local ConfigTo [ :tostr $1 ];
|
||||
|
||||
:global IfThenElse;
|
||||
:global LogPrintExit2;
|
||||
:global ParseKeyValueStore;
|
||||
|
||||
:local InterfaceReEnable ({});
|
||||
:foreach BridgePort in=[ /interface/bridge/port/find where !(comment=[]) ] do={
|
||||
:local BridgePortVal [ /interface/bridge/port/get $BridgePort ];
|
||||
:foreach Config,Vlan in=[ $ParseKeyValueStore ($BridgePortVal->"comment") ] do={
|
||||
:if ($Config = $ConfigTo) do={
|
||||
:local DHCPClient [ /ip/dhcp-client/find where interface=$BridgePortVal->"interface" comment="toggle with bridge port" ];
|
||||
|
||||
:if ($Vlan = "dhcp-client") do={
|
||||
:if ([ :len $DHCPClient ] != 1) do={
|
||||
$LogPrintExit2 warning $0 ([ $IfThenElse ([ :len $DHCPClient ] = 0) "Missing" "Duplicate" ] . \
|
||||
" dhcp client configuration for interface " . $BridgePortVal->"interface" . "!") true;
|
||||
}
|
||||
:local DHCPClientDisabled [ /ip/dhcp-client/get $DHCPClient disabled ];
|
||||
|
||||
:if ($BridgePortVal->"disabled" = false || $DHCPClientDisabled = true) do={
|
||||
$LogPrintExit2 info $0 ("Disabling bridge port for interface " . $BridgePortVal->"interface" . ", enabling dhcp client.") false;
|
||||
/interface/bridge/port/disable $BridgePort;
|
||||
:delay 200ms;
|
||||
/ip/dhcp-client/enable $DHCPClient;
|
||||
}
|
||||
} else={
|
||||
:local VlanName $Vlan;
|
||||
:if ($Vlan != [ :tostr [ :tonum $Vlan ] ]) do={
|
||||
:do {
|
||||
:set $Vlan ([ /interface/bridge/vlan/get [ find where comment=$Vlan ] vlan-ids ]->0);
|
||||
} on-error={
|
||||
$LogPrintExit2 warning $0 ("Could not find VLAN '" . $Vlan . "' for interface " . $BridgePortVal->"interface" . "!") true;
|
||||
}
|
||||
}
|
||||
:if ($BridgePortVal->"disabled" = true || $Vlan != $BridgePortVal->"pvid") do={
|
||||
$LogPrintExit2 info $0 ("Enabling bridge port for interface " . $BridgePortVal->"interface" . ", changing to " . $ConfigTo . \
|
||||
" vlan " . $Vlan . [ $IfThenElse ($Vlan != $VlanName) (" (" . $VlanName . ")") ] . ", disabling dhcp client.") false;
|
||||
:if ([ :len $DHCPClient ] = 1) do={
|
||||
/ip/dhcp-client/disable $DHCPClient;
|
||||
:delay 200ms;
|
||||
}
|
||||
:local Disable [ /interface/ethernet/find where name=$BridgePortVal->"interface" ];
|
||||
:if ([ :len $Disable ] > 0) do={
|
||||
/interface/ethernet/disable $Disable;
|
||||
:set InterfaceReEnable ($InterfaceReEnable, $Disable);
|
||||
}
|
||||
/interface/bridge/port/set disabled=no pvid=$Vlan $BridgePort;
|
||||
} else={
|
||||
$LogPrintExit2 debug $0 ("Interface " . $BridgePortVal->"interface" . " already connected to " . $ConfigTo . \
|
||||
" vlan " . $Vlan . ".") false;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
:if ([ :len $InterfaceReEnable ] > 0) do={
|
||||
:delay 2s;
|
||||
$LogPrintExit2 info $0 ("Re-enabling interfaces...") false;
|
||||
/interface/ethernet/enable $InterfaceReEnable;
|
||||
}
|
||||
}
|
||||
# dummy for migration
|
||||
|
|
|
|||
73
mod/bridge-port-vlan.rsc
Normal file
73
mod/bridge-port-vlan.rsc
Normal file
|
|
@ -0,0 +1,73 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/bridge-port-vlan
|
||||
# Copyright (c) 2013-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
#
|
||||
# manage VLANs on bridge ports
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/doc/mod/bridge-port-vlan.md
|
||||
|
||||
:global BridgePortVlan;
|
||||
|
||||
:global BridgePortVlan do={
|
||||
:local ConfigTo [ :tostr $1 ];
|
||||
|
||||
:global IfThenElse;
|
||||
:global LogPrintExit2;
|
||||
:global ParseKeyValueStore;
|
||||
|
||||
:local InterfaceReEnable ({});
|
||||
:foreach BridgePort in=[ /interface/bridge/port/find where !(comment=[]) ] do={
|
||||
:local BridgePortVal [ /interface/bridge/port/get $BridgePort ];
|
||||
:foreach Config,Vlan in=[ $ParseKeyValueStore ($BridgePortVal->"comment") ] do={
|
||||
:if ($Config = $ConfigTo) do={
|
||||
:local DHCPClient [ /ip/dhcp-client/find where interface=$BridgePortVal->"interface" comment="toggle with bridge port" ];
|
||||
|
||||
:if ($Vlan = "dhcp-client") do={
|
||||
:if ([ :len $DHCPClient ] != 1) do={
|
||||
$LogPrintExit2 warning $0 ([ $IfThenElse ([ :len $DHCPClient ] = 0) "Missing" "Duplicate" ] . \
|
||||
" dhcp client configuration for interface " . $BridgePortVal->"interface" . "!") true;
|
||||
}
|
||||
:local DHCPClientDisabled [ /ip/dhcp-client/get $DHCPClient disabled ];
|
||||
|
||||
:if ($BridgePortVal->"disabled" = false || $DHCPClientDisabled = true) do={
|
||||
$LogPrintExit2 info $0 ("Disabling bridge port for interface " . $BridgePortVal->"interface" . ", enabling dhcp client.") false;
|
||||
/interface/bridge/port/disable $BridgePort;
|
||||
:delay 200ms;
|
||||
/ip/dhcp-client/enable $DHCPClient;
|
||||
}
|
||||
} else={
|
||||
:local VlanName $Vlan;
|
||||
:if ($Vlan != [ :tostr [ :tonum $Vlan ] ]) do={
|
||||
:do {
|
||||
:set $Vlan ([ /interface/bridge/vlan/get [ find where comment=$Vlan ] vlan-ids ]->0);
|
||||
} on-error={
|
||||
$LogPrintExit2 warning $0 ("Could not find VLAN '" . $Vlan . "' for interface " . $BridgePortVal->"interface" . "!") true;
|
||||
}
|
||||
}
|
||||
:if ($BridgePortVal->"disabled" = true || $Vlan != $BridgePortVal->"pvid") do={
|
||||
$LogPrintExit2 info $0 ("Enabling bridge port for interface " . $BridgePortVal->"interface" . ", changing to " . $ConfigTo . \
|
||||
" vlan " . $Vlan . [ $IfThenElse ($Vlan != $VlanName) (" (" . $VlanName . ")") ] . ", disabling dhcp client.") false;
|
||||
:if ([ :len $DHCPClient ] = 1) do={
|
||||
/ip/dhcp-client/disable $DHCPClient;
|
||||
:delay 200ms;
|
||||
}
|
||||
:local Disable [ /interface/ethernet/find where name=$BridgePortVal->"interface" ];
|
||||
:if ([ :len $Disable ] > 0) do={
|
||||
/interface/ethernet/disable $Disable;
|
||||
:set InterfaceReEnable ($InterfaceReEnable, $Disable);
|
||||
}
|
||||
/interface/bridge/port/set disabled=no pvid=$Vlan $BridgePort;
|
||||
} else={
|
||||
$LogPrintExit2 debug $0 ("Interface " . $BridgePortVal->"interface" . " already connected to " . $ConfigTo . \
|
||||
" vlan " . $Vlan . ".") false;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
:if ([ :len $InterfaceReEnable ] > 0) do={
|
||||
:delay 2s;
|
||||
$LogPrintExit2 info $0 ("Re-enabling interfaces...") false;
|
||||
/interface/ethernet/enable $InterfaceReEnable;
|
||||
}
|
||||
}
|
||||
|
|
@ -1,54 +1,3 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/inspectvar
|
||||
# Copyright (c) 2020-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global InspectVar;
|
||||
:global InspectVarReturn;
|
||||
|
||||
# inspect variable and print on terminal
|
||||
:set InspectVar do={
|
||||
:global InspectVarReturn;
|
||||
:global PrettyPrint;
|
||||
|
||||
$PrettyPrint [ $InspectVarReturn $1 ];
|
||||
}
|
||||
|
||||
# inspect variable and return formatted string
|
||||
:set InspectVarReturn do={
|
||||
:local Input $1;
|
||||
:local Level (0 + [ :tonum $2 ]);
|
||||
|
||||
:global IfThenElse;
|
||||
:global InspectVarReturn;
|
||||
|
||||
:local IndentReturn do={
|
||||
:local Prefix [ :tostr $1 ];
|
||||
:local Value [ :tostr $2 ];
|
||||
:local Level [ :tonum $3 ];
|
||||
|
||||
:local Indent "";
|
||||
:for I from=1 to=$Level step=1 do={
|
||||
:set Indent ($Indent . " ");
|
||||
}
|
||||
:return ($Indent . "-" . $Prefix . "-> " . $Value);
|
||||
}
|
||||
|
||||
:local TypeOf [ :typeof $Input ];
|
||||
:local Return [ $IndentReturn "type" $TypeOf $Level ];
|
||||
|
||||
:if ($TypeOf = "array") do={
|
||||
:foreach Key,Value in=$Input do={
|
||||
:set $Return ($Return . "\n" . \
|
||||
[ $IndentReturn "key" $Key ($Level + 1) ] . "\n" . \
|
||||
[ $InspectVarReturn $Value ($Level + 2) ]);
|
||||
}
|
||||
} else={
|
||||
:if ($TypeOf != "nothing") do={
|
||||
:set $Return ($Return . "\n" . \
|
||||
[ $IndentReturn "value" [ $IfThenElse ([ :len $Input ] > 80) \
|
||||
([ :pick $Input 0 77 ] . "...") $Input ] $Level ]);
|
||||
}
|
||||
}
|
||||
:return $Return;
|
||||
}
|
||||
#
|
||||
# dummy for migration
|
||||
|
|
|
|||
54
mod/inspectvar.rsc
Normal file
54
mod/inspectvar.rsc
Normal file
|
|
@ -0,0 +1,54 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/inspectvar
|
||||
# Copyright (c) 2020-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global InspectVar;
|
||||
:global InspectVarReturn;
|
||||
|
||||
# inspect variable and print on terminal
|
||||
:set InspectVar do={
|
||||
:global InspectVarReturn;
|
||||
:global PrettyPrint;
|
||||
|
||||
$PrettyPrint [ $InspectVarReturn $1 ];
|
||||
}
|
||||
|
||||
# inspect variable and return formatted string
|
||||
:set InspectVarReturn do={
|
||||
:local Input $1;
|
||||
:local Level (0 + [ :tonum $2 ]);
|
||||
|
||||
:global IfThenElse;
|
||||
:global InspectVarReturn;
|
||||
|
||||
:local IndentReturn do={
|
||||
:local Prefix [ :tostr $1 ];
|
||||
:local Value [ :tostr $2 ];
|
||||
:local Level [ :tonum $3 ];
|
||||
|
||||
:local Indent "";
|
||||
:for I from=1 to=$Level step=1 do={
|
||||
:set Indent ($Indent . " ");
|
||||
}
|
||||
:return ($Indent . "-" . $Prefix . "-> " . $Value);
|
||||
}
|
||||
|
||||
:local TypeOf [ :typeof $Input ];
|
||||
:local Return [ $IndentReturn "type" $TypeOf $Level ];
|
||||
|
||||
:if ($TypeOf = "array") do={
|
||||
:foreach Key,Value in=$Input do={
|
||||
:set $Return ($Return . "\n" . \
|
||||
[ $IndentReturn "key" $Key ($Level + 1) ] . "\n" . \
|
||||
[ $InspectVarReturn $Value ($Level + 2) ]);
|
||||
}
|
||||
} else={
|
||||
:if ($TypeOf != "nothing") do={
|
||||
:set $Return ($Return . "\n" . \
|
||||
[ $IndentReturn "value" [ $IfThenElse ([ :len $Input ] > 80) \
|
||||
([ :pick $Input 0 77 ] . "...") $Input ] $Level ]);
|
||||
}
|
||||
}
|
||||
:return $Return;
|
||||
}
|
||||
47
mod/ipcalc
47
mod/ipcalc
|
|
@ -1,46 +1,3 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/ipcalc
|
||||
# Copyright (c) 2020-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global IPCalc;
|
||||
:global IPCalcReturn;
|
||||
|
||||
# print netmask, network, min host, max host and broadcast
|
||||
:set IPCalc do={
|
||||
:local Input [ :tostr $1 ];
|
||||
|
||||
:global IPCalcReturn;
|
||||
:global PrettyPrint;
|
||||
|
||||
:local Values [ $IPCalcReturn $1 ];
|
||||
|
||||
$PrettyPrint ( \
|
||||
"Address: " . $Values->"address" . "\n" . \
|
||||
"Netmask: " . $Values->"netmask" . "\n" . \
|
||||
"Network: " . $Values->"network" . "\n" . \
|
||||
"HostMin: " . $Values->"hostmin" . "\n" . \
|
||||
"HostMax: " . $Values->"hostmax" . "\n" . \
|
||||
"Broadcast: " . $Values->"broadcast");
|
||||
}
|
||||
|
||||
# calculate and return netmask, network, min host, max host and broadcast
|
||||
:set IPCalcReturn do={
|
||||
:local Input [ :tostr $1 ];
|
||||
:local Address [ :toip [ :pick $Input 0 [ :find $Input "/" ] ] ];
|
||||
:local Bits [ :tonum [ :pick $Input ([ :find $Input "/" ] + 1) [ :len $Input ] ] ];
|
||||
:local Mask ((255.255.255.255 << (32 - $Bits)) & 255.255.255.255);
|
||||
|
||||
:local Return {
|
||||
"address"=$Address;
|
||||
"netmask"=$Mask;
|
||||
"networkaddress"=($Address & $Mask);
|
||||
"networkbits"=$Bits;
|
||||
"network"=(($Address & $Mask) . "/" . $Bits);
|
||||
"hostmin"=(($Address & $Mask) | 0.0.0.1);
|
||||
"hostmax"=(($Address | ~$Mask) ^ 0.0.0.1);
|
||||
"broadcast"=($Address | ~$Mask);
|
||||
}
|
||||
|
||||
:return $Return;
|
||||
}
|
||||
#
|
||||
# dummy for migration
|
||||
|
|
|
|||
46
mod/ipcalc.rsc
Normal file
46
mod/ipcalc.rsc
Normal file
|
|
@ -0,0 +1,46 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/ipcalc
|
||||
# Copyright (c) 2020-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global IPCalc;
|
||||
:global IPCalcReturn;
|
||||
|
||||
# print netmask, network, min host, max host and broadcast
|
||||
:set IPCalc do={
|
||||
:local Input [ :tostr $1 ];
|
||||
|
||||
:global IPCalcReturn;
|
||||
:global PrettyPrint;
|
||||
|
||||
:local Values [ $IPCalcReturn $1 ];
|
||||
|
||||
$PrettyPrint ( \
|
||||
"Address: " . $Values->"address" . "\n" . \
|
||||
"Netmask: " . $Values->"netmask" . "\n" . \
|
||||
"Network: " . $Values->"network" . "\n" . \
|
||||
"HostMin: " . $Values->"hostmin" . "\n" . \
|
||||
"HostMax: " . $Values->"hostmax" . "\n" . \
|
||||
"Broadcast: " . $Values->"broadcast");
|
||||
}
|
||||
|
||||
# calculate and return netmask, network, min host, max host and broadcast
|
||||
:set IPCalcReturn do={
|
||||
:local Input [ :tostr $1 ];
|
||||
:local Address [ :toip [ :pick $Input 0 [ :find $Input "/" ] ] ];
|
||||
:local Bits [ :tonum [ :pick $Input ([ :find $Input "/" ] + 1) [ :len $Input ] ] ];
|
||||
:local Mask ((255.255.255.255 << (32 - $Bits)) & 255.255.255.255);
|
||||
|
||||
:local Return {
|
||||
"address"=$Address;
|
||||
"netmask"=$Mask;
|
||||
"networkaddress"=($Address & $Mask);
|
||||
"networkbits"=$Bits;
|
||||
"network"=(($Address & $Mask) . "/" . $Bits);
|
||||
"hostmin"=(($Address & $Mask) | 0.0.0.1);
|
||||
"hostmax"=(($Address | ~$Mask) ^ 0.0.0.1);
|
||||
"broadcast"=($Address | ~$Mask);
|
||||
}
|
||||
|
||||
:return $Return;
|
||||
}
|
||||
|
|
@ -1,206 +1,3 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/notification-email
|
||||
# Copyright (c) 2013-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global FlushEmailQueue;
|
||||
:global LogForwardFilterLogForwarding;
|
||||
:global NotificationEMailSubject;
|
||||
:global NotificationFunctions;
|
||||
:global QuotedPrintable;
|
||||
:global SendEMail;
|
||||
:global SendEMail2;
|
||||
|
||||
# flush e-mail queue
|
||||
:set FlushEmailQueue do={
|
||||
:global EmailQueue;
|
||||
|
||||
:global EitherOr;
|
||||
:global IsDNSResolving;
|
||||
:global IsTimeSync;
|
||||
:global LogPrintExit2;
|
||||
|
||||
:local AllDone true;
|
||||
:local QueueLen [ :len $EmailQueue ];
|
||||
:local Scheduler [ /system/scheduler/find where name=$0 ];
|
||||
|
||||
:if ([ :len $Scheduler ] > 0 && [ /system/scheduler/get $Scheduler interval ] < 1m) do={
|
||||
/system/scheduler/set interval=1m comment="Doing initial checks..." $Scheduler;
|
||||
}
|
||||
|
||||
:if ([ /tool/e-mail/get last-status ] = "in-progress") do={
|
||||
$LogPrintExit2 debug $0 ("Sending mail is currently in progress, not flushing.") false;
|
||||
:return false;
|
||||
}
|
||||
|
||||
:if ([ $IsTimeSync ] = false) do={
|
||||
$LogPrintExit2 debug $0 ("Time is not synced, not flushing.") false;
|
||||
:return false;
|
||||
}
|
||||
|
||||
:if ([ :typeof [ :toip [ /tool/e-mail/get address ] ] ] != "ip" && [ $IsDNSResolving ] = false) do={
|
||||
$LogPrintExit2 debug $0 ("Server address is a DNS name and resolving fails, not flushing.") false;
|
||||
:return false;
|
||||
}
|
||||
|
||||
:if ([ :len $Scheduler ] > 0 && $QueueLen = 0) do={
|
||||
$LogPrintExit2 warning $0 ("Flushing E-Mail messages from scheduler, but queue is empty.") false;
|
||||
}
|
||||
|
||||
/system/scheduler/set interval=([ $EitherOr $QueueLen 1 ] . "m") comment="Sending..." $Scheduler;
|
||||
|
||||
:foreach Id,Message in=$EmailQueue do={
|
||||
:if ([ :typeof $Message ] = "array" ) do={
|
||||
:local Attach ({});
|
||||
:while ([ /tool/e-mail/get last-status ] = "in-progress") do={ :delay 1s; }
|
||||
:foreach File in=[ :toarray [ $EitherOr ($Message->"attach") "" ] ] do={
|
||||
:if ([ :len [ /file/find where name=$File ] ] = 1) do={
|
||||
:set Attach ($Attach, $File);
|
||||
} else={
|
||||
$LogPrintExit2 warning $0 ("File '" . $File . "' does not exist, can not attach.") false;
|
||||
}
|
||||
}
|
||||
/tool/e-mail/send to=($Message->"to") cc=($Message->"cc") subject=($Message->"subject") \
|
||||
body=($Message->"body") file=$Attach;
|
||||
:local Wait true;
|
||||
:do {
|
||||
:delay 1s;
|
||||
:local Status [ /tool/e-mail/get last-status ];
|
||||
:if ($Status = "succeeded") do={
|
||||
:set ($EmailQueue->$Id);
|
||||
:set Wait false;
|
||||
:if (($Message->"remove-attach") = true) do={
|
||||
:foreach File in=$Attach do={
|
||||
/file/remove $File;
|
||||
}
|
||||
}
|
||||
}
|
||||
:if ($Status = "failed") do={
|
||||
:set AllDone false;
|
||||
:set Wait false;
|
||||
}
|
||||
} while=($Wait = true);
|
||||
}
|
||||
}
|
||||
|
||||
:if ($AllDone = true && $QueueLen = [ :len $EmailQueue ]) do={
|
||||
/system/scheduler/remove $Scheduler;
|
||||
:set EmailQueue;
|
||||
} else={
|
||||
/system/scheduler/set interval=1m comment="Waiting for retry..." $Scheduler;
|
||||
}
|
||||
}
|
||||
|
||||
# generate filter for log-forward
|
||||
:set LogForwardFilterLogForwarding do={
|
||||
:global EscapeForRegEx;
|
||||
:global NotificationEMailSubject;
|
||||
:global SymbolForNotification;
|
||||
|
||||
:return ("^Error sending e-mail <(" . \
|
||||
[ $EscapeForRegEx [ $NotificationEMailSubject ([ $SymbolForNotification \
|
||||
"memo" ] . "Log Forwarding") ] ] . "|" . \
|
||||
[ $EscapeForRegEx [ $NotificationEMailSubject ([ $SymbolForNotification \
|
||||
"warning-sign" ] . "Log Forwarding") ] ] . ")>:");
|
||||
}
|
||||
|
||||
# generate the e-mail subject
|
||||
:set NotificationEMailSubject do={
|
||||
:global Identity;
|
||||
:global IdentityExtra;
|
||||
|
||||
:global QuotedPrintable;
|
||||
|
||||
:return [ $QuotedPrintable ("[" . $IdentityExtra . $Identity . "] " . $1) ];
|
||||
}
|
||||
|
||||
# send notification via e-mail - expects one array argument
|
||||
:set ($NotificationFunctions->"email") do={
|
||||
:local Notification $1;
|
||||
|
||||
:global EmailGeneralTo;
|
||||
:global EmailGeneralToOverride;
|
||||
:global EmailGeneralCc;
|
||||
:global EmailGeneralCcOverride;
|
||||
:global EmailQueue;
|
||||
|
||||
:global EitherOr;
|
||||
:global IfThenElse;
|
||||
:global NotificationEMailSubject;
|
||||
|
||||
:local To [ $EitherOr ($EmailGeneralToOverride->($Notification->"origin")) $EmailGeneralTo ];
|
||||
:local Cc [ $EitherOr ($EmailGeneralCcOverride->($Notification->"origin")) $EmailGeneralCc ];
|
||||
|
||||
:local EMailSettings [ /tool/e-mail/get ];
|
||||
:if ([ :len $To ] = 0 || ($EMailSettings->"address") = "0.0.0.0" || ($EMailSettings->"from") = "<>") do={
|
||||
:return false;
|
||||
}
|
||||
|
||||
:if ([ :typeof $EmailQueue ] = "nothing") do={
|
||||
:set EmailQueue ({});
|
||||
}
|
||||
:local Signature [ /system/note/get note ];
|
||||
:set ($EmailQueue->[ :len $EmailQueue ]) {
|
||||
to=$To; cc=$Cc;
|
||||
subject=[ $NotificationEMailSubject ($Notification->"subject") ];
|
||||
body=(($Notification->"message") . \
|
||||
[ $IfThenElse ([ :len ($Notification->"link") ] > 0) ("\n\n" . ($Notification->"link")) "" ] . \
|
||||
[ $IfThenElse ([ :len $Signature ] > 0) ("\n-- \n" . $Signature) "" ]); \
|
||||
attach=($Notification->"attach"); remove-attach=($Notification->"remove-attach") };
|
||||
:if ([ :len [ /system/scheduler/find where name="\$FlushEmailQueue" ] ] = 0) do={
|
||||
/system/scheduler/add name="\$FlushEmailQueue" interval=1s start-time=startup \
|
||||
comment="Queuing new mail..." on-event=(":global FlushEmailQueue; \$FlushEmailQueue;");
|
||||
}
|
||||
}
|
||||
|
||||
# convert string to quoted-printable
|
||||
:global QuotedPrintable do={
|
||||
:local Input [ :tostr $1 ];
|
||||
|
||||
:if ([ :len $Input ] = 0) do={
|
||||
:return $Input;
|
||||
}
|
||||
|
||||
:local Return "";
|
||||
:local Chars ("\80\81\82\83\84\85\86\87\88\89\8A\8B\8C\8D\8E\8F\90\91\92\93\94\95\96\97" . \
|
||||
"\98\99\9A\9B\9C\9D\9E\9F\A0\A1\A2\A3\A4\A5\A6\A7\A8\A9\AA\AB\AC\AD\AE\AF\B0\B1\B2\B3" . \
|
||||
"\B4\B5\B6\B7\B8\B9\BA\BB\BC\BD\BE\BF\C0\C1\C2\C3\C4\C5\C6\C7\C8\C9\CA\CB\CC\CD\CE\CF" . \
|
||||
"\D0\D1\D2\D3\D4\D5\D6\D7\D8\D9\DA\DB\DC\DD\DE\DF\E0\E1\E2\E3\E4\E5\E6\E7\E8\E9\EA\EB" . \
|
||||
"\EC\ED\EE\EF\F0\F1\F2\F3\F4\F5\F6\F7\F8\F9\FA\FB\FC\FD\FE\FF");
|
||||
:local Hex { "0"; "1"; "2"; "3"; "4"; "5"; "6"; "7"; "8"; "9"; "A"; "B"; "C"; "D"; "E"; "F" };
|
||||
|
||||
:for I from=0 to=([ :len $Input ] - 1) do={
|
||||
:local Char [ :pick $Input $I ];
|
||||
:local Replace [ :find $Chars $Char ];
|
||||
|
||||
:if ($Char = "=") do={
|
||||
:set Char "=3D";
|
||||
}
|
||||
:if ([ :typeof $Replace ] = "num") do={
|
||||
:set Char ("=" . ($Hex->($Replace / 16 + 8)) . ($Hex->($Replace % 16)));
|
||||
}
|
||||
:set Return ($Return . $Char);
|
||||
}
|
||||
|
||||
:if ($Input = $Return) do={
|
||||
:return $Input;
|
||||
}
|
||||
|
||||
:return ("=\?utf-8\?Q\?" . $Return . "\?=");
|
||||
}
|
||||
|
||||
# send notification via e-mail - expects at least two string arguments
|
||||
:set SendEMail do={
|
||||
:global SendEMail2;
|
||||
|
||||
$SendEMail2 ({ subject=$1; message=$2; link=$3 });
|
||||
}
|
||||
|
||||
# send notification via e-mail - expects one array argument
|
||||
:set SendEMail2 do={
|
||||
:local Notification $1;
|
||||
|
||||
:global NotificationFunctions;
|
||||
|
||||
($NotificationFunctions->"email") ("\$NotificationFunctions->\"email\"") $Notification;
|
||||
}
|
||||
#
|
||||
# dummy for migration
|
||||
|
|
|
|||
206
mod/notification-email.rsc
Normal file
206
mod/notification-email.rsc
Normal file
|
|
@ -0,0 +1,206 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/notification-email
|
||||
# Copyright (c) 2013-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global FlushEmailQueue;
|
||||
:global LogForwardFilterLogForwarding;
|
||||
:global NotificationEMailSubject;
|
||||
:global NotificationFunctions;
|
||||
:global QuotedPrintable;
|
||||
:global SendEMail;
|
||||
:global SendEMail2;
|
||||
|
||||
# flush e-mail queue
|
||||
:set FlushEmailQueue do={
|
||||
:global EmailQueue;
|
||||
|
||||
:global EitherOr;
|
||||
:global IsDNSResolving;
|
||||
:global IsTimeSync;
|
||||
:global LogPrintExit2;
|
||||
|
||||
:local AllDone true;
|
||||
:local QueueLen [ :len $EmailQueue ];
|
||||
:local Scheduler [ /system/scheduler/find where name=$0 ];
|
||||
|
||||
:if ([ :len $Scheduler ] > 0 && [ /system/scheduler/get $Scheduler interval ] < 1m) do={
|
||||
/system/scheduler/set interval=1m comment="Doing initial checks..." $Scheduler;
|
||||
}
|
||||
|
||||
:if ([ /tool/e-mail/get last-status ] = "in-progress") do={
|
||||
$LogPrintExit2 debug $0 ("Sending mail is currently in progress, not flushing.") false;
|
||||
:return false;
|
||||
}
|
||||
|
||||
:if ([ $IsTimeSync ] = false) do={
|
||||
$LogPrintExit2 debug $0 ("Time is not synced, not flushing.") false;
|
||||
:return false;
|
||||
}
|
||||
|
||||
:if ([ :typeof [ :toip [ /tool/e-mail/get address ] ] ] != "ip" && [ $IsDNSResolving ] = false) do={
|
||||
$LogPrintExit2 debug $0 ("Server address is a DNS name and resolving fails, not flushing.") false;
|
||||
:return false;
|
||||
}
|
||||
|
||||
:if ([ :len $Scheduler ] > 0 && $QueueLen = 0) do={
|
||||
$LogPrintExit2 warning $0 ("Flushing E-Mail messages from scheduler, but queue is empty.") false;
|
||||
}
|
||||
|
||||
/system/scheduler/set interval=([ $EitherOr $QueueLen 1 ] . "m") comment="Sending..." $Scheduler;
|
||||
|
||||
:foreach Id,Message in=$EmailQueue do={
|
||||
:if ([ :typeof $Message ] = "array" ) do={
|
||||
:local Attach ({});
|
||||
:while ([ /tool/e-mail/get last-status ] = "in-progress") do={ :delay 1s; }
|
||||
:foreach File in=[ :toarray [ $EitherOr ($Message->"attach") "" ] ] do={
|
||||
:if ([ :len [ /file/find where name=$File ] ] = 1) do={
|
||||
:set Attach ($Attach, $File);
|
||||
} else={
|
||||
$LogPrintExit2 warning $0 ("File '" . $File . "' does not exist, can not attach.") false;
|
||||
}
|
||||
}
|
||||
/tool/e-mail/send to=($Message->"to") cc=($Message->"cc") subject=($Message->"subject") \
|
||||
body=($Message->"body") file=$Attach;
|
||||
:local Wait true;
|
||||
:do {
|
||||
:delay 1s;
|
||||
:local Status [ /tool/e-mail/get last-status ];
|
||||
:if ($Status = "succeeded") do={
|
||||
:set ($EmailQueue->$Id);
|
||||
:set Wait false;
|
||||
:if (($Message->"remove-attach") = true) do={
|
||||
:foreach File in=$Attach do={
|
||||
/file/remove $File;
|
||||
}
|
||||
}
|
||||
}
|
||||
:if ($Status = "failed") do={
|
||||
:set AllDone false;
|
||||
:set Wait false;
|
||||
}
|
||||
} while=($Wait = true);
|
||||
}
|
||||
}
|
||||
|
||||
:if ($AllDone = true && $QueueLen = [ :len $EmailQueue ]) do={
|
||||
/system/scheduler/remove $Scheduler;
|
||||
:set EmailQueue;
|
||||
} else={
|
||||
/system/scheduler/set interval=1m comment="Waiting for retry..." $Scheduler;
|
||||
}
|
||||
}
|
||||
|
||||
# generate filter for log-forward
|
||||
:set LogForwardFilterLogForwarding do={
|
||||
:global EscapeForRegEx;
|
||||
:global NotificationEMailSubject;
|
||||
:global SymbolForNotification;
|
||||
|
||||
:return ("^Error sending e-mail <(" . \
|
||||
[ $EscapeForRegEx [ $NotificationEMailSubject ([ $SymbolForNotification \
|
||||
"memo" ] . "Log Forwarding") ] ] . "|" . \
|
||||
[ $EscapeForRegEx [ $NotificationEMailSubject ([ $SymbolForNotification \
|
||||
"warning-sign" ] . "Log Forwarding") ] ] . ")>:");
|
||||
}
|
||||
|
||||
# generate the e-mail subject
|
||||
:set NotificationEMailSubject do={
|
||||
:global Identity;
|
||||
:global IdentityExtra;
|
||||
|
||||
:global QuotedPrintable;
|
||||
|
||||
:return [ $QuotedPrintable ("[" . $IdentityExtra . $Identity . "] " . $1) ];
|
||||
}
|
||||
|
||||
# send notification via e-mail - expects one array argument
|
||||
:set ($NotificationFunctions->"email") do={
|
||||
:local Notification $1;
|
||||
|
||||
:global EmailGeneralTo;
|
||||
:global EmailGeneralToOverride;
|
||||
:global EmailGeneralCc;
|
||||
:global EmailGeneralCcOverride;
|
||||
:global EmailQueue;
|
||||
|
||||
:global EitherOr;
|
||||
:global IfThenElse;
|
||||
:global NotificationEMailSubject;
|
||||
|
||||
:local To [ $EitherOr ($EmailGeneralToOverride->($Notification->"origin")) $EmailGeneralTo ];
|
||||
:local Cc [ $EitherOr ($EmailGeneralCcOverride->($Notification->"origin")) $EmailGeneralCc ];
|
||||
|
||||
:local EMailSettings [ /tool/e-mail/get ];
|
||||
:if ([ :len $To ] = 0 || ($EMailSettings->"address") = "0.0.0.0" || ($EMailSettings->"from") = "<>") do={
|
||||
:return false;
|
||||
}
|
||||
|
||||
:if ([ :typeof $EmailQueue ] = "nothing") do={
|
||||
:set EmailQueue ({});
|
||||
}
|
||||
:local Signature [ /system/note/get note ];
|
||||
:set ($EmailQueue->[ :len $EmailQueue ]) {
|
||||
to=$To; cc=$Cc;
|
||||
subject=[ $NotificationEMailSubject ($Notification->"subject") ];
|
||||
body=(($Notification->"message") . \
|
||||
[ $IfThenElse ([ :len ($Notification->"link") ] > 0) ("\n\n" . ($Notification->"link")) "" ] . \
|
||||
[ $IfThenElse ([ :len $Signature ] > 0) ("\n-- \n" . $Signature) "" ]); \
|
||||
attach=($Notification->"attach"); remove-attach=($Notification->"remove-attach") };
|
||||
:if ([ :len [ /system/scheduler/find where name="\$FlushEmailQueue" ] ] = 0) do={
|
||||
/system/scheduler/add name="\$FlushEmailQueue" interval=1s start-time=startup \
|
||||
comment="Queuing new mail..." on-event=(":global FlushEmailQueue; \$FlushEmailQueue;");
|
||||
}
|
||||
}
|
||||
|
||||
# convert string to quoted-printable
|
||||
:global QuotedPrintable do={
|
||||
:local Input [ :tostr $1 ];
|
||||
|
||||
:if ([ :len $Input ] = 0) do={
|
||||
:return $Input;
|
||||
}
|
||||
|
||||
:local Return "";
|
||||
:local Chars ("\80\81\82\83\84\85\86\87\88\89\8A\8B\8C\8D\8E\8F\90\91\92\93\94\95\96\97" . \
|
||||
"\98\99\9A\9B\9C\9D\9E\9F\A0\A1\A2\A3\A4\A5\A6\A7\A8\A9\AA\AB\AC\AD\AE\AF\B0\B1\B2\B3" . \
|
||||
"\B4\B5\B6\B7\B8\B9\BA\BB\BC\BD\BE\BF\C0\C1\C2\C3\C4\C5\C6\C7\C8\C9\CA\CB\CC\CD\CE\CF" . \
|
||||
"\D0\D1\D2\D3\D4\D5\D6\D7\D8\D9\DA\DB\DC\DD\DE\DF\E0\E1\E2\E3\E4\E5\E6\E7\E8\E9\EA\EB" . \
|
||||
"\EC\ED\EE\EF\F0\F1\F2\F3\F4\F5\F6\F7\F8\F9\FA\FB\FC\FD\FE\FF");
|
||||
:local Hex { "0"; "1"; "2"; "3"; "4"; "5"; "6"; "7"; "8"; "9"; "A"; "B"; "C"; "D"; "E"; "F" };
|
||||
|
||||
:for I from=0 to=([ :len $Input ] - 1) do={
|
||||
:local Char [ :pick $Input $I ];
|
||||
:local Replace [ :find $Chars $Char ];
|
||||
|
||||
:if ($Char = "=") do={
|
||||
:set Char "=3D";
|
||||
}
|
||||
:if ([ :typeof $Replace ] = "num") do={
|
||||
:set Char ("=" . ($Hex->($Replace / 16 + 8)) . ($Hex->($Replace % 16)));
|
||||
}
|
||||
:set Return ($Return . $Char);
|
||||
}
|
||||
|
||||
:if ($Input = $Return) do={
|
||||
:return $Input;
|
||||
}
|
||||
|
||||
:return ("=\?utf-8\?Q\?" . $Return . "\?=");
|
||||
}
|
||||
|
||||
# send notification via e-mail - expects at least two string arguments
|
||||
:set SendEMail do={
|
||||
:global SendEMail2;
|
||||
|
||||
$SendEMail2 ({ subject=$1; message=$2; link=$3 });
|
||||
}
|
||||
|
||||
# send notification via e-mail - expects one array argument
|
||||
:set SendEMail2 do={
|
||||
:local Notification $1;
|
||||
|
||||
:global NotificationFunctions;
|
||||
|
||||
($NotificationFunctions->"email") ("\$NotificationFunctions->\"email\"") $Notification;
|
||||
}
|
||||
|
|
@ -1,165 +1,3 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/notification-matrix
|
||||
# Copyright (c) 2013-2023 Michael Gisbers <michael@gisbers.de>
|
||||
# Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global FlushMatrixQueue;
|
||||
:global NotificationFunctions;
|
||||
:global SendMatrix;
|
||||
:global SendMatrix2;
|
||||
|
||||
# flush Matrix queue
|
||||
:set FlushMatrixQueue do={
|
||||
:global MatrixQueue;
|
||||
|
||||
:global IsFullyConnected;
|
||||
:global LogPrintExit2;
|
||||
|
||||
:if ([ $IsFullyConnected ] = false) do={
|
||||
$LogPrintExit2 debug $0 ("System is not fully connected, not flushing.") false;
|
||||
:return false;
|
||||
}
|
||||
|
||||
:local AllDone true;
|
||||
:local QueueLen [ :len $MatrixQueue ];
|
||||
|
||||
:if ([ :len [ /system/scheduler/find where name=$0 ] ] > 0 && $QueueLen = 0) do={
|
||||
$LogPrintExit2 warning $0 ("Flushing Matrix messages from scheduler, but queue is empty.") false;
|
||||
}
|
||||
|
||||
:foreach Id,Message in=$MatrixQueue do={
|
||||
:if ([ :typeof $Message ] = "array" ) do={
|
||||
:do {
|
||||
/tool/fetch check-certificate=yes-without-crl output=none http-method=post \
|
||||
("https://" . $Message->"homeserver" . "/_matrix/client/r0/rooms/" . $Message->"room" . \
|
||||
"/send/m.room.message?access_token=" . $Message->"accesstoken") \
|
||||
http-data=("{ \"msgtype\": \"m.text\", \"body\": \"" . $Message->"plain" . "\"," . \
|
||||
"\"format\": \"org.matrix.custom.html\", \"formatted_body\": \"" . \
|
||||
$Message->"formatted" . "\" }") as-value;
|
||||
:set ($MatrixQueue->$Id);
|
||||
} on-error={
|
||||
$LogPrintExit2 debug $0 ("Sending queued Matrix message failed.") false;
|
||||
:set AllDone false;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
:if ($AllDone = true && $QueueLen = [ :len $MatrixQueue ]) do={
|
||||
/system/scheduler/remove [ find where name=$0 ];
|
||||
:set MatrixQueue;
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via Matrix - expects one array argument
|
||||
:set ($NotificationFunctions->"matrix") do={
|
||||
:local Notification $1;
|
||||
|
||||
:global Identity;
|
||||
:global IdentityExtra;
|
||||
:global MatrixAccessToken;
|
||||
:global MatrixAccessTokenOverride;
|
||||
:global MatrixHomeServer;
|
||||
:global MatrixHomeServerOverride;
|
||||
:global MatrixQueue;
|
||||
:global MatrixRoom;
|
||||
:global MatrixRoomOverride;
|
||||
|
||||
:global EitherOr;
|
||||
:global LogPrintExit2;
|
||||
:global SymbolForNotification;
|
||||
|
||||
:local PrepareText do={
|
||||
:local Input [ :tostr $1 ];
|
||||
|
||||
:if ([ :len $Input ] = 0) do={
|
||||
:return "";
|
||||
}
|
||||
|
||||
:local Return "";
|
||||
:local Chars {
|
||||
"plain"={ "\\"; "\""; "\n" };
|
||||
"format"={ "\\"; "\""; "\n"; "&"; "<"; ">" };
|
||||
}
|
||||
:local Subs {
|
||||
"plain"={ "\\\\"; "\\\""; "\\n" };
|
||||
"format"={ "\\\\"; """; "<br/>"; "&"; "<"; ">" };
|
||||
}
|
||||
|
||||
:for I from=0 to=([ :len $Input ] - 1) do={
|
||||
:local Char [ :pick $Input $I ];
|
||||
:local Replace [ :find ($Chars->$2) $Char ];
|
||||
|
||||
:if ([ :typeof $Replace ] = "num") do={
|
||||
:set Char ($Subs->$2->$Replace);
|
||||
}
|
||||
:set Return ($Return . $Char);
|
||||
}
|
||||
|
||||
:return $Return;
|
||||
}
|
||||
|
||||
:local AccessToken [ $EitherOr ($MatrixAccessTokenOverride->($Notification->"origin")) $MatrixAccessToken ];
|
||||
:local HomeServer [ $EitherOr ($MatrixHomeServerOverride->($Notification->"origin")) $MatrixHomeServer ];
|
||||
:local Room [ $EitherOr ($MatrixRoomOverride->($Notification->"origin")) $MatrixRoom ];
|
||||
|
||||
:if ([ :len $AccessToken ] = 0 || [ :len $HomeServer ] = 0 || [ :len $Room ] = 0) do={
|
||||
:return false;
|
||||
}
|
||||
|
||||
:local Plain [ $PrepareText ("## [" . $IdentityExtra . $Identity . "] " . \
|
||||
($Notification->"subject") . "\n```\n" . ($Notification->"message") . "\n```") "plain" ];
|
||||
:local Formatted ("<h2>" . [ $PrepareText ("[" . $IdentityExtra . $Identity . "] " . \
|
||||
($Notification->"subject")) "format" ] . "</h2>" . "<pre><code>" . \
|
||||
[ $PrepareText ($Notification->"message") "format" ] . "</code></pre>");
|
||||
:if ([ :len ($Notification->"link") ] > 0) do={
|
||||
:set Plain ($Plain . "\\n" . [ $SymbolForNotification "link" ] . \
|
||||
[ $PrepareText ("[" . $Notification->"link" . "](" . $Notification->"link" . ")") "plain" ]);
|
||||
:set Formatted ($Formatted . "<br/>" . [ $SymbolForNotification "link" ] . \
|
||||
"<a href=\\\"" . [ $PrepareText ($Notification->"link") "format" ] . "\\\">" . \
|
||||
[ $PrepareText ($Notification->"link") "format" ] . "</a>");
|
||||
}
|
||||
|
||||
:do {
|
||||
/tool/fetch check-certificate=yes-without-crl output=none http-method=post \
|
||||
("https://" . $HomeServer . "/_matrix/client/r0/rooms/" . $Room . \
|
||||
"/send/m.room.message?access_token=" . $AccessToken) \
|
||||
http-data=("{ \"msgtype\": \"m.text\", \"body\": \"" . $Plain . "\"," . \
|
||||
"\"format\": \"org.matrix.custom.html\", \"formatted_body\": \"" . \
|
||||
$Formatted . "\" }") as-value;
|
||||
} on-error={
|
||||
$LogPrintExit2 info $0 ("Failed sending Matrix notification! Queuing...") false;
|
||||
|
||||
:if ([ :typeof $MatrixQueue ] = "nothing") do={
|
||||
:set MatrixQueue ({});
|
||||
}
|
||||
:local Text ([ $SymbolForNotification "alarm-clock" ] . \
|
||||
"This message was queued since " . [ /system/clock/get date ] . \
|
||||
" " . [ /system/clock/get time ] . " and may be obsolete.");
|
||||
:set Plain ($Plain . "\\n" . $Text);
|
||||
:set Formatted ($Formatted . "<br/>" . $Text);
|
||||
:set ($MatrixQueue->[ :len $MatrixQueue ]) { room=$Room; \
|
||||
accesstoken=$AccessToken; homeserver=$HomeServer; \
|
||||
plain=$Plain; formatted=$Formatted };
|
||||
:if ([ :len [ /system/scheduler/find where name="\$FlushMatrixQueue" ] ] = 0) do={
|
||||
/system/scheduler/add name="\$FlushMatrixQueue" interval=1m start-time=startup \
|
||||
on-event=(":global FlushMatrixQueue; \$FlushMatrixQueue;");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via Matrix - expects at least two string arguments
|
||||
:set SendMatrix do={
|
||||
:global SendMatrix2;
|
||||
|
||||
$SendMatrix2 ({ subject=$1; message=$2; link=$3 });
|
||||
}
|
||||
|
||||
# send notification via Matrix - expects one array argument
|
||||
:set SendMatrix2 do={
|
||||
:local Notification $1;
|
||||
|
||||
:global NotificationFunctions;
|
||||
|
||||
($NotificationFunctions->"matrix") ("\$NotificationFunctions->\"matrix\"") $Notification;
|
||||
}
|
||||
#
|
||||
# dummy for migration
|
||||
|
|
|
|||
165
mod/notification-matrix.rsc
Normal file
165
mod/notification-matrix.rsc
Normal file
|
|
@ -0,0 +1,165 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/notification-matrix
|
||||
# Copyright (c) 2013-2023 Michael Gisbers <michael@gisbers.de>
|
||||
# Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global FlushMatrixQueue;
|
||||
:global NotificationFunctions;
|
||||
:global SendMatrix;
|
||||
:global SendMatrix2;
|
||||
|
||||
# flush Matrix queue
|
||||
:set FlushMatrixQueue do={
|
||||
:global MatrixQueue;
|
||||
|
||||
:global IsFullyConnected;
|
||||
:global LogPrintExit2;
|
||||
|
||||
:if ([ $IsFullyConnected ] = false) do={
|
||||
$LogPrintExit2 debug $0 ("System is not fully connected, not flushing.") false;
|
||||
:return false;
|
||||
}
|
||||
|
||||
:local AllDone true;
|
||||
:local QueueLen [ :len $MatrixQueue ];
|
||||
|
||||
:if ([ :len [ /system/scheduler/find where name=$0 ] ] > 0 && $QueueLen = 0) do={
|
||||
$LogPrintExit2 warning $0 ("Flushing Matrix messages from scheduler, but queue is empty.") false;
|
||||
}
|
||||
|
||||
:foreach Id,Message in=$MatrixQueue do={
|
||||
:if ([ :typeof $Message ] = "array" ) do={
|
||||
:do {
|
||||
/tool/fetch check-certificate=yes-without-crl output=none http-method=post \
|
||||
("https://" . $Message->"homeserver" . "/_matrix/client/r0/rooms/" . $Message->"room" . \
|
||||
"/send/m.room.message?access_token=" . $Message->"accesstoken") \
|
||||
http-data=("{ \"msgtype\": \"m.text\", \"body\": \"" . $Message->"plain" . "\"," . \
|
||||
"\"format\": \"org.matrix.custom.html\", \"formatted_body\": \"" . \
|
||||
$Message->"formatted" . "\" }") as-value;
|
||||
:set ($MatrixQueue->$Id);
|
||||
} on-error={
|
||||
$LogPrintExit2 debug $0 ("Sending queued Matrix message failed.") false;
|
||||
:set AllDone false;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
:if ($AllDone = true && $QueueLen = [ :len $MatrixQueue ]) do={
|
||||
/system/scheduler/remove [ find where name=$0 ];
|
||||
:set MatrixQueue;
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via Matrix - expects one array argument
|
||||
:set ($NotificationFunctions->"matrix") do={
|
||||
:local Notification $1;
|
||||
|
||||
:global Identity;
|
||||
:global IdentityExtra;
|
||||
:global MatrixAccessToken;
|
||||
:global MatrixAccessTokenOverride;
|
||||
:global MatrixHomeServer;
|
||||
:global MatrixHomeServerOverride;
|
||||
:global MatrixQueue;
|
||||
:global MatrixRoom;
|
||||
:global MatrixRoomOverride;
|
||||
|
||||
:global EitherOr;
|
||||
:global LogPrintExit2;
|
||||
:global SymbolForNotification;
|
||||
|
||||
:local PrepareText do={
|
||||
:local Input [ :tostr $1 ];
|
||||
|
||||
:if ([ :len $Input ] = 0) do={
|
||||
:return "";
|
||||
}
|
||||
|
||||
:local Return "";
|
||||
:local Chars {
|
||||
"plain"={ "\\"; "\""; "\n" };
|
||||
"format"={ "\\"; "\""; "\n"; "&"; "<"; ">" };
|
||||
}
|
||||
:local Subs {
|
||||
"plain"={ "\\\\"; "\\\""; "\\n" };
|
||||
"format"={ "\\\\"; """; "<br/>"; "&"; "<"; ">" };
|
||||
}
|
||||
|
||||
:for I from=0 to=([ :len $Input ] - 1) do={
|
||||
:local Char [ :pick $Input $I ];
|
||||
:local Replace [ :find ($Chars->$2) $Char ];
|
||||
|
||||
:if ([ :typeof $Replace ] = "num") do={
|
||||
:set Char ($Subs->$2->$Replace);
|
||||
}
|
||||
:set Return ($Return . $Char);
|
||||
}
|
||||
|
||||
:return $Return;
|
||||
}
|
||||
|
||||
:local AccessToken [ $EitherOr ($MatrixAccessTokenOverride->($Notification->"origin")) $MatrixAccessToken ];
|
||||
:local HomeServer [ $EitherOr ($MatrixHomeServerOverride->($Notification->"origin")) $MatrixHomeServer ];
|
||||
:local Room [ $EitherOr ($MatrixRoomOverride->($Notification->"origin")) $MatrixRoom ];
|
||||
|
||||
:if ([ :len $AccessToken ] = 0 || [ :len $HomeServer ] = 0 || [ :len $Room ] = 0) do={
|
||||
:return false;
|
||||
}
|
||||
|
||||
:local Plain [ $PrepareText ("## [" . $IdentityExtra . $Identity . "] " . \
|
||||
($Notification->"subject") . "\n```\n" . ($Notification->"message") . "\n```") "plain" ];
|
||||
:local Formatted ("<h2>" . [ $PrepareText ("[" . $IdentityExtra . $Identity . "] " . \
|
||||
($Notification->"subject")) "format" ] . "</h2>" . "<pre><code>" . \
|
||||
[ $PrepareText ($Notification->"message") "format" ] . "</code></pre>");
|
||||
:if ([ :len ($Notification->"link") ] > 0) do={
|
||||
:set Plain ($Plain . "\\n" . [ $SymbolForNotification "link" ] . \
|
||||
[ $PrepareText ("[" . $Notification->"link" . "](" . $Notification->"link" . ")") "plain" ]);
|
||||
:set Formatted ($Formatted . "<br/>" . [ $SymbolForNotification "link" ] . \
|
||||
"<a href=\\\"" . [ $PrepareText ($Notification->"link") "format" ] . "\\\">" . \
|
||||
[ $PrepareText ($Notification->"link") "format" ] . "</a>");
|
||||
}
|
||||
|
||||
:do {
|
||||
/tool/fetch check-certificate=yes-without-crl output=none http-method=post \
|
||||
("https://" . $HomeServer . "/_matrix/client/r0/rooms/" . $Room . \
|
||||
"/send/m.room.message?access_token=" . $AccessToken) \
|
||||
http-data=("{ \"msgtype\": \"m.text\", \"body\": \"" . $Plain . "\"," . \
|
||||
"\"format\": \"org.matrix.custom.html\", \"formatted_body\": \"" . \
|
||||
$Formatted . "\" }") as-value;
|
||||
} on-error={
|
||||
$LogPrintExit2 info $0 ("Failed sending Matrix notification! Queuing...") false;
|
||||
|
||||
:if ([ :typeof $MatrixQueue ] = "nothing") do={
|
||||
:set MatrixQueue ({});
|
||||
}
|
||||
:local Text ([ $SymbolForNotification "alarm-clock" ] . \
|
||||
"This message was queued since " . [ /system/clock/get date ] . \
|
||||
" " . [ /system/clock/get time ] . " and may be obsolete.");
|
||||
:set Plain ($Plain . "\\n" . $Text);
|
||||
:set Formatted ($Formatted . "<br/>" . $Text);
|
||||
:set ($MatrixQueue->[ :len $MatrixQueue ]) { room=$Room; \
|
||||
accesstoken=$AccessToken; homeserver=$HomeServer; \
|
||||
plain=$Plain; formatted=$Formatted };
|
||||
:if ([ :len [ /system/scheduler/find where name="\$FlushMatrixQueue" ] ] = 0) do={
|
||||
/system/scheduler/add name="\$FlushMatrixQueue" interval=1m start-time=startup \
|
||||
on-event=(":global FlushMatrixQueue; \$FlushMatrixQueue;");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via Matrix - expects at least two string arguments
|
||||
:set SendMatrix do={
|
||||
:global SendMatrix2;
|
||||
|
||||
$SendMatrix2 ({ subject=$1; message=$2; link=$3 });
|
||||
}
|
||||
|
||||
# send notification via Matrix - expects one array argument
|
||||
:set SendMatrix2 do={
|
||||
:local Notification $1;
|
||||
|
||||
:global NotificationFunctions;
|
||||
|
||||
($NotificationFunctions->"matrix") ("\$NotificationFunctions->\"matrix\"") $Notification;
|
||||
}
|
||||
|
|
@ -1,176 +1,3 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/notification-telegram
|
||||
# Copyright (c) 2013-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global FlushTelegramQueue;
|
||||
:global NotificationFunctions;
|
||||
:global SendTelegram;
|
||||
:global SendTelegram2;
|
||||
|
||||
# flush telegram queue
|
||||
:set FlushTelegramQueue do={
|
||||
:global TelegramQueue;
|
||||
|
||||
:global IsFullyConnected;
|
||||
:global LogPrintExit2;
|
||||
|
||||
:if ([ $IsFullyConnected ] = false) do={
|
||||
$LogPrintExit2 debug $0 ("System is not fully connected, not flushing.") false;
|
||||
:return false;
|
||||
}
|
||||
|
||||
:local AllDone true;
|
||||
:local QueueLen [ :len $TelegramQueue ];
|
||||
|
||||
:if ([ :len [ /system/scheduler/find where name=$0 ] ] > 0 && $QueueLen = 0) do={
|
||||
$LogPrintExit2 warning $0 ("Flushing Telegram messages from scheduler, but queue is empty.") false;
|
||||
}
|
||||
|
||||
:foreach Id,Message in=$TelegramQueue do={
|
||||
:if ([ :typeof $Message ] = "array" ) do={
|
||||
:do {
|
||||
/tool/fetch check-certificate=yes-without-crl output=none http-method=post \
|
||||
("https://api.telegram.org/bot" . ($Message->"tokenid") . "/sendMessage") \
|
||||
http-data=("chat_id=" . ($Message->"chatid") . \
|
||||
"&disable_notification=" . ($Message->"silent") . \
|
||||
"&reply_to_message_id=" . ($Notification->"replyto") . \
|
||||
"&disable_web_page_preview=true&parse_mode=" . ($Message->"parsemode") . \
|
||||
"&text=" . ($Message->"text")) as-value;
|
||||
:set ($TelegramQueue->$Id);
|
||||
} on-error={
|
||||
$LogPrintExit2 debug $0 ("Sending queued Telegram message failed.") false;
|
||||
:set AllDone false;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
:if ($AllDone = true && $QueueLen = [ :len $TelegramQueue ]) do={
|
||||
/system/scheduler/remove [ find where name=$0 ];
|
||||
:set TelegramQueue;
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via telegram - expects one array argument
|
||||
:set ($NotificationFunctions->"telegram") do={
|
||||
:local Notification $1;
|
||||
|
||||
:global Identity;
|
||||
:global IdentityExtra;
|
||||
:global TelegramChatId;
|
||||
:global TelegramChatIdOverride;
|
||||
:global TelegramFixedWidthFont;
|
||||
:global TelegramQueue;
|
||||
:global TelegramTokenId;
|
||||
:global TelegramTokenIdOverride;
|
||||
|
||||
:global CertificateAvailable;
|
||||
:global CharacterReplace;
|
||||
:global EitherOr;
|
||||
:global IfThenElse;
|
||||
:global LogPrintExit2;
|
||||
:global SymbolForNotification;
|
||||
:global UrlEncode;
|
||||
|
||||
:local EscapeMD do={
|
||||
:global TelegramFixedWidthFont;
|
||||
|
||||
:global CharacterReplace;
|
||||
:global IfThenElse;
|
||||
|
||||
:if ($TelegramFixedWidthFont != true) do={
|
||||
:return ($1 . [ $IfThenElse ($2 = "body") ("\n") "" ]);
|
||||
}
|
||||
|
||||
:local Return $1;
|
||||
:local Chars {
|
||||
"body"={ "\\"; "`" };
|
||||
"plain"={ "_"; "*"; "["; "]"; "("; ")"; "~"; "`"; ">";
|
||||
"#"; "+"; "-"; "="; "|"; "{"; "}"; "."; "!" };
|
||||
}
|
||||
:foreach Char in=($Chars->$2) do={
|
||||
:set Return [ $CharacterReplace $Return $Char ("\\" . $Char) ];
|
||||
}
|
||||
|
||||
:if ($2 = "body") do={
|
||||
:return ("```\n" . $Return . "\n```");
|
||||
}
|
||||
|
||||
:return $Return;
|
||||
}
|
||||
|
||||
:local ChatId [ $EitherOr ($Notification->"chatid") \
|
||||
[ $EitherOr ($TelegramChatIdOverride->($Notification->"origin")) $TelegramChatId ] ];
|
||||
:local TokenId [ $EitherOr ($TelegramTokenIdOverride->($Notification->"origin")) $TelegramTokenId ];
|
||||
|
||||
:if ([ :len $TokenId ] = 0 || [ :len $ChatId ] = 0) do={
|
||||
:return false;
|
||||
}
|
||||
|
||||
:local Truncated false;
|
||||
:local Text ("*__" . [ $EscapeMD ("[" . $IdentityExtra . $Identity . "] " . \
|
||||
($Notification->"subject")) "plain" ] . "__*\n\n");
|
||||
:local LenSubject [ :len $Text ];
|
||||
:local LenMessage [ :len ($Notification->"message") ];
|
||||
:local LenLink [ :len ($Notification->"link") ];
|
||||
:local LenSum ($LenSubject + $LenMessage + $LenLink);
|
||||
:if ($LenSum > 3968) do={
|
||||
:set Text ($Text . [ $EscapeMD ([ :pick ($Notification->"message") 0 (3840 - $LenSubject - $LenLink) ] . "...") "body" ]);
|
||||
:set Truncated true;
|
||||
} else={
|
||||
:set Text ($Text . [ $EscapeMD ($Notification->"message") "body" ]);
|
||||
}
|
||||
:if ($LenLink > 0) do={
|
||||
:set Text ($Text . "\n" . [ $SymbolForNotification "link" ] . [ $EscapeMD ($Notification->"link") "plain" ]);
|
||||
}
|
||||
:if ($Truncated = true) do={
|
||||
:set Text ($Text . "\n" . [ $SymbolForNotification "scissors" ] . \
|
||||
[ $EscapeMD ("The message was too long and has been truncated, cut off " . \
|
||||
(($LenSum - [ :len $Text ]) * 100 / $LenSum) . "%!") "plain" ]);
|
||||
}
|
||||
:set Text [ $UrlEncode $Text ];
|
||||
:local ParseMode [ $IfThenElse ($TelegramFixedWidthFont = true) "MarkdownV2" "" ];
|
||||
|
||||
:do {
|
||||
:if ([ $CertificateAvailable "Go Daddy Secure Certificate Authority - G2" ] = false) do={
|
||||
$LogPrintExit2 warning $0 ("Downloading required certificate failed.") true;
|
||||
}
|
||||
/tool/fetch check-certificate=yes-without-crl output=none http-method=post \
|
||||
("https://api.telegram.org/bot" . $TokenId . "/sendMessage") \
|
||||
http-data=("chat_id=" . $ChatId . "&disable_notification=" . ($Notification->"silent") . \
|
||||
"&reply_to_message_id=" . ($Notification->"replyto") . \
|
||||
"&disable_web_page_preview=true&parse_mode=" . $ParseMode . "&text=" . $Text) as-value;
|
||||
} on-error={
|
||||
$LogPrintExit2 info $0 ("Failed sending telegram notification! Queuing...") false;
|
||||
|
||||
:if ([ :typeof $TelegramQueue ] = "nothing") do={
|
||||
:set TelegramQueue ({});
|
||||
}
|
||||
:set Text ($Text . [ $UrlEncode ("\n" . [ $SymbolForNotification "alarm-clock" ] . \
|
||||
[ $EscapeMD ("This message was queued since " . [ /system/clock/get date ] . \
|
||||
" " . [ /system/clock/get time ] . " and may be obsolete.") "plain" ]) ]);
|
||||
:set ($TelegramQueue->[ :len $TelegramQueue ]) { chatid=$ChatId; tokenid=$TokenId;
|
||||
parsemode=$ParseMode; text=$Text; silent=($Notification->"silent");
|
||||
replyto=($Notification->"replyto") };
|
||||
:if ([ :len [ /system/scheduler/find where name="\$FlushTelegramQueue" ] ] = 0) do={
|
||||
/system/scheduler/add name="\$FlushTelegramQueue" interval=1m start-time=startup \
|
||||
on-event=(":global FlushTelegramQueue; \$FlushTelegramQueue;");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via telegram - expects at least two string arguments
|
||||
:set SendTelegram do={
|
||||
:global SendTelegram2;
|
||||
|
||||
$SendTelegram2 ({ subject=$1; message=$2; link=$3; silent=$4 });
|
||||
}
|
||||
|
||||
# send notification via telegram - expects one array argument
|
||||
:set SendTelegram2 do={
|
||||
:local Notification $1;
|
||||
|
||||
:global NotificationFunctions;
|
||||
|
||||
($NotificationFunctions->"telegram") ("\$NotificationFunctions->\"telegram\"") $Notification;
|
||||
}
|
||||
#
|
||||
# dummy for migration
|
||||
|
|
|
|||
176
mod/notification-telegram.rsc
Normal file
176
mod/notification-telegram.rsc
Normal file
|
|
@ -0,0 +1,176 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/notification-telegram
|
||||
# Copyright (c) 2013-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global FlushTelegramQueue;
|
||||
:global NotificationFunctions;
|
||||
:global SendTelegram;
|
||||
:global SendTelegram2;
|
||||
|
||||
# flush telegram queue
|
||||
:set FlushTelegramQueue do={
|
||||
:global TelegramQueue;
|
||||
|
||||
:global IsFullyConnected;
|
||||
:global LogPrintExit2;
|
||||
|
||||
:if ([ $IsFullyConnected ] = false) do={
|
||||
$LogPrintExit2 debug $0 ("System is not fully connected, not flushing.") false;
|
||||
:return false;
|
||||
}
|
||||
|
||||
:local AllDone true;
|
||||
:local QueueLen [ :len $TelegramQueue ];
|
||||
|
||||
:if ([ :len [ /system/scheduler/find where name=$0 ] ] > 0 && $QueueLen = 0) do={
|
||||
$LogPrintExit2 warning $0 ("Flushing Telegram messages from scheduler, but queue is empty.") false;
|
||||
}
|
||||
|
||||
:foreach Id,Message in=$TelegramQueue do={
|
||||
:if ([ :typeof $Message ] = "array" ) do={
|
||||
:do {
|
||||
/tool/fetch check-certificate=yes-without-crl output=none http-method=post \
|
||||
("https://api.telegram.org/bot" . ($Message->"tokenid") . "/sendMessage") \
|
||||
http-data=("chat_id=" . ($Message->"chatid") . \
|
||||
"&disable_notification=" . ($Message->"silent") . \
|
||||
"&reply_to_message_id=" . ($Notification->"replyto") . \
|
||||
"&disable_web_page_preview=true&parse_mode=" . ($Message->"parsemode") . \
|
||||
"&text=" . ($Message->"text")) as-value;
|
||||
:set ($TelegramQueue->$Id);
|
||||
} on-error={
|
||||
$LogPrintExit2 debug $0 ("Sending queued Telegram message failed.") false;
|
||||
:set AllDone false;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
:if ($AllDone = true && $QueueLen = [ :len $TelegramQueue ]) do={
|
||||
/system/scheduler/remove [ find where name=$0 ];
|
||||
:set TelegramQueue;
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via telegram - expects one array argument
|
||||
:set ($NotificationFunctions->"telegram") do={
|
||||
:local Notification $1;
|
||||
|
||||
:global Identity;
|
||||
:global IdentityExtra;
|
||||
:global TelegramChatId;
|
||||
:global TelegramChatIdOverride;
|
||||
:global TelegramFixedWidthFont;
|
||||
:global TelegramQueue;
|
||||
:global TelegramTokenId;
|
||||
:global TelegramTokenIdOverride;
|
||||
|
||||
:global CertificateAvailable;
|
||||
:global CharacterReplace;
|
||||
:global EitherOr;
|
||||
:global IfThenElse;
|
||||
:global LogPrintExit2;
|
||||
:global SymbolForNotification;
|
||||
:global UrlEncode;
|
||||
|
||||
:local EscapeMD do={
|
||||
:global TelegramFixedWidthFont;
|
||||
|
||||
:global CharacterReplace;
|
||||
:global IfThenElse;
|
||||
|
||||
:if ($TelegramFixedWidthFont != true) do={
|
||||
:return ($1 . [ $IfThenElse ($2 = "body") ("\n") "" ]);
|
||||
}
|
||||
|
||||
:local Return $1;
|
||||
:local Chars {
|
||||
"body"={ "\\"; "`" };
|
||||
"plain"={ "_"; "*"; "["; "]"; "("; ")"; "~"; "`"; ">";
|
||||
"#"; "+"; "-"; "="; "|"; "{"; "}"; "."; "!" };
|
||||
}
|
||||
:foreach Char in=($Chars->$2) do={
|
||||
:set Return [ $CharacterReplace $Return $Char ("\\" . $Char) ];
|
||||
}
|
||||
|
||||
:if ($2 = "body") do={
|
||||
:return ("```\n" . $Return . "\n```");
|
||||
}
|
||||
|
||||
:return $Return;
|
||||
}
|
||||
|
||||
:local ChatId [ $EitherOr ($Notification->"chatid") \
|
||||
[ $EitherOr ($TelegramChatIdOverride->($Notification->"origin")) $TelegramChatId ] ];
|
||||
:local TokenId [ $EitherOr ($TelegramTokenIdOverride->($Notification->"origin")) $TelegramTokenId ];
|
||||
|
||||
:if ([ :len $TokenId ] = 0 || [ :len $ChatId ] = 0) do={
|
||||
:return false;
|
||||
}
|
||||
|
||||
:local Truncated false;
|
||||
:local Text ("*__" . [ $EscapeMD ("[" . $IdentityExtra . $Identity . "] " . \
|
||||
($Notification->"subject")) "plain" ] . "__*\n\n");
|
||||
:local LenSubject [ :len $Text ];
|
||||
:local LenMessage [ :len ($Notification->"message") ];
|
||||
:local LenLink [ :len ($Notification->"link") ];
|
||||
:local LenSum ($LenSubject + $LenMessage + $LenLink);
|
||||
:if ($LenSum > 3968) do={
|
||||
:set Text ($Text . [ $EscapeMD ([ :pick ($Notification->"message") 0 (3840 - $LenSubject - $LenLink) ] . "...") "body" ]);
|
||||
:set Truncated true;
|
||||
} else={
|
||||
:set Text ($Text . [ $EscapeMD ($Notification->"message") "body" ]);
|
||||
}
|
||||
:if ($LenLink > 0) do={
|
||||
:set Text ($Text . "\n" . [ $SymbolForNotification "link" ] . [ $EscapeMD ($Notification->"link") "plain" ]);
|
||||
}
|
||||
:if ($Truncated = true) do={
|
||||
:set Text ($Text . "\n" . [ $SymbolForNotification "scissors" ] . \
|
||||
[ $EscapeMD ("The message was too long and has been truncated, cut off " . \
|
||||
(($LenSum - [ :len $Text ]) * 100 / $LenSum) . "%!") "plain" ]);
|
||||
}
|
||||
:set Text [ $UrlEncode $Text ];
|
||||
:local ParseMode [ $IfThenElse ($TelegramFixedWidthFont = true) "MarkdownV2" "" ];
|
||||
|
||||
:do {
|
||||
:if ([ $CertificateAvailable "Go Daddy Secure Certificate Authority - G2" ] = false) do={
|
||||
$LogPrintExit2 warning $0 ("Downloading required certificate failed.") true;
|
||||
}
|
||||
/tool/fetch check-certificate=yes-without-crl output=none http-method=post \
|
||||
("https://api.telegram.org/bot" . $TokenId . "/sendMessage") \
|
||||
http-data=("chat_id=" . $ChatId . "&disable_notification=" . ($Notification->"silent") . \
|
||||
"&reply_to_message_id=" . ($Notification->"replyto") . \
|
||||
"&disable_web_page_preview=true&parse_mode=" . $ParseMode . "&text=" . $Text) as-value;
|
||||
} on-error={
|
||||
$LogPrintExit2 info $0 ("Failed sending telegram notification! Queuing...") false;
|
||||
|
||||
:if ([ :typeof $TelegramQueue ] = "nothing") do={
|
||||
:set TelegramQueue ({});
|
||||
}
|
||||
:set Text ($Text . [ $UrlEncode ("\n" . [ $SymbolForNotification "alarm-clock" ] . \
|
||||
[ $EscapeMD ("This message was queued since " . [ /system/clock/get date ] . \
|
||||
" " . [ /system/clock/get time ] . " and may be obsolete.") "plain" ]) ]);
|
||||
:set ($TelegramQueue->[ :len $TelegramQueue ]) { chatid=$ChatId; tokenid=$TokenId;
|
||||
parsemode=$ParseMode; text=$Text; silent=($Notification->"silent");
|
||||
replyto=($Notification->"replyto") };
|
||||
:if ([ :len [ /system/scheduler/find where name="\$FlushTelegramQueue" ] ] = 0) do={
|
||||
/system/scheduler/add name="\$FlushTelegramQueue" interval=1m start-time=startup \
|
||||
on-event=(":global FlushTelegramQueue; \$FlushTelegramQueue;");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via telegram - expects at least two string arguments
|
||||
:set SendTelegram do={
|
||||
:global SendTelegram2;
|
||||
|
||||
$SendTelegram2 ({ subject=$1; message=$2; link=$3; silent=$4 });
|
||||
}
|
||||
|
||||
# send notification via telegram - expects one array argument
|
||||
:set SendTelegram2 do={
|
||||
:local Notification $1;
|
||||
|
||||
:global NotificationFunctions;
|
||||
|
||||
($NotificationFunctions->"telegram") ("\$NotificationFunctions->\"telegram\"") $Notification;
|
||||
}
|
||||
|
|
@ -1,46 +1,3 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/scriptrunonece
|
||||
# Copyright (c) 2020-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global ScriptRunOnce;
|
||||
|
||||
# fetch and run script(s) once
|
||||
:set ScriptRunOnce do={
|
||||
:local Scripts [ :toarray $1 ];
|
||||
|
||||
:global ScriptRunOnceBaseUrl;
|
||||
:global ScriptRunOnceUrlSuffix;
|
||||
|
||||
:global LogPrintExit2;
|
||||
:global ValidateSyntax;
|
||||
|
||||
:foreach Script in=$Scripts do={
|
||||
:if (!($Script ~ "^(ftp|https\?|sftp)://")) do={
|
||||
:if ([ :len $ScriptRunOnceBaseUrl ] = 0) do={
|
||||
$LogPrintExit2 warning $0 ("Script '" . $Script . "' is not an url and base url is not available.") true;
|
||||
}
|
||||
:set Script ($ScriptRunOnceBaseUrl . $Script . $ScriptRunOnceUrlSuffix);
|
||||
}
|
||||
|
||||
:local Source;
|
||||
:do {
|
||||
:set Source ([ /tool/fetch check-certificate=yes-without-crl $Script output=user as-value ]->"data");
|
||||
} on-error={
|
||||
$LogPrintExit2 warning $0 ("Failed fetching script '" . $Script . "'!") false;
|
||||
}
|
||||
|
||||
:if ([ :len $Source ] > 0) do={
|
||||
:if ([ $ValidateSyntax $Source ] = true) do={
|
||||
:do {
|
||||
$LogPrintExit2 info $0 ("Running script '" . $Script . "' now.") false;
|
||||
[ :parse $Source ];
|
||||
} on-error={
|
||||
$LogPrintExit2 warning $0 ("The script '" . $Script . "' failed to run!") false;
|
||||
}
|
||||
} else={
|
||||
$LogPrintExit2 warning $0 ("The script '" . $Script . "' failed syntax validation!") false;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
#
|
||||
# dummy for migration
|
||||
|
|
|
|||
46
mod/scriptrunonce.rsc
Normal file
46
mod/scriptrunonce.rsc
Normal file
|
|
@ -0,0 +1,46 @@
|
|||
#!rsc by RouterOS
|
||||
# RouterOS script: mod/scriptrunonece
|
||||
# Copyright (c) 2020-2023 Christian Hesse <mail@eworm.de>
|
||||
# https://git.eworm.de/cgit/routeros-scripts/about/COPYING.md
|
||||
|
||||
:global ScriptRunOnce;
|
||||
|
||||
# fetch and run script(s) once
|
||||
:set ScriptRunOnce do={
|
||||
:local Scripts [ :toarray $1 ];
|
||||
|
||||
:global ScriptRunOnceBaseUrl;
|
||||
:global ScriptRunOnceUrlSuffix;
|
||||
|
||||
:global LogPrintExit2;
|
||||
:global ValidateSyntax;
|
||||
|
||||
:foreach Script in=$Scripts do={
|
||||
:if (!($Script ~ "^(ftp|https\?|sftp)://")) do={
|
||||
:if ([ :len $ScriptRunOnceBaseUrl ] = 0) do={
|
||||
$LogPrintExit2 warning $0 ("Script '" . $Script . "' is not an url and base url is not available.") true;
|
||||
}
|
||||
:set Script ($ScriptRunOnceBaseUrl . $Script . ".rsc" . $ScriptRunOnceUrlSuffix);
|
||||
}
|
||||
|
||||
:local Source;
|
||||
:do {
|
||||
:set Source ([ /tool/fetch check-certificate=yes-without-crl $Script output=user as-value ]->"data");
|
||||
} on-error={
|
||||
$LogPrintExit2 warning $0 ("Failed fetching script '" . $Script . "'!") false;
|
||||
}
|
||||
|
||||
:if ([ :len $Source ] > 0) do={
|
||||
:if ([ $ValidateSyntax $Source ] = true) do={
|
||||
:do {
|
||||
$LogPrintExit2 info $0 ("Running script '" . $Script . "' now.") false;
|
||||
[ :parse $Source ];
|
||||
} on-error={
|
||||
$LogPrintExit2 warning $0 ("The script '" . $Script . "' failed to run!") false;
|
||||
}
|
||||
} else={
|
||||
$LogPrintExit2 warning $0 ("The script '" . $Script . "' failed syntax validation!") false;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue