Set Up Price Alerts

const API_KEY = 'ngm_live_YOUR_KEY';

async function getQuote(symbol) {
  const res = await fetch(
    `https://api.ngnmarket.com/v1/companies/${symbol}`,
    { headers: { Authorization: `Bearer ${API_KEY}` } }
  );
  const { data } = await res.json();
  return data; // current_price, price_change_percent, last_updated, etc.
}

import requests

API_KEY = 'ngm_live_YOUR_KEY'

def get_quote(symbol):
    res = requests.get(
        f'https://api.ngnmarket.com/v1/companies/{symbol}',
        headers={'Authorization': f'Bearer {API_KEY}'},
    )
    return res.json()['data']

function isTriggered(alert, quote) {
  const { condition, target } = alert;
  const { current_price, price_change_percent } = quote;

  switch (condition) {
    case 'above':        return current_price >= target;
    case 'below':        return current_price <= target;
    case 'change_above': return price_change_percent >= target;
    case 'change_below': return price_change_percent <= target;
    default:             return false;
  }
}

def is_triggered(alert, quote):
    condition = alert['condition']
    target    = alert['target']
    price     = quote['current_price']
    change    = quote['price_change_percent']

    if condition == 'above':        return price >= target
    if condition == 'below':        return price <= target
    if condition == 'change_above': return change >= target
    if condition == 'change_below': return change <= target
    return False

async function notify(alert, quote) {
  const message = buildMessage(alert, quote);

  // Option A: webhook
  await fetch(process.env.WEBHOOK_URL, {
    method:  'POST',
    headers: { 'Content-Type': 'application/json' },
    body:    JSON.stringify({ text: message, alert, quote }),
  });

  // Option B: log to console (replace with your email/SMS/push SDK)
  console.log(`[ALERT] ${message}`);
}

function buildMessage({ condition, target, symbol }, { current_price, price_change_percent }) {
  if (condition === 'above')        return `${symbol} hit ₦${current_price} — above your ₦${target} target`;
  if (condition === 'below')        return `${symbol} dropped to ₦${current_price} — below your ₦${target} target`;
  if (condition === 'change_above') return `${symbol} is up ${price_change_percent.toFixed(2)}% today (target: +${target}%)`;
  if (condition === 'change_below') return `${symbol} is down ${price_change_percent.toFixed(2)}% today (target: ${target}%)`;
}

import os, httpx

def notify(alert, quote):
    message = build_message(alert, quote)

    # Option A: webhook
    httpx.post(os.environ['WEBHOOK_URL'], json={
        'text': message, 'alert': alert, 'quote': quote
    })

    # Option B: print (replace with your email/SMS/push SDK)
    print(f"[ALERT] {message}")

def build_message(alert, quote):
    cond   = alert['condition']
    target = alert['target']
    sym    = alert['symbol']
    price  = quote['current_price']
    change = quote['price_change_percent']

    if cond == 'above':        return f"{sym} hit ₦{price} — above your ₦{target} target"
    if cond == 'below':        return f"{sym} dropped to ₦{price} — below your ₦{target} target"
    if cond == 'change_above': return f"{sym} is up {change:.2f}% today (target: +{target}%)"
    if cond == 'change_below': return f"{sym} is down {change:.2f}% today (target: {target}%)"

const triggered = new Set(); // prevent repeat notifications per session

async function checkAlerts() {
  for (const alert of alerts) {
    // Skip already-triggered alerts
    if (triggered.has(alert.id)) continue;

    const quote = await getQuote(alert.symbol);
    if (isTriggered(alert, quote)) {
      await notify(alert, quote);
      triggered.add(alert.id); // fire once per session
    }
  }
}

// Check every 5 minutes during market hours
const INTERVAL = 5 * 60 * 1000;
checkAlerts();
const timer = setInterval(checkAlerts, INTERVAL);

import time, threading

triggered = set()

def check_alerts():
    for alert in alerts:
        if alert['id'] in triggered:
            continue
        quote = get_quote(alert['symbol'])
        if is_triggered(alert, quote):
            notify(alert, quote)
            triggered.add(alert['id'])

def run_checker(interval_seconds=300):
    while True:
        check_alerts()
        time.sleep(interval_seconds)

# Run in background thread
thread = threading.Thread(target=run_checker, daemon=True)
thread.start()