#ifndef __INCLUDE_NAPI_LPC_H
#define __INCLUDE_NAPI_LPC_H

#ifdef __USE_W32API
#include <ddk/ntapi.h>
#include <napi/types.h>
#endif /* !__USE_W32API */

#include <ntos/security.h>

#define MAX_MESSAGE_DATA   (0x130)

#ifndef __USE_W32API

typedef enum 
{
    UNUSED_MSG_TYPE        = 0x0, /* ReactOS */
    LPC_NEW_MESSAGE        = 0x0, /* NT */
    LPC_REQUEST            = 0x1,
    LPC_REPLY              = 0x2,
    LPC_DATAGRAM           = 0x3,
    LPC_LOST_REPLY         = 0x4,
    LPC_PORT_CLOSED        = 0x5,
    LPC_CLIENT_DIED        = 0x6,
    LPC_EXCEPTION          = 0x7,
    LPC_DEBUG_EVENT        = 0x8,
    LPC_ERROR_EVENT        = 0x9,
    LPC_CONNECTION_REQUEST = 0xa,
    LPC_CONNECTION_REFUSED = 0xb

} LPC_TYPE, *PLPC_TYPE;

typedef struct _LPC_SECTION_WRITE
{
   ULONG Length;
   HANDLE SectionHandle;
   ULONG SectionOffset;
   ULONG ViewSize;
   PVOID ViewBase;
   PVOID TargetViewBase;
} LPC_SECTION_WRITE, *PLPC_SECTION_WRITE;

typedef struct _LPC_SECTION_READ
{
   ULONG Length;
   ULONG ViewSize;
   PVOID ViewBase;
} LPC_SECTION_READ, *PLPC_SECTION_READ;

typedef struct _LPC_MESSAGE
{
   USHORT DataSize;
   USHORT MessageSize;
   USHORT MessageType;
   USHORT VirtualRangesOffset;
   CLIENT_ID ClientId;
   ULONG MessageId;
   ULONG SectionSize; /* CallbackID */
} LPC_MESSAGE, *PLPC_MESSAGE;

#endif /* !__USE_W32API */


typedef struct _LPC_TERMINATION_MESSAGE
{
   LPC_MESSAGE Header;
   TIME CreationTime;
} LPC_TERMINATION_MESSAGE, *PLPC_TERMINATION_MESSAGE;

typedef struct _LPC_DEBUG_MESSAGE
{
   LPC_MESSAGE Header;
   ULONG EventCode;
   ULONG Status;
   union {
      struct {
         EXCEPTION_RECORD ExceptionRecord;
         ULONG FirstChance;
      } Exception;
      struct {
         ULONG Reserved;
         PVOID StartAddress;
      } CreateThread;
      struct {
         ULONG Reserved;
	 HANDLE FileHandle;
	 PVOID Base;
	 ULONG PointerToSymbolTable;
	 ULONG NumberOfSymbols;
	 ULONG Reserved2;
	 PVOID EntryPoint;
      } CreateProcess;
      struct {
	 ULONG ExitCode;
      } ExitThread;
      struct {
	 ULONG ExitCode;
      } ExitProcess;
      struct {
	 HANDLE FileHandle;
	 PVOID Base;
	 ULONG PointerToSymbolTable;
	 ULONG NumberOfSymbols;
      } LoadDll;
      struct {
	 PVOID Base;
      } UnloadDll;
#ifdef ANONYMOUSUNIONS
   };
#else
   } u;
#endif
} LPC_DEBUG_MESSAGE, * PLPC_DEBUG_MESSAGE;

typedef struct _LPC_MAX_MESSAGE
{
   LPC_MESSAGE Header;
   BYTE Data[MAX_MESSAGE_DATA];
} LPC_MAX_MESSAGE, *PLPC_MAX_MESSAGE;

#define PORT_MESSAGE_TYPE(m) (LPC_TYPE)((m).Header.MessageType)

#ifndef __USE_NT_LPC__
NTSTATUS STDCALL NtAcceptConnectPort (PHANDLE	PortHandle,
				      HANDLE NamedPortHandle,
				      PLPC_MESSAGE ServerReply,
				      BOOLEAN AcceptIt,
				      PLPC_SECTION_WRITE WriteMap,
				      PLPC_SECTION_READ ReadMap);
#else
NTSTATUS STDCALL NtAcceptConnectPort (PHANDLE	PortHandle,
				      ULONG PortIdentifier,
				      PLPC_MESSAGE ServerReply,
				      BOOLEAN AcceptIt,
				      PLPC_SECTION_WRITE WriteMap,
				      PLPC_SECTION_READ ReadMap);
#endif /* ndef __USE_NT_LPC__ */

NTSTATUS STDCALL NtCompleteConnectPort (HANDLE PortHandle);

NTSTATUS STDCALL NtConnectPort(PHANDLE PortHandle,
			       PUNICODE_STRING PortName,
			       PSECURITY_QUALITY_OF_SERVICE SecurityQos,
			       PLPC_SECTION_WRITE SectionInfo,
			       PLPC_SECTION_READ MapInfo,
			       PULONG MaxMessageSize,
			       PVOID ConnectInfo,
			       PULONG ConnectInfoLength);

NTSTATUS STDCALL NtReplyWaitReplyPort (HANDLE PortHandle,
				       PLPC_MESSAGE ReplyMessage);
 
NTSTATUS STDCALL NtCreatePort(PHANDLE PortHandle,
			      POBJECT_ATTRIBUTES ObjectAttributes,
			      ULONG MaxConnectInfoLength,
			      ULONG MaxDataLength,
			      ULONG NPMessageQueueSize OPTIONAL);

NTSTATUS STDCALL NtCreateWaitablePort(PHANDLE PortHandle,
			              POBJECT_ATTRIBUTES ObjectAttributes,
			              ULONG MaxConnectInfoLength,
			              ULONG MaxDataLength,
			              ULONG NPMessageQueueSize OPTIONAL);

NTSTATUS STDCALL NtImpersonateClientOfPort (HANDLE PortHandle,
					    PLPC_MESSAGE ClientMessage);

NTSTATUS STDCALL NtListenPort (HANDLE PortHandle,
			       PLPC_MESSAGE LpcMessage);

NTSTATUS STDCALL NtQueryInformationPort (HANDLE PortHandle,
					 CINT PortInformationClass,	
					 PVOID PortInformation,	
					 ULONG PortInformationLength,	
					 PULONG ReturnLength);
NTSTATUS STDCALL NtReplyPort (HANDLE PortHandle,
			      PLPC_MESSAGE LpcReply);
NTSTATUS STDCALL NtReplyWaitReceivePort (HANDLE	PortHandle,
					 PULONG PortId,
					 PLPC_MESSAGE MessageReply,
					 PLPC_MESSAGE MessageRequest);
NTSTATUS STDCALL NtRequestPort (HANDLE PortHandle,
			        PLPC_MESSAGE LpcMessage);

NTSTATUS STDCALL NtRequestWaitReplyPort (HANDLE PortHandle,
					 PLPC_MESSAGE LpcReply,      
					 PLPC_MESSAGE LpcRequest);

NTSTATUS STDCALL NtReadRequestData (HANDLE PortHandle,
				    PLPC_MESSAGE Message,
				    ULONG Index,
				    PVOID Buffer,
				    ULONG BufferLength,
				    PULONG ReturnLength);

NTSTATUS STDCALL NtWriteRequestData (HANDLE PortHandle,
				     PLPC_MESSAGE Message,
				     ULONG Index,
				     PVOID Buffer,
				     ULONG BufferLength,
				     PULONG ReturnLength);


#endif /* __INCLUDE_NAPI_LPC_H */