Skip to content

Commit d7f8786

Browse files
committed
Moves try/catch deeper into turnover-limits iteration function
1 parent 618b631 commit d7f8786

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

apps/hellgate/src/hg_limiter.erl

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -283,20 +283,20 @@ rollback_payment_limits(TurnoverLimits, Invoice, Payment, Route, Iter, Flags) ->
283283
{LegacyTurnoverLimits, BatchTurnoverLimits} = split_turnover_limits_by_available_limiter_api(TurnoverLimits),
284284
ok = legacy_rollback_payment_limits(Context, LegacyTurnoverLimits, Invoice, Payment, Route, Iter, Flags),
285285
OperationIdSegments = make_route_operation_segments(Invoice, Payment, Route, Iter),
286+
ok = batch_rollback_limits(Context, BatchTurnoverLimits, OperationIdSegments, Flags).
287+
288+
batch_rollback_limits(_Context, [], _OperationIdSegments, _Flags) ->
289+
ok;
290+
batch_rollback_limits(Context, TurnoverLimits, OperationIdSegments, Flags) ->
291+
{LimitRequest, _} = prepare_limit_request(TurnoverLimits, OperationIdSegments),
286292
IgnoreError = lists:member(ignore_not_found, Flags) orelse lists:member(ignore_business_error, Flags),
287293
try
288-
ok = batch_rollback_limits(Context, BatchTurnoverLimits, OperationIdSegments)
294+
ok = hg_limiter_client:rollback_batch(LimitRequest, Context)
289295
catch
290296
error:(?OPERATION_NOT_FOUND) when IgnoreError =:= true ->
291297
ok
292298
end.
293299

294-
batch_rollback_limits(_Context, [], _OperationIdSegments) ->
295-
ok;
296-
batch_rollback_limits(Context, TurnoverLimits, OperationIdSegments) ->
297-
{LimitRequest, _} = prepare_limit_request(TurnoverLimits, OperationIdSegments),
298-
hg_limiter_client:rollback_batch(LimitRequest, Context).
299-
300300
legacy_rollback_payment_limits(Context, TurnoverLimits, Invoice, Payment, Route, Iter, Flags) ->
301301
ChangeIDs = [
302302
construct_payment_change_id(Route, Iter, Invoice, Payment),
@@ -312,7 +312,7 @@ rollback_shop_limits(TurnoverLimits, Party, Shop, Invoice, Payment, Flags) ->
312312
{LegacyTurnoverLimits, BatchTurnoverLimits} = split_turnover_limits_by_available_limiter_api(TurnoverLimits),
313313
ok = legacy_rollback_shop_limits(Context, LegacyTurnoverLimits, Party, Shop, Invoice, Payment, Flags),
314314
OperationIdSegments = make_shop_operation_segments(Party, Shop, Invoice, Payment),
315-
ok = batch_rollback_limits(Context, BatchTurnoverLimits, OperationIdSegments).
315+
ok = batch_rollback_limits(Context, BatchTurnoverLimits, OperationIdSegments, Flags).
316316

317317
legacy_rollback_shop_limits(Context, TurnoverLimits, Party, Shop, Invoice, Payment, Flags) ->
318318
ChangeIDs = [construct_shop_change_id(Party, Shop, Invoice, Payment)],

0 commit comments

Comments
 (0)