program dproxy;

{$APPTYPE CONSOLE}

uses
  windows,
  WinSock,
  StrUtils,
  SysUtils,
  uutil in 'uutil.pas';

const
  pcount = 32;

var
  wsaData  : TWSADATA;
  mainsock : TSocket;
  client   : TSOCKADDR;
  csock    : TSocket;
  addr     : SOCKADDR_IN;
  Size     : integer;
  bol      : boolean;
  i        : integer;

  a_exit : array of boolean;
  a_sock : array of TClientEx;
  a_hndl : array of THandle;

function SocksHandlerTreadProc(pParam:pointer):DWORD; stdcall;
var
  s1   : TSocket;
  j    : integer;
  i    : integer;
  loop : integer;
  bol  : boolean;
  buf_1: AnsiString;
  buf  : AnsiString;
  buf_len : integer;
  p  : integer;
  p2 : integer;
  p3 : integer;
  z_s : string;
  recv_result : integer;
  DataType : TDataType;
  Host_str : string;
  Host_host : string;
  Host_port : string;
  zapros_str : string;
  url : string;
  remHost : u_long;
  RemPort : u_short;
  sa  : TSockaddrin;
  lpMsgBuf : array[0..255] of Char;

  name : TSockaddr;
begin
  j := integer(pParam);
  WHILE TRUE DO
  BEGIN
    while a_sock[j].Socket=0 do sleep(40);
    i := sizeof(name);
    getpeername(a_sock[j].Socket, name, i);
    a_sock[j].client := LongToIp(name.sin_addr.S_addr);
    z_s   := #13#10;
    loop  := 0;
    bol   := True;
    buf_1 := '';
    buf   := '';
    buf_len := 1024;
    DataType := dtGET;
    while loop=0 do
    begin
      inc(loop);
      while bol do
      begin
        setlength(buf_1,buf_len);
        recv_result := recv(a_sock[j].Socket,buf_1[1],buf_len,0);
        if recv_result>0 then setlength(buf_1,recv_result)
                         else break;
        buf := buf + buf_1;
        p := pos(z_s+z_s,buf);
        if p<>0 then
        begin
          bol := False;
          break;
        end;
      end;
      if bol then break;
      buf_1 := lowercase(copy(buf,1,4));
      if buf_1<>'get ' then
        if buf_1='post' then DataType := dtPOST
                        else if buf_1='head' then DataType := dtHEAD
                                             else break;
  
      p := pos(z_s,buf);
      zapros_str := copy(buf,1,p-1);
      delete(buf,1,p+1);
  
      p   := posex(#32,zapros_str);
      p3  := p;
      p2  := posex(#32,zapros_str,p+1);
      url := copy(zapros_str,p+1,p2-p-1);
      delete(zapros_str,p,p2-p+1);
      delete(url,1,7);
      p         := pos('/',url);
      host_str  := copy(url,1,p-1);
      delete(url,1,p-1);
      p         := pos(':',host_str);
      if p=0 then
      begin
        host_port := '80';
        host_host := host_str;
      end
             else
      begin
        host_host := copy(host_str,1,p-1);
        host_port := copy(host_str,p+1,length(host_str));
      end;
      insert(#32+url+#32,zapros_str,p3);
      buf := zapros_str + z_s + buf;
      remHost := HostToLong(host_host);
      RemPort := strtoint(host_port);
      writeln(a_sock[j].client + ' ' + zapros_str);
      s1  := socket(AF_INET, SOCK_STREAM,0);
      FillChar(sa,sizeof(sa),0);
      sa.sin_addr.S_addr := remHost;
      sa.sin_family := af_inet;
      sa.sin_port   := htons(80);
      if connect(s1,sa,sizeof(sa))<>SOCKET_ERROR then
      begin
        send(s1,buf[1],length(buf),0);
        bol := True;
        while bol do
        begin
          setlength(buf_1,buf_len);
          recv_result := recv(s1,buf_1[1],buf_len,0);
          if recv_result>0 then
          begin
            setlength(buf_1,recv_result);
            send(a_sock[j].Socket,buf_1[1],length(buf_1),0);
          end
                           else break;
        end;
      end;
      shutdown(s1, SD_BOTH);
      closesocket(s1);
    end;

    shutdown(a_sock[j].Socket, SD_BOTH);
    closesocket(a_sock[j].Socket);
    a_sock[j].Socket := 0;
  END;
  result := 0;
end;

begin
  WSAStartup(MAKEWORD(2,0), wsaData);
  mainsock             := socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  addr.sin_family      := AF_INET;
  addr.sin_port        := htons(8080);
  addr.sin_addr.s_addr := INADDR_ANY;
  Size                 := SizeOf(Client);
  if (Bind(mainsock,addr,SizeOf(addr))=0) and (Listen(mainsock,$FF)=0) then
  begin
    setlength(a_exit,pcount);
    setlength(a_sock,pcount);
    setlength(a_hndl,pcount);
    for i:=0 to pcount-1 do
    begin
      a_exit[i]        := False;
      a_sock[i].Socket := 0;
      fillchar(a_sock[i].Client,buf1len,0);
      CreateThread(nil,0,@SocksHandlerTreadProc,pointer(i),0,a_hndl[i]);
    end;
    while true do
    begin
      csock := accept(mainsock, @Client, @Size);
      bol   := True;
      for i:=0 to pcount-1 do
        if a_sock[i].Socket=0 then
        begin
          bol := False;
          a_sock[i].Socket := csock;
//          move(inet_ntoa(Client.sin_addr),a_sock[i].Client,buf1len);
          break;
        end;
      if bol then
      begin
        shutdown(csock, SD_BOTH);
        closesocket(csock);
      end;
    end;
  end;
  readln;
end.