Compare commits
25 commits
20190211.3
...
master
Author | SHA1 | Date | |
---|---|---|---|
flash | 9178cd5e14 | ||
flash | 866bd93afa | ||
flash | b6656506ee | ||
flash | b793af9157 | ||
flash | dd7b63fc24 | ||
flash | 1f9ac0552a | ||
flash | cbe982ba77 | ||
flash | 8bf5a00a40 | ||
flash | e1c57d76a2 | ||
flash | b81e048f06 | ||
flash | 82eeaa93ab | ||
flash | b541481e9b | ||
flash | cc2d295273 | ||
flash | b4c409991e | ||
flash | cf732fac93 | ||
flash | 44b80b9707 | ||
flash | f3c9bc18b2 | ||
flash | 1e8e180a78 | ||
flash | 33b50e9323 | ||
flash | 9365f34399 | ||
flash | f251c26102 | ||
flash | 451fabd371 | ||
flash | 25e9f6a994 | ||
flash | 8a79ec6a8f | ||
flash | 36644423f5 |
|
@ -1,12 +1,12 @@
|
|||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>netcoreapp2.2</TargetFramework>
|
||||
<TargetFramework>net6.0</TargetFramework>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="SSH.NET" Version="2016.1.0" />
|
||||
<PackageReference Include="MySql.Data" Version="8.1.0" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
|
|
|
@ -1,31 +1,11 @@
|
|||
namespace BackupManager
|
||||
{
|
||||
public class Config
|
||||
{
|
||||
public StorageMethod StorageMethod { get; set; } = StorageMethod.Sftp;
|
||||
|
||||
public string SftpHost { get; set; }
|
||||
public ushort SftpPort { get; set; }
|
||||
public string SftpUsername { get; set; }
|
||||
public string SftpPassphrase { get; set; }
|
||||
public string SftpPrivateKey { get; set; }
|
||||
public string SftpBackupDirectoryPath { get; set; }
|
||||
public string SftpTrustedHost { get; set; }
|
||||
namespace BackupManager {
|
||||
public class Config {
|
||||
public string FileSystemPathV2 { get; set; }
|
||||
|
||||
public string FileSystemPath { get; set; } = @"backups";
|
||||
|
||||
public string MySqlDumpPathWindows { get; set; } = @"C:\Program Files\MySQL\MySQL Server 8.0\bin\mysqldump.exe";
|
||||
public string MySqlDumpPath { get; set; } = @"mysqldump";
|
||||
public string MySqlHost { get; set; } = @"localhost";
|
||||
public string MySqlUser { get; set; }
|
||||
public string MySqlPass { get; set; }
|
||||
public string MySqlDatabases { get; set; } = @"misuzu";
|
||||
|
||||
public string MisuzuPath { get; set; }
|
||||
|
||||
public string SatoriHost { get; set; }
|
||||
public ushort SatoriPort { get; set; }
|
||||
public string SatoriSecret { get; set; }
|
||||
public bool SatoriErrorsOnly { get; set; } = true;
|
||||
public string MySqlExcludeDatabases { get; set; } = @"mysql information_schema performance_schema";
|
||||
}
|
||||
}
|
||||
|
|
|
@ -1,37 +1,26 @@
|
|||
using Renci.SshNet;
|
||||
using Renci.SshNet.Common;
|
||||
using MySql.Data.MySqlClient;
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Diagnostics;
|
||||
using System.IO;
|
||||
using System.IO.Compression;
|
||||
using System.Linq;
|
||||
using System.Net;
|
||||
using System.Net.Sockets;
|
||||
using System.Runtime.InteropServices;
|
||||
using System.Security.Cryptography;
|
||||
using System.Text;
|
||||
using System.Threading;
|
||||
using System.Xml;
|
||||
using System.Xml.Serialization;
|
||||
|
||||
namespace BackupManager
|
||||
{
|
||||
public static class Program
|
||||
{
|
||||
public readonly static Stopwatch sw = new Stopwatch();
|
||||
public static class Program {
|
||||
public readonly static Stopwatch sw = new();
|
||||
|
||||
private const string CONFIG_NAME = @"FlashiiBackupManager.v1.xml";
|
||||
|
||||
public static bool IsWindows
|
||||
=> RuntimeInformation.IsOSPlatform(OSPlatform.Windows);
|
||||
|
||||
public readonly static DateTimeOffset Startup = DateTimeOffset.UtcNow;
|
||||
|
||||
public static string Basename
|
||||
=> $@"{Environment.MachineName} {Startup.Year:0000}-{Startup.Month:00}-{Startup.Day:00} {Startup.Hour:00}{Startup.Minute:00}{Startup.Second:00}";
|
||||
public static string DatabaseDumpName
|
||||
=> $@"{Basename}.sql.gz";
|
||||
public static string UserDataName
|
||||
public static string BackupName
|
||||
=> $@"{Basename}.zip";
|
||||
|
||||
private static Config Config;
|
||||
|
@ -40,445 +29,190 @@ namespace BackupManager
|
|||
CONFIG_NAME
|
||||
);
|
||||
|
||||
private static object BackupStorage;
|
||||
public static string BackupStore => string.IsNullOrWhiteSpace(Config.FileSystemPathV2)
|
||||
? Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.Personal), @"Backups")
|
||||
: Config.FileSystemPathV2;
|
||||
|
||||
private static SftpClient SFTP;
|
||||
private static bool Headless;
|
||||
|
||||
public static bool Headless;
|
||||
public static Stream ToXml(this object obj, bool pretty = false) {
|
||||
MemoryStream ms = new();
|
||||
XmlSerializer xs = new(obj.GetType());
|
||||
|
||||
public static string WindowsToUnixPath(this string path)
|
||||
{
|
||||
return IsWindows ? path.Replace('\\', '/') : path;
|
||||
}
|
||||
|
||||
public static Stream ToXml(this object obj, bool pretty = false)
|
||||
{
|
||||
MemoryStream ms = new MemoryStream();
|
||||
XmlSerializer xs = new XmlSerializer(obj.GetType());
|
||||
|
||||
using (XmlWriter xw = XmlWriter.Create(ms, new XmlWriterSettings { Indent = pretty }))
|
||||
using(XmlWriter xw = XmlWriter.Create(ms, new XmlWriterSettings { Indent = pretty }))
|
||||
xs.Serialize(xw, obj);
|
||||
|
||||
ms.Seek(0, SeekOrigin.Begin);
|
||||
return ms;
|
||||
}
|
||||
|
||||
public static T FromXml<T>(Stream xml)
|
||||
{
|
||||
if (xml.CanSeek)
|
||||
public static T FromXml<T>(Stream xml) {
|
||||
if(xml.CanSeek)
|
||||
xml.Seek(0, SeekOrigin.Begin);
|
||||
|
||||
XmlSerializer xs = new XmlSerializer(typeof(T));
|
||||
XmlSerializer xs = new(typeof(T));
|
||||
return (T)xs.Deserialize(xml);
|
||||
}
|
||||
|
||||
public static void SaveConfig()
|
||||
{
|
||||
public static void SaveConfig() {
|
||||
Log(@"Saving configuration...");
|
||||
using (FileStream fs = new FileStream(ConfigPath, FileMode.Create, FileAccess.Write))
|
||||
using (Stream cs = Config.ToXml(true))
|
||||
cs.CopyTo(fs);
|
||||
using FileStream fs = new(ConfigPath, FileMode.Create, FileAccess.Write);
|
||||
using Stream cs = Config.ToXml(true);
|
||||
cs.CopyTo(fs);
|
||||
}
|
||||
|
||||
public static void LoadConfig()
|
||||
{
|
||||
public static void LoadConfig() {
|
||||
Log(@"Loading configuration...");
|
||||
using (FileStream fs = File.OpenRead(ConfigPath))
|
||||
Config = FromXml<Config>(fs);
|
||||
using FileStream fs = File.OpenRead(ConfigPath);
|
||||
Config = FromXml<Config>(fs);
|
||||
}
|
||||
|
||||
public static void Main(string[] args)
|
||||
{
|
||||
public static void Main(string[] args) {
|
||||
Headless = args.Contains(@"-cron") || args.Contains(@"-headless");
|
||||
|
||||
Log(@"Flashii Backup Manager");
|
||||
sw.Start();
|
||||
|
||||
if (!File.Exists(ConfigPath))
|
||||
{
|
||||
if(!File.Exists(ConfigPath)) {
|
||||
Config = new Config();
|
||||
SaveConfig();
|
||||
Error(@"No configuration file exists, created a blank one. Be sure to fill it out properly.");
|
||||
}
|
||||
|
||||
LoadConfig();
|
||||
|
||||
switch (Config.StorageMethod)
|
||||
{
|
||||
case StorageMethod.Sftp:
|
||||
if (string.IsNullOrWhiteSpace(Config.SftpHost) || string.IsNullOrWhiteSpace(Config.SftpUsername))
|
||||
{
|
||||
sw.Stop();
|
||||
Config.SftpHost = Config.SftpHost ?? @"";
|
||||
Config.SftpPort = Config.SftpPort < 1 ? (ushort)22 : Config.SftpPort;
|
||||
Config.SftpUsername = Config.SftpUsername ?? @"";
|
||||
Config.SftpPassphrase = Config.SftpPassphrase ?? @"";
|
||||
Config.SftpPrivateKey = Config.SftpPrivateKey ?? @"";
|
||||
Config.SftpTrustedHost = Config.SftpTrustedHost ?? @"";
|
||||
Config.SftpBackupDirectoryPath = Config.SftpBackupDirectoryPath ?? @"";
|
||||
SaveConfig();
|
||||
Error(@"No Sftp host/auth details found in the configuration.");
|
||||
}
|
||||
|
||||
if (!string.IsNullOrEmpty(Config.SftpPrivateKey))
|
||||
SFTP = new SftpClient(Config.SftpHost, Config.SftpPort, Config.SftpUsername, new PrivateKeyFile(Config.SftpPrivateKey, Config.SftpPassphrase ?? string.Empty));
|
||||
else
|
||||
SFTP = new SftpClient(Config.SftpHost, Config.SftpPort, Config.SftpUsername, Config.SftpPassphrase ?? string.Empty);
|
||||
if(!Directory.Exists(BackupStore))
|
||||
Directory.CreateDirectory(BackupStore);
|
||||
|
||||
using (ManualResetEvent mre = new ManualResetEvent(false))
|
||||
{
|
||||
if (!string.IsNullOrWhiteSpace(Config.SftpTrustedHost))
|
||||
SFTP.HostKeyReceived += (s, e) =>
|
||||
{
|
||||
string checkString = e.HostKeyName + @"#" + Convert.ToBase64String(e.HostKey) + @"#" + Convert.ToBase64String(e.FingerPrint);
|
||||
e.CanTrust = Config.SftpTrustedHost.SequenceEqual(checkString);
|
||||
mre.Set();
|
||||
};
|
||||
else
|
||||
mre.Set();
|
||||
Log(@"Fetching database list...");
|
||||
|
||||
try
|
||||
{
|
||||
SFTP.Connect();
|
||||
} catch (SshConnectionException)
|
||||
{
|
||||
Error(@"Error during SFTP connect, it's possible the server key changed.");
|
||||
}
|
||||
MySqlConnectionStringBuilder connStr = new() {
|
||||
Server = Config.MySqlHost,
|
||||
UserID = Config.MySqlUser,
|
||||
Password = Config.MySqlPass,
|
||||
CharacterSet = @"utf8mb4",
|
||||
SslMode = MySqlSslMode.Disabled,
|
||||
};
|
||||
|
||||
mre.WaitOne();
|
||||
}
|
||||
break;
|
||||
List<string> databases = new();
|
||||
string[] exclude = Config.MySqlExcludeDatabases.Split(' ');
|
||||
|
||||
case StorageMethod.FileSystem:
|
||||
if (!Directory.Exists(Config.FileSystemPath))
|
||||
Directory.CreateDirectory(Config.FileSystemPath);
|
||||
break;
|
||||
}
|
||||
using(MySqlConnection conn = new(connStr.ToString())) {
|
||||
conn.Open();
|
||||
|
||||
GetBackupStorage();
|
||||
using(MySqlCommand comm = new(@"SET NAMES 'utf8mb4';", conn))
|
||||
comm.ExecuteNonQuery();
|
||||
|
||||
Log(@"Database backup...");
|
||||
using(MySqlCommand comm = new(@"SHOW DATABASES;", conn))
|
||||
using(MySqlDataReader read = comm.ExecuteReader()) {
|
||||
while(read.Read()) {
|
||||
string database = read.GetString(0);
|
||||
|
||||
using (Stream s = CreateMySqlDump())
|
||||
using (Stream g = GZipEncodeStream(s))
|
||||
{
|
||||
object f = Upload(DatabaseDumpName, @"application/sql+gzip", g);
|
||||
if(string.IsNullOrEmpty(database) || exclude.Contains(database))
|
||||
continue;
|
||||
|
||||
switch (f)
|
||||
{
|
||||
default:
|
||||
Log($@"MySQL dump uploaded.");
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (Directory.Exists(Config.MisuzuPath))
|
||||
{
|
||||
Log(@"Filesystem backup...");
|
||||
string mszConfig = GetMisuzuConfig();
|
||||
|
||||
if (!File.Exists(mszConfig))
|
||||
Error(@"Could not find Misuzu config.");
|
||||
|
||||
string mszStore = FindMisuzuStorageDir(mszConfig);
|
||||
|
||||
if (!Directory.Exists(mszStore))
|
||||
Error(@"Could not find Misuzu storage directory.");
|
||||
|
||||
string archivePath = CreateMisuzuDataBackup(mszConfig, mszStore);
|
||||
|
||||
using (FileStream fs = File.OpenRead(archivePath))
|
||||
{
|
||||
object f = Upload(UserDataName, @"application/zip", fs);
|
||||
|
||||
switch (f)
|
||||
{
|
||||
default:
|
||||
Log($@"Misuzu data uploaded.");
|
||||
break;
|
||||
databases.Add(database);
|
||||
}
|
||||
}
|
||||
|
||||
File.Delete(archivePath);
|
||||
}
|
||||
|
||||
Log(@"Creating backup archive...");
|
||||
|
||||
string archivePath = Path.GetTempFileName();
|
||||
|
||||
using(FileStream fs = File.OpenWrite(archivePath))
|
||||
using(ZipArchive archive = new(fs, ZipArchiveMode.Create)) {
|
||||
Log(@"Database backup...");
|
||||
|
||||
string sqldefaults = Path.GetTempFileName();
|
||||
|
||||
using(FileStream sqlConfFs = File.Open(sqldefaults, FileMode.Open, FileAccess.ReadWrite))
|
||||
using(StreamWriter sw = new(sqlConfFs)) {
|
||||
sw.WriteLine(@"[client]");
|
||||
sw.WriteLine($@"user={Config.MySqlUser}");
|
||||
sw.WriteLine($@"password={Config.MySqlPass}");
|
||||
sw.WriteLine(@"default-character-set=utf8mb4");
|
||||
}
|
||||
|
||||
foreach(string database in databases)
|
||||
CreateDbDump(archive, sqldefaults, database);
|
||||
|
||||
Log($@"MariaDB dump done.");
|
||||
File.Delete(sqldefaults);
|
||||
}
|
||||
|
||||
string targetPath = Path.Combine(BackupStore, BackupName);
|
||||
File.Move(archivePath, targetPath);
|
||||
Log($@"Moved backup archive to {targetPath}");
|
||||
|
||||
SaveConfig();
|
||||
sw.Stop();
|
||||
Log($@"Done! Took {sw.Elapsed}.", true);
|
||||
Log($@"Done! Took {sw.Elapsed}.");
|
||||
|
||||
#if DEBUG
|
||||
Console.ReadLine();
|
||||
#endif
|
||||
}
|
||||
|
||||
public static void Log(object line, bool forceSatori = false)
|
||||
{
|
||||
if (Headless)
|
||||
return;
|
||||
public static void Log(object line) {
|
||||
if(!Headless) {
|
||||
if(sw?.IsRunning == true) {
|
||||
ConsoleColor fg = Console.ForegroundColor;
|
||||
Console.ForegroundColor = ConsoleColor.Yellow;
|
||||
Console.Write(sw.ElapsedMilliseconds.ToString().PadRight(10));
|
||||
Console.ForegroundColor = fg;
|
||||
}
|
||||
|
||||
if (sw?.IsRunning == true)
|
||||
{
|
||||
ConsoleColor fg = Console.ForegroundColor;
|
||||
Console.ForegroundColor = ConsoleColor.Yellow;
|
||||
Console.Write(sw.ElapsedMilliseconds.ToString().PadRight(10));
|
||||
Console.ForegroundColor = fg;
|
||||
Console.WriteLine(line);
|
||||
}
|
||||
|
||||
Console.WriteLine(line);
|
||||
|
||||
if (forceSatori || !(Config?.SatoriErrorsOnly ?? true))
|
||||
SatoriBroadcast(line.ToString());
|
||||
}
|
||||
|
||||
public static void Error(object line, int exit = 0x00DEAD00)
|
||||
{
|
||||
if (!Headless)
|
||||
{
|
||||
public static void Error(object line, int exit = 0x00DEAD00) {
|
||||
if(!Headless) {
|
||||
Console.ForegroundColor = ConsoleColor.Red;
|
||||
Log(line);
|
||||
Console.ResetColor();
|
||||
}
|
||||
|
||||
SatoriBroadcast(line.ToString(), true);
|
||||
|
||||
#if DEBUG
|
||||
Console.ReadLine();
|
||||
#endif
|
||||
|
||||
Environment.Exit(exit);
|
||||
}
|
||||
|
||||
public static object Upload(string name, string type, Stream stream)
|
||||
{
|
||||
Log($@"Uploading '{name}'...");
|
||||
|
||||
switch (Config.StorageMethod)
|
||||
{
|
||||
case StorageMethod.Sftp:
|
||||
SFTP.UploadFile(stream, (BackupStorage as string) + @"/" + name);
|
||||
break;
|
||||
public static void CreateDbDump(ZipArchive archive, string defaults, string database) {
|
||||
Log($@"Dumping {database}...");
|
||||
|
||||
case StorageMethod.FileSystem:
|
||||
string filename = Path.Combine(BackupStorage as string, name);
|
||||
string sqldump = Path.GetTempFileName();
|
||||
|
||||
using (FileStream fs = File.OpenWrite(filename))
|
||||
stream.CopyTo(fs);
|
||||
break;
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
public static string GetMisuzuConfig()
|
||||
{
|
||||
return Path.Combine(Config.MisuzuPath, @"config/config.ini");
|
||||
}
|
||||
|
||||
public static string FindMisuzuStorageDir(string config)
|
||||
{
|
||||
Log(@"Finding storage directory...");
|
||||
|
||||
string[] configLines = File.ReadAllLines(config);
|
||||
bool storageSectionFound = false;
|
||||
string path = string.Empty;
|
||||
|
||||
foreach (string line in configLines)
|
||||
{
|
||||
if (!string.IsNullOrEmpty(path))
|
||||
break;
|
||||
if (line.StartsWith('['))
|
||||
storageSectionFound = line == @"[Storage]";
|
||||
if (!storageSectionFound)
|
||||
continue;
|
||||
|
||||
string[] split = line.Split('=', StringSplitOptions.RemoveEmptyEntries);
|
||||
|
||||
if (split.Length < 2 || split[0] != @"path")
|
||||
continue;
|
||||
|
||||
path = string.Join('=', split.Skip(1));
|
||||
break;
|
||||
}
|
||||
|
||||
if (string.IsNullOrEmpty(path))
|
||||
path = Path.Combine(Config.MisuzuPath, @"store");
|
||||
|
||||
return path;
|
||||
}
|
||||
|
||||
public static string CreateMisuzuDataBackup(string configPath, string storePath)
|
||||
{
|
||||
Log(@"Creating Zip archive containing non-volatile Misuzu data...");
|
||||
|
||||
string tmpName = Path.GetTempFileName();
|
||||
|
||||
using (FileStream fs = File.OpenWrite(tmpName))
|
||||
using (ZipArchive za = new ZipArchive(fs, ZipArchiveMode.Create))
|
||||
{
|
||||
za.CreateEntryFromFile(configPath, @"config/config.ini", CompressionLevel.Optimal);
|
||||
|
||||
string[] storeFiles = Directory.GetFiles(storePath, @"*", SearchOption.AllDirectories);
|
||||
|
||||
foreach (string file in storeFiles)
|
||||
za.CreateEntryFromFile(
|
||||
file,
|
||||
@"store/" + file.Replace(storePath, string.Empty).WindowsToUnixPath().Trim('/'),
|
||||
CompressionLevel.Optimal
|
||||
);
|
||||
}
|
||||
|
||||
return tmpName;
|
||||
}
|
||||
|
||||
public static Stream CreateMySqlDump()
|
||||
{
|
||||
Log(@"Dumping MySQL Databases...");
|
||||
string tmpFile = Path.GetTempFileName();
|
||||
|
||||
using (FileStream fs = File.Open(tmpFile, FileMode.Open, FileAccess.ReadWrite))
|
||||
using (StreamWriter sw = new StreamWriter(fs))
|
||||
{
|
||||
sw.WriteLine(@"[client]");
|
||||
sw.WriteLine($@"user={Config.MySqlUser}");
|
||||
sw.WriteLine($@"password={Config.MySqlPass}");
|
||||
sw.WriteLine(@"default-character-set=utf8mb4");
|
||||
}
|
||||
|
||||
// should we use --result-file ?
|
||||
StringBuilder mysqldumpArgs = new StringBuilder();
|
||||
mysqldumpArgs.AppendFormat(@"--defaults-file={0} ", tmpFile);
|
||||
StringBuilder mysqldumpArgs = new();
|
||||
mysqldumpArgs.AppendFormat(@"--defaults-file={0} ", defaults);
|
||||
mysqldumpArgs.Append(@"--single-transaction ");
|
||||
mysqldumpArgs.Append(@"--tz-utc --triggers ");
|
||||
mysqldumpArgs.Append(@"--routines --hex-blob ");
|
||||
mysqldumpArgs.Append(@"--add-locks --order-by-primary ");
|
||||
mysqldumpArgs.Append(@"-l -Q -q -B "); // lock, quote names, quick, databases list
|
||||
mysqldumpArgs.Append(Config.MySqlDatabases);
|
||||
mysqldumpArgs.Append(@"--skip-lock-tables "); // might regret this, we'll find out someday
|
||||
mysqldumpArgs.AppendFormat(@"--result-file={0} ", sqldump);
|
||||
mysqldumpArgs.Append(@"-Q -q -B "); // lock, quote names, quick, database list
|
||||
mysqldumpArgs.Append(database);
|
||||
|
||||
Process p = Process.Start(new ProcessStartInfo
|
||||
{
|
||||
FileName = IsWindows ? Config.MySqlDumpPathWindows : Config.MySqlDumpPath,
|
||||
RedirectStandardError = false,
|
||||
RedirectStandardInput = false,
|
||||
RedirectStandardOutput = true,
|
||||
#if DEBUG
|
||||
Log($@"mysqldump args: {mysqldumpArgs}");
|
||||
#endif
|
||||
|
||||
Process p = Process.Start(new ProcessStartInfo {
|
||||
FileName = Config.MySqlDumpPath,
|
||||
Arguments = mysqldumpArgs.ToString(),
|
||||
UseShellExecute = false,
|
||||
CreateNoWindow = true,
|
||||
});
|
||||
|
||||
int read;
|
||||
byte[] buffer = new byte[1024];
|
||||
MemoryStream ms = new MemoryStream();
|
||||
|
||||
while ((read = p.StandardOutput.BaseStream.Read(buffer, 0, buffer.Length)) > 0)
|
||||
ms.Write(buffer, 0, read);
|
||||
|
||||
p.WaitForExit();
|
||||
File.Delete(tmpFile);
|
||||
ms.Seek(0, SeekOrigin.Begin);
|
||||
|
||||
return ms;
|
||||
}
|
||||
archive.CreateEntryFromFile(sqldump, $@"mariadb/{database}.sql", CompressionLevel.Optimal);
|
||||
|
||||
public static Stream GZipEncodeStream(Stream input)
|
||||
{
|
||||
Log(@"Compressing stream...");
|
||||
MemoryStream output = new MemoryStream();
|
||||
|
||||
using (GZipStream gz = new GZipStream(output, CompressionLevel.Optimal, true))
|
||||
input.CopyTo(gz);
|
||||
|
||||
output.Seek(0, SeekOrigin.Begin);
|
||||
return output;
|
||||
}
|
||||
|
||||
public static void GetBackupStorage(string name = null)
|
||||
{
|
||||
switch (Config.StorageMethod)
|
||||
{
|
||||
case StorageMethod.Sftp:
|
||||
string directory = (BackupStorage = name ?? Config.SftpBackupDirectoryPath) as string;
|
||||
try
|
||||
{
|
||||
SFTP.ListDirectory(directory);
|
||||
} catch (SftpPathNotFoundException)
|
||||
{
|
||||
SFTP.CreateDirectory(directory);
|
||||
}
|
||||
break;
|
||||
|
||||
case StorageMethod.FileSystem:
|
||||
BackupStorage = name ?? Config.FileSystemPath;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
public static void SatoriBroadcast(string text, bool error = false)
|
||||
{
|
||||
if (string.IsNullOrEmpty(text)
|
||||
|| Config == null
|
||||
|| string.IsNullOrWhiteSpace(Config.SatoriHost)
|
||||
|| string.IsNullOrWhiteSpace(Config.SatoriSecret)
|
||||
|| Config.SatoriPort < 1)
|
||||
return;
|
||||
|
||||
IPAddress ip = null;
|
||||
|
||||
try
|
||||
{
|
||||
ip = IPAddress.Parse(Config.SatoriHost);
|
||||
}
|
||||
catch
|
||||
{
|
||||
try
|
||||
{
|
||||
ip = Dns.GetHostAddresses(Config.SatoriHost).FirstOrDefault();
|
||||
}
|
||||
catch
|
||||
{
|
||||
ip = null;
|
||||
}
|
||||
}
|
||||
|
||||
if (ip == null)
|
||||
return;
|
||||
|
||||
EndPoint endPoint = new IPEndPoint(ip, Config.SatoriPort);
|
||||
|
||||
StringBuilder textBuilder = new StringBuilder();
|
||||
textBuilder.Append(@"[b]Backup System[/b]: ");
|
||||
|
||||
if (error)
|
||||
textBuilder.Append(@"[color=red]");
|
||||
|
||||
textBuilder.Append(text);
|
||||
|
||||
if (error)
|
||||
textBuilder.Append(@"[/color]");
|
||||
|
||||
text = textBuilder.ToString();
|
||||
|
||||
StringBuilder messageBuilder = new StringBuilder();
|
||||
|
||||
using (HMACSHA256 hmac = new HMACSHA256(Encoding.UTF8.GetBytes(Config.SatoriSecret)))
|
||||
{
|
||||
byte[] hash = hmac.ComputeHash(Encoding.UTF8.GetBytes(text));
|
||||
|
||||
foreach (byte b in hash)
|
||||
messageBuilder.AppendFormat(@"{0:x2}", b);
|
||||
}
|
||||
|
||||
messageBuilder.Append(text);
|
||||
string message = messageBuilder.ToString();
|
||||
byte[] messageBytes = new byte[Encoding.UTF8.GetByteCount(message) + 2];
|
||||
messageBytes[0] = messageBytes[messageBytes.Length - 1] = 0x0F;
|
||||
Encoding.UTF8.GetBytes(message).CopyTo(messageBytes, 1);
|
||||
|
||||
using (Socket sock = new Socket(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp))
|
||||
{
|
||||
sock.NoDelay = sock.Blocking = true;
|
||||
sock.Connect(endPoint);
|
||||
sock.Send(messageBytes);
|
||||
}
|
||||
File.Delete(sqldump);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -1,9 +0,0 @@
|
|||
namespace BackupManager
|
||||
{
|
||||
public enum StorageMethod
|
||||
{
|
||||
//GoogleDrive = 1,
|
||||
Sftp = 2,
|
||||
FileSystem = 4, // for debugging mysqldump
|
||||
}
|
||||
}
|
|
@ -6,5 +6,5 @@ Provided for transparency.
|
|||
## Grant line for MySQL backup user
|
||||
|
||||
```
|
||||
GRANT SELECT, LOCK TABLES, SHOW VIEW, EVENT, TRIGGER, EXECUTE ON *.* TO 'user'@'localhost';
|
||||
GRANT SELECT, LOCK TABLES, SHOW VIEW, SHOW DATABASES, EVENT, TRIGGER, EXECUTE ON *.* TO 'user'@'localhost';
|
||||
```
|
||||
|
|
|
@ -1,3 +1,7 @@
|
|||
export DOTNET_CLI_TELEMETRY_OPTOUT=1
|
||||
cwd="$(pwd)"
|
||||
cd "$(dirname "$0")"
|
||||
|
||||
dotnet run --project BackupManager -c Release -f netcoreapp2.2 -- -cron
|
||||
export DOTNET_CLI_TELEMETRY_OPTOUT=1
|
||||
dotnet run --project BackupManager -c Release -f net6.0 -- -cron
|
||||
|
||||
cd "$cwd"
|
||||
|
|
Reference in a new issue