Function api_social_watch_start

IntelOSINT.py:21817–21857

()

@app.route('/api/social/watch', methods=['POST'])
def api_social_watch_start():
    payload = request.json or {}
    target = str(payload.get('target') or "").strip()
    platform = _normalize_instagram_platform(payload.get('platform'))
    if not platform:
        return jsonify({"error": "Supportata solo la piattaforma Instagram"}), 400
    if not target:
        return jsonify({"error": "target mancante"}), 400
    try:
        interval_seconds = max(5, int(payload.get('interval_seconds') or payload.get('interval', 300)))
    except Exception:
        interval_seconds = 300
    try:
        iterations = int(payload.get('iterations') or 0)
    except Exception:
        iterations = 0
    watch_id = uuid.uuid4().hex
    now = datetime.now(timezone.utc).isoformat()
    watch = {
        "watch_id": watch_id,
        "target": target,
        "platform": platform,
        "interval_seconds": interval_seconds,
        "iterations": max(0, iterations),
        "iterations_done": 0,
        "events": [],
        "running": True,
        "status": "running",
        "created_at": now,
        "last_run_at": None,
        "last_snapshot_id": None,
        "last_error": None
    }
    with SOCIAL_WATCHES_LOCK:
        SOCIAL_WATCHES[watch_id] = watch
    threading.Thread(
        target=_social_watch_worker,
        args=(watch_id, target, platform, interval_seconds, max(0, iterations)),
        daemon=True
    ).start()
    return jsonify(watch)

@app.route('/api/social/watch/<watch_id>', methods=['GET'])
def api_social_watch_status(watch_id):