using System;

using Microsoft.Win32.SafeHandles;

using System.Text;

using System.Runtime.InteropServices;

using System.Threading;

using System.IO;

using System.Diagnostics;

namespace SoundGraph

{

    public class Server

    {

        [Flags]

        public enum EFileAccess : uint

        {

            //

            // Standart Section

            //

            AccessSystemSecurity = 0x1000000,   // AccessSystemAcl access type

            MaximumAllowed = 0x2000000,     // MaximumAllowed access type

            Delete = 0x10000,

            ReadControl = 0x20000,

            WriteDAC = 0x40000,

            WriteOwner = 0x80000,

            Synchronize = 0x100000,

            StandardRightsRequired = 0xF0000,

            StandardRightsRead = ReadControl,

            StandardRightsWrite = ReadControl,

            StandardRightsExecute = ReadControl,

            StandardRightsAll = 0x1F0000,

            SpecificRightsAll = 0xFFFF,

            FILE_READ_DATA = 0x0001,        // file & pipe

            FILE_LIST_DIRECTORY = 0x0001,       // directory

            FILE_WRITE_DATA = 0x0002,       // file & pipe

            FILE_ADD_FILE = 0x0002,         // directory

            FILE_APPEND_DATA = 0x0004,      // file

            FILE_ADD_SUBDIRECTORY = 0x0004,     // directory

            FILE_CREATE_PIPE_INSTANCE = 0x0004, // named pipe

            FILE_READ_EA = 0x0008,          // file & directory

            FILE_WRITE_EA = 0x0010,         // file & directory

            FILE_EXECUTE = 0x0020,          // file

            FILE_TRAVERSE = 0x0020,         // directory

            FILE_DELETE_CHILD = 0x0040,     // directory

            FILE_READ_ATTRIBUTES = 0x0080,      // all

            FILE_WRITE_ATTRIBUTES = 0x0100,     // all

            //

            // Generic Section

            //

            GenericRead = 0x80000000,

            GenericWrite = 0x40000000,

            GenericExecute = 0x20000000,

            GenericAll = 0x10000000,

            SPECIFIC_RIGHTS_ALL = 0x00FFFF,

            FILE_ALL_ACCESS =

            StandardRightsRequired |

            Synchronize |

            0x1FF,

            FILE_GENERIC_READ =

            StandardRightsRead |

            FILE_READ_DATA |

            FILE_READ_ATTRIBUTES |

            FILE_READ_EA |

            Synchronize,

            FILE_GENERIC_WRITE =

            StandardRightsWrite |

            FILE_WRITE_DATA |

            FILE_WRITE_ATTRIBUTES |

            FILE_WRITE_EA |

            FILE_APPEND_DATA |

            Synchronize,

            FILE_GENERIC_EXECUTE =

            StandardRightsExecute |

              FILE_READ_ATTRIBUTES |

              FILE_EXECUTE |

              Synchronize

        }

        [Flags]

        public enum EFileShare : uint

        {

            /// <summary>

            /// 

            /// </summary>

            None = 0x00000000,

            /// <summary>

            /// Enables subsequent open operations on an object to request read access. 

            /// Otherwise, other processes cannot open the object if they request read access. 

            /// If this flag is not specified, but the object has been opened for read access, the function fails.

            /// </summary>

            Read = 0x00000001,

            /// <summary>

            /// Enables subsequent open operations on an object to request write access. 

            /// Otherwise, other processes cannot open the object if they request write access. 

            /// If this flag is not specified, but the object has been opened for write access, the function fails.

            /// </summary>

            Write = 0x00000002,

            /// <summary>

            /// Enables subsequent open operations on an object to request delete access. 

            /// Otherwise, other processes cannot open the object if they request delete access.

            /// If this flag is not specified, but the object has been opened for delete access, the function fails.

            /// </summary>

            Delete = 0x00000004

        }

        public enum ECreationDisposition : uint

        {

            /// <summary>

            /// Creates a new file. The function fails if a specified file exists.

            /// </summary>

            New = 1,

            /// <summary>

            /// Creates a new file, always. 

            /// If a file exists, the function overwrites the file, clears the existing attributes, combines the specified file attributes, 

            /// and flags with FILE_ATTRIBUTE_ARCHIVE, but does not set the security descriptor that the SECURITY_ATTRIBUTES structure specifies.

            /// </summary>

            CreateAlways = 2,

            /// <summary>

            /// Opens a file. The function fails if the file does not exist. 

            /// </summary>

            OpenExisting = 3,

            /// <summary>

            /// Opens a file, always. 

            /// If a file does not exist, the function creates a file as if dwCreationDisposition is CREATE_NEW.

            /// </summary>

            OpenAlways = 4,

            /// <summary>

            /// Opens a file and truncates it so that its size is 0 (zero) bytes. The function fails if the file does not exist.

            /// The calling process must open the file with the GENERIC_WRITE access right. 

            /// </summary>

            TruncateExisting = 5

        }

        [Flags]

        public enum EFileAttributes : uint

        {

            None = 0x00000000,

            Readonly = 0x00000001,

            Hidden = 0x00000002,

            System = 0x00000004,

            Directory = 0x00000010,

            Archive = 0x00000020,

            Device = 0x00000040,

            Normal = 0x00000080,

            Temporary = 0x00000100,

            SparseFile = 0x00000200,

            ReparsePoint = 0x00000400,

            Compressed = 0x00000800,

            Offline = 0x00001000,

            NotContentIndexed = 0x00002000,

            Encrypted = 0x00004000,

            Write_Through = 0x80000000,

            Overlapped = 0x40000000,

            NoBuffering = 0x20000000,

            RandomAccess = 0x10000000,

            SequentialScan = 0x08000000,

            DeleteOnClose = 0x04000000,

            BackupSemantics = 0x02000000,

            PosixSemantics = 0x01000000,

            OpenReparsePoint = 0x00200000,

            OpenNoRecall = 0x00100000,

            FirstPipeInstance = 0x00080000

        }

        [DllImport("kernel32.dll", SetLastError = true)]

        public static extern SafeFileHandle CreateNamedPipe(

           String pipeName,

           uint dwOpenMode,

           uint dwPipeMode,

           uint nMaxInstances,

           uint nOutBufferSize,

           uint nInBufferSize,

           uint nDefaultTimeOut,

           IntPtr lpSecurityAttributes);

        [DllImport("kernel32.dll", SetLastError = true)]

        public static extern int ConnectNamedPipe(

           SafeFileHandle hNamedPipe,

           IntPtr lpOverlapped);

        [DllImport("kernel32.dll", SetLastError = true)]

        public static extern int DisconnectNamedPipe(

           SafeFileHandle hNamedPipe);

        [DllImport("kernel32.dll", SetLastError = true, CharSet = CharSet.Auto)]

        public static extern SafeFileHandle CreateFile(

           string lpFileName,

           EFileAccess dwDesiredAccess,

           EFileShare dwShareMode,

           IntPtr lpSecurityAttributes,

           ECreationDisposition dwCreationDisposition,

           EFileAttributes dwFlagsAndAttributes,

           IntPtr hTemplateFile);

        //[DllImport("kernel32.dll", SetLastError = true)]

        //static extern bool CloseHandle(IntPtr hHandle);

        public const uint PIPE_ACCESS_DUPLEX = (0x00000003);

        public const uint FILE_FLAG_OVERLAPPED = (0x40000000);

        public const uint PIPE_ACCESS_OUTBOUND = (0x00000002);

        public const uint PIPE_ACCESS_INBOUND = (0x00000001);

        public const uint PIPE_TYPE_BYTE = (0x00000000);

        public const uint PIPE_UNLIMITED_INSTANCES = 255;

        public const int BUFFER_SIZE = 256;

        //

        public string iPipeNameOutbound;

        SafeFileHandle iPipeOutbound;

        public FileStream iStreamOutbound;

        //

        public string iPipeNameInbound;

        Thread iThreadInbound;

        SafeFileHandle iPipeInbound;

        public FileStream iStreamInbound;

        private bool iQuit = false;

        public Server(string aPipeNameOutbound, string aPipeNameInbound)

        {

            iPipeNameOutbound = aPipeNameOutbound;

            iPipeNameInbound = aPipeNameInbound;

        }

        /**

         * Start our services.

         */

        public void Start()

        {

            //Start inbound thread to receive messages

            this.iThreadInbound = new Thread(new ThreadStart(ThreadInbound));

            this.iThreadInbound.Start();

        }

        /**

         * Stop our services.

         */

        public void Stop()

        {

            iQuit = true;

        }

        /**

         * Inbound thread is receiving messages from our client

         */

        private void ThreadInbound()

        {

            //Keep on trying to connect on our read pipe

            while ((iPipeInbound == null || iPipeInbound.IsInvalid) && !iQuit)

            {

                Trace.WriteLine("Trying to connect to inbound pipe...");

                iPipeInbound = CreateFile(iPipeNameInbound, EFileAccess.GenericRead, EFileShare.None, IntPtr.Zero, ECreationDisposition.OpenExisting, EFileAttributes.None, IntPtr.Zero);

                System.Threading.Thread.Sleep(1000);

            }

            //Client now connected create our inbound stream

            if (iPipeInbound!=null && !iPipeInbound.IsInvalid)

            {

                iStreamInbound = new FileStream(iPipeInbound, FileAccess.Read, BUFFER_SIZE, false);

                if (iStreamInbound.CanRead)

                {

                    Trace.WriteLine("Inbound stream ready!");

                }

            }

            //Keep on trying to connect to our write pipe

            while ((iPipeOutbound == null || iPipeOutbound.IsInvalid) && !iQuit)

            {

                Trace.WriteLine("Trying to connect to outbound pipe...");

                iPipeOutbound = CreateFile(iPipeNameOutbound, EFileAccess.GenericWrite, EFileShare.None, IntPtr.Zero, ECreationDisposition.OpenExisting, EFileAttributes.None, IntPtr.Zero);

                System.Threading.Thread.Sleep(1000);

            }

            //Client now connected create our stream

            if (iPipeOutbound!=null && !iPipeOutbound.IsInvalid)

            {

                iStreamOutbound = new FileStream(iPipeOutbound, FileAccess.Write, BUFFER_SIZE, false);

                if (iStreamOutbound.CanWrite)

                {

                    Trace.WriteLine("Outbound stream ready!");

                }

            }

            //Listening loop

            byte[] buffer = null;

            ASCIIEncoding encoder = new ASCIIEncoding();

            while (!iQuit)

            {                

                int bytesRead = 0;

                try

                {

                    buffer = new byte[BUFFER_SIZE];

                    bytesRead = iStreamInbound.Read(buffer, 0, BUFFER_SIZE);

                }

                catch

                {

                    //read error has occurred

                    break;

                }

                //client has disconnected

                if (bytesRead == 0)

                    break;

                //fire message received event

                //if (this.MessageReceived != null)

                //    this.MessageReceived(clientse, encoder.GetString(buffer, 0, bytesRead));

                int ReadLength = 0;

                for (int i = 0; i < BUFFER_SIZE; i++)

                {

                    //if (buffer[i].ToString("x2") != "cc")

                    if (buffer[i] != 0)

                    {

                        ReadLength++;

                    }

                    else

                        break;

                }

                if (ReadLength > 0)

                {

                    byte[] Rc = new byte[ReadLength];

                    Buffer.BlockCopy(buffer, 0, Rc, 0, ReadLength);

                    Trace.WriteLine(encoder.GetString(Rc, 0, ReadLength));

                    Trace.WriteLine("Received " + ReadLength + " Bytes: " + encoder.GetString(Rc, 0, ReadLength));

                    buffer.Initialize();

                }

            }

            //clean up resources

            if (iStreamInbound!=null) iStreamInbound.Close();

            if (iPipeInbound != null) iPipeInbound.Close();

            //

            if (iStreamOutbound != null) iStreamOutbound.Close();

            if (iPipeOutbound != null) iPipeOutbound.Close();

        }

        /**

         * Send a message to our client.

         */

        public void SendMessage(string message)

        {

                ASCIIEncoding encoder = new ASCIIEncoding();

                byte[] messageBuffer = encoder.GetBytes(message);

                if (iStreamOutbound != null && iStreamOutbound.CanWrite)

                {

                    iStreamOutbound.Write(messageBuffer, 0, messageBuffer.Length);

                    iStreamOutbound.Flush();

                }

        }

    }

}