import { Client } from '@modelcontextprotocol/sdk/client/index.js';
import { StdioClientTransport } from '@modelcontextprotocol/sdk/client/stdio.js';
import { CustomerData } from './customerService.js';
export interface MCPAction {
tool: string;
input: any;
result?: any;
error?: string;
}
export class MCPClient {
private client: Client | null = null;
private transport: StdioClientTransport | null = null;
constructor(private mcpServerPath: string) { }
async initialize(): Promise<void> {
if (this.client) {
return; // Already initialized
}
console.log('[MCP Client] Initializing with server path:', this.mcpServerPath);
try {
// Create transport
const isDev = process.env.NODE_ENV === 'development';
const command = isDev ? 'npx' : 'node';
const args = isDev ? ['tsx', this.mcpServerPath] : [this.mcpServerPath];
this.transport = new StdioClientTransport({
command,
args,
env: process.env as Record<string, string>,
});
// Create client
this.client = new Client(
{
name: 'chatbot-client',
version: '1.0.0',
},
{
capabilities: {},
}
);
// Connect
await this.client.connect(this.transport);
console.log('[MCP Client] Connected successfully');
// List available tools
const tools = await this.client.listTools();
console.log('[MCP Client] Available tools:', tools.tools.map(t => t.name));
} catch (error) {
console.error('[MCP Client] Initialization error:', error);
throw error;
}
}
async getAddressByZipcode(zipcode: string): Promise<MCPAction> {
const action: MCPAction = {
tool: 'getAddressByZipcode',
input: { zipcode },
};
console.log('[MCP Client] Looking up address for zipcode:', zipcode);
try {
if (!this.client) {
await this.initialize();
}
const result = await this.client!.callTool({
name: 'getAddressByZipcode',
arguments: { zipcode } as Record<string, unknown>,
});
console.log('[MCP Client] Raw result:', JSON.stringify(result, null, 2));
// Parse the text content from MCP response
if (result && result.content && Array.isArray(result.content) && result.content.length > 0) {
const firstContent = result.content[0] as any;
if (firstContent && firstContent.text) {
action.result = JSON.parse(firstContent.text);
console.log('[MCP Client] Parsed result:', action.result);
} else {
action.result = result;
}
} else {
action.result = result;
}
} catch (error) {
console.error('[MCP Client] Error looking up address:', error);
action.error = error instanceof Error ? error.message : 'Unknown error';
}
return action;
}
async createCustomer(customerData: CustomerData): Promise<MCPAction> {
const action: MCPAction = {
tool: 'createCustomer',
input: customerData,
};
console.log('[MCP Client] Creating customer:', customerData);
try {
if (!this.client) {
await this.initialize();
}
const result = await this.client!.callTool({
name: 'createCustomer',
arguments: customerData as unknown as Record<string, unknown>,
});
console.log('[MCP Client] Raw result:', JSON.stringify(result, null, 2));
// Parse the text content from MCP response
if (result && result.content && Array.isArray(result.content) && result.content.length > 0) {
const firstContent = result.content[0] as any;
if (firstContent && firstContent.text) {
action.result = JSON.parse(firstContent.text);
console.log('[MCP Client] Parsed result:', action.result);
} else {
action.result = result;
}
} else {
action.result = result;
}
} catch (error) {
console.error('[MCP Client] Error creating customer:', error);
action.error = error instanceof Error ? error.message : 'Unknown error';
}
return action;
}
async listPaymentPlans(): Promise<MCPAction> {
const action: MCPAction = {
tool: 'list_payment_plans',
input: {},
};
console.log('[MCP Client] Fetching payment plans');
try {
if (!this.client) {
await this.initialize();
}
const result = await this.client!.callTool({
name: 'list_payment_plans',
arguments: {},
});
console.log('[MCP Client] Raw result:', JSON.stringify(result, null, 2));
// Parse the text content from MCP response
if (result && result.content && Array.isArray(result.content) && result.content.length > 0) {
const firstContent = result.content[0] as any;
if (firstContent && firstContent.text) {
action.result = JSON.parse(firstContent.text);
console.log('[MCP Client] Parsed result:', action.result);
} else {
action.result = result;
}
} else {
action.result = result;
}
} catch (error) {
console.error('[MCP Client] Error fetching payment plans:', error);
action.error = error instanceof Error ? error.message : 'Unknown error';
}
return action;
}
async listCheckoutOffers(): Promise<MCPAction> {
const action: MCPAction = {
tool: 'list_checkout_offers',
input: {},
};
console.log('[MCP Client] Fetching checkout offers');
try {
if (!this.client) {
await this.initialize();
}
const result = await this.client!.callTool({
name: 'list_checkout_offers',
arguments: {},
});
console.log('[MCP Client] Raw result:', JSON.stringify(result, null, 2));
// Parse the text content from MCP response
if (result && result.content && Array.isArray(result.content) && result.content.length > 0) {
const firstContent = result.content[0] as any;
if (firstContent && firstContent.text) {
action.result = JSON.parse(firstContent.text);
console.log('[MCP Client] Parsed result:', action.result);
} else {
action.result = result;
}
} else {
action.result = result;
}
} catch (error) {
console.error('[MCP Client] Error fetching checkout offers:', error);
action.error = error instanceof Error ? error.message : 'Unknown error';
}
return action;
}
async createPayment(paymentData: any): Promise<MCPAction> {
const action: MCPAction = {
tool: 'createPayment',
input: paymentData,
};
console.log('[MCP Client] Creating payment:', paymentData);
try {
if (!this.client) {
await this.initialize();
}
const result = await this.client!.callTool({
name: 'createPayment',
arguments: paymentData as unknown as Record<string, unknown>,
});
console.log('[MCP Client] Raw result:', JSON.stringify(result, null, 2));
// Parse the text content from MCP response
if (result && result.content && Array.isArray(result.content) && result.content.length > 0) {
const firstContent = result.content[0] as any;
if (firstContent && firstContent.text) {
action.result = JSON.parse(firstContent.text);
console.log('[MCP Client] Parsed result:', action.result);
} else {
action.result = result;
}
} else {
action.result = result;
}
} catch (error) {
console.error('[MCP Client] Error creating payment:', error);
action.error = error instanceof Error ? error.message : 'Unknown error';
}
return action;
}
async getToolsForOpenAI(): Promise<any[]> {
if (!this.client) {
await this.initialize();
}
try {
const toolsList = await this.client!.listTools();
console.log('[MCP Client] Fetched tools for OpenAI:', toolsList.tools.map(t => t.name));
// Convert MCP tools to OpenAI function calling format
return toolsList.tools.map(tool => ({
type: 'function',
function: {
name: tool.name,
description: tool.description,
parameters: tool.inputSchema,
},
}));
} catch (error) {
console.error('[MCP Client] Error fetching tools:', error);
return [];
}
}
async shutdown(): Promise<void> {
console.log('[MCP Client] Shutting down');
try {
if (this.client) {
await this.client.close();
this.client = null;
}
if (this.transport) {
await this.transport.close();
this.transport = null;
}
} catch (error) {
console.error('[MCP Client] Shutdown error:', error);
}
}
}
