АРЧ АП11 - Архитектура после регресса: Архитектура: протянуть continuity-backed organization authority в session scope bootstrap и удержать phase12 wider replay зелёным

llm_normalizer/backend/dist/services/assistantOrganizationScopeRuntimeAdapter.js

@@ -2,6 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.resolveSessionOrganizationScopeContextRuntime = resolveSessionOrganizationScopeContextRuntime;
 exports.mergeFollowupContextWithOrganizationScopeRuntime = mergeFollowupContextWithOrganizationScopeRuntime;
+const assistantContinuityPolicy_1 = require("./assistantContinuityPolicy");
 function extractOrganizationsFromNavigationState(addressNavigationState, normalizeOrganizationScopeValue) {
     if (!addressNavigationState || typeof addressNavigationState !== "object") {
         return [];
@@ -26,7 +27,17 @@ function resolveActiveOrganizationFromNavigationState(addressNavigationState, no
     return normalizeOrganizationScopeValue(addressNavigationState.session_context?.organization_scope);
 }
 function resolveSessionOrganizationScopeContextRuntime(input) {
+    const continuityAuthority = (0, assistantContinuityPolicy_1.resolveAssistantOrganizationAuthority)({
+        sessionItems: Array.isArray(input.items) ? input.items : [],
+        toNonEmptyString: input.normalizeOrganizationScopeValue,
+        normalizeOrganizationScopeValue: input.normalizeOrganizationScopeValue
+    });
+    const continuityKnownOrganizations = Array.isArray(continuityAuthority.knownOrganizations)
+        ? continuityAuthority.knownOrganizations
+        : [];
+    const continuityActiveOrganization = input.normalizeOrganizationScopeValue(continuityAuthority.activeOrganization);
     const knownOrganizations = Array.from(new Map([
+        ...continuityKnownOrganizations,
         ...extractOrganizationsFromNavigationState(input.addressNavigationState, input.normalizeOrganizationScopeValue),
         ...input.extractKnownOrganizationsFromHistory(input.items)
     ].map((value) => [String(value).toLowerCase(), value])).values());
@@ -35,6 +46,7 @@ function resolveSessionOrganizationScopeContextRuntime(input) {
     const navigationActiveOrganization = resolveActiveOrganizationFromNavigationState(input.addressNavigationState, input.normalizeOrganizationScopeValue);
     const activeOrganization = selectedOrganization ??
         navigationActiveOrganization ??
+        continuityActiveOrganization ??
         input.normalizeOrganizationScopeValue(lastActiveOrganization) ??
         (knownOrganizations.length === 1 ? knownOrganizations[0] : null);
     return {

llm_normalizer/backend/src/services/assistantOrganizationScopeRuntimeAdapter.ts

@@ -1,4 +1,5 @@
 import type { AddressNavigationState } from "../types/addressNavigation";
+import { resolveAssistantOrganizationAuthority } from "./assistantContinuityPolicy";
 
 export interface AssistantSessionOrganizationScopeContext {
   knownOrganizations: string[];
@@ -57,9 +58,21 @@ function resolveActiveOrganizationFromNavigationState(
 export function resolveSessionOrganizationScopeContextRuntime<ItemType = unknown>(
   input: ResolveSessionOrganizationScopeContextRuntimeInput<ItemType>
 ): AssistantSessionOrganizationScopeContext {
+  const continuityAuthority = resolveAssistantOrganizationAuthority({
+    sessionItems: Array.isArray(input.items) ? input.items : [],
+    toNonEmptyString: input.normalizeOrganizationScopeValue,
+    normalizeOrganizationScopeValue: input.normalizeOrganizationScopeValue
+  });
+  const continuityKnownOrganizations = Array.isArray(continuityAuthority.knownOrganizations)
+    ? continuityAuthority.knownOrganizations
+    : [];
+  const continuityActiveOrganization = input.normalizeOrganizationScopeValue(
+    continuityAuthority.activeOrganization
+  );
   const knownOrganizations = Array.from(
     new Map(
       [
+        ...continuityKnownOrganizations,
         ...extractOrganizationsFromNavigationState(input.addressNavigationState, input.normalizeOrganizationScopeValue),
         ...input.extractKnownOrganizationsFromHistory(input.items)
       ].map((value) => [String(value).toLowerCase(), value])
@@ -77,6 +90,7 @@ export function resolveSessionOrganizationScopeContextRuntime<ItemType = unknown
   const activeOrganization =
     selectedOrganization ??
     navigationActiveOrganization ??
+    continuityActiveOrganization ??
     input.normalizeOrganizationScopeValue(lastActiveOrganization) ??
     (knownOrganizations.length === 1 ? knownOrganizations[0] : null);
 

llm_normalizer/backend/tests/assistantOrganizationScopeRuntimeAdapter.test.ts

@@ -90,6 +90,35 @@ describe("assistant organization scope runtime adapter", () => {
     });
   });
 
+  it("reuses assistant continuity authority from prior assistant debug when legacy helpers are empty", () => {
+    const normalizeOrganizationScopeValue = vi.fn((value: unknown) =>
+      typeof value === "string" && value.trim() ? value.trim() : null
+    );
+
+    const context = resolveSessionOrganizationScopeContextRuntime({
+      userMessage: "просто продолжай",
+      items: [
+        {
+          role: "assistant",
+          debug: {
+            assistant_known_organizations: ["Org C", "Org D"],
+            assistant_active_organization: "Org C"
+          }
+        }
+      ] as any[],
+      extractKnownOrganizationsFromHistory: () => [],
+      resolveOrganizationSelectionFromMessage: () => null,
+      findLastAssistantActiveOrganization: () => null,
+      normalizeOrganizationScopeValue
+    });
+
+    expect(context).toEqual({
+      knownOrganizations: ["Org C", "Org D"],
+      selectedOrganization: null,
+      activeOrganization: "Org C"
+    });
+  });
+
   it("merges organization into followup previous filters when organization is missing", () => {
     const merged = mergeFollowupContextWithOrganizationScopeRuntime({
       followupContext: {