kvs/src/kvs_purchase.erl

-module(kvs_purchase).
-copyright('Synrc Research Center s.r.o.').
-include_lib("kvs/include/products.hrl").
-include_lib("kvs/include/purchases.hrl").
-include_lib("kvs/include/config.hrl").
-include_lib("kvs/include/accounts.hrl").
-include_lib("kvs/include/feed_state.hrl").
-compile(export_all).

solvent(UId, ProductId) ->
    {ok, Credit} = kvs_accounts:balance(UId, currency),
    {ok, #product{price = Price}} = kvs:get(product, ProductId),
    Credit >= Price.

buy(UId, ProductId) ->
    {ok, #product{price = Price}} = kvs:get(product, ProductId),
    kvs_accounts:transaction(UId, currency, -Price, "Buy " ++ ProductId ++ " for "++ integer_to_list(Price)),
    kvs:put(#user_product{username=UId, timestamp=now(), product_id = ProductId}).

give(UId, ProductId) ->
    kvs:put(#user_product{username=UId, timestamp=now(), product_id = ProductId}).

products(UId) -> DBA=?DBA, DBA:products(UId).

handle_notice(["kvs_purchase", "user", UId, "buy"] = Route,
    Message, #state{owner = Owner, type =Type} = State) ->
    error_logger:info_msg(" queue_action(~p): buy_gift: Owner=~p, Route=~p, Message=~p", [self(), {Type, Owner}, Route, Message]),
    {GId} = Message,
    buy(UId, GId),
    {noreply, State};

handle_notice(["kvs_purchase", "user", UId, "give"] = Route,
    Message, #state{owner = Owner, type =Type} = State) ->
    error_logger:info_msg(" queue_action(~p): give_gift: Owner=~p, Route=~p, Message=~p", [self(), {Type, Owner}, Route, Message]),
    {GId} = Message,
    give(UId, GId),
    {noreply, State};

handle_notice(R,_,S) -> error_logger:info_msg("Unhandled PURCHASE notice ~p", [R]), {noreply, S}.