import requests
import time
from datetime import datetime, timedelta

# TOP云API配置
API_KEY = "your_api_key"  # 在TOP云控制台获取
ENDPOINT = "https://api.topyun.vip/v1"
INSTANCE_ID = "i-1234567890abcdef0"  # 目标云主机ID

def get_current_ips():
    """查询当前云主机的IP列表"""
    url = f"{ENDPOINT}/instances/{INSTANCE_ID}"
    headers = {"Authorization": f"Bearer {API_KEY}"}
    response = requests.get(url, headers=headers)
    return response.json()["public_ips"]

def assign_new_ip():
    """分配新IP（假设节点支持多IP绑定）"""
    url = f"{ENDPOINT}/instances/{INSTANCE_ID}/ips"
    headers = {"Authorization": f"Bearer {API_KEY}"}
    data = {"action": "assign_new"}
    response = requests.post(url, headers=headers, json=data)
    return response.json()["new_ip"]

def rotate_ip():
    """执行IP轮换逻辑"""
    current_ips = get_current_ips()
    if len(current_ips) >= 2:  # 若已有多个IP，释放最旧的IP
        oldest_ip = current_ips[-1]
        release_url = f"{ENDPOINT}/instances/{INSTANCE_ID}/ips/{oldest_ip}"
        requests.delete(release_url, headers={"Authorization": f"Bearer {API_KEY}"})
    new_ip = assign_new_ip()
    print(f"[{datetime.now()}] IP已切换至: {new_ip}")

# 主循环：每天执行一次
while True:
    rotate_ip()
    time.sleep(86400)  # 24小时

#!/bin/bash

# 配置参数
API_KEY="your_api_key"
INSTANCE_ID="i-1234567890abcdef0"
MAX_RETRIES=3
THRESHOLD=50  # 每分钟最大允许请求数

# 获取当前IP的请求计数（假设通过日志分析）
current_ip=$(curl -s -H "Authorization: Bearer $API_KEY" \
    "https://api.topyun.vip/v1/instances/$INSTANCE_ID" | jq -r '.public_ips[0]')
request_count=$(grep "$current_ip" /var/log/crawler.log | grep "200" | wc -l)

# 判断是否需要切换IP
if [ $request_count -gt $THRESHOLD ]; then
    echo "[$(date)] 请求超限，开始切换IP..."
    for i in $(seq 1 $MAX_RETRIES); do
        # 重启云主机触发IP切换（需节点支持）
        curl -X POST -H "Authorization: Bearer $API_KEY" \
            "https://api.topyun.vip/v1/instances/$INSTANCE_ID/reboot"
        sleep 60  # 等待IP更新
        new_ip=$(curl -s -H "Authorization: Bearer $API_KEY" \
            "https://api.topyun.vip/v1/instances/$INSTANCE_ID" | jq -r '.public_ips[0]')
        if [ "$new_ip" != "$current_ip" ]; then
            echo "[$(date)] IP切换成功: $new_ip"
            break
        else
            echo "[$(date)] 第$i次重试失败..."
        fi
    done
else
    echo "[$(date)] 请求正常，无需切换IP"
fi

const axios = require('axios');
const { exec } = require('child_process');

app.post('/webhook/waf-alert', async (req, res) => {
    const { attack_type, source_ip, instance_id } = req.body;
    if (attack_type === "IP_BLOCK") {
        // 调用TOP云API切换IP
        exec(`curl -X POST -H "Authorization: Bearer YOUR_API_KEY" \
            https://api.topyun.vip/v1/instances/${instance_id}/reboot`,
            (error) => {
                if (error) console.error("IP切换失败:", error);
                else console.log(`已屏蔽攻击IP ${source_ip}，并触发IP切换`);
            });
    }
    res.sendStatus(200);
});