Skip to content

Commit 3e5b6fb

Browse files
yongboyyongboy
committed
source
0 parents  commit 3e5b6fb

40 files changed

+15507
-0
lines changed

‎.checkstyle

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
3+
<fileset-config file-format-version="1.2.0" simple-config="true" sync-formatter="false">
4+
<fileset name="all" enabled="true" check-config-name="Sun Checks" local="false">
5+
<file-match-pattern match-pattern="." include-pattern="true"/>
6+
</fileset>
7+
</fileset-config>

‎.externalToolBuilders/org.erlide.core.builder.dialyzer.launch

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
2+
<launchConfiguration type="org.eclipse.ant.AntBuilderLaunchConfigurationType">
3+
<booleanAttribute key="org.eclipse.ui.externaltools.ATTR_BUILDER_ENABLED" value="false"/>
4+
<stringAttribute key="org.eclipse.ui.externaltools.ATTR_DISABLED_BUILDER" value="org.erlide.core.builder.dialyzer"/>
5+
<mapAttribute key="org.eclipse.ui.externaltools.ATTR_TOOL_ARGUMENTS"/>
6+
<booleanAttribute key="org.eclipse.ui.externaltools.ATTR_TRIGGERS_CONFIGURED" value="true"/>
7+
</launchConfiguration>

‎.project

+27
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<projectDescription>
3+
<name>socket.io_cowboy</name>
4+
<comment></comment>
5+
<projects>
6+
</projects>
7+
<buildSpec>
8+
<buildCommand>
9+
<name>org.erlide.core.erlbuilder</name>
10+
<arguments>
11+
</arguments>
12+
</buildCommand>
13+
<buildCommand>
14+
<name>org.eclipse.ui.externaltools.ExternalToolBuilder</name>
15+
<triggers>full,incremental,</triggers>
16+
<arguments>
17+
<dictionary>
18+
<key>LaunchConfigHandle</key>
19+
<value>&lt;project&gt;/.externalToolBuilders/org.erlide.core.builder.dialyzer.launch</value>
20+
</dictionary>
21+
</arguments>
22+
</buildCommand>
23+
</buildSpec>
24+
<natures>
25+
<nature>org.erlide.core.erlnature</nature>
26+
</natures>
27+
</projectDescription>

‎.settings/org.erlide.core.prefs

+7
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
backend_version=R15B
2+
eclipse.preferences.version=1
3+
external_includes=
4+
external_modules=
5+
nukeOutputOnClean=false
6+
output_dir=ebin
7+
source_dirs=deps/lager/src;test;deps/cowboy/src;src

‎Makefile

+17
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
PREFIX:=../
2+
DEST:=$(PREFIX)$(PROJECT)
3+
4+
REBAR=./rebar
5+
6+
all:
7+
@$(REBAR) get-deps compile
8+
9+
edoc:
10+
@$(REBAR) doc
11+
12+
clean:
13+
@$(REBAR) clean
14+
rm -f erl_crash.dump
15+
16+
app:
17+
@$(REBAR) create template=demoapp dest=$(DEST) appid=$(PROJECT)

‎rebar

102 KB
Binary file not shown.

‎rebar.config

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
%%-*- mode: erlang -*-
2+
{deps, [
3+
{cowboy, ".*", {git, "git://github.com/extend/cowboy.git", {tag, "0.6.1"}}},
4+
{lager, ".*", {git, "git://github.com/basho/lager.git", "master"}}
5+
]}.
6+
{erl_opts, [{parse_transform, lager_transform}, {lager_truncation_size, 1024}]}.

‎src/common_polling.erl

+119
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,119 @@
1+
%% @author yongboy <[email protected]>
2+
%% @copyright 2012 yongboy <[email protected]>
3+
%% @doc socketio.
4+
5+
-module(common_polling).
6+
-export([timeout_call/1, set_timeout/1, set_timeout/2, do_post_msg/1]).
7+
-define(HEARBEAT_INTERVAL, socketio:get_env(heartbeat_interval)*1000).
8+
-define(HEARBEAT_TIMEOUT, socketio:get_env(heartbeat_timeout)*1000).
9+
10+
%%
11+
%% API Functions
12+
%%
13+
14+
%% @doc handle message come from clinet
15+
-spec do_post_msg({_SessionId, _Msg}) -> string().
16+
do_post_msg({SessionId, Msg}) ->
17+
{[Type, MessageId, Endpoint, SubMsgData]} = socketio_decode:decode(Msg),
18+
case session_server:check(SessionId) of
19+
false ->
20+
string:join(["7:", Endpoint, "[\"Request Invalide\"]+[\"Please do not do that!\"]"], ":");
21+
true ->
22+
do_handle_post_msg({Type, MessageId, Endpoint, SubMsgData}, {SessionId, Msg}),
23+
"1"
24+
end.
25+
26+
%% @doc timeout call
27+
-spec timeout_call(_Any) -> void.
28+
timeout_call({SessionId}) ->
29+
session_server:unregister(SessionId);
30+
timeout_call({SessionId, Endpoint, Type}) ->
31+
Implement = endpoint_server:lookup(Endpoint),
32+
Implement:on_disconnect({SessionId, Endpoint, timeout}, fun(SendMsg, Others) ->
33+
send_call({SessionId, Type, Endpoint}, SendMsg, Others)
34+
end),
35+
session_server:unregister(SessionId).
36+
37+
%% @doc set timer execute one time with default ?HEARBEAT_TIMEOUT
38+
-spec set_timeout(_SessionId) -> void.
39+
set_timeout(SessionId) ->
40+
set_timeout(SessionId, ?HEARBEAT_TIMEOUT).
41+
42+
%% @doc set timer execute one time
43+
-spec set_timeout(_SessionId, _Timeout) -> void.
44+
set_timeout(SessionId, Timeout) ->
45+
Endpoint = session_server:call({SessionId, getEndpoint}),
46+
Args = case Endpoint of
47+
undefined ->
48+
{SessionId};
49+
_ ->
50+
{SessionId, Endpoint, "5"}
51+
end,
52+
TimeRef = case timer:apply_after(Timeout, ?MODULE, timeout_call, [Args]) of
53+
{ok, TRef} ->
54+
TRef;
55+
{error, _Reason} ->
56+
undefined
57+
end,
58+
session_server:cast({SessionId, timeout, TimeRef}).
59+
60+
%%
61+
%% Local Functions
62+
%%
63+
do_handle_post_msg({Type, MessageId, Endpoint, SubMsgData}, {SessionId, Msg}) ->
64+
Implement = endpoint_server:lookup(Endpoint),
65+
case Type of
66+
"0" ->
67+
Implement:on_disconnect({SessionId, Endpoint, SubMsgData}, fun(SendMsg, Others) ->
68+
send_call({SessionId, Type, Endpoint}, SendMsg, Others)
69+
end),
70+
session_server:unregister(SessionId);
71+
"1" ->
72+
session_server:cast({SessionId, endpoint, Endpoint}),
73+
session_server:cast({SessionId, self(), post, Msg}),
74+
Implement:on_connect({SessionId, MessageId, Endpoint, SubMsgData}, fun(SendMsg, Others) ->
75+
send_call({SessionId, Type, Endpoint}, SendMsg, Others)
76+
end);
77+
"2" ->
78+
set_timeout(SessionId, ?HEARBEAT_TIMEOUT),
79+
%% timer:send_after(?HEARBEAT_INTERVAL, Room, {self(), post, "2::"}); %% TODO
80+
timer:apply_after(?HEARBEAT_INTERVAL, session_server, cast, [{SessionId, self(), post, "2::"}]);
81+
"5" ->
82+
Implement:on_message({SessionId, Type, MessageId, Endpoint, SubMsgData}, fun(SendMsg, Others) ->
83+
send_call({SessionId, Type, Endpoint}, SendMsg, Others)
84+
end)
85+
end.
86+
87+
send_call({SessionId, _, Endpoint}, SendMsg, ack) ->
88+
Message = {SessionId, self(), post, string:join(["6", "", Endpoint, SendMsg], ":")},
89+
send_message(Message);
90+
send_call({SessionId, Type, Endpoint}, SendMsg, self) ->
91+
Message = {SessionId, self(), post, string:join([Type, "", Endpoint, SendMsg], ":")},
92+
send_message(Message);
93+
94+
send_call(_, _, []) ->
95+
void;
96+
send_call({_, Type, Endpoint}, SendMsg, TargetSessionIdes = [_|_]) ->
97+
lists:foreach(fun(TargetSessionId) ->
98+
Message = {TargetSessionId, self(), post, string:join([Type, "", Endpoint, SendMsg], ":")},
99+
send_message(Message)
100+
end, TargetSessionIdes);
101+
102+
send_call(_, _, {[], _}) ->
103+
void;
104+
send_call({_, _, Endpoint}, SendMsg, {TargetSessionIds=[_|_], MessageType}) ->
105+
lists:foreach(fun(TargetSessionId) ->
106+
Message = {TargetSessionId, self(), post, string:join([MessageType, "", Endpoint, SendMsg], ":")},
107+
send_message(Message)
108+
end, TargetSessionIds);
109+
110+
send_call({_, _, Endpoint}, SendMsg, {TargetSessionId, MessageType}) ->
111+
Message = {TargetSessionId, self(), post, string:join([MessageType, "", Endpoint, SendMsg], ":")},
112+
send_message(Message);
113+
114+
send_call({_, Type, Endpoint}, SendMsg, TargetSessionId) ->
115+
Message = {TargetSessionId, self(), post, string:join([Type, "", Endpoint, SendMsg], ":")},
116+
send_message(Message).
117+
118+
send_message(Message) ->
119+
session_server:cast(Message).

‎src/cowboy_static_handler.erl

+96
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,96 @@
1+
%% @author Tom Burdick <[email protected]>
2+
3+
%% @doc Static File Cowboy Handler.
4+
5+
-module(cowboy_static_handler).
6+
7+
-behaviour(cowboy_http_handler).
8+
9+
%% cowboy_http_handler api
10+
-export([init/3, handle/2, terminate/2]).
11+
12+
-record(state, {path=undefined, method=undefined, exists=undefined,
13+
filepath=undefined, delpaths=undefined}).
14+
15+
16+
%% ----------------------------------------------------------------------------
17+
%% cowboy_http_handler api
18+
%% ----------------------------------------------------------------------------
19+
20+
init({_Transport, http}, Req, Opts) ->
21+
case lists:keyfind(path, 1, Opts) of
22+
{path, Path} ->
23+
case lists:keyfind(delpaths, 1, Opts) of
24+
false ->
25+
{ok, Req, #state{path=Path}};
26+
{delpaths, DelPaths} ->
27+
{ok, Req, #state{path=Path, delpaths=DelPaths}}
28+
end;
29+
false ->
30+
{error, "No Path Given"}
31+
end.
32+
33+
handle(Req, State) ->
34+
{Method, Req2} = cowboy_http_req:method(Req),
35+
method_allowed(Req2, State#state{method=Method}).
36+
37+
terminate(_Req, _State) ->
38+
ok.
39+
40+
41+
%% ----------------------------------------------------------------------------
42+
%% internal api
43+
%% ----------------------------------------------------------------------------
44+
45+
%% @doc Join binary tokens in lists together using the unix path delimiter /
46+
-spec filename_join(list(binary())) -> binary().
47+
filename_join(Tokens) ->
48+
lists:foldl(
49+
fun
50+
(Token, <<>>) when is_binary(Token) ->
51+
<<Token/binary>>;
52+
(Token, <<>>) when is_list(Token) ->
53+
Rest = filename_join(Token),
54+
<<Rest/binary>>;
55+
(Token, Path) when is_list(Token) ->
56+
Rest = filename_join(Token),
57+
<<Path/binary, "/", Rest/binary>>;
58+
(Token, Path) when is_binary(Token) ->
59+
<<Path/binary, "/", Token/binary>>
60+
end, <<>>, Tokens).
61+
62+
method_allowed(Req, State=#state{method='GET'}) ->
63+
resource_exists(Req, State);
64+
method_allowed(Req, State=#state{method='HEAD'}) ->
65+
resource_exists(Req, State);
66+
method_allowed(Req, State) ->
67+
{ok, Req2} = cowboy_http_req:reply(405, [], <<>>, Req),
68+
{ok, Req2, State}.
69+
70+
resource_exists(Req, State) ->
71+
{PathTokens, Req2} = cowboy_http_req:path_info(Req),
72+
FilePath =
73+
case State#state.delpaths of
74+
undefined ->
75+
filename_join([State#state.path | PathTokens]);
76+
DelPaths ->
77+
NewPathToken = lists:subtract(PathTokens, DelPaths),
78+
filename_join([State#state.path | NewPathToken])
79+
end,
80+
case filelib:is_regular(FilePath) of
81+
true ->
82+
valid_request(Req2, State#state{exists=true, filepath=FilePath});
83+
false ->
84+
{ok, Req3} = cowboy_http_req:reply(404, [], <<>>, Req),
85+
{ok, Req3, State#state{exists=false, filepath=FilePath}}
86+
end.
87+
88+
valid_request(Req, State=#state{method='GET'}) ->
89+
{ok, Body} = file:read_file(State#state.filepath),
90+
{ok, Req2} = cowboy_http_req:reply(200, [], Body, Req),
91+
{ok, Req2, State};
92+
valid_request(Req, State=#state{method='HEAD'}) ->
93+
FileSize = filelib:file_size(State#state.filepath),
94+
{ok, Req2} = cowboy_http_req:reply(200, [{<<"Content-Length">>, FileSize}], <<>>, Req),
95+
{ok, Req2, State}.
96+

0 commit comments

Comments
 (0)