#!/usr/bin/python3

import socket
import os
import struct

#SOCK_PATH = "/tmp/CoreFxPipe_mySocket"
#  TRY changing this to the same within C#
# 
SOCK_PATH = "/mySocket"
#  SOCK_PATH = r'\\.\pipe\mySocket'

# with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as sock:
# Change socket.AF_UNIX to socket.AF_INET for Windows
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
    try:
        os.remove(SOCK_PATH)
    except OSError:
        pass
    #sock.bind(SOCK_PATH)
    #Traceback (most recent call last):
    #sock.bind(SOCK_PATH)
    #TypeError: bind(): AF_INET address must be tuple, not str

    sock.bind((SOCK_PATH, 443))
    #socket.gaierror: [Errno 11001] getaddrinfo failed

    sock.listen()
    conn, addr = sock.accept()
    with conn:
        try:
            while True:
                amount_expected = struct.unpack('I', conn.recv(4))[0]
                print("amount_expected :", amount_expected)

                message = conn.recv(amount_expected)
                print("Received message : ", message.decode())

                # Send data
                message_rev = message[::-1].decode()
                print("Sent message (reversed) : ", message_rev)

                conn.sendall(
                    struct.pack(
                        'I',
                        len(message_rev)
                    )
                    + message_rev.encode('utf-8')
                )

        except (struct.error, KeyboardInterrupt) as e:
            print(e)

        finally:
            print('closing socket')

    class PipeClient
    {
        public void PipeClient_Main(string[] args)
        {
            using (NamedPipeClientStream
                   pipeClient = new NamedPipeClientStream
                                      (".", "mySocket", PipeDirection.InOut))
            {
    
                // Connect to the pipe or wait until the pipe is available.
                Console.WriteLine("Attempting to connect to pipe...");
                pipeClient.Connect();
    
                try
                {
                    // Read user input and send that to the client process.
                    using (BinaryWriter _bw = new BinaryWriter(pipeClient))
                    using (BinaryReader _br = new BinaryReader(pipeClient))
                    {
                        while (true)
                        {
                            //sw.AutoFlush = true;
                            Console.Write("Enter text: ");
                            var str = Console.ReadLine();
    
                            var buf = Encoding.ASCII.GetBytes(str);     // Get ASCII byte array
                            _bw.Write((uint)buf.Length);                // Write string length
                            _bw.Write(buf);                              // Write string
                            Console.WriteLine("Wrote: \"{0}\"", str);
                            Console.WriteLine("Let's hear from the server now..");
    
                            var len = _br.ReadUInt32();
                            var temp = new string(_br.ReadChars((int)len));
    
                            Console.WriteLine("Received from client: {0}", temp);
                        }
                    }
                }
                // Catch the IOException that is raised if the pipe is broken
                // or disconnected.
                catch (IOException e)
                {
                    Console.WriteLine("ERROR: {0}", e.Message);
                }
    
            }
            Console.Write("Press Enter to continue...");
        }
    }