/*
 * Copyright (C) 2022 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

const mallocSize = 1024 * 1024;

let Module_T: any = null;

function initConfigWASM(wasmFunctionName:string) {
    return new Promise((resolve, reject) => {
        function callModelFun(functionName: string) {
            let func = eval(functionName);
            Module_T = new func({
                locateFile: (s: any) => {
                    return s
                },
                print: (line: any) => {
                },
                printErr: (line: any) => {
                },
                onRuntimeInitialized: () => {
                    resolve("ok")
                },
                onAbort: () => {
                }
            });
        }
        callModelFun(wasmFunctionName)
    })
}

self.onmessage = async (e: MessageEvent) => {
    if (e.data.action === "open") {
        let jsFile = e.data.wasmJsName
        importScripts(jsFile)
        await initConfigWASM(e.data.WasmName);
        let dataCallBack = (heapPtr: number, size: number, isEnd: number, isConfig: number) => {
            if (isConfig == 1) {
                let jsonOut: Uint8Array = Module_T.HEAPU8.slice(heapPtr, heapPtr + size);
                let decoder = new TextDecoder();
                let result = decoder.decode(jsonOut);
                let json = JSON.parse(result);
                self.postMessage({
                    results: json,
                });
            }
        }
        let fn = Module_T.addFunction(dataCallBack, "viiii");
        Module_T._Init(fn, mallocSize)
        Module_T._TraceStreamer_In_JsonConfig();
    }
}