kvs.erl 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324
  1. -module(kvs).
  2. -author('Maxim Sokhatsky <maxim@synrc.com>').
  3. -include_lib("kvs/include/users.hrl").
  4. -include_lib("kvs/include/translations.hrl").
  5. -include_lib("kvs/include/groups.hrl").
  6. -include_lib("kvs/include/feeds.hrl").
  7. -include_lib("kvs/include/acls.hrl").
  8. -include_lib("kvs/include/meetings.hrl").
  9. -include_lib("kvs/include/invites.hrl").
  10. -include_lib("kvs/include/config.hrl").
  11. -include_lib("kvs/include/accounts.hrl").
  12. -include_lib("kvs/include/log.hrl").
  13. -include_lib("kvs/include/membership.hrl").
  14. -include_lib("kvs/include/payments.hrl").
  15. -include_lib("kvs/include/products.hrl").
  16. -include_lib("stdlib/include/qlc.hrl").
  17. -include_lib("kvs/include/feed_state.hrl").
  18. -compile(export_all).
  19. -define(r, {sr, record_info(fields, acl)}).
  20. start() -> DBA = ?DBA, DBA:start().
  21. dir() -> DBA = ?DBA, DBA:dir().
  22. stop() -> DBA = ?DBA, DBA:stop().
  23. initialize() -> DBA = ?DBA, DBA:initialize().
  24. delete() -> DBA = ?DBA, DBA:delete().
  25. init_indexes() -> DBA = ?DBA, DBA:init_indexes().
  26. add(Record) when is_tuple(Record) ->
  27. Id = element(#iterator.id, Record),
  28. case kvs:get(element(1,Record), Id) of {ok, _} -> error_logger:info_msg("Exist: ~p", [Id]),{error, exist};
  29. {error, not_found} ->
  30. Type = element(1, Record),
  31. CName = element(#iterator.container, Record),
  32. Cid = case element(#iterator.feed_id, Record) of undefined -> ?FEED(Type); Fid -> Fid end,
  33. error_logger:info_msg("check container ~p ~p", [CName, Cid]),
  34. Container = case kvs:get(CName, Cid) of {ok,C} -> error_logger:info_msg("ok"),C;
  35. {error, not_found} when Cid /= undefined ->
  36. case CName of
  37. acl -> A = #acl{ id = Cid}, kvs:put(A), A;
  38. _ -> F = #feed{id = Cid}, kvs:put(F), F end;
  39. _ -> error end,
  40. if Container == error -> {error, no_container}; true ->
  41. error_logger:info_msg("container ~p", [Container]),
  42. Next = undefined,
  43. Prev = case element(#container.top, Container) of undefined -> error_logger:info_msg("TOP undefined"), undefined;
  44. Tid -> error_logger:info_msg("Current container top: ~p", [Tid]),
  45. case kvs:get(Type, Tid) of {error, not_found} -> error_logger:info_msg("No top element in db"),undefined;
  46. {ok, Top} -> error_logger:info_msg("Update top: old ~p", [Top]), NewTop = setelement(#iterator.next, Top, Id), kvs:put(NewTop), element(#iterator.id, NewTop) end end,
  47. error_logger:info_msg("Next ~p Prev ~p",[Next,Prev]),
  48. C1 = setelement(#container.top, Container, Id),
  49. C2 = setelement(#container.entries_count, C1, element(#container.entries_count, Container)+1),
  50. error_logger:info_msg("Update container ~p top ~p", [Container, Id]),
  51. error_logger:info_msg("New container: ~p", [C2]),
  52. kvs:put(C2),
  53. R = setelement(#iterator.feeds, Record, [{F1, kvs_feed:create()} || F1 <- element(#iterator.feeds, Record)]),
  54. R1 = setelement(#iterator.next, R, Next),
  55. R2 = setelement(#iterator.prev, R1, Prev),
  56. R3 = setelement(#iterator.feed_id, R2, element(#container.id, Container)),
  57. kvs:put(R3),
  58. error_logger:info_msg("PUT: ~p", [R3]),
  59. {ok, R3} end end.
  60. remove(RecordName, RecordId) ->
  61. error_logger:info_msg("Remove ~p ~p", [RecordName, RecordId]),
  62. case kvs:get(RecordName, RecordId) of {error, not_found} -> error_logger:info_msg("not found");
  63. {ok, E} ->
  64. error_logger:info_msg("going to remove ~p", [E]),
  65. Id = element(#iterator.id, E),
  66. CName = element(#iterator.container, E),
  67. Cid = element(#iterator.feed_id, E),
  68. error_logger:info_msg("Remove entry ~p from {~p, Feed: ~p}", [Id, CName, Cid]),
  69. {ok, Container} = kvs:get(CName, Cid),
  70. Top = element(#container.top, Container),
  71. Next = element(#iterator.next, E),
  72. Prev = element(#iterator.prev, E),
  73. case kvs:get(RecordName, Next) of {ok, NE} -> NewNext = setelement(#iterator.prev, NE, Prev), kvs:put(NewNext); _ -> ok end,
  74. case kvs:get(RecordName, Prev) of {ok, PE} -> NewPrev = setelement(#iterator.next, PE, Next), kvs:put(NewPrev); _ -> ok end,
  75. C1 = case Top of Id -> setelement(#container.top, Container, Prev); _ -> Container end,
  76. C2 = setelement(#container.entries_count, C1, element(#container.entries_count, Container)-1),
  77. kvs:put(C2),
  78. error_logger:info_msg("Remove record ~p id: ~p", [RecordName, Id]),
  79. kvs:delete(RecordName, Id) end.
  80. %purge_feed(FeedId) ->
  81. % {ok,Feed} = kvs:get(feed,FeedId),
  82. % Removal = entry_traversal(Feed#feed.top, -1),
  83. % [kvs:delete(entry,Id)||#entry{id=Id}<-Removal],
  84. % kvs:put(Feed#feed{top=undefined}).
  85. %purge_unverified_feeds() ->
  86. % [ [purge_feed(Fid)|| {_, Fid} <- Feeds ] || #user{feeds=Feeds, email=E} <- kvs:all(user), E==undefined].
  87. traversal( _,undefined,_) -> [];
  88. traversal(_,_,0) -> [];
  89. traversal(RecordType, Start, Count)->
  90. case kvs:get(RecordType, Start) of {error,_} -> [];
  91. {ok, R} -> Prev = element(#iterator.prev, R),
  92. Count1 = case Count of C when is_integer(C) -> C - 1; _-> Count end,
  93. [R | traversal(RecordType, Prev, Count1)] end.
  94. entries(Container, RecordType) -> entries(Container, RecordType, undefined).
  95. entries({ok, Container}, RecordType, Count) -> entries(Container, RecordType, Count);
  96. entries({_, FeedId}, undefined, Count) -> entries(kvs:get(feed, FeedId), entry, Count);
  97. entries({_, FeedId}, StartFrom, Count) ->
  98. case kvs:get(entry,{StartFrom, FeedId}) of {error,not_found}->[];
  99. {ok, E} -> traversal(entry, element(#iterator.prev, E), Count) end;
  100. entries(Container, RecordType, Count) ->
  101. traversal(RecordType, element(#container.top, Container), Count).
  102. init_db() ->
  103. case kvs:get(user,"joe") of
  104. {error,_} ->
  105. add_seq_ids(),
  106. kvs_account:create_account(system),
  107. %add_sample_users(),
  108. % add_sample_packages(),
  109. % add_sample_payments(),
  110. add_translations();
  111. {ok,_} -> ignore end.
  112. add_sample_packages() -> kvs_membership:add_sample_data().
  113. add_sample_payments() ->
  114. {ok, Pkg1} = kvs:get(membership,1),
  115. {ok, Pkg2} = kvs:get(membership,2),
  116. {ok, Pkg3} = kvs:get(membership,3),
  117. {ok, Pkg4} = kvs:get(membership,4),
  118. PList = [{"doxtop", Pkg1},{"maxim", Pkg2},{"maxim",Pkg4}, {"kate", Pkg3} ],
  119. [ok = add_payment(U, P) || {U, P} <- PList],
  120. ok.
  121. add_payment(UserId, Package) ->
  122. {ok, MPId} = kvs_payment:add_payment(#payment{user_id=UserId, membership=Package}),
  123. kvs_payment:set_payment_state(MPId, ?MP_STATE_DONE, undefined).
  124. add_seq_ids() ->
  125. Init = fun(Key) ->
  126. case kvs:get(id_seq, Key) of
  127. {error, _} -> ok = kvs:put(#id_seq{thing = Key, id = 0});
  128. {ok, _} -> ignore
  129. end
  130. end,
  131. Init("meeting"),
  132. Init("user_transaction"),
  133. Init("user_product"),
  134. Init("user_payment"),
  135. Init("user_status"),
  136. Init("transaction"),
  137. Init("membership"),
  138. Init("payment"),
  139. Init("acl"),
  140. Init("acl_entry"),
  141. Init("feed"),
  142. Init("entry"),
  143. Init("like_entry"),
  144. Init("likes"),
  145. Init("one_like"),
  146. Init("comment").
  147. add_translations() ->
  148. lists:foreach(fun({English, Lang, Word}) ->
  149. kvs:put(#translation{english = English, lang = "en", word = English}),
  150. kvs:put(#translation{english = English, lang = Lang, word = Word}) end, ?URL_DICTIONARY).
  151. add_sample_users() ->
  152. Groups = [],
  153. UserList = [],
  154. kvs:put(Groups),
  155. {ok, Quota} = kvs:get(config,"accounts/default_quota", 300),
  156. [ begin
  157. [ kvs_group:join(Me#user.username,G#group.id) || G <- Groups ],
  158. kvs_account:create_account(Me#user.username),
  159. kvs_account:transaction(Me#user.username, quota, Quota, #tx_default_assignment{}),
  160. kvs:put(Me#user{password = kvs:sha(Me#user.password)})
  161. end || Me <- UserList ],
  162. %kvs_acl:define_access({user, "maxim"}, {feature, admin}, allow),
  163. %kvs_acl:define_access({user_type, admin}, {feature, admin}, allow),
  164. [ kvs_user:subscribe(Me#user.username, Her#user.username) || Her <- UserList, Me <- UserList, Her /= Me ],
  165. [ kvs_user:init_mq(U) || U <- UserList ],
  166. ok.
  167. version() -> DBA=?DBA, DBA:version().
  168. add_configs() ->
  169. %% smtp
  170. kvs:put(#config{key="smtp/user", value="noreply@synrc.com"}),
  171. kvs:put(#config{key="smtp/password", value="maxim@synrc.com"}),
  172. kvs:put(#config{key="smtp/host", value="mail.synrc.com"}),
  173. kvs:put(#config{key="smtp/port", value=465}),
  174. kvs:put(#config{key="smtp/with_ssl", value=true}),
  175. kvs:put(#config{key="accounts/default_quota", value=2000}),
  176. kvs:put(#config{key="accounts/quota_limit/soft", value=-30}),
  177. kvs:put(#config{key="accounts/quota_limit/hard", value=-100}),
  178. kvs:put(#config{key="purchase/notifications/email", value=["maxim@synrc.com"]}),
  179. kvs:put(#config{key="delivery/notifications/email", value=["maxim@synrc.com"]}).
  180. put(Record) ->
  181. DBA=?DBA,
  182. DBA:put(Record).
  183. put_if_none_match(Record) ->
  184. DBA=?DBA,
  185. DBA:put_if_none_match(Record).
  186. update(Record, Meta) ->
  187. DBA=?DBA,
  188. DBA:update(Record, Meta).
  189. get(RecordName, Key) ->
  190. DBA=?DBA,
  191. DBA:get(RecordName, Key).
  192. get_for_update(RecordName, Key) ->
  193. DBA=?DBA,
  194. DBA:get_for_update(RecordName, Key).
  195. get(RecordName, Key, Default) ->
  196. DBA=?DBA,
  197. case DBA:get(RecordName, Key) of
  198. {ok,{RecordName,Key,Value}} ->
  199. ?INFO("db:get config value ~p,", [{RecordName, Key, Value}]),
  200. {ok,Value};
  201. {error, _B} ->
  202. ?INFO("db:get new config value ~p,", [{RecordName, Key, Default}]),
  203. DBA:put({RecordName,Key,Default}),
  204. {ok,Default} end.
  205. delete(Keys) -> DBA=?DBA, DBA:delete(Keys).
  206. delete(Tab, Key) -> ?INFO("db:delete ~p:~p",[Tab, Key]), DBA=?DBA,DBA:delete(Tab, Key).
  207. delete_by_index(Tab, IndexId, IndexVal) -> DBA=?DBA,DBA:delete_by_index(Tab, IndexId, IndexVal).
  208. multi_select(RecordName, Keys) -> DBA=?DBA,DBA:multi_select(RecordName, Keys).
  209. select(From, PredicateFunction) -> ?INFO("db:select ~p, ~p",[From,PredicateFunction]), DBA=?DBA, DBA:select(From, PredicateFunction).
  210. count(RecordName) -> DBA=?DBA,DBA:count(RecordName).
  211. all(RecordName) -> DBA=?DBA,DBA:all(RecordName).
  212. all_by_index(RecordName, Index, IndexValue) -> DBA=?DBA,DBA:all_by_index(RecordName, Index, IndexValue).
  213. next_id(RecordName) -> DBA=?DBA,DBA:next_id(RecordName).
  214. next_id(RecordName, Incr) -> DBA=?DBA,DBA:next_id(RecordName, Incr).
  215. next_id(RecordName, Default, Incr) -> DBA=?DBA,DBA:next_id(RecordName, Default, Incr).
  216. make_admin(User) ->
  217. {ok,U} = kvs:get(user, User),
  218. kvs:put(U#user{type = admin}),
  219. kvs_acl:define_access({user, U#user.username}, {feature, admin}, allow),
  220. kvs_acl:define_access({user_type, admin}, {feature, admin}, allow),
  221. ok.
  222. make_rich(User) ->
  223. Q = kvs:get_config("accounts/default_quota", 300),
  224. kvs_account:transaction(User, quota, Q * 100, #tx_default_assignment{}),
  225. kvs_account:transaction(User, internal, Q, #tx_default_assignment{}),
  226. kvs_account:transaction(User, currency, Q * 2, #tx_default_assignment{}).
  227. list_to_term(String) ->
  228. {ok, T, _} = erl_scan:string(String++"."),
  229. case erl_parse:parse_term(T) of
  230. {ok, Term} ->
  231. Term;
  232. {error, Error} ->
  233. Error
  234. end.
  235. save_db(Path) ->
  236. Data = lists:append([all(B) || B <- [list_to_term(B) || B <- store_riak:dir()] ]),
  237. kvs:save(Path, Data).
  238. load_db(Path) ->
  239. add_seq_ids(),
  240. AllEntries = kvs:load(Path),
  241. [{_,_,{_,Handler}}] = ets:lookup(config, "riak_client"),
  242. [case is_tuple(E) of
  243. false -> skip;
  244. true -> put(E)
  245. end || E <- AllEntries].
  246. make_paid_fake(UId) ->
  247. put(#payment{user_id=UId,info= "fake_purchase"}).
  248. save(Dir, Value) ->
  249. filelib:ensure_dir(Dir),
  250. file:write_file(Dir, term_to_binary(Value)).
  251. load(Key) ->
  252. {ok, Bin} = file:read_file(Key),
  253. binary_to_term(Bin).
  254. coalesce(undefined, B) -> B;
  255. coalesce(A, _) -> A.
  256. uuid() ->
  257. R1 = random:uniform(round(math:pow(2, 48))) - 1,
  258. R2 = random:uniform(round(math:pow(2, 12))) - 1,
  259. R3 = random:uniform(round(math:pow(2, 32))) - 1,
  260. R4 = random:uniform(round(math:pow(2, 30))) - 1,
  261. R5 = erlang:phash({node(), now()}, round(math:pow(2, 32))),
  262. UUIDBin = <<R1:48, 4:4, R2:12, 2:2, R3:32, R4: 30>>,
  263. <<TL:32, TM:16, THV:16, CSR:8, CSL:8, N:48>> = UUIDBin,
  264. lists:flatten(io_lib:format("~8.16.0b-~4.16.0b-~4.16.0b-~2.16.0b~2.16.0b-~12.16.0b-~8.16.0b",
  265. [TL, TM, THV, CSR, CSL, N, R5])).
  266. uuname() ->
  267. lists:flatten(io_lib:format("~8.16.0b",[erlang:phash2({node(), now()}, round(math:pow(2, 32)))])).
  268. sha(Raw) ->
  269. lists:flatten([io_lib:format("~2.16.0b", [N]) || <<N>> <= crypto:sha(Raw)]).
  270. sha_upper(Raw) ->
  271. SHA = sha(Raw),
  272. string:to_upper(SHA).