Fixing the conversion and post migration gateway pipeline

Author: Asaif Ali

agent_service/app/application/agents/conversion/conversion_agent.py

@@ -1,26 +1,30 @@
-from agno.agent import Agent
-from app.infrastructure.agents_backend.model_provider import model
-
-conversion_agent = Agent(
-    model=model,
-    markdown=False,
-    debug_mode=True,
-    retries=1,
-    instructions="""
-    You are a code migration agent. You will be given context for a source to target symbol/code conversion.
-    Context will include: 
-    - Source code for the source symbol
-    - Code from any dependent plans/symbols (if any)
-    - Similar code snippets that were already migrated (if any)
-    Important
-    - Using the context, generate new code in target laguage in text format & return it.  
-    - If similar already migrated code snippets are given, use them as coding guidelines/format references to generate new code. We must follow existing coding standards.    
-    
-    Rules:
-    - Output ONLY raw executable code. No markdown, no fences, no comments outside the code.
-    - No explanations, no notes, no "Note:" lines, no section headers.
-    - No import statements unless they are strictly required by the converted symbol.
-    - Follow the coding style of any similar snippets provided.
-    - Do not add example usage blocks or standalone invocation calls at the end.
-    """
-)
+from agno.agent import Agent
+from app.infrastructure.agents_backend.model_provider import model
+
+conversion_agent = Agent(
+    model=model,
+    markdown=False,
+    debug_mode=True,
+    retries=1,
+    instructions="""
+    You are a code migration agent. You will be given context for a source to target symbol/code conversion.
+    Context will include: 
+    - Source code for the source symbol
+    - Code from any dependent plans/symbols (if any)
+    - Similar code snippets that were already migrated (if any)
+    Important
+    - Using the context, generate new code in target laguage in text format & return it.  
+    - If similar already migrated code snippets are given, use them as coding guidelines/format references to generate new code. We must follow existing coding standards.    
+    
+    Rules:
+    - Output ONLY raw executable code. No markdown, no fences, no comments outside the code.
+    - No explanations, no notes, no "Note:" lines, no section headers.
+    - No import statements unless they are strictly required by the converted symbol.
+    - Follow the coding style of any similar snippets provided.
+    - Do not add example usage blocks or standalone invocation calls at the end.
+    - Preserve executable entry-point semantics from the source module. If the source
+      module executes a translated symbol at runtime, the target must preserve that
+      behavior using the idiomatic entry-point convention of the target language.
+      Do not add an entry point when the source is clearly a reusable library/module.
+    """
+)

agent_service/app/application/agents/conversion/conversion_tools.py

@@ -19,6 +19,7 @@
 import app.application.agents.knowledge_base.knowledge_base_agent as kb
 from app.application.agents.conversion.conversion_agent import conversion_agent
 from app.infrastructure.utils.Agent_helpers.conversion_helper import _conversion_event_helper
+from app.infrastructure.utils.language_adapters import adapter_for_file, get_adapter, ExecutionContract
 from app.domain.interfaces.i_folder_structure_goals_repository import (
     IFolderStructureGoalsRepository,
 )
@@ -53,11 +54,6 @@
 logging.basicConfig(level=logging.INFO)
 _conversion_step_start_sent: set = set()
 
-def _ensure_qdrant_kb_ready() -> None:
-    if kb.source_knowledge is None or kb.target_knowledge is None:
-        kb.init_knowledge_bases()
-
-
 _folder_goals_repo: Optional[IFolderStructureGoalsRepository] = None
 _json_artifact_repo: Optional[IJsonArtifactRepository] = None
 __all__=[
@@ -257,6 +253,29 @@ def generate_new_code(step_input: StepInput) -> dict:
         f"Architecture    : {runtime_tech['architecture'] or 'Unknown'}\n"
     )
 
+    # Resolve executable behavior through the language adapter registry. The
+    # conversion engine never branches on source/target language itself.
+    execution_contract = None
+    entrypoint_context = ""
+    try:
+        source_adapter = adapter_for_file(Path(str(source_file_path)))
+        if source_adapter is not None:
+            execution_contract = source_adapter.detect_execution_contract(
+                Path(str(source_file_path)), target_symbol_name
+            )
+        if execution_contract and execution_contract.executable:
+            target_adapter = get_adapter(runtime_tech.get("language", ""))
+            target_name = target_adapter.display_name if target_adapter else runtime_tech.get("language", "target")
+            entrypoint_context = (
+                "SOURCE EXECUTION CONTRACT: the source module executes the translated "
+                f"symbol '{execution_contract.entry_symbol}'. Preserve that runtime behavior "
+                f"using the idiomatic executable entry-point convention of the target language ({target_name}). "
+                "Do not add an entry point when the source is clearly a reusable library/module."
+            )
+    except Exception:
+        execution_contract = None
+        entrypoint_context = ""
+
     try:
         user = current_user.get()
         migration_name = migration_name_ctx.get(None)
@@ -295,6 +314,7 @@ def generate_new_code(step_input: StepInput) -> dict:
         EXISTING DEPENDENCIES TO USE: {deps_content} 
         EXISTING SIMILAR CODE SNIPPETS: []
         PRE-APPROVED LIBRARIES (from dependency file — use these for imports, do not invent others): {file_deps_content}
+        {entrypoint_context}
         When writing the target code, make sure to correctly use the exisisting dependencies alongwith their correct import paths/naming conventions.
         Return just the final raw code, no extra explanations & no extra formatting such as ```python, ```, etc.  
         """
@@ -306,6 +326,12 @@ def generate_new_code(step_input: StepInput) -> dict:
     if target_code.endswith("```"):
         target_code = target_code.rsplit("\n", 1)[0] if "\n" in target_code else target_code[:-3]
 
+    target_adapter = get_adapter(runtime_tech.get("language", ""))
+    if target_adapter is not None and execution_contract is not None:
+        target_code = target_adapter.ensure_entrypoint(
+            target_code, execution_contract, target_symbol_name
+        )
+
     track_tokens(resp, source="conversion:symbol_convert")
 
     try: