tests

Author: tripolskypetr

TODO.md

@@ -624,7 +624,47 @@ storage, state, file-history) и умирает БЕЗ dispose (process.exit); r
 
 ### Новые тесты (6), сьют вырос до 271/271 — test/spec/finalguard.test.mjs
 
-## Найденные и исправленные баги (27 итого)
+## 28-й заход: глубокая перепроверка навигации (+7 тестов, +2 бага)
+
+### Баг №28: changeToPrevAgent вёл на самого себя (off-by-one стека) + ложное покрытие
+Файлы: `src/client/ClientSwarm.ts`, `src/functions/navigate/changeToPrevAgent.ts`,
+`test/spec/navigation.test.mjs`
+- setAgentName пушит НОВОГО агента → вершина стека всегда текущий агент;
+  navigationPop возвращал текущего: после A→B→C «prev» пытался перейти на C
+  (сам в себя) и падал recursion-guard'ом; реальный возврат получался только
+  со второго вызова, с исключением на первом.
+- Оригинальный тест «Will navigate back to prev agent» был ЛОЖНО-зелёным: его
+  мок навигирует только с triage-агента, второй запрос (sales→refund) ничего
+  не делал, prev «переходил» в самого себя и ассерт case-ом совпадал.
+- Исправление: navigationPop отбрасывает вершину, если она равна активному
+  агенту, и возвращает следующий элемент (или default); changeToPrevAgent
+  больше не проверяет recursion-route (возврат назад легитимен и ограничен
+  глубиной стека), но no-op'ится при возврате в текущего агента. Мок
+  оригинального теста дополнен веткой sales→refund — теперь проверяет
+  задуманный флоу.
+
+### Баг №29: server-side changeToAgent посреди выполнения вешал сессию навсегда
+Файл: `src/client/ClientAgent.ts` (найден пробой N4)
+- changeToAgent диспоузит старый инстанс агента; если его выполнение ещё шло
+  (медленный getCompletion), будущий вывод терялся: ожидатель complete() и
+  busy-lock висли навсегда, все последующие сообщения — тоже.
+- Исправление: счётчик _activeExecutions (обёртка queued execute); dispose при
+  живом выполнении инкрементит _outputEpoch (поздний результат умирающего
+  инстанса дропается) и резолвит ожидателя пустым выводом — complete()
+  возвращает "", busy освобождается, следующее сообщение идёт новому агенту.
+
+### Новые тесты (7), сьют вырос до 278/278 — test/spec/navprev.test.mjs
+- полный обход стека: A→B→C, prev→B, prev→A(default), prev→no-op;
+- легитимная ре-навигация A↔B между отдельными сообщениями НЕ гасится;
+- параллельные changeToAgent сериализуются (queued per client);
+- смена агента посреди медленного выполнения: "" + следующий ответ от нового
+  агента (регрессия бага №29);
+- changeToDefaultAgent после цепочки + prev по стеку;
+- навигация без dependsOn работает (warning-контракт);
+- navigation stack восстанавливается из persist-адаптера, prev после
+  пересоздания сессии ведёт назад корректно.
+
+## Найденные и исправленные баги (29 итого)
 
 ### 1. Дедлок waitForOutput при functools-kit v4 (причина 39 упавших тестов)
 Файл: `src/client/ClientSwarm.ts`

src/client/ClientAgent.ts

@@ -737,6 +737,15 @@ export class ClientAgent implements IAgent {
    */
   _activeToolChains = 0;
 
+  /**
+   * Count of EXECUTE_FN executions currently in flight for this agent instance.
+   * dispose() checks it: tearing the instance down mid-execution (e.g. a
+   * server-side changeToAgent while the completion is still running) must
+   * resolve the pending output waiter with an empty result — otherwise the
+   * waiter and the session busy lock would hang forever.
+   */
+  _activeExecutions = 0;
+
   /**
    * Generation counter for output emissions. Bumped by commitCancelOutput and by
    * swarm-level output substitution (emit). Executions capture the epoch at start
@@ -1701,9 +1710,14 @@ export class ClientAgent implements IAgent {
    * Executes the incoming message and processes tool calls if present, queued to prevent overlapping executions.
    * Implements IAgent.execute, delegating to EXECUTE_FN with queuing via functools-kit’s queued decorator.
    */
-  execute = queued(
-    async (incoming, mode) => await EXECUTE_FN(incoming, mode, this)
-  ) as IAgent["execute"];
+  execute = queued(async (incoming, mode) => {
+    this._activeExecutions += 1;
+    try {
+      return await EXECUTE_FN(incoming, mode, this);
+    } finally {
+      this._activeExecutions -= 1;
+    }
+  }) as IAgent["execute"];
 
   /**
    * Runs a stateless completion for the incoming message, queued to prevent overlapping executions.
@@ -1722,6 +1736,14 @@ export class ClientAgent implements IAgent {
       this.params.logger.debug(
         `ClientAgent agentName=${this.params.agentName} clientId=${this.params.clientId} dispose`
       );
+    if (this._activeExecutions > 0) {
+      // The instance is being torn down while its execution is still running
+      // (e.g. changeToAgent mid-completion). Resolve the pending waiter with an
+      // empty output and invalidate the epoch so the late completion result of
+      // the dying instance is dropped instead of poisoning the next waiter.
+      this._outputEpoch += 1;
+      await this._outputSubject.next("");
+    }
     {
       this._agentChangeSubject.unsubscribeAll();
       this._resqueSubject.unsubscribeAll();

src/client/ClientSwarm.ts

@@ -409,6 +409,15 @@ export class ClientSwarm implements ISwarm {
         this.params.swarmName
       );
     }
+    // setAgentName pushes the NEW agent, so the top of the stack is the agent
+    // we are currently on — drop it first, otherwise "previous" would resolve
+    // to the active agent itself (self-navigation instead of going back).
+    const activeAgent = await this.getAgentName();
+    if (
+      this._navigationStack[this._navigationStack.length - 1] === activeAgent
+    ) {
+      this._navigationStack.pop();
+    }
     const prevAgent = this._navigationStack.pop();
     await this.params.setNavigationStack(
       this.params.clientId,

src/functions/navigate/changeToPrevAgent.ts

@@ -34,13 +34,15 @@ const createChangeToPrevAgent = memoize(
         agentName: AgentName,
         swarmName: SwarmName
       ) => {
-        if (
-          !swarm.navigationValidationService.shouldNavigate(
-            agentName,
-            clientId,
-            swarmName
-          )
-        ) {
+        // Going back is legitimate by definition and naturally bounded by the
+        // depth of the navigation stack, so the recursion route guard does not
+        // apply here. Only a no-op transition to the current agent is skipped.
+        const activeAgent = await swarm.swarmPublicService.getAgentName(
+          METHOD_NAME,
+          clientId,
+          swarmName
+        );
+        if (agentName === activeAgent) {
           return false;
         }
         // Notify all agents in the swarm of the change

test/index.mjs

@@ -40,6 +40,7 @@ import "./spec/hookguard.test.mjs";
 import "./spec/sweepguard.test.mjs";
 import "./spec/crashrecovery.test.mjs";
 import "./spec/finalguard.test.mjs";
+import "./spec/navprev.test.mjs";
 
 run(import.meta.url, () => {
     console.log("All tests are finished");

test/spec/navigation.test.mjs

@@ -51,6 +51,7 @@ const beforeAll = () => {
     agentName: SALES_AGENT,
     completion: "mock-completion",
     prompt: "Tell your name to the user",
+    tools: [NAVIGATE_TO_REFUND_TOOL],
   });
 
   addAgent({
@@ -154,7 +155,7 @@ const beforeAll = () => {
         };
       }
       if (
-        agentName === TRIAGE_AGENT &&
+        (agentName === TRIAGE_AGENT || agentName === SALES_AGENT) &&
         lastMessage.content === NAVIGATE_TO_REFUND_REQUEST
       ) {
         return {