tool_engine.py 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300
  1. import json
  2. from copy import deepcopy
  3. from datetime import datetime, timezone
  4. from mimetypes import guess_type
  5. from typing import Any, Union
  6. from yarl import URL
  7. from core.app.entities.app_invoke_entities import InvokeFrom
  8. from core.callback_handler.agent_tool_callback_handler import DifyAgentCallbackHandler
  9. from core.callback_handler.workflow_tool_callback_handler import DifyWorkflowCallbackHandler
  10. from core.file.file_obj import FileTransferMethod
  11. from core.tools.entities.tool_entities import ToolInvokeMessage, ToolInvokeMessageBinary, ToolInvokeMeta, ToolParameter
  12. from core.tools.errors import (
  13. ToolEngineInvokeError,
  14. ToolInvokeError,
  15. ToolNotFoundError,
  16. ToolNotSupportedError,
  17. ToolParameterValidationError,
  18. ToolProviderCredentialValidationError,
  19. ToolProviderNotFoundError,
  20. )
  21. from core.tools.tool.tool import Tool
  22. from core.tools.tool.workflow_tool import WorkflowTool
  23. from core.tools.utils.message_transformer import ToolFileMessageTransformer
  24. from extensions.ext_database import db
  25. from models.model import Message, MessageFile
  26. class ToolEngine:
  27. """
  28. Tool runtime engine take care of the tool executions.
  29. """
  30. @staticmethod
  31. def agent_invoke(tool: Tool, tool_parameters: Union[str, dict],
  32. user_id: str, tenant_id: str, message: Message, invoke_from: InvokeFrom,
  33. agent_tool_callback: DifyAgentCallbackHandler) \
  34. -> tuple[str, list[tuple[MessageFile, bool]], ToolInvokeMeta]:
  35. """
  36. Agent invokes the tool with the given arguments.
  37. """
  38. # check if arguments is a string
  39. if isinstance(tool_parameters, str):
  40. # check if this tool has only one parameter
  41. parameters = [
  42. parameter for parameter in tool.get_runtime_parameters()
  43. if parameter.form == ToolParameter.ToolParameterForm.LLM
  44. ]
  45. if parameters and len(parameters) == 1:
  46. tool_parameters = {
  47. parameters[0].name: tool_parameters
  48. }
  49. else:
  50. raise ValueError(f"tool_parameters should be a dict, but got a string: {tool_parameters}")
  51. # invoke the tool
  52. try:
  53. # hit the callback handler
  54. agent_tool_callback.on_tool_start(
  55. tool_name=tool.identity.name,
  56. tool_inputs=tool_parameters
  57. )
  58. meta, response = ToolEngine._invoke(tool, tool_parameters, user_id)
  59. response = ToolFileMessageTransformer.transform_tool_invoke_messages(
  60. messages=response,
  61. user_id=user_id,
  62. tenant_id=tenant_id,
  63. conversation_id=message.conversation_id
  64. )
  65. # extract binary data from tool invoke message
  66. binary_files = ToolEngine._extract_tool_response_binary(response)
  67. # create message file
  68. message_files = ToolEngine._create_message_files(
  69. tool_messages=binary_files,
  70. agent_message=message,
  71. invoke_from=invoke_from,
  72. user_id=user_id
  73. )
  74. plain_text = ToolEngine._convert_tool_response_to_str(response)
  75. # hit the callback handler
  76. agent_tool_callback.on_tool_end(
  77. tool_name=tool.identity.name,
  78. tool_inputs=tool_parameters,
  79. tool_outputs=plain_text
  80. )
  81. # transform tool invoke message to get LLM friendly message
  82. return plain_text, message_files, meta
  83. except ToolProviderCredentialValidationError as e:
  84. error_response = "Please check your tool provider credentials"
  85. agent_tool_callback.on_tool_error(e)
  86. except (
  87. ToolNotFoundError, ToolNotSupportedError, ToolProviderNotFoundError
  88. ) as e:
  89. error_response = f"there is not a tool named {tool.identity.name}"
  90. agent_tool_callback.on_tool_error(e)
  91. except (
  92. ToolParameterValidationError
  93. ) as e:
  94. error_response = f"tool parameters validation error: {e}, please check your tool parameters"
  95. agent_tool_callback.on_tool_error(e)
  96. except ToolInvokeError as e:
  97. error_response = f"tool invoke error: {e}"
  98. agent_tool_callback.on_tool_error(e)
  99. except ToolEngineInvokeError as e:
  100. meta = e.args[0]
  101. error_response = f"tool invoke error: {meta.error}"
  102. agent_tool_callback.on_tool_error(e)
  103. return error_response, [], meta
  104. except Exception as e:
  105. error_response = f"unknown error: {e}"
  106. agent_tool_callback.on_tool_error(e)
  107. return error_response, [], ToolInvokeMeta.error_instance(error_response)
  108. @staticmethod
  109. def workflow_invoke(tool: Tool, tool_parameters: dict,
  110. user_id: str, workflow_id: str,
  111. workflow_tool_callback: DifyWorkflowCallbackHandler,
  112. workflow_call_depth: int) \
  113. -> list[ToolInvokeMessage]:
  114. """
  115. Workflow invokes the tool with the given arguments.
  116. """
  117. try:
  118. # hit the callback handler
  119. workflow_tool_callback.on_tool_start(
  120. tool_name=tool.identity.name,
  121. tool_inputs=tool_parameters
  122. )
  123. if isinstance(tool, WorkflowTool):
  124. tool.workflow_call_depth = workflow_call_depth + 1
  125. response = tool.invoke(user_id, tool_parameters)
  126. # hit the callback handler
  127. workflow_tool_callback.on_tool_end(
  128. tool_name=tool.identity.name,
  129. tool_inputs=tool_parameters,
  130. tool_outputs=response
  131. )
  132. return response
  133. except Exception as e:
  134. workflow_tool_callback.on_tool_error(e)
  135. raise e
  136. @staticmethod
  137. def _invoke(tool: Tool, tool_parameters: dict, user_id: str) \
  138. -> tuple[ToolInvokeMeta, list[ToolInvokeMessage]]:
  139. """
  140. Invoke the tool with the given arguments.
  141. """
  142. started_at = datetime.now(timezone.utc)
  143. meta = ToolInvokeMeta(time_cost=0.0, error=None, tool_config={
  144. 'tool_name': tool.identity.name,
  145. 'tool_provider': tool.identity.provider,
  146. 'tool_provider_type': tool.tool_provider_type().value,
  147. 'tool_parameters': deepcopy(tool.runtime.runtime_parameters),
  148. 'tool_icon': tool.identity.icon
  149. })
  150. try:
  151. response = tool.invoke(user_id, tool_parameters)
  152. except Exception as e:
  153. meta.error = str(e)
  154. raise ToolEngineInvokeError(meta)
  155. finally:
  156. ended_at = datetime.now(timezone.utc)
  157. meta.time_cost = (ended_at - started_at).total_seconds()
  158. return meta, response
  159. @staticmethod
  160. def _convert_tool_response_to_str(tool_response: list[ToolInvokeMessage]) -> str:
  161. """
  162. Handle tool response
  163. """
  164. result = ''
  165. for response in tool_response:
  166. if response.type == ToolInvokeMessage.MessageType.TEXT:
  167. result += response.message
  168. elif response.type == ToolInvokeMessage.MessageType.LINK:
  169. result += f"result link: {response.message}. please tell user to check it."
  170. elif response.type == ToolInvokeMessage.MessageType.IMAGE_LINK or \
  171. response.type == ToolInvokeMessage.MessageType.IMAGE:
  172. result += "image has been created and sent to user already, you do not need to create it, just tell the user to check it now."
  173. elif response.type == ToolInvokeMessage.MessageType.JSON:
  174. result += f"tool response: {json.dumps(response.message, ensure_ascii=False)}."
  175. else:
  176. result += f"tool response: {response.message}."
  177. return result
  178. @staticmethod
  179. def _extract_tool_response_binary(tool_response: list[ToolInvokeMessage]) -> list[ToolInvokeMessageBinary]:
  180. """
  181. Extract tool response binary
  182. """
  183. result = []
  184. for response in tool_response:
  185. if response.type == ToolInvokeMessage.MessageType.IMAGE_LINK or \
  186. response.type == ToolInvokeMessage.MessageType.IMAGE:
  187. mimetype = None
  188. if response.meta.get('mime_type'):
  189. mimetype = response.meta.get('mime_type')
  190. else:
  191. try:
  192. url = URL(response.message)
  193. extension = url.suffix
  194. guess_type_result, _ = guess_type(f'a{extension}')
  195. if guess_type_result:
  196. mimetype = guess_type_result
  197. except Exception:
  198. pass
  199. if not mimetype:
  200. mimetype = 'image/jpeg'
  201. result.append(ToolInvokeMessageBinary(
  202. mimetype=response.meta.get('mime_type', 'image/jpeg'),
  203. url=response.message,
  204. save_as=response.save_as,
  205. ))
  206. elif response.type == ToolInvokeMessage.MessageType.BLOB:
  207. result.append(ToolInvokeMessageBinary(
  208. mimetype=response.meta.get('mime_type', 'octet/stream'),
  209. url=response.message,
  210. save_as=response.save_as,
  211. ))
  212. elif response.type == ToolInvokeMessage.MessageType.LINK:
  213. # check if there is a mime type in meta
  214. if response.meta and 'mime_type' in response.meta:
  215. result.append(ToolInvokeMessageBinary(
  216. mimetype=response.meta.get('mime_type', 'octet/stream') if response.meta else 'octet/stream',
  217. url=response.message,
  218. save_as=response.save_as,
  219. ))
  220. return result
  221. @staticmethod
  222. def _create_message_files(
  223. tool_messages: list[ToolInvokeMessageBinary],
  224. agent_message: Message,
  225. invoke_from: InvokeFrom,
  226. user_id: str
  227. ) -> list[tuple[Any, str]]:
  228. """
  229. Create message file
  230. :param messages: messages
  231. :return: message files, should save as variable
  232. """
  233. result = []
  234. for message in tool_messages:
  235. file_type = 'bin'
  236. if 'image' in message.mimetype:
  237. file_type = 'image'
  238. elif 'video' in message.mimetype:
  239. file_type = 'video'
  240. elif 'audio' in message.mimetype:
  241. file_type = 'audio'
  242. elif 'text' in message.mimetype:
  243. file_type = 'text'
  244. elif 'pdf' in message.mimetype:
  245. file_type = 'pdf'
  246. elif 'zip' in message.mimetype:
  247. file_type = 'archive'
  248. # ...
  249. message_file = MessageFile(
  250. message_id=agent_message.id,
  251. type=file_type,
  252. transfer_method=FileTransferMethod.TOOL_FILE.value,
  253. belongs_to='assistant',
  254. url=message.url,
  255. upload_file_id=None,
  256. created_by_role=('account'if invoke_from in [InvokeFrom.EXPLORE, InvokeFrom.DEBUGGER] else 'end_user'),
  257. created_by=user_id,
  258. )
  259. db.session.add(message_file)
  260. db.session.commit()
  261. db.session.refresh(message_file)
  262. result.append((
  263. message_file.id,
  264. message.save_as
  265. ))
  266. db.session.close()
  267. return result