244 lines
10 KiB
C#
244 lines
10 KiB
C#
using DTLib.Dtsod;
|
||
using DTLib.Filesystem;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Net.Sockets;
|
||
using System.Text;
|
||
using static DTLib.PublicLog;
|
||
|
||
namespace DTLib.Network
|
||
{
|
||
//
|
||
// передача файлов по сети
|
||
//
|
||
public class FSP
|
||
{
|
||
Socket mainSocket;
|
||
static public bool debug = false;
|
||
public FSP(Socket _mainSocket) => mainSocket = _mainSocket;
|
||
|
||
public uint BytesDownloaded = 0;
|
||
public uint BytesUploaded = 0;
|
||
public uint Filesize = 0;
|
||
|
||
/*public delegate void PackageTransferDel(uint size);
|
||
public event PackageTransferDel PackageRecieved;
|
||
public event PackageTransferDel PackageSent;*/
|
||
|
||
// скачивает файл с помощью FSP протокола
|
||
public void DownloadFile(string filePath_server, string filePath_client)
|
||
{
|
||
Debug("b", $"requesting file download: {filePath_server}\n");
|
||
mainSocket.SendPackage("requesting file download".ToBytes());
|
||
mainSocket.SendPackage(filePath_server.ToBytes());
|
||
DownloadFile(filePath_client);
|
||
}
|
||
|
||
public void DownloadFile(string filePath_client)
|
||
{
|
||
BytesDownloaded = 0;
|
||
using var fileStream = File.OpenWrite(filePath_client);
|
||
Filesize = mainSocket.GetPackage().ToStr().ToUInt();
|
||
var hashstr = mainSocket.GetPackage().HashToString();
|
||
mainSocket.SendPackage("ready".ToBytes());
|
||
int packagesCount = 0;
|
||
byte[] buffer = new byte[5120];
|
||
int fullPackagesCount = SimpleConverter.Truncate(Filesize / buffer.Length);
|
||
// рассчёт скорости
|
||
/*int seconds = 0;
|
||
var speedCounter = new Timer(true, 1000, () =>
|
||
{
|
||
seconds++;
|
||
PackageRecieved(BytesDownloaded);
|
||
});*/
|
||
// получение файла
|
||
|
||
for (byte n = 0; packagesCount < fullPackagesCount; packagesCount++)
|
||
{
|
||
buffer = mainSocket.GetPackage();
|
||
BytesDownloaded += (uint)buffer.Length;
|
||
fileStream.Write(buffer, 0, buffer.Length);
|
||
if (n == 100)
|
||
{
|
||
fileStream.Flush();
|
||
n = 0;
|
||
}
|
||
else n++;
|
||
}
|
||
// получение остатка
|
||
if ((Filesize - fileStream.Position) > 0)
|
||
{
|
||
mainSocket.SendPackage("remain request".ToBytes());
|
||
buffer = mainSocket.GetPackage();
|
||
BytesDownloaded += (uint)buffer.Length;
|
||
fileStream.Write(buffer, 0, buffer.Length);
|
||
}
|
||
//speedCounter.Stop();
|
||
fileStream.Flush();
|
||
fileStream.Close();
|
||
Debug(new string[] { "g", $" downloaded {BytesDownloaded} of {Filesize} bytes\n" });
|
||
}
|
||
|
||
public byte[] DownloadFileToMemory(string filePath_server)
|
||
{
|
||
BytesDownloaded = 0;
|
||
Debug("b", $"requesting file download: {filePath_server}\n");
|
||
mainSocket.SendPackage("requesting file download".ToBytes());
|
||
mainSocket.SendPackage(filePath_server.ToBytes());
|
||
using var fileStream = new System.IO.MemoryStream();
|
||
Filesize = mainSocket.GetPackage().ToStr().ToUInt();
|
||
var hashstr = mainSocket.GetPackage().HashToString();
|
||
mainSocket.SendPackage("ready".ToBytes());
|
||
int packagesCount = 0;
|
||
byte[] buffer = new byte[5120];
|
||
int fullPackagesCount = SimpleConverter.Truncate(Filesize / buffer.Length);
|
||
// рассчёт скорости
|
||
/*int seconds = 0;
|
||
var speedCounter = new Timer(true, 1000, () =>
|
||
{
|
||
seconds++;
|
||
PackageRecieved(BytesDownloaded);
|
||
});*/
|
||
// получение файла
|
||
for (; packagesCount < fullPackagesCount; packagesCount++)
|
||
{
|
||
buffer = mainSocket.GetPackage();
|
||
BytesDownloaded += (uint)buffer.Length;
|
||
fileStream.Write(buffer, 0, buffer.Length);
|
||
}
|
||
// получение остатка
|
||
if ((Filesize - fileStream.Position) > 0)
|
||
{
|
||
mainSocket.SendPackage("remain request".ToBytes());
|
||
buffer = mainSocket.GetPackage();
|
||
BytesDownloaded += (uint)buffer.Length;
|
||
fileStream.Write(buffer, 0, buffer.Length);
|
||
}
|
||
//speedCounter.Stop();
|
||
byte[] output = fileStream.GetBuffer();
|
||
fileStream.Close();
|
||
Debug(new string[] { "g", $" downloaded {BytesDownloaded} of {Filesize} bytes\n" });
|
||
return output;
|
||
}
|
||
|
||
// отдаёт файл с помощью FSP протокола
|
||
public void UploadFile(string filePath)
|
||
{
|
||
Debug("b", $"uploading file {filePath}\n");
|
||
using var fileStream = File.OpenRead(filePath);
|
||
Filesize = File.GetSize(filePath).ToUInt();
|
||
var fileHash = new Hasher().HashFile(filePath);
|
||
mainSocket.SendPackage(Filesize.ToString().ToBytes());
|
||
mainSocket.SendPackage(fileHash);
|
||
if (mainSocket.GetPackage().ToStr() != "ready") throw new Exception("user socket isn't ready");
|
||
byte[] buffer = new byte[5120];
|
||
var hashstr = fileHash.HashToString();
|
||
int packagesCount = 0;
|
||
int fullPackagesCount = SimpleConverter.Truncate(Filesize / buffer.Length);
|
||
// рассчёт скорости
|
||
/*int seconds = 0;
|
||
var speedCounter = new Timer(true, 1000, () =>
|
||
{
|
||
seconds++;
|
||
PackageSent(BytesUploaded);
|
||
});*/
|
||
// отправка файла
|
||
for (; packagesCount < fullPackagesCount; packagesCount++)
|
||
{
|
||
fileStream.Read(buffer, 0, buffer.Length);
|
||
mainSocket.SendPackage(buffer);
|
||
BytesUploaded += (uint)buffer.Length;
|
||
}
|
||
// досылка остатка
|
||
if ((Filesize - fileStream.Position) > 0)
|
||
{
|
||
mainSocket.GetAnswer("remain request");
|
||
buffer = new byte[(Filesize - fileStream.Position).ToInt()];
|
||
fileStream.Read(buffer, 0, buffer.Length);
|
||
mainSocket.SendPackage(buffer);
|
||
BytesUploaded += (uint)buffer.Length;
|
||
}
|
||
//speedCounter.Stop();
|
||
fileStream.Close();
|
||
Debug(new string[] { "g", $" uploaded {BytesUploaded} of {Filesize} bytes\n" });
|
||
}
|
||
|
||
public void DownloadByManifest(string dirOnServer, string dirOnClient, bool overwrite = false, bool delete_excess = false)
|
||
{
|
||
if (!dirOnClient.EndsWith("\\")) dirOnClient += "\\";
|
||
if (!dirOnServer.EndsWith("\\")) dirOnServer += "\\";
|
||
Debug("b", "downloading manifest <", "c", dirOnServer + "manifest.dtsod", "b", ">\n");
|
||
var manifest = new DtsodV23(DownloadFileToMemory(dirOnServer + "manifest.dtsod").ToStr());
|
||
Debug("g", $"found {manifest.Values.Count} files in manifest\n");
|
||
var hasher = new Hasher();
|
||
foreach (string fileOnServer in manifest.Keys)
|
||
{
|
||
string fileOnClient = dirOnClient + fileOnServer;
|
||
Debug("b", "file <", "c", fileOnClient, "b", ">... ");
|
||
if (!File.Exists(fileOnClient))
|
||
{
|
||
DebugNoTime("y", "doesn't exist\n");
|
||
DownloadFile(dirOnServer + fileOnServer, fileOnClient);
|
||
}
|
||
else if (overwrite && hasher.HashFile(fileOnClient).HashToString() != manifest[fileOnServer])
|
||
{
|
||
DebugNoTime("y", "outdated\n");
|
||
DownloadFile(dirOnServer + fileOnServer, fileOnClient);
|
||
}
|
||
else DebugNoTime("g", "without changes\n");
|
||
}
|
||
// удаление лишних файлов
|
||
if (delete_excess)
|
||
{
|
||
List<string> dirs = new();
|
||
foreach (string file in Directory.GetAllFiles(dirOnClient, ref dirs))
|
||
{
|
||
if (!manifest.ContainsKey(file.Remove(0, dirOnClient.Length)))
|
||
{
|
||
Debug("y", $"deleting excess file: {file}\n");
|
||
File.Delete(file);
|
||
}
|
||
}
|
||
// удаление пустых папок
|
||
/*foreach (string dir in dirs)
|
||
{
|
||
if (Directory.Exists(dir) && Directory.GetAllFiles(dir).Count == 0)
|
||
{
|
||
Debug("y", $"deleting empty dir: {dir}\n");
|
||
Directory.Delete(dir);
|
||
}
|
||
}*/
|
||
}
|
||
}
|
||
|
||
public static DtsodV23 CreateManifest(string dir)
|
||
{
|
||
if (!dir.EndsWith("\\")) dir += "\\";
|
||
Log($"b", $"creating manifest of {dir}\n");
|
||
StringBuilder manifestBuilder = new();
|
||
Hasher hasher = new();
|
||
if (Directory.GetFiles(dir).Contains(dir + "manifest.dtsod")) File.Delete(dir + "manifest.dtsod");
|
||
foreach (string _file in Directory.GetAllFiles(dir))
|
||
{
|
||
string file = _file.Remove(0, dir.Length);
|
||
manifestBuilder.Append(file);
|
||
manifestBuilder.Append(": \"");
|
||
byte[] hash = hasher.HashFile(dir + file);
|
||
manifestBuilder.Append(hash.HashToString());
|
||
manifestBuilder.Append("\";\n");
|
||
}
|
||
Debug($"g", $" manifest of {dir} created\n");
|
||
return new DtsodV23(manifestBuilder.ToString());
|
||
}
|
||
|
||
static void Debug(params string[] msg)
|
||
{
|
||
if (debug) Log(msg);
|
||
}
|
||
static void DebugNoTime(params string[] msg)
|
||
{
|
||
if (debug) LogNoTime(msg);
|
||
}
|
||
}
|
||
}
|