feat: gate progressive routing legacy retirement

Author: rockyshi1993

hooks/_runtime/host-adapter-identity.cjs

@@ -0,0 +1,64 @@
+'use strict'
+
+const crypto = require('crypto')
+const fs = require('fs')
+const path = require('path')
+
+const HOST_VARIANTS = Object.freeze({
+  claude: 'claude-code/print-user-global-local-stdio',
+  codex: 'codex-cli/exec-user-global-local-stdio',
+  copilot: 'copilot-cli/print-user-global-local-stdio',
+  gemini: 'gemini-cli/headless-user-global-local-stdio',
+  grok: 'grok-cli-single/global-launcher-local-stdio'
+})
+
+const HOST_ALIASES = Object.freeze({
+  'claude-code': 'claude',
+  'github-copilot': 'copilot',
+  'gemini-cli': 'gemini',
+  'grok-cli-single': 'grok',
+  'grok-single': 'grok'
+})
+
+function sha256 (value) {
+  return crypto.createHash('sha256').update(value).digest('hex')
+}
+
+function normalizeHostId (host) {
+  const value = String(host || '').trim().toLowerCase()
+  if (Object.prototype.hasOwnProperty.call(HOST_VARIANTS, value)) return value
+  return HOST_ALIASES[value] || ''
+}
+
+function normalizeHostVariant (host) {
+  const value = String(host || '').trim().toLowerCase()
+  if (Object.values(HOST_VARIANTS).includes(value)) return value
+  const hostId = normalizeHostId(value)
+  return HOST_VARIANTS[hostId] || `${value || 'unknown'}/unsupported`
+}
+
+function getLifecycleHostAdapterDigest (host, options = {}) {
+  const fsImpl = options.fs || fs
+  const hostVariant = normalizeHostVariant(host)
+  const runtimeRoot = path.resolve(options.runtimeRoot || __dirname)
+  const files = [
+    'host-adapter-identity.cjs',
+    'lifecycle-host-adapters.cjs',
+    'lifecycle.cjs'
+  ].map(name => ({
+    name,
+    digest: sha256(fsImpl.readFileSync(path.join(runtimeRoot, name)))
+  }))
+  return sha256(JSON.stringify({
+    schemaVersion: 'HostAdapterIdentityV1',
+    hostVariant,
+    files
+  }))
+}
+
+module.exports = {
+  HOST_VARIANTS,
+  getLifecycleHostAdapterDigest,
+  normalizeHostId,
+  normalizeHostVariant
+}

hooks/_runtime/host-skill-route-capabilities.v1.json

@@ -2,35 +2,28 @@
   "schemaVersion": "HostSkillRouteCapabilityV1",
   "capabilities": [
     {
-      "hostVariant": "claude-code/user-global-local-stdio",
+      "hostVariant": "claude-code/print-user-global-local-stdio",
       "status": "UNVERIFIED",
       "testedVersion": "2.1.197",
       "protocol": "MCP 2024-11-05",
       "evidenceRef": null
     },
     {
-      "hostVariant": "codex/user-global-local-stdio",
+      "hostVariant": "codex-cli/exec-user-global-local-stdio",
       "status": "UNVERIFIED",
       "testedVersion": "unverified",
       "protocol": "MCP 2024-11-05",
       "evidenceRef": null
     },
     {
-      "hostVariant": "copilot/user-global-local-stdio",
+      "hostVariant": "copilot-cli/print-user-global-local-stdio",
       "status": "UNVERIFIED",
       "testedVersion": "unverified",
       "protocol": "MCP 2024-11-05",
       "evidenceRef": null
     },
     {
-      "hostVariant": "gemini-cli/user-global-local-stdio",
-      "status": "UNVERIFIED",
-      "testedVersion": "unverified",
-      "protocol": "MCP 2024-11-05",
-      "evidenceRef": null
-    },
-    {
-      "hostVariant": "grok/user-global-local-stdio",
+      "hostVariant": "gemini-cli/headless-user-global-local-stdio",
       "status": "UNVERIFIED",
       "testedVersion": "unverified",
       "protocol": "MCP 2024-11-05",
@@ -41,10 +34,10 @@
       "status": "PASS",
       "testedVersion": "grok 0.2.112 (9bbd559437)",
       "protocol": "MCP 2024-11-05",
-      "runtimeContractDigest": "3b2e25d1a1b65050943ea08de5d7348907666ab9a0691d169f953d4e196081f5",
+      "runtimeContractDigest": "a9772e7f30b2b40f72c16f70ffbcb82844d5a59546b0bdf6a3068eda53794141",
       "hostAdapterDigest": "b2ab490df9c881a1a8b67c8391f72c615d05a64aab1db9e4bd6ec8a5f0a99385",
-      "evidenceDigest": "b18ea51c81782239ab60a685ee9a995c13490e719a04004995f6920ee2e176be",
-      "evidenceRef": "E:/Worker/.devcodex/devcodex/.audit-state/skill-route-s15-grok-launcher-production-converged-20260728.json",
+      "evidenceDigest": "667c4481e6cc2634c67a276b724306ae2c77170b10dbf41ca20d18832a6766f4",
+      "evidenceRef": "E:/Worker/.devcodex/devcodex/.audit-state/skill-route-s15-grok-20260729-final-production.json",
       "entrySurface": "devcodex grok -p/--single",
       "bootstrapDelivery": "global launcher --rules",
       "defaultEligible": true

hooks/_runtime/lifecycle-bootstrap-state.cjs

@@ -7,6 +7,29 @@ const {
 } = require('./content-identity.cjs')
 const { readContextPlanObservation } = require('./context-plan-observation.cjs')
 
+function parseContextToolIdentity (rawName, explicitServer = '') {
+  const raw = String(rawName || '').trim()
+  const lower = raw.toLowerCase()
+  let server = String(explicitServer || '').trim().toLowerCase()
+  let tool = lower
+  const mcp = lower.match(/^mcp__(.+)__([a-z0-9_]+)$/)
+  const doubleUnderscore = lower.match(/^([^_]+(?:-[^_]+)*)__([a-z0-9_]+)$/)
+  const pair = lower.match(/^([^/]+)\/([a-z0-9_]+)$/)
+  if (mcp) {
+    server = mcp[1]
+    tool = mcp[2]
+  } else if (doubleUnderscore) {
+    server = doubleUnderscore[1]
+    tool = doubleUnderscore[2]
+  } else if (pair) {
+    server = pair[1]
+    tool = pair[2]
+  }
+  if (server === 'devcodex_profile') server = 'devcodex-profile'
+  if (server === 'devcodex_memory') server = 'devcodex-memory'
+  return { raw, server, tool }
+}
+
 function buildLifecycleBootstrapStateUtils(ctx) {
   const {
     fs,
@@ -104,23 +127,10 @@ function buildLifecycleBootstrapStateUtils(ctx) {
   }
 
   function canonicalContextTool(payload) {
-    const raw = getToolName(payload)
-    const lower = raw.toLowerCase()
-    let server = String(payload?.server_name || payload?.serverName || '').trim().toLowerCase()
-    let tool = lower
-    const claude = lower.match(/^mcp__([^_]+(?:-[^_]+)*)__([a-z0-9_]+)$/)
-    const grok = lower.match(/^([^_]+(?:-[^_]+)*)__([a-z0-9_]+)$/)
-    const pair = lower.match(/^([^/]+)\/([a-z0-9_]+)$/)
-    if (claude) {
-      server = claude[1]
-      tool = claude[2]
-    } else if (grok) {
-      server = grok[1]
-      tool = grok[2]
-    } else if (pair) {
-      server = pair[1]
-      tool = pair[2]
-    }
+    const { raw, server, tool } = parseContextToolIdentity(
+      getToolName(payload),
+      payload?.server_name || payload?.serverName
+    )
     if (!server && (PROFILE_TOOLS.has(tool) || PROFILE_ROUTE_TOOLS.has(tool) || MEMORY_READ_TOOLS.has(tool))) {
       return { raw, server: '', tool, canonical: '', recognizedName: true }
     }
@@ -1546,4 +1556,7 @@ function buildLifecycleBootstrapStateUtils(ctx) {
   }
 }
 
-module.exports = { buildLifecycleBootstrapStateUtils }
+module.exports = {
+  buildLifecycleBootstrapStateUtils,
+  parseContextToolIdentity
+}

hooks/_runtime/lifecycle-host-adapters.cjs

@@ -21,6 +21,7 @@ const CODEX_EVENT_MAP = Object.freeze({
 })
 
 const COPILOT_EVENT_MAP = Object.freeze({
+  userPromptTransformed: 'UserPromptSubmit',
   userPromptSubmitted: 'UserPromptSubmit',
   UserPromptSubmit: 'UserPromptSubmit',
   preToolUse: 'PreToolUse',
@@ -232,6 +233,10 @@ function normalizeHostPayload(host, payload) {
     if (normalized.transcriptPath && !normalized.transcript_path) normalized.transcript_path = normalized.transcriptPath
     if (normalized.stopReason && !normalized.stop_reason) normalized.stop_reason = normalized.stopReason
     if (normalized.toolResult && !normalized.tool_result) normalized.tool_result = normalized.toolResult
+    if (originalEvent === 'userPromptTransformed' &&
+        /^Progressive Skill route is incomplete:/i.test(String(normalized.prompt || '').trim())) {
+      normalized.devcodex_host_continuation = true
+    }
   }
   if (host === 'gemini' && typeof payload?.prompt_response === 'string') normalized.response = payload.prompt_response
   return { originalEvent, mappedEvent, payload: normalized }
@@ -331,7 +336,7 @@ function adaptGrokOutput(originalEvent, output) {
   return next
 }
 
-function adaptCopilotOutput(originalEvent, output) {
+function adaptCopilotOutput(originalEvent, output, input = {}) {
   const value = output && typeof output === 'object' && !Array.isArray(output) ? { ...output } : {}
   const event = normalizeEventToken(originalEvent)
   const specific = value.hookSpecificOutput && typeof value.hookSpecificOutput === 'object'
@@ -371,6 +376,24 @@ function adaptCopilotOutput(originalEvent, output) {
     }
   }
 
+  if (event === 'userprompttransformed') {
+    const additionalContext = [
+      value.systemMessage,
+      specific.additionalContext,
+      value.additionalContext
+    ].filter(item => typeof item === 'string' && item.trim()).join('\n\n')
+    const transformedPrompt = String(
+      input.transformedPrompt || input.transformed_prompt || input.prompt || ''
+    )
+    return additionalContext
+      ? {
+          modifiedTransformedPrompt: [transformedPrompt, additionalContext]
+            .filter(Boolean)
+            .join('\n\n')
+        }
+      : {}
+  }
+
   if (event === 'agentstop' || event === 'stop') {
     if (value.decision === 'block') {
       return {
@@ -385,7 +408,7 @@ function adaptCopilotOutput(originalEvent, output) {
   return {}
 }
 
-function adaptHostOutput(host, originalEvent, output) {
+function adaptHostOutput(host, originalEvent, output, input = {}) {
   const value = output && typeof output === 'object' && !Array.isArray(output) ? { ...output } : { continue: true }
   if (value.hookSpecificOutput && typeof value.hookSpecificOutput === 'object') {
     value.hookSpecificOutput = { ...value.hookSpecificOutput, hookEventName: originalEvent }
@@ -394,7 +417,7 @@ function adaptHostOutput(host, originalEvent, output) {
     return adaptGrokOutput(originalEvent, value)
   }
   if (host === 'copilot') {
-    return adaptCopilotOutput(originalEvent, value)
+    return adaptCopilotOutput(originalEvent, value, input)
   }
   if (host !== 'gemini') return value
 
@@ -469,7 +492,11 @@ function runHostAdapter(host, input, options = {}) {
   try { output = child.stdout.trim() ? JSON.parse(child.stdout) : { continue: true } } catch (error) {
     return { status: 1, error: `invalid lifecycle output: ${error.message}`, output: null }
   }
-  const result = { status: 0, error: '', output: adaptHostOutput(host, normalized.originalEvent, output) }
+  const result = {
+    status: 0,
+    error: '',
+    output: adaptHostOutput(host, normalized.originalEvent, output, input)
+  }
   appendAdapterTrace(host, 'output', input, normalized, result, options.env || process.env)
   return result
 }
@@ -503,6 +530,30 @@ function probeHostAdapterContract(host) {
   }
 }
 
+function applyCliEnvironmentOverrides (argv, env = process.env) {
+  const authorityIndex = argv.indexOf('--skill-route-probe-authority')
+  if (authorityIndex >= 0 && argv[authorityIndex + 1]) {
+    env.DEVCODEX_SKILL_ROUTE_PROBE_AUTHORITY = path.resolve(argv[authorityIndex + 1])
+  }
+  const routeTraceIndex = argv.indexOf('--skill-route-trace')
+  if (routeTraceIndex >= 0 && argv[routeTraceIndex + 1]) {
+    env.DEVCODEX_SKILL_ROUTE_TRACE = path.resolve(argv[routeTraceIndex + 1])
+  }
+  const lifecycleTraceIndex = argv.indexOf('--lifecycle-trace')
+  if (lifecycleTraceIndex >= 0 && argv[lifecycleTraceIndex + 1]) {
+    env.DEVCODEX_LIFECYCLE_TRACE = path.resolve(argv[lifecycleTraceIndex + 1])
+  }
+  const workspaceRootIndex = argv.indexOf('--workspace-root')
+  if (workspaceRootIndex >= 0 && argv[workspaceRootIndex + 1]) {
+    env.DEVCODEX_WORKSPACE_ROOT = path.resolve(argv[workspaceRootIndex + 1])
+  }
+  const eventIndex = argv.indexOf('--event')
+  if (eventIndex >= 0 && argv[eventIndex + 1]) {
+    env.DEVCODEX_HOST_EVENT = String(argv[eventIndex + 1]).trim()
+  }
+  return env
+}
+
 if (require.main === module) {
   const host = String(process.argv[2] || '').trim().toLowerCase()
   if (!Object.prototype.hasOwnProperty.call(EVENT_MAP, host)) {
@@ -514,6 +565,7 @@ if (require.main === module) {
     process.stdout.write(JSON.stringify(probe))
     process.exit(probe.status === 'passed' ? 0 : 1)
   }
+  applyCliEnvironmentOverrides(process.argv.slice(3))
   let input = ''
   process.stdin.setEncoding('utf8')
   process.stdin.on('data', chunk => { input += chunk })
@@ -524,6 +576,10 @@ if (require.main === module) {
       process.exit(2)
       return
     }
+    if (!payload.hookEventName && !payload.hook_event_name &&
+        process.env.DEVCODEX_HOST_EVENT) {
+      payload.hookEventName = process.env.DEVCODEX_HOST_EVENT
+    }
     const result = runHostAdapter(host, payload)
     if (result.status !== 0) {
       process.stderr.write(`${result.error}\n`)
@@ -536,6 +592,7 @@ if (require.main === module) {
 
 module.exports = {
   EVENT_MAP,
+  applyCliEnvironmentOverrides,
   adaptCopilotOutput,
   adaptHostOutput,
   adaptGrokOutput,

hooks/_runtime/lifecycle.cjs

@@ -1241,6 +1241,12 @@ async function main() {
 
   // ── UserPromptSubmit ───────────────────────────────────────────────────────
   if (eventName === 'UserPromptSubmit') {
+    if (payload.devcodex_host_continuation === true) {
+      state.lastReason = 'host-route-continuation'
+      saveState(state)
+      writeStdout(noopOutput())
+      return
+    }
     const workflowCompletionLifecycle = state.workflowCompletionLifecycle
     state = resetState(mode, state)
     state.workflowCompletionLifecycle = workflowCompletionLifecycle
@@ -1355,6 +1361,9 @@ async function main() {
     let progressiveSkillRouteMode = 'legacy'
     try {
       const { bootstrapSkillRouteForTurn } = require('./skill-route-tool.cjs')
+      const {
+        getLifecycleHostAdapterDigest
+      } = require('./host-adapter-identity.cjs')
       const route = bootstrapSkillRouteForTurn({
         project: state.contextAcquisition?.project,
         contextEpoch: state.contextAcquisition?.contextEpoch,
@@ -1363,7 +1372,8 @@ async function main() {
         cwd: CONTEXT_ROOT
       }, {
         inputRoot: CONTEXT_ROOT,
-        env: process.env
+        env: process.env,
+        hostAdapterDigest: getLifecycleHostAdapterDigest(platform)
       })
       progressiveSkillRouteMode = route.modeReceipt?.effective || 'legacy'
       progressiveSkillRouteMsg = route.injectionText || ''