invite systems are really weird stuff

src/invites.erl

@@ -1,92 +0,0 @@
--module(invites).
--compile(export_all).
--include_lib("kvs/include/users.hrl").
--include_lib("kvs/include/invites.hrl").
--include_lib("kvs/include/log.hrl").
-
-%% use rpc call to web node to get gettext support
--define(TXT2(Key, Lang), gettext:key2str(Key, Lang)).
-
-generate_code(User) -> generate_code(User, undefined).
-generate_code(#user{username = User}, Mail) -> generate_code(User, Mail);
-generate_code(User, Mail) when is_list(User);
-                               User == undefined ->
-    Code = code(),
-    Rec = #invite_code{code = Code,
-                       create_date = erlang:now(),
-                       recipient = Mail,
-                       issuer = User},
-    %kvs:put(Rec),
-    nsx_msg:notify(["invite", "user", User, "add_invite_to_issuer"], {Rec}),
-    {ok, Code}.
-
-check_code(Code) ->
-    case kvs:get(invite_code, Code) of
-        {ok, Invite} ->
-            case Invite of
-                Invite when Invite#invite_code.created_user =/= undefined ->
-                    error;
-                _ ->
-                    {ok, Invite}
-            end;
-        {error, _} ->
-            error
-    end.
-
-use_code(Code, #user{username = UN}) ->
-    use_code(Code, UN);
-use_code(Code, User) when is_list(User) ->
-    case kvs:get(invite_code, Code) of
-        {ok, Invite} ->
-            Result = kvs:put(Invite#invite_code{created_user = User}),
-            %% add to tree
-            Parent = Invite#invite_code.issuer,
-            Parent /= undefined andalso
-                kvs:put_into_invitation_tree(Parent, User, Code),
-            ?INFO("Put code: parent ~p, user: ~p, Code: ~p", [Parent, User, Code]),
-            Result;
-        {error, _} ->
-            error
-    end.
-
-get_user_code(#user{username = UN}) -> get_user_code(UN);
-get_user_code(User) when is_list(User) -> kvs:invite_code_by_issuer(User).
-get_code_per_created_user(#user{username = UN}) -> get_code_per_created_user(UN);
-get_code_per_created_user(User) -> kvs:invite_code_by_user(User).
-get_all_code() -> kvs:all(invite_code).
-
-code() ->
-    <<A:(16*8), _/binary>> = crypto:rand_bytes(16),
-    lists:sublist(lists:flatten(io_lib:format("~25.36.0b", [A])), 14, 9).
-
-
-send_invite_email(User, Email, UserName, Text) ->
-    %% FIXME: hardcoded tr language
-    send_invite_email(User, Email, UserName, Text, "tr").
-
--spec send_invite_email(record(user), string(), string(), string(), string()) -> {ok, string()} | {error, atom()}.
-send_invite_email(User, Email, UserName, Text, Lang) ->
-    case validator_is_email:validate("", Email) of
-	true ->
-	    case length(UserName)>0 of
-		true ->
-		    Code = generate_code(User, Email),
-		    ?INFO("Code: ~p",[Code]),
-		    {ok, InviteCode} = Code,
-		    Url = site_utils:create_url_invite(InviteCode),
-		    ?INFO("Invite url: ~p, InviteCode: ~p",[Url,InviteCode]),
-		    FromUser = case User#user.username of
-				   S when is_list(S) -> S;
-				   undefined -> ?TXT2("'kakaranet robot'", Lang)
-			       end,
-		    {Subject, Content} = site_utils:invite_message(FromUser, Url, Text, UserName, Lang),
-                    nsx_msg:notify_email(Subject, Content, Email),
-		    {ok, InviteCode};
-		_ ->
-		    {error, wrong_username}
-	    end;
-	false ->
-	    {error, wrong_email}
-    end.
-
-

src/kvs.erl

@@ -306,17 +306,13 @@ list_to_term(String) ->
             Error
     end.
 
-list_buckets() ->
-    [list_to_term(B) || B <- store_riak:dir()].
-
 save_db(Path) ->
     Data = lists:append([all(B) || B <- list_buckets()]),
-    salode:save(Path, Data).
+    kvs:save(Path, Data).
 
 load_db(Path) ->
-    sore_riak:clean(),
     add_seq_ids(),
-    AllEntries = salode:load(Path),
+    AllEntries = kvs:load(Path),
     [{_,_,{_,Handler}}] = ets:lookup(config, "riak_client"),
     [case is_tuple(E) of
         false -> skip;
@@ -325,3 +321,12 @@ load_db(Path) ->
 
 make_paid_fake(UId) ->
     put({user_purchase, UId, "fake_purchase"}).
+
+save(Key, Value) ->
+    Dir = ling:trim_from_last(Key, "/"),
+    filelib:ensure_dir(Dir),
+    file:write_file(Key, term_to_binary(Value)).
+
+load(Key) ->
+    {ok, Bin} = file:read_file(Key),
+    binary_to_term(Bin).