endpoint_service.py 1.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. from core.plugin.manager.endpoint import PluginEndpointManager
  2. class EndpointService:
  3. @classmethod
  4. def create_endpoint(cls, tenant_id: str, user_id: str, plugin_unique_identifier: str, name: str, settings: dict):
  5. return PluginEndpointManager().create_endpoint(
  6. tenant_id=tenant_id,
  7. user_id=user_id,
  8. plugin_unique_identifier=plugin_unique_identifier,
  9. name=name,
  10. settings=settings,
  11. )
  12. @classmethod
  13. def list_endpoints(cls, tenant_id: str, user_id: str, page: int, page_size: int):
  14. return PluginEndpointManager().list_endpoints(
  15. tenant_id=tenant_id,
  16. user_id=user_id,
  17. page=page,
  18. page_size=page_size,
  19. )
  20. @classmethod
  21. def update_endpoint(cls, tenant_id: str, user_id: str, endpoint_id: str, name: str, settings: dict):
  22. return PluginEndpointManager().update_endpoint(
  23. tenant_id=tenant_id,
  24. user_id=user_id,
  25. endpoint_id=endpoint_id,
  26. name=name,
  27. settings=settings,
  28. )
  29. @classmethod
  30. def delete_endpoint(cls, tenant_id: str, user_id: str, endpoint_id: str):
  31. return PluginEndpointManager().delete_endpoint(
  32. tenant_id=tenant_id,
  33. user_id=user_id,
  34. endpoint_id=endpoint_id,
  35. )
  36. @classmethod
  37. def enable_endpoint(cls, tenant_id: str, user_id: str, endpoint_id: str):
  38. return PluginEndpointManager().enable_endpoint(
  39. tenant_id=tenant_id,
  40. user_id=user_id,
  41. endpoint_id=endpoint_id,
  42. )
  43. @classmethod
  44. def disable_endpoint(cls, tenant_id: str, user_id: str, endpoint_id: str):
  45. return PluginEndpointManager().disable_endpoint(
  46. tenant_id=tenant_id,
  47. user_id=user_id,
  48. endpoint_id=endpoint_id,
  49. )