esa MCP Server

import path from "node:path"; import { type CreatePostCommentParams, type CreatePostCommentResponse, CreatePostCommentResponseSchema, type CreatePostParams, type CreatePostResponse, CreatePostResponseSchema, type DeleteCommentParams, type DeletePostParams, type GetPostCommentsParams, type GetPostCommentsResponse, GetPostCommentsResponseSchema, type GetPostParams, type GetPostResponse, GetPostResponseSchema, type GetPostsParams, type GetPostsResponse, GetPostsResponseSchema, type GetTagsParams, type GetTagsResponse, GetTagsResponseSchema, type UpdateCommentParams, type UpdateCommentResponse, UpdateCommentResponseSchema, type UpdatePostParams, type UpdatePostResponse, UpdatePostResponseSchema, } from "./types.js"; export class Esa { private readonly _teamName: string; private readonly _accessToken: string; constructor(config: { teamName: string; accessToken: string }) { this._teamName = config.teamName; this._accessToken = config.accessToken; } async getPosts(params: GetPostsParams = {}): Promise<GetPostsResponse> { const response = await this._request({ path: path.join("v1/teams", this._teamName, "posts"), method: "GET", query: params, }); const data = await response.json(); return GetPostsResponseSchema.parse(data); } async getPost(params: GetPostParams): Promise<GetPostResponse> { const { post_number, ...queryParams } = params; const response = await this._request({ path: `/v1/teams/${this._teamName}/posts/${post_number}`, method: "GET", query: queryParams, }); const data = await response.json(); return GetPostResponseSchema.parse(data); } async createPost(params: CreatePostParams): Promise<CreatePostResponse> { const response = await this._request({ path: `/v1/teams/${this._teamName}/posts`, method: "POST", body: { post: params }, }); const data = await response.json(); return CreatePostResponseSchema.parse(data); } async updatePost(params: UpdatePostParams): Promise<UpdatePostResponse> { const { post_number, ...postParams } = params; const response = await this._request({ path: `/v1/teams/${this._teamName}/posts/${post_number}`, method: "PATCH", body: { post: postParams }, }); const data = await response.json(); return UpdatePostResponseSchema.parse(data); } async getTags(params: GetTagsParams): Promise<GetTagsResponse> { const response = await this._request({ path: path.join("v1/teams", this._teamName, "tags"), method: "GET", query: params, }); const data = await response.json(); return GetTagsResponseSchema.parse(data); } async deletePost(params: DeletePostParams): Promise<void> { await this._request({ path: `/v1/teams/${this._teamName}/posts/${params.post_number}`, method: "DELETE", }); } async getPostComments( params: GetPostCommentsParams, ): Promise<GetPostCommentsResponse> { const { post_number, ...queryParams } = params; const response = await this._request({ path: `/v1/teams/${this._teamName}/posts/${post_number}/comments`, method: "GET", query: queryParams, }); const data = await response.json(); return GetPostCommentsResponseSchema.parse(data); } async createPostComment( params: CreatePostCommentParams, ): Promise<CreatePostCommentResponse> { const { post_number, ...commentParams } = params; const response = await this._request({ path: `/v1/teams/${this._teamName}/posts/${post_number}/comments`, method: "POST", body: { comment: commentParams }, }); const data = await response.json(); return CreatePostCommentResponseSchema.parse(data); } async updateComment( params: UpdateCommentParams, ): Promise<UpdateCommentResponse> { const { comment_id, ...commentParams } = params; const response = await this._request({ path: `/v1/teams/${this._teamName}/comments/${comment_id}`, method: "PATCH", body: { comment: commentParams }, }); const data = await response.json(); return UpdateCommentResponseSchema.parse(data); } async deleteComment(params: DeleteCommentParams): Promise<void> { await this._request({ path: `/v1/teams/${this._teamName}/comments/${params.comment_id}`, method: "DELETE", }); } private async _request(params: { path: string; query?: Record<string, string | number>; method: string; body?: Record<string, unknown>; }): Promise<Response> { const url = new URL("https://api.esa.io"); url.pathname = path.join(url.pathname, params.path); if (params.query) { for (const [key, value] of Object.entries(params.query)) { if (value) { url.searchParams.set(key, value.toString()); } } } const response = await fetch(url, { method: params.method, headers: { Authorization: `Bearer ${this._accessToken}`, "Content-Type": "application/json", }, body: params.body ? JSON.stringify(params.body) : undefined, }); if (!response.ok) { const text = await response.text(); throw new Error(text); } return response; } }