fixed 28a62119 from https://gitee.com/hyq5234/xts_acts/pulls/8166

Add the new cases of worker module.

issue: https://gitee.com/openharmony/xts_acts/issues/I6PJ2HSigned-off-by: Nyqhan <hanyuqing2@huawei.com>

commonlibrary/ets_utils/threadWorker_lib_standard/entry/src/main/ets/test/ThreadWorker.test.js

@@ -465,14 +465,46 @@ describe('threadWorkerTest', function () {
      * @tc.desc: Sends a message to the worker thread when throw error.
      */
      it('threadWorker_postMessage_test_007', 0, async function (done) {
+        let ss = new worker.ThreadWorker("entry/ets/workers/newworker_007.js");
+        let isTerminate = false;
+        ss.onexit = function () {
+            isTerminate = true;
+        }
         try {
-            const ss = new worker.ThreadWorker("entry/ets/workers/newworker_007.js")
-            ss.postMessage()
+            ss.postMessage();
         } catch (error) {
-            expect(error.name).assertEqual("BusinessError")
-            expect(error.message).assertEqual("Worker messageObject must be not null with postMessage")
+            ss.terminate();
+            while (!isTerminate) {
+                await promiseCase();
             }
-        done()
+            expect(error.name).assertEqual("BusinessError");
+            expect(error.message).assertEqual("Worker messageObject must be not null with postMessage");
+        }
+        done();
+    })
+
+    // check worker handle error is ok
+    /**
+     * @tc.name: threadWorker_postMessage_test_008
+     * @tc.desc: Sends a message to the worker thread when throw error.
+     */
+    it('threadWorker_postMessage_test_008', 0, async function (done) {
+        let ss = new worker.ThreadWorker("entry/ets/workers/newworker_007.js");
+        let isTerminate = false;
+        ss.onexit = function () {
+            isTerminate = true;
+        }
+        try {
+            ss.postMessage("123", "123");
+        } catch (error) {
+            ss.terminate();
+            while (!isTerminate) {
+                await promiseCase();
+            }
+            expect(error.name).assertEqual("BusinessError");
+            expect(error.message).assertEqual("transfer list must be an Array");
+        }
+        done();
     })
 
     // check worker terminate is ok
@@ -2298,7 +2330,7 @@ describe('threadWorkerTest', function () {
             const data = Symbol();
             ss.postMessage(data);
         } catch (error) {
-            console.info("worker:: recv error message: " + error.message)
+            console.info("worker:: recv error message: " + error.message);
             while (!flag) {
                 await promiseCase();
             }
@@ -2310,5 +2342,115 @@ describe('threadWorkerTest', function () {
         expect(flag).assertTrue();
         done();
     })
+
+    // Check the postmessage of worker is ok.
+    /**
+     * @tc.name: threadWorker_worker_postmessage_test_001
+     * @tc.desc: Check the postmessage of worker is ok.
+     */
+    it('threadWorker_worker_postmessage_test_001', 0, async function (done) {
+        let ss = new worker.ThreadWorker("entry/ets/workers/newworker_022.js");
+        let res = "";
+        let flag = false;
+        let isTerminate = false;
+        ss.onmessage = function (d) {
+            res = d.data;
+            flag = true;
+        }
+        ss.onexit = function() {
+            isTerminate = true;
+        }
+        ss.postMessage("1");
+        while (!flag) {
+            await promiseCase();
+        }
+        ss.terminate();
+        while (!isTerminate) {
+            await promiseCase();
+        }
+        expect(res).assertEqual("Worker param count must be more than 1 with new");
+        done();
+    })
+
+
+    // Check the postmessage of worker is ok.
+    /**
+     * @tc.name: threadWorker_worker_postmessage_test_002
+     * @tc.desc: Check the postmessage of worker is ok.
+     */
+    it('threadWorker_worker_postmessage_test_002', 0, async function (done) {
+        let ss = new worker.ThreadWorker("entry/ets/workers/newworker_023.js");
+        let res = "";
+        let flag = false;
+        let isTerminate = false;
+        ss.onmessage = function (d) {
+            res = d.data;
+            flag = true;
+        }
+        ss.onexit = function() {
+            isTerminate = true;
+        }
+        ss.postMessage("1");
+        while (!flag) {
+            await promiseCase();
+        }
+        ss.terminate();
+        while (!isTerminate) {
+            await promiseCase();
+        }
+        expect(res).assertEqual("Transfer list must be an Array");
+        done();
+    })
+
+    // Check the postmessage of worker is ok.
+    /**
+     * @tc.name: threadWorker_worker_postmessage_test_003
+     * @tc.desc: Check the postmessage of worker is ok.
+     */
+    it('threadWorker_worker_postmessage_test_003', 0, async function (done) {
+        let ss = new worker.ThreadWorker("entry/ets/workers/newworker_024.js");
+        let res = "";
+        let flag = false;
+        let isTerminate = false;
+        ss.onmessage = function (d) {
+            res = d.data;
+            flag = true;
+        }
+        ss.onexit = function() {
+            isTerminate = true;
+        }
+        ss.postMessage("1")
+        while (!flag) {
+            await promiseCase();
+        }
+        ss.terminate();
+        while (!isTerminate) {
+            await promiseCase();
+        }
+        expect(res).assertEqual("Serializing an uncaught exception failed, failed to serialize message.");
+        done();
+    })
+
+    // Check the close of worker is ok.
+    /**
+     * @tc.name: threadWorker_worker_close_test_001
+     * @tc.desc: Check the close of worker is ok.
+     */
+    it('threadWorker_worker_close_test_001', 0, async function (done) {
+        let ss = new worker.ThreadWorker("entry/ets/workers/newworker_025.js");
+        let res = 0;
+        let isTerminate = false;
+        ss.onexit = function() {
+            res += 1
+            isTerminate = true;
+        }
+        ss.postMessage("1");
+        while (!isTerminate) {
+            await promiseCase();
+        }
+
+        expect(res == 1).assertTrue();
+        done();
+    })
 })
 }
\ No newline at end of file

commonlibrary/ets_utils/threadWorker_lib_standard/entry/src/main/ets/workers/newworker.js

@@ -16,11 +16,7 @@
 import worker from '@ohos.worker';
 const parentPort = worker.workerPort;
 
-console.info("worker:: new version")
-
-parentPort.onclose = function() {
-    console.info("worker::worker.js onclose");
-}
+console.info("worker:: new version");
 
 parentPort.onmessage = function(e) {
     let data = e.data;

commonlibrary/ets_utils/threadWorker_lib_standard/entry/src/main/ets/workers/newworker_022.js

+/*
+ * 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.
+ */
+
+import worker from '@ohos.worker';
+const workerPort = worker.workerPort;
+
+workerPort.onmessage = function(e) {
+    try {
+        workerPort.postMessage();
+    } catch (e) {
+        let data = e.message;
+        workerPort.postMessage(data);
+    }
+}
\ No newline at end of file

commonlibrary/ets_utils/threadWorker_lib_standard/entry/src/main/ets/workers/newworker_023.js

+/*
+ * 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.
+ */
+
+import worker from '@ohos.worker';
+const workerPort = worker.workerPort;
+
+workerPort.onmessage = function(e) {
+    try {
+        workerPort.postMessage("123", "123");
+    } catch (e) {
+        let data = e.message;
+        workerPort.postMessage(data);
+    }
+}
\ No newline at end of file

commonlibrary/ets_utils/threadWorker_lib_standard/entry/src/main/ets/workers/newworker_024.js

+/*
+ * 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.
+ */
+
+import worker from '@ohos.worker';
+const workerPort = worker.workerPort;
+
+workerPort.onmessage = function(e) {
+    try {
+        const symbol = Symbol();
+        workerPort.postMessage(symbol);
+    } catch (e) {
+        let data = e.message;
+        workerPort.postMessage(data);
+    }
+}
\ No newline at end of file

commonlibrary/ets_utils/threadWorker_lib_standard/entry/src/main/ets/workers/newworker_025.js

+/*
+ * 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.
+ */
+
+import worker from '@ohos.worker';
+const workerPort = worker.workerPort;
+
+workerPort.onmessage = function(e) {
+    workerPort.close();
+}
\ No newline at end of file