fix: process infer optional types

Author: robertandreimoldoveanu

src/uipath_langchain/_cli/cli_init.py

@@ -32,6 +32,25 @@ def resolve_refs(schema, root=None):
     return schema
 
 
+def process_nullable_types(
+    schema: Dict[str, Any] | list[Any] | Any,
+) -> Dict[str, Any] | list[Any]:
+    """Process the schema to handle nullable types by removing anyOf with null and keeping the base type."""
+    if isinstance(schema, dict):
+        if "anyOf" in schema and len(schema["anyOf"]) == 2:
+            types = [t.get("type") for t in schema["anyOf"]]
+            if "null" in types:
+                non_null_type = next(
+                    t for t in schema["anyOf"] if t.get("type") != "null"
+                )
+                return non_null_type
+
+        return {k: process_nullable_types(v) for k, v in schema.items()}
+    elif isinstance(schema, list):
+        return [process_nullable_types(item) for item in schema]
+    return schema
+
+
 def generate_schema_from_graph(graph: CompiledStateGraph) -> Dict[str, Any]:
     """Extract input/output schema from a LangGraph graph"""
     schema = {
@@ -42,24 +61,29 @@ def generate_schema_from_graph(graph: CompiledStateGraph) -> Dict[str, Any]:
     if hasattr(graph, "input_schema"):
         if hasattr(graph.input_schema, "model_json_schema"):
             input_schema = graph.input_schema.model_json_schema()
-
             unpacked_ref_def_properties = resolve_refs(input_schema)
 
-            schema["input"]["properties"] = unpacked_ref_def_properties.get(
-                "properties", {}
+            # Process the schema to handle nullable types
+            processed_properties = process_nullable_types(
+                unpacked_ref_def_properties.get("properties", {})
             )
+
+            schema["input"]["properties"] = processed_properties
             schema["input"]["required"] = unpacked_ref_def_properties.get(
                 "required", []
             )
 
     if hasattr(graph, "output_schema"):
         if hasattr(graph.output_schema, "model_json_schema"):
             output_schema = graph.output_schema.model_json_schema()
-
             unpacked_ref_def_properties = resolve_refs(output_schema)
-            schema["output"]["properties"] = unpacked_ref_def_properties.get(
-                "properties", {}
+
+            # Process the schema to handle nullable types
+            processed_properties = process_nullable_types(
+                unpacked_ref_def_properties.get("properties", {})
             )
+
+            schema["output"]["properties"] = processed_properties
             schema["output"]["required"] = unpacked_ref_def_properties.get(
                 "required", []
             )
@@ -170,4 +194,5 @@ async def langgraph_init_middleware_async(entrypoint: str) -> MiddlewareResult:
 
 def langgraph_init_middleware(entrypoint: str) -> MiddlewareResult:
     """Middleware to check for langgraph.json and create uipath.json with schemas"""
+    print("langgraph_init_middleware")
     return asyncio.run(langgraph_init_middleware_async(entrypoint))