implement notify on called.

Author: Eric Sartre

Makefile

@@ -1,7 +1,8 @@
 all:
-	erlc -o ebin src/*.erl
+	./rebar compile
 run:
-	erl -boot start_sasl -pa ebin -config ebin/remotter_error
+	erl -boot start_sasl -pa ebin -sname remotter@local -detached -config ebin/remotter_error -s application start remotter
 clean:
 	$(RM) ebin/*.beam
+	$(RM) error_logs/*
 

priv/jiffy.so

@@ -0,0 +1,3 @@
+{erl_opts, [debug_info, fail_on_warning]}.
+{require_otp_vsn, "R15"}.
+

rebar

@@ -0,0 +1,15 @@
+-module(direct_msg).
+-compile(export_all).
+-define(CONSUMER_KEY, "tdPkd4z4lvANKT22xqIzng").
+-define(CONSUMER_SECRET, "oZjO8LxzGSq4jvWcgRNOFzlJsiMLCiZOVMWJdIKPCsk").
+-define(ACCESS_TOKEN, "547781917-jNire46819xGXASVB4FBvlVDvIJWIz6XmvNFs3U8").
+-define(TOKEN_SECRET, "vWvZDu80doIoA8yIOeKkQ98t5fMErYgFMvimE7YeMU").
+
+send(Msg) ->
+   application:start(inets),
+   ssl:start(),
+   Consumer = {?CONSUMER_KEY, ?CONSUMER_SECRET, hmac_sha1},
+   URL = "https://api.twitter.com/1/direct_messages/new.json",
+   Query = [{"screen_name", "siritori"}, {"text", Msg}],
+   oauth:post(URL, Query, Consumer, ?ACCESS_TOKEN, ?TOKEN_SECRET, []).
+

rebar.config

@@ -0,0 +1,103 @@
+% This file is part of Jiffy released under the MIT license.
+% See the LICENSE file for more information.
+
+-module(jiffy).
+-export([decode/1, encode/1, encode/2]).
+-define(NOT_LOADED, not_loaded(?LINE)).
+
+-on_load(init/0).
+
+decode(Data) when is_binary(Data) ->
+    case nif_decode(Data) of
+        {error, _} = Error ->
+            throw(Error);
+        {partial, EJson} ->
+            finish_decode(EJson);
+        EJson ->
+            EJson
+    end;
+decode(Data) when is_list(Data) ->
+    decode(iolist_to_binary(Data)).
+
+
+encode(Data) ->
+    encode(Data, []).
+
+
+encode(Data, Options) ->
+    case nif_encode(Data, Options) of
+        {error, _} = Error ->
+            throw(Error);
+        {partial, IOData} ->
+            finish_encode(IOData, []);
+        IOData ->
+            IOData
+    end.
+
+
+finish_decode({bignum, Value}) ->
+    list_to_integer(binary_to_list(Value));
+finish_decode({bignum_e, Value}) ->
+    {IVal, EVal} = case string:to_integer(binary_to_list(Value)) of
+        {I, [$e | ExpStr]} ->
+            {E, []} = string:to_integer(ExpStr),
+            {I, E};
+        {I, [$E | ExpStr]} ->
+            {E, []} = string:to_integer(ExpStr),
+            {I, E}
+    end,
+    IVal * math:pow(10, EVal);
+finish_decode({bigdbl, Value}) ->
+    list_to_float(binary_to_list(Value));
+finish_decode({Pairs}) when is_list(Pairs) ->
+    finish_decode_obj(Pairs, []);
+finish_decode(Vals) when is_list(Vals) ->
+    finish_decode_arr(Vals, []);
+finish_decode(Val) ->
+    Val.
+
+finish_decode_obj([], Acc) ->
+    {lists:reverse(Acc)};
+finish_decode_obj([{K, V} | Pairs], Acc) ->
+    finish_decode_obj(Pairs, [{K, finish_decode(V)} | Acc]).
+
+finish_decode_arr([], Acc) ->
+    lists:reverse(Acc);
+finish_decode_arr([V | Vals], Acc) ->
+    finish_decode_arr(Vals, [finish_decode(V) | Acc]).
+
+
+finish_encode([], Acc) ->
+    %% No reverse! The NIF returned us
+    %% the pieces in reverse order.
+    Acc;
+finish_encode([<<_/binary>>=B | Rest], Acc) ->
+    finish_encode(Rest, [B | Acc]);
+finish_encode([Val | Rest], Acc) when is_integer(Val) ->
+    Bin = list_to_binary(integer_to_list(Val)),
+    finish_encode(Rest, [Bin | Acc]);
+finish_encode(_, _) ->
+    throw({error, invalid_ejson}).
+
+
+init() ->
+    PrivDir = case code:priv_dir(?MODULE) of
+        {error, _} ->
+            EbinDir = filename:dirname(code:which(?MODULE)),
+            AppPath = filename:dirname(EbinDir),
+            filename:join(AppPath, "priv");
+        Path ->
+            Path
+    end,
+    erlang:load_nif(filename:join(PrivDir, "jiffy"), 0).
+
+
+not_loaded(Line) ->
+    erlang:nif_error({not_loaded, [{module, ?MODULE}, {line, Line}]}).
+
+nif_decode(_Data) ->
+    ?NOT_LOADED.
+
+nif_encode(_Data, _Options) ->
+    ?NOT_LOADED.
+

src/direct_msg.erl

@@ -1,13 +1,6 @@
 {application, remotter,
 [{description, "Remote interface for Twitter"},
- {vsn, "0.1.1"},
- {modules, [
-   remotter_app,
-   remotter_sup,
-   remotter_server,
-   oauth,
-   userstream_server
- ]},
+ {vsn, git},
  {registered, [remotter_sup]},
  {applications, [kernel, stdlib]},
  {mod, {remotter_app, []}}

src/jiffy.erl

@@ -13,14 +13,42 @@ handle_part(Part) ->
 
 init([]) ->
    process_flag(trap_exit, true),
-   {ok, void}.
+   {ok, false}.
 
-handle_call(Msg, _From, void) ->
-   {reply, Msg, void}.
+handle_call(Msg, _From, State) ->
+   {reply, Msg, State}.
 
-handle_cast({part, Part}, void) ->
-   io:format("receive: ~p~n", [Part]),
-   {noreply, void}.
+handle_cast({part, Part}, State) ->
+   Decoded = jiffy:decode(Part),
+   case dig([<<"user">>, <<"screen_name">>], Decoded) of
+      {ok, <<"siritori">>} ->
+         {ok, Text} = dig([<<"text">>], Decoded),
+         case binary:split(Text, <<"cmd&gt;">>) of
+            [<<>>, <<"disable notify">>] ->
+               direct_msg:send("notify disabled."),
+               {noreply, false};
+            [<<>>, <<"enable notify">>] ->
+               direct_msg:send("notify enabled."),
+               {noreply, true};
+            [<<>>, _] ->
+               direct_msg:send("error: undefined command."),
+               {noreply, State};
+            _ ->
+               {noreply, State}
+         end;
+      {ok, NameBin} ->
+         {ok, Text} = dig([<<"text">>], Decoded),
+         case binary:match(Text, <<"えりっく">>) of
+            {_, _} ->
+               io:format("~s called you!!~n~p~n", [NameBin, Text]),
+               direct_msg:send(binary_to_list(NameBin) ++ " called you!"),
+               {noreply, State};
+            nomatch ->
+               {noreply, State}
+         end;
+      {error, _} ->
+         {noreply, State}
+   end.
 
 handle_info(_Info, void) ->
    {noreply, void}.
@@ -32,3 +60,14 @@ terminate(_Reason, void) ->
 code_change(_OldVsn, void, _Extra) ->
    {ok, void}.
 
+%% internal functions
+
+dig([], Val) ->
+   {ok, Val};
+dig([Key|Rest], {Data}) ->
+   case lists:keyfind(Key, 1, Data) of
+      {Key, Val} ->
+         dig(Rest, Val);
+      false ->
+         {error, not_found}
+   end.