Merges fistful apps into hellgate umbrella

.env

@@ -1,7 +1,3 @@
-# NOTE
-# You SHOULD specify point releases here so that build time and run time Erlang/OTPs
-# are the same. See: https://github.com/erlware/relx/pull/902
-SERVICE_NAME=hellgate
 OTP_VERSION=27.1.2
 REBAR_VERSION=3.24
 THRIFT_VERSION=0.14.2.3

.github/workflows/basic-linters.yml

@@ -3,7 +3,12 @@ name: Vality basic linters
 on:
   pull_request:
     branches:
-      - "*"
+      - master
+      - main
+  push:
+    branches:
+      - master
+      - main
 
 jobs:
   lint:

.github/workflows/erlang-checks.yaml → .github/workflows/erlang-checks.yml

@@ -30,13 +30,13 @@ jobs:
   run:
     name: Run checks
     needs: setup
-    uses: valitydev/erlang-workflows/.github/workflows/erlang-parallel-build.yml@v1.0.18
+    uses: valitydev/erlang-workflows/.github/workflows/erlang-parallel-build.yml@v1
     with:
       otp-version: ${{ needs.setup.outputs.otp-version }}
       rebar-version: ${{ needs.setup.outputs.rebar-version }}
       use-thrift: true
       thrift-version: ${{ needs.setup.outputs.thrift-version }}
       run-ct-with-compose: true
       use-coveralls: true
-      cache-version: v9
+      cache-version: v103
       upload-coverage: false

.gitignore

@@ -4,12 +4,14 @@ log
 /_checkouts/
 *~
 erl_crash.dump
+rebar3.crashdump
 .tags*
 *.sublime-workspace
+.edts
 .DS_Store
 /.idea/
 *.beam
-tags
+/test/log/
 # make stuff
 /.image.*
 Makefile.env

Dockerfile

@@ -1,7 +1,7 @@
 ARG OTP_VERSION
 
 # Build the release
 FROM docker.io/library/erlang:${OTP_VERSION} AS builder
 SHELL ["/bin/bash", "-o", "pipefail", "-c"]
 
 # Install thrift compiler
@@ -17,36 +17,31 @@
 # Build the release
 WORKDIR /build
 RUN rebar3 compile && \
-    rebar3 as prod release
+    rebar3 as prod release --all
 
 # Make a runner image
 FROM docker.io/library/erlang:${OTP_VERSION}-slim
 
-ARG SERVICE_NAME
+ARG USER_NAME=apprunner
 ARG USER_UID=1001
 ARG USER_GID=$USER_UID
 
 # Set env
+ENV RELX_REPLACE_OS_VARS=true
+ENV ERL_DIST_PORT=31337
 ENV CHARSET=UTF-8
 ENV LANG=C.UTF-8
 
-# Set runtime
-WORKDIR /opt/${SERVICE_NAME}
-
-COPY --from=builder /build/_build/prod/rel/${SERVICE_NAME} /opt/${SERVICE_NAME}
-
-RUN echo "#!/bin/sh" >> /entrypoint.sh && \
-    echo "exec /opt/${SERVICE_NAME}/bin/${SERVICE_NAME} foreground" >> /entrypoint.sh && \
-    chmod +x /entrypoint.sh
+COPY --from=builder /build/_build/prod/rel/ /opt/
 
 # Setup user
-RUN groupadd --gid ${USER_GID} ${SERVICE_NAME} && \
-    mkdir /var/log/${SERVICE_NAME} && \
-    chown ${USER_UID}:${USER_GID} /var/log/${SERVICE_NAME} && \
-    useradd --uid ${USER_UID} --gid ${USER_GID} -M ${SERVICE_NAME}
-USER ${SERVICE_NAME}
+RUN groupadd --gid ${USER_GID} ${USER_NAME} && \
+    useradd --uid ${USER_UID} --gid ${USER_GID} -M ${USER_NAME} && \
+    chown -R ${USER_UID}:${USER_GID} /opt
+
+USER ${USER_NAME}
 
 ENTRYPOINT []
-CMD ["/entrypoint.sh"]
+CMD []
 
 EXPOSE 8022

README.md

@@ -47,3 +47,55 @@ $ make wdeps-test
 @TODO Please write a couple of words about what your project does and how it does it.
 
 [1]: http://erlang.org/doc/man/shell.html
+
+# Fistful
+
+> Wallet Processing Service
+
+## Development plan
+
+### Бизнес-функционал
+
+* [x] Минимальный тестсьют для кошельков
+* [x] Реализовать честный identity challenge
+* [x] Запилить payment provider interface
+* [ ] Запилить контактные данные личности
+* [x] Запилить нормально трансферы
+* [ ] Заворачивать изменения в единственный ивент в рамках операции
+* [.] Компактизировать состояние сессий
+* [ ] Запилить контроль лимитов по кошелькам
+* [ ] Запилить авторизацию по активной идентификации
+* [ ] Запилить отмену identity challenge
+* [ ] Запускать выводы через оплату инвойса провайдеру выводов
+* [ ] Обслуживать выводы по факту оплаты инвойса
+
+### Корректность
+
+* [.] Схема хранения моделей
+* [ ] [Дегидратация](#дегидратация)
+* [ ] [Поддержка checkout](#поддержка-checkout)
+* [ ] [Коммуналка](#коммуналка)
+
+### Удобство поддержки
+
+* [ ] Добавить [служебные лимиты](#служебные-лимиты) в рамках одного party
+* [ ] Добавить ручную прополку для всех асинхронных процессов
+* [ ] Вынести _ff_withdraw_ в отдельный сервис
+* [ ] Разделить _development_, _release_ и _test_ зависимости
+* [ ] Вынести части _ff_core_ в _genlib_
+
+## Поддержка checkout
+
+Каждая машина, на которую мы можем сослаться в рамках асинхронной операции, должно в идеале давать возможность _зафиксировать версию_ своего состояния посредством некой _ревизии_. Получение состояния по _ревизии_ осуществляется с помощью вызова операции _checkout_. В тривиальном случае _ревизия_ может быть выражена _меткой времени_, в идеале – _номером ревизии_.
+
+## Коммуналка
+
+Сервис должен давать возможность работать _нескольким_ клиентам, которые возможно не знают ничего друг о друге кроме того, что у них разные _tenant id_. В идеале _tenant_ должен иметь возможность давать знать о себе _динамически_, в рантайме, однако это довольно трудоёмкая задача. Если приводить аналогию с _Riak KV_, клиенты к нему могут: создать новый _bucket type_ с необходимыми характеристиками, создать новый _bucket_ с требуемыми параметрами N/R/W и так далее.
+
+## Дегидратация
+
+В итоге как будто бы не самая здравая идея. Есть ощущение, что проще и дешевле хранить и оперировать идентификаторами, и разыменовывать их каждый раз по необходимости.
+
+## Служебные лимиты
+
+Нужно уметь _ограничивать_ максимальное _ожидаемое_ количество тех или иных объектов, превышение которого может негативно влиять на качество обслуживания системы. Например, мы можем считать количество _выводов_ одним участником неограниченным, однако при этом неограниченное количество созданных _личностей_ мы совершенно не ожидаем. В этом случае возможно будет разумно ограничить их количество сверху труднодостижимой для подавляющего большинства планкой, например, в 1000 объектов. В идеале подобное должно быть точечно конфигурируемым.

apps/ff_core/src/ff_core.app.src

@@ -0,0 +1,15 @@
+{application, ff_core, [
+    {description, "Core types and facilities"},
+    {vsn, "1"},
+    {registered, []},
+    {applications, [
+        kernel,
+        stdlib,
+        genlib
+    ]},
+    {env, []},
+    {modules, []},
+    {maintainers, []},
+    {licenses, ["Apache 2.0"]},
+    {links, ["https://github.com/valitydev/fistful-server"]}
+]}.

apps/ff_core/src/ff_failure.erl

@@ -0,0 +1,41 @@
+%%%
+%%% Errors
+
+-module(ff_failure).
+
+-type code() :: binary().
+-type reason() :: binary().
+
+-type failure() :: #{
+    code := code(),
+    reason => reason(),
+    sub => sub_failure()
+}.
+
+-type sub_failure() :: #{
+    code := code(),
+    sub => sub_failure()
+}.
+
+-export_type([code/0]).
+-export_type([reason/0]).
+-export_type([failure/0]).
+-export_type([sub_failure/0]).
+
+-export([code/1]).
+-export([reason/1]).
+-export([sub_failure/1]).
+
+%% API
+
+-spec code(failure() | sub_failure()) -> code().
+code(#{code := Code}) ->
+    Code.
+
+-spec reason(failure()) -> reason() | undefined.
+reason(Failure) ->
+    maps:get(reason, Failure, undefined).
+
+-spec sub_failure(failure() | sub_failure()) -> sub_failure() | undefined.
+sub_failure(Failure) ->
+    maps:get(sub, Failure, undefined).

apps/ff_core/src/ff_indef.erl

@@ -0,0 +1,151 @@
+%%%
+%%% Indefinite value.
+
+-module(ff_indef).
+
+-export([new/1]).
+-export([new/3]).
+-export([current/1]).
+-export([expmin/1]).
+-export([expmax/1]).
+-export([account/2]).
+-export([confirm/2]).
+-export([reject/2]).
+
+-export([to_range/1]).
+
+% totally ordered
+-type ord(T) :: T.
+
+-type indef(T) :: #{
+    expected_min := ord(T),
+    current := ord(T),
+    expected_max := ord(T)
+}.
+
+-export_type([indef/1]).
+
+%%
+
+-spec new(T) -> indef(T).
+
+-spec new(T, T, T) -> indef(T).
+
+-spec current(indef(T)) -> T.
+
+-spec expmin(indef(T)) -> T.
+
+-spec expmax(indef(T)) -> T.
+-spec account(T, indef(T)) -> indef(T).
+
+-spec confirm(T, indef(T)) -> indef(T).
+
+-spec reject(T, indef(T)) -> indef(T).
+
+new(Seed) ->
+    #{
+        expected_min => Seed,
+        current => Seed,
+        expected_max => Seed
+    }.
+
+new(ExpMin, Current, ExpMax) ->
+    #{
+        expected_min => ExpMin,
+        current => Current,
+        expected_max => ExpMax
+    }.
+
+current(#{current := V}) ->
+    V.
+
+expmin(#{expected_min := V}) ->
+    V.
+
+expmax(#{expected_max := V}) ->
+    V.
+
+account(Delta, #{expected_min := ExpMin, expected_max := ExpMax} = Indef) ->
+    Indef#{
+        expected_min := erlang:min(ExpMin + Delta, ExpMin),
+        expected_max := erlang:max(ExpMax + Delta, ExpMax)
+    }.
+
+confirm(Delta, #{current := Current, expected_min := ExpMin, expected_max := ExpMax} = Indef) ->
+    Indef#{
+        current := Current + Delta,
+        expected_min := erlang:max(ExpMin + Delta, ExpMin),
+        expected_max := erlang:min(ExpMax + Delta, ExpMax)
+    }.
+
+reject(Delta, #{expected_min := ExpMin, expected_max := ExpMax} = Indef) ->
+    Indef#{
+        expected_min := erlang:max(ExpMin - Delta, ExpMin),
+        expected_max := erlang:min(ExpMax - Delta, ExpMax)
+    }.
+
+-spec to_range(indef(T)) -> ff_range:range(T).
+to_range(#{expected_min := ExpMin, expected_max := ExpMax}) ->
+    {{inclusive, ExpMin}, {inclusive, ExpMax}}.
+
+%% Tests
+
+-ifdef(TEST).
+
+-include_lib("eunit/include/eunit.hrl").
+
+-spec test() -> _.
+
+-spec convergency_test() -> _.
+
+convergency_test() ->
+    Opset = gen_opset(3 / 5, 2 / 3, 20),
+    #{
+        current := C,
+        expected_min := ExpMin,
+        expected_max := ExpMax
+    } = lists:foldl(
+        fun({Op, Delta}, Indef) -> Op(Delta, Indef) end,
+        new(0),
+        Opset
+    ),
+    ?assertEqual(C, ExpMin),
+    ?assertEqual(C, ExpMax).
+
+gen_opset(Pe, Pc, N) ->
+    lists:reverse(gen_opset({Pe, Pc, N, []}, [])).
+
+gen_opset(St, Acc) ->
+    case gen_op(St) of
+        {Op, St1} ->
+            gen_opset(St1, [Op | Acc]);
+        done ->
+            Acc
+    end.
+
+gen_op({_, _, 0, []}) ->
+    done;
+gen_op({Pe, Pc, N, Ds}) ->
+    case
+        ff_random:from_choices([
+            {Pe * sign(N), account},
+            {(1 - Pe) * sign(length(Ds)), commit}
+        ])
+    of
+        account ->
+            Delta = ff_random:from_range(-1000, 1000),
+            {{fun account/2, Delta}, {Pe, Pc, N - 1, [Delta | Ds]}};
+        commit ->
+            Delta = ff_random:from_list(Ds),
+            Op = ff_random:from_choices([{Pc, fun confirm/2}, {1 - Pc, fun reject/2}]),
+            {{Op, Delta}, {Pe, Pc, N, Ds -- [Delta]}}
+    end.
+
+sign(I) when I > 0 ->
+    1;
+sign(0) ->
+    0;
+sign(I) when I < 0 ->
+    -1.
+
+-endif.

apps/ff_core/src/ff_map.erl

@@ -0,0 +1,24 @@
+%%%
+%%% Well, a map
+%%%
+
+-module(ff_map).
+
+-type result(T) ::
+    {ok, T}
+    | {error, notfound}.
+
+-export_type([result/1]).
+
+-export([find/2]).
+
+%%
+
+-spec find(Key, #{Key => Value}) -> result(Value).
+find(Key, Map) ->
+    case Map of
+        #{Key := Value} ->
+            {ok, Value};
+        #{} ->
+            {error, notfound}
+    end.