Flomo 工具（10分钟）

import requestsdef send_flomo_note(api_url: str, content: str) -> None:    """    Send a note to Flomo via the API URL. Raises requests.RequestException on network errors,    and ValueError on invalid status codes or input.    """    api_url = api_url.strip()    if not api_url:        raise ValueError("API URL is required and cannot be empty.")    if not api_url.startswith('https://flomoapp.com/iwh/'):        raise ValueError(            "API URL should be in the format: https://flomoapp.com/iwh/{token}/{secret}/"        )    if not content:        raise ValueError("Content cannot be empty.")        headers = {'Content-Type': 'application/json'}    response = requests.post(api_url, json={"content": content}, headers=headers, timeout=10)        if response.status_code != 200:        raise ValueError(f"API URL is not valid. Received status code: {response.status_code}")

from typing import Anyfrom dify_plugin import ToolProviderfrom dify_plugin.errors.tool import ToolProviderCredentialValidationErrorimport requestsfrom utils.flomo_utils import send_flomo_noteclass FlomoProvider(ToolProvider):    def _validate_credentials(self, credentials: dict[str, Any]) -> None:        try:            api_url = credentials.get('api_url', '').strip()            # Use utility for validation and sending test note            send_flomo_note(api_url, "Hello, #flomo https://flomoapp.com")        except ValueError as e:            raise ToolProviderCredentialValidationError(str(e))        except requests.RequestException as e:            raise ToolProviderCredentialValidationError(f"Connection error: {str(e)}")

from collections.abc import Generatorfrom typing import Anyfrom dify_plugin import Toolfrom dify_plugin.entities.tool import ToolInvokeMessageimport requestsfrom utils.flomo_utils import send_flomo_noteclass FlomoTool(Tool):    def _invoke(self, tool_parameters: dict[str, Any]) -> Generator[ToolInvokeMessage]:        content = tool_parameters.get("content", "")        api_url = self.runtime.credentials.get("api_url", "")                try:            send_flomo_note(api_url, content)        except ValueError as e:            yield self.create_text_message(str(e))            return        except requests.RequestException as e:            yield self.create_text_message(f"Connection error: {str(e)}")            return                    # Return success message and structured data        yield self.create_text_message(            "Note created successfully! Your content has been sent to Flomo."        )        yield self.create_json_message({            "status": "success",            "content": content,        })