-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathmcp-wrapper.js
More file actions
117 lines (104 loc) · 2.63 KB
/
Copy pathmcp-wrapper.js
File metadata and controls
117 lines (104 loc) · 2.63 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
#!/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';
const API_KEY = process.env.SOCIALAPIS_API_KEY || process.argv[2];
const MCP_PROXY_URL = process.env.MCP_PROXY_URL || 'https://mcp.socialapis.io';
if (!API_KEY) {
console.error('Error: SOCIALAPIS_API_KEY environment variable or API key argument required');
console.error('Usage: socialapis-mcp <api-key>');
process.exit(1);
}
const server = new Server(
{
name: 'socialapis-mcp',
version: '1.0.0',
},
{
capabilities: {
tools: {},
},
}
);
// Fetch tools from server
async function getTools() {
try {
const response = await fetch(`${MCP_PROXY_URL}/tools`);
const data = await response.json();
return data.tools;
} catch (error) {
console.error('Failed to fetch tools:', error);
return [];
}
}
let cachedTools = null;
server.setRequestHandler(ListToolsRequestSchema, async () => {
if (!cachedTools) {
cachedTools = await getTools();
}
return { tools: cachedTools };
});
server.setRequestHandler(CallToolRequestSchema, async (request) => {
const { name, arguments: args } = request.params;
try {
const response = await fetch(`${MCP_PROXY_URL}/proxy`, {
method: 'POST',
headers: {
'x-api-key': API_KEY,
'Content-Type': 'application/json',
},
body: JSON.stringify({
tool: name,
arguments: args,
}),
});
const result = await response.json();
if (result.success) {
return {
content: [
{
type: 'text',
text: JSON.stringify(result.data, null, 2),
},
],
};
} else {
return {
content: [
{
type: 'text',
text: JSON.stringify(result.data || result, null, 2),
},
],
isError: true,
};
}
} catch (error) {
return {
content: [
{
type: 'text',
text: JSON.stringify({
error: error.message,
tool: name,
}),
},
],
isError: true,
};
}
});
async function main() {
const transport = new StdioServerTransport();
await server.connect(transport);
console.error('✅ SocialAPIs MCP Client running');
console.error(`🔑 Using API key: ${API_KEY.substring(0, 8)}...`);
console.error(`🌐 Proxy URL: ${MCP_PROXY_URL}`);
}
main().catch((error) => {
console.error('❌ Server error:', error);
process.exit(1);
});