import TencentCloudLogProducer

// 配置初始化
let config = ClsLogSenderConfig(
    endpoint: "your_endpoint" ?? "",
    accessKeyId: "your_accessKeyId" ?? "",
    accessKey: "your_accessKey" ?? ""
)
config.sendLogInterval = 5 // 日志发送逗留时间，默认5秒
config.maxMemorySize = 32 * 1024 * 1024 // 内存上限，默认32MB
config.token = "your_temp_token" // 临时密钥（可选）

// 启动SDK
let sender = LogSender.shared()
sender.setConfig(config)
sender.start()

import UIKit
import TencentCloudLogProducer

// 实现 CLSOutputDelegate 协议的输出类
class CLSWriter: NSObject, CLSOutputDelegate {
    func write(_ line: String!) {
        print("CLSWriter output: \\(line ?? "")")
    }
}

// 初始化配置
func initNetworkDiagnosis() {
    let config = ClsConfig()
    config.endpoint = "ap-guangzhou.cls.tencentcs.com"
    config.accessKeyId = "your_access_key_id"
    config.accessKeySecret = "your_access_key_secret"
    config.topicId = "your_topic_id"
    config.pluginAppId = "your_plugin_id"

    // 可选：自定义参数
    config.userId = "user1"
    config.channel = "channel1"
    config.addCustom(withKey: "customKey1", andValue: "testValue")

    // 添加网络探测插件
    let clsAdapter = ClsAdapter.sharedInstance()
    let plugin = CLSNetworkDiagnosisPlugin()
    clsAdapter.add(unsafeBitCast(plugin, to: baseClsPlugin.self))
    clsAdapter.initWith(config)
}


import TencentCloudLogProducer

// 构建日志内容
let logContent = Log_Content()
logContent.key = "user_behavior"
logContent.value = "click_submit_button"

// 构建日志项（时间戳为秒级）
let logItem = Log()
logItem.contentsArray.add(logContent)
logItem.time = Int64(Date().timeIntervalSince1970)

// 写入本地数据库（自动触发批处理发送）
ClsLogStorage.sharedInstance().write(logItem, topicId: "your_topicId") { success, error in
    if success {
        print("日志写入成功，等待发送")
    } else {
        print("日志写入失败：error.debugDescription)")
    }
}

//方法一：基础 Ping 探测
ClsNetworkDiagnosis.sharedInstance().ping(
    "cloud.tencent.com",
    size: 64,
    output: CLSWriter()
) { result in
    print("Ping 探测结果：\\(result?.description ?? "无结果")")
}

// 方法 2：指定超时时间和探测次数的 Ping 探测
ClsNetworkDiagnosis.sharedInstance().ping(
    "cloud.tencent.com",
    size: 64,
    task_timeout: 3000,  // 超时时间：3000毫秒
    output: CLSWriter(),
    complete: { result in
        print("Ping 探测结果：\\(result?.description ?? "无结果")")
    },
    count: 10  // 探测次数
)

//方法 3：带自定义字段的 Ping 探测
let customFields = NSMutableDictionary()
customFields["detect_scene"] = "log_upload_failure"
customFields["app_version"] = "1.0.0"

ClsNetworkDiagnosis.sharedInstance().ping(
    "cloud.tencent.com",
    size: 64,
    output: CLSWriter(),
    complete: { result in
        print("Ping 探测结果：\\(result?.description ?? "无结果")")
    },
    customFiled: customFields
)

//方法 4：完整参数的 Ping 探测
let customFields = NSMutableDictionary()
customFields["detect_scene"] = "log_upload_failure"

ClsNetworkDiagnosis.sharedInstance().ping(
    "cloud.tencent.com",
    size: 64,
    task_timeout: 3000,
    output: CLSWriter(),
    complete: { result in
        guard let result = result else {
            print("Ping 探测失败")
            return
        }
        print("Ping 探测结果：")
        print("- 平均延迟：\\(result.avgRtt ?? "") ms")
        print("- 丢包率：\\(result.loss_rate ?? "") %")
        print("- 完整结果：\\(result.description)")
    },
    count: 10,
    customFiled: customFields
)


//方法 1：基础 TCPPing 探测
ClsNetworkDiagnosis.sharedInstance().tcpPing(
    "cloud.tencent.com",
    output: CLSWriter()
) { result in
    print("TCPPing 探测结果：\\(result?.description ?? "无结果")")
}

//方法 2：指定端口、超时时间和探测次数的 TCPPing 探测
ClsNetworkDiagnosis.sharedInstance().tcpPing(
    "cloud.tencent.com",
    port: 80,            // 目标端口
    task_timeout: 3000,  // 超时时间：3000毫秒
    count: 10,           // 探测次数
    output: CLSWriter()
) { result in
    print("TCPPing 探测结果：\\(result?.description ?? "无结果")")
}

//方法 3：带自定义字段的 TCPPing 探测
let customFields = NSMutableDictionary()
customFields["detect_scene"] = "log_upload_failure"
customFields["connection_type"] = "wifi"

ClsNetworkDiagnosis.sharedInstance().tcpPing(
    "cloud.tencent.com",
    output: CLSWriter(),
    complete: { result in
        print("TCPPing 探测结果：\\(result?.description ?? "无结果")")
    },
    customFiled: customFields
)

//方法 4：完整参数的 TCPPing 探测
let customFields = NSMutableDictionary()
customFields["detect_scene"] = "log_upload_failure"

ClsNetworkDiagnosis.sharedInstance().tcpPing(
    "cloud.tencent.com",
    port: 443,           // HTTPS 端口
    task_timeout: 5000,
    count: 10,
    output: CLSWriter(),
    complete: { result in
        guard let result = result else {
            print("TCPPing 探测失败")
            return
        }
        print("TCPPing 探测结果：")
        print("- 平均延迟：\\(result.avgRtt ?? "") ms")
        print("- 成功率：\\(result.success_rate ?? "") %")
        print("- 完整结果：\\(result.description)")
    },
    customFiled: customFields
)


// 方法 1：基础 TraceRoute 探测
ClsNetworkDiagnosis.sharedInstance().traceRoute(
    "cloud.tencent.com",
    output: CLSWriter()
) { result in
    print("TraceRoute 探测结果：\\(result?.content ?? "无结果")")
}

//方法 2：指定最大跳数的 TraceRoute 探测
ClsNetworkDiagnosis.sharedInstance().traceRoute(
    "cloud.tencent.com",
    output: CLSWriter(),
    complete: { result in
        guard let result = result else {
            print("TraceRoute 探测失败")
            return
        }
        print("TraceRoute 探测结果：")
        print("- 跳数：\\(result.hop_count ?? 0)")
        print("- 路由详情：\\(result.content ?? "")")
    },
    maxTtl: 30  // 最大跳数
)

//方法 3：带自定义字段的 TraceRoute 探测
let customFields = NSMutableDictionary()
customFields["detect_scene"] = "log_upload_failure"
customFields["network_carrier"] = "China Mobile"

ClsNetworkDiagnosis.sharedInstance().traceRoute(
    "cloud.tencent.com",
    output: CLSWriter(),
    complete: { result in
        print("TraceRoute 探测结果：\\(result?.content ?? "无结果")")
    },
    customFiled: customFields
)
//方法 4：完整参数的 TraceRoute 探测
let customFields = NSMutableDictionary()
customFields["detect_scene"] = "log_upload_failure"

ClsNetworkDiagnosis.sharedInstance().traceRoute(
    "cloud.tencent.com",
    output: CLSWriter(),
    complete: { result in
        guard let result = result else {
            print("TraceRoute 探测失败")
            return
        }
        print("TraceRoute 探测结果：")
        print("- 完成状态：\\(result.status)")
        print("- 跳数：\\(result.hop_count ?? 0)")
        print("- 详细路由：")
        print(result.content ?? "无路由信息")
    },
    maxTtl: 30,
    customFiled: customFields
)



//方法 1：基础 探测
ClsNetworkDiagnosis.sharedInstance().httping(
    "https://ap-guangzhou.cls.tencentcs.com/ping",
    output: CLSWriter()
) { result in
    print("HttpPing 探测结果：\\(result?.description ?? "无结果")")
}

//方法 2：带自定义字段的 HttpPing 探测
let customFields = NSMutableDictionary()
customFields["detect_scene"] = "log_upload_failure"
customFields["api_endpoint"] = "ap-guangzhou"

ClsNetworkDiagnosis.sharedInstance().httping(
    "https://ap-guangzhou.cls.tencentcs.com/ping",
    output: CLSWriter(),
    complate: { result in
        guard let result = result else {
            print("HttpPing 探测失败")
            return
        }
        print("HttpPing 探测结果：")
        print("- HTTP 状态码：\\(result.statusCode ?? 0)")
        print("- 响应时间：\\(result.responseTime ?? "") ms")
        print("- 完整结果：\\(result.description)")
    },
    customFiled: customFields
)
iftshi