// This Pine Script™ code is subject to the terms of the Mozilla Public License 2.0 at https://mozilla.org/MPL/2.0/
// © Halving32 - ( ) = valor actual | [ ] = valor teórico Benford
//    _    _       _       _             ____ ___  
//   | |  | |     | |     (_)           |___ \__ \ 
//   | |__| | __ _| |_   ___ _ __   __ _  __) | ) |
//   |  __  |/ _` | \ \ / / | '_ \ / _` ||__ < / / 
//   | |  | | (_| | |\ V /| | | | | (_| |___) / /_ 
//   |_|  |_|\__,_|_| \_/ |_|_| |_|\__, |____/____|
//                                  __/ |          
//                                 |___/           


//@version=6
// © Halving32 — Benford's Law Multi-Exchange % Change
// Compara la distribución del primer dígito del cambio % (precio o volumen)
// con la distribución teórica de Benford — hasta 8 exchanges simultáneas

indicator("Benford's Law — Multi Exchange",
     overlay          = false,
     max_bars_back    = 5000,
     max_labels_count = 500,
     max_lines_count  = 500)

// ════════════════════════════════════════════════════════════════════════
//  CONFIGURACIÓN GENERAL
// ════════════════════════════════════════════════════════════════════════
data_source   = input.string('Price', 'Fuente de Datos',
     options = ['Price', 'Volume'], group = 'General')
use_auto_bars = input.bool(true,  'Auto-ajustar Barras por Timeframe', group = 'General')
manual_len    = input.int(5000,   'Barras Manuales', minval = 100,      group = 'General')

// ════════════════════════════════════════════════════════════════════════
//  EXCHANGES
//
//  ⚠️  IMPORTANTE: TradingView valida TODOS los símbolos al cargar el script
//  sin importar si el exchange está desactivado (show=false).
//  Por eso los exchanges 5-8 usan BINANCE:BCHUSDT como placeholder seguro.
//  Para activar un exchange adicional:
//    1) Cambia su símbolo en los inputs (busca primero en TV que exista)
//    2) Activa el toggle "Visible"
//
//  Exchanges confirmados para BCH: BINANCE:BCHUSDT · BYBIT:BCHUSDT ·
//  OKX:BCHUSDT · KRAKEN:BCHUSD · BITFINEX:BCHUSD
//  Para probar: MEXC:BCHUSDT · KUCOIN:BCHUSDT · GATEIO:BCHUSDT
// ════════════════════════════════════════════════════════════════════════

// ── Exchanges activos por defecto (símbolo verificado) ─────────────────
sym1  = input.symbol('BINANCE:BCHUSDT', 'Símbolo', group = 'Exchange 1 — Binance')
c1    = input.color(color.rgb(243,186,47), 'Color',   group = 'Exchange 1 — Binance')
show1 = input.bool(true,                   'Visible', group = 'Exchange 1 — Binance')

sym2  = input.symbol('BYBIT:BCHUSDT',   'Símbolo', group = 'Exchange 2 — Bybit')
c2    = input.color(color.rgb(255,140,0),  'Color',   group = 'Exchange 2 — Bybit')
show2 = input.bool(true,                   'Visible', group = 'Exchange 2 — Bybit')

sym3  = input.symbol('OKX:BCHUSDT',     'Símbolo', group = 'Exchange 3 — OKX')
c3    = input.color(color.rgb(0,200,220),  'Color',   group = 'Exchange 3 — OKX')
show3 = input.bool(true,                   'Visible', group = 'Exchange 3 — OKX')

sym4  = input.symbol('KRAKEN:BCHUSD',   'Símbolo', group = 'Exchange 4 — Kraken')
c4    = input.color(color.rgb(100,70,220), 'Color',   group = 'Exchange 4 — Kraken')
show4 = input.bool(true,                   'Visible', group = 'Exchange 4 — Kraken')

// ── Exchanges opcionales — placeholder seguro hasta que el usuario ──────
// ── cambie el símbolo y verifique que existe en TradingView ─────────────
sym5  = input.symbol('BINANCE:BCHUSDT', 'Símbolo (prueba: BITFINEX:BCHUSD)', group = 'Exchange 5 — Opcional A')
c5    = input.color(color.rgb(0,185,75),   'Color',   group = 'Exchange 5 — Opcional A')
show5 = input.bool(false,                  'Visible (activa solo si el símbolo es válido)', group = 'Exchange 5 — Opcional A')

sym6  = input.symbol('BINANCE:BCHUSDT', 'Símbolo (prueba: MEXC:BCHUSDT)', group = 'Exchange 6 — Opcional B')
c6    = input.color(color.rgb(0,100,255),  'Color',   group = 'Exchange 6 — Opcional B')
show6 = input.bool(false,                  'Visible (activa solo si el símbolo es válido)', group = 'Exchange 6 — Opcional B')

sym7  = input.symbol('BINANCE:BCHUSDT', 'Símbolo (prueba: KUCOIN:BCHUSDT)', group = 'Exchange 7 — Opcional C')
c7    = input.color(color.rgb(0,150,100),  'Color',   group = 'Exchange 7 — Opcional C')
show7 = input.bool(false,                  'Visible (activa solo si el símbolo es válido)', group = 'Exchange 7 — Opcional C')

sym8  = input.symbol('BINANCE:BCHUSDT', 'Símbolo (prueba: GATEIO:BCHUSDT)', group = 'Exchange 8 — Opcional D')
c8    = input.color(color.rgb(210,50,140), 'Color',   group = 'Exchange 8 — Opcional D')
show8 = input.bool(false,                  'Visible (activa solo si el símbolo es válido)', group = 'Exchange 8 — Opcional D')

// ════════════════════════════════════════════════════════════════════════
//  BARRAS MÁXIMAS POR TIMEFRAME
// ════════════════════════════════════════════════════════════════════════
get_max_bars() =>
    int r = 5000
    if use_auto_bars
        if timeframe.isseconds
            r := 1000
        else if timeframe.isminutes
            m = timeframe.multiplier
            r := m <= 5 ? 5000 : m <= 15 ? 3000 : 2000
        else if timeframe.isdaily
            r := 2000
        else if timeframe.isweekly
            r := 1000
        else if timeframe.ismonthly
            r := 500
    else
        r := manual_len
    r

len = get_max_bars()

// ════════════════════════════════════════════════════════════════════════
//  DISTRIBUCIÓN TEÓRICA DE BENFORD
// ════════════════════════════════════════════════════════════════════════
benford = array.from(0.301, 0.176, 0.125, 0.097, 0.079, 0.067, 0.058, 0.051, 0.046)

// ════════════════════════════════════════════════════════════════════════
//  FUNCIONES AUXILIARES
// ════════════════════════════════════════════════════════════════════════
get_leading_digit(val) =>
    s = str.tostring(math.abs(val))
    int found = 0
    for k = 0 to str.length(s) - 1
        ch = str.substring(s, k, k + 1)
        if str.contains('123456789', ch)
            found := int(str.tonumber(ch))
            break
    found

safe_pct(curr, prev) =>
    na(curr) or na(prev) or prev == 0.0
         ? 0.0
         : math.abs((curr - prev) / prev * 100.0)

count_digit(dc, pct) =>
    int added = 0
    if pct > 0.0
        dg = get_leading_digit(pct)
        if dg >= 1 and dg <= 9
            array.set(dc, dg - 1, array.get(dc, dg - 1) + 1)
            added := 1
    added

get_ex_name(sym) =>
    p = str.split(sym, ':')
    array.size(p) >= 2 ? array.get(p, 0) : sym

// ════════════════════════════════════════════════════════════════════════
//  FETCH DATA — close y volume separados por exchange
//  Todos los símbolos default son VÁLIDOS → no puede haber "Símbolo incorrecto"
//  al cargar el script con la configuración por defecto.
// ════════════════════════════════════════════════════════════════════════
p1 = request.security(sym1, timeframe.period, close,  barmerge.gaps_off, barmerge.lookahead_off)
p2 = request.security(sym2, timeframe.period, close,  barmerge.gaps_off, barmerge.lookahead_off)
p3 = request.security(sym3, timeframe.period, close,  barmerge.gaps_off, barmerge.lookahead_off)
p4 = request.security(sym4, timeframe.period, close,  barmerge.gaps_off, barmerge.lookahead_off)
p5 = request.security(sym5, timeframe.period, close,  barmerge.gaps_off, barmerge.lookahead_off)
p6 = request.security(sym6, timeframe.period, close,  barmerge.gaps_off, barmerge.lookahead_off)
p7 = request.security(sym7, timeframe.period, close,  barmerge.gaps_off, barmerge.lookahead_off)
p8 = request.security(sym8, timeframe.period, close,  barmerge.gaps_off, barmerge.lookahead_off)

v1 = request.security(sym1, timeframe.period, volume, barmerge.gaps_off, barmerge.lookahead_off)
v2 = request.security(sym2, timeframe.period, volume, barmerge.gaps_off, barmerge.lookahead_off)
v3 = request.security(sym3, timeframe.period, volume, barmerge.gaps_off, barmerge.lookahead_off)
v4 = request.security(sym4, timeframe.period, volume, barmerge.gaps_off, barmerge.lookahead_off)
v5 = request.security(sym5, timeframe.period, volume, barmerge.gaps_off, barmerge.lookahead_off)
v6 = request.security(sym6, timeframe.period, volume, barmerge.gaps_off, barmerge.lookahead_off)
v7 = request.security(sym7, timeframe.period, volume, barmerge.gaps_off, barmerge.lookahead_off)
v8 = request.security(sym8, timeframe.period, volume, barmerge.gaps_off, barmerge.lookahead_off)

_use_price = data_source == 'Price'
d1 = _use_price ? p1 : v1
d2 = _use_price ? p2 : v2
d3 = _use_price ? p3 : v3
d4 = _use_price ? p4 : v4
d5 = _use_price ? p5 : v5
d6 = _use_price ? p6 : v6
d7 = _use_price ? p7 : v7
d8 = _use_price ? p8 : v8

// ════════════════════════════════════════════════════════════════════════
//  CONTADORES PERSISTENTES
// ════════════════════════════════════════════════════════════════════════
var array<int> dc1 = array.new_int(9, 0)
var array<int> dc2 = array.new_int(9, 0)
var array<int> dc3 = array.new_int(9, 0)
var array<int> dc4 = array.new_int(9, 0)
var array<int> dc5 = array.new_int(9, 0)
var array<int> dc6 = array.new_int(9, 0)
var array<int> dc7 = array.new_int(9, 0)
var array<int> dc8 = array.new_int(9, 0)
var int t1 = 0
var int t2 = 0
var int t3 = 0
var int t4 = 0
var int t5 = 0
var int t6 = 0
var int t7 = 0
var int t8 = 0

// ════════════════════════════════════════════════════════════════════════
//  OBJETOS VISUALES (cleanup en tiempo real)
// ════════════════════════════════════════════════════════════════════════
var array<line>  v_lines  = array.new<line>()
var array<label> v_labels = array.new<label>()

// ════════════════════════════════════════════════════════════════════════
//  TABLA LEYENDA
// ════════════════════════════════════════════════════════════════════════
var table legend_tbl = table.new(
     position.top_right, 3, 10,
     bgcolor      = color.new(color.black, 20),
     border_width = 1,
     border_color = color.new(color.white, 55),
     frame_width  = 1,
     frame_color  = color.new(color.white, 25))

fill_legend_row(tbl_ref, row, name, clr, total, visible) =>
    tc    = visible ? color.white : color.new(color.white, 65)
    dot_c = visible ? clr         : color.new(clr, 70)
    bg    = color.new(color.black, 40)
    table.cell(tbl_ref, 0, row, name,
         text_color = tc,    text_size = size.small,
         bgcolor    = bg,    text_halign = text.align_left)
    table.cell(tbl_ref, 1, row, '●',
         text_color = dot_c, text_size = size.normal,
         bgcolor    = bg,    text_halign = text.align_center)
    table.cell(tbl_ref, 2, row, str.tostring(total, '#'),
         text_color = tc,    text_size = size.small,
         bgcolor    = bg,    text_halign = text.align_right)

// ════════════════════════════════════════════════════════════════════════
//  LÓGICA PRINCIPAL — solo en última barra
// ════════════════════════════════════════════════════════════════════════
if barstate.islast and bar_index >= len

    // ── 1. Cleanup ─────────────────────────────────────────────────────
    for l in v_lines
        line.delete(l)
    array.clear(v_lines)
    for lb in v_labels
        label.delete(lb)
    array.clear(v_labels)

    // ── 2. Reset contadores ────────────────────────────────────────────
    for i = 0 to 8
        array.set(dc1, i, 0)
        array.set(dc2, i, 0)
        array.set(dc3, i, 0)
        array.set(dc4, i, 0)
        array.set(dc5, i, 0)
        array.set(dc6, i, 0)
        array.set(dc7, i, 0)
        array.set(dc8, i, 0)
    t1 := 0
    t2 := 0
    t3 := 0
    t4 := 0
    t5 := 0
    t6 := 0
    t7 := 0
    t8 := 0

    // ── 3. Recolección ─────────────────────────────────────────────────
    for i = 1 to len - 1
        if show1
            t1 += count_digit(dc1, safe_pct(d1[i], d1[i + 1]))
        if show2
            t2 += count_digit(dc2, safe_pct(d2[i], d2[i + 1]))
        if show3
            t3 += count_digit(dc3, safe_pct(d3[i], d3[i + 1]))
        if show4
            t4 += count_digit(dc4, safe_pct(d4[i], d4[i + 1]))
        if show5
            t5 += count_digit(dc5, safe_pct(d5[i], d5[i + 1]))
        if show6
            t6 += count_digit(dc6, safe_pct(d6[i], d6[i + 1]))
        if show7
            t7 += count_digit(dc7, safe_pct(d7[i], d7[i + 1]))
        if show8
            t8 += count_digit(dc8, safe_pct(d8[i], d8[i + 1]))

    // ── 4. Distribuciones porcentuales ─────────────────────────────────
    ap1 = array.new_float(9, 0.0)
    ap2 = array.new_float(9, 0.0)
    ap3 = array.new_float(9, 0.0)
    ap4 = array.new_float(9, 0.0)
    ap5 = array.new_float(9, 0.0)
    ap6 = array.new_float(9, 0.0)
    ap7 = array.new_float(9, 0.0)
    ap8 = array.new_float(9, 0.0)
    for i = 0 to 8
        array.set(ap1, i, t1 > 0 ? array.get(dc1, i) / float(t1) : 0.0)
        array.set(ap2, i, t2 > 0 ? array.get(dc2, i) / float(t2) : 0.0)
        array.set(ap3, i, t3 > 0 ? array.get(dc3, i) / float(t3) : 0.0)
        array.set(ap4, i, t4 > 0 ? array.get(dc4, i) / float(t4) : 0.0)
        array.set(ap5, i, t5 > 0 ? array.get(dc5, i) / float(t5) : 0.0)
        array.set(ap6, i, t6 > 0 ? array.get(dc6, i) / float(t6) : 0.0)
        array.set(ap7, i, t7 > 0 ? array.get(dc7, i) / float(t7) : 0.0)
        array.set(ap8, i, t8 > 0 ? array.get(dc8, i) / float(t8) : 0.0)

    // ── 5. Parámetros de dibujo ────────────────────────────────────────
    bar_spc = 5
    base_x  = bar_index + 10
    max_y   = 32.0

    // ── 6. Ejes ────────────────────────────────────────────────────────
    array.push(v_lines, line.new(base_x, 0, base_x + 8 * bar_spc, 0, color = color.white, width = 2))
    array.push(v_lines, line.new(base_x, 0, base_x, max_y,         color = color.white, width = 2))

    // ── 7. Etiquetas de dígito y guías ────────────────────────────────
    for i = 0 to 8
        xp  = base_x + i * bar_spc
        bv  = array.get(benford, i) * 100
        lbl = str.tostring(i + 1) + '\n[' + str.tostring(bv, '#.#') + '%]'
        array.push(v_labels, label.new(xp, -5.5, lbl,
             color     = color.new(color.gray, 30),
             style     = label.style_label_up,
             textcolor = color.white,
             textalign = text.align_center,
             size      = size.small))
        array.push(v_lines, line.new(xp, 0.0, xp, bv,
             color = color.new(color.white, 55), width = 3))

    // ── 8. Título ──────────────────────────────────────────────────────
    array.push(v_labels, label.new(
         base_x + 4 * bar_spc, max_y + 2.0,
         "Benford's Law — 1er Dígito del Cambio % (" + data_source + ")",
         color     = color.new(color.black, 100),
         style     = label.style_none,
         textcolor = color.new(color.white, 10),
         textalign = text.align_center,
         size      = size.normal))

    // ── 9. Línea Benford (roja punteada) ───────────────────────────────
    for i = 0 to 7
        x1 = base_x + i * bar_spc
        x2 = base_x + (i + 1) * bar_spc
        y1 = array.get(benford, i) * 100
        y2 = array.get(benford, i + 1) * 100
        array.push(v_lines, line.new(x1, y1, x2, y2,
             color = color.red, width = 3, style = line.style_dashed))

    // ── 10. Líneas por exchange ────────────────────────────────────────
    if show1
        for i = 0 to 7
            array.push(v_lines, line.new(
                 base_x + i * bar_spc,       array.get(ap1, i) * 100,
                 base_x + (i + 1) * bar_spc, array.get(ap1, i + 1) * 100,
                 color = c1, width = 2))
    if show2
        for i = 0 to 7
            array.push(v_lines, line.new(
                 base_x + i * bar_spc,       array.get(ap2, i) * 100,
                 base_x + (i + 1) * bar_spc, array.get(ap2, i + 1) * 100,
                 color = c2, width = 2))
    if show3
        for i = 0 to 7
            array.push(v_lines, line.new(
                 base_x + i * bar_spc,       array.get(ap3, i) * 100,
                 base_x + (i + 1) * bar_spc, array.get(ap3, i + 1) * 100,
                 color = c3, width = 2))
    if show4
        for i = 0 to 7
            array.push(v_lines, line.new(
                 base_x + i * bar_spc,       array.get(ap4, i) * 100,
                 base_x + (i + 1) * bar_spc, array.get(ap4, i + 1) * 100,
                 color = c4, width = 2))
    if show5
        for i = 0 to 7
            array.push(v_lines, line.new(
                 base_x + i * bar_spc,       array.get(ap5, i) * 100,
                 base_x + (i + 1) * bar_spc, array.get(ap5, i + 1) * 100,
                 color = c5, width = 2))
    if show6
        for i = 0 to 7
            array.push(v_lines, line.new(
                 base_x + i * bar_spc,       array.get(ap6, i) * 100,
                 base_x + (i + 1) * bar_spc, array.get(ap6, i + 1) * 100,
                 color = c6, width = 2))
    if show7
        for i = 0 to 7
            array.push(v_lines, line.new(
                 base_x + i * bar_spc,       array.get(ap7, i) * 100,
                 base_x + (i + 1) * bar_spc, array.get(ap7, i + 1) * 100,
                 color = c7, width = 2))
    if show8
        for i = 0 to 7
            array.push(v_lines, line.new(
                 base_x + i * bar_spc,       array.get(ap8, i) * 100,
                 base_x + (i + 1) * bar_spc, array.get(ap8, i + 1) * 100,
                 color = c8, width = 2))

    // ── 11. Tabla Leyenda ──────────────────────────────────────────────
    bg_h = color.new(color.navy, 40)
    table.cell(legend_tbl, 0, 0, 'Exchange',
         text_color = color.white, text_size = size.small,
         bgcolor = bg_h, text_halign = text.align_left)
    table.cell(legend_tbl, 1, 0, '●',
         text_color = color.white, text_size = size.small,
         bgcolor = bg_h, text_halign = text.align_center)
    table.cell(legend_tbl, 2, 0, 'N',
         text_color = color.white, text_size = size.small,
         bgcolor = bg_h, text_halign = text.align_right)

    fill_legend_row(legend_tbl, 1, get_ex_name(sym1), c1, t1, show1)
    fill_legend_row(legend_tbl, 2, get_ex_name(sym2), c2, t2, show2)
    fill_legend_row(legend_tbl, 3, get_ex_name(sym3), c3, t3, show3)
    fill_legend_row(legend_tbl, 4, get_ex_name(sym4), c4, t4, show4)
    fill_legend_row(legend_tbl, 5, get_ex_name(sym5), c5, t5, show5)
    fill_legend_row(legend_tbl, 6, get_ex_name(sym6), c6, t6, show6)
    fill_legend_row(legend_tbl, 7, get_ex_name(sym7), c7, t7, show7)
    fill_legend_row(legend_tbl, 8, get_ex_name(sym8), c8, t8, show8)

    bg_b = color.new(color.black, 40)
    table.cell(legend_tbl, 0, 9, 'Benford (ref.)',
         text_color = color.red, text_size = size.small,
         bgcolor = bg_b, text_halign = text.align_left)
    table.cell(legend_tbl, 1, 9, '- -',
         text_color = color.new(color.red, 20), text_size = size.small,
         bgcolor = bg_b, text_halign = text.align_center)
    table.cell(legend_tbl, 2, 9, '—',
         text_color = color.red, text_size = size.small,
         bgcolor = bg_b, text_halign = text.align_right)

// ════════════════════════════════════════════════════════════════════════
//  ESCALA (invisible — ancla el eje Y)
// ════════════════════════════════════════════════════════════════════════
plot(32, color = color.new(color.white, 100), title = 'Scale Max')
plot(-8, color = color.new(color.white, 100), title = 'Scale Min')