feat: eliminate Python altimate-engine — all 73 methods native TypeScript

packages/opencode/src/altimate/index.ts

@@ -1,10 +1,13 @@
 // Barrel export for all Altimate custom code
 
-// Bridge
+// Bridge (legacy — being replaced by native dispatcher)
 export { Bridge } from "./bridge/client"
 export { ensureEngine, enginePythonPath } from "./bridge/engine"
 export * from "./bridge/protocol"
 
+// Native dispatcher (new — Strangler Fig migration layer)
+export { Dispatcher } from "./native"
+
 // Telemetry
 export { Telemetry } from "./telemetry"
 

packages/opencode/src/altimate/native/dispatcher.ts

@@ -0,0 +1,85 @@
+/**
+ * Dispatcher — routes tool calls to either native TypeScript handlers or the
+ * Python bridge (fallback). This is the Strangler Fig migration layer.
+ *
+ * Feature flags:
+ *   ALTIMATE_NATIVE_ONLY=1   — throws if no native handler (CI gate)
+ *   ALTIMATE_SHADOW_MODE=1   — runs both native + bridge, logs mismatches
+ */
+
+import { Bridge } from "../bridge/client"
+import { BridgeMethods, type BridgeMethod } from "../bridge/protocol"
+import { Log } from "../../util/log"
+
+type NativeHandler = (params: any) => Promise<any>
+
+const nativeHandlers = new Map<string, NativeHandler>()
+
+/** Register a native TypeScript handler for a bridge method. */
+export function register(method: string, handler: NativeHandler): void {
+  nativeHandlers.set(method, handler)
+}
+
+/** Dispatch a method call to native handler or bridge fallback. */
+export async function call<M extends BridgeMethod>(
+  method: M,
+  params: (typeof BridgeMethods)[M] extends { params: infer P } ? P : never,
+): Promise<(typeof BridgeMethods)[M] extends { result: infer R } ? R : never> {
+  const native = nativeHandlers.get(method as string)
+
+  if (native) {
+    if (process.env.ALTIMATE_SHADOW_MODE === "1") {
+      // Parity testing: run both native and bridge, log mismatches
+      try {
+        const [nativeResult, bridgeResult] = await Promise.allSettled([
+          native(params),
+          Bridge.call(method, params),
+        ])
+        if (
+          nativeResult.status === "fulfilled" &&
+          bridgeResult.status === "fulfilled"
+        ) {
+          const nativeJson = JSON.stringify(nativeResult.value, null, 0)
+          const bridgeJson = JSON.stringify(bridgeResult.value, null, 0)
+          if (nativeJson !== bridgeJson) {
+            Log.Default.warn("shadow mode mismatch", {
+              method: String(method),
+              native: nativeJson.slice(0, 500),
+              bridge: bridgeJson.slice(0, 500),
+            })
+          }
+        }
+        if (nativeResult.status === "fulfilled") {
+          return nativeResult.value as any
+        }
+        // Native failed — fall through to bridge result or throw
+        if (bridgeResult.status === "fulfilled") {
+          return bridgeResult.value as any
+        }
+        throw nativeResult.reason
+      } catch (e) {
+        // Shadow mode should not break the user — fall through to bridge
+        return Bridge.call(method, params)
+      }
+    }
+    return native(params) as any
+  }
+
+  if (process.env.ALTIMATE_NATIVE_ONLY === "1") {
+    throw new Error(
+      `No native handler for ${String(method)} (ALTIMATE_NATIVE_ONLY=1)`,
+    )
+  }
+
+  return Bridge.call(method, params)
+}
+
+/** Check if a native handler is registered for a method. */
+export function hasNativeHandler(method: string): boolean {
+  return nativeHandlers.has(method)
+}
+
+/** List all methods that have native handlers registered. */
+export function listNativeMethods(): string[] {
+  return Array.from(nativeHandlers.keys())
+}

packages/opencode/src/altimate/native/index.ts

@@ -0,0 +1 @@
+export * as Dispatcher from "./dispatcher"

packages/opencode/src/altimate/tools/altimate-core-check.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreCheckTool = Tool.define("altimate_core_check", {
   description:
@@ -12,7 +12,7 @@ export const AltimateCoreCheckTool = Tool.define("altimate_core_check", {
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.check", {
+      const result = await Dispatcher.call("altimate_core.check", {
         sql: args.sql,
         schema_path: args.schema_path ?? "",
         schema_context: args.schema_context,

packages/opencode/src/altimate/tools/altimate-core-classify-pii.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreClassifyPiiTool = Tool.define("altimate_core_classify_pii", {
   description:
@@ -11,7 +11,7 @@ export const AltimateCoreClassifyPiiTool = Tool.define("altimate_core_classify_p
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.classify_pii", {
+      const result = await Dispatcher.call("altimate_core.classify_pii", {
         schema_path: args.schema_path ?? "",
         schema_context: args.schema_context,
       })

packages/opencode/src/altimate/tools/altimate-core-column-lineage.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreColumnLineageTool = Tool.define("altimate_core_column_lineage", {
   description:
@@ -13,7 +13,7 @@ export const AltimateCoreColumnLineageTool = Tool.define("altimate_core_column_l
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.column_lineage", {
+      const result = await Dispatcher.call("altimate_core.column_lineage", {
         sql: args.sql,
         dialect: args.dialect ?? "",
         schema_path: args.schema_path ?? "",

packages/opencode/src/altimate/tools/altimate-core-compare.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreCompareTool = Tool.define("altimate_core_compare", {
   description:
@@ -12,7 +12,7 @@ export const AltimateCoreCompareTool = Tool.define("altimate_core_compare", {
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.compare", {
+      const result = await Dispatcher.call("altimate_core.compare", {
         left_sql: args.left_sql,
         right_sql: args.right_sql,
         dialect: args.dialect ?? "",

packages/opencode/src/altimate/tools/altimate-core-complete.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreCompleteTool = Tool.define("altimate_core_complete", {
   description:
@@ -13,7 +13,7 @@ export const AltimateCoreCompleteTool = Tool.define("altimate_core_complete", {
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.complete", {
+      const result = await Dispatcher.call("altimate_core.complete", {
         sql: args.sql,
         cursor_pos: args.cursor_pos,
         schema_path: args.schema_path ?? "",

packages/opencode/src/altimate/tools/altimate-core-correct.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreCorrectTool = Tool.define("altimate_core_correct", {
   description:
@@ -12,7 +12,7 @@ export const AltimateCoreCorrectTool = Tool.define("altimate_core_correct", {
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.correct", {
+      const result = await Dispatcher.call("altimate_core.correct", {
         sql: args.sql,
         schema_path: args.schema_path ?? "",
         schema_context: args.schema_context,

packages/opencode/src/altimate/tools/altimate-core-equivalence.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreEquivalenceTool = Tool.define("altimate_core_equivalence", {
   description:
@@ -13,7 +13,7 @@ export const AltimateCoreEquivalenceTool = Tool.define("altimate_core_equivalenc
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.equivalence", {
+      const result = await Dispatcher.call("altimate_core.equivalence", {
         sql1: args.sql1,
         sql2: args.sql2,
         schema_path: args.schema_path ?? "",

packages/opencode/src/altimate/tools/altimate-core-export-ddl.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreExportDdlTool = Tool.define("altimate_core_export_ddl", {
   description:
@@ -11,7 +11,7 @@ export const AltimateCoreExportDdlTool = Tool.define("altimate_core_export_ddl",
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.export_ddl", {
+      const result = await Dispatcher.call("altimate_core.export_ddl", {
         schema_path: args.schema_path ?? "",
         schema_context: args.schema_context,
       })

packages/opencode/src/altimate/tools/altimate-core-extract-metadata.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreExtractMetadataTool = Tool.define("altimate_core_extract_metadata", {
   description:
@@ -11,7 +11,7 @@ export const AltimateCoreExtractMetadataTool = Tool.define("altimate_core_extrac
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.metadata", {
+      const result = await Dispatcher.call("altimate_core.metadata", {
         sql: args.sql,
         dialect: args.dialect ?? "",
       })

packages/opencode/src/altimate/tools/altimate-core-fingerprint.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreFingerprintTool = Tool.define("altimate_core_fingerprint", {
   description:
@@ -11,7 +11,7 @@ export const AltimateCoreFingerprintTool = Tool.define("altimate_core_fingerprin
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.fingerprint", {
+      const result = await Dispatcher.call("altimate_core.fingerprint", {
         schema_path: args.schema_path ?? "",
         schema_context: args.schema_context,
       })

packages/opencode/src/altimate/tools/altimate-core-fix.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreFixTool = Tool.define("altimate_core_fix", {
   description:
@@ -13,7 +13,7 @@ export const AltimateCoreFixTool = Tool.define("altimate_core_fix", {
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.fix", {
+      const result = await Dispatcher.call("altimate_core.fix", {
         sql: args.sql,
         schema_path: args.schema_path ?? "",
         schema_context: args.schema_context,

packages/opencode/src/altimate/tools/altimate-core-format.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreFormatTool = Tool.define("altimate_core_format", {
   description:
@@ -11,7 +11,7 @@ export const AltimateCoreFormatTool = Tool.define("altimate_core_format", {
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.format", {
+      const result = await Dispatcher.call("altimate_core.format", {
         sql: args.sql,
         dialect: args.dialect ?? "",
       })

packages/opencode/src/altimate/tools/altimate-core-grade.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreGradeTool = Tool.define("altimate_core_grade", {
   description:
@@ -12,7 +12,7 @@ export const AltimateCoreGradeTool = Tool.define("altimate_core_grade", {
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.grade", {
+      const result = await Dispatcher.call("altimate_core.grade", {
         sql: args.sql,
         schema_path: args.schema_path ?? "",
         schema_context: args.schema_context,

packages/opencode/src/altimate/tools/altimate-core-import-ddl.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreImportDdlTool = Tool.define("altimate_core_import_ddl", {
   description:
@@ -11,7 +11,7 @@ export const AltimateCoreImportDdlTool = Tool.define("altimate_core_import_ddl",
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.import_ddl", {
+      const result = await Dispatcher.call("altimate_core.import_ddl", {
         ddl: args.ddl,
         dialect: args.dialect ?? "",
       })

packages/opencode/src/altimate/tools/altimate-core-introspection-sql.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreIntrospectionSqlTool = Tool.define("altimate_core_introspection_sql", {
   description:
@@ -12,7 +12,7 @@ export const AltimateCoreIntrospectionSqlTool = Tool.define("altimate_core_intro
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.introspection_sql", {
+      const result = await Dispatcher.call("altimate_core.introspection_sql", {
         db_type: args.db_type,
         database: args.database,
         schema_name: args.schema_name,

packages/opencode/src/altimate/tools/altimate-core-is-safe.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreIsSafeTool = Tool.define("altimate_core_is_safe", {
   description:
@@ -10,7 +10,7 @@ export const AltimateCoreIsSafeTool = Tool.define("altimate_core_is_safe", {
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.is_safe", {
+      const result = await Dispatcher.call("altimate_core.is_safe", {
         sql: args.sql,
       })
       const data = result.data as Record<string, any>

packages/opencode/src/altimate/tools/altimate-core-lint.ts

@@ -1,6 +1,6 @@
 import z from "zod"
 import { Tool } from "../../tool/tool"
-import { Bridge } from "../bridge/client"
+import { Dispatcher } from "../native"
 
 export const AltimateCoreLintTool = Tool.define("altimate_core_lint", {
   description:
@@ -12,7 +12,7 @@ export const AltimateCoreLintTool = Tool.define("altimate_core_lint", {
   }),
   async execute(args, ctx) {
     try {
-      const result = await Bridge.call("altimate_core.lint", {
+      const result = await Dispatcher.call("altimate_core.lint", {
         sql: args.sql,
         schema_path: args.schema_path ?? "",
         schema_context: args.schema_context,