#!/usr/bin/env node
import { Server } from '@modelcontextprotocol/sdk/server/index.js';
import { StdioServerTransport } from '@modelcontextprotocol/sdk/server/stdio.js';
import {
CallToolRequestSchema,
ListToolsRequestSchema,
ListResourcesRequestSchema,
ListResourceTemplatesRequestSchema,
ReadResourceRequestSchema,
} from '@modelcontextprotocol/sdk/types.js';
import { BitbucketOAuth } from './auth/oauth.js';
import { BitbucketClient } from './api/client.js';
import { ToolHandler, toolDefinitions } from './tools/index.js';
import { ResourceHandler } from './resources/index.js';
// Environment variable configuration
const config = {
clientId: process.env.BITBUCKET_CLIENT_ID ?? '',
clientSecret: process.env.BITBUCKET_CLIENT_SECRET ?? '',
// Support both BITBUCKET_ACCESS_TOKEN and BITBUCKET_TOKEN for backwards compatibility
accessToken: process.env.BITBUCKET_ACCESS_TOKEN ?? process.env.BITBUCKET_TOKEN,
refreshToken: process.env.BITBUCKET_REFRESH_TOKEN,
// For app password auth (Basic auth)
username: process.env.BITBUCKET_USERNAME,
};
// Create and start the MCP server
async function main(): Promise<void> {
// Initialize OAuth and client
const oauth = new BitbucketOAuth(config);
const client = new BitbucketClient(oauth);
const toolHandler = new ToolHandler(client);
const resourceHandler = new ResourceHandler(client);
// Create MCP server
const server = new Server(
{
name: 'bitbucket-mcp',
version: '1.0.0',
},
{
capabilities: {
tools: {},
resources: {},
},
}
);
// Handle tool listing
server.setRequestHandler(ListToolsRequestSchema, () => {
return Promise.resolve({
tools: toolDefinitions,
});
});
// Handle tool calls
server.setRequestHandler(CallToolRequestSchema, async (request) => {
const { name, arguments: args } = request.params;
try {
const result = await toolHandler.handleTool(name, args ?? {});
return {
content: [
{
type: 'text',
text: JSON.stringify(result, null, 2),
},
],
};
} catch (error) {
const message = error instanceof Error ? error.message : 'Unknown error';
return {
content: [
{
type: 'text',
text: `Error: ${message}`,
},
],
isError: true,
};
}
});
// Handle resource template listing
server.setRequestHandler(ListResourceTemplatesRequestSchema, () => {
return Promise.resolve({
resourceTemplates: resourceHandler.listResourceTemplates(),
});
});
// Handle resource listing (empty since resources are dynamic)
server.setRequestHandler(ListResourcesRequestSchema, () => {
return Promise.resolve({
resources: [],
});
});
// Handle resource reading
server.setRequestHandler(ReadResourceRequestSchema, async (request) => {
const { uri } = request.params;
try {
return await resourceHandler.readResource(uri);
} catch (error) {
const message = error instanceof Error ? error.message : 'Unknown error';
throw new Error(`Failed to read resource: ${message}`);
}
});
// Connect via stdio transport
const transport = new StdioServerTransport();
await server.connect(transport);
// Log to stderr so it doesn't interfere with MCP protocol
console.error('Bitbucket MCP server started');
}
// Run the server
main().catch((error) => {
console.error('Fatal error:', error);
process.exit(1);
});
