Zerodha MCP Server

import { kc } from "../config/KiteConfig"; import axios from "axios"; import { getTokens } from "../utils/readWrite"; export async function placeOrder( variety: "amo" | "regular" | "co" | "auction" | "iceberg", tradingsymbol: string, exchange: "NSE" | "BSE", qty: Number, orderType: "BUY" | "SELL", ) { try { const data = await kc.placeOrder( variety, { exchange: exchange, tradingsymbol: tradingsymbol, transaction_type: orderType, quantity: Number(qty), product: "CNC", order_type: "MARKET" } ); // console.log(data); return data; } catch (err) { console.log(`Error in placeOrder: ${JSON.stringify(err, null, 2)}`); return err; } } export async function getHoldings() { try { const data = await kc.getHoldings(); // console.log(data); return data; } catch (err) { console.error("Error getting data:", err); return { error: "Failed to get your Holdings", err }; } } export async function getMFSIPs() { try { const { access_token } = await getTokens()!; const res = await axios.get("https://api.kite.trade/mf/sips", { headers: { "Authorization": `token ${process.env.API_KEY}:${access_token}` } }); return res.data; } catch(err) { console.error("Error getting your SIP data:", err); return { error: "Failed to get your SIP data", err }; } } export async function getMFHoldings() { try { const { access_token } = await getTokens()!; const res = await axios.get("https://api.kite.trade/mf/holdings", { headers: { "Authorization": `token ${process.env.API_KEY}:${access_token}` } }); return res.data; } catch (err: any) { console.error("Manual MF Holdings Error:", err?.response?.data || err.message); return { error: "Failed to fetch MF holdings manually", err }; } } // ! You need to pay for this via Zerodha to use this functionality export async function getStocksData(instruments: string | string[]) { try { const data = await kc.getQuote(instruments); // console.log(JSON.stringify(data, null, 5)); return data; } catch (err) { console.error("Error getting MF SIPs:", err); return { error: "Failed to get MF SIPs", err }; } }