diff --git a/internal/lkgateway/web/templates/layout.html b/internal/lkgateway/web/templates/layout.html
index 1e2012e..a0b6dff 100644
--- a/internal/lkgateway/web/templates/layout.html
+++ b/internal/lkgateway/web/templates/layout.html
@@ -554,7 +554,7 @@ button.dq-link, .dq-link { background:none !important; border:0 !important; padd
Входящие
- {{end}}{{if can "view"}}
Ручной ввод M2M{{end}}{{if and devOn (can "settings")}}
Тест DEPO{{end}}{{if and devOn (can "operate")}}
Тестирование M2M{{end}}
+ {{end}}{{if can "view"}}
Ручной ввод M2M{{end}}{{if and devOn (can "settings")}}
Тест DEPO{{end}}{{if and devOn (can "operate")}}
Тестирование M2M{{end}}{{if and devOn (can "settings")}}
Эмуляторы{{end}}
{{if and .NPR (can "npr")}}
НПР / УДС{{end}}
{{if or (can "view") (can "quik")}}
Обмен ▾
diff --git a/internal/nsdadapter/mock/sender.go b/internal/nsdadapter/mock/sender.go
index 6c32328..e7ee742 100644
--- a/internal/nsdadapter/mock/sender.go
+++ b/internal/nsdadapter/mock/sender.go
@@ -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},
},
}
}
diff --git a/internal/nsdadapter/mock/sender_test.go b/internal/nsdadapter/mock/sender_test.go
index 55f46ab..9850013 100644
--- a/internal/nsdadapter/mock/sender_test.go
+++ b/internal/nsdadapter/mock/sender_test.go
@@ -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):
+ }
+}