当心你的 AI！使用 Replit AI 掩盖你的 C2 流量

https[://]aaaaaaaa-2222-b33f-b33f--11-133713371337ee.ReplitSubDomain.replit.dev

https[://]LegitApp.replit.dev

import osimport loggingimport requestsfrom flask import Flask, request, jsonify, render_template, redirect, url_for, flash, Responsefrom urllib.parse import urljoinimport json
# Configure logginglogging.basicConfig(    level=logging.DEBUG,    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')logger = logging.getLogger(__name__)
# Initialize Flask appapp = Flask(__name__)app.secret_key = os.environ.get("SESSION_SECRET",                                "default-secret-key-for-development")
# Target API hostTARGET_HOST = "https://****.live:8080"

@app.route('/')def index():    """Serve the coming soon landing page."""    from datetime import datetime    current_year = datetime.now().year    return render_template('index.html', current_year=current_year)

@app.route('/subscribe', methods=['POST'])def subscribe():    """Handle newsletter subscription."""    email = request.form.get('email')
    if not email:        flash('Email is required!', 'danger')        return redirect(url_for('index'))
    # Here you would typically save the email to a database or send it to a mailing service    # For now, we'll just log it    logger.info(f"Newsletter subscription: {email}")
    flash('Thank you for subscribing!', 'success')    return redirect(url_for('index'))

@app.route('/api/stats/traffic', methods=['GET', 'POST'])def proxy_traffic_stats():    """Proxy requests to the original host's traffic stats endpoint."""    method = request.method    target_url = urljoin(TARGET_HOST, "/api/stats/traffic")
    # Log the incoming request    logger.debug(f"Incoming request: {method} {request.url}")    logger.debug(f"Request headers: {request.headers}")    if method == 'POST':        logger.debug(f"Request data: {request.get_data()}")
    # Prepare headers to forward    headers = {        key: value        for key, value in request.headers.items()        if key.lower() not in ['host', 'content-length']    }
    try:        # Forward the request to the target host        if method == 'GET':            response = requests.get(target_url,                                    headers=headers,                                    params=request.args,                                    timeout=10,                                    verify=False)        elif method == 'POST':            response = requests.post(target_url,                                     headers=headers,                                     data=request.get_data(),                                     timeout=10,                                     verify=False)        else:            return jsonify({"error": "Method not allowed"}), 405
        # Log the response        logger.debug(f"Response status: {response.status_code}")        logger.debug(f"Response headers: {response.headers}")        logger.debug(f"Response content: {response.content}")
        # Prepare the response to send back to the client        excluded_headers = [            'content-encoding', 'content-length', 'transfer-encoding',            'connection'        ]        headers = [(name, value)                   for name, value in response.raw.headers.items()                   if name.lower() not in excluded_headers]
        # Add no-cache headers        no_cache_headers = [('Cache-Control',                             'no-store, no-cache, must-revalidate, max-age=0'),                            ('Pragma', 'no-cache'), ('Expires', '0')]        headers.extend(no_cache_headers)
        # Return the response        return Response(response.content, response.status_code, headers)
    except requests.RequestException as e:        logger.error(f"Proxy error: {str(e)}")        return jsonify({            "error": "Failed to forward request",            "details": str(e)        }), 502

if __name__ == '__main__':    app.run(host='0.0.0.0', port=5000, debug=True)