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