diff --git a/notification/ces_standard/subscribeandpublish/BUILD.gn b/notification/ces_standard/subscribeandpublish/BUILD.gn index 4155c8668a001a282531832a4a89a2d5aa19bc4c..ee40072be6577eef41095fcd34aa7e2e60f74e15 100644 --- a/notification/ces_standard/subscribeandpublish/BUILD.gn +++ b/notification/ces_standard/subscribeandpublish/BUILD.gn @@ -18,8 +18,7 @@ group("SubscribeAndPublish") { if (is_standard_system) { deps = [ "actssubscriberorderedtest:ActsSubscriberOrderTest", - - #"actssubscriberunordersystemtest:ActsSubscriberTestUnorderSystem", + "actssubscriberunordersystemtest:ActsSubscriberTestUnorderSystem", "actssubscriberunordertest:ActsSubscriberUnorderTest", ] } diff --git a/notification/ces_standard/subscribeandpublish/actssubscriberorderedtest/entry/src/main/js/test/ActsSubscriber_test_ordered.js b/notification/ces_standard/subscribeandpublish/actssubscriberorderedtest/entry/src/main/js/test/ActsSubscriber_test_ordered.js index 91771b6273aa9649fe47c771ee75372740cd5a06..8bb458c89f3ff183339d756d2b2999deac9f1e2a 100644 --- a/notification/ces_standard/subscribeandpublish/actssubscriberorderedtest/entry/src/main/js/test/ActsSubscriber_test_ordered.js +++ b/notification/ces_standard/subscribeandpublish/actssubscriberorderedtest/entry/src/main/js/test/ActsSubscriber_test_ordered.js @@ -1,529 +1,550 @@ -/* - * Copyright (c) 2021 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 Subscriber from '@ohos.commonevent' -import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index' - -describe('ActsSubscriberTestOrder', function () { - console.info("===========ActsSubscriberTestOrder start====================>"); - var num = 0, num2 = 0; - var order = false; - var commonEventSubscriber0100; - var commonEventSubscriber0101; - var commonEventSubscriber0200_1; - var commonEventSubscriber0200_2; - var commonEventSubscriber0300_1; - var commonEventSubscriber0300_2; - var commonEventSubscriber0400_1; - var commonEventSubscriber0400_2; - var commonEventSubscriber0500_1; - var commonEventSubscriber0500_2; - - function publishCallback(err) { - console.info("===============>publishCallback"); - } - - function unsubscribeCallback(err) { - console.info("===============>unsubscribeCallback"); - } - - /* - * @tc.number : ActsSubscriberTestOrder_0100 - * @tc.name : verify subscribe and publish : Check subscribe same event and publish common ordered event - * @tc.desc : Check the subscriber can receive event "publish_event0100" type of the interface (by Promise) - */ - it('ActsSubscriberTestOrder_0100', 0, async function (done) { - console.info("===============ActsSubscriberTestOrder_0100===============>"); - - var commonEventSubscribeInfo_1 = { - events: ["publish_event0100"], - priority: 10 - }; - - var commonEventSubscribeInfo_2 = { - events: ["publish_event0100"], - priority: 9 - }; - - var commonEventPublishData = { - bundleName: "publish_event0100_bundleName", - code: 1, - data: "publish_event1001_init", - isOrdered: true, - isSticky: false, - } - - async function subscriberCallBack0100(err, data) { - console.info("===============>subscriberCallBack0100========event: " + data.event); - console.info("===============>subscriberCallBack0100========bundleName: " + data.bundleName); - console.info("===============>subscriberCallBack0100=========code: " + data.code); - console.info("===============>subscriberCallBack0100=========data: " + data.data); - expect(data.event).assertEqual("publish_event0100"); - expect(data.code).assertEqual(1); - expect(data.data).assertEqual("publish_event1001_init"); - expect(data.bundleName).assertEqual("publish_event0100_bundleName"); - - commonEventSubscriber0100.setCode(2).then(()=>{ - console.info("===============>subscriberCallBack0100 setCodeCallBack promise"); - }) - - commonEventSubscriber0100.setData("publish_event1001_change").then(()=>{ - console.info("===============>subscriberCallBack0100 setDataCallBack promise"); - }) - - commonEventSubscriber0100.setCodeAndData(2, "publish_event1001_change").then(()=>{ - console.info("===============>subscriberCallBack0100 setCodeAndDataCallback promise"); - }) - - commonEventSubscriber0100.getAbortCommonEvent().then(function(data) { - console.info( - "===============>subscriberCallBack0100 getAbortCommonEventCallback1 promise abort: " + data); - }) - - commonEventSubscriber0100.clearAbortCommonEvent().then(()=>{ - console.info("===============>subscriberCallBack0100 clearAbortCommonEventCallback promise"); - }) - - commonEventSubscriber0100.getAbortCommonEvent().then(function(data) { - console.info( - "===============>subscriberCallBack0100 getAbortCommonEventCallback2 promise abort: " + data); - }) - - commonEventSubscriber0100.finishCommonEvent().then(()=>{ - console.info("===============>subscriberCallBack0100 finishCommonEvent promise"); - }) - } - - async function subscriberCallBack0101(err, data) { - console.info("===============>subscriberCallBack0101========code: " + err.code); - console.info("===============>subscriberCallBack0101========event: " + data.event); - console.info("===============>subscriberCallBack0101========bundleName: " + data.bundleName); - console.info("===============>subscriberCallBack0101=========code: " + data.code); - console.info("===============>subscriberCallBack0101=========data: " + data.data); - expect(data.event).assertEqual("publish_event0100"); - console.info("===============>subscriberCallBack0101=========1 code "+ data.code); - expect(data.code).assertEqual(2); - commonEventSubscriber0101.getCode().then(function(data) { - console.info("===============>subscriberCallBack0101 getCodeCallBack promise code: "+ data); - }) - expect(data.data).assertEqual("publish_event1001_change"); - commonEventSubscriber0100.getData().then(function(data) { - console.info("===============>subscriberCallBack0100 getDataCallBack promise data: "+ data); - }) - expect(data.bundleName).assertEqual("publish_event0100_bundleName"); - commonEventSubscriber0101.finishCommonEvent().then(()=>{ - console.info("===============>subscriberCallBack0101 finishCommonEvent promise"); - }) - done(); - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo_1 - ).then(function (data) { - console.info("===============ActsSubscriberTestOrder_0100==========createSubscriber promise1"); - commonEventSubscriber0100 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestOrder_0100=========getSubscribeInfo promise1"); - Subscriber.subscribe(commonEventSubscriber0100, subscriberCallBack0100); - }); - }) - - Subscriber.createSubscriber( - commonEventSubscribeInfo_2 - ).then(function (data) { - console.info("===============ActsSubscriberTestOrder_0100==========createSubscriber promise2"); - commonEventSubscriber0101 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestOrder_0100=========getSubscribeInfo promise2"); - Subscriber.subscribe(commonEventSubscriber0101, subscriberCallBack0101); - Subscriber.publish("publish_event0100", commonEventPublishData, publishCallback); - }); - }) - }) - - /* - * @tc.number : ActsSubscriberTestOrder_0200 - * @tc.name : verify subscribe and publish : Check subscribe different event - * and twice publish common ordered event and check unsubscribe event - * @tc.desc : Check the subscriber can receive event "publish_event0200" type of the interface (by Promise) - */ - it ('ActsSubscriberTestOrder_0200', 0, async function (done) { - console.info("===============ActsSubscriberTestOrder_0200===============>"); - - var commonEventSubscribeInfo_1 = { - events: ["publish_event0200", - "publish_event0201"], - priority: 10 - }; - - var commonEventSubscribeInfo_2 = { - events: ["publish_event0201"], - priority: 9 - }; - - var commonEventPublishData1 = { - bundleName: "publish_event0200_bundleName", - code: 1, - data: "publish_event0200_init", - isOrdered: false, - isSticky: false, - } - - var commonEventPublishData2 = { - bundleName: "publish_event0201_bundleName", - code: 1, - data: "publish_event0201_init", - isOrdered: true, - isSticky: false, - } - - async function subscriberCallBack0200_1(err, data) { - console.info("===============>subscriberCallBack0200_1========event: " + data.event); - console.info("===============>subscriberCallBack0200_1========bundleName: " + data.bundleName); - console.info("===============>subscriberCallBack0200_1=========code: " + data.code); - console.info("===============>subscriberCallBack0200_1=========data: " + data.data); - console.info("===============>subscriberCallBack0200_1=========num2: " + num2); - if (num2 == 0) { - num2++; - expect(data.event).assertEqual("publish_event0200"); - console.info("===============>subscriberCallBack0200_1=====num2:0====code: " + data.code); - expect(data.code).assertEqual(1); - expect(data.data).assertEqual("publish_event0200_init"); - expect(data.bundleName).assertEqual("publish_event0200_bundleName"); - }else { - num2 = 0; - expect(data.event).assertEqual("publish_event0201"); - console.info("===============>subscriberCallBack0200_1=====num2:1====code: " + data.code); - expect(data.code).assertEqual(1); - expect(data.data).assertEqual("publish_event0201_init"); - expect(data.bundleName).assertEqual("publish_event0201_bundleName"); - commonEventSubscriber0200_1.finishCommonEvent().then(()=>{ - console.info("===============>subscriberCallBack0200_1:num:1:finishCommonEventCallBack"); - }) - } - } - - async function subscriberCallBack0200_2(err, data) { - console.info("===============>subscriberCallBack0200_2========event: " + data.event); - console.info("===============>subscriberCallBack0200_2========bundleName: " + data.bundleName); - console.info("===============>subscriberCallBack0200_2=========code=: " + data.code); - console.info("===============>subscriberCallBack0200_2=========data: " + data.data); - - expect(data.event).assertEqual("publish_event0201"); - console.info("===============>subscriberCallBack0200_2=========code: " + data.code); - expect(data.code).assertEqual(1); - expect(data.data).assertEqual("publish_event0201_init"); - expect(data.bundleName).assertEqual("publish_event0201_bundleName"); - commonEventSubscriber0200_2.finishCommonEvent().then(()=>{ - console.info("===============>subscriberCallBack0200_2:finishCommonEventCallBack"); - }) - done(); - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo_1, - ).then(function (data) { - console.info("===============ActsSubscriberTestOrder_0200==========createSubscriber promise1"); - commonEventSubscriber0200_1 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestOrder_0200=========getSubscribeInfo promise1"); - Subscriber.subscribe(commonEventSubscriber0200_1, subscriberCallBack0200_1); - }); - }) - - Subscriber.createSubscriber( - commonEventSubscribeInfo_2, - ).then(function (data) { - console.info("===============ActsSubscriberTestOrder_0200==========createSubscriber promise2"); - commonEventSubscriber0200_2 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestOrder_0200=========getSubscribeInfo promise2"); - Subscriber.subscribe(commonEventSubscriber0200_2, subscriberCallBack0200_2); - Subscriber.unsubscribe(commonEventSubscriber0200_1,unsubscribeCallback); - Subscriber.publish("publish_event0200", commonEventPublishData1, publishCallback); - Subscriber.publish("publish_event0201", commonEventPublishData2, publishCallback); - - }); - }) - }) - - /* - * @tc.number : ActsSubscriberTestOrder_0300 - * @tc.name : verify subscribe and publish : Check subscribe different events - * and some publish common ordered events - * @tc.desc : Check the subscriber can receive event "publish_event0301" type of the interface (by Promise) - */ - it ('ActsSubscriberTestOrder_0300', 0, async function (done) { - console.info("===============ActsSubscriberTestOrder_0300===============>"); - - var commonEventSubscribeInfo_1 = { - events: ["publish_event0301"], - priority: 9 - }; - - var commonEventSubscribeInfo_2 = { - events: ["publish_event0301"], - priority: 10 - }; - - var commonEventPublishData2 = { - bundleName: "publish_event0301_bundleName", - code: 1, - data: "publish_event0301_init", - isOrdered: true, - isSticky: false, - } - - async function subscriberCallBack0300_1(err, data) { - console.info("===============>subscriberCallBack0300_1========event: " + data.event); - console.info("===============>subscriberCallBack0300_1========bundleName: " + data.bundleName); - console.info("===============>subscriberCallBack0300_1=========code: " + data.code); - console.info("===============>subscriberCallBack0300_1=========dat: " + data.data); - console.info("===============>subscriberCallBack0300_1=========order: " + order); - - expect(data.event).assertEqual("publish_event0301"); - expect(data.code).assertEqual(1); - expect(data.data).assertEqual("publish_event0301_init"); - expect(data.bundleName).assertEqual("publish_event0301_bundleName"); - expect(order).assertEqual(1); - - if (order == true) { - order = false; - } - - commonEventSubscriber0300_1.isOrderedCommonEvent().then(function(data) { - console.info( - "========>subscriberCallBack0300_1 publish_event0301 isOrderedCommonEvent promise " + data); - expect(data).assertEqual(1); - }) - commonEventSubscriber0300_1.finishCommonEvent().then(()=>{ - console.info("===============>subscriberCallBack0300_1 publish_event0301 finishCommonEventCallBack"); - }) - done(); - } - - async function subscriberCallBack0300_2(err, data) { - console.info("===============>subscriberCallBack0300_2========event: " + data.event); - console.info("===============>subscriberCallBack0300_2========bundleName: " + data.bundleName); - console.info("===============>subscriberCallBack0300_2=========code: " + data.code); - console.info("===============>subscriberCallBack0300_2=========data: " + data.data); - console.info("===============>subscriberCallBack0300_2=========order: " + order); - - expect(data.event).assertEqual("publish_event0301"); - expect(data.code).assertEqual(1); - expect(data.data).assertEqual("publish_event0301_init"); - expect(data.bundleName).assertEqual("publish_event0301_bundleName"); - - if (order == false) { - order = true; - } - - commonEventSubscriber0300_2.isOrderedCommonEvent().then(function(data) { - console.info("===============>subscriberCallBack0300_2 isOrderedCommonEvent promise " + data); - expect(data).assertEqual(1); - }) - commonEventSubscriber0300_2.finishCommonEvent().then(()=>{ - console.info("===============>subscriberCallBack0300_2 publish_event0301 finishCommonEventCallBack"); - }) - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo_1, - ).then(function (data) { - console.info("===============ActsSubscriberTestOrder_0300==========createSubscriber promise1"); - commonEventSubscriber0300_1 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestOrder_0300=========getSubscribeInfo promise1"); - Subscriber.subscribe(commonEventSubscriber0300_1, subscriberCallBack0300_1); - }); - }) - - Subscriber.createSubscriber( - commonEventSubscribeInfo_2, - ).then(function (data) { - console.info("===============ActsSubscriberTestOrder_0300==========createSubscriber promise2"); - commonEventSubscriber0300_2 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestOrder_0300=========getSubscribeInfo promise2"); - Subscriber.subscribe(commonEventSubscriber0300_2, subscriberCallBack0300_2); - var numindex = 0; - for (; numindex < 3; ++numindex) { - Subscriber.publish("publish_event0301", commonEventPublishData2, publishCallback); - } - }); - }) - }) - - /* - * @tc.number : ActsSubscriberTestOrder_0400 - * @tc.name : verify subscribe and publish : Check subscribe same events - * and publish common ordered events and check abort event - * @tc.desc : Check the subscriber can receive event "publish_event0400" type of the interface (by promise) - */ - it ('ActsSubscriberTestOrder_0400', 0, async function (done) { - console.info("===============ActsSubscriberTestOrder_0400===============>"); - - var commonEventSubscribeInfo_1 = { - events: ["publish_event0400"], - priority: 10 - }; - - var commonEventSubscribeInfo_2 = { - events: ["publish_event0400"], - priority: 9 - }; - - var commonEventPublishData = { - bundleName: "publish_event0400_bundleName", - code: 1, - data: "publish_event0400_init", - isOrdered: true, - isSticky: false, - } - - async function subscriberCallBack0400_1(err, data) { - console.info("===============>SubscriberPromise0400_1========event: " + data.event); - console.info("===============>SubscriberPromise0400_1========bundleName: " + data.bundleName); - console.info("===============>SubscriberPromise0400_1=========code: " + data.code); - console.info("===============>SubscriberPromise0400_1=========data: " + data.data); - expect(data.event).assertEqual("publish_event0400"); - expect(data.code).assertEqual(1); - expect(data.data).assertEqual("publish_event0400_init"); - expect(data.bundleName).assertEqual("publish_event0400_bundleName"); - commonEventSubscriber0400_1.getAbortCommonEvent().then(function(data) { - console.info("====>SubscriberPromise0400_1======>getAbortCommonEventPromise0400_1:1 abort2: " + data); - }); - commonEventSubscriber0400_1.abortCommonEvent().then(() => { - console.info("===============>SubscriberPromise0400_1=========>AbortCommonEventPromise0400_1"); - }); - commonEventSubscriber0400_1.getAbortCommonEvent().then(function(data) { - console.info( - "===>SubscriberPromise0400_1===========>getAbortCommonEventPromise0400_1:2 abort2: " + data); - }); - commonEventSubscriber0400_1.finishCommonEvent().then(()=> { - console.info("===============>SubscriberPromise0400_1==========>finishCommonEventPromise0400_1"); - }); - done(); - } - - async function subscriberCallBack0400_2(err, data) { - console.info("===============>SubscriberPromise0400_2========event: " + data.event); - expect().assertFail(); - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo_1 - ).then(function (data) { - console.info("===============createSubscriberPromise0400_1:1"); - commonEventSubscriber0400_1 = data; - data.getSubscribeInfo().then(function (data) { - console.info("=============GetSubscribeInfoPromisek0400_1 data.events[0]: " + data.events[0]); - expect(data.events[0]).assertEqual("publish_event0400"); - Subscriber.subscribe(commonEventSubscriber0400_1, subscriberCallBack0400_1); - }) - }) - - Subscriber.createSubscriber( - commonEventSubscribeInfo_2 - ).then(function (data) { - console.info("==================createSubscriberPromise0400_1:2"); - commonEventSubscriber0400_2 = data; - data.getSubscribeInfo().then(function (data) { - console.info("==============GetSubscribeInfoPromisek0400_1 data.events[0] : " + data.events[0]); - expect(data.events[0]).assertEqual("publish_event0400"); - Subscriber.subscribe(commonEventSubscriber0400_2, subscriberCallBack0400_2); - Subscriber.publish("publish_event0400", commonEventPublishData, publishCallback); - }) - }) - }) - - /* - * @tc.number : ActsSubscriberTestOrder_0500 - * @tc.name : verify subscribe and publish : Check subscriber same events - * and publish common ordered events and check subscriberInfo priority - * @tc.desc : Check the subscriber can receive event "publish_event0500" type of the interface (by promise) - */ - it ('ActsSubscriberTestOrder_0500', 0, async function (done) { - console.info("===============ActsSubscriberTestOrder_0500===============>"); - - var commonEventSubscribeInfo_1 = { - events: ["publish_event0500"], - priority: 1001 - }; - - var commonEventSubscribeInfo_2 = { - events: ["publish_event0500"], - priority: -101 - }; - - var commonEventPublishData = { - bundleName: "publish_event0500_bundleName", - code: 10, - data: "publish_event0500_init", - isOrdered: true, - isSticky: false, - } - - async function subscriberCallBack0500_1(err, data) { - console.info("===============>SubscriberPromise0500_1========event: " + data.event); - console.info("===============>SubscriberPromise0500_1========bundleName: " + data.bundleName); - console.info("===============>SubscriberPromise0500_1=========code: " + data.code); - console.info("===============>SubscriberPromise0500_1=========data: " + data.data); - expect(data.event).assertEqual("publish_event0500"); - expect(data.code).assertEqual(10); - expect(data.data).assertEqual("publish_event0500_init"); - expect(data.bundleName).assertEqual("publish_event0500_bundleName"); - commonEventSubscriber0500_1.finishCommonEvent().then(() => { - console.info("===============>SubscriberPromise0500_1==========>finishCommonEventPromise0500_1"); - }); - } - - async function subscriberCallBack0500_2(err, data) { - console.info("===============>SubscriberPromise0500_2========event: " + data.event); - console.info("===============>SubscriberPromise0500_2========bundleName: " + data.bundleName); - console.info("===============>SubscriberPromise0500_2=========code: " + data.code); - console.info("===============>SubscriberPromise0500_2========data: " + data.data); - expect(data.event).assertEqual("publish_event0500"); - expect(data.code).assertEqual(10); - expect(data.data).assertEqual("publish_event0500_init"); - expect(data.bundleName).assertEqual("publish_event0500_bundleName"); - done(); - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo_1 - ).then(function (data) { - console.info("===============createSubscriberPromise0500_1:1"); - commonEventSubscriber0500_1 = data; - data.getSubscribeInfo().then(function (data) { - console.info("=============GetSubscribeInfoPromisek0500_1:1 data.events[0]: " + data.events[0]); - expect(data.events[0]).assertEqual("publish_event0500"); - Subscriber.subscribe(commonEventSubscriber0500_1, subscriberCallBack0500_1); - }) - }) - - Subscriber.createSubscriber( - commonEventSubscribeInfo_2 - ).then(function (data) { - console.info("==================createSubscriberPromise0500_1:2"); - commonEventSubscriber0500_2 = data; - data.getSubscribeInfo().then(function (data) { - console.info("==============GetSubscribeInfoPromisek0500_1:2 data.events[0] : " + data.events[0]); - expect(data.events[0]).assertEqual("publish_event0500"); - Subscriber.subscribe(commonEventSubscriber0500_2, subscriberCallBack0500_2); - Subscriber.publish("publish_event0500", commonEventPublishData, publishCallback); - }) - }) - }) -}) +/* + * Copyright (c) 2021 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 Subscriber from '@ohos.commonevent' +import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index' + +describe('ActsSubscriberTestOrder', function () { + console.info("===========ActsSubscriberTestOrder start====================>"); + var num2 = 0; + var order = false; + var commonEventSubscriber0100; + var commonEventSubscriber0101; + var commonEventSubscriber0200; + var commonEventSubscriber0201; + var commonEventSubscriber0300; + var commonEventSubscriber0301; + var commonEventSubscriber0400; + var commonEventSubscriber0401; + var commonEventSubscriber0500; + var commonEventSubscriber0501; + + function publishCallback(err) { + console.info("===============>publishCallback"); + } + + function unsubscribeCallback(err) { + console.info("===============>unsubscribeCallback"); + } + + /* + * @tc.number : ActsSubscriberTestOrder_0100 + * @tc.name : verify subscribe and publish : Check subscribe same event and publish common ordered event + * @tc.desc : Check the subscriber can receive event "publish_event0100" type of the interface (by Promise) + */ + it('ActsSubscriberTestOrder_0100', 0, async function (done) { + console.info("===============ActsSubscriberTestOrder_0100===============>"); + + var commonEventSubscribeInfo1 = { + events: ["publish_event0100"], + priority: 10 + }; + + var commonEventSubscribeInfo2 = { + events: ["publish_event0100"], + priority: 9 + }; + + var commonEventPublishData = { + bundleName: "publish_event0100_bundleName", + code: 1, + data: "publish_event1001_init", + isOrdered: true, + } + + async function subscriberCallBack0100(err, data) { + console.info("===============>subscriberCallBack0100========event: " + data.event); + console.info("===============>subscriberCallBack0100========bundleName: " + data.bundleName); + console.info("===============>subscriberCallBack0100=========code: " + data.code); + console.info("===============>subscriberCallBack0100=========data: " + data.data); + expect(data.event).assertEqual("publish_event0100"); + expect(data.code).assertEqual(1); + expect(data.data).assertEqual("publish_event1001_init"); + expect(data.bundleName).assertEqual("publish_event0100_bundleName"); + + commonEventSubscriber0100.setCode(2).then(()=>{ + console.info("===============>subscriberCallBack0100 setCode promise"); + }) + + commonEventSubscriber0100.setData("publish_event1001_change").then(()=>{ + console.info("===============>subscriberCallBack0100 setData promise"); + }) + + commonEventSubscriber0100.setCodeAndData(2, "publish_event1001_change").then(()=>{ + console.info("===============>subscriberCallBack0100 setCodeAndData promise"); + }) + + commonEventSubscriber0100.getAbortCommonEvent().then(function(data) { + console.info( + "===============>subscriberCallBack0100 getAbortCommonEvent promise abort: " + data); + }) + + commonEventSubscriber0100.clearAbortCommonEvent().then(()=>{ + console.info("===============>subscriberCallBack0100 clearAbortCommonEvent promise"); + }) + + commonEventSubscriber0100.getAbortCommonEvent().then(function(data) { + console.info( + "===============>subscriberCallBack0100 getAbortCommonEvent promise abort: " + data); + }) + + commonEventSubscriber0100.finishCommonEvent().then(()=>{ + console.info("===============>subscriberCallBack0100 finishCommonEvent promise"); + }) + } + + async function subscriberCallBack0101(err, data) { + console.info("===============>subscriberCallBack0101========code: " + err.code); + console.info("===============>subscriberCallBack0101========event: " + data.event); + console.info("===============>subscriberCallBack0101========bundleName: " + data.bundleName); + console.info("===============>subscriberCallBack0101=========code: " + data.code); + console.info("===============>subscriberCallBack0101=========data: " + data.data); + expect(data.event).assertEqual("publish_event0100"); + console.info("===============>subscriberCallBack0101=========1 code "+ data.code); + expect(data.code).assertEqual(2); + commonEventSubscriber0101.getCode().then(function(data) { + console.info("===============>subscriberCallBack0101 getCode promise code: "+ data); + }) + expect(data.data).assertEqual("publish_event1001_change"); + commonEventSubscriber0100.getData().then(function(data) { + console.info("===============>subscriberCallBack0101 getData promise data: "+ data); + }) + expect(data.bundleName).assertEqual("publish_event0100_bundleName"); + commonEventSubscriber0101.finishCommonEvent().then(()=>{ + console.info("===============>subscriberCallBack0101 finishCommonEvent promise"); + }) + done(); + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo1 + ).then(function (data) { + console.info("===============ActsSubscriberTestOrder_0100==========createSubscriber promise1"); + commonEventSubscriber0100 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestOrder_0100=========getSubscribeInfo promise1"); + Subscriber.subscribe(commonEventSubscriber0100, subscriberCallBack0100); + }); + }) + + Subscriber.createSubscriber( + commonEventSubscribeInfo2 + ).then(function (data) { + console.info("===============ActsSubscriberTestOrder_0100==========createSubscriber promise2"); + commonEventSubscriber0101 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestOrder_0100=========getSubscribeInfo promise2"); + Subscriber.subscribe(commonEventSubscriber0101, subscriberCallBack0101); + setTimeout(function () { + console.debug("===================ActsSubscriberTestOrder_0100 delay 100ms=================="); + Subscriber.publish("publish_event0100", commonEventPublishData, publishCallback); + }, 100); + }); + }) + }) + + /* + * @tc.number : ActsSubscriberTestOrder_0200 + * @tc.name : verify subscribe and publish : Check subscribe different event + * and twice publish common ordered event and check unsubscribe event + * @tc.desc : Check the subscriber can receive event "publish_event0200" type of the interface (by Promise) + */ + it ('ActsSubscriberTestOrder_0200', 0, async function (done) { + console.info("===============ActsSubscriberTestOrder_0200===============>"); + + var commonEventSubscribeInfo1 = { + events: ["publish_event0200", + "publish_event0201"], + priority: 10 + }; + + var commonEventSubscribeInfo2 = { + events: ["publish_event0201"], + priority: 9 + }; + + var commonEventPublishData1 = { + bundleName: "publish_event0200_bundleName", + code: 1, + data: "publish_event0200_init", + isOrdered: false, + } + + var commonEventPublishData2 = { + bundleName: "publish_event0201_bundleName", + code: 1, + data: "publish_event0201_init", + isOrdered: true, + } + + async function subscriberCallBack0200(err, data) { + console.info("===============>subscriberCallBack0200========event: " + data.event); + console.info("===============>subscriberCallBack0200========bundleName: " + data.bundleName); + console.info("===============>subscriberCallBack0200=========code: " + data.code); + console.info("===============>subscriberCallBack0200=========data: " + data.data); + console.info("===============>subscriberCallBack0200=========num2: " + num2); + if (num2 == 0) { + num2++; + expect(data.event).assertEqual("publish_event0200"); + console.info("===============>subscriberCallBack0200=====num2:0====code: " + data.code); + expect(data.code).assertEqual(1); + expect(data.data).assertEqual("publish_event0200_init"); + expect(data.bundleName).assertEqual("publish_event0200_bundleName"); + }else { + num2 = 0; + expect(data.event).assertEqual("publish_event0201"); + console.info("===============>subscriberCallBack0200=====num2:1====code: " + data.code); + expect(data.code).assertEqual(1); + expect(data.data).assertEqual("publish_event0201_init"); + expect(data.bundleName).assertEqual("publish_event0201_bundleName"); + commonEventSubscriber0200.finishCommonEvent().then(()=>{ + console.info("===============>subscriberCallBack0200:num2:1:finishCommonEvent promise"); + }) + } + } + + async function subscriberCallBack0201(err, data) { + console.info("===============>subscriberCallBack0201========event: " + data.event); + console.info("===============>subscriberCallBack0201========bundleName: " + data.bundleName); + console.info("===============>subscriberCallBack0201=========code=: " + data.code); + console.info("===============>subscriberCallBack0201=========data: " + data.data); + + expect(data.event).assertEqual("publish_event0201"); + console.info("===============>subscriberCallBack0201=========code: " + data.code); + expect(data.code).assertEqual(1); + expect(data.data).assertEqual("publish_event0201_init"); + expect(data.bundleName).assertEqual("publish_event0201_bundleName"); + commonEventSubscriber0201.finishCommonEvent().then(()=>{ + console.info("===============>subscriberCallBack0201:finishCommonEvent promise"); + }) + done(); + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo1, + ).then(function (data) { + console.info("===============ActsSubscriberTestOrder_0200==========createSubscriber promise1"); + commonEventSubscriber0200 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestOrder_0200=========getSubscribeInfo promise1"); + Subscriber.subscribe(commonEventSubscriber0200, subscriberCallBack0200); + }); + }) + + Subscriber.createSubscriber( + commonEventSubscribeInfo2, + ).then(function (data) { + console.info("===============ActsSubscriberTestOrder_0200==========createSubscriber promise2"); + commonEventSubscriber0201 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestOrder_0200=========getSubscribeInfo promise2"); + Subscriber.subscribe(commonEventSubscriber0201, subscriberCallBack0201); + setTimeout(function () { + console.debug("===================ActsSubscriberTestOrder_0200 delay 100ms=================="); + Subscriber.unsubscribe(commonEventSubscriber0200, unsubscribeCallback); + }, 100); + setTimeout(function () { + console.debug("===================ActsSubscriberTestOrder_0200 delay 100ms=================="); + Subscriber.publish("publish_event0200", commonEventPublishData1, publishCallback); + }, 100); + setTimeout(function () { + console.debug("===================ActsSubscriberTestOrder_0200 delay 100ms=================="); + Subscriber.publish("publish_event0201", commonEventPublishData2, publishCallback); + }, 100); + }); + }) + }) + + /* + * @tc.number : ActsSubscriberTestOrder_0300 + * @tc.name : verify subscribe and publish : Check subscribe different events + * and some publish common ordered events + * @tc.desc : Check the subscriber can receive event "publish_event0301" type of the interface (by Promise) + */ + it ('ActsSubscriberTestOrder_0300', 0, async function (done) { + console.info("===============ActsSubscriberTestOrder_0300===============>"); + + var commonEventSubscribeInfo1 = { + events: ["publish_event0301"], + priority: 9 + }; + + var commonEventSubscribeInfo2 = { + events: ["publish_event0301"], + priority: 10 + }; + + var commonEventPublishData2 = { + bundleName: "publish_event0301_bundleName", + code: 1, + data: "publish_event0301_init", + isOrdered: true, + } + + var callBackNum = 0; + async function subscriberCallBack0300(err, data) { + console.info("===============>subscriberCallBack0300========event: " + data.event); + console.info("===============>subscriberCallBack0300========bundleName: " + data.bundleName); + console.info("===============>subscriberCallBack0300=========code: " + data.code); + console.info("===============>subscriberCallBack0300=========dat: " + data.data); + console.info("===============>subscriberCallBack0300=========order: " + order); + + expect(data.event).assertEqual("publish_event0301"); + expect(data.code).assertEqual(1); + expect(data.data).assertEqual("publish_event0301_init"); + expect(data.bundleName).assertEqual("publish_event0301_bundleName"); + expect(order).assertEqual(true); + + if (order == true) { + order = false; + } + + commonEventSubscriber0300.isOrderedCommonEvent().then(function(data) { + console.info("========>subscriberCallBack0300 isOrderedCommonEvent promise " + data); + expect(data).assertEqual(true); + }) + commonEventSubscriber0300.finishCommonEvent().then(()=>{ + console.info("===============>subscriberCallBack0300 finishCommonEvent promise"); + }) + + callBackNum++; + if (callBackNum == 3) { + done(); + } + } + + async function subscriberCallBack0301(err, data) { + console.info("===============>subscriberCallBack0301========event: " + data.event); + console.info("===============>subscriberCallBack0301========bundleName: " + data.bundleName); + console.info("===============>subscriberCallBack0301=========code: " + data.code); + console.info("===============>subscriberCallBack0301=========data: " + data.data); + console.info("===============>subscriberCallBack0301=========order: " + order); + + expect(data.event).assertEqual("publish_event0301"); + expect(data.code).assertEqual(1); + expect(data.data).assertEqual("publish_event0301_init"); + expect(data.bundleName).assertEqual("publish_event0301_bundleName"); + + if (order == false) { + order = true; + } + + commonEventSubscriber0301.isOrderedCommonEvent().then(function(data) { + console.info("===============>subscriberCallBack0301 isOrderedCommonEvent promise" + data); + expect(data).assertEqual(true); + }) + commonEventSubscriber0301.finishCommonEvent().then(()=>{ + console.info("===============>subscriberCallBack0301 finishCommonEvent promise"); + }) + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo1, + ).then(function (data) { + console.info("===============ActsSubscriberTestOrder_0300==========createSubscriber promise1"); + commonEventSubscriber0300 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestOrder_0300=========getSubscribeInfo promise1"); + Subscriber.subscribe(commonEventSubscriber0300, subscriberCallBack0300); + }); + }) + + Subscriber.createSubscriber( + commonEventSubscribeInfo2, + ).then(function (data) { + console.info("===============ActsSubscriberTestOrder_0300==========createSubscriber promise2"); + commonEventSubscriber0301 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestOrder_0300=========getSubscribeInfo promise2"); + Subscriber.subscribe(commonEventSubscriber0301, subscriberCallBack0301); + var numindex = 0; + for (; numindex < 3; ++numindex) { + setTimeout(function () { + console.debug("===================ActsSubscriberTestOrder_0300 delay 100ms=================="); + Subscriber.publish("publish_event0301", commonEventPublishData2, publishCallback); + }, 100); + } + }); + }) + }) + + /* + * @tc.number : ActsSubscriberTestOrder_0400 + * @tc.name : verify subscribe and publish : Check subscribe same events + * and publish common ordered events and check abort event + * @tc.desc : Check the subscriber can receive event "publish_event0400" type of the interface (by promise) + */ + it ('ActsSubscriberTestOrder_0400', 0, async function (done) { + console.info("===============ActsSubscriberTestOrder_0400===============>"); + + var commonEventSubscribeInfo1 = { + events: ["publish_event0400"], + priority: 10 + }; + + var commonEventSubscribeInfo2 = { + events: ["publish_event0400"], + priority: 9 + }; + + var commonEventPublishData = { + bundleName: "publish_event0400_bundleName", + code: 1, + data: "publish_event0400_init", + isOrdered: true, + } + + async function subscriberCallBack0400(err, data) { + console.info("===============>subscriberCallBack0400========event: " + data.event); + console.info("===============>subscriberCallBack0400========bundleName: " + data.bundleName); + console.info("===============>subscriberCallBack0400=========code: " + data.code); + console.info("===============>subscriberCallBack0400=========data: " + data.data); + expect(data.event).assertEqual("publish_event0400"); + expect(data.code).assertEqual(1); + expect(data.data).assertEqual("publish_event0400_init"); + expect(data.bundleName).assertEqual("publish_event0400_bundleName"); + commonEventSubscriber0400.getAbortCommonEvent().then(function(data) { + console.info("===============>subscriberCallBack0400 getAbortCommonEvent promise abort2: " + data); + }); + commonEventSubscriber0400.abortCommonEvent().then(() => { + console.info("===============>subscriberCallBack0400 abortCommonEvent promise"); + }); + commonEventSubscriber0400.getAbortCommonEvent().then(function(data) { + console.info( + "===============>subscriberCallBack0400 getAbortCommonEvent promise abort2: " + data); + }); + commonEventSubscriber0400.finishCommonEvent().then(()=> { + console.info("===============>subscriberCallBack0400 finishCommonEvent promise"); + }); + done(); + } + + async function subscriberCallBack0401(err, data) { + console.info("===============>subscriberCallBack0401========event: " + data.event); + expect().assertFail(); + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo1 + ).then(function (data) { + console.info("===============ActsSubscriberTestOrder_0400==========createSubscriber promise1"); + commonEventSubscriber0400 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestOrder_0400=========getSubscribeInfo promise1"); + expect(data.events[0]).assertEqual("publish_event0400"); + Subscriber.subscribe(commonEventSubscriber0400, subscriberCallBack0400); + }) + }) + + Subscriber.createSubscriber( + commonEventSubscribeInfo2 + ).then(function (data) { + console.info("===============ActsSubscriberTestOrder_0400==========createSubscriber promise2"); + commonEventSubscriber0401 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestOrder_0400=========getSubscribeInfo promise2"); + expect(data.events[0]).assertEqual("publish_event0400"); + Subscriber.subscribe(commonEventSubscriber0401, subscriberCallBack0401); + setTimeout(function () { + console.debug("===================ActsSubscriberTestOrder_0400 delay 100mss=================="); + Subscriber.publish("publish_event0400", commonEventPublishData, publishCallback); + }, 100); + }) + }) + }) + + /* + * @tc.number : ActsSubscriberTestOrder_0500 + * @tc.name : verify subscribe and publish : Check subscriber same events + * and publish common ordered events and check subscriberInfo priority + * @tc.desc : Check the subscriber can receive event "publish_event0500" type of the interface (by promise) + */ + it ('ActsSubscriberTestOrder_0500', 0, async function (done) { + console.info("===============ActsSubscriberTestOrder_0500===============>"); + + var commonEventSubscribeInfo1 = { + events: ["publish_event0500"], + priority: 1001 + }; + + var commonEventSubscribeInfo2 = { + events: ["publish_event0500"], + priority: -101 + }; + + var commonEventPublishData = { + bundleName: "publish_event0500_bundleName", + code: 10, + data: "publish_event0500_init", + isOrdered: true, + } + + async function subscriberCallBack0500(err, data) { + console.info("===============>subscriberCallBack0500========event: " + data.event); + console.info("===============>subscriberCallBack0500========bundleName: " + data.bundleName); + console.info("===============>subscriberCallBack0500=========code: " + data.code); + console.info("===============>subscriberCallBack0500=========data: " + data.data); + expect(data.event).assertEqual("publish_event0500"); + expect(data.code).assertEqual(10); + expect(data.data).assertEqual("publish_event0500_init"); + expect(data.bundleName).assertEqual("publish_event0500_bundleName"); + commonEventSubscriber0500.finishCommonEvent().then(() => { + console.info("===============>subscriberCallBack0500 finishCommonEvent promise"); + }); + } + + async function subscriberCallBack0501(err, data) { + console.info("===============>subscriberCallBack0501========event: " + data.event); + console.info("===============>subscriberCallBack0501========bundleName: " + data.bundleName); + console.info("===============>subscriberCallBack0501=========code: " + data.code); + console.info("===============>subscriberCallBack0501========data: " + data.data); + expect(data.event).assertEqual("publish_event0500"); + expect(data.code).assertEqual(10); + expect(data.data).assertEqual("publish_event0500_init"); + expect(data.bundleName).assertEqual("publish_event0500_bundleName"); + commonEventSubscriber0501.finishCommonEvent().then(() => { + console.info("===============>subscriberCallBack0501 finishCommonEvent promise"); + }); + done(); + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo1 + ).then(function (data) { + console.info("===============ActsSubscriberTestOrder_0500==========createSubscriber promise1"); + commonEventSubscriber0500 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestOrder_0500==========getSubscribeInfo promise1"); + expect(data.events[0]).assertEqual("publish_event0500"); + Subscriber.subscribe(commonEventSubscriber0500, subscriberCallBack0500); + }) + }) + + Subscriber.createSubscriber( + commonEventSubscribeInfo2 + ).then(function (data) { + console.info("===============ActsSubscriberTestOrder_0500==========createSubscriber promise2"); + commonEventSubscriber0501 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestOrder_0500==========getSubscribeInfo promise2"); + expect(data.events[0]).assertEqual("publish_event0500"); + Subscriber.subscribe(commonEventSubscriber0501, subscriberCallBack0501); + setTimeout(function () { + console.debug("===================ActsSubscriberTestOrder_0500 delay 100ms=================="); + Subscriber.publish("publish_event0500", commonEventPublishData, publishCallback); + }, 100); + }) + }) + }) +}) diff --git a/notification/ces_standard/subscribeandpublish/actssubscriberunordersystemtest/entry/src/main/js/default/pages/index/index.js b/notification/ces_standard/subscribeandpublish/actssubscriberunordersystemtest/entry/src/main/js/default/pages/index/index.js index b663350ec570dec198c3649e2294e9ce2b728f2e..fc224cb3319965d374231d453223631aabda48a2 100644 --- a/notification/ces_standard/subscribeandpublish/actssubscriberunordersystemtest/entry/src/main/js/default/pages/index/index.js +++ b/notification/ces_standard/subscribeandpublish/actssubscriberunordersystemtest/entry/src/main/js/default/pages/index/index.js @@ -34,6 +34,7 @@ export default { core.addService('expect', expectExtend) core.init() const configService = core.getDefaultService('config') + this.timeout = 100000; configService.setConfig(this) require('../../../test/List.test') diff --git a/notification/ces_standard/subscribeandpublish/actssubscriberunordertest/entry/src/main/js/test/ActsSubscriber_test_unorder.js b/notification/ces_standard/subscribeandpublish/actssubscriberunordertest/entry/src/main/js/test/ActsSubscriber_test_unorder.js index 308a7acfb2ed017d6c331bc61c1bee2c189d5d4a..88a38d835f8178c51d68c358018d979abbfa61e7 100755 --- a/notification/ces_standard/subscribeandpublish/actssubscriberunordertest/entry/src/main/js/test/ActsSubscriber_test_unorder.js +++ b/notification/ces_standard/subscribeandpublish/actssubscriberunordertest/entry/src/main/js/test/ActsSubscriber_test_unorder.js @@ -1,667 +1,668 @@ -/* - * Copyright (c) 2021 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 Subscriber from '@ohos.commonevent' -import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index' - -describe('ActsSubscriberTestUnorder', async function (done) { - console.info("===========ActsSubscriberTestUnorder start====================>"); - var commonEventSubscriber001; - var commonEventSubscriber002; - var commonEventSubscriber003; - var commonEventSubscriber004; - var commonEventSubscriber005_1; - var commonEventSubscriber005_2; - var commonEventSubscriber006; - var commonEventSubscriber007; - var commonEventSubscriber008; - var commonEventSubscriber009; - var commonEventSubscriber010_1; - var commonEventSubscriber010_2; - var commonEventSubscriber011; - var commonEventSubscriber012; - - function publishCallback(err) { - console.info("==========================>publishCallback"); - } - - function publishCallback1000_1(err) { - console.info("==========================>publishCallback"); - } - - function publishCallback1000_2(err) { - console.info("==========================>publishCallback"); - } - - function unsubscriberCallBack(err) { - console.info("==========================>unsubscriberCallBack"); - } - - /* - * @tc.number : ActsSubscriberTestUnorder_0100 - * @tc.name : verify subscribe and publish : Check subscribe and publish common event data - * @tc.desc : Check the subscriber can receive event "publish_event0100" type of the interface (by Promise) - */ - it('ActsSubscriberTestUnorder_0100', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_0100=============================>"); - function subscriberCallBack001(err, data) { - console.info("==========================>subscriberCallBack001"); - expect(data.event).assertEqual("publish_event0100"); - expect(data.bundleName).assertEqual(""); - expect(data.code).assertEqual(0); - expect(data.data).assertEqual(""); - done(); - } - - var commonEventSubscribeInfo = { - events: ["publish_event0100"], - }; - - Subscriber.createSubscriber( - commonEventSubscribeInfo - ).then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0100=========createSubscriber promise"); - commonEventSubscriber001 = data; - data.getSubscribeInfo().then(function (data){ - console.info("===============ActsSubscriberTestUnorder_0100=========getSubscribeInfo promise"); - Subscriber.subscribe(commonEventSubscriber001, subscriberCallBack001); - setTimeout(function (){ - console.info("==========ActsSubscriberTestUnorder_0100 publish start============"); - Subscriber.publish("publish_event0100", publishCallback); - }, 1000); - }); - }) - }) - - /* - * @tc.number : ActsSubscriberTestUnorder_0200 - * @tc.name : verify subscribe and publish : Check subscribe and publish common event data - * of containing special characters - * @tc.desc : Check the subscriber can receive event "@#￥#3243adsafdf_" type of the interface (by Promise) - */ - it('ActsSubscriberTestUnorder_0200', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_0200==========================>"); - - function subscriberCallBack002(err, data) { - console.info("==========================>subscriberCallBack002"); - expect(data.event).assertEqual("@#￥#3243adsafdf_"); - expect(data.bundleName).assertEqual(""); - expect(data.code).assertEqual(0); - expect(data.data).assertEqual(""); - done(); - } - - var commonEventSubscribeInfo = { - events: ["@#￥#3243adsafdf_"], - }; - - Subscriber.createSubscriber( - commonEventSubscribeInfo - ).then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0200=========createSubscriber promise"); - commonEventSubscriber002 = data; - data.getSubscribeInfo().then(function (data){ - console.info("===============ActsSubscriberTestUnorder_0200=========getSubscribeInfo promise"); - Subscriber.subscribe(commonEventSubscriber002, subscriberCallBack002); - setTimeout(function (){ - console.info("==========ActsSubscriberTestUnorder_0200 publish start============"); - Subscriber.publish("@#￥#3243adsafdf_", publishCallback); - }, 1000); - }); - }) - }) - - /* - * @tc.number : ActsSubscriberTestUnorder_0300 - * @tc.name : verify subscribe and publish : Check subscribe and publish common event data - * with publishInfo data - * @tc.desc : Check the subscriber can receive event "publish_event0300" type of the interface (by Promise) - */ - it('ActsSubscriberTestUnorder_0300', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_0300==========================>"); - var commonEventSubscribeInfo = { - events: ["publish_event0300"], - publisherDeviceId: "PublishDeviceId0300", - priority: 10, - }; - - var commonEventPublishData = { - isOrdered: false, - bundleName: "PublishBundleName0300", - code: 55, - data: "PublishData0300", - } - - function isOrderedCommonEventCallback003(err, data) { - console.info("==========================>isOrderedCommonEventCallback003"); - expect(data).assertEqual(false); - done(); - } - - function subscriberCallBack003(err, data) { - console.info("==========================>subscriberCallBack003"); - expect(data.event).assertEqual("publish_event0300"); - expect(data.bundleName).assertEqual("PublishBundleName0300"); - expect(data.code).assertEqual(55); - expect(data.data).assertEqual("PublishData0300"); - commonEventSubscriber003.isOrderedCommonEvent(isOrderedCommonEventCallback003); - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo - ).then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0300=========createSubscriber promise"); - commonEventSubscriber003 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0300=========getSubscribeInfo promise"); - Subscriber.subscribe(commonEventSubscriber003, subscriberCallBack003); - setTimeout(function (){ - console.info("==========ActsSubscriberTestUnorder_0300 publish start============"); - Subscriber.publish("publish_event0300", commonEventPublishData, publishCallback); - }, 1000); - }); - }) - }) - - /* - * @tc.number : ActsSubscriberTestUnorder_0400 - * @tc.name : verify subscribe and publish : Check subscribe and publish sticky event - * @tc.desc : Check the subscriber can receive event "publish_event0400" type of the interface (by Promise) - */ - it('ActsSubscriberTestUnorder_0400', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_0400==========================>"); - var commonEventSubscribeInfo = { - events: ["publish_event0400"] - }; - - var commonEventPublishData = { - isOrdered: false, - isSticky: true, - } - - function isStickyCommonEventCallback004(err, data) { - console.info("==========================>isStickyCommonEventCallback004 isSticky:"+ data); - expect(data).assertEqual(true); - done(); - } - - function subscriberCallBack004(err, data) { - console.info("==========================>subscriberCallBack0400"); - expect(data.event).assertEqual("publish_event0400"); - expect(data.bundleName).assertEqual(""); - expect(data.code).assertEqual(0); - expect(data.data).assertEqual(""); - commonEventSubscriber004.isStickyCommonEvent(isStickyCommonEventCallback004); - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo - ).then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0400=========createSubscriber promise"); - commonEventSubscriber004 = data; - data.getSubscribeInfo().then(function (data){ - console.info("===============ActsSubscriberTestUnorder_0400=========getSubscribeInfo promise"); - Subscriber.subscribe(commonEventSubscriber004, subscriberCallBack004); - setTimeout(function (){ - console.info("==========ActsSubscriberTestUnorder_0400 publish start============"); - Subscriber.publish("publish_event0400", commonEventPublishData, publishCallback); - }, 1000); - }); - }) - }) - - /* - * @tc.number : ActsSubscriberTestUnorder_0500 - * @tc.name : verify subscribe and publish : Check the two different subscribe and one publish, - * and check unsubscribe event - * @tc.desc : Check the subscriber can receive event "publish_event0500" type of the interface (by Promise) - */ - it('ActsSubscriberTestUnorder_0500', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_0500==========================>"); - var commonEventSubscribeInfo = { - events: ["publish_event0500"] - }; - - var commonEventPublishData = { - isOrdered: false, - isSticky: false, - } - - function subscriberCallBack005(err, data) { - console.info("==========================>subscriberCallBack0500"); - expect(data.event).assertEqual("publish_event0500"); - expect(data.bundleName).assertEqual(""); - expect(data.code).assertEqual(0); - expect(data.data).assertEqual(""); - done(); - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo - ).then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0500_1=========createSubscriber promise"); - commonEventSubscriber005_1 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0500_1=========getSubscribeInfo promise"); - Subscriber.subscribe(commonEventSubscriber005_1, subscriberCallBack005); - }); - }) - - Subscriber.createSubscriber( - commonEventSubscribeInfo - ).then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0500_2=========createSubscriber promise"); - commonEventSubscriber005_2 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0500_2=========getSubscribeInfo promise"); - Subscriber.subscribe(commonEventSubscriber005_2, subscriberCallBack005); - Subscriber.unsubscribe(commonEventSubscriber005_1, unsubscriberCallBack); - setTimeout(function (){ - console.info("==========ActsSubscriberTestUnorder_0500 publish start============"); - Subscriber.publish("publish_event0500", commonEventPublishData, publishCallback); - }, 1000); - }); - }) - }) - - /* - * @tc.number : ActsSubscriberTestUnorder_0600 - * @tc.name : verify subscribe and publish : Check one subscribe and twice publish common events - * @tc.desc : Check the subscriber can receive event "publish_event0600" type of the interface (by Promise) - */ - it('ActsSubscriberTestUnorder_0600', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_0600==========================>"); - var num = 0; - var commonEventSubscribeInfo = { - events: ["publish_event0600"] - }; - - var commonEventPublishData = { - isOrdered: false, - isSticky: false, - } - - function subscriberCallBack006(err, data) { - console.info("==========================>subscriberCallBack0600"); - expect(data.event).assertEqual("publish_event0600"); - expect(data.bundleName).assertEqual(""); - expect(data.code).assertEqual(0); - expect(data.data).assertEqual(""); - console.info("==========================>subscriberCallBack0600 num = " + num); - if (num == 0) { - num++; - } else if(num == 1) { - num = 0; - done(); - } - } - console.info("===============ActsSubscriberTestUnorder_0600 11111111111111==========================>"); - Subscriber.createSubscriber( - commonEventSubscribeInfo - ).then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0600=========createSubscriber promise"); - commonEventSubscriber006 = data; - console.info("===============ActsSubscriberTestUnorder_0600 22222222222222==========================>"); - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0700=========getSubscribeInfo promise"); - Subscriber.subscribe(commonEventSubscriber006, subscriberCallBack006); - setTimeout(function (){ - console.info("==========ActsSubscriberTestUnorder_0600 publish start============"); - Subscriber.publish("publish_event0600", commonEventPublishData, publishCallback); - Subscriber.publish("publish_event0600", commonEventPublishData, publishCallback); - }, 1000); - }); - }) - }) - - /* - * @tc.number : ActsSubscriberTestUnorder_0700 - * @tc.name : verify subscribe and publish : Check subscribe and publish common event with permission - * @tc.desc : Check the subscriber can receive event "publish_event0700" type of the interface (by Promise) - */ - it('ActsSubscriberTestUnorder_0700', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_0700==========================>"); - var commonEventSubscribeInfo = { - events: ["publish_event0700"], - publisherPermission:"publish_event0700_permission" - }; - - var commonEventPublishData = { - subscriberPermissions:["publish_event0700_permission"], - isOrdered: false, - isSticky: false, - } - - function subscriberCallBack007(err, data) { - console.info("==========================>subscriberCallBack0700"); - expect(data.event).assertEqual("publish_event0700"); - expect(data.bundleName).assertEqual(""); - expect(data.code).assertEqual(0); - expect(data.data).assertEqual(""); - done(); - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo - ).then(function (data) { - console.info("=================ActsSubscriberTestUnorder_0700=========createSubscriberPromise0700"); - commonEventSubscriber007 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0700=========getSubscribeInfo promise"); - Subscriber.subscribe(commonEventSubscriber007, subscriberCallBack007); - setTimeout(function (){ - console.info("==========ActsSubscriberTestUnorder_0700 publish start============"); - Subscriber.publish("publish_event0700", commonEventPublishData, publishCallback); - }, 1000); - }); - }); - }) - - /* - * @tc.number : ActsSubscriberTestUnorder_0800 - * @tc.name : verify subscribe and publish : Check subscribe and publish common event - * with permission and check IsOrderedCommonEvent - * @tc.desc : Check the subscriber can receive event "publish_event0800" type of the interface (by Promise) - */ - it('ActsSubscriberTestUnorder_0800', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_0800==========================>"); - var commonEventSubscribeInfo = { - events: ["publish_event0800"], - publisherPermission:"publish_event0800_publisherPermission" - }; - - var commonEventPublishData = { - subscriberPermissions:["publish_event0800_subscriberPermissions"], - isOrdered: false, - isSticky: false - } - - function isOrderedCommonEventCallback009(err, data) { - console.info("==========================>isOrderedCommonEventCallback008"); - expect(data).assertEqual(false); - done(); - } - - function sleep(delay) { - var start = (new Date()).getTime(); - while((new Date()).getTime() - start < delay) { - continue; - } - done(); - } - - function subscriberCallBack008(err, data) { - console.info("==========================>subscriberCallBack0800"); - expect(data.event).assertEqual("publish_event0800"); - expect(data.bundleName).assertEqual(""); - expect(data.code).assertEqual(0); - expect(data.data).assertEqual(""); - expect().assertFail(); - commonEventSubscriber008.isOrderedCommonEvent(isOrderedCommonEventCallback009); - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo - ).then(function (data) { - console.info("==========================>createSubscriberPromise0800=======================>"); - commonEventSubscriber008 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0800=========getSubscribeInfo promise"); - Subscriber.subscribe(commonEventSubscriber008, subscriberCallBack008); - setTimeout(function (){ - console.debug("==========ActsSubscriberTestUnorder_0800 publish start============"); - Subscriber.publish("publish_event0800", commonEventPublishData, publishCallback); - }, 1000); - }); - }); - sleep(5); - }) - - /* - * @tc.number : ActsSubscriberTestUnorder_0900 - * @tc.name : verify subscribe and publish : Check subscribe and publish sticky event - * with publishpermission and check IsStickyCommonEvent - * @tc.desc : Check the subscriber can receive event "publish_event0900" type of the interface (by Promise) - */ - it('ActsSubscriberTestUnorder_0900', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_0900==========================>"); - var commonEventSubscribeInfo = { - events: ["publish_event0900"] - }; - - var commonEventPublishData = { - subscriberPermissions:["publish_event0900_permission"], - isOrdered: false, - isSticky: true - } - - function isStickyCommonEventCallback009(err, data) { - console.info("==========================>isStickyCommonEventCallback009"); - expect(data).assertEqual(true); - done(); - } - - function subscriberCallBack009(err, data) { - console.info("==========================>subscriberCallBack0900"); - expect(data.event).assertEqual("publish_event0900"); - expect(data.bundleName).assertEqual(""); - expect(data.code).assertEqual(0); - expect(data.data).assertEqual(""); - commonEventSubscriber009.isStickyCommonEvent(isStickyCommonEventCallback009); - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo - ).then(function (data) { - console.info("==========================>createSubscriberPromise0900=======================>"); - commonEventSubscriber009 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestUnorder_0900=========getSubscribeInfo promise="); - Subscriber.subscribe(commonEventSubscriber009, subscriberCallBack009); - setTimeout(function (){ - console.info("==========ActsSubscriberTestUnorder_0900 publish start============"); - Subscriber.publish("publish_event0900", commonEventPublishData, publishCallback); - }, 1000); - }); - }); - }) - - /* - * @tc.number : ActsSubscriberTestUnorder_1000 - * @tc.name : verify subscribe and publish : Check different subscribes and publish different common event - * @tc.desc : Check the subscriber can receive event "publish_event1000" type of the interface - */ - it('ActsSubscriberTestUnorder_1000', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_1000==========================>"); - - var num = 0; - - var commonEventSubscribeInfo_1 = { - events: ["publish_event1000_1"], - priority: 5 - }; - - var commonEventSubscribeInfo_2 = { - events: ["publish_event1000_2"], - priority: 10 - }; - - var commonEventPublishData_1 = { - bundleName: "publish_event1000_bundleName1", - code: 3, - data: "publish_event1000_data", - isOrdered: false, - isSticky: false, - } - - var commonEventPublishData_2 = { - bundleName: "publish_event1000_bundleName2", - code: 5, - data: "publish_event1000_data", - isOrdered: false, - isSticky: false, - } - - async function subscriberCallBack010_1(err, data) { - console.info("==========================>subscriberCallBack010_1"); - console.info("==========================>subscriberCallBack010_1 event:"+data.event); - console.info("==========================>subscriberCallBack010_1 bundleName:"+data.bundleName); - expect(data.event).assertEqual("publish_event1000_1"); - expect(data.bundleName).assertEqual("publish_event1000_bundleName1"); - expect(data.code).assertEqual(3); - expect(data.data).assertEqual("publish_event1000_data"); - if (num == 0) { - num++; - }else if (num == 1) { - done(); - } - } - - function subscriberCallBack010_2(err, data) { - console.info("==========================>subscriberCallBack010_2"); - console.info("==========================>subscriberCallBack010_2 event:"+data.event); - console.info("==========================>subscriberCallBack010_2 bundleName:"+data.bundleName); - expect(data.event).assertEqual("publish_event1000_2"); - expect(data.bundleName).assertEqual("publish_event1000_bundleName2"); - expect(data.code).assertEqual(5); - expect(data.data).assertEqual("publish_event1000_data"); - if (num == 0) { - num++; - }else if (num == 1) { - done(); - } - } - - Subscriber.createSubscriber( - commonEventSubscribeInfo_1 - ).then(function (data) { - console.info("=================ActsSubscriberTestUnorder_1000=========>createSubscriber Promise1000_1"); - commonEventSubscriber010_1 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestUnorder_1000=========getSubscribeInfo promise1000_1"); - Subscriber.subscribe(commonEventSubscriber010_1, subscriberCallBack010_1); - }); - }); - - Subscriber.createSubscriber( - commonEventSubscribeInfo_2 - ).then(function (data) { - console.info("=================ActsSubscriberTestUnorder_1000=========>createSubscriber Promise1000_2"); - commonEventSubscriber010_2 = data; - data.getSubscribeInfo().then(function (data) { - console.info("===============ActsSubscriberTestUnorder_1000=========getSubscribeInfo promise1000_2"); - Subscriber.subscribe(commonEventSubscriber010_2, subscriberCallBack010_2); - setTimeout(function (){ - console.info("==========ActsSubscriberTestUnorder_1000 publish start============"); - Subscriber.publish("publish_event1000_1", commonEventPublishData_1, publishCallback1000_1); - Subscriber.publish("publish_event1000_2", commonEventPublishData_2, publishCallback1000_2); - }, 1000); - }); - }); - }) - - /* - * @tc.number : ActsSubscriberTestUnorder_1100 - * @tc.name : verify subscribe and publish : Check one subscribes and publish one common event - * @tc.desc : Check the subscriber can receive event "publish_event1100" type of the callback interface - */ - it('ActsSubscriberTestUnorder_1100', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_1100==========================>"); - function subscriberCallBack011(err, data) { - console.info("==========================>subscriberCallBack011"); - expect(data.event).assertEqual("publish_event1100"); - expect(data.bundleName).assertEqual(""); - expect(data.code).assertEqual(0); - expect(data.data).assertEqual(""); - done(); - } - - var commonEventSubscribeInfo = { - events: ["publish_event1100"], - }; - - function getSubscribeInfo1100CallBack(err, data) { - console.info("==========================>getSubscribeInfo1100CallBack=======================>"); - expect(data.events[0]).assertEqual("publish_event1100"); - Subscriber.subscribe(commonEventSubscriber011, subscriberCallBack011); - setTimeout(function (){ - console.debug("==========ActsSubscriberTestUnorder_1100 publish start============"); - Subscriber.publish("publish_event1100", publishCallback); - }, 1000); - } - - function createSubscriber1100CallBack(err, data) { - console.info("==========================>createSubscriber1100CallBack=======================>"); - commonEventSubscriber011 = data; - data.getSubscribeInfo(getSubscribeInfo1100CallBack); - } - - Subscriber.createSubscriber(commonEventSubscribeInfo, createSubscriber1100CallBack); - }) - - /* - * @tc.number : ActsSubscriberTestUnorder_1200 - * @tc.name : verify subscribe and publish : Check one subscribes and publish one common event with parameters - * @tc.desc : Check the subscriber can receive event "publish_event1200" type of the callback interface - */ - it('ActsSubscriberTestUnorder_1200', 0, async function (done) { - console.info("===============ActsSubscriberTestUnorder_1200==========================>"); - function subscriberCallBack012(err, data) { - console.info("==========================>subscriberCallBack012"); - console.info("==========================>subscriberCallBack012 " + JSON.stringify(data)); - expect(data.event).assertEqual("publish_event1200"); - expect(data.bundleName).assertEqual(""); - expect(data.code).assertEqual(0); - expect(data.data).assertEqual(""); - console.info("==========================>subscriberCallBack012:key1-value = "+ data.parameters["key1"]); - console.info("==========================>subscriberCallBack012:key2-value = "+ data.parameters["key2"][0]); - console.info("==========================>subscriberCallBack012:key2-value = "+ data.parameters["key2"][1]); - console.info("==========================>subscriberCallBack012:key3-value = "+ data.parameters["key3"]); - done(); - } - - var commonEventSubscribeInfo = { - events: ["publish_event1200"], - }; - - var commonEventPublishData = { - isOrdered: false, - isSticky: false, - parameters: { - key1: "ActsSubscriberTestUnorder_1200_key", - key2: [100,200], - key3: 44 - } - } - - function getSubscribeInfo1200CallBack(err, data) { - console.info("==========================>getSubscribeInfo1200CallBack=======================>"); - expect(data.events[0]).assertEqual("publish_event1200"); - Subscriber.subscribe(commonEventSubscriber012, subscriberCallBack012); - setTimeout(function (){ - console.info("==========ActsSubscriberTestUnorder_1200 publish start============"); - Subscriber.publish("publish_event1200", commonEventPublishData, publishCallback); - }, 1000); - } - - function createSubscriber1200CallBack(err, data) { - console.info("==========================>createSubscriber1200CallBack=======================>"); - commonEventSubscriber012 = data; - data.getSubscribeInfo(getSubscribeInfo1200CallBack); - } - - Subscriber.createSubscriber(commonEventSubscribeInfo, createSubscriber1200CallBack); - }) -}) - +/* + * Copyright (c) 2021 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 Subscriber from '@ohos.commonevent' +import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index' + +describe('ActsSubscriberTestUnorder', async function (done) { + console.info("===========ActsSubscriberTestUnorder start====================>"); + var commonEventSubscriber001; + var commonEventSubscriber002; + var commonEventSubscriber003; + var commonEventSubscriber004; + var commonEventSubscriber005_1; + var commonEventSubscriber005_2; + var commonEventSubscriber006; + var commonEventSubscriber007; + var commonEventSubscriber008; + var commonEventSubscriber009; + var commonEventSubscriber010_1; + var commonEventSubscriber010_2; + var commonEventSubscriber011; + var commonEventSubscriber012; + + function publishCallback(err) { + console.info("==========================>publishCallback"); + } + + function publishCallback1000_1(err) { + console.info("==========================>publishCallback"); + } + + function publishCallback1000_2(err) { + console.info("==========================>publishCallback"); + } + + function unsubscriberCallBack(err) { + console.info("==========================>unsubscriberCallBack"); + } + + /* + * @tc.number : ActsSubscriberTestUnorder_0100 + * @tc.name : verify subscribe and publish : Check subscribe and publish common event data + * @tc.desc : Check the subscriber can receive event "publish_event0100" type of the interface (by Promise) + */ + it('ActsSubscriberTestUnorder_0100', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_0100=============================>"); + function subscriberCallBack001(err, data) { + console.info("==========================>subscriberCallBack001"); + expect(data.event).assertEqual("publish_event0100"); + expect(data.bundleName).assertEqual(""); + expect(data.code).assertEqual(0); + expect(data.data).assertEqual(""); + done(); + } + + var commonEventSubscribeInfo = { + events: ["publish_event0100"], + }; + + Subscriber.createSubscriber( + commonEventSubscribeInfo + ).then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0100=========createSubscriber promise"); + commonEventSubscriber001 = data; + data.getSubscribeInfo().then(function (data){ + console.info("===============ActsSubscriberTestUnorder_0100=========getSubscribeInfo promise"); + Subscriber.subscribe(commonEventSubscriber001, subscriberCallBack001); + setTimeout(function (){ + console.info("==========ActsSubscriberTestUnorder_0100 publish start============"); + Subscriber.publish("publish_event0100", publishCallback); + }, 1000); + }); + }) + }) + + /* + * @tc.number : ActsSubscriberTestUnorder_0200 + * @tc.name : verify subscribe and publish : Check subscribe and publish common event data + * of containing special characters + * @tc.desc : Check the subscriber can receive event "@#￥#3243adsafdf_" type of the interface (by Promise) + */ + it('ActsSubscriberTestUnorder_0200', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_0200==========================>"); + + function subscriberCallBack002(err, data) { + console.info("==========================>subscriberCallBack002"); + expect(data.event).assertEqual("@#￥#3243adsafdf_"); + expect(data.bundleName).assertEqual(""); + expect(data.code).assertEqual(0); + expect(data.data).assertEqual(""); + done(); + } + + var commonEventSubscribeInfo = { + events: ["@#￥#3243adsafdf_"], + }; + + Subscriber.createSubscriber( + commonEventSubscribeInfo + ).then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0200=========createSubscriber promise"); + commonEventSubscriber002 = data; + data.getSubscribeInfo().then(function (data){ + console.info("===============ActsSubscriberTestUnorder_0200=========getSubscribeInfo promise"); + Subscriber.subscribe(commonEventSubscriber002, subscriberCallBack002); + setTimeout(function (){ + console.info("==========ActsSubscriberTestUnorder_0200 publish start============"); + Subscriber.publish("@#￥#3243adsafdf_", publishCallback); + }, 1000); + }); + }) + }) + + /* + * @tc.number : ActsSubscriberTestUnorder_0300 + * @tc.name : verify subscribe and publish : Check subscribe and publish common event data + * with publishInfo data + * @tc.desc : Check the subscriber can receive event "publish_event0300" type of the interface (by Promise) + */ + it('ActsSubscriberTestUnorder_0300', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_0300==========================>"); + var commonEventSubscribeInfo = { + events: ["publish_event0300"], + publisherDeviceId: "PublishDeviceId0300", + priority: 10, + }; + + var commonEventPublishData = { + isOrdered: false, + bundleName: "PublishBundleName0300", + code: 55, + data: "PublishData0300", + } + + function isOrderedCommonEventCallback003(err, data) { + console.info("==========================>isOrderedCommonEventCallback003"); + expect(data).assertEqual(false); + done(); + } + + function subscriberCallBack003(err, data) { + console.info("==========================>subscriberCallBack003"); + expect(data.event).assertEqual("publish_event0300"); + expect(data.bundleName).assertEqual("PublishBundleName0300"); + expect(data.code).assertEqual(55); + expect(data.data).assertEqual("PublishData0300"); + commonEventSubscriber003.isOrderedCommonEvent(isOrderedCommonEventCallback003); + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo + ).then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0300=========createSubscriber promise"); + commonEventSubscriber003 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0300=========getSubscribeInfo promise"); + Subscriber.subscribe(commonEventSubscriber003, subscriberCallBack003); + setTimeout(function (){ + console.info("==========ActsSubscriberTestUnorder_0300 publish start============"); + Subscriber.publish("publish_event0300", commonEventPublishData, publishCallback); + }, 1000); + }); + }) + }) + + /* + * @tc.number : ActsSubscriberTestUnorder_0400 + * @tc.name : verify subscribe and publish : Check subscribe and publish sticky event + * @tc.desc : Check the subscriber can receive event "publish_event0400" type of the interface (by Promise) + */ + it('ActsSubscriberTestUnorder_0400', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_0400==========================>"); + var commonEventSubscribeInfo = { + events: ["publish_event0400"] + }; + + var commonEventPublishData = { + isOrdered: false, + isSticky: true, + } + + function isStickyCommonEventCallback004(err, data) { + console.info("==========================>isStickyCommonEventCallback004 isSticky:"+ data); + expect(data).assertEqual(true); + done(); + } + + function subscriberCallBack004(err, data) { + console.info("==========================>subscriberCallBack0400"); + expect(data.event).assertEqual("publish_event0400"); + expect(data.bundleName).assertEqual(""); + expect(data.code).assertEqual(0); + expect(data.data).assertEqual(""); + commonEventSubscriber004.isStickyCommonEvent(isStickyCommonEventCallback004); + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo + ).then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0400=========createSubscriber promise"); + commonEventSubscriber004 = data; + data.getSubscribeInfo().then(function (data){ + console.info("===============ActsSubscriberTestUnorder_0400=========getSubscribeInfo promise"); + Subscriber.subscribe(commonEventSubscriber004, subscriberCallBack004); + setTimeout(function (){ + console.info("==========ActsSubscriberTestUnorder_0400 publish start============"); + Subscriber.publish("publish_event0400", commonEventPublishData, publishCallback); + }, 1000); + }); + }) + }) + + /* + * @tc.number : ActsSubscriberTestUnorder_0500 + * @tc.name : verify subscribe and publish : Check the two different subscribe and one publish, + * and check unsubscribe event + * @tc.desc : Check the subscriber can receive event "publish_event0500" type of the interface (by Promise) + */ + it('ActsSubscriberTestUnorder_0500', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_0500==========================>"); + var commonEventSubscribeInfo = { + events: ["publish_event0500"] + }; + + var commonEventPublishData = { + isOrdered: false, + isSticky: false, + } + + function subscriberCallBack005(err, data) { + console.info("==========================>subscriberCallBack0500"); + expect(data.event).assertEqual("publish_event0500"); + expect(data.bundleName).assertEqual(""); + expect(data.code).assertEqual(0); + expect(data.data).assertEqual(""); + done(); + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo + ).then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0500_1=========createSubscriber promise"); + commonEventSubscriber005_1 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0500_1=========getSubscribeInfo promise"); + Subscriber.subscribe(commonEventSubscriber005_1, subscriberCallBack005); + }); + }) + + Subscriber.createSubscriber( + commonEventSubscribeInfo + ).then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0500_2=========createSubscriber promise"); + commonEventSubscriber005_2 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0500_2=========getSubscribeInfo promise"); + Subscriber.subscribe(commonEventSubscriber005_2, subscriberCallBack005); + Subscriber.unsubscribe(commonEventSubscriber005_1, unsubscriberCallBack); + setTimeout(function (){ + console.info("==========ActsSubscriberTestUnorder_0500 publish start============"); + Subscriber.publish("publish_event0500", commonEventPublishData, publishCallback); + }, 1000); + }); + }) + }) + + /* + * @tc.number : ActsSubscriberTestUnorder_0600 + * @tc.name : verify subscribe and publish : Check one subscribe and twice publish common events + * @tc.desc : Check the subscriber can receive event "publish_event0600" type of the interface (by Promise) + */ + it('ActsSubscriberTestUnorder_0600', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_0600==========================>"); + var num = 0; + var commonEventSubscribeInfo = { + events: ["publish_event0600"] + }; + + var commonEventPublishData = { + isOrdered: false, + isSticky: false, + } + + function subscriberCallBack006(err, data) { + console.info("==========================>subscriberCallBack0600"); + expect(data.event).assertEqual("publish_event0600"); + expect(data.bundleName).assertEqual(""); + expect(data.code).assertEqual(0); + expect(data.data).assertEqual(""); + console.info("==========================>subscriberCallBack0600 num = " + num); + if (num == 0) { + num++; + } else if(num == 1) { + num = 0; + done(); + } + } + console.info("===============ActsSubscriberTestUnorder_0600 11111111111111==========================>"); + Subscriber.createSubscriber( + commonEventSubscribeInfo + ).then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0600=========createSubscriber promise"); + commonEventSubscriber006 = data; + console.info("===============ActsSubscriberTestUnorder_0600 22222222222222==========================>"); + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0700=========getSubscribeInfo promise"); + Subscriber.subscribe(commonEventSubscriber006, subscriberCallBack006); + setTimeout(function (){ + console.info("==========ActsSubscriberTestUnorder_0600 publish start============"); + Subscriber.publish("publish_event0600", commonEventPublishData, publishCallback); + Subscriber.publish("publish_event0600", commonEventPublishData, publishCallback); + }, 1000); + }); + }) + }) + + /* + * @tc.number : ActsSubscriberTestUnorder_0700 + * @tc.name : verify subscribe and publish : Check subscribe and publish common event with permission + * @tc.desc : Check the subscriber can receive event "publish_event0700" type of the interface (by Promise) + */ + it('ActsSubscriberTestUnorder_0700', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_0700==========================>"); + var commonEventSubscribeInfo = { + events: ["publish_event0700"], + publisherPermission:"publish_event0700_permission" + }; + + var commonEventPublishData = { + subscriberPermissions:["publish_event0700_permission"], + isOrdered: false, + isSticky: false, + } + + function subscriberCallBack007(err, data) { + console.info("==========================>subscriberCallBack0700"); + expect(data.event).assertEqual("publish_event0700"); + expect(data.bundleName).assertEqual(""); + expect(data.code).assertEqual(0); + expect(data.data).assertEqual(""); + done(); + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo + ).then(function (data) { + console.info("=================ActsSubscriberTestUnorder_0700=========createSubscriberPromise0700"); + commonEventSubscriber007 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0700=========getSubscribeInfo promise"); + Subscriber.subscribe(commonEventSubscriber007, subscriberCallBack007); + setTimeout(function (){ + console.info("==========ActsSubscriberTestUnorder_0700 publish start============"); + Subscriber.publish("publish_event0700", commonEventPublishData, publishCallback); + }, 1000); + }); + }); + }) + + /* + * @tc.number : ActsSubscriberTestUnorder_0800 + * @tc.name : verify subscribe and publish : Check subscribe and publish common event + * with permission and check IsOrderedCommonEvent + * @tc.desc : Check the subscriber can receive event "publish_event0800" type of the interface (by Promise) + */ + it('ActsSubscriberTestUnorder_0800', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_0800==========================>"); + var commonEventSubscribeInfo = { + events: ["publish_event0800"], + publisherPermission:"publish_event0800_publisherPermission" + }; + + var commonEventPublishData = { + subscriberPermissions:["publish_event0800_subscriberPermissions"], + isOrdered: false, + isSticky: false + } + + function isOrderedCommonEventCallback009(err, data) { + console.info("==========================>isOrderedCommonEventCallback008"); + expect(data).assertEqual(false); + done(); + } + + function sleep(delay) { + var start = (new Date()).getTime(); + while((new Date()).getTime() - start < delay) { + continue; + } + done(); + } + + function subscriberCallBack008(err, data) { + console.info("==========================>subscriberCallBack0800"); + expect(data.event).assertEqual("publish_event0800"); + expect(data.bundleName).assertEqual(""); + expect(data.code).assertEqual(0); + expect(data.data).assertEqual(""); + expect().assertFail(); + commonEventSubscriber008.isOrderedCommonEvent(isOrderedCommonEventCallback009); + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo + ).then(function (data) { + console.info("==========================>createSubscriberPromise0800=======================>"); + commonEventSubscriber008 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0800=========getSubscribeInfo promise"); + Subscriber.subscribe(commonEventSubscriber008, subscriberCallBack008); + setTimeout(function (){ + console.debug("==========ActsSubscriberTestUnorder_0800 publish start============"); + Subscriber.publish("publish_event0800", commonEventPublishData, publishCallback); + }, 1000); + }); + }); + + sleep(1000); + }) + + /* + * @tc.number : ActsSubscriberTestUnorder_0900 + * @tc.name : verify subscribe and publish : Check subscribe and publish sticky event + * with publishpermission and check IsStickyCommonEvent + * @tc.desc : Check the subscriber can receive event "publish_event0900" type of the interface (by Promise) + */ + it('ActsSubscriberTestUnorder_0900', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_0900==========================>"); + var commonEventSubscribeInfo = { + events: ["publish_event0900"] + }; + + var commonEventPublishData = { + subscriberPermissions:["publish_event0900_permission"], + isOrdered: false, + isSticky: true + } + + function isStickyCommonEventCallback009(err, data) { + console.info("==========================>isStickyCommonEventCallback009"); + expect(data).assertEqual(true); + done(); + } + + function subscriberCallBack009(err, data) { + console.info("==========================>subscriberCallBack0900"); + expect(data.event).assertEqual("publish_event0900"); + expect(data.bundleName).assertEqual(""); + expect(data.code).assertEqual(0); + expect(data.data).assertEqual(""); + commonEventSubscriber009.isStickyCommonEvent(isStickyCommonEventCallback009); + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo + ).then(function (data) { + console.info("==========================>createSubscriberPromise0900=======================>"); + commonEventSubscriber009 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestUnorder_0900=========getSubscribeInfo promise="); + Subscriber.subscribe(commonEventSubscriber009, subscriberCallBack009); + setTimeout(function (){ + console.info("==========ActsSubscriberTestUnorder_0900 publish start============"); + Subscriber.publish("publish_event0900", commonEventPublishData, publishCallback); + }, 1000); + }); + }); + }) + + /* + * @tc.number : ActsSubscriberTestUnorder_1000 + * @tc.name : verify subscribe and publish : Check different subscribes and publish different common event + * @tc.desc : Check the subscriber can receive event "publish_event1000" type of the interface + */ + it('ActsSubscriberTestUnorder_1000', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_1000==========================>"); + + var num = 0; + + var commonEventSubscribeInfo_1 = { + events: ["publish_event1000_1"], + priority: 5 + }; + + var commonEventSubscribeInfo_2 = { + events: ["publish_event1000_2"], + priority: 10 + }; + + var commonEventPublishData_1 = { + bundleName: "publish_event1000_bundleName1", + code: 3, + data: "publish_event1000_data", + isOrdered: false, + isSticky: false, + } + + var commonEventPublishData_2 = { + bundleName: "publish_event1000_bundleName2", + code: 5, + data: "publish_event1000_data", + isOrdered: false, + isSticky: false, + } + + async function subscriberCallBack010_1(err, data) { + console.info("==========================>subscriberCallBack010_1"); + console.info("==========================>subscriberCallBack010_1 event:"+data.event); + console.info("==========================>subscriberCallBack010_1 bundleName:"+data.bundleName); + expect(data.event).assertEqual("publish_event1000_1"); + expect(data.bundleName).assertEqual("publish_event1000_bundleName1"); + expect(data.code).assertEqual(3); + expect(data.data).assertEqual("publish_event1000_data"); + if (num == 0) { + num++; + }else if (num == 1) { + done(); + } + } + + function subscriberCallBack010_2(err, data) { + console.info("==========================>subscriberCallBack010_2"); + console.info("==========================>subscriberCallBack010_2 event:"+data.event); + console.info("==========================>subscriberCallBack010_2 bundleName:"+data.bundleName); + expect(data.event).assertEqual("publish_event1000_2"); + expect(data.bundleName).assertEqual("publish_event1000_bundleName2"); + expect(data.code).assertEqual(5); + expect(data.data).assertEqual("publish_event1000_data"); + if (num == 0) { + num++; + }else if (num == 1) { + done(); + } + } + + Subscriber.createSubscriber( + commonEventSubscribeInfo_1 + ).then(function (data) { + console.info("=================ActsSubscriberTestUnorder_1000=========>createSubscriber Promise1000_1"); + commonEventSubscriber010_1 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestUnorder_1000=========getSubscribeInfo promise1000_1"); + Subscriber.subscribe(commonEventSubscriber010_1, subscriberCallBack010_1); + }); + }); + + Subscriber.createSubscriber( + commonEventSubscribeInfo_2 + ).then(function (data) { + console.info("=================ActsSubscriberTestUnorder_1000=========>createSubscriber Promise1000_2"); + commonEventSubscriber010_2 = data; + data.getSubscribeInfo().then(function (data) { + console.info("===============ActsSubscriberTestUnorder_1000=========getSubscribeInfo promise1000_2"); + Subscriber.subscribe(commonEventSubscriber010_2, subscriberCallBack010_2); + setTimeout(function (){ + console.info("==========ActsSubscriberTestUnorder_1000 publish start============"); + Subscriber.publish("publish_event1000_1", commonEventPublishData_1, publishCallback1000_1); + Subscriber.publish("publish_event1000_2", commonEventPublishData_2, publishCallback1000_2); + }, 1000); + }); + }); + }) + + /* + * @tc.number : ActsSubscriberTestUnorder_1100 + * @tc.name : verify subscribe and publish : Check one subscribes and publish one common event + * @tc.desc : Check the subscriber can receive event "publish_event1100" type of the callback interface + */ + it('ActsSubscriberTestUnorder_1100', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_1100==========================>"); + function subscriberCallBack011(err, data) { + console.info("==========================>subscriberCallBack011"); + expect(data.event).assertEqual("publish_event1100"); + expect(data.bundleName).assertEqual(""); + expect(data.code).assertEqual(0); + expect(data.data).assertEqual(""); + done(); + } + + var commonEventSubscribeInfo = { + events: ["publish_event1100"], + }; + + function getSubscribeInfo1100CallBack(err, data) { + console.info("==========================>getSubscribeInfo1100CallBack=======================>"); + expect(data.events[0]).assertEqual("publish_event1100"); + Subscriber.subscribe(commonEventSubscriber011, subscriberCallBack011); + setTimeout(function (){ + console.debug("==========ActsSubscriberTestUnorder_1100 publish start============"); + Subscriber.publish("publish_event1100", publishCallback); + }, 1000); + } + + function createSubscriber1100CallBack(err, data) { + console.info("==========================>createSubscriber1100CallBack=======================>"); + commonEventSubscriber011 = data; + data.getSubscribeInfo(getSubscribeInfo1100CallBack); + } + + Subscriber.createSubscriber(commonEventSubscribeInfo, createSubscriber1100CallBack); + }) + + /* + * @tc.number : ActsSubscriberTestUnorder_1200 + * @tc.name : verify subscribe and publish : Check one subscribes and publish one common event with parameters + * @tc.desc : Check the subscriber can receive event "publish_event1200" type of the callback interface + */ + it('ActsSubscriberTestUnorder_1200', 0, async function (done) { + console.info("===============ActsSubscriberTestUnorder_1200==========================>"); + function subscriberCallBack012(err, data) { + console.info("==========================>subscriberCallBack012"); + console.info("==========================>subscriberCallBack012 " + JSON.stringify(data)); + expect(data.event).assertEqual("publish_event1200"); + expect(data.bundleName).assertEqual(""); + expect(data.code).assertEqual(0); + expect(data.data).assertEqual(""); + console.info("==========================>subscriberCallBack012:key1-value = "+ data.parameters["key1"]); + console.info("==========================>subscriberCallBack012:key2-value = "+ data.parameters["key2"][0]); + console.info("==========================>subscriberCallBack012:key2-value = "+ data.parameters["key2"][1]); + console.info("==========================>subscriberCallBack012:key3-value = "+ data.parameters["key3"]); + done(); + } + + var commonEventSubscribeInfo = { + events: ["publish_event1200"], + }; + + var commonEventPublishData = { + isOrdered: false, + isSticky: false, + parameters: { + key1: "ActsSubscriberTestUnorder_1200_key", + key2: [100,200], + key3: 44 + } + } + + function getSubscribeInfo1200CallBack(err, data) { + console.info("==========================>getSubscribeInfo1200CallBack=======================>"); + expect(data.events[0]).assertEqual("publish_event1200"); + Subscriber.subscribe(commonEventSubscriber012, subscriberCallBack012); + setTimeout(function (){ + console.info("==========ActsSubscriberTestUnorder_1200 publish start============"); + Subscriber.publish("publish_event1200", commonEventPublishData, publishCallback); + }, 1000); + } + + function createSubscriber1200CallBack(err, data) { + console.info("==========================>createSubscriber1200CallBack=======================>"); + commonEventSubscriber012 = data; + data.getSubscribeInfo(getSubscribeInfo1200CallBack); + } + + Subscriber.createSubscriber(commonEventSubscribeInfo, createSubscriber1200CallBack); + }) +}) +