logos-storage/logos-storage-nim-cs-dist-tests
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim-cs-dist-tests.git synced 2026-01-07 16:03:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Tracks whether work item has changed.

Browse Source
This commit is contained in:
ThatBen 2025-02-27 09:22:57 +01:00
parent d701e2a73d
commit e862094014
No known key found for this signature in database
GPG Key ID: 62C543548433D43E
2 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Tools/AutoClient/Modes/FolderStore/FileSaver.cs
View File

@ -22,10 +22,12 @@ namespace AutoClient.Modes.FolderStore
}
public bool HasFailed { get; private set; }
public bool Changes { get; private set; }
public void Process()
{
HasFailed = false;
Changes = false;
if (HasRecentPurchase(entry))
{
Log($"Purchase running: '{entry.PurchaseId}'");
@ -86,6 +88,7 @@ namespace AutoClient.Modes.FolderStore
private void UploadFile()
{
Changes = true;
try
{
entry.BasicCid = instance.UploadFile(folderFile).Id;
@ -105,6 +108,7 @@ namespace AutoClient.Modes.FolderStore
{
if (string.IsNullOrEmpty(entry.BasicCid)) return;
Changes = true;
try
{
var request = CreateNewStorageRequest();

18
Tools/AutoClient/Modes/FolderStore/FolderSaver.cs
View File

@ -32,8 +32,10 @@ namespace AutoClient.Modes.FolderStore
if (!folderFile.ToLowerInvariant().EndsWith(FolderSaverFilename))
{
SaveFile(folderFile);
counter++;
if (SaveFile(folderFile))
{
counter++;
}
}
if (failureCount > 9)
@ -54,7 +56,7 @@ namespace AutoClient.Modes.FolderStore
}
}
private void SaveFile(string folderFile)
private bool SaveFile(string folderFile)
{
var localFilename = Path.GetFileName(folderFile);
var entry = status.Files.SingleOrDefault(f => f.Filename == localFilename);
@ -66,14 +68,15 @@ namespace AutoClient.Modes.FolderStore
};
status.Files.Add(entry);
}
ProcessFileEntry(folderFile, entry);
return ProcessFileEntry(folderFile, entry);
}
private void ProcessFileEntry(string folderFile, FileStatus entry)
private bool ProcessFileEntry(string folderFile, FileStatus entry)
{
var fileSaver = CreateFileSaver(folderFile, entry);
fileSaver.Process();
if (fileSaver.HasFailed) failureCount++;
return fileSaver.Changes;
}
private void SaveFolderSaverJsonFile()
@ -101,7 +104,7 @@ namespace AutoClient.Modes.FolderStore
var min = MinCodexStorageFilesize * 2;
if (info.Length < min)
{
var required = min - info.Length;
var required = Math.Max(1024, min - info.Length);
status.Padding = paddingMessage + GenerateRandomString(required);
}
}
@ -111,8 +114,7 @@ namespace AutoClient.Modes.FolderStore
var result = "";
while (result.Length < required)
{
var diff = required - result.Length;
var bytes = new byte[diff];
var bytes = new byte[1024];
random.NextBytes(bytes);
result += string.Join("", bytes.Select(b => b.ToString()));
}