MCP server

import { Client } from "@modelcontextprotocol/sdk/client/index.js";
import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";

const client = new Client({ name: "my-app", version: "1.0.0" });
await client.connect(
  new StreamableHTTPClientTransport(new URL("https://ai.realmarketapi.com/mcp"))
);

// Live price
const price = await client.callTool({
  name: "get_price",
  arguments: { symbolCode: "EURUSD", timeframe: "H1", apiKey: "YOUR_API_KEY" }
});
console.log(JSON.parse(price.content[0].text));

// RSI(14)
const rsi = await client.callTool({
  name: "get_rsi",
  arguments: { symbolCode: "EURUSD", timeframe: "H1", apiKey: "YOUR_API_KEY" }
});
console.log(JSON.parse(rsi.content[0].text));

// 24h market overview — no key needed
const baseline = await client.callTool({
  name: "get_baseline_candles",
  arguments: {}
});
console.log(JSON.parse(baseline.content[0].text));

await client.close();

import asyncio, json
from mcp import ClientSession
from mcp.client.streamable_http import streamablehttp_client

async def main():
    async with streamablehttp_client("https://ai.realmarketapi.com/mcp") as (read, write, _):
        async with ClientSession(read, write) as session:
            await session.initialize()

            # Support & resistance
            result = await session.call_tool("get_support_resistance", {
                "symbolCode": "BTCUSD",
                "timeframe": "H4",
                "apiKey": "YOUR_API_KEY"
            })
            data = json.loads(result.content[0].text)
            print(data["supports"])

            # Historical data
            result = await session.call_tool("get_history", {
                "symbolCode": "EURUSD",
                "startTime": "2025-03-01T00:00:00Z",
                "endTime":   "2025-03-19T00:00:00Z",
                "apiKey": "YOUR_API_KEY",
                "pageSize": 100
            })
            history = json.loads(result.content[0].text)
            print(f"Total candles: {history['totalCount']}")

asyncio.run(main())

# Step 1 — Initialize (save Mcp-Session-Id header)
POST /mcp  Content-Type: application/json
{ "jsonrpc":"2.0","id":1,"method":"initialize",
  "params":{ "protocolVersion":"2024-11-05",
             "clientInfo":{"name":"my-client","version":"1.0"},
             "capabilities":{} } }

# Step 2 — List tools
POST /mcp  Mcp-Session-Id: <id>
{ "jsonrpc":"2.0","id":2,"method":"tools/list","params":{} }

# Step 3 — Call a tool
POST /mcp  Mcp-Session-Id: <id>
{
  "jsonrpc": "2.0", "id": 3,
  "method": "tools/call",
  "params": {
    "name": "get_macd",
    "arguments": { "symbolCode":"EURUSD","timeframe":"H1","apiKey":"YOUR_API_KEY" }
  }
}