Planner Autonomy: разрешить value-flow candidate поверх exact reply

llm_normalizer/backend/src/services/assistantMcpDiscoveryResponsePolicy.ts

@@ -303,6 +303,9 @@ function hasExactMatchedFactualAddressReply(
   if (!hasEffectivelyFactualAddressReply(input)) {
     return false;
   }
+  if (hasOpenScopeValueFlowDiscoveryPriority(input, entryPoint)) {
+    return false;
+  }
   const mcpCallStatus = toNonEmptyString(input.addressRuntimeMeta?.mcp_call_status);
   const truthMode = toNonEmptyString(input.addressRuntimeMeta?.truth_mode);
   const selectedRecipe = toNonEmptyString(input.addressRuntimeMeta?.selected_recipe);
@@ -317,6 +320,24 @@ function hasExactMatchedFactualAddressReply(
   );
 }
 
+function hasOpenScopeValueFlowDiscoveryPriority(
+  input: ApplyAssistantMcpDiscoveryResponsePolicyInput,
+  entryPoint: AssistantMcpDiscoveryRuntimeEntryPointContract | null
+): boolean {
+  if (!isDiscoveryReadyAddressCandidate(input, entryPoint)) {
+    return false;
+  }
+  if (!hasEffectivelyFactualAddressReply(input)) {
+    return false;
+  }
+  const detectedIntent = toNonEmptyString(input.addressRuntimeMeta?.detected_intent);
+  return Boolean(
+    isOpenScopeValueFlowRanking(entryPoint) ||
+      needsOpenScopeValueFlowOrganizationClarification(entryPoint) ||
+      (detectedIntent === "customer_revenue_and_payments" && isOpenScopeValueFlowWithoutSubject(entryPoint))
+  );
+}
+
 function hasRuntimeAdjustedExactReply(
   input: ApplyAssistantMcpDiscoveryResponsePolicyInput,
   entryPoint: AssistantMcpDiscoveryRuntimeEntryPointContract | null
@@ -495,6 +516,7 @@ export function applyAssistantMcpDiscoveryResponsePolicy(
   const fullConfirmedFactualAddressReply = hasFullConfirmedFactualAddressReply(input, entryPoint);
   const exactMatchedFactualAddressReply = hasExactMatchedFactualAddressReply(input, entryPoint);
   const runtimeAdjustedExactReply = hasRuntimeAdjustedExactReply(input, entryPoint);
+  const openScopeValueFlowDiscoveryPriority = hasOpenScopeValueFlowDiscoveryPriority(input, entryPoint);
 
   if (!entryPoint) {
     pushReason(reasonCodes, "mcp_discovery_response_policy_no_entry_point");
@@ -517,6 +539,9 @@ export function applyAssistantMcpDiscoveryResponsePolicy(
   if (semanticConflictWithDiscoveryTurnMeaning) {
     pushReason(reasonCodes, "mcp_discovery_response_policy_semantic_conflict_allows_candidate_override");
   }
+  if (openScopeValueFlowDiscoveryPriority) {
+    pushReason(reasonCodes, "mcp_discovery_response_policy_open_scope_value_flow_candidate_priority");
+  }
   if (matchedFactualAddressContinuationTarget) {
     pushReason(reasonCodes, "mcp_discovery_response_policy_keep_factual_address_continuation_target");
   }