install_config.py

#!/usr/bin/env python3
"""
install_config.py — One-shot installer for SignalScanner v1.

Run AFTER copying the files to /Users/YOUR_USERNAME/vibe_os/signal_dashboard/.

Does:
    1. Writes Telegram token + chat_id into config.yaml
    2. Creates logs/ directory
    3. Verifies Ollama is reachable and model is loaded
    4. Does a quick ccxt connectivity test to Kraken
"""
import json
import subprocess
import sys
import time
from pathlib import Path

import requests
import yaml


TOKEN = "YOUR_TELEGRAM_BOT_TOKEN_HERE"
CHAT_ID = "YOUR_CHAT_ID_HERE"
BOT_NAME = "SignalScanner_V1_Bot"

BASE = Path("/Users/YOUR_USERNAME/vibe_os/signal_dashboard")


def step(n, msg):
    print(f"\n{'='*60}\nStep {n}: {msg}\n{'='*60}")


def main():
    if not BASE.exists():
        print(f"❌ {BASE} does not exist. Copy the files there first.")
        sys.exit(1)

    # Step 1: update config.yaml
    step(1, "Populating Telegram credentials in config.yaml")
    cfg_path = BASE / "config.yaml"
    with open(cfg_path) as f:
        cfg = yaml.safe_load(f)
    cfg["telegram"]["token"] = TOKEN
    cfg["telegram"]["chat_id"] = CHAT_ID
    cfg["telegram"]["bot_name"] = BOT_NAME
    with open(cfg_path, "w") as f:
        yaml.safe_dump(cfg, f, default_flow_style=False, sort_keys=False)
    print(f"✅ config.yaml updated — bot: @{BOT_NAME}")

    # Step 2: logs dir
    step(2, "Creating logs directory")
    (BASE / "logs").mkdir(exist_ok=True)
    print(f"✅ {BASE / 'logs'}/ ready")

    # Step 3: Ollama connectivity
    step(3, "Checking Ollama")
    try:
        r = requests.get("http://127.0.0.1:11434/api/tags", timeout=5)
        if r.status_code == 200:
            models = [m["name"] for m in r.json().get("models", [])]
            print(f"✅ Ollama reachable, models: {models}")
            if "llama3.2:3b" not in models:
                print("⚠️  llama3.2:3b not found. Run: ollama pull llama3.2:3b")
        else:
            print(f"⚠️  Ollama returned {r.status_code}")
    except requests.exceptions.ConnectionError:
        print("⚠️  Ollama not running. Start it with: ollama serve &")
    except Exception as e:
        print(f"⚠️  Ollama check failed: {e}")

    # Step 4: Kraken connectivity
    step(4, "Testing Kraken connectivity via ccxt")
    try:
        import ccxt
        ex = ccxt.kraken({"enableRateLimit": True, "timeout": 10000})
        ex.load_markets()
        ticker = ex.fetch_ticker("BTC/USDT")
        print(f"✅ Kraken reachable, BTC/USDT: ${ticker['last']:,.2f}")
    except Exception as e:
        print(f"❌ Kraken test failed: {e}")
        sys.exit(1)

    # Step 5: Telegram test
    step(5, "Testing Telegram bot")
    try:
        r = requests.post(
            f"https://api.telegram.org/bot{TOKEN}/sendMessage",
            json={
                "chat_id": CHAT_ID,
                "text": "✅ SignalScanner v1 install complete. Bot ready.",
            },
            timeout=10,
        )
        if r.status_code == 200:
            print(f"✅ Telegram message sent to chat {CHAT_ID}")
        else:
            print(f"⚠️  Telegram send returned {r.status_code}: {r.text[:200]}")
    except Exception as e:
        print(f"⚠️  Telegram test failed: {e}")

    print(f"\n{'='*60}")
    print("Install complete. Next steps:")
    print(f"{'='*60}")
    print("1. First test run (single pass, no infinite loop):")
    print(f"   cd {BASE} && python3 scanner.py --once")
    print()
    print("2. Start scanner as background process (terminal 1):")
    print(f"   cd {BASE} && python3 scanner.py")
    print()
    print("3. Open web dashboard (terminal 2):")
    print(f"   cd {BASE} && python3 web_app.py")
    print("   # Then visit http://127.0.0.1:8082")
    print()
    print("4. Open terminal dashboard (terminal 3):")
    print(f"   cd {BASE} && python3 terminal_dashboard.py")
    print()
    print("5. Start Telegram summarizer daemon (terminal 4):")
    print(f"   cd {BASE} && python3 summarizer.py --daemon")
    print("   # Then in Telegram, send '/summary' to @SignalScanner_V1_Bot")


if __name__ == "__main__":
    main()