pacserver/src/Pacserver/Pacserver.cs

using System.Net.Http.Headers;
using System.Text.RegularExpressions;

namespace Pacserver.Utils;
public class PacserverUtils {
    public string pacmanCacheDirectory = string.Empty;
    public string pacmanDatabaseDirectory = string.Empty;
    public static List<String> pathsToDetermine = new List<String>() { "CacheDir", "DBPath" };
    public void readPacmanConfig() {
        using (StreamReader file = new StreamReader("/etc/pacman.conf")) {
            Regex regex = new Regex(@"\/(?:[\w.-]+\/)*[\w.-]+(?:\.\w+)*\/?$"); // https://regex101.com/r/GwWeui/2
            string? line;

            while ((line = file.ReadLine()) is not null) {
                foreach (string path in pathsToDetermine) {
                    if (line.Contains(path)) {
                        Match match = regex.Match(line);
                        if (match.Success) {
                            switch (path) {
                                case "CacheDir":
                                    pacmanCacheDirectory = match.ToString();
                                    break;
                                case "DBPath":
                                    pacmanDatabaseDirectory = match.ToString();
                                    break;
                                default:
                                    throw new Exception("Could not deal with " + match.ToString());
                            }
                        } else {
                            string pathsToDetermineString = string.Join(",", pathsToDetermine);
                            throw new Exception("Could not determine the necessary file paths: " + pathsToDetermineString);
                        }
                    }
                }
            }
        }
    }

    public List<String> packageNamesAndVersion = new List<String>();
    public void getEveryPackageNameAndVersionViaFolderName(string filePath) {
        string[] directories = Directory.GetDirectories(pacmanDatabaseDirectory + "local/");
        foreach (string directory in directories) {
            packageNamesAndVersion.Add(new DirectoryInfo(directory).Name);
        }

        if (packageNamesAndVersion.Capacity > 0) {
            File.WriteAllLines(filePath, packageNamesAndVersion);
        } else {
            throw new Exception("How did you execute this without any packages?");
        }
    }

    public List<String> diffOfPackagesOrDatabases = new List<String>();
    public void diff(string before, string after) {
        if (File.Exists(before) && File.Exists(after)) {
            diffOfPackagesOrDatabases = File.ReadAllLines(after).Except(File.ReadLines(before)).ToList();
        } else {
            throw new FileNotFoundException("Necessary files could not be found");
        }
    }

    public List<String> databases = new List<String>();
    public void checkIfDatabasesWereModified(string mode, string filePath) {
        string[] databases = Directory.GetFiles(pacmanDatabaseDirectory + "sync/");

        foreach (string database in databases) {
            switch (mode) {
                case "before":
                    writeDatabaseAccessTimeToFile(filePath, database);
                    break;
                case "after":
                    writeDatabaseAccessTimeToFile(filePath, database);
                    break;
                default:
                    throw new ArgumentException("No valid mode was given. Valid modes are before and after");
            }
        }
    }

    public void writeDatabaseAccessTimeToFile(string filePath, string database) {
        if (!File.Exists(filePath)) {
            using (File.Open(filePath, FileMode.OpenOrCreate, FileAccess.ReadWrite, FileShare.ReadWrite)) {
                using (StreamWriter sw = new StreamWriter(filePath)) {
                    sw.WriteLine(database + " " + File.GetLastAccessTime(database));
                }
            }
        } else if (File.Exists(filePath)) {
            using (File.Open(filePath, FileMode.Open, FileAccess.ReadWrite, FileShare.ReadWrite)) {
                using (var sw = new StreamWriter(filePath, true)) {
                    sw.WriteLine(database + " " + File.GetLastAccessTime(database));
                }
            }
        }
    }

    private static List<String> newerPackagesAndDatabases = new List<String>();
    public async void transferPacmanCache() {
        HttpClient client = new HttpClient();
        HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Post, "http://192.168.0.69:12000/upload?path=/");
        MultipartFormDataContent content = new MultipartFormDataContent();

        foreach (string pkgOrDb in newerPackagesAndDatabases) {
            content.Add(new ByteArrayContent(File.ReadAllBytes(pacmanCacheDirectory + pkgOrDb)), "path", Path.GetFileName(pacmanCacheDirectory + pkgOrDb));
        }
        request.Content = content;

        await client.SendAsync(request);
    }

    public void transferPacmanDatabases() {

    }
}