Bridge-and-Join-s/internal/nsdadapter/mock

internal/nsdadapter/mock — заглушка NSDSender

Имитирует Интеграционный шлюз НРД для локальных стендов и сквозных тестов. Реализует интерфейс m2mcore.NSDSender:

• Send — синхронно возвращает синтетический M2MTransferResponse с StatusCode=INFO и записями 01 по каждой ЦБ.
• SendDecision — фиксирует и завершает (мы — отправители Decision).
• Параллельно — спавнит горутину, которая через Config.DecisionDelay (по умолчанию 3 секунды) эмитит M2MTransferDecision в канал Decisions().

Исходы

Через Config.DefaultOutcome или SetOutcome(guid, ...):

• OutcomeConfirm — Confirmation по всем ЦБ.
• OutcomeReject — Rejection с кодом Config.RejectionCode (по умолчанию 07).
• OutcomeTimeout — Decision вообще не приходит (эмуляция SLA-таймаута).

Параметры

cfg := mock.DefaultConfig()
cfg.DecisionDelay = 1 * time.Second
cfg.DefaultOutcome = mock.OutcomeConfirm
sender := mock.NewSender(cfg)

resp, _ := sender.Send(ctx, req)
// resp.StatusCode == "INFO"

decision := <-sender.Decisions()
// Через ~1с прилетает Decision с Confirmation

Подписка на эмитированные Decision

go func() {
    for d := range sender.Decisions() {
        _ = svc.ApplyDecision(ctx, d)
    }
}()

В lk-gateway это делает Server.consumeDecisions (запускается в Run).

Контекст эмиссии

Эмиссия Decision использует внутренний контекст mock'а (создаётся в NewSender через context.Background()), а не контекст HTTP-запроса вызывающего. Это критично — контекст HTTP-запроса закрывается сразу после возврата ответа, и без своего lifecycle мок бы прерывал эмиссию до истечения DecisionDelay. Stop() отменяет внутренний контекст.

Статистика

Stats() возвращает счётчики Sent, Confirmed, Rejected, TimedOut — для admin-страницы lk-gateway.