-module(tcp_server).
-author('Bin Shen <23420800@qq.com>').
-compile(export_all).

-export([listen/1, loop/3]).
-import(handler,[doWork/3]).

-define(TCP_OPTIONS, [binary, {packet, 0}, {active, false}, {reuseaddr, true}]).

% Call echo:listen(Port) to start the service.  
listen(Port) ->
  {ok, LSocket} = gen_tcp:listen(Port, ?TCP_OPTIONS), accept(LSocket).

% Wait for incoming connections and spawn the echo loop when we get one.  
accept(LSocket) ->
  {ok, Socket} = gen_tcp:accept(LSocket),
  spawn(fun() -> loop(Socket, <<>>, 0) end),
  accept(LSocket).

% Echo back whatever data we receive on Socket.  
loop(Socket, Chain, Count) ->

  io:format("~p~n", [Count]),

  case gen_tcp:recv(Socket, 0) of

%%    {ok, <<90, 0, 16, 1, 0, 1, A1, A2, A3, A4, A5, A6>>} ->
%%      io:format("recv +++++++"),
%%      io:format("recv ~p~n", [A1]),
%%      io:format("recv ~p~n", [A2]),
%%      io:format("recv ~p~n", [A3]),
%%      io:format("recv ~p~n", [A4]),
%%      io:format("recv ~p~n", [A5]),
%%      io:format("recv ~p~n", [A6]),
%%
%%      loop(Socket);

    {ok, Data} ->
%%      io:format("recv ~p~n", [Data]),
%%      gen_tcp:send(Socket, Data),

%%      io:format("recv ~p~n", [Data]),
%%
%%      X = binary_to_list(Data),
%%      io:format("recv ~w~n", [X]),
%%
%%      Y = [ integer_to_list(N, 16) || N <- X],
%%      io:format("recv ~w~n", [Y]),

      ChainLen = byte_size(Chain),
      DataLen = byte_size(Data),
      doWork(Socket, <<Chain:ChainLen/binary, Data:DataLen/binary >>, Count);

%%      loop(Socket);
    {error, closed} ->
      ok
  end.