Files
fscan/common/flag_test.go
T
ZacharyZcR 760c8ea502 v2.1.2 核心优化与多架构发布 (#561)
* feat: v2.1.0 核心重构与功能增强

## 架构重构
- 全局变量消除,迁移至 Config/State 对象
- SMB 插件融合(smb/smb2/smbghost/smbinfo)
- 服务探测重构,实现 Nmap 风格 fallback 机制
- 输出系统重构,TXT 实时刷盘 + 双写机制
- i18n 框架升级至 go-i18n

## 性能优化
- 正则表达式预编译
- 内存优化 map[string]struct{}
- 并发指纹匹配
- SOCKS5 连接复用
- 滑动窗口调度 + 自适应线程池

## 新功能
- Web 管理界面
- 多格式 POC 适配(xray/afrog)
- 增强指纹库(3139条)
- Favicon hash 指纹识别
- 插件选择性编译(Build Tags)
- fscan-lab 靶场环境
- 默认端口扩展(62→133)

## 构建系统
- 添加 no_local tag 支持排除本地插件
- 多版本构建:fscan/fscan-nolocal/fscan-web
- CI 添加 snapshot 模式支持仅测试构建

## Bug 修复
- 修复 120+ 个问题,包括 RDP panic、批量扫描漏报、
  JSON 输出格式、Redis 检测、Context 超时等

## 测试增强
- 单元测试覆盖率 74-100%
- 并发安全测试
- 集成测试(Web/端口/服务/SSH/ICMP)

* fix(ci): 移除 PR 对 Project 自动化的触发

* fix: Elasticsearch未授权检测优先于爆破 (#554)

* fix: 修复RDP爆破高误报率问题 (#555)

- 移除 screen.go 中错误的认证结果覆盖逻辑
- 启用 NLA 协议的 ErrorCode 字段检测
- 添加 PubKeyAuth 验证确保认证真正成功
- 修复 io.go 中错误被静默忽略的问题
- 修复 socket.go/io.go 中可能导致 panic 的代码
- 修复 screen.go 中文件句柄泄漏和 log.Panic

* fix: 修复-user/-pwd凭据参数不生效的问题

问题原因:
- Parse()解析凭据后更新globalConfig
- 但BuildConfigFromFlags()创建新Config时使用默认字典
- 导致解析的UserPassPairs等凭据信息被丢弃

修复内容:
1. initialize.go: 将Parse解析的凭据结果应用到新Config
2. credential.go: 单用户密码对时创建UserPassPairs
3. rdp.go: 单凭据测试时跳过指纹识别,减少连接次数

* feat: RDP使用NLA仅验证模式,避免挤掉已登录用户

- 添加ErrNLAAuthSuccess标志用于NLA验证成功信号
- tpkt层支持nlaAuthOnly模式,验证成功后不建立完整会话
- x224层正确传播NLA验证结果
- rdpCrack改用NlaAuth进行凭据验证

* fix: 修复进度条在Windows终端满屏重复输出的问题

- 添加终端宽度检测,动态调整进度条长度
- 使用空格覆盖清除旧内容,避免残留
- 简化进度条格式,确保不超过终端宽度

* feat: 优化日志颜色方案,区分漏洞和普通信息

- 新增 LogVuln 级别(红色),用于漏洞和重要发现
- 密码爆破成功、未授权访问、POC漏洞等改用红色显示
- 普通信息(扫描统计等)改为白色
- Web指纹保持绿色

* refactor: 精简化输出,移除冗余启动信息

- 移除showParseSummary开局配置输出
- 移除LogPluginInfo/LogPluginInfoWithPort插件信息输出
- 移除alive_scanner冗余统计输出
- 移除port_scan_start扫描开始提示
- 移除handleUDPPorts SNMP死代码
- 移除相关i18n条目

* chore: 版本号更新为2.1.1

* fix: 降级依赖版本以保持Go 1.20兼容性

* feat(ldap): 添加NTLM Hash认证支持 (#433)

* chore: 清理无用的 replace 指令

* fix(ping): 修复 TTL expired 导致主机误判为存活的问题

在 ExecCommandPing 中增加错误关键词检测,当 ping 输出包含
TTL expired、Destination unreachable 等错误信息时,不再将
目标主机标记为存活。

Fixes #454

* fix(proxy): 修复透明代理导致输出全端口的问题

在代理初始化时主动探测代理行为,通过连接 RFC 5737 保留的
测试地址来检测是否存在"全回显"问题。如果探测到代理不可靠,
则在端口扫描时跳过所有端口,避免误报。

- 新增 proxyReliable 标志位标记代理可靠性
- 新增 ProbeProxyBehavior 函数探测代理行为
- 端口扫描前检查代理可靠性并输出警告

Fixes #495

* refactor: 移动debug模块到common/debug子包

* fix(web): 修复-u模式下Web插件未执行的问题

* fix: 优化输出格式和颜色显示

- 网段统计格式改为 10.253.0.0/16 网段存活: 26
- WebTitle基础信息改为白色,指纹识别单独绿色输出
- 移除重复的端口数量输出

* fix: URL解析自动补全协议头

-uf 文件中 192.168.1.1:8080 自动转为 http://192.168.1.1:8080

* fix: 修复-u/-uf模式下URLs丢失导致0目标扫描的问题

Parse阶段将URLs设置到全局状态,但Initialize随后创建新状态
并覆盖了全局状态,导致URLs数据丢失。现在在创建新状态前
先保存并迁移Parse阶段设置的URLs和HostPorts数据。

* fix: 智能检测HTTP/HTTPS协议并优化URL显示

- 修复-u/-uf模式URLs丢失导致0目标扫描问题
- detectProtocol改为主动TLS握手检测,不依赖服务名
- WebTitle输出显示完整协议(http/https)
- 隐藏标准端口(80/443)使输出更简洁

* refactor: 精简parsers包,统一配置构建入口

- 删除冗余的中间层(XXXInput、XXXParser类)
- 新增 config_builder.go 统一配置构建
- parsers包从3000+行精简至~540行
- 保留核心函数:ParseIP、ParsePort、文件读取、凭据解析

* test: 扩展parsers单元测试覆盖边缘情况

- 新增内网简写解析测试(192/172/10)
- 新增完整IP范围和无效CIDR测试
- 新增Windows行尾(CRLF)处理测试
- 新增凭据和哈希文件解析测试
- 新增端口解析边缘情况测试
- 测试覆盖率达到94.2%

* refactor: 优化控制台输出格式

- 去掉时间戳,保留[*][+]前缀
- Web输出合并WebTitle和WebFinger为一行
- 有指纹显示绿色[+],无指纹显示白色[*]
- 格式: code:xxx len:xxx title:xxx server:xxx [指纹]
- 服务探测格式: [Product:xxx ||Version:xxx] Banner:(xxx)
- 字段对齐,输出更清爽

* feat: 添加凭据测试未发现弱密码的提示

- credential_tester.go: 失败时设置 Type=ResultTypeCredential
- scanner.go: 根据结果类型在 error 级别输出'未发现弱密码'提示
- 新增 i18n 翻译 brute_no_weak_pass

使用 -log all 或 -log error 可看到此提示

* refactor(logging): 重构日志级别为层级过滤设计

- LogLevel 从 string 改为 int 类型,支持层级比较
- 层级设计:Debug(0) < Base(1) < Info(2) < Success(3) < Vuln(4) < Error(5)
- 设置一个级别后,显示该级别及以上的日志
- Error 级别始终显示,不会被配置过滤掉
- 保留向后兼容别名(LevelAll, LevelInfoSuccess 等)
- 更新测试以匹配新的层级过滤行为

* style(logging): Error级别日志改为黄色显示

* style(findnet): NetInfo输出改为每行一个IP

* refactor(ms17010): 优化错误提示,明确指出SMBv1不支持等情况

* fix(credential): 修复凭据测试结果不一致的问题

问题原因:
1. 未知错误类型不重试,导致服务端限流时跳过正确密码
2. SSH 错误分类不够准确,某些临时错误未被识别

修复内容:
1. 未知错误改为可重试(可能是临时问题)
2. 增加 SSH 特有的网络错误识别(handshake failed, disconnect 等)

* fix(portfinger): 修复SMB2服务指纹识别和NetInfo输出问题

- 添加SMB2ProgNeg探针支持现代Windows的SMB2协议
- 修复Go regexp对高位字节的UTF-8兼容问题,使用Latin-1转换
- 修复探针失败后连接重建逻辑
- 修复vendor_product字段名不匹配问题
- 修复NetInfo多行输出被其他日志打断的问题

* fix(config): 从默认端口移除9100,避免触发打印机打印 (#517)

* feat(proxy): 增强代理端口扫描的深度验证机制

- 新增4阶段深度验证:Banner读取→探测发送→响应等待→最终判定
- 新增SOCKS5错误码和代理错误文本检测
- 优化ProbeProxyBehavior探测逻辑,发送数据验证连接可达性
- 解决透明代理/全回显代理导致的假阳性问题

* fix(proxy): 修复代理深度验证的若干问题

- detector.go: 修复 AutoConfigureProxy 覆盖探测结果的问题
  只有未探测过时才设置默认 proxyReliable 值

- port_scan.go: 改进深度验证机制
  - 使用带 Host header 的 HTTP GET 请求替代 OPTIONS
  - 延长响应等待超时至 2s 以适配慢速服务器
  - 正确重置连接 deadline 避免影响后续操作

* refactor: 统一 common 包文件命名风格

Flag.go -> flag.go

* refactor(proxy): 删除自定义 contains() 函数,改用标准库

- 用 strings.Contains() 替代手写的 contains()
- 删除过时的注释

* fix(parsers): 修复带横杠域名被误识别为IP范围的问题

如 111-555.sss.com 这类域名因包含 - 被错误解析为 IP 范围,
添加 looksLikeIPRange() 检查,只有 - 前是有效 IP 才走范围解析

* fix(proxy): 修复代理模式下服务识别错误和端口漏扫问题

- port_scan.go: 验证通过后重建干净连接,避免HTTP GET探测污染服务识别
- port_scan.go: 优化验证策略,用轻量CRLF探测替代HTTP GET,超时从2.2s降至0.6s
- manager.go: 修正ProbeProxyBehavior判断逻辑,超时应视为代理正常转发

* fix(pool): 移除线程池预分配,优化大规模扫描内存占用

WithPreAlloc(true) 会预先创建所有 worker goroutine,
在大规模扫描(如 25域名×65535端口)时可能导致内存问题

* refactor(logging): 统一日志前缀,删除废弃的 LogBase

- 删除 LogBase 函数,所有调用迁移到 LogInfo/LogError
- 新增 PrefixDebug ([.]) 前缀,所有日志级别现在都有前缀
- 修复日志输出缩进不一致的问题
- 删除未使用的 PrefixDefault 常量

* perf(icmp): 实现自适应等待算法优化存活检测性能

- 新增 waitAdaptive 函数,监控响应增量实现智能提前结束
- 算法保守原则:最小等待1s + 连续500ms无新响应才提前结束
- 添加100ms检查间隔避免CPU空转
- 保留原有最大等待时间(3s/6s)作为兜底
- 添加完整单元测试覆盖各种场景

优化效果:
- 全部响应:~100ms (原3s)
- 无响应:~1s (原3s)
- 部分响应后稳定:~1.5s (原3s)

* perf(scan): 实现启发式优化提升扫描体验

1. 端口优先级排序:高价值端口(80,443,22,3389等)优先扫描
   - 用户能更快看到有意义的结果
   - 不影响端口喷洒策略

2. TCP 补充探测:ICMP 响应率<10%时自动启用
   - 对未响应主机用 TCP 80/443/22/445 补充探测
   - 解决防火墙过滤 ICMP 导致漏检的问题

* refactor(grdp): 精简RDP库,删除认证检测不需要的代码

- 删除 VNC 协议支持 (protocol/rfb, client/rfb.go)
- 删除完整客户端框架 (client/)
- 删除 RemoteApp 等插件 (plugin/)
- 删除 RLE 图形解压 (core/rle.go)
- 删除绘图指令处理 (pdu/orders.go, pdu/gdi.go)
- 精简 screen.go,移除截图和完整会话功能
- 移除未使用的 RGB 转换函数

grdp 代码从 13,044 行精简至 7,581 行,削减 42%

* refactor(common): 删除死代码,优化代码风格

- 删除未使用的 joinStrings/joinInts 函数
- 删除未使用的 memStats 字段和 getMemoryInfo 方法
- 简化 parsePasswords 中的循环为 append(...) 形式

* refactor(services): 统一数据库插件的DBWrapper

4个数据库插件(MySQL、PostgreSQL、MSSQL、Oracle)都有相同的sql.DB包装代码,
合并为通用的SQLDBWrapper,减少重复。

* refactor(core,grdp): 删除未使用的死代码

- 移除 BaseScanStrategy.LogPluginInfoWithPort 方法(无调用者)
- 移除 mcs.go 中被注释的旧 connect 函数实现

* refactor: 删除 deadcode 检测出的未使用函数

- proxy/detector.go: 删除 IsSOCKS5Standard, IsProxyInitialized
- findnet.go: 删除 NetworkInfo.OneLine, TreeFormat 方法
- port_scan.go: 删除 estimateScanTime 函数
- web_scanner.go: 删除 GetFingerprints 函数
- 清理相关测试代码

* refactor: 删除更多未使用的死代码

- parse.go: 删除 RemoveDuplicate 函数及其测试
- parsers.go: 删除 excludeHosts, removeDuplicates 别名函数
- 更新测试使用真正的函数名

* fix(test): 修复 TestParseIP_InvalidIPRange 测试用例

- 删除不合理的测试用例(无效IP被当作普通主机名处理是设计行为)
- 修复测试逻辑,只在真正通过时输出"正确"

* fix(scan): 移除域名预解析,保留原始域名进行扫描

域名预解析会将域名转换为IP,导致虚拟主机场景下HTTP访问失败
(Host头变成IP而非域名,无法正确路由)

* fix(scan): 修复 -hf 参数无法单独使用的问题

* fix(proxy): 修复透明代理环境下 SOCKS5 代理全端口误报问题

问题:在透明代理(TUN模式)环境下使用 SOCKS5 代理扫描时,
会出现全端口开放的误报,因为代理可靠性检测被透明代理污染。

修复方案(参考 fscanx):
1. 将探针从 CRLF 改为 HTTP GET,更有效检测真实连接状态
2. 删除 "uncertain" 状态,无响应一律判定为端口关闭
3. 调整超时时间以适应代理链路延迟

Fixes #524

* feat(telnet): 新增 telnetd RCE 命令执行验证,修复未授权访问日志级别

* fix: 修复 i18n.Tr vet 报错、Unicode 测试用例,移除过期域名

- 移除 i18n.Tr 中错误的 fmt.Sprintf fallback,消除 go vet 误报
- 修复 match_engine_test Unicode 测试用例与 Latin-1 转换逻辑不匹配
- README 移除过期的 fscan.club 域名
- 添加 .gitattributes 统一换行符为 LF

* refactor: 统一控制台输出风格,使用统一的日志函数

手动合并 PR #558 的改动,适配重构后的代码路径

* fix(ci): 修复版本注入和CI触发配置

- goreleaser ldflags 指向正确的包路径 common.version/commit/date
- version 改为 var 支持 ldflags 注入,banner 显示 commit 和构建日期
- test-build 触发分支增加 dev-* 通配

* fix(ci): 修复 Windows 产物 .exe.exe 双后缀问题

* feat(ci): 扩展构建架构支持 MIPS/ARM/FreeBSD/Solaris
2026-04-25 17:39:16 +08:00

1163 lines
28 KiB
Go

package common
import (
"testing"
"time"
)
// =============================================================================
// FlagVars 默认值测试
// =============================================================================
func TestFlagVars_DefaultValues(t *testing.T) {
// 测试全局 flagVars 初始化
fv := GetFlagVars()
if fv == nil {
t.Fatal("GetFlagVars() 返回 nil")
}
}
// =============================================================================
// BuildConfigFromFlags 测试 - 扫描控制参数
// =============================================================================
func TestBuildConfigFromFlags_ScanControl(t *testing.T) {
tests := []struct {
name string
fv *FlagVars
validate func(*testing.T, *Config)
}{
{
name: "默认扫描模式",
fv: &FlagVars{
ScanMode: "all",
ThreadNum: 600,
ModuleThreadNum: 20,
TimeoutSec: 3,
GlobalTimeout: 180,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Mode != "all" {
t.Errorf("Mode = %q, want %q", cfg.Mode, "all")
}
if cfg.ThreadNum != 600 {
t.Errorf("ThreadNum = %d, want %d", cfg.ThreadNum, 600)
}
if cfg.ModuleThreadNum != 20 {
t.Errorf("ModuleThreadNum = %d, want %d", cfg.ModuleThreadNum, 20)
}
if cfg.Timeout != 3*time.Second {
t.Errorf("Timeout = %v, want %v", cfg.Timeout, 3*time.Second)
}
},
},
{
name: "自定义线程数",
fv: &FlagVars{
ThreadNum: 100,
ModuleThreadNum: 10,
TimeoutSec: 5,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.ThreadNum != 100 {
t.Errorf("ThreadNum = %d, want %d", cfg.ThreadNum, 100)
}
if cfg.ModuleThreadNum != 10 {
t.Errorf("ModuleThreadNum = %d, want %d", cfg.ModuleThreadNum, 10)
}
if cfg.Timeout != 5*time.Second {
t.Errorf("Timeout = %v, want %v", cfg.Timeout, 5*time.Second)
}
},
},
{
name: "禁用Ping",
fv: &FlagVars{
DisablePing: true,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.DisablePing {
t.Error("DisablePing 应该为 true")
}
},
},
{
name: "仅存活检测模式",
fv: &FlagVars{
AliveOnly: true,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.AliveOnly {
t.Error("AliveOnly 应该为 true")
}
},
},
{
name: "禁用暴力破解",
fv: &FlagVars{
DisableBrute: true,
MaxRetries: 5,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.DisableBrute {
t.Error("DisableBrute 应该为 true")
}
if cfg.MaxRetries != 5 {
t.Errorf("MaxRetries = %d, want %d", cfg.MaxRetries, 5)
}
},
},
{
name: "本地插件模式",
fv: &FlagVars{
LocalPlugin: "systeminfo",
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.LocalMode {
t.Error("LocalMode 应该为 true")
}
if cfg.LocalPlugin != "systeminfo" {
t.Errorf("LocalPlugin = %q, want %q", cfg.LocalPlugin, "systeminfo")
}
},
},
{
name: "扫描模式组合",
fv: &FlagVars{
ScanMode: "ssh,ftp,mysql",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Mode != "ssh,ftp,mysql" {
t.Errorf("Mode = %q, want %q", cfg.Mode, "ssh,ftp,mysql")
}
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
cfg := BuildConfigFromFlags(tt.fv)
if cfg == nil {
t.Fatal("BuildConfigFromFlags 返回 nil")
}
tt.validate(t, cfg)
})
}
}
// =============================================================================
// BuildConfigFromFlags 测试 - Web扫描参数
// =============================================================================
func TestBuildConfigFromFlags_WebScan(t *testing.T) {
tests := []struct {
name string
fv *FlagVars
validate func(*testing.T, *Config)
}{
{
name: "Web超时设置",
fv: &FlagVars{
WebTimeout: 10,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Network.WebTimeout != 10*time.Second {
t.Errorf("WebTimeout = %v, want %v", cfg.Network.WebTimeout, 10*time.Second)
}
},
},
{
name: "最大重定向次数",
fv: &FlagVars{
MaxRedirects: 5,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Network.MaxRedirects != 5 {
t.Errorf("MaxRedirects = %d, want %d", cfg.Network.MaxRedirects, 5)
}
},
},
{
name: "Cookie设置",
fv: &FlagVars{
Cookie: "session=abc123; token=xyz",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.HTTP.Cookie != "session=abc123; token=xyz" {
t.Errorf("Cookie = %q, want %q", cfg.HTTP.Cookie, "session=abc123; token=xyz")
}
},
},
{
name: "UserAgent设置",
fv: &FlagVars{
UserAgent: "CustomAgent/1.0",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.HTTP.UserAgent != "CustomAgent/1.0" {
t.Errorf("UserAgent = %q, want %q", cfg.HTTP.UserAgent, "CustomAgent/1.0")
}
},
},
{
name: "HTTP代理设置",
fv: &FlagVars{
HTTPProxy: "http://127.0.0.1:8080",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Network.HTTPProxy != "http://127.0.0.1:8080" {
t.Errorf("HTTPProxy = %q, want %q", cfg.Network.HTTPProxy, "http://127.0.0.1:8080")
}
},
},
{
name: "SOCKS5代理设置",
fv: &FlagVars{
Socks5Proxy: "socks5://127.0.0.1:1080",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Network.Socks5Proxy != "socks5://127.0.0.1:1080" {
t.Errorf("Socks5Proxy = %q, want %q", cfg.Network.Socks5Proxy, "socks5://127.0.0.1:1080")
}
},
},
{
name: "网络接口设置",
fv: &FlagVars{
Iface: "eth0",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Network.Iface != "eth0" {
t.Errorf("Iface = %q, want %q", cfg.Network.Iface, "eth0")
}
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
cfg := BuildConfigFromFlags(tt.fv)
if cfg == nil {
t.Fatal("BuildConfigFromFlags 返回 nil")
}
tt.validate(t, cfg)
})
}
}
// =============================================================================
// BuildConfigFromFlags 测试 - POC参数
// =============================================================================
func TestBuildConfigFromFlags_POC(t *testing.T) {
tests := []struct {
name string
fv *FlagVars
validate func(*testing.T, *Config)
}{
{
name: "POC路径设置",
fv: &FlagVars{
PocPath: "/path/to/pocs",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.POC.PocPath != "/path/to/pocs" {
t.Errorf("PocPath = %q, want %q", cfg.POC.PocPath, "/path/to/pocs")
}
},
},
{
name: "POC名称过滤",
fv: &FlagVars{
PocName: "struts,spring",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.POC.PocName != "struts,spring" {
t.Errorf("PocName = %q, want %q", cfg.POC.PocName, "struts,spring")
}
},
},
{
name: "全量POC扫描",
fv: &FlagVars{
PocFull: true,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.POC.Full {
t.Error("POC.Full 应该为 true")
}
},
},
{
name: "DNSLog启用",
fv: &FlagVars{
DNSLog: true,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.DNSLog {
t.Error("DNSLog 应该为 true")
}
},
},
{
name: "POC并发数",
fv: &FlagVars{
PocNum: 50,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.POC.Num != 50 {
t.Errorf("PocNum = %d, want %d", cfg.POC.Num, 50)
}
},
},
{
name: "禁用POC扫描",
fv: &FlagVars{
DisablePocScan: true,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.POC.Disabled {
t.Error("POC.Disabled 应该为 true")
}
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
cfg := BuildConfigFromFlags(tt.fv)
if cfg == nil {
t.Fatal("BuildConfigFromFlags 返回 nil")
}
tt.validate(t, cfg)
})
}
}
// =============================================================================
// BuildConfigFromFlags 测试 - Redis参数
// =============================================================================
func TestBuildConfigFromFlags_Redis(t *testing.T) {
tests := []struct {
name string
fv *FlagVars
validate func(*testing.T, *Config)
}{
{
name: "Redis文件设置",
fv: &FlagVars{
RedisFile: "/path/to/redis.txt",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Redis.File != "/path/to/redis.txt" {
t.Errorf("RedisFile = %q, want %q", cfg.Redis.File, "/path/to/redis.txt")
}
},
},
{
name: "Redis Shell设置",
fv: &FlagVars{
RedisShell: "192.168.1.1:4444",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Redis.Shell != "192.168.1.1:4444" {
t.Errorf("RedisShell = %q, want %q", cfg.Redis.Shell, "192.168.1.1:4444")
}
},
},
{
name: "Redis写入路径",
fv: &FlagVars{
RedisWritePath: "/var/spool/cron/",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Redis.WritePath != "/var/spool/cron/" {
t.Errorf("RedisWritePath = %q, want %q", cfg.Redis.WritePath, "/var/spool/cron/")
}
},
},
{
name: "Redis写入内容",
fv: &FlagVars{
RedisWriteContent: "* * * * * /bin/bash -c 'whoami'",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Redis.WriteContent != "* * * * * /bin/bash -c 'whoami'" {
t.Errorf("RedisWriteContent 不匹配")
}
},
},
{
name: "Redis写入文件",
fv: &FlagVars{
RedisWriteFile: "root",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Redis.WriteFile != "root" {
t.Errorf("RedisWriteFile = %q, want %q", cfg.Redis.WriteFile, "root")
}
},
},
{
name: "禁用Redis利用",
fv: &FlagVars{
DisableRedis: true,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.Redis.Disabled {
t.Error("Redis.Disabled 应该为 true")
}
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
cfg := BuildConfigFromFlags(tt.fv)
if cfg == nil {
t.Fatal("BuildConfigFromFlags 返回 nil")
}
tt.validate(t, cfg)
})
}
}
// =============================================================================
// BuildConfigFromFlags 测试 - 输出显示参数
// =============================================================================
func TestBuildConfigFromFlags_Output(t *testing.T) {
tests := []struct {
name string
fv *FlagVars
validate func(*testing.T, *Config)
}{
{
name: "输出文件设置",
fv: &FlagVars{
Outputfile: "scan_result.txt",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Output.File != "scan_result.txt" {
t.Errorf("Output.File = %q, want %q", cfg.Output.File, "scan_result.txt")
}
},
},
{
name: "JSON输出格式",
fv: &FlagVars{
OutputFormat: "json",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Output.Format != "json" {
t.Errorf("Output.Format = %q, want %q", cfg.Output.Format, "json")
}
},
},
{
name: "CSV输出格式",
fv: &FlagVars{
OutputFormat: "csv",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Output.Format != "csv" {
t.Errorf("Output.Format = %q, want %q", cfg.Output.Format, "csv")
}
},
},
{
name: "禁用保存",
fv: &FlagVars{
DisableSave: true,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.Output.DisableSave {
t.Error("Output.DisableSave 应该为 true")
}
},
},
{
name: "静默模式",
fv: &FlagVars{
Silent: true,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.Output.Silent {
t.Error("Output.Silent 应该为 true")
}
},
},
{
name: "禁用颜色",
fv: &FlagVars{
NoColor: true,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.Output.NoColor {
t.Error("Output.NoColor 应该为 true")
}
},
},
{
name: "日志级别设置",
fv: &FlagVars{
LogLevel: "debug",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Output.LogLevel != "debug" {
t.Errorf("Output.LogLevel = %q, want %q", cfg.Output.LogLevel, "debug")
}
},
},
{
name: "禁用进度条",
fv: &FlagVars{
DisableProgress: true,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.Output.DisableProgress {
t.Error("Output.DisableProgress 应该为 true")
}
if cfg.Output.ShowProgress {
t.Error("Output.ShowProgress 应该为 false")
}
},
},
{
name: "启用性能统计",
fv: &FlagVars{
PerfStats: true,
},
validate: func(t *testing.T, cfg *Config) {
if !cfg.Output.PerfStats {
t.Error("Output.PerfStats 应该为 true")
}
},
},
{
name: "语言设置-中文",
fv: &FlagVars{
Language: "zh",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Output.Language != "zh" {
t.Errorf("Output.Language = %q, want %q", cfg.Output.Language, "zh")
}
},
},
{
name: "语言设置-英文",
fv: &FlagVars{
Language: "en",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Output.Language != "en" {
t.Errorf("Output.Language = %q, want %q", cfg.Output.Language, "en")
}
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
cfg := BuildConfigFromFlags(tt.fv)
if cfg == nil {
t.Fatal("BuildConfigFromFlags 返回 nil")
}
tt.validate(t, cfg)
})
}
}
// =============================================================================
// BuildConfigFromFlags 测试 - 频率控制参数
// =============================================================================
func TestBuildConfigFromFlags_RateLimit(t *testing.T) {
tests := []struct {
name string
fv *FlagVars
validate func(*testing.T, *Config)
}{
{
name: "数据包速率限制",
fv: &FlagVars{
PacketRateLimit: 1000,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Network.PacketRateLimit != 1000 {
t.Errorf("PacketRateLimit = %d, want %d", cfg.Network.PacketRateLimit, 1000)
}
},
},
{
name: "最大数据包数量",
fv: &FlagVars{
MaxPacketCount: 100000,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Network.MaxPacketCount != 100000 {
t.Errorf("MaxPacketCount = %d, want %d", cfg.Network.MaxPacketCount, 100000)
}
},
},
{
name: "ICMP发送速率",
fv: &FlagVars{
ICMPRate: 0.5,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Network.ICMPRate != 0.5 {
t.Errorf("ICMPRate = %f, want %f", cfg.Network.ICMPRate, 0.5)
}
},
},
{
name: "无速率限制",
fv: &FlagVars{
PacketRateLimit: 0,
MaxPacketCount: 0,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Network.PacketRateLimit != 0 {
t.Errorf("PacketRateLimit = %d, want %d", cfg.Network.PacketRateLimit, 0)
}
if cfg.Network.MaxPacketCount != 0 {
t.Errorf("MaxPacketCount = %d, want %d", cfg.Network.MaxPacketCount, 0)
}
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
cfg := BuildConfigFromFlags(tt.fv)
if cfg == nil {
t.Fatal("BuildConfigFromFlags 返回 nil")
}
tt.validate(t, cfg)
})
}
}
// =============================================================================
// BuildConfigFromFlags 测试 - 凭据参数
// =============================================================================
func TestBuildConfigFromFlags_Credentials(t *testing.T) {
tests := []struct {
name string
fv *FlagVars
validate func(*testing.T, *Config)
}{
{
name: "用户名密码设置",
fv: &FlagVars{
Username: "admin",
Password: "password123",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Credentials.Username != "admin" {
t.Errorf("Username = %q, want %q", cfg.Credentials.Username, "admin")
}
if cfg.Credentials.Password != "password123" {
t.Errorf("Password = %q, want %q", cfg.Credentials.Password, "password123")
}
},
},
{
name: "域设置",
fv: &FlagVars{
Domain: "WORKGROUP",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Credentials.Domain != "WORKGROUP" {
t.Errorf("Domain = %q, want %q", cfg.Credentials.Domain, "WORKGROUP")
}
},
},
{
name: "SSH密钥路径",
fv: &FlagVars{
SSHKeyPath: "/home/user/.ssh/id_rsa",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Credentials.SSHKeyPath != "/home/user/.ssh/id_rsa" {
t.Errorf("SSHKeyPath = %q, want %q", cfg.Credentials.SSHKeyPath, "/home/user/.ssh/id_rsa")
}
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
cfg := BuildConfigFromFlags(tt.fv)
if cfg == nil {
t.Fatal("BuildConfigFromFlags 返回 nil")
}
tt.validate(t, cfg)
})
}
}
// =============================================================================
// BuildConfigFromFlags 测试 - 高级功能参数
// =============================================================================
func TestBuildConfigFromFlags_Advanced(t *testing.T) {
tests := []struct {
name string
fv *FlagVars
validate func(*testing.T, *Config)
}{
{
name: "Shellcode设置",
fv: &FlagVars{
Shellcode: "4831c048...",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Shellcode != "4831c048..." {
t.Errorf("Shellcode = %q, want %q", cfg.Shellcode, "4831c048...")
}
},
},
{
name: "反向Shell目标",
fv: &FlagVars{
ReverseShellTarget: "192.168.1.100:4444",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.LocalExploit.ReverseShellTarget != "192.168.1.100:4444" {
t.Errorf("ReverseShellTarget = %q, want %q", cfg.LocalExploit.ReverseShellTarget, "192.168.1.100:4444")
}
},
},
{
name: "SOCKS5代理端口",
fv: &FlagVars{
Socks5ProxyPort: 1080,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Socks5ProxyPort != 1080 {
t.Errorf("Socks5ProxyPort = %d, want %d", cfg.Socks5ProxyPort, 1080)
}
},
},
{
name: "正向Shell端口",
fv: &FlagVars{
ForwardShellPort: 5555,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.LocalExploit.ForwardShellPort != 5555 {
t.Errorf("ForwardShellPort = %d, want %d", cfg.LocalExploit.ForwardShellPort, 5555)
}
},
},
{
name: "持久化目标文件",
fv: &FlagVars{
PersistenceTargetFile: "/etc/crontab",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.PersistenceTargetFile != "/etc/crontab" {
t.Errorf("PersistenceTargetFile = %q, want %q", cfg.PersistenceTargetFile, "/etc/crontab")
}
},
},
{
name: "Windows PE文件",
fv: &FlagVars{
WinPEFile: "C:\\Windows\\Temp\\payload.exe",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.WinPEFile != "C:\\Windows\\Temp\\payload.exe" {
t.Errorf("WinPEFile = %q, want %q", cfg.WinPEFile, "C:\\Windows\\Temp\\payload.exe")
}
},
},
{
name: "键盘记录输出文件",
fv: &FlagVars{
KeyloggerOutputFile: "keylog.txt",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.LocalExploit.KeyloggerOutputFile != "keylog.txt" {
t.Errorf("KeyloggerOutputFile = %q, want %q", cfg.LocalExploit.KeyloggerOutputFile, "keylog.txt")
}
},
},
{
name: "下载URL和路径",
fv: &FlagVars{
DownloadURL: "http://example.com/file.txt",
DownloadSavePath: "/tmp/downloaded.txt",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.LocalExploit.DownloadURL != "http://example.com/file.txt" {
t.Errorf("DownloadURL = %q, want %q", cfg.LocalExploit.DownloadURL, "http://example.com/file.txt")
}
if cfg.LocalExploit.DownloadSavePath != "/tmp/downloaded.txt" {
t.Errorf("DownloadSavePath = %q, want %q", cfg.LocalExploit.DownloadSavePath, "/tmp/downloaded.txt")
}
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
cfg := BuildConfigFromFlags(tt.fv)
if cfg == nil {
t.Fatal("BuildConfigFromFlags 返回 nil")
}
tt.validate(t, cfg)
})
}
}
// =============================================================================
// BuildConfigFromFlags 测试 - 目标配置参数
// =============================================================================
func TestBuildConfigFromFlags_Target(t *testing.T) {
tests := []struct {
name string
fv *FlagVars
validate func(*testing.T, *Config)
}{
{
name: "端口设置",
fv: &FlagVars{
Ports: "22,80,443,8080",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Target.Ports != "22,80,443,8080" {
t.Errorf("Ports = %q, want %q", cfg.Target.Ports, "22,80,443,8080")
}
},
},
{
name: "端口范围设置",
fv: &FlagVars{
Ports: "1-1000",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Target.Ports != "1-1000" {
t.Errorf("Ports = %q, want %q", cfg.Target.Ports, "1-1000")
}
},
},
{
name: "排除端口设置",
fv: &FlagVars{
ExcludePorts: "22,23",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Target.ExcludePorts != "22,23" {
t.Errorf("ExcludePorts = %q, want %q", cfg.Target.ExcludePorts, "22,23")
}
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
cfg := BuildConfigFromFlags(tt.fv)
if cfg == nil {
t.Fatal("BuildConfigFromFlags 返回 nil")
}
tt.validate(t, cfg)
})
}
}
// =============================================================================
// 参数边界值测试
// =============================================================================
func TestBuildConfigFromFlags_BoundaryValues(t *testing.T) {
tests := []struct {
name string
fv *FlagVars
validate func(*testing.T, *Config)
}{
{
name: "最小线程数",
fv: &FlagVars{
ThreadNum: 1,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.ThreadNum != 1 {
t.Errorf("ThreadNum = %d, want %d", cfg.ThreadNum, 1)
}
},
},
{
name: "大线程数",
fv: &FlagVars{
ThreadNum: 10000,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.ThreadNum != 10000 {
t.Errorf("ThreadNum = %d, want %d", cfg.ThreadNum, 10000)
}
},
},
{
name: "零超时值",
fv: &FlagVars{
TimeoutSec: 0,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Timeout != 0 {
t.Errorf("Timeout = %v, want %v", cfg.Timeout, 0)
}
},
},
{
name: "大超时值",
fv: &FlagVars{
TimeoutSec: 300,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Timeout != 300*time.Second {
t.Errorf("Timeout = %v, want %v", cfg.Timeout, 300*time.Second)
}
},
},
{
name: "零重定向次数",
fv: &FlagVars{
MaxRedirects: 0,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Network.MaxRedirects != 0 {
t.Errorf("MaxRedirects = %d, want %d", cfg.Network.MaxRedirects, 0)
}
},
},
{
name: "空字符串参数",
fv: &FlagVars{
Username: "",
Password: "",
Cookie: "",
UserAgent: "",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Credentials.Username != "" {
t.Errorf("Username 应该为空")
}
if cfg.Credentials.Password != "" {
t.Errorf("Password 应该为空")
}
if cfg.HTTP.Cookie != "" {
t.Errorf("Cookie 应该为空")
}
if cfg.HTTP.UserAgent != "" {
t.Errorf("UserAgent 应该为空")
}
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
cfg := BuildConfigFromFlags(tt.fv)
if cfg == nil {
t.Fatal("BuildConfigFromFlags 返回 nil")
}
tt.validate(t, cfg)
})
}
}
// =============================================================================
// 参数组合测试
// =============================================================================
func TestBuildConfigFromFlags_Combinations(t *testing.T) {
tests := []struct {
name string
fv *FlagVars
validate func(*testing.T, *Config)
}{
{
name: "完整扫描配置",
fv: &FlagVars{
ScanMode: "all",
ThreadNum: 500,
ModuleThreadNum: 15,
TimeoutSec: 5,
DisablePing: true,
DisableBrute: false,
MaxRetries: 3,
Ports: "1-65535",
WebTimeout: 10,
MaxRedirects: 5,
PocFull: true,
PocNum: 30,
Outputfile: "result.json",
OutputFormat: "json",
Language: "zh",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Mode != "all" {
t.Errorf("Mode = %q, want %q", cfg.Mode, "all")
}
if cfg.ThreadNum != 500 {
t.Errorf("ThreadNum = %d, want %d", cfg.ThreadNum, 500)
}
if !cfg.DisablePing {
t.Error("DisablePing 应该为 true")
}
if cfg.POC.Full != true {
t.Error("POC.Full 应该为 true")
}
if cfg.Output.Format != "json" {
t.Errorf("Output.Format = %q, want %q", cfg.Output.Format, "json")
}
},
},
{
name: "最小配置",
fv: &FlagVars{},
validate: func(t *testing.T, cfg *Config) {
// 验证空配置不会导致崩溃
if cfg == nil {
t.Fatal("空配置返回nil")
}
},
},
{
name: "代理组合配置",
fv: &FlagVars{
HTTPProxy: "http://127.0.0.1:8080",
Socks5Proxy: "socks5://127.0.0.1:1080",
WebTimeout: 30,
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Network.HTTPProxy != "http://127.0.0.1:8080" {
t.Errorf("HTTPProxy = %q, want %q", cfg.Network.HTTPProxy, "http://127.0.0.1:8080")
}
if cfg.Network.Socks5Proxy != "socks5://127.0.0.1:1080" {
t.Errorf("Socks5Proxy = %q, want %q", cfg.Network.Socks5Proxy, "socks5://127.0.0.1:1080")
}
},
},
{
name: "Redis利用组合",
fv: &FlagVars{
RedisShell: "192.168.1.100:4444",
RedisWritePath: "/var/spool/cron/",
RedisWriteFile: "root",
RedisWriteContent: "* * * * * bash -i",
},
validate: func(t *testing.T, cfg *Config) {
if cfg.Redis.Shell != "192.168.1.100:4444" {
t.Errorf("Redis.Shell = %q", cfg.Redis.Shell)
}
if cfg.Redis.WritePath != "/var/spool/cron/" {
t.Errorf("Redis.WritePath = %q", cfg.Redis.WritePath)
}
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
cfg := BuildConfigFromFlags(tt.fv)
if cfg == nil {
t.Fatal("BuildConfigFromFlags 返回 nil")
}
tt.validate(t, cfg)
})
}
}
// =============================================================================
// checkParameterConflicts 测试
// =============================================================================
func TestCheckParameterConflicts(t *testing.T) {
// 保存原始flagVars
originalFlagVars := flagVars
tests := []struct {
name string
fv *FlagVars
wantError bool
}{
{
name: "无冲突",
fv: &FlagVars{
ScanMode: "all",
},
wantError: false,
},
{
name: "本地插件包含逗号",
fv: &FlagVars{
LocalPlugin: "systeminfo,avdetect",
},
wantError: true,
},
{
name: "本地插件包含分号",
fv: &FlagVars{
LocalPlugin: "systeminfo;avdetect",
},
wantError: true,
},
{
name: "本地插件包含空格",
fv: &FlagVars{
LocalPlugin: "systeminfo avdetect",
},
wantError: true,
},
{
name: "本地插件包含管道符",
fv: &FlagVars{
LocalPlugin: "systeminfo|avdetect",
},
wantError: true,
},
{
name: "单个本地插件-正常",
fv: &FlagVars{
LocalPlugin: "systeminfo",
},
wantError: false,
},
{
name: "AliveOnly和ICMP模式同时指定",
fv: &FlagVars{
AliveOnly: true,
ScanMode: "icmp",
},
wantError: false, // 只是警告,不是错误
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
// 设置测试flagVars
flagVars = tt.fv
err := checkParameterConflicts()
if tt.wantError && err == nil {
t.Error("期望返回错误,但没有")
}
if !tt.wantError && err != nil {
t.Errorf("不期望错误,但返回: %v", err)
}
})
}
// 恢复原始flagVars
flagVars = originalFlagVars
}