forex-scalping.com

Code: Select all

//@version=5
indicator("Strict Flat-Before-News Timer", overlay=true)

// --- Inputs ---
grp_news = "News Event Time (Exchange Timezone)"
newsHour = input.int(8, "News Hour", minval=0, maxval=23, group=grp_news)
newsMinute = input.int(30, "News Minute", minval=0, maxval=59, group=grp_news)
warnMinutes = input.int(10, "Warning Window (Mins)", minval=1, group=grp_news)

// --- Time Calculations ---
// Convert everything to minutes from midnight for easy comparison
newsTimeInMins = newsHour * 60 + newsMinute
currentBarInMins = hour * 60 + minute

// Check if the current bar falls within the strict kill window
inKillWindow = (newsTimeInMins - currentBarInMins <= warnMinutes) and (newsTimeInMins - currentBarInMins > 0)

// --- Visual & Alert Triggers ---
// Paint the background a glaring red during the warning window
bgcolor(inKillWindow ? color.new(color.red, 80) : na, title="Pre-News Kill Window")

// Trigger an alert the moment the warning window begins
if inKillWindow and not inKillWindow[1]
    alert("FLAT NOW! Tier-1 News in " + str.tostring(warnMinutes) + " minutes. Kill all orders and limits.", alert.freq_once_per_bar)

Code: Select all

//@version=5
indicator("Risk Management: Tier-1 Liquidation Protocol", overlay=true)

// --- Macro Event Configuration ---
grp_time = "Event Scheduling"
eventHour   = input.int(14, "Event Hour (0-23)", group=grp_time) 
eventMinute = input.int(30, "Event Minute (0-59)", group=grp_time)
eventTz     = input.string("America/New_York", "Event Timezone", group=grp_time)

// --- Risk Parameters ---
grp_risk = "Execution Controls"
liqWindow   = input.int(10, "Liquidation Window (Mins)", minval=1, tooltip="Enforced flat duration prior to print", group=grp_risk)
webhookMsg  = input.text('{"command": "flatten_book", "asset": "{{ticker}}", "reason": "Tier-1 Event"}', "JSON Webhook Payload", group=grp_risk)

// --- Execution Engine ---
currentHour   = hour(time, eventTz)
currentMinute = minute(time, eventTz)

// Calculate minute delta
currentTotalMins = (currentHour * 60) + currentMinute
eventTotalMins   = (eventHour * 60) + eventMinute
timeDelta = eventTotalMins - currentTotalMins

if timeDelta < 0
    timeDelta := timeDelta + 1440 // Handle session rollover

bool isLiquidationPhase = (timeDelta <= liqWindow) and (timeDelta > 0)

// --- UI & API Triggers ---
// 1. Chart Visualization: Institutional risk highlight
bgcolor(isLiquidationPhase ? color.new(#8b0000, 85) : na, title="Restricted Trading Phase")

// 2. Automated API Alert (Triggers once to execution bridge)
if isLiquidationPhase and not isLiquidationPhase[1]
    alert(webhookMsg, alert.freq_once_per_bar)

// 3. Heads-up Display (HUD) Panel
var table riskPanel = table.new(position.top_right, 2, 1, border_width=1, border_color=color.gray)

if barstate.islast
    table.cell(riskPanel, 0, 0, "TIER-1 STATUS", text_color=color.silver, bgcolor=color.new(color.black, 20), text_size=size.small)
    
    if isLiquidationPhase
        table.cell(riskPanel, 1, 0, "FLAT MANDATE ACTIVE", text_color=color.white, bgcolor=color.new(color.red, 30), text_size=size.small)
    else if timeDelta <= (liqWindow + 30) // 30-minute warning horizon
        table.cell(riskPanel, 1, 0, "T-" + str.tostring(timeDelta) + " MINS", text_color=color.white, bgcolor=color.new(color.orange, 40), text_size=size.small)
    else
        table.cell(riskPanel, 1, 0, "CLEAR", text_color=color.gray, bgcolor=color.new(color.green, 80), text_size=size.small)

Code: Select all

//@version=5
indicator("Execution State Machine: Tier-1 Liquidity Node", overlay=true)

// --- System Configuration ---
grp_event = "Event Vector"
eventHour   = input.int(14, "Event Hour (0-23)", group=grp_event) 
eventMinute = input.int(30, "Event Minute (0-59)", group=grp_event)
eventTz     = input.string("America/New_York", "Timezone", group=grp_event)

grp_params = "State Parameters"
killWindow  = input.int(10, "Pre-Event Kill Window (Min)", group=grp_params)
coolWindow  = input.int(5,  "Post-Event Cooldown (Min)", group=grp_params)

// --- Custom Data Structures ---
// Defining a state object to maintain clean architecture
type SystemState
    int   deltaMinutes
    string phaseName
    color  phaseColor
    bool   isExecutionLocked

// --- State Computation Engine ---
method evaluateState(int targetHour, int targetMin, int pre, int post) =>
    int currTotal = (hour(time, eventTz) * 60) + minute(time, eventTz)
    int evTotal   = (targetHour * 60) + targetMin
    
    int delta = evTotal - currTotal
    if delta < -720 // Handle midnight crossover
        delta := delta + 1440
    else if delta > 720
        delta := delta - 1440

    SystemState state = SystemState.new(delta, "NEUTRAL", color.new(color.gray, 80), false)
    
    if delta > 0 and delta <= (pre + 15) and delta > pre
        state.phaseName := "WARNING (T-" + str.tostring(delta) + ")"
        state.phaseColor := color.new(color.orange, 85)
    else if delta > 0 and delta <= pre
        state.phaseName := "RESTRICTED (PRE-PRINT)"
        state.phaseColor := color.new(color.maroon, 85)
        state.isExecutionLocked := true
    else if delta <= 0 and delta >= -post
        state.phaseName := "RESTRICTED (COOLDOWN)"
        state.phaseColor := color.new(color.maroon, 85)
        state.isExecutionLocked := true
        
    state

// --- Execution ---
SystemState currentState = evaluateState(eventHour, eventMinute, killWindow, coolWindow)

// Visual enforcement of the state
bgcolor(currentState.phaseColor, title="State Enforcement Background")

// --- API Contract (JSON Webhook) ---
// Formulates a robust payload for consumption by a backend (e.g., C# / REST API)
if currentState.isExecutionLocked and not currentState.isExecutionLocked[1]
    string jsonPayload = '{"action": "LOCK_DOWN", ' +
                         '"asset": "' + syminfo.ticker + '", ' +
                         '"timestamp": ' + str.tostring(timenow) + ', ' +
                         '"commands": ["CLOSE_ALL_MARKET", "CANCEL_ALL_PENDING"]}'
    alert(jsonPayload, alert.freq_once_per_bar)

if not currentState.isExecutionLocked and currentState.isExecutionLocked[1]
    string jsonPayload = '{"action": "UNLOCK", ' +
                         '"asset": "' + syminfo.ticker + '", ' +
                         '"timestamp": ' + str.tostring(timenow) + '}'
    alert(jsonPayload, alert.freq_once_per_bar)

// --- Telemetry HUD ---
var table telemetry = table.new(position.top_right, 1, 2, border_width=1, border_color=color.rgb(40,40,40))

if barstate.islast
    table.cell(telemetry, 0, 0, "EXECUTION ENGINE", text_color=color.rgb(180,180,180), bgcolor=color.rgb(20,20,20), text_size=size.small)
    table.cell(telemetry, 0, 1, currentState.phaseName, text_color=color.white, bgcolor=currentState.phaseColor, text_size=size.small)