Fájl részletek

Előnézet (első 120 sor)

import json
import os
import freqtrade_ui
import tempfile
import hashlib
import subprocess
import csv
from datetime import datetime, timezone

from flask import Flask, jsonify, render_template, Response, redirect, request

from rules_loader import (
    load_rules_doc,
    save_rules_doc,
    load_lab_override_doc,
    save_lab_override_doc,
    list_lab_profiles,
)
from rules_merge import build_effective_rules


APP_DIR = os.path.dirname(os.path.abspath(__file__))
ROOT_DIR = os.path.abspath(os.path.join(APP_DIR, ".."))

STATE_PATH = os.path.join(ROOT_DIR, "state.json")
FREQTRADE_CONFIG_PATH = os.path.join(ROOT_DIR, "freqtrade", "user_data", "config.json")
SETTINGS_ENV_FILE = "/etc/systemd/system/saturnus-runner.service.d/30-canonical-env.conf"

POLL_INTERVAL_MS = 15000

MONITOR_DATA_DIR = "/opt/bots/saturnus_monitor/data"
MONITOR_PRICES_CSV = os.path.join(MONITOR_DATA_DIR, "prices.csv")


def _parse_iso_ts(value: str):
    if not value:
        return None
    raw = str(value).strip()
    try:
        if raw.endswith("Z"):
            return datetime.fromisoformat(raw.replace("Z", "+00:00"))
        return datetime.fromisoformat(raw)
    except Exception:
        return None


def load_chart_history_from_prices_csv(days: int = 10, short_days: int = 1, long_days: int = 10):
    rows = []
    try:
        with open(MONITOR_PRICES_CSV, "r", encoding="utf-8") as f:
            reader = csv.DictReader(f)
            for row in reader:
                ts = _parse_iso_ts(row.get("timestamp_utc"))
                if ts is None:
                    continue
                try:
                    last = float(row.get("last"))
                except Exception:
                    continue
                rows.append((ts, last))
    except Exception as e:
        return {
            "ok": False,
            "error": "prices_csv_unavailable",
            "detail": str(e),
            "labels": [],
            "price": [],
            "ma_short": [],
            "ma_long": [],
        }

    if not rows:
        return {
            "ok": False,
            "error": "prices_csv_empty",
            "labels": [],
            "price": [],
            "ma_short": [],
            "ma_long": [],
        }

    rows.sort(key=lambda x: x[0])

    # perces gyertyásítás: adott perc utolsó ára maradjon meg
    minute_map = {}
    minute_order = []
    for ts, last in rows:
        minute_ts = ts.replace(second=0, microsecond=0)
        key = minute_ts.isoformat()
        if key not in minute_map:
            minute_order.append(key)
        minute_map[key] = (minute_ts, last)

    minute_rows = [minute_map[k] for k in minute_order]
    if not minute_rows:
        return {
            "ok": False,
            "error": "minute_rows_empty",
            "labels": [],
            "price": [],
            "ma_short": [],
            "ma_long": [],
        }

    max_ts = minute_rows[-1][0]
    cutoff = max_ts.timestamp() - (int(days) * 86400)

    filtered = [(ts, last) for ts, last in minute_rows if ts.timestamp() >= cutoff]
    if not filtered:
        filtered = minute_rows[-min(len(minute_rows), int(days) * 1440):]

    short_window = max(1, int(short_days) * 1440)
    long_window = max(1, int(long_days) * 1440)

    labels = []
    price = []
    ma_short = []
    ma_long = []

    short_buf = []

Csak változott diff sorok

Teljes diff