[Feature] 基于符号链接的多客户端共存方案 about starward HOT 6 OPEN

    static void Main(string[] args)
    {
        //mklink需要管理员权限
        System.Security.Principal.WindowsIdentity identity = System.Security.Principal.WindowsIdentity.GetCurrent();
        System.Security.Principal.WindowsPrincipal principal = new System.Security.Principal.WindowsPrincipal(identity);
        if (!principal.IsInRole(System.Security.Principal.WindowsBuiltInRole.Administrator))
        {
            System.Diagnostics.ProcessStartInfo startInfo = new System.Diagnostics.ProcessStartInfo();
            startInfo.UseShellExecute = true;
            startInfo.WorkingDirectory = Environment.CurrentDirectory;
            startInfo.FileName = System.AppDomain.CurrentDomain.BaseDirectory + "GenshinImapctStarter.exe";
            startInfo.Verb = "runas";
            System.Diagnostics.Process.Start(startInfo);
            Environment.Exit(0);
            return;
        }

        Starter starter = new Starter();
        starter.Init().Wait();
        starter.CreateGame("E:\\ABCD\\", "global450").Wait();//测试，
    }

    public class Starter
    {
        private readonly string datapath = AppDomain.CurrentDomain.BaseDirectory + "data\\";
        private JObject jconfig = new JObject();
        public async Task Init()
        {
            if (!File.Exists(datapath + ".\\config.json"))
            {
                ChangeDefaultGamePath();
                await File.WriteAllTextAsync(datapath + ".\\config.json", this.jconfig.ToString());
            }
            this.jconfig = JObject.Parse(await File.ReadAllTextAsync(datapath + ".\\config.json"));
        }
        public void ChangeDefaultGamePath()
        {
            try
            {
                do
                {
                    Console.WriteLine("Input default game path:");
                    jconfig["game_default_path"] = Console.ReadLine();
                }
                while (!Directory.Exists((string)jconfig["game_default_path"]!));
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
            }

        }
        public async Task CreateGame(string path, string version)
        {
            Console.WriteLine($"Create {version} Game to {path}");
            string versionpath = this.datapath + $"GameData\\{version}\\";
            JObject jversionconfig = JObject.Parse(await File.ReadAllTextAsync(versionpath + "config.json"));

            string target, link;
            if ((string)jversionconfig["game_type"]! == "China")
            {
                target = path + "YuanShen_Data\\StreamingAssets\\";
            }
            else
            {
                target = path + "GenshinImpact_Data\\StreamingAssets\\";
            }
            if ((string)this.jconfig["game_default_type"]! == "China")
            {
                link = this.jconfig["game_default_path"] + "YuanShen_Data\\StreamingAssets\\";
            }
            else
            {
                link = this.jconfig["game_default_path"] + "GenshinImpact_Data\\StreamingAssets\\";
            }
            await Ziper.Decompress(versionpath + "gamedata.zip", path, 1024 * 1024);
            this.Link(target, link);
            Console.WriteLine($"Task succeeded");
        }
        public void Link(string target, string link)
        {
            CMD cmd = new CMD();
            string[] dirlinkpaths = File.ReadAllLines(this.datapath + "dirlink.txt");
            string[] filelinkpaths = File.ReadAllLines(this.datapath + "filelink.txt");
            for (int i = 0; i < filelinkpaths.Length; i++)
            {
                string a = $"mklink \"{target + filelinkpaths[i]}\" \"{link + filelinkpaths[i]}\"";
                cmd.Run(a);
            }
            for (int i = 0; i < dirlinkpaths.Length; i++)
            {
                cmd.Run($"mklink /d \"{target + dirlinkpaths[i]}\" \"{link + dirlinkpaths[i]}\"");
            }

            cmd.Exit();
        }
        public async Task<string> GetVersion(string path)
        {
            string content = await File.ReadAllTextAsync(path + ".\\StreamingAssets\\asb_settings.json");
            JObject jsondata = JObject.Parse(content);
            return (string)jsondata["variance"]!;
        }

        public class CMD
        {
            private Process process;
            public CMD()
            {
                process = new Process();
                process.StartInfo.FileName = "cmd.exe";
                process.StartInfo.CreateNoWindow = true;
                process.StartInfo.UseShellExecute = false;
                process.StartInfo.RedirectStandardInput = true;
                process.StartInfo.RedirectStandardOutput = true;
                process.StartInfo.RedirectStandardError = true;
                process.StartInfo.Verb = "runas";
                process.Start();
                process.BeginOutputReadLine();
                process.BeginErrorReadLine();
                process.StandardInput.AutoFlush = true;
                
            }
            public void Exit()
            {
                process.StandardInput.WriteLine("exit");
                process.StandardInput.Flush();
                process.WaitForExit();
            }
            public void Run(string command)
            {
                process.StandardInput.WriteLine(command);
            }
        }

        public class Ziper
        {
            public static async Task Decompress(string zipFile, string targetPath, int bufferSize)
            {
                if (!Directory.Exists(targetPath))
                {
                    Directory.CreateDirectory(targetPath);
                }
                string currentpath = targetPath;

                ZipEntry entry;
                ZipInputStream zipinputstream = new ZipInputStream(File.OpenRead(zipFile));
                while ((entry = zipinputstream.GetNextEntry()) != null)
                {
                    if (entry.Name.Contains("/"))
                    {
                        string parentpath = entry.Name.Remove(entry.Name.LastIndexOf("/"));
                        if (!Directory.Exists(parentpath))
                        {
                            Directory.CreateDirectory(currentpath + parentpath);
                        }
                    }
                    if (entry.IsDirectory)
                    {
                        continue;
                    }
                    FileStream outputfilestream = File.Create(currentpath + entry.Name);
                    int readlength;
                    byte[] buffer = new byte[bufferSize];
                    while ((readlength = await zipinputstream.ReadAsync(buffer, 0, bufferSize)) > 0)
                    {
                        await outputfilestream.WriteAsync(buffer, 0, readlength);
                    }
                    outputfilestream.Close();
                    zipinputstream.CloseEntry();
                }
                zipinputstream.Close();
            }
        }

    }

}