自定义指标 API

Read the attached [AI-scripting.txt] https://mobchart.com/docs/public/AI-scripting.txt file and use it as the only reference for the MobChart scripting API.

Create a custom indicator that plots a 20-period EMA and a 50-period EMA on the chart. Color the candles green when EMA20 is above EMA50 and red otherwise.

Use only the documented API. Do not invent functions. Return the complete indicator code.

define("My Indicator", "Shows EMA line", "onchart", true, false);

define("Window max", "Label at the highest visible high", "onchart", true, true, { fullRange: true });

const length = input.number("Period", 14, 1, 100, 1);
const type = input.select("Type", 'sma', ['sma', 'ema']);
const color = input.color("Line Color", "#FF0000");

const length = style.number("Size", 14, 1, 100, 1);
const color = style.select("Background Color", '#FF0000', ["#FF0000", "#AA0000", "#BB0000"]);
const color = style.color("Background Color", "#FF0000");

[
    {
        "open": 115886.17,
        "high": 115911.96,
        "low": 115764.27,
        "close": 115815.16,
        "volume": 228.41528,
        "startTime": 1757699100000
    },
    {...},
    ...
]

[
    {
        "data": {
            "asks": {
                "109425": 5.467,
                "109495": 3.564,
                ...
            },
            "bids": {
                "33000": 3.746,
                "35000": 16.49,
                ...
            }
        },
        "startTime": 1757699100000
    },
    {...},
    ...
]

[
    {
        "data": {
            "totalBuy": 16053385,
            "totalSell": 20490989,
            "0.8654": { "buy": 286845, "sell": 336689 },
            "0.8653": { "buy": 271848, "sell": 259167 },
            "0.8652": { "buy": 318814, "sell": 373497 },
            ...
        },
        "startTime": 1757699100000
    },
    {...},
    ...
]

[
    {
        "data": {
            "totalBuy": 16053385,
            "totalSell": 20490989,
            "0.8654": { "buy": 286845, "sell": 336689 },
            "0.8653": { "buy": 271848, "sell": 259167 },
            "0.8652": { "buy": 318814, "sell": 373497 },
            ...
        },
        "startTime": 1757699100000
    },
    {...},
    ...
]

[
    {  
        "data": {
            "FR": 0.00003777, // 资金费率
            "OI": { // 未平仓合约K线
                "open": 85645.708,
                "close": 83496.225,
                "high": 85801.04,
                "low": 83397.918
            },
            "LS": { "l": 0.5426, "s": 0.4574 }, // 多空比
            "taLS": { "l": 0.552, "s": 0.448 }, // 大户账户多空比
            "tpLS": { "l": 0.5996, "s": 0.4004 } // 大户持仓多空比
        },
        "startTime": 1757699100000
    },
    {...},
    ...
]

{
    "asks": {
        "109425": 5.467,
        "109495": 3.564,
        ...
    },
    "bids": {
        "109400": 1.2,
        "109390": 0.8,
        ...
    }
}

const candles = source.ohlcv(); // exchange、ticker 和 timeframe 参数默认为当前图表。
const closes = candles.map(c => c.close);

{
    "BTCUSDT": {
        "asks": {
            "109500": {
                "price": 109500,
                "quantity": 42.5,          // 以基础资产计的数量
                "quantityUSDT": 4653750,   // 以计价货币计的数量
                "distance": 0.62,          // 与当前价格的距离，百分比
                "duration": 184,           // 订单已挂单的分钟数
                "touches": 2,
                "currentTouches": 1,
                "filledPercent": 12.4,
                "strength": 95.5,          // 百分比，参见筛选器
                "diversity": 11,
                "isContinuous": true,
                "date": "2026-10-10T06:12:03.000Z"
            },
            ...
        },
        "bids": { ... },
        "volume1hTotal": 183000000
    },
    ...
}

// 将图表市场价格附近的大单绘制为水平线，并标注数量和存续时间
const candles = await source.ohlcv();
const lastDate = candles.at(-1).startTime;
const levels = await source.levels(currentExchange, { tickers: [currentTicker], nearness: 3, size: 300000, lifespan: 30 });
const own = levels[currentTicker] || { asks: {}, bids: {} };
for (const [type, color] of [["asks", "#ef5350"], ["bids", "#26a69a"]]) {
    for (const [price, level] of Object.entries(own[type])) {
        plot.horizontalLine(`${type} ${price}`, +price, color, 0.8, Math.min(4, 1 + level.quantityUSDT / 1e6));
        plot.text(`${type} ${price} label`, `${(level.quantityUSDT / 1e6).toFixed(2)}M · ${level.duration}m`, lastDate, +price, 10, color);
    }
}

{
    ok: true,                 // 状态码 200–299
    status: 200,              // HTTP 状态码，请求未发送时为 0
    headers: { "content-type": "application/json", ... },
    data: { ... },            // 解析为 JSON 的响应体，响应体不是 JSON 时为 null
    text: "...",              // 原始响应体
    error: null               // 请求失败的原因："timeout"、"url not allowed"、"too many requests" 等
}

define("Fear & Greed", "Crypto Fear & Greed index", "offchart", true, true);

const res = http.get("https://api.alternative.me/fng/?limit=30");
if (!res.ok) logger.log("request failed:", res.status, res.error);

// res.data = { data: [{ value: "71", timestamp: "1757635200" }, ...] }
const byDay = {};
(res.data?.data || []).forEach((row) => { byDay[Number(row.timestamp) * 1000] = Number(row.value); });

const candles = source.ohlcv();
const values = candles.map((c) => c ? byDay[c.startTime - (c.startTime % 86400000)] ?? null : null);
plot.lineSeries("Fear & Greed", values, "#00C8FF");

const candles = source.ohlcv();
const last = candles.at(-1);

const res = http.post(
    "https://example.com/api/signals",
    { exchange: currentExchange, ticker: currentTicker, close: last.close },
    { headers: { "x-api-key": "YOUR_KEY" } } // 仅限私有代码
);
logger.log("signal sent:", res.ok, res.status, res.data);

const candles = source.ohlcv(currentExchange, currentTicker, currentTimeframe);
const closes = candles.map(c => c.close);

const candles = source.ohlcv();
logger.log("First candle:", candles?.[0]);

plot.text("Text object", "Hello world!", 1757699100000, 115000, 10, "#00C8FF", 0.5);
plot.straightLine(`${namePrefix} Open`, level.timeStart, level.open, level.timeEnd, level.open, color);
plot.circle(`${namePrefix} High`, level.timeStart, level.high, 3, color);

plot.lineSeries("EMA", ta.ema(closes, 20), "#00C8FF");
// 每根K线保留各自的颜色：收盘价高于 EMA 为绿色，低于为红色
plot.lineSeries("Close", closes, (v, i) => v > ema[i] ? colorBuy : colorSell);
plot.barSeries("Premium %", premiumPercents, ((d) => d > 0 ? color1 : color2), 1);
plot.candleSeries(
    "Candles",
    opens, closes, highs, lows,
    (v, i) => {
        return opens?.[i] > closes?.[i] ? colorBuy : colorSell
    }
);
plot.areaSeries("Volume", volumes, "#00C8FF", 0.3);
// 按K线着色的区域，K线越大越不透明
plot.areaSeries("Delta", deltas, (v, i) => v >= 0 ? colorBuy : colorSell, (v, i) => Math.min(1, Math.abs(v) / maxDelta));

// 收盘价与其下方 1% 之间的压力带，按该K线的失衡比率着色和设置透明度
plot.bandSeries(
    "Bid pressure",
    closes,
    closes.map(c => c * 0.99),
    (upper, lower, i) => ratios[i] > 0 ? bidColor : askColor,
    (upper, lower, i) => Math.abs(ratios[i]) / 100
);

// 图表的成交量分布，与内置工具效果相同
const rows = await source.clusters();
plot.profile("Volume", rows.map((r) => r?.data ?? null), { step: 5 });

// 仅大额成交，按 delta 着色，位于左侧边缘
const minSize = input.number("Min trade size", 50, 0, 100000, 1);
const big = rows.map((r) => {
    if (!r?.data) return null;
    const out = {};
    for (const [price, c] of Object.entries(r.data)) {
        if (price === "totalBuy" || price === "totalSell") continue;
        if (c.buy + c.sell >= minSize) out[price] = { buy: c.buy, sell: c.sell };
    }
    return out;
});
plot.profile("Large trades", big, { step: 5, delta: true, orient: "left" });

// 将实时订单簿作为右侧边缘的分布图：买盘用买入颜色，卖盘用卖出颜色
const book = await source.orderbook();
const rows = {};
for (const [price, qty] of Object.entries(book.bids)) rows[price] = { buy: qty };
for (const [price, qty] of Object.entries(book.asks)) rows[price] = { sell: qty };
plot.histogram("Order book", rows, { step: 5, width: 25, valueArea: false, poc: false });

// 自定义直方图：最近 100 根K线的集群成交量，越近的K线权重越大
const rows = await source.clusters();
const weighted = {};
rows.slice(-100).forEach((r, i, arr) => {
    if (!r?.data) return;
    const weight = (i + 1) / arr.length;
    for (const [price, c] of Object.entries(r.data)) {
        if (price === "totalBuy" || price === "totalSell") continue;
        const cell = weighted[price] || (weighted[price] = { buy: 0, sell: 0 });
        cell.buy += (c.buy || 0) * weight;
        cell.sell += (c.sell || 0) * weight;
    }
});
plot.histogram("Weighted volume", weighted, { step: 5, orient: "left", delta: true });

const candles = await source.ohlcv();
const closes = candles.map((c) => c.close);
const rsi = ta.rsi(closes, 14);
const last = rsi.at(-1);
const change = (closes.at(-1) / closes.at(-25) - 1) * 100;

plot.table("Stats", [
    ["Metric", "Value"],
    ["RSI 14", { text: last.toFixed(1), color: last > 70 ? "#ef5350" : last < 30 ? "#26a69a" : undefined }],
    ["Change 24 bars", { text: change.toFixed(2) + "%", align: "right" }],
    ["Volume", candles.slice(-24).reduce((s, c) => s + c.volume, 0).toFixed(0)],
], { position: "top-right", header: true });

const candles = source.ohlcv();
const closes = candles.map(c => c.close);
const rsiValues = ta.rsi(closes, 14);
plot.lineSeries("RSI", rsiValues, "#00C8FF");

const alertVolumeThreshold = alertInput.number("Volume threshold", 1000, 0, 10000000, 1);

if (candle.volume > alertVolumeThreshold) {
    alert.fire("High volume", `vol ${candle.volume}`, candle.startTime);
}

// 简单形式：每当图形针对新日期绘制时触发
plot.box(...).alert("High volume", `vol ${candle.volume}`);

// 回调形式：不返回任何内容则跳过，返回 [title, message] 则触发
plot.box(...).alert((shape) => {
    if (candle.volume > alertVolumeThreshold)
        alert.fire("High volume", `vol ${candle.volume}`, candle.startTime);
});

plot.lineSeries("RSI", rsiValues, color).alert((rsi, date) => {
    if (rsi > alertRsiThreshold) alert.fire("RSI high", `RSI ${rsi.toFixed(1)}`, latestCandle.startTime);
});

const title = "Volume alerts";
const description = "Shows boxes on high-volume candles";
define(title, description, "onchart", true, true);

const color = style.color("Color", "#00C8FF");
const volumeThreshold = input.number("Volume threshold", 1000, 0, 10000000, 1);
const alertVolumeThreshold = alertInput.number("Alert volume threshold", 5000, 0, 10000000, 1);
const alertCloseThreshold = alertInput.number("Alert close threshold", 100000, 0, 10000000, 1);

const candles = source.ohlcv();
const latestCandle = candles.at(-1);
const closes = candles.map(c => c.close);

// 序列提醒：检查最新收盘价
plot.lineSeries("Closes", closes, color).alert((close, date) => {
    if (close > alertCloseThreshold) alert.fire("Close above threshold", `close ${close}`, latestCandle.startTime);
});

for (let i = 0; i < candles.length; i++) {
    const candle = candles[i];

    if (candle.volume > volumeThreshold) {
        const right = i < candles.length - 1 ? candles[i + 1].startTime : candle.startTime + 60000;

        // 图形提醒：与用户的提醒阈值进行比较
        plot.box(`Volume ${i}`, candle.startTime, candle.high, right, candle.low, "#00C8FF", 0.3)
            .alert(() => {
                if (candle.volume > alertVolumeThreshold)
                    alert.fire("High volume", `vol ${candle.volume}`, candle.startTime);
            });
    }
}

const title = "Your first indicator";
const description = "Shows closes lines on the chart";
const indicatorType = "onchart";

define(title, description, indicatorType, true, true);

const color = input.color("Line Color", "#00C8FF");
const candles = source.ohlcv();
const closes = candles.map(c => c.close);
plot.lineSeries("Closes", closes, color);

define("Example Indicator", "Demonstrates basic plotting", "onchart", true, true);

const color = input.color("Line Color", "#00FF99");
const candles = source.ohlcv();
const closes = candles.map(c => c.close);

const ema20 = ta.ema(closes, 20);
plot.lineSeries("EMA 20", ema20, color);

const title = "Colored Volume Bars";  
const description = "Volumes colored based on candle direction.";  
const indicatorType = "onchart";  
const isPublic = true;  
const isPublicCode = true;  

define(title, description, indicatorType, isPublic, isPublicCode);  

// 获取 OHLC K线
const candles = source.ohlcv();  

const colorUp = style.color("Color 1", "#2BB462"); // 上涨使用的绿色
const colorDown = style.color("Color 2", "#FB4C51"); // 下跌使用的红色
const volumes = candles.map(candle => candle.volume);  

plot.barSeries("Volume", volumes, (value, index) => {
    const currentCandle = candles[index];  
    return currentCandle.close >= currentCandle.open ? colorUp : colorDown;  
});

define('Coinbase Premium Index', 'Coinbase Premium Index', 'offchart', true, false);

const color1 = style.color("Color 1", "#2BB462");
const color2 = style.color("Color 2", "#FB4C51");

// 获取 OHLC K线
const cbCandles = source.ohlcv('coinbase', 'BTC-USD');
const binanceCandles = source.ohlcv('binance', 'BTCUSDT');

// 提取收盘价
const cbCloses = cbCandles.map(c => c.close);
const binanceCloses = binanceCandles.map(c => c.close);

// --- Coinbase 溢价指数计算 ---
const premiumPercent = cbCloses.map((cb, i) => {
    const b = binanceCloses[i];
    return ((cb - b) / b) * 100;
});

// 绘制溢价指数
plot.barSeries("Premium %", premiumPercent, ((d) => d > 0 ? color1 : color2)) // 百分比差值

const title = "Candles";
const description = "Simple candles draw";
const indicatorType = "offchart";
const isPublic = true;
const isPublicCode = true;
define(title, description, indicatorType, isPublic, isPublicCode);

const colorBuy = style.color("Buy Color", "#2BB462");
const colorSell = style.color("Sell Color", "#7a3d3f");
const candles = source.ohlcv();
const closes = candles.map(c => c.close);
const opens = candles.map(c => c.open);
const highs = candles.map(c => c.high);
const lows = candles.map(c => c.low);
plot.candleSeries(
    "Candles",
    opens, closes, highs, lows,
    (v, i) => {
        return opens?.[i] > closes?.[i] ? colorBuy : colorSell
    }
);

const title = "Order Book Pressure";
const description = "Bid / ask depth imbalance bands around the price";
define(title, description, "onchart", true, true);

const minBidRatio = input.number("Min bid ratio %", 20, 0, 100, 1);
const minAskRatio = input.number("Min ask ratio %", 20, 0, 100, 1);
const depthFrom = input.select("Depth from", "0%", ["0%", "1%", "2.5%", "5%"]);
const depthTo = input.select("Depth to", "5%", ["1%", "2.5%", "5%", "10%"]);

const bidColor = style.color("Bid fill color", "#a5d6a7");
const askColor = style.color("Ask fill color", "#f1627e");
const extremeColor = style.color("Extreme color", "#ffff00");
const highlight = style.boolean("Highlight extremes", true);
const showRef = style.boolean("Show reference lines", true);

const alertMinRatio = alertInput.number("Alert min |ratio| %", 40, 0, 100, 1);

const bounds = [1, 2.5, 5, 10]; // 距收盘价的深度区间，%
const from = parseFloat(depthFrom);
const to = parseFloat(depthTo);

const candles = source.ohlcv();
const depths = source.depths();
const liveBook = source.orderbook();

// 每根K线的订单簿：depths()[i] 是 candles[i] 的快照（最大的限价单），最新K线使用实时订单簿
const lastIndex = candles.length - 1;
const books = candles.map((c, i) => {
    if (!c) return null;
    if (i === lastIndex && ta.bestBid(liveBook)) return liveBook;
    return depths[i]?.data || null;
});
const closes = candles.map(c => c ? c.close : null);

// 每个区间的失衡比率，%（正值 = 买盘占优，负值 = 卖盘占优）
const ratios = bounds.map((upper, b) => {
    const lower = b === 0 ? 0 : bounds[b - 1];
    return candles.map((c, i) => {
        const book = books[i];
        if (!c || !book) return null;
        const bid = ta.sumBids(book, upper, c.close) - ta.sumBids(book, lower, c.close);
        const ask = ta.sumAsks(book, upper, c.close) - ta.sumAsks(book, lower, c.close);
        const total = bid + ask;
        return total > 0 ? ((bid - ask) / total) * 100 : 0;
    });
});

// 比率越强 -> 带越不透明，极端比率使用极端颜色
const bandOpacity = (ratio) => Math.min(0.95, Math.abs(ratio || 0) / 70 * 0.95);
const bandColor = (ratio) => highlight && Math.abs(ratio || 0) >= 63 ? extremeColor : (ratio >= 0 ? bidColor : askColor);

bounds.forEach((upper, b) => {
    const lower = b === 0 ? 0 : bounds[b - 1];
    if (from > lower || upper > to) return; // 该区间不在所选深度范围内

    const bidUpper = closes.map(c => c != null ? c * (1 - lower / 100) : null);
    const bidLower = closes.map(c => c != null ? c * (1 - upper / 100) : null);
    const askLower = closes.map(c => c != null ? c * (1 + lower / 100) : null);
    const askUpper = closes.map(c => c != null ? c * (1 + upper / 100) : null);

    if (showRef) {
        plot.lineSeries(`Bid ${upper}%`, bidLower, bidColor, 0.4);
        plot.lineSeries(`Ask ${upper}%`, askUpper, askColor, 0.4);
    }

    // 买盘压力：仅在买盘占优超过最小比率的K线上填充该带
    plot.bandSeries(
        `Bid pressure ${lower}-${upper}%`,
        bidUpper.map((v, i) => ratios[b][i] >= minBidRatio ? v : null),
        bidLower,
        (upper, lower, i) => bandColor(ratios[b][i]),
        (upper, lower, i) => bandOpacity(ratios[b][i])
    );

    // 卖盘压力
    plot.bandSeries(
        `Ask pressure ${lower}-${upper}%`,
        askUpper.map((v, i) => ratios[b][i] <= -minAskRatio ? v : null),
        askLower,
        (upper, lower, i) => bandColor(ratios[b][i]),
        (upper, lower, i) => bandOpacity(ratios[b][i])
    );

    // 最新K线上的提醒
    const latestRatio = ratios[b][lastIndex];
    if (latestRatio != null && Math.abs(latestRatio) >= alertMinRatio) {
        alert.fire(`Pressure ${lower}-${upper}%`, `ratio ${latestRatio.toFixed(1)}%`, candles[lastIndex].startTime);
    }
});