Method ServerThread

client/Program.cs:334–380

()

        }
                
        static void ServerThread() {
                
            using (NamedPipeServerStream serverStream = new NamedPipeServerStream("lsarelayx", PipeDirection.InOut, 10, PipeTransmissionMode.Byte)) {

                serverThreadReady.Set();

                while (true) {

                    try {

                        serverStream.WaitForConnection();
                        var command = BitseryObject.ReadFromStream(serverStream);

                        if (command is InitRequest) {
                            Console.WriteLine($"[+] Init command received from LSA");
                            initResponse.WriteToStream(serverStream);
                   
                        } else if (command is RelayRequest relayRequest) {
                            
                            var relayResponse = ProcessRelayRequest(relayRequest);
                            relayResponse.WriteToStream(serverStream);                            

                        } else if (command is NegotiateRequest negotiateRequest) {

                            var response = ProcessNegotiateToken(negotiateRequest);
                            response.WriteToStream(serverStream);

                        }

                        serverStream.Flush();

                    } catch (Exception e) {

                        Console.WriteLine($"[!] Pipe disconnected with error {e.Message}");
       
                    } finally {
                        try {
                            serverStream.WaitForPipeDrain();
                        } catch (Exception) { 

                        } finally {
                            serverStream.Disconnect();
                        }
                    }
                }
            }
        }


        //https://stackoverflow.com/questions/283456/byte-array-pattern-search