feat(admin): dev-страница «Эмуляторы» — переключатели и настройки эмуляции НРД и МНП QUIK
В режиме разработки новая страница /admin/emulators с двумя клавишами: - «Эмулятор НРД» (флаг LK.EmulateNSD): заявки ЛК и ручного ввода идут через внутренний имитатор, в НРД ничего не отправляется. Настройки: задержка решения (0–300 с), исход (подтвердить/отклонить/не отвечать), код отказа M2M01–M2M09/18. Сендер перенастраивается в рантайме через потокобезопасный mock.Sender.Reconfigure — без перезапуска. - «Эмулятор МНП QUIK» (флаг QuikMNP.Emulate): шаги цикла без записи в боевую БД МНП. Настройки: задержка шага (0–60 с), точечные отказы по шагам (регистрация/подпись/отказ/зачисление) — эмулированный отказ ведёт себя как боевой: шаг OK=false, состояние не продвигается, повтор на следующем проходе. Настройки хранятся в setup.json (nsd_emu/mnp_emu), обратная совместимость — дефолты. Баннер «Режим эмуляции» показывается и при ручном включении эмуляторов (раньше зависел только от отсутствия ИШ). Пункт меню «Эмуляторы» и две плитки на дашборде — только в dev. Пути занесены в devOnlyPath. Попутно: исправлен race в TestLicenseActivateAndRenew (cleanup восстанавливал DefaultLicensePublicKey без moduleEnforceMu — падал под -race и на чистом HEAD).
This commit is contained in:
@@ -89,6 +89,21 @@ func (s *Sender) SetOutcome(guid m2m.UUID, out DecisionOutcome) {
|
||||
s.outcomes.Store(guid, out)
|
||||
}
|
||||
|
||||
// Reconfigure меняет настройки mock'а в рантайме (задержка, исход по умолчанию,
|
||||
// код отказа) — без пересоздания сендера: канал Decisions() привязан к экземпляру.
|
||||
func (s *Sender) Reconfigure(cfg Config) {
|
||||
s.mu.Lock()
|
||||
s.cfg = cfg
|
||||
s.mu.Unlock()
|
||||
}
|
||||
|
||||
// config — текущие настройки (потокобезопасный снимок для Send).
|
||||
func (s *Sender) config() Config {
|
||||
s.mu.Lock()
|
||||
defer s.mu.Unlock()
|
||||
return s.cfg
|
||||
}
|
||||
|
||||
// Decisions — канал эмитированных от имени принимающей стороны Decision'ов.
|
||||
// Подписаться, считать в горутине, передавать в m2mcore.Deal.ReceiveDecision.
|
||||
func (s *Sender) Decisions() <-chan *m2m.M2MTransferDecision { return s.decisions }
|
||||
@@ -130,11 +145,12 @@ func (s *Sender) Send(ctx context.Context, req *m2m.M2MTransferRequest) (*m2m.M2
|
||||
|
||||
// Эмитим Decision в отдельной горутине. Используем lifeCtx, чтобы
|
||||
// HTTP-таймауты вызывающего не прерывали эмиссию.
|
||||
outcome := s.cfg.DefaultOutcome
|
||||
cfg := s.config()
|
||||
outcome := cfg.DefaultOutcome
|
||||
if v, ok := s.outcomes.Load(req.Header.GUID); ok {
|
||||
outcome = v.(DecisionOutcome)
|
||||
}
|
||||
go s.emitDecision(s.lifeCtx, req, outcome)
|
||||
go s.emitDecision(s.lifeCtx, req, cfg, outcome)
|
||||
_ = ctx
|
||||
|
||||
return resp, nil
|
||||
@@ -155,11 +171,11 @@ func (s *Sender) SendDecision(_ context.Context, decision *m2m.M2MTransferDecisi
|
||||
return nil
|
||||
}
|
||||
|
||||
func (s *Sender) emitDecision(ctx context.Context, req *m2m.M2MTransferRequest, outcome DecisionOutcome) {
|
||||
func (s *Sender) emitDecision(ctx context.Context, req *m2m.M2MTransferRequest, cfg Config, outcome DecisionOutcome) {
|
||||
select {
|
||||
case <-ctx.Done():
|
||||
return
|
||||
case <-time.After(s.cfg.DecisionDelay):
|
||||
case <-time.After(cfg.DecisionDelay):
|
||||
}
|
||||
|
||||
if outcome == OutcomeTimeout {
|
||||
@@ -222,7 +238,7 @@ func (s *Sender) emitDecision(ctx context.Context, req *m2m.M2MTransferRequest,
|
||||
} else {
|
||||
ds.TransferDecision = m2m.DecisionTransfer{
|
||||
Rejection: &m2m.Rejection{
|
||||
Codes: []string{s.cfg.RejectionCode},
|
||||
Codes: []string{cfg.RejectionCode},
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
@@ -138,3 +138,52 @@ func TestMockSetOutcomeOverride(t *testing.T) {
|
||||
t.Fatal("Decision не пришёл")
|
||||
}
|
||||
}
|
||||
|
||||
func TestMockReconfigure(t *testing.T) {
|
||||
cfg := mock.DefaultConfig()
|
||||
cfg.DecisionDelay = 20 * time.Millisecond
|
||||
s := mock.NewSender(cfg)
|
||||
if _, err := s.Send(context.Background(), validRequest()); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
select {
|
||||
case d := <-s.Decisions():
|
||||
if d.Data.Securities[0].TransferDecision.Confirmation == nil {
|
||||
t.Error("до Reconfigure ожидалось Confirmation")
|
||||
}
|
||||
case <-time.After(time.Second):
|
||||
t.Fatal("Decision не пришёл")
|
||||
}
|
||||
|
||||
// Меняем исход и код отказа на лету — канал решений продолжает работать.
|
||||
cfg.DefaultOutcome = mock.OutcomeReject
|
||||
cfg.RejectionCode = "18"
|
||||
s.Reconfigure(cfg)
|
||||
if _, err := s.Send(context.Background(), validRequest()); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
select {
|
||||
case d := <-s.Decisions():
|
||||
rej := d.Data.Securities[0].TransferDecision.Rejection
|
||||
if rej == nil {
|
||||
t.Fatal("после Reconfigure ожидалось Rejection")
|
||||
}
|
||||
if len(rej.Codes) != 1 || rej.Codes[0] != "18" {
|
||||
t.Errorf("код отказа %v, ожидался 18", rej.Codes)
|
||||
}
|
||||
case <-time.After(time.Second):
|
||||
t.Fatal("Decision не пришёл — канал не должен ломаться после Reconfigure")
|
||||
}
|
||||
|
||||
// И таймаут переключается на лету.
|
||||
cfg.DefaultOutcome = mock.OutcomeTimeout
|
||||
s.Reconfigure(cfg)
|
||||
if _, err := s.Send(context.Background(), validRequest()); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
select {
|
||||
case <-s.Decisions():
|
||||
t.Error("при OutcomeTimeout Decision не должен прилетать")
|
||||
case <-time.After(200 * time.Millisecond):
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user