plane_v2_api_handlers.go 8.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227
  1. package data
  2. import (
  3. "context"
  4. "github.com/mark3labs/mcp-go/mcp"
  5. "fwh-toolbox-server/cmd/mcp/tools/helper"
  6. )
  7. // === Workspace Handlers ===
  8. func handlePlaneV2ListWorkspaces(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  9. data, err := planeV2Svc.ListWorkspaces()
  10. return planeRawResult(data, err, "列出工作空间")
  11. }
  12. func handlePlaneV2GetWorkspace(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  13. slug, err := req.RequireString("workspace_slug")
  14. if err != nil {
  15. return helper.ParamError("workspace_slug"), nil
  16. }
  17. data, apiErr := planeV2Svc.GetWorkspace(slug)
  18. return planeRawResult(data, apiErr, "获取工作空间详情")
  19. }
  20. // === Project Handlers ===
  21. func handlePlaneV2ListProjects(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  22. slug, err := req.RequireString("workspace_slug")
  23. if err != nil {
  24. return helper.ParamError("workspace_slug"), nil
  25. }
  26. data, apiErr := planeV2Svc.ListProjects(slug)
  27. return planeRawResult(data, apiErr, "列出项目")
  28. }
  29. func handlePlaneV2GetProject(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  30. slug, _ := req.RequireString("workspace_slug")
  31. projectId, err := req.RequireString("project_id")
  32. if err != nil {
  33. return helper.ParamError("project_id"), nil
  34. }
  35. data, apiErr := planeV2Svc.GetProject(slug, projectId)
  36. return planeRawResult(data, apiErr, "获取项目详情")
  37. }
  38. // === Issue Handlers ===
  39. func handlePlaneV2ListIssues(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  40. slug, _ := req.RequireString("workspace_slug")
  41. projectId, _ := req.RequireString("project_id")
  42. data, err := planeV2Svc.ListIssues(slug, projectId)
  43. return planeRawResult(data, err, "列出工作项")
  44. }
  45. func handlePlaneV2GetIssue(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  46. slug, _ := req.RequireString("workspace_slug")
  47. projectId, _ := req.RequireString("project_id")
  48. issueId, err := req.RequireString("issue_id")
  49. if err != nil {
  50. return helper.ParamError("issue_id"), nil
  51. }
  52. data, apiErr := planeV2Svc.GetIssue(slug, projectId, issueId)
  53. return planeRawResult(data, apiErr, "获取工作项详情")
  54. }
  55. func handlePlaneV2GetSubIssues(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  56. slug, _ := req.RequireString("workspace_slug")
  57. projectId, _ := req.RequireString("project_id")
  58. issueId, err := req.RequireString("issue_id")
  59. if err != nil {
  60. return helper.ParamError("issue_id"), nil
  61. }
  62. data, apiErr := planeV2Svc.GetSubIssues(slug, projectId, issueId)
  63. return planeRawResult(data, apiErr, "获取子工作项")
  64. }
  65. func handlePlaneV2GetIssueActivity(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  66. slug, _ := req.RequireString("workspace_slug")
  67. projectId, _ := req.RequireString("project_id")
  68. issueId, err := req.RequireString("issue_id")
  69. if err != nil {
  70. return helper.ParamError("issue_id"), nil
  71. }
  72. data, apiErr := planeV2Svc.GetIssueActivity(slug, projectId, issueId)
  73. return planeRawResult(data, apiErr, "获取工作项活动历史")
  74. }
  75. // === Intake Handlers ===
  76. func handlePlaneV2ListIntakeIssues(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  77. slug, _ := req.RequireString("workspace_slug")
  78. projectId, _ := req.RequireString("project_id")
  79. status := req.GetString("status", "")
  80. data, err := planeV2Svc.ListIntakeIssues(slug, projectId, status)
  81. return planeRawResult(data, err, "列出收件箱工作项")
  82. }
  83. func handlePlaneV2GetIntakeIssue(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  84. slug, _ := req.RequireString("workspace_slug")
  85. projectId, _ := req.RequireString("project_id")
  86. issueId, err := req.RequireString("issue_id")
  87. if err != nil {
  88. return helper.ParamError("issue_id"), nil
  89. }
  90. data, apiErr := planeV2Svc.GetIntakeIssue(slug, projectId, issueId)
  91. return planeRawResult(data, apiErr, "获取收件箱工作项详情")
  92. }
  93. // === Cycle Handlers ===
  94. func handlePlaneV2ListCycles(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  95. slug, _ := req.RequireString("workspace_slug")
  96. projectId, _ := req.RequireString("project_id")
  97. data, err := planeV2Svc.ListCycles(slug, projectId)
  98. return planeRawResult(data, err, "列出周期")
  99. }
  100. func handlePlaneV2GetCycle(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  101. slug, _ := req.RequireString("workspace_slug")
  102. projectId, _ := req.RequireString("project_id")
  103. cycleId, err := req.RequireString("cycle_id")
  104. if err != nil {
  105. return helper.ParamError("cycle_id"), nil
  106. }
  107. data, apiErr := planeV2Svc.GetCycle(slug, projectId, cycleId)
  108. return planeRawResult(data, apiErr, "获取周期详情")
  109. }
  110. // === Module Handlers ===
  111. func handlePlaneV2ListModules(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  112. slug, _ := req.RequireString("workspace_slug")
  113. projectId, _ := req.RequireString("project_id")
  114. data, err := planeV2Svc.ListModules(slug, projectId)
  115. return planeRawResult(data, err, "列出模块")
  116. }
  117. func handlePlaneV2GetModule(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  118. slug, _ := req.RequireString("workspace_slug")
  119. projectId, _ := req.RequireString("project_id")
  120. moduleId, err := req.RequireString("module_id")
  121. if err != nil {
  122. return helper.ParamError("module_id"), nil
  123. }
  124. data, apiErr := planeV2Svc.GetModule(slug, projectId, moduleId)
  125. return planeRawResult(data, apiErr, "获取模块详情")
  126. }
  127. // === Label Handlers ===
  128. func handlePlaneV2ListLabels(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  129. slug, _ := req.RequireString("workspace_slug")
  130. projectId, _ := req.RequireString("project_id")
  131. data, err := planeV2Svc.ListLabels(slug, projectId)
  132. return planeRawResult(data, err, "列出标签")
  133. }
  134. // === State Handlers ===
  135. func handlePlaneV2ListStates(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  136. slug, _ := req.RequireString("workspace_slug")
  137. projectId, _ := req.RequireString("project_id")
  138. data, err := planeV2Svc.ListStates(slug, projectId)
  139. return planeRawResult(data, err, "列出状态")
  140. }
  141. // === Page Handlers ===
  142. func handlePlaneV2ListPages(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  143. slug, _ := req.RequireString("workspace_slug")
  144. projectId, _ := req.RequireString("project_id")
  145. data, err := planeV2Svc.ListPages(slug, projectId)
  146. return planeRawResult(data, err, "列出页面")
  147. }
  148. func handlePlaneV2GetPage(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  149. slug, _ := req.RequireString("workspace_slug")
  150. projectId, _ := req.RequireString("project_id")
  151. pageId, err := req.RequireString("page_id")
  152. if err != nil {
  153. return helper.ParamError("page_id"), nil
  154. }
  155. data, apiErr := planeV2Svc.GetPage(slug, projectId, pageId)
  156. return planeRawResult(data, apiErr, "获取页面详情")
  157. }
  158. func handlePlaneV2GetPageDescription(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  159. slug, _ := req.RequireString("workspace_slug")
  160. projectId, _ := req.RequireString("project_id")
  161. pageId, err := req.RequireString("page_id")
  162. if err != nil {
  163. return helper.ParamError("page_id"), nil
  164. }
  165. data, apiErr := planeV2Svc.GetPageDescription(slug, projectId, pageId)
  166. return planeRawResult(data, apiErr, "获取页面描述内容")
  167. }
  168. // === Member Handlers ===
  169. func handlePlaneV2ListWorkspaceMembers(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  170. slug, err := req.RequireString("workspace_slug")
  171. if err != nil {
  172. return helper.ParamError("workspace_slug"), nil
  173. }
  174. data, apiErr := planeV2Svc.ListWorkspaceMembers(slug)
  175. return planeRawResult(data, apiErr, "列出工作空间成员")
  176. }
  177. func handlePlaneV2ListProjectMembers(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  178. slug, _ := req.RequireString("workspace_slug")
  179. projectId, _ := req.RequireString("project_id")
  180. data, err := planeV2Svc.ListProjectMembers(slug, projectId)
  181. return planeRawResult(data, err, "列出项目成员")
  182. }
  183. // === Sticky Handlers ===
  184. func handlePlaneV2ListStickies(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  185. slug, err := req.RequireString("workspace_slug")
  186. if err != nil {
  187. return helper.ParamError("workspace_slug"), nil
  188. }
  189. data, apiErr := planeV2Svc.ListStickies(slug)
  190. return planeRawResult(data, apiErr, "列出便签")
  191. }