mirror of
https://git.eworm.de/cgit/routeros-scripts
synced 2025-06-27 03:48:57 +02:00
global-functions: sort alphabetically
This commit is contained in:
Christian Hesse
parent
3db752bc97
commit
001e7eeb39
17 changed files with 339 additions and 340 deletions
615
global-functions
615
global-functions
|
|
@ -9,89 +9,64 @@
|
|||
:global ExpectedConfigVersion 12;
|
||||
|
||||
# global variables not to be changed by user
|
||||
:global SentConfigChangesNotification "-";
|
||||
:global SentRouterosUpdateNotification "-";
|
||||
:global SentLteFirmwareUpgradeNotification "-";
|
||||
:global Identity [ / system identity get name ];
|
||||
:global SentConfigChangesNotification "-";
|
||||
:global SentLteFirmwareUpgradeNotification "-";
|
||||
:global SentRouterosUpdateNotification "-";
|
||||
|
||||
# global functions
|
||||
:global UrlEncode;
|
||||
:global CharacterReplace;
|
||||
:global CertificateNameByCN;
|
||||
:global CertificateDownload;
|
||||
:global CertificateAvailable;
|
||||
:global SendEMail;
|
||||
:global SendTelegram;
|
||||
:global SendNotification;
|
||||
:global GetMacVendor;
|
||||
:global CertificateDownload;
|
||||
:global CertificateNameByCN;
|
||||
:global CharacterReplace;
|
||||
:global CleanFilePath;
|
||||
:global DownloadPackage;
|
||||
:global ScriptLock;
|
||||
:global ScriptFromTerminal;
|
||||
:global WaitForFile;
|
||||
:global ParseKeyValueStore;
|
||||
:global GetRandom;
|
||||
:global RandomDelay;
|
||||
:global DeviceInfo;
|
||||
:global ScriptInstallUpdate;
|
||||
:global MailServerIsUp;
|
||||
:global TimeIsSync;
|
||||
:global WaitTimeSync;
|
||||
:global DownloadPackage;
|
||||
:global GetMacVendor;
|
||||
:global GetRandom;
|
||||
:global LogPrintExit;
|
||||
:global MailServerIsUp;
|
||||
:global ParseKeyValueStore;
|
||||
:global RandomDelay;
|
||||
:global ScriptFromTerminal;
|
||||
:global ScriptInstallUpdate;
|
||||
:global ScriptLock;
|
||||
:global SendEMail;
|
||||
:global SendNotification;
|
||||
:global SendTelegram;
|
||||
:global TimeIsSync;
|
||||
:global UrlEncode;
|
||||
:global WaitForFile;
|
||||
:global WaitTimeSync;
|
||||
|
||||
# url encoding
|
||||
:set UrlEncode do={
|
||||
:local Input [ :tostr $1 ];
|
||||
:local Return "";
|
||||
|
||||
:if ([ :len $Input ] > 0) do={
|
||||
:local Chars " !\"#\$%&'()*+,:;<=>\?@[\\]^`{|}~";
|
||||
:local Subs { "%20"; "%21"; "%22"; "%23"; "%24"; "%25"; "%26"; "%27"; "%28"; "%29";
|
||||
"%2A"; "%2B"; "%2C"; "%3A"; "%3B"; "%3C"; "%3D"; "%3E"; "%3F"; "%40";
|
||||
"%5B"; "%5C"; "%5D"; "%5E"; "%60"; "%7B"; "%7C"; "%7D"; "%7E" };
|
||||
|
||||
:for I from=0 to=([ :len $Input ] - 1) do={
|
||||
:local Char [ :pick $Input $I ];
|
||||
:local Replace [ :find $Chars $Char ];
|
||||
|
||||
:if ([ :len $Replace ] > 0) do={
|
||||
:set Char ($Subs->$Replace);
|
||||
}
|
||||
:set Return ($Return . $Char);
|
||||
}
|
||||
}
|
||||
|
||||
:return $Return;
|
||||
}
|
||||
|
||||
# character replace
|
||||
:set CharacterReplace do={
|
||||
:local String [ :tostr $1 ];
|
||||
:local ReplaceFrom [ :tostr $2 ];
|
||||
:local ReplaceWith [ :tostr $3 ];
|
||||
:local Return "";
|
||||
|
||||
:if ($ReplaceFrom = "") do={
|
||||
:return $String;
|
||||
}
|
||||
|
||||
:while ([ :typeof [ :find $String $ReplaceFrom ] ] != "nil") do={
|
||||
:local Pos [ :find $String $ReplaceFrom ];
|
||||
:set Return ($Return . [ :pick $String 0 $Pos ] . $ReplaceWith);
|
||||
:set String [ :pick $String ($Pos + [ :len $ReplaceFrom ]) [ :len $String ] ];
|
||||
}
|
||||
|
||||
:return ($Return . $String);
|
||||
}
|
||||
|
||||
# name a certificate by its common-name
|
||||
:set CertificateNameByCN do={
|
||||
# check and download required certificate
|
||||
:set CertificateAvailable do={
|
||||
:local CommonName [ :tostr $1 ];
|
||||
|
||||
:global CharacterReplace;
|
||||
:global CertificateDownload;
|
||||
:global ParseKeyValueStore;
|
||||
|
||||
:local Cert [ / certificate find where common-name=$CommonName ];
|
||||
/ certificate set $Cert name=[ $CharacterReplace [ $CharacterReplace $CommonName " " "-" ] "---" "-" ];
|
||||
:if ([ / system resource get free-hdd-space ] < 8388608 && \
|
||||
[ / certificate settings get crl-download ] = true && \
|
||||
[ / certificate settings get crl-store ] = "system") do={
|
||||
:log warn "This system has low free flash space but is configured to download certificate CRLs to system!";
|
||||
}
|
||||
|
||||
:if ([ / certificate print count-only where common-name=$CommonName ] = 0) do={
|
||||
:log info ("Certificate with CommonName \"" . $CommonName . "\" not available.");
|
||||
$CertificateDownload $CommonName;
|
||||
}
|
||||
|
||||
:local CertVal;
|
||||
:local Issuer $CommonName;
|
||||
:do {
|
||||
:if ([ / certificate print count-only where common-name=$Issuer ] = 0) do={
|
||||
:log info ("Certificate chain for \"" . $CommonName . "\" is incomplete, missing \"" . $Issuer . "\".");
|
||||
$CertificateDownload $CommonName;
|
||||
}
|
||||
:set CertVal [ / certificate get [ find where common-name=$Issuer ] ];
|
||||
:set Issuer ([ $ParseKeyValueStore ($CertVal->"issuer") ]->"CN");
|
||||
} while=($Issuer != $CertVal->"common-name");
|
||||
}
|
||||
|
||||
# download and import certificate
|
||||
|
|
@ -126,118 +101,34 @@
|
|||
}
|
||||
}
|
||||
|
||||
# check and download required certificate
|
||||
:set CertificateAvailable do={
|
||||
# name a certificate by its common-name
|
||||
:set CertificateNameByCN do={
|
||||
:local CommonName [ :tostr $1 ];
|
||||
|
||||
:global CertificateDownload;
|
||||
:global ParseKeyValueStore;
|
||||
:global CharacterReplace;
|
||||
|
||||
:if ([ / system resource get free-hdd-space ] < 8388608 && \
|
||||
[ / certificate settings get crl-download ] = true && \
|
||||
[ / certificate settings get crl-store ] = "system") do={
|
||||
:log warn "This system has low free flash space but is configured to download certificate CRLs to system!";
|
||||
}
|
||||
|
||||
:if ([ / certificate print count-only where common-name=$CommonName ] = 0) do={
|
||||
:log info ("Certificate with CommonName \"" . $CommonName . "\" not available.");
|
||||
$CertificateDownload $CommonName;
|
||||
}
|
||||
|
||||
:local CertVal;
|
||||
:local Issuer $CommonName;
|
||||
:do {
|
||||
:if ([ / certificate print count-only where common-name=$Issuer ] = 0) do={
|
||||
:log info ("Certificate chain for \"" . $CommonName . "\" is incomplete, missing \"" . $Issuer . "\".");
|
||||
$CertificateDownload $CommonName;
|
||||
}
|
||||
:set CertVal [ / certificate get [ find where common-name=$Issuer ] ];
|
||||
:set Issuer ([ $ParseKeyValueStore ($CertVal->"issuer") ]->"CN");
|
||||
} while=($Issuer != $CertVal->"common-name");
|
||||
:local Cert [ / certificate find where common-name=$CommonName ];
|
||||
/ certificate set $Cert name=[ $CharacterReplace [ $CharacterReplace $CommonName " " "-" ] "---" "-" ];
|
||||
}
|
||||
|
||||
# send notification via e-mail
|
||||
:set SendEMail do={
|
||||
:local Subject [ :tostr $1 ];
|
||||
:local Message [ :tostr $2 ];
|
||||
:local Attach [ :tostr $3 ];
|
||||
# character replace
|
||||
:set CharacterReplace do={
|
||||
:local String [ :tostr $1 ];
|
||||
:local ReplaceFrom [ :tostr $2 ];
|
||||
:local ReplaceWith [ :tostr $3 ];
|
||||
:local Return "";
|
||||
|
||||
:global Identity;
|
||||
:global EmailGeneralTo;
|
||||
:global EmailGeneralCc;
|
||||
|
||||
:if ([ :len $EmailGeneralTo ] > 0) do={
|
||||
:do {
|
||||
:local Signature [ / system note get note ];
|
||||
:if ([ :len $Signature ] > 0) do={
|
||||
:set Signature ("\n-- \n" . $Signature);
|
||||
}
|
||||
/ tool e-mail send to=$EmailGeneralTo cc=$EmailGeneralCc \
|
||||
subject=("[" . $Identity . "] " . $Subject) \
|
||||
body=($Message . $Signature) file=$Attach;
|
||||
} on-error={
|
||||
:log warning "Failed sending notification mail!";
|
||||
}
|
||||
:if ($ReplaceFrom = "") do={
|
||||
:return $String;
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via telegram
|
||||
:set SendTelegram do={
|
||||
:local Subject [ :tostr $1 ];
|
||||
:local Message [ :tostr $2 ];
|
||||
:local Silent [ :tostr $3 ];
|
||||
|
||||
:global Identity;
|
||||
:global TelegramTokenId;
|
||||
:global TelegramChatId;
|
||||
|
||||
:global UrlEncode;
|
||||
:global CertificateAvailable;
|
||||
|
||||
:if ([ :len $TelegramTokenId ] > 0 && [ :len $TelegramChatId ] > 0) do={
|
||||
$CertificateAvailable "Go Daddy Secure Certificate Authority - G2";
|
||||
:do {
|
||||
/ tool fetch check-certificate=yes-without-crl output=none http-method=post \
|
||||
("https://api.telegram.org/bot" . $TelegramTokenId . "/sendMessage") \
|
||||
http-data=("chat_id=" . $TelegramChatId . "&disable_notification=" . $Silent . \
|
||||
"&text=" . [ $UrlEncode ("[" . $Identity . "] " . $Subject . "\n\n" . $Message) ]);
|
||||
} on-error={
|
||||
:log warning "Failed sending telegram notification!";
|
||||
}
|
||||
:while ([ :typeof [ :find $String $ReplaceFrom ] ] != "nil") do={
|
||||
:local Pos [ :find $String $ReplaceFrom ];
|
||||
:set Return ($Return . [ :pick $String 0 $Pos ] . $ReplaceWith);
|
||||
:set String [ :pick $String ($Pos + [ :len $ReplaceFrom ]) [ :len $String ] ];
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via e-mail and telegram
|
||||
# Note that attachment is ignored for telegram, silent is ignored for e-mail!
|
||||
:set SendNotification do={
|
||||
:local Subject [ :tostr $1 ];
|
||||
:local Message [ :tostr $2 ];
|
||||
:local Attach [ :tostr $3 ];
|
||||
:local Silent [ :tostr $4 ];
|
||||
|
||||
:global SendEMail;
|
||||
:global SendTelegram;
|
||||
|
||||
$SendEMail $Subject $Message $Attach;
|
||||
$SendTelegram $Subject $Message $Silent;
|
||||
}
|
||||
|
||||
|
||||
# get MAC vendor
|
||||
:set GetMacVendor do={
|
||||
:local Mac [ :tostr $1 ];
|
||||
|
||||
:global CertificateAvailable;
|
||||
|
||||
:do {
|
||||
:local Vendor;
|
||||
$CertificateAvailable "Let's Encrypt Authority X3";
|
||||
:set Vendor ([ / tool fetch check-certificate=yes-without-crl \
|
||||
("https://api.macvendors.com/" . [ :pick $Mac 0 8 ]) output=user as-value ]->"data");
|
||||
:return $Vendor;
|
||||
} on-error={
|
||||
:return "unknown vendor";
|
||||
}
|
||||
:return ($Return . $String);
|
||||
}
|
||||
|
||||
# clean file path
|
||||
|
|
@ -259,6 +150,49 @@
|
|||
:return $Path;
|
||||
}
|
||||
|
||||
# get readable device info
|
||||
:set DeviceInfo do={
|
||||
:global ExpectedConfigVersion;
|
||||
:global GlobalConfigVersion;
|
||||
:global Identity;
|
||||
|
||||
:local Resource [ / system resource get ];
|
||||
:local RouterBoard [ / system routerboard get ];
|
||||
:local Update [ / system package update get ];
|
||||
|
||||
:local Info ( \
|
||||
"Hostname: " . $Identity . "\n" . \
|
||||
"Board name: " . $Resource->"board-name" . "\n" . \
|
||||
"Architecture: " . $Resource->"architecture-name");
|
||||
:if ($RouterBoard->"routerboard" = true) do={
|
||||
:local Revision "";
|
||||
:if ([ :len ($RouterBoard->"revision") ] > 0) do={
|
||||
:set Revision (" " . $RouterBoard->"revision");
|
||||
}
|
||||
:set Info ($Info . "\n" . \
|
||||
"Model: " . $RouterBoard->"model" . $Revision . "\n" . \
|
||||
"Serial number: " . $RouterBoard->"serial-number");
|
||||
}
|
||||
:set Info ($Info . "\n" . \
|
||||
"RouterOS:\n" . \
|
||||
" Channel: " . $Update->"channel" . "\n" . \
|
||||
" Installed: " . $Update->"installed-version");
|
||||
:if ([ :typeof ($Update->"latest-version") ] != "nothing" && \
|
||||
$Update->"installed-version" != $Update->"latest-version") do={
|
||||
:set Info ($Info . "\n" . \
|
||||
" Available: " . $Update->"latest-version");
|
||||
}
|
||||
:set Info ($Info . "\n" . \
|
||||
"RouterOS-Scripts Configuration Version:\n" . \
|
||||
" Current: " . $GlobalConfigVersion);
|
||||
:if ($GlobalConfigVersion != $ExpectedConfigVersion) do={
|
||||
:set Info ($Info . "\n" . \
|
||||
" Expected: " . $ExpectedConfigVersion);
|
||||
}
|
||||
|
||||
:return $Info;
|
||||
}
|
||||
|
||||
# download package from upgrade server
|
||||
:set DownloadPackage do={
|
||||
:local PkgName [ :tostr $1 ];
|
||||
|
|
@ -304,68 +238,23 @@
|
|||
:return false;
|
||||
}
|
||||
|
||||
# lock script against multiple invocation
|
||||
:set ScriptLock do={
|
||||
:global LogPrintExit;
|
||||
# get MAC vendor
|
||||
:set GetMacVendor do={
|
||||
:local Mac [ :tostr $1 ];
|
||||
|
||||
:local Script [ :tostr $1 ];
|
||||
:global CertificateAvailable;
|
||||
|
||||
:if ([ / system script job print count-only where script=$Script ] > 1) do={
|
||||
$LogPrintExit info ("Script " . $Script . " started more than once... Aborting.") true;
|
||||
:do {
|
||||
:local Vendor;
|
||||
$CertificateAvailable "Let's Encrypt Authority X3";
|
||||
:set Vendor ([ / tool fetch check-certificate=yes-without-crl \
|
||||
("https://api.macvendors.com/" . [ :pick $Mac 0 8 ]) output=user as-value ]->"data");
|
||||
:return $Vendor;
|
||||
} on-error={
|
||||
:return "unknown vendor";
|
||||
}
|
||||
}
|
||||
|
||||
# check if script is run from terminal
|
||||
:set ScriptFromTerminal do={
|
||||
:local Script [ :tostr $1 ];
|
||||
|
||||
:foreach Job in=[ / system script job find where script=$Script ] do={
|
||||
:set Job [ / system script job get $Job ];
|
||||
:while ([ :typeof ($Job->"parent") ] = "id") do={
|
||||
:set Job [ / system script job get [ find where .id=($Job->"parent") ] ];
|
||||
}
|
||||
:if (($Job->"type") = "login") do={
|
||||
:log debug ("Script " . $Script . " started from terminal.");
|
||||
:return true;
|
||||
}
|
||||
}
|
||||
|
||||
:return false;
|
||||
}
|
||||
|
||||
# wait for file to be available
|
||||
:set WaitForFile do={
|
||||
:global CleanFilePath;
|
||||
|
||||
:local FileName [ $CleanFilePath [ :tostr $1 ] ];
|
||||
:local I 0;
|
||||
|
||||
:while ([ file print count-only where name=$FileName ] = 0) do={
|
||||
:if ($I > 20) do={
|
||||
:return false;
|
||||
}
|
||||
:delay 100ms;
|
||||
:set I ($I + 1);
|
||||
}
|
||||
:return true;
|
||||
}
|
||||
|
||||
# parse key value store
|
||||
:set ParseKeyValueStore do={
|
||||
:global CharacterReplace;
|
||||
|
||||
:local Source $1;
|
||||
:if ([ :typeof $Source ] != "array") do={
|
||||
:set Source [ :tostr $1 ];
|
||||
}
|
||||
:local Result [ :toarray "" ];
|
||||
:foreach KeyValue in=[ :toarray $Source ] do={
|
||||
:set KeyValue [ :toarray [ $CharacterReplace $KeyValue "=" "," ] ];
|
||||
:set ($Result->($KeyValue->0)) ($KeyValue->1);
|
||||
}
|
||||
:return $Result;
|
||||
}
|
||||
|
||||
# generate random number
|
||||
# Warning: This is a *very* weak algorithm and in *no way*
|
||||
# useful for cryptography or similar!
|
||||
|
|
@ -379,67 +268,24 @@
|
|||
:return ($Sum % $Max);
|
||||
}
|
||||
|
||||
# delay a random amount of seconds
|
||||
:set RandomDelay do={
|
||||
:global GetRandom;
|
||||
# log and print with same text, optionally exit
|
||||
:set LogPrintExit do={
|
||||
:local Severity [ :tostr $1 ];
|
||||
:local Message [ :tostr $2 ];
|
||||
:local Exit [ :tostr $3 ];
|
||||
|
||||
:delay ([ $GetRandom $1 ] . "s");
|
||||
}
|
||||
|
||||
# get readable device info
|
||||
:set DeviceInfo do={
|
||||
:global ExpectedConfigVersion;
|
||||
:global GlobalConfigVersion;
|
||||
:global Identity;
|
||||
|
||||
:local Resource [ / system resource get ];
|
||||
:local RouterBoard [ / system routerboard get ];
|
||||
:local Update [ / system package update get ];
|
||||
|
||||
:local Info ( \
|
||||
"Hostname: " . $Identity . "\n" . \
|
||||
"Board name: " . $Resource->"board-name" . "\n" . \
|
||||
"Architecture: " . $Resource->"architecture-name");
|
||||
:if ($RouterBoard->"routerboard" = true) do={
|
||||
:local Revision "";
|
||||
:if ([ :len ($RouterBoard->"revision") ] > 0) do={
|
||||
:set Revision (" " . $RouterBoard->"revision");
|
||||
}
|
||||
:set Info ($Info . "\n" . \
|
||||
"Model: " . $RouterBoard->"model" . $Revision . "\n" . \
|
||||
"Serial number: " . $RouterBoard->"serial-number");
|
||||
}
|
||||
:set Info ($Info . "\n" . \
|
||||
"RouterOS:\n" . \
|
||||
" Channel: " . $Update->"channel" . "\n" . \
|
||||
" Installed: " . $Update->"installed-version");
|
||||
:if ([ :typeof ($Update->"latest-version") ] != "nothing" && \
|
||||
$Update->"installed-version" != $Update->"latest-version") do={
|
||||
:set Info ($Info . "\n" . \
|
||||
" Available: " . $Update->"latest-version");
|
||||
}
|
||||
:set Info ($Info . "\n" . \
|
||||
"RouterOS-Scripts Configuration Version:\n" . \
|
||||
" Current: " . $GlobalConfigVersion);
|
||||
:if ($GlobalConfigVersion != $ExpectedConfigVersion) do={
|
||||
:set Info ($Info . "\n" . \
|
||||
" Expected: " . $ExpectedConfigVersion);
|
||||
:if ($Severity ~ "^(error|info)\$") do={
|
||||
:if ($Severity = "error" ) do={ :log error $Message; }
|
||||
:if ($Severity = "info" ) do={ :log info $Message; }
|
||||
} else={
|
||||
:log warning $Message;
|
||||
}
|
||||
|
||||
:return $Info;
|
||||
}
|
||||
|
||||
# install new scripts, update existing scripts
|
||||
:set ScriptInstallUpdate do={
|
||||
:local Scripts [ :toarray $1 ];
|
||||
|
||||
:foreach Script in=$Scripts do={
|
||||
:if ([ / system script print count-only where name=$Script ] = 0) do={
|
||||
:log info ("Adding new script: " . $Script);
|
||||
/ system script add name=$Script source="#!rsc";
|
||||
}
|
||||
:if ($Exit = "true") do={
|
||||
:error ($Severity . ": " . $Message);
|
||||
} else={
|
||||
:put ($Severity . ": " . $Message);
|
||||
}
|
||||
/ system script run script-updates;
|
||||
}
|
||||
|
||||
# check if mail server is up
|
||||
|
|
@ -463,6 +309,137 @@
|
|||
:return false;
|
||||
}
|
||||
|
||||
# parse key value store
|
||||
:set ParseKeyValueStore do={
|
||||
:global CharacterReplace;
|
||||
|
||||
:local Source $1;
|
||||
:if ([ :typeof $Source ] != "array") do={
|
||||
:set Source [ :tostr $1 ];
|
||||
}
|
||||
:local Result [ :toarray "" ];
|
||||
:foreach KeyValue in=[ :toarray $Source ] do={
|
||||
:set KeyValue [ :toarray [ $CharacterReplace $KeyValue "=" "," ] ];
|
||||
:set ($Result->($KeyValue->0)) ($KeyValue->1);
|
||||
}
|
||||
:return $Result;
|
||||
}
|
||||
|
||||
# delay a random amount of seconds
|
||||
:set RandomDelay do={
|
||||
:global GetRandom;
|
||||
|
||||
:delay ([ $GetRandom $1 ] . "s");
|
||||
}
|
||||
|
||||
# check if script is run from terminal
|
||||
:set ScriptFromTerminal do={
|
||||
:local Script [ :tostr $1 ];
|
||||
|
||||
:foreach Job in=[ / system script job find where script=$Script ] do={
|
||||
:set Job [ / system script job get $Job ];
|
||||
:while ([ :typeof ($Job->"parent") ] = "id") do={
|
||||
:set Job [ / system script job get [ find where .id=($Job->"parent") ] ];
|
||||
}
|
||||
:if (($Job->"type") = "login") do={
|
||||
:log debug ("Script " . $Script . " started from terminal.");
|
||||
:return true;
|
||||
}
|
||||
}
|
||||
|
||||
:return false;
|
||||
}
|
||||
|
||||
# install new scripts, update existing scripts
|
||||
:set ScriptInstallUpdate do={
|
||||
:local Scripts [ :toarray $1 ];
|
||||
|
||||
:foreach Script in=$Scripts do={
|
||||
:if ([ / system script print count-only where name=$Script ] = 0) do={
|
||||
:log info ("Adding new script: " . $Script);
|
||||
/ system script add name=$Script source="#!rsc";
|
||||
}
|
||||
}
|
||||
/ system script run script-updates;
|
||||
}
|
||||
|
||||
# lock script against multiple invocation
|
||||
:set ScriptLock do={
|
||||
:global LogPrintExit;
|
||||
|
||||
:local Script [ :tostr $1 ];
|
||||
|
||||
:if ([ / system script job print count-only where script=$Script ] > 1) do={
|
||||
$LogPrintExit info ("Script " . $Script . " started more than once... Aborting.") true;
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via e-mail
|
||||
:set SendEMail do={
|
||||
:local Subject [ :tostr $1 ];
|
||||
:local Message [ :tostr $2 ];
|
||||
:local Attach [ :tostr $3 ];
|
||||
|
||||
:global Identity;
|
||||
:global EmailGeneralTo;
|
||||
:global EmailGeneralCc;
|
||||
|
||||
:if ([ :len $EmailGeneralTo ] > 0) do={
|
||||
:do {
|
||||
:local Signature [ / system note get note ];
|
||||
:if ([ :len $Signature ] > 0) do={
|
||||
:set Signature ("\n-- \n" . $Signature);
|
||||
}
|
||||
/ tool e-mail send to=$EmailGeneralTo cc=$EmailGeneralCc \
|
||||
subject=("[" . $Identity . "] " . $Subject) \
|
||||
body=($Message . $Signature) file=$Attach;
|
||||
} on-error={
|
||||
:log warning "Failed sending notification mail!";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
# send notification via e-mail and telegram
|
||||
# Note that attachment is ignored for telegram, silent is ignored for e-mail!
|
||||
:set SendNotification do={
|
||||
:local Subject [ :tostr $1 ];
|
||||
:local Message [ :tostr $2 ];
|
||||
:local Attach [ :tostr $3 ];
|
||||
:local Silent [ :tostr $4 ];
|
||||
|
||||
:global SendEMail;
|
||||
:global SendTelegram;
|
||||
|
||||
$SendEMail $Subject $Message $Attach;
|
||||
$SendTelegram $Subject $Message $Silent;
|
||||
}
|
||||
|
||||
# send notification via telegram
|
||||
:set SendTelegram do={
|
||||
:local Subject [ :tostr $1 ];
|
||||
:local Message [ :tostr $2 ];
|
||||
:local Silent [ :tostr $3 ];
|
||||
|
||||
:global Identity;
|
||||
:global TelegramTokenId;
|
||||
:global TelegramChatId;
|
||||
|
||||
:global UrlEncode;
|
||||
:global CertificateAvailable;
|
||||
|
||||
:if ([ :len $TelegramTokenId ] > 0 && [ :len $TelegramChatId ] > 0) do={
|
||||
$CertificateAvailable "Go Daddy Secure Certificate Authority - G2";
|
||||
:do {
|
||||
/ tool fetch check-certificate=yes-without-crl output=none http-method=post \
|
||||
("https://api.telegram.org/bot" . $TelegramTokenId . "/sendMessage") \
|
||||
http-data=("chat_id=" . $TelegramChatId . "&disable_notification=" . $Silent . \
|
||||
"&text=" . [ $UrlEncode ("[" . $Identity . "] " . $Subject . "\n\n" . $Message) ]);
|
||||
} on-error={
|
||||
:log warning "Failed sending telegram notification!";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
# check if system time is sync
|
||||
:set TimeIsSync do={
|
||||
:if ([ / system ntp client get enabled ] = true && \
|
||||
|
|
@ -478,6 +455,48 @@
|
|||
:return false;
|
||||
}
|
||||
|
||||
# url encoding
|
||||
:set UrlEncode do={
|
||||
:local Input [ :tostr $1 ];
|
||||
:local Return "";
|
||||
|
||||
:if ([ :len $Input ] > 0) do={
|
||||
:local Chars " !\"#\$%&'()*+,:;<=>\?@[\\]^`{|}~";
|
||||
:local Subs { "%20"; "%21"; "%22"; "%23"; "%24"; "%25"; "%26"; "%27"; "%28"; "%29";
|
||||
"%2A"; "%2B"; "%2C"; "%3A"; "%3B"; "%3C"; "%3D"; "%3E"; "%3F"; "%40";
|
||||
"%5B"; "%5C"; "%5D"; "%5E"; "%60"; "%7B"; "%7C"; "%7D"; "%7E" };
|
||||
|
||||
:for I from=0 to=([ :len $Input ] - 1) do={
|
||||
:local Char [ :pick $Input $I ];
|
||||
:local Replace [ :find $Chars $Char ];
|
||||
|
||||
:if ([ :len $Replace ] > 0) do={
|
||||
:set Char ($Subs->$Replace);
|
||||
}
|
||||
:set Return ($Return . $Char);
|
||||
}
|
||||
}
|
||||
|
||||
:return $Return;
|
||||
}
|
||||
|
||||
# wait for file to be available
|
||||
:set WaitForFile do={
|
||||
:global CleanFilePath;
|
||||
|
||||
:local FileName [ $CleanFilePath [ :tostr $1 ] ];
|
||||
:local I 0;
|
||||
|
||||
:while ([ file print count-only where name=$FileName ] = 0) do={
|
||||
:if ($I > 20) do={
|
||||
:return false;
|
||||
}
|
||||
:delay 100ms;
|
||||
:set I ($I + 1);
|
||||
}
|
||||
:return true;
|
||||
}
|
||||
|
||||
# wait for time to become synced
|
||||
:set WaitTimeSync do={
|
||||
:global TimeIsSync;
|
||||
|
|
@ -490,23 +509,3 @@
|
|||
:delay 1s;
|
||||
}
|
||||
}
|
||||
|
||||
# log and print with same text, optionally exit
|
||||
:set LogPrintExit do={
|
||||
:local Severity [ :tostr $1 ];
|
||||
:local Message [ :tostr $2 ];
|
||||
:local Exit [ :tostr $3 ];
|
||||
|
||||
:if ($Severity ~ "^(error|info)\$") do={
|
||||
:if ($Severity = "error" ) do={ :log error $Message; }
|
||||
:if ($Severity = "info" ) do={ :log info $Message; }
|
||||
} else={
|
||||
:log warning $Message;
|
||||
}
|
||||
|
||||
:if ($Exit = "true") do={
|
||||
:error ($Severity . ": " . $Message);
|
||||
} else={
|
||||
:put ($Severity . ": " . $Message);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue