import {LogProducer} from "@farmerx/tencntcloud-cls-sdk-ohos";

// 初期化します。
let producer = new LogProducer(
    "#[topic_id]",
    "#[access_key]",
    "#[access_secret]",
    "#[access_token]",
    "",
    "#[endpoint]", 100, 100, 2000)

// callbackコールバック関数を設定します。
producer.setCallback((err: Error | null, topicID: string, code: number, request_id: string, errorMessage: string) => {
    if (err==null) {
        hilog.info(0x0000,
            'testTagCLS',
            'onLogCallback.topic: %{public}s , code: %{public}d, request_id: %{public}s, errorMessage: %{public}s',
            topicID, code, request_id, errorMessage
        );
    } else {
        hilog.info(0x0000,
            'testTagCLS',
            'onLogCallback.topic: %{public}s, code: %{public}d, request_id: %{public}s, errorMessage: %{public}s',
            topicID, code, request_id, err.message
        );
    }
})

// ソースIPを設定します。
producer.setSourceIp("127.0.0.3")


// reset access key
producer.setAccessKey("#[access_key]", "#[access_secret]", "#[access_token]");

// 同期送信します。
function syncsencLog() {
    let logs: Record<string, string>[] = [];
    let log: Record<string, string> = {};
    // キーバリューペアを追加します。
    log["key1"] = "value1";
    log["key2"] = "value2";
    log["key3"] = "value3";
    logs.push(log)
    try {
        let rsp = producer.syncSendLogs( "127.0.0.1", logs)
        hilog.info(0x0000, 'testTag', "========%{public}s, %{public}s", rsp.requestId, rsp.rspText)
    } catch (e) {
        // ....
    }
}
// 非同期送信します。
function asyncSendLog() {
    let log: Record<string, string> = {};
    // キーバリューペアを追加します。
    log["key1"] = "value1";
    log["key2"] = "value2";
    log["key3"] = "value3";
    try {
        producer.addLog(log)
    } catch (e) {
        // ....
    }
    
}

asyncSendLog()
sencLog()