json.py 1.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. import json
  2. from datetime import datetime
  3. from json_repair import repair_json
  4. from litellm.types.utils import ModelResponse
  5. from openhands.core.exceptions import LLMResponseError
  6. from openhands.events.event import Event
  7. from openhands.events.serialization import event_to_dict
  8. from openhands.llm.metrics import Metrics
  9. def my_default_encoder(obj):
  10. """Custom JSON encoder that handles datetime and event objects"""
  11. if isinstance(obj, datetime):
  12. return obj.isoformat()
  13. if isinstance(obj, Event):
  14. return event_to_dict(obj)
  15. if isinstance(obj, Metrics):
  16. return obj.get()
  17. if isinstance(obj, ModelResponse):
  18. return obj.model_dump()
  19. return json.JSONEncoder().default(obj)
  20. def dumps(obj, **kwargs):
  21. """Serialize an object to str format"""
  22. return json.dumps(obj, default=my_default_encoder, **kwargs)
  23. def loads(json_str, **kwargs):
  24. """Create a JSON object from str"""
  25. try:
  26. return json.loads(json_str, **kwargs)
  27. except json.JSONDecodeError:
  28. pass
  29. depth = 0
  30. start = -1
  31. for i, char in enumerate(json_str):
  32. if char == '{':
  33. if depth == 0:
  34. start = i
  35. depth += 1
  36. elif char == '}':
  37. depth -= 1
  38. if depth == 0 and start != -1:
  39. response = json_str[start : i + 1]
  40. try:
  41. json_str = repair_json(response)
  42. return json.loads(json_str, **kwargs)
  43. except (json.JSONDecodeError, ValueError, TypeError) as e:
  44. raise LLMResponseError(
  45. 'Invalid JSON in response. Please make sure the response is a valid JSON object.'
  46. ) from e
  47. raise LLMResponseError('No valid JSON object found in response.')