import { Client } from '@modelcontextprotocol/sdk/client/index.js';
import { SSEClientTransport } from '@modelcontextprotocol/sdk/client/sse.js';
export interface ConnectedClient {
client: Client;
cleanup: () => Promise<void>;
name: string;
}
export const createClient = async (authToken: string, serverUrl: string = 'http://localhost:3006'): Promise<ConnectedClient> => {
try {
const url = new URL(`${serverUrl}/sse`);
url.searchParams.set('token', authToken);
const transport = new SSEClientTransport(url);
const client = new Client({
name: 'resource-hub-client',
version: '1.0.0',
}, {
capabilities: {
prompts: {},
resources: { subscribe: true },
tools: {}
}
});
await client.connect(transport);
return {
client,
name: 'resource-hub-client',
cleanup: async () => {
await transport.close();
}
};
} catch (error) {
console.error('Failed to connect to server:', error);
throw error;
}
};