VRCX/Dotnet/IPC/IPCServer.cs

// Copyright(c) 2019-2025 pypy, Natsumi and individual contributors.
// All rights reserved.
//
// This work is licensed under the terms of the MIT license.
// For a copy, see <https://opensource.org/licenses/MIT>.

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.IO.Pipes;
using System.Threading.Tasks;

namespace VRCX
{
    public class IPCServer
    {
        public static readonly IPCServer Instance;
        public static readonly ConcurrentDictionary<IPCClient, byte> Clients = new();

        static IPCServer()
        {
            Instance = new IPCServer();
        }

        public void Init()
        {
            new IPCServer().CreateIPCServer();
        }

        public static void Send(IPCPacket ipcPacket)
        {
            foreach (var client in Clients)
            {
                client.Key?.Send(ipcPacket);
            }
        }

        public static string GetIpcName()
        {
            var hash = 0;
            foreach (var c in Environment.UserName)
            {
                hash += c;
            }
            return $"vrcx-ipc-{hash}";
        }

        public void CreateIPCServer()
        {
            var ipcServer = new NamedPipeServerStream(GetIpcName(), PipeDirection.InOut, NamedPipeServerStream.MaxAllowedServerInstances, PipeTransmissionMode.Byte, PipeOptions.Asynchronous);
            ipcServer.BeginWaitForConnection(DoAccept, ipcServer);
        }

        private void DoAccept(IAsyncResult asyncResult)
        {
            var ipcServer = (NamedPipeServerStream)asyncResult.AsyncState;

            try
            {
                ipcServer.EndWaitForConnection(asyncResult);
            }
            catch (Exception e)
            {
                Console.WriteLine(e);
            }

            var ipcClient = new IPCClient(ipcServer);
            Clients.TryAdd(ipcClient, 0);
            ipcClient.BeginRead();
            CreateIPCServer();
        }
    }
}