feat(monorepo): [limiter] Incorporates limiter into core services

.env

@@ -1,4 +1,3 @@
-SERVICE_NAME=hellgate
 OTP_VERSION=28.5.0
 REBAR_VERSION=3.26
 THRIFT_VERSION=0.14.2.3

README.md

@@ -1,3 +1,5 @@
+**TODO: Clean up readme!**
+
 # Hellgate
 
 Core logic service for payment states processing.
@@ -99,3 +101,6 @@ $ make wdeps-test
 ## Служебные лимиты
 
 Нужно уметь _ограничивать_ максимальное _ожидаемое_ количество тех или иных объектов, превышение которого может негативно влиять на качество обслуживания системы. Например, мы можем считать количество _выводов_ одним участником неограниченным, однако при этом неограниченное количество созданных _личностей_ мы совершенно не ожидаем. В этом случае возможно будет разумно ограничить их количество сверху труднодостижимой для подавляющего большинства планкой, например, в 1000 объектов. В идеале подобное должно быть точечно конфигурируемым.
+
+# limiter
+Service for limits calculating

apps/limiter/src/lim_body.erl

@@ -0,0 +1,51 @@
+-module(lim_body).
+
+-export([get/3]).
+
+-type amount() :: integer().
+-type cash() :: #{
+    amount := amount(),
+    currency := currency()
+}.
+
+-type currency() :: dmsl_domain_thrift:'CurrencySymbolicCode'().
+-type config() :: lim_config_machine:config().
+-type body_type() :: full | partial.
+
+-export_type([amount/0]).
+-export_type([currency/0]).
+-export_type([cash/0]).
+
+-import(lim_pipeline, [do/1, unwrap/1]).
+
+-spec get(body_type(), config(), lim_context:t()) ->
+    {ok, cash()} | {error, notfound}.
+get(BodyType, Config, LimitContext) ->
+    do(fun() ->
+        ContextType = lim_config_machine:context_type(Config),
+        Operation = unwrap(lim_context:get_operation(ContextType, LimitContext)),
+        Body = unwrap(get_body_for_operation(BodyType, ContextType, LimitContext)),
+        apply_op_behaviour(Operation, Body, Config)
+    end).
+
+-spec get_body_for_operation(body_type(), lim_context:context_type(), lim_context:t()) ->
+    {ok, cash()} | {error, notfound}.
+get_body_for_operation(full, ContextType, LimitContext) ->
+    lim_context:get_value(ContextType, cost, LimitContext);
+get_body_for_operation(partial, ContextType, LimitContext) ->
+    lim_context:get_value(ContextType, capture_cost, LimitContext).
+
+apply_op_behaviour(Operation, Body, #{op_behaviour := ComputationConfig}) ->
+    case maps:get(Operation, ComputationConfig, undefined) of
+        addition ->
+            Body;
+        subtraction ->
+            invert_body(Body);
+        undefined ->
+            Body
+    end;
+apply_op_behaviour(_Operation, Body, _Config) ->
+    Body.
+
+invert_body(#{amount := Amount} = Cash) ->
+    Cash#{amount := -Amount}.

apps/limiter/src/lim_client_woody.erl

@@ -0,0 +1,59 @@
+-module(lim_client_woody).
+
+-export([call/4]).
+-export([call/5]).
+-export([get_service_client_url/1]).
+
+-define(APP, limiter).
+-define(DEFAULT_DEADLINE, 5000).
+
+%%
+-type service_name() :: atom().
+
+-spec call(service_name(), woody:func(), woody:args(), woody_context:ctx()) -> woody:result().
+call(ServiceName, Function, Args, Context) ->
+    EventHandler = {scoper_woody_event_handler, #{}},
+    call(ServiceName, Function, Args, Context, EventHandler).
+
+-spec call(service_name(), woody:func(), woody:args(), woody_context:ctx(), woody:ev_handler()) -> woody:result().
+call(ServiceName, Function, Args, Context0, EventHandler) ->
+    Deadline = get_service_deadline(ServiceName),
+    Context1 = set_deadline(Deadline, Context0),
+    Url = get_service_client_url(ServiceName),
+    Service = get_service_modname(ServiceName),
+    Request = {Service, Function, Args},
+    woody_client:call(
+        Request,
+        #{url => Url, event_handler => EventHandler},
+        Context1
+    ).
+
+get_service_client_config(ServiceName) ->
+    ServiceClients = genlib_app:env(?APP, service_clients, #{}),
+    maps:get(ServiceName, ServiceClients, #{}).
+
+-spec get_service_client_url(atom()) -> lim_maybe:'maybe'(woody:url()).
+get_service_client_url(ServiceName) ->
+    maps:get(url, get_service_client_config(ServiceName), undefined).
+
+-spec get_service_modname(service_name()) -> woody:service().
+get_service_modname(xrates) ->
+    {xrates_rate_thrift, 'Rates'};
+get_service_modname(liminator) ->
+    {liminator_liminator_thrift, 'LiminatorService'};
+get_service_modname(accounter) ->
+    {dmsl_accounter_thrift, 'Accounter'}.
+
+-spec get_service_deadline(service_name()) -> undefined | woody_deadline:deadline().
+get_service_deadline(ServiceName) ->
+    ServiceClient = get_service_client_config(ServiceName),
+    Timeout = maps:get(deadline, ServiceClient, ?DEFAULT_DEADLINE),
+    woody_deadline:from_timeout(Timeout).
+
+set_deadline(Deadline, Context) ->
+    case woody_context:get_deadline(Context) of
+        undefined ->
+            woody_context:set_deadline(Deadline, Context);
+        _AlreadySet ->
+            Context
+    end.