#!/usr/bin/env node
import { Server } from "@modelcontextprotocol/sdk/server/index.js";
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
import {
CallToolRequestSchema,
ListToolsRequestSchema,
} from "@modelcontextprotocol/sdk/types.js";
import {
listChannels,
getChannelInfo,
getChannelMembers,
channelToolDefinitions,
} from "./tools/channels.js";
import {
getMessages,
getThreadReplies,
sendMessage,
searchMessages,
messageToolDefinitions,
} from "./tools/messages.js";
import {
listUsers,
getUserInfo,
getUserProfile,
userToolDefinitions,
} from "./tools/users.js";
import {
listFiles,
getFileInfo,
uploadFile,
fileToolDefinitions,
} from "./tools/files.js";
import {
addReaction,
removeReaction,
getReactions,
reactionToolDefinitions,
} from "./tools/reactions.js";
import {
listWorkspaces,
switchWorkspace,
getCurrentWorkspace,
workspaceToolDefinitions,
} from "./tools/workspaces.js";
import { SlackClientError } from "./slack-client.js";
const server = new Server(
{
name: "slack-mcp",
version: "1.0.0",
},
{
capabilities: {
tools: {},
},
}
);
const allToolDefinitions = [
...workspaceToolDefinitions,
...channelToolDefinitions,
...messageToolDefinitions,
...userToolDefinitions,
...fileToolDefinitions,
...reactionToolDefinitions,
];
server.setRequestHandler(ListToolsRequestSchema, async () => {
return {
tools: allToolDefinitions,
};
});
server.setRequestHandler(CallToolRequestSchema, async (request) => {
const { name, arguments: args } = request.params;
try {
let result: unknown;
switch (name) {
// Workspace tools
case "slack_list_workspaces":
result = listWorkspaces();
break;
case "slack_switch_workspace":
result = switchWorkspace(args?.team_id as string);
break;
case "slack_get_current_workspace":
result = getCurrentWorkspace();
break;
// Channel tools
case "slack_list_channels":
result = await listChannels({
types: args?.types as string,
excludeArchived: args?.exclude_archived as boolean,
limit: args?.limit as number,
cursor: args?.cursor as string,
});
break;
case "slack_get_channel_info":
result = await getChannelInfo(args?.channel_id as string);
break;
case "slack_get_channel_members":
result = await getChannelMembers(args?.channel_id as string, {
limit: args?.limit as number,
cursor: args?.cursor as string,
});
break;
// Message tools
case "slack_get_messages":
result = await getMessages(args?.channel_id as string, {
limit: args?.limit as number,
cursor: args?.cursor as string,
oldest: args?.oldest as string,
latest: args?.latest as string,
});
break;
case "slack_get_thread_replies":
result = await getThreadReplies(
args?.channel_id as string,
args?.thread_ts as string,
{
limit: args?.limit as number,
cursor: args?.cursor as string,
}
);
break;
case "slack_send_message":
result = await sendMessage(
args?.channel_id as string,
args?.text as string,
{
threadTs: args?.thread_ts as string,
}
);
break;
case "slack_reply_to_thread":
result = await sendMessage(
args?.channel_id as string,
args?.text as string,
{
threadTs: args?.thread_ts as string,
}
);
break;
case "slack_search_messages":
result = await searchMessages(args?.query as string, {
count: args?.count as number,
page: args?.page as number,
sortBy: args?.sort_by as "score" | "timestamp",
sortDir: args?.sort_dir as "asc" | "desc",
});
break;
// User tools
case "slack_list_users":
result = await listUsers({
limit: args?.limit as number,
cursor: args?.cursor as string,
});
break;
case "slack_get_user_info":
result = await getUserInfo(args?.user_id as string);
break;
case "slack_get_user_profile":
result = await getUserProfile(args?.user_id as string);
break;
// File tools
case "slack_list_files":
result = await listFiles({
channel: args?.channel as string,
user: args?.user as string,
types: args?.types as string,
count: args?.count as number,
page: args?.page as number,
});
break;
case "slack_get_file_info":
result = await getFileInfo(args?.file_id as string);
break;
case "slack_upload_file":
result = await uploadFile({
channels: args?.channel_id as string,
content: args?.content as string,
filename: args?.filename as string,
title: args?.title as string,
initialComment: args?.initial_comment as string,
threadTs: args?.thread_ts as string,
});
break;
// Reaction tools
case "slack_add_reaction":
result = await addReaction(
args?.channel_id as string,
args?.timestamp as string,
args?.emoji as string
);
break;
case "slack_remove_reaction":
result = await removeReaction(
args?.channel_id as string,
args?.timestamp as string,
args?.emoji as string
);
break;
case "slack_get_reactions":
result = await getReactions(
args?.channel_id as string,
args?.timestamp as string
);
break;
default:
return {
content: [
{
type: "text",
text: JSON.stringify({ error: `Unknown tool: ${name}` }),
},
],
isError: true,
};
}
return {
content: [
{
type: "text",
text: JSON.stringify(result, null, 2),
},
],
};
} catch (error) {
const errorMessage =
error instanceof SlackClientError
? `Slack API Error (${error.code}): ${error.message}`
: error instanceof Error
? error.message
: "An unknown error occurred";
return {
content: [
{
type: "text",
text: JSON.stringify({ error: errorMessage }),
},
],
isError: true,
};
}
});
async function main() {
const transport = new StdioServerTransport();
await server.connect(transport);
console.error("Slack MCP Server running on stdio");
}
main().catch((error) => {
console.error("Fatal error:", error);
process.exit(1);
});
