BG-676: Add Customers

.gitignore

@@ -11,3 +11,6 @@ log
 # make stuff
 /.image.*
 Makefile.env
+
+.claude
+CLAUDE.md

.tool-versions

@@ -0,0 +1 @@
+erlang 27.1.2

apps/capi/src/capi_auth.erl

@@ -27,7 +27,7 @@
 -type consumer() :: client | merchant | provider.
 -type token_spec() :: #{
     party := binary(),
-    scope := {invoice | invoice_template, binary()},
+    scope := {invoice | invoice_template | customer, binary()},
     shop => binary(),
     lifetime => pos_integer() | unlimited,
     metadata => token_keeper_client:metadata()
@@ -168,7 +168,8 @@ resolve_auth_scope(TokenSpec) ->
     ).
 
 resolve_auth_method(#{scope := {invoice, _}}) -> ?CTX_V1_AUTHMETHOD_INVOICEACCESSTOKEN;
-resolve_auth_method(#{scope := {invoice_template, _}}) -> ?CTX_V1_AUTHMETHOD_INVOICETEMPLATEACCESSTOKEN.
+resolve_auth_method(#{scope := {invoice_template, _}}) -> ?CTX_V1_AUTHMETHOD_INVOICETEMPLATEACCESSTOKEN;
+resolve_auth_method(#{scope := {customer, _}}) -> ?CTX_V1_AUTHMETHOD_CUSTOMERACCESSTOKEN.
 
 resolve_auth_expiration(TokenSpec) ->
     case get_token_lifetime(TokenSpec) of
@@ -185,18 +186,27 @@ get_token_lifetime(#{lifetime := LifeTime} = TokenSpec) when LifeTime =/= undefi
 get_token_lifetime(#{scope := {invoice, _}}) ->
     ?DEFAULT_INVOICE_ACCESS_TOKEN_LIFETIME;
 get_token_lifetime(#{scope := {invoice_template, _}}) ->
+    unlimited;
+get_token_lifetime(#{scope := {customer, _}}) ->
     unlimited.
 
 verify_token_lifetime(#{scope := {invoice, _}}, LifeTime) when LifeTime =/= unlimited -> ok;
-verify_token_lifetime(#{scope := {invoice_template, _}}, _LifeTime) -> ok.
+verify_token_lifetime(#{scope := {invoice_template, _}}, _LifeTime) -> ok;
+verify_token_lifetime(#{scope := {customer, _}}, _LifeTime) -> ok.
 
 %%
 
 create_metadata(TokenSpec) ->
     PartyID = maps:get(party, TokenSpec),
     Metadata0 = maps:get(metadata, TokenSpec, #{}),
     Metadata1 = put_metadata(get_metadata_mapped_key(party_id), PartyID, Metadata0),
-    put_metadata(get_metadata_mapped_key(token_consumer), <<"client">>, Metadata1).
+    Metadata2 = put_metadata(get_metadata_mapped_key(token_consumer), <<"client">>, Metadata1),
+    maybe_put_customer_id(TokenSpec, Metadata2).
+
+maybe_put_customer_id(#{scope := {customer, CustomerID}}, Metadata) ->
+    put_metadata(get_metadata_mapped_key(customer_id), CustomerID, Metadata);
+maybe_put_customer_id(_TokenSpec, Metadata) ->
+    Metadata.
 
 extract_auth_context(#{swagger_context := #{auth_context := AuthContext}}) ->
     AuthContext.

apps/capi/src/capi_bouncer_context.erl

@@ -6,6 +6,7 @@
 -include_lib("damsel/include/dmsl_payproc_thrift.hrl").
 -include_lib("damsel/include/dmsl_domain_thrift.hrl").
 -include_lib("damsel/include/dmsl_webhooker_thrift.hrl").
+-include_lib("damsel/include/dmsl_customer_thrift.hrl").
 
 -type fragment() :: bouncer_client:context_fragment().
 -type acc() :: bouncer_context_helpers:context_fragment().
@@ -20,6 +21,7 @@
     {operation, prototype_operation()}
     | {payproc, prototype_payproc()}
     | {webhooks, prototype_webhooks()}
+    | {cubasty, prototype_cubasty()}
 ].
 
 -type prototype_operation() :: #{
@@ -30,7 +32,8 @@
     payment => entity_id(),
     refund => entity_id(),
     invoice_template => entity_id(),
-    webhook => entity_id()
+    webhook => entity_id(),
+    customer => entity_id()
 }.
 
 -type prototype_payproc() :: #{
@@ -42,6 +45,10 @@
     webhook => webhook_id() | webhook() | undefined
 }.
 
+-type prototype_cubasty() :: #{
+    customer => entity_id() | undefined
+}.
+
 -type invoice_id() :: dmsl_domain_thrift:'InvoiceID'().
 -type invoice() :: dmsl_domain_thrift:'Invoice'().
 
@@ -57,6 +64,7 @@
 -export_type([prototype_operation/0]).
 -export_type([prototype_payproc/0]).
 -export_type([prototype_webhooks/0]).
+-export_type([prototype_cubasty/0]).
 
 -export([new/0]).
 -export([build/3]).
@@ -89,7 +97,8 @@ build(operation, #{id := OperationID} = Params, Acc, _WoodyCtx) ->
                 payment = maybe_entity(payment, Params),
                 refund = maybe_entity(refund, Params),
                 invoice_template = maybe_entity(invoice_template, Params),
-                webhook = maybe_entity(webhook, Params)
+                webhook = maybe_entity(webhook, Params),
+                customer = maybe_entity(customer, Params)
             }
         }
     };
@@ -117,6 +126,16 @@ build(webhooks, #{} = Params, Acc, WoodyCtx) ->
                 fun(V) -> build_webhook_ctx(V, WoodyCtx) end
             )
         }
+    };
+build(cubasty, #{} = Params, Acc, WoodyCtx) ->
+    Acc#ctx_v1_ContextFragment{
+        cubasty = #ctx_v1_ContextCustomerManagement{
+            customer = maybe_with(
+                customer,
+                Params,
+                fun(V) -> build_customer_ctx(V, WoodyCtx) end
+            )
+        }
     }.
 
 %%
@@ -196,6 +215,23 @@ build_webhook_filter({Type, Filter}) ->
 build_webhook_filter_details(#webhooker_InvoiceEventFilter{shop_ref = #domain_ShopConfigRef{id = ShopID}}, Ctx) ->
     Ctx#ctx_v1_WebhookFilter{shop = 'maybe'(ShopID, fun build_entity/1)}.
 
+build_customer_ctx(ID, WoodyCtx) when is_binary(ID) ->
+    maybe_with_woody_result(
+        customer_management,
+        'Get',
+        {ID},
+        WoodyCtx,
+        fun build_customer_ctx/1
+    );
+build_customer_ctx(CustomerState, _WoodyCtx) ->
+    build_customer_ctx(CustomerState).
+
+build_customer_ctx(#customer_CustomerState{customer = Customer}) ->
+    #ctx_v1_Customer{
+        id = Customer#customer_Customer.id,
+        party = build_entity(Customer#customer_Customer.party_ref#domain_PartyConfigRef.id)
+    }.
+
 %%
 
 'maybe'(undefined, _Then) ->

apps/capi/src/capi_feature_schemas.erl

@@ -76,11 +76,13 @@
 -define(postal_code, 71).
 -define(date_of_birth, 72).
 -define(document_id, 73).
+-define(metadata, 74).
 
 -export([payment/0]).
 -export([invoice/0]).
 -export([invoice_template/0]).
 -export([refund/0]).
+-export([customer/0]).
 
 -spec payment() -> schema().
 payment() ->
@@ -166,6 +168,28 @@ refund() ->
         ?allocation => {<<"allocation">>, {set, allocation_transaction()}}
     }.
 
+-spec customer() -> schema().
+customer() ->
+    #{
+        ?contact_info => {<<"contactInfo">>, contact_info_schema()},
+        ?metadata => <<"metadata">>
+    }.
+
+contact_info_schema() ->
+    #{
+        ?email => <<"email">>,
+        ?phone_number => <<"phoneNumber">>,
+        ?first_name => <<"firstName">>,
+        ?last_name => <<"lastName">>,
+        ?country => <<"country">>,
+        ?state => <<"state">>,
+        ?city => <<"city">>,
+        ?address => <<"address">>,
+        ?postal_code => <<"postalCode">>,
+        ?date_of_birth => <<"dateOfBirth">>,
+        ?document_id => <<"documentId">>
+    }.
+
 -spec payment_tool_schema() -> schema().
 payment_tool_schema() ->
     {union, <<"type">>, #{

apps/capi/src/capi_handler.erl

@@ -104,6 +104,7 @@ get_handlers() ->
         capi_handler_antifraud,
         capi_handler_categories,
         capi_handler_countries,
+        capi_handler_customers,
         capi_handler_invoice_templates,
         capi_handler_invoices,
         capi_handler_parties,
@@ -309,6 +310,7 @@ set_context_meta(Context) ->
 -spec set_request_meta(operation_id(), request_data()) -> ok.
 set_request_meta(OperationID, Req) ->
     InterestParams = [
+        'customerID',
         'invoiceID',
         'invoiceTemplateID',
         'webhookID',