Skip to content

X
Xts Acts

OpenHarmony / Xts Acts
接近 2 年 前同步成功

通知 9
Star 22
Fork 0
X
Xts Acts
提交 d4ba8ea5 编写于 作者: O openharmony_ci 提交者： Gitee
浏览文件
操作

!1264 Modify xts case bug 

Merge pull request !1264 from blackleon/master_1202_xtsces
上级 4136e9e8 9ef4ab80
隐藏空白更改
内联 并排
Showing with 1516 addition and 1495 deletion
notification/ces_standard/subscribeandpublish/actssubscriberorderedtest/entry/src/main/js/test/ActsSubscriber_test_ordered.js
浏览文件 @ d4ba8ea5
/* /*
* Copyright (c) 2021 Huawei Device Co., Ltd. * Copyright (c) 2021 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
* You may obtain a copy of the License at * You may obtain a copy of the License at
* *
* http://www.apache.org/licenses/LICENSE-2.0 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
import Subscriber from '@ohos.commonevent' import Subscriber from '@ohos.commonevent'
import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index' import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index'
describe('ActsSubscriberTestOrder', function () { describe('ActsSubscriberTestOrder', function () {
console.info("===========ActsSubscriberTestOrder start====================>"); console.info("===========ActsSubscriberTestOrder start====================>");
var num = 0, num2 = 0; var num2 = 0;
var order = false; var order = false;
var commonEventSubscriber0100; var commonEventSubscriber0100;
var commonEventSubscriber0101; var commonEventSubscriber0101;
var commonEventSubscriber0200; var commonEventSubscriber0200;
var commonEventSubscriber0201; var commonEventSubscriber0201;
var commonEventSubscriber0300; var commonEventSubscriber0300;
var commonEventSubscriber0301; var commonEventSubscriber0301;
var commonEventSubscriber0400; var commonEventSubscriber0400;
var commonEventSubscriber0401; var commonEventSubscriber0401;
var commonEventSubscriber0500; var commonEventSubscriber0500;
var commonEventSubscriber0501; var commonEventSubscriber0501;
function publishCallback(err) { function publishCallback(err) {
console.info("===============>publishCallback"); console.info("===============>publishCallback");
} }
function unsubscribeCallback(err) { function unsubscribeCallback(err) {
console.info("===============>unsubscribeCallback"); console.info("===============>unsubscribeCallback");
} }
/* /*
* @tc.number : ActsSubscriberTestOrder_0100 * @tc.number : ActsSubscriberTestOrder_0100
* @tc.name : verify subscribe and publish : Check subscribe same event and publish common ordered event * @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) * @tc.desc : Check the subscriber can receive event "publish_event0100" type of the interface (by Promise)
*/ */
it('ActsSubscriberTestOrder_0100', 0, async function (done) { it('ActsSubscriberTestOrder_0100', 0, async function (done) {
console.info("===============ActsSubscriberTestOrder_0100===============>"); console.info("===============ActsSubscriberTestOrder_0100===============>");
var commonEventSubscribeInfo1 = { var commonEventSubscribeInfo1 = {
events: ["publish_event0100"], events: ["publish_event0100"],
priority: 10 priority: 10
}; };
var commonEventSubscribeInfo2 = { var commonEventSubscribeInfo2 = {
events: ["publish_event0100"], events: ["publish_event0100"],
priority: 9 priority: 9
}; };
var commonEventPublishData = { var commonEventPublishData = {
bundleName: "publish_event0100_bundleName", bundleName: "publish_event0100_bundleName",
code: 1, code: 1,
data: "publish_event1001_init", data: "publish_event1001_init",
isOrdered: true, isOrdered: true,
} }
async function subscriberCallBack0100(err, data) { async function subscriberCallBack0100(err, data) {
console.info("===============>subscriberCallBack0100========event: " + data.event); console.info("===============>subscriberCallBack0100========event: " + data.event);
console.info("===============>subscriberCallBack0100========bundleName: " + data.bundleName); console.info("===============>subscriberCallBack0100========bundleName: " + data.bundleName);
console.info("===============>subscriberCallBack0100=========code: " + data.code); console.info("===============>subscriberCallBack0100=========code: " + data.code);
console.info("===============>subscriberCallBack0100=========data: " + data.data); console.info("===============>subscriberCallBack0100=========data: " + data.data);
expect(data.event).assertEqual("publish_event0100"); expect(data.event).assertEqual("publish_event0100");
expect(data.code).assertEqual(1); expect(data.code).assertEqual(1);
expect(data.data).assertEqual("publish_event1001_init"); expect(data.data).assertEqual("publish_event1001_init");
expect(data.bundleName).assertEqual("publish_event0100_bundleName"); expect(data.bundleName).assertEqual("publish_event0100_bundleName");
commonEventSubscriber0100.setCode(2).then(()=>{ commonEventSubscriber0100.setCode(2).then(()=>{
console.info("===============>subscriberCallBack0100 setCode promise"); console.info("===============>subscriberCallBack0100 setCode promise");
}) })
commonEventSubscriber0100.setData("publish_event1001_change").then(()=>{ commonEventSubscriber0100.setData("publish_event1001_change").then(()=>{
console.info("===============>subscriberCallBack0100 setData promise"); console.info("===============>subscriberCallBack0100 setData promise");
}) })
commonEventSubscriber0100.setCodeAndData(2, "publish_event1001_change").then(()=>{ commonEventSubscriber0100.setCodeAndData(2, "publish_event1001_change").then(()=>{
console.info("===============>subscriberCallBack0100 setCodeAndData promise"); console.info("===============>subscriberCallBack0100 setCodeAndData promise");
}) })
commonEventSubscriber0100.getAbortCommonEvent().then(function(data) { commonEventSubscriber0100.getAbortCommonEvent().then(function(data) {
console.info( console.info(
"===============>subscriberCallBack0100 getAbortCommonEvent promise abort: " + data); "===============>subscriberCallBack0100 getAbortCommonEvent promise abort: " + data);
}) })
commonEventSubscriber0100.clearAbortCommonEvent().then(()=>{ commonEventSubscriber0100.clearAbortCommonEvent().then(()=>{
console.info("===============>subscriberCallBack0100 clearAbortCommonEvent promise"); console.info("===============>subscriberCallBack0100 clearAbortCommonEvent promise");
}) })
commonEventSubscriber0100.getAbortCommonEvent().then(function(data) { commonEventSubscriber0100.getAbortCommonEvent().then(function(data) {
console.info( console.info(
"===============>subscriberCallBack0100 getAbortCommonEvent promise abort: " + data); "===============>subscriberCallBack0100 getAbortCommonEvent promise abort: " + data);
}) })
commonEventSubscriber0100.finishCommonEvent().then(()=>{ commonEventSubscriber0100.finishCommonEvent().then(()=>{
console.info("===============>subscriberCallBack0100 finishCommonEvent promise"); console.info("===============>subscriberCallBack0100 finishCommonEvent promise");
}) })
} }
async function subscriberCallBack0101(err, data) { async function subscriberCallBack0101(err, data) {
console.info("===============>subscriberCallBack0101========code: " + err.code); console.info("===============>subscriberCallBack0101========code: " + err.code);
console.info("===============>subscriberCallBack0101========event: " + data.event); console.info("===============>subscriberCallBack0101========event: " + data.event);
console.info("===============>subscriberCallBack0101========bundleName: " + data.bundleName); console.info("===============>subscriberCallBack0101========bundleName: " + data.bundleName);
console.info("===============>subscriberCallBack0101=========code: " + data.code); console.info("===============>subscriberCallBack0101=========code: " + data.code);
console.info("===============>subscriberCallBack0101=========data: " + data.data); console.info("===============>subscriberCallBack0101=========data: " + data.data);
expect(data.event).assertEqual("publish_event0100"); expect(data.event).assertEqual("publish_event0100");
console.info("===============>subscriberCallBack0101=========1 code "+ data.code); console.info("===============>subscriberCallBack0101=========1 code "+ data.code);
expect(data.code).assertEqual(2); expect(data.code).assertEqual(2);
commonEventSubscriber0101.getCode().then(function(data) { commonEventSubscriber0101.getCode().then(function(data) {
console.info("===============>subscriberCallBack0101 getCode promise code: "+ data); console.info("===============>subscriberCallBack0101 getCode promise code: "+ data);
}) })
expect(data.data).assertEqual("publish_event1001_change"); expect(data.data).assertEqual("publish_event1001_change");
commonEventSubscriber0100.getData().then(function(data) { commonEventSubscriber0100.getData().then(function(data) {
console.info("===============>subscriberCallBack0101 getData promise data: "+ data); console.info("===============>subscriberCallBack0101 getData promise data: "+ data);
}) })
expect(data.bundleName).assertEqual("publish_event0100_bundleName"); expect(data.bundleName).assertEqual("publish_event0100_bundleName");
commonEventSubscriber0101.finishCommonEvent().then(()=>{ commonEventSubscriber0101.finishCommonEvent().then(()=>{
console.info("===============>subscriberCallBack0101 finishCommonEvent promise"); console.info("===============>subscriberCallBack0101 finishCommonEvent promise");
}) })
done(); done();
} }
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo1 commonEventSubscribeInfo1
).then(function (data) { ).then(function (data) {
console.info("===============ActsSubscriberTestOrder_0100==========createSubscriber promise1"); console.info("===============ActsSubscriberTestOrder_0100==========createSubscriber promise1");
commonEventSubscriber0100 = data; commonEventSubscriber0100 = data;
data.getSubscribeInfo().then(function (data) { data.getSubscribeInfo().then(function (data) {
console.info("===============ActsSubscriberTestOrder_0100=========getSubscribeInfo promise1"); console.info("===============ActsSubscriberTestOrder_0100=========getSubscribeInfo promise1");
Subscriber.subscribe(commonEventSubscriber0100, subscriberCallBack0100); Subscriber.subscribe(commonEventSubscriber0100, subscriberCallBack0100);
}); });
}) })
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo2 commonEventSubscribeInfo2
).then(function (data) { ).then(function (data) {
console.info("===============ActsSubscriberTestOrder_0100==========createSubscriber promise2"); console.info("===============ActsSubscriberTestOrder_0100==========createSubscriber promise2");
commonEventSubscriber0101 = data; commonEventSubscriber0101 = data;
data.getSubscribeInfo().then(function (data) { data.getSubscribeInfo().then(function (data) {
console.info("===============ActsSubscriberTestOrder_0100=========getSubscribeInfo promise2"); console.info("===============ActsSubscriberTestOrder_0100=========getSubscribeInfo promise2");
Subscriber.subscribe(commonEventSubscriber0101, subscriberCallBack0101); Subscriber.subscribe(commonEventSubscriber0101, subscriberCallBack0101);
Subscriber.publish("publish_event0100", commonEventPublishData, publishCallback); 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) * @tc.number : ActsSubscriberTestOrder_0200
*/ * @tc.name : verify subscribe and publish : Check subscribe different event
it ('ActsSubscriberTestOrder_0200', 0, async function (done) { * and twice publish common ordered event and check unsubscribe event
console.info("===============ActsSubscriberTestOrder_0200===============>"); * @tc.desc : Check the subscriber can receive event "publish_event0200" type of the interface (by Promise)
*/
var commonEventSubscribeInfo1 = { it ('ActsSubscriberTestOrder_0200', 0, async function (done) {
events: ["publish_event0200", console.info("===============ActsSubscriberTestOrder_0200===============>");
"publish_event0201"],
priority: 10 var commonEventSubscribeInfo1 = {
}; events: ["publish_event0200",
"publish_event0201"],
var commonEventSubscribeInfo2 = { priority: 10
events: ["publish_event0201"], };
priority: 9
}; var commonEventSubscribeInfo2 = {
events: ["publish_event0201"],
var commonEventPublishData1 = { priority: 9
bundleName: "publish_event0200_bundleName", };
code: 1,
data: "publish_event0200_init", var commonEventPublishData1 = {
isOrdered: false, bundleName: "publish_event0200_bundleName",
} code: 1,
data: "publish_event0200_init",
var commonEventPublishData2 = { isOrdered: false,
bundleName: "publish_event0201_bundleName", }
code: 1,
data: "publish_event0201_init", var commonEventPublishData2 = {
isOrdered: true, bundleName: "publish_event0201_bundleName",
} code: 1,
data: "publish_event0201_init",
async function subscriberCallBack0200(err, data) { isOrdered: true,
console.info("===============>subscriberCallBack0200========event: " + data.event); }
console.info("===============>subscriberCallBack0200========bundleName: " + data.bundleName);
console.info("===============>subscriberCallBack0200=========code: " + data.code); async function subscriberCallBack0200(err, data) {
console.info("===============>subscriberCallBack0200=========data: " + data.data); console.info("===============>subscriberCallBack0200========event: " + data.event);
console.info("===============>subscriberCallBack0200=========num2: " + num2); console.info("===============>subscriberCallBack0200========bundleName: " + data.bundleName);
if (num2 == 0) { console.info("===============>subscriberCallBack0200=========code: " + data.code);
num2++; console.info("===============>subscriberCallBack0200=========data: " + data.data);
expect(data.event).assertEqual("publish_event0200"); console.info("===============>subscriberCallBack0200=========num2: " + num2);
console.info("===============>subscriberCallBack0200=====num2:0====code: " + data.code); if (num2 == 0) {
expect(data.code).assertEqual(1); num2++;
expect(data.data).assertEqual("publish_event0200_init"); expect(data.event).assertEqual("publish_event0200");
expect(data.bundleName).assertEqual("publish_event0200_bundleName"); console.info("===============>subscriberCallBack0200=====num2:0====code: " + data.code);
}else { expect(data.code).assertEqual(1);
num2 = 0; expect(data.data).assertEqual("publish_event0200_init");
expect(data.event).assertEqual("publish_event0201"); expect(data.bundleName).assertEqual("publish_event0200_bundleName");
console.info("===============>subscriberCallBack0200=====num2:1====code: " + data.code); }else {
expect(data.code).assertEqual(1); num2 = 0;
expect(data.data).assertEqual("publish_event0201_init"); expect(data.event).assertEqual("publish_event0201");
expect(data.bundleName).assertEqual("publish_event0201_bundleName"); console.info("===============>subscriberCallBack0200=====num2:1====code: " + data.code);
commonEventSubscriber0200.finishCommonEvent().then(()=>{ expect(data.code).assertEqual(1);
console.info("===============>subscriberCallBack0200:num:1:finishCommonEvent promise"); 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); async function subscriberCallBack0201(err, data) {
console.info("===============>subscriberCallBack0201=========data: " + data.data); console.info("===============>subscriberCallBack0201========event: " + data.event);
console.info("===============>subscriberCallBack0201========bundleName: " + data.bundleName);
expect(data.event).assertEqual("publish_event0201"); console.info("===============>subscriberCallBack0201=========code=: " + data.code);
console.info("===============>subscriberCallBack0201=========code: " + data.code); console.info("===============>subscriberCallBack0201=========data: " + data.data);
expect(data.code).assertEqual(1);
expect(data.data).assertEqual("publish_event0201_init"); expect(data.event).assertEqual("publish_event0201");
expect(data.bundleName).assertEqual("publish_event0201_bundleName"); console.info("===============>subscriberCallBack0201=========code: " + data.code);
commonEventSubscriber0201.finishCommonEvent().then(()=>{ expect(data.code).assertEqual(1);
console.info("===============>subscriberCallBack0201:finishCommonEvent promise"); expect(data.data).assertEqual("publish_event0201_init");
}) expect(data.bundleName).assertEqual("publish_event0201_bundleName");
done(); commonEventSubscriber0201.finishCommonEvent().then(()=>{
} console.info("===============>subscriberCallBack0201:finishCommonEvent promise");
})
Subscriber.createSubscriber( done();
commonEventSubscribeInfo1, }
).then(function (data) {
console.info("===============ActsSubscriberTestOrder_0200==========createSubscriber promise1"); Subscriber.createSubscriber(
commonEventSubscriber0200 = data; commonEventSubscribeInfo1,
data.getSubscribeInfo().then(function (data) { ).then(function (data) {
console.info("===============ActsSubscriberTestOrder_0200=========getSubscribeInfo promise1"); console.info("===============ActsSubscriberTestOrder_0200==========createSubscriber promise1");
Subscriber.subscribe(commonEventSubscriber0200, subscriberCallBack0200); 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"); Subscriber.createSubscriber(
commonEventSubscriber0201 = data; commonEventSubscribeInfo2,
data.getSubscribeInfo().then(function (data) { ).then(function (data) {
console.info("===============ActsSubscriberTestOrder_0200=========getSubscribeInfo promise2"); console.info("===============ActsSubscriberTestOrder_0200==========createSubscriber promise2");
Subscriber.subscribe(commonEventSubscriber0201, subscriberCallBack0201); commonEventSubscriber0201 = data;
Subscriber.unsubscribe(commonEventSubscriber0200, unsubscribeCallback); data.getSubscribeInfo().then(function (data) {
Subscriber.publish("publish_event0200", commonEventPublishData1, publishCallback); console.info("===============ActsSubscriberTestOrder_0200=========getSubscribeInfo promise2");
Subscriber.publish("publish_event0201", commonEventPublishData2, publishCallback); 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==================");
* @tc.number : ActsSubscriberTestOrder_0300 Subscriber.publish("publish_event0200", commonEventPublishData1, publishCallback);
* @tc.name : verify subscribe and publish : Check subscribe different events }, 100);
* and some publish common ordered events setTimeout(function () {
* @tc.desc : Check the subscriber can receive event "publish_event0301" type of the interface (by Promise) console.debug("===================ActsSubscriberTestOrder_0200 delay 100ms==================");
*/ Subscriber.publish("publish_event0201", commonEventPublishData2, publishCallback);
it ('ActsSubscriberTestOrder_0300', 0, async function (done) { }, 100);
console.info("===============ActsSubscriberTestOrder_0300===============>"); });
})
var commonEventSubscribeInfo1 = { })
events: ["publish_event0301"],
priority: 9 /*
}; * @tc.number : ActsSubscriberTestOrder_0300
* @tc.name : verify subscribe and publish : Check subscribe different events
var commonEventSubscribeInfo2 = { * and some publish common ordered events
events: ["publish_event0301"], * @tc.desc : Check the subscriber can receive event "publish_event0301" type of the interface (by Promise)
priority: 10 */
}; it ('ActsSubscriberTestOrder_0300', 0, async function (done) {
console.info("===============ActsSubscriberTestOrder_0300===============>");
var commonEventPublishData2 = {
bundleName: "publish_event0301_bundleName", var commonEventSubscribeInfo1 = {
code: 1, events: ["publish_event0301"],
data: "publish_event0301_init", priority: 9
isOrdered: true, };
}
var commonEventSubscribeInfo2 = {
async function subscriberCallBack0300(err, data) { events: ["publish_event0301"],
console.info("===============>subscriberCallBack0300========event: " + data.event); priority: 10
console.info("===============>subscriberCallBack0300========bundleName: " + data.bundleName); };
console.info("===============>subscriberCallBack0300=========code: " + data.code);
console.info("===============>subscriberCallBack0300=========dat: " + data.data); var commonEventPublishData2 = {
console.info("===============>subscriberCallBack0300=========order: " + order); bundleName: "publish_event0301_bundleName",
code: 1,
expect(data.event).assertEqual("publish_event0301"); data: "publish_event0301_init",
expect(data.code).assertEqual(1); isOrdered: true,
expect(data.data).assertEqual("publish_event0301_init"); }
expect(data.bundleName).assertEqual("publish_event0301_bundleName");
expect(order).assertEqual(true); var callBackNum = 0;
async function subscriberCallBack0300(err, data) {
if (order == true) { console.info("===============>subscriberCallBack0300========event: " + data.event);
order = false; console.info("===============>subscriberCallBack0300========bundleName: " + data.bundleName);
} console.info("===============>subscriberCallBack0300=========code: " + data.code);
console.info("===============>subscriberCallBack0300=========dat: " + data.data);
commonEventSubscriber0300.isOrderedCommonEvent().then(function(data) { console.info("===============>subscriberCallBack0300=========order: " + order);
console.info("========>subscriberCallBack0300 isOrderedCommonEvent promise " + data);
expect(data).assertEqual(true); expect(data.event).assertEqual("publish_event0301");
}) expect(data.code).assertEqual(1);
commonEventSubscriber0300.finishCommonEvent().then(()=>{ expect(data.data).assertEqual("publish_event0301_init");
console.info("===============>subscriberCallBack0300 finishCommonEvent promise"); expect(data.bundleName).assertEqual("publish_event0301_bundleName");
}) expect(order).assertEqual(true);
done();
} if (order == true) {
order = false;
async function subscriberCallBack0301(err, data) { }
console.info("===============>subscriberCallBack0301========event: " + data.event);
console.info("===============>subscriberCallBack0301========bundleName: " + data.bundleName); commonEventSubscriber0300.isOrderedCommonEvent().then(function(data) {
console.info("===============>subscriberCallBack0301=========code: " + data.code); console.info("========>subscriberCallBack0300 isOrderedCommonEvent promise " + data);
console.info("===============>subscriberCallBack0301=========data: " + data.data); expect(data).assertEqual(true);
console.info("===============>subscriberCallBack0301=========order: " + order); })
commonEventSubscriber0300.finishCommonEvent().then(()=>{
expect(data.event).assertEqual("publish_event0301"); console.info("===============>subscriberCallBack0300 finishCommonEvent promise");
expect(data.code).assertEqual(1); })
expect(data.data).assertEqual("publish_event0301_init");
expect(data.bundleName).assertEqual("publish_event0301_bundleName"); callBackNum++;
if (callBackNum == 3) {
if (order == false) { done();
order = true; }
} }
commonEventSubscriber0301.isOrderedCommonEvent().then(function(data) { async function subscriberCallBack0301(err, data) {
console.info("===============>subscriberCallBack0301 isOrderedCommonEvent promise" + data); console.info("===============>subscriberCallBack0301========event: " + data.event);
expect(data).assertEqual(true); console.info("===============>subscriberCallBack0301========bundleName: " + data.bundleName);
}) console.info("===============>subscriberCallBack0301=========code: " + data.code);
commonEventSubscriber0301.finishCommonEvent().then(()=>{ console.info("===============>subscriberCallBack0301=========data: " + data.data);
console.info("===============>subscriberCallBack0301 finishCommonEvent promise"); console.info("===============>subscriberCallBack0301=========order: " + order);
})
} expect(data.event).assertEqual("publish_event0301");
expect(data.code).assertEqual(1);
Subscriber.createSubscriber( expect(data.data).assertEqual("publish_event0301_init");
commonEventSubscribeInfo1, expect(data.bundleName).assertEqual("publish_event0301_bundleName");
).then(function (data) {
console.info("===============ActsSubscriberTestOrder_0300==========createSubscriber promise1"); if (order == false) {
commonEventSubscriber0300 = data; order = true;
data.getSubscribeInfo().then(function (data) { }
console.info("===============ActsSubscriberTestOrder_0300=========getSubscribeInfo promise1");
Subscriber.subscribe(commonEventSubscriber0300, subscriberCallBack0300); commonEventSubscriber0301.isOrderedCommonEvent().then(function(data) {
}); console.info("===============>subscriberCallBack0301 isOrderedCommonEvent promise" + data);
}) expect(data).assertEqual(true);
})
Subscriber.createSubscriber( commonEventSubscriber0301.finishCommonEvent().then(()=>{
commonEventSubscribeInfo2, console.info("===============>subscriberCallBack0301 finishCommonEvent promise");
).then(function (data) { })
console.info("===============ActsSubscriberTestOrder_0300==========createSubscriber promise2"); }
commonEventSubscriber0301 = data;
data.getSubscribeInfo().then(function (data) { Subscriber.createSubscriber(
console.info("===============ActsSubscriberTestOrder_0300=========getSubscribeInfo promise2"); commonEventSubscribeInfo1,
Subscriber.subscribe(commonEventSubscriber0301, subscriberCallBack0301); ).then(function (data) {
var numindex = 0; console.info("===============ActsSubscriberTestOrder_0300==========createSubscriber promise1");
for (; numindex < 3; ++numindex) { commonEventSubscriber0300 = data;
Subscriber.publish("publish_event0301", commonEventPublishData2, publishCallback); data.getSubscribeInfo().then(function (data) {
} console.info("===============ActsSubscriberTestOrder_0300=========getSubscribeInfo promise1");
}); Subscriber.subscribe(commonEventSubscriber0300, subscriberCallBack0300);
}) });
}) })
/* Subscriber.createSubscriber(
* @tc.number : ActsSubscriberTestOrder_0400 commonEventSubscribeInfo2,
* @tc.name : verify subscribe and publish : Check subscribe same events ).then(function (data) {
* and publish common ordered events and check abort event console.info("===============ActsSubscriberTestOrder_0300==========createSubscriber promise2");
* @tc.desc : Check the subscriber can receive event "publish_event0400" type of the interface (by promise) commonEventSubscriber0301 = data;
*/ data.getSubscribeInfo().then(function (data) {
it ('ActsSubscriberTestOrder_0400', 0, async function (done) { console.info("===============ActsSubscriberTestOrder_0300=========getSubscribeInfo promise2");
console.info("===============ActsSubscriberTestOrder_0400===============>"); Subscriber.subscribe(commonEventSubscriber0301, subscriberCallBack0301);
var numindex = 0;
var commonEventSubscribeInfo1 = { for (; numindex < 3; ++numindex) {
events: ["publish_event0400"], setTimeout(function () {
priority: 10 console.debug("===================ActsSubscriberTestOrder_0300 delay 100ms==================");
}; Subscriber.publish("publish_event0301", commonEventPublishData2, publishCallback);
}, 100);
var commonEventSubscribeInfo2 = { }
events: ["publish_event0400"], });
priority: 9 })
}; })
var commonEventPublishData = { /*
bundleName: "publish_event0400_bundleName", * @tc.number : ActsSubscriberTestOrder_0400
code: 1, * @tc.name : verify subscribe and publish : Check subscribe same events
data: "publish_event0400_init", * and publish common ordered events and check abort event
isOrdered: true, * @tc.desc : Check the subscriber can receive event "publish_event0400" type of the interface (by promise)
} */
it ('ActsSubscriberTestOrder_0400', 0, async function (done) {
async function subscriberCallBack0400(err, data) { console.info("===============ActsSubscriberTestOrder_0400===============>");
console.info("===============>subscriberCallBack0400========event: " + data.event);
console.info("===============>subscriberCallBack0400========bundleName: " + data.bundleName); var commonEventSubscribeInfo1 = {
console.info("===============>subscriberCallBack0400=========code: " + data.code); events: ["publish_event0400"],
console.info("===============>subscriberCallBack0400=========data: " + data.data); priority: 10
expect(data.event).assertEqual("publish_event0400"); };
expect(data.code).assertEqual(1);
expect(data.data).assertEqual("publish_event0400_init"); var commonEventSubscribeInfo2 = {
expect(data.bundleName).assertEqual("publish_event0400_bundleName"); events: ["publish_event0400"],
commonEventSubscriber0400.getAbortCommonEvent().then(function(data) { priority: 9
console.info("===============>subscriberCallBack0400 getAbortCommonEvent promise abort2: " + data); };
});
commonEventSubscriber0400.abortCommonEvent().then(() => { var commonEventPublishData = {
console.info("===============>subscriberCallBack0400 abortCommonEvent promise"); bundleName: "publish_event0400_bundleName",
}); code: 1,
commonEventSubscriber0400.getAbortCommonEvent().then(function(data) { data: "publish_event0400_init",
console.info( isOrdered: true,
"===============>subscriberCallBack0400 getAbortCommonEvent promise abort2: " + data); }
});
commonEventSubscriber0400.finishCommonEvent().then(()=> { async function subscriberCallBack0400(err, data) {
console.info("===============>subscriberCallBack0400 finishCommonEvent promise"); console.info("===============>subscriberCallBack0400========event: " + data.event);
}); console.info("===============>subscriberCallBack0400========bundleName: " + data.bundleName);
done(); console.info("===============>subscriberCallBack0400=========code: " + data.code);
} console.info("===============>subscriberCallBack0400=========data: " + data.data);
expect(data.event).assertEqual("publish_event0400");
async function subscriberCallBack0401(err, data) { expect(data.code).assertEqual(1);
console.info("===============>subscriberCallBack0401========event: " + data.event); expect(data.data).assertEqual("publish_event0400_init");
expect().assertFail(); expect(data.bundleName).assertEqual("publish_event0400_bundleName");
} commonEventSubscriber0400.getAbortCommonEvent().then(function(data) {
console.info("===============>subscriberCallBack0400 getAbortCommonEvent promise abort2: " + data);
Subscriber.createSubscriber( });
commonEventSubscribeInfo1 commonEventSubscriber0400.abortCommonEvent().then(() => {
).then(function (data) { console.info("===============>subscriberCallBack0400 abortCommonEvent promise");
console.info("===============ActsSubscriberTestOrder_0400==========createSubscriber promise1"); });
commonEventSubscriber0400 = data; commonEventSubscriber0400.getAbortCommonEvent().then(function(data) {
data.getSubscribeInfo().then(function (data) { console.info(
console.info("===============ActsSubscriberTestOrder_0400=========getSubscribeInfo promise1"); "===============>subscriberCallBack0400 getAbortCommonEvent promise abort2: " + data);
expect(data.events[0]).assertEqual("publish_event0400"); });
Subscriber.subscribe(commonEventSubscriber0400, subscriberCallBack0400); commonEventSubscriber0400.finishCommonEvent().then(()=> {
}) console.info("===============>subscriberCallBack0400 finishCommonEvent promise");
}) });
done();
Subscriber.createSubscriber( }
commonEventSubscribeInfo2
).then(function (data) { async function subscriberCallBack0401(err, data) {
console.info("===============ActsSubscriberTestOrder_0400==========createSubscriber promise2"); console.info("===============>subscriberCallBack0401========event: " + data.event);
commonEventSubscriber0401 = data; expect().assertFail();
data.getSubscribeInfo().then(function (data) { }
console.info("===============ActsSubscriberTestOrder_0400=========getSubscribeInfo promise2");
expect(data.events[0]).assertEqual("publish_event0400"); Subscriber.createSubscriber(
Subscriber.subscribe(commonEventSubscriber0401, subscriberCallBack0401); commonEventSubscribeInfo1
Subscriber.publish("publish_event0400", commonEventPublishData, publishCallback); ).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");
* @tc.number : ActsSubscriberTestOrder_0500 Subscriber.subscribe(commonEventSubscriber0400, subscriberCallBack0400);
* @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)
*/ Subscriber.createSubscriber(
it ('ActsSubscriberTestOrder_0500', 0, async function (done) { commonEventSubscribeInfo2
console.info("===============ActsSubscriberTestOrder_0500===============>"); ).then(function (data) {
console.info("===============ActsSubscriberTestOrder_0400==========createSubscriber promise2");
var commonEventSubscribeInfo1 = { commonEventSubscriber0401 = data;
events: ["publish_event0500"], data.getSubscribeInfo().then(function (data) {
priority: 1001 console.info("===============ActsSubscriberTestOrder_0400=========getSubscribeInfo promise2");
}; expect(data.events[0]).assertEqual("publish_event0400");
Subscriber.subscribe(commonEventSubscriber0401, subscriberCallBack0401);
var commonEventSubscribeInfo2 = { setTimeout(function () {
events: ["publish_event0500"], console.debug("===================ActsSubscriberTestOrder_0400 delay 100mss==================");
priority: -101 Subscriber.publish("publish_event0400", commonEventPublishData, publishCallback);
}; }, 100);
})
var commonEventPublishData = { })
bundleName: "publish_event0500_bundleName", })
code: 10,
data: "publish_event0500_init", /*
isOrdered: true, * @tc.number : ActsSubscriberTestOrder_0500
} * @tc.name : verify subscribe and publish : Check subscriber same events
* and publish common ordered events and check subscriberInfo priority
async function subscriberCallBack0500(err, data) { * @tc.desc : Check the subscriber can receive event "publish_event0500" type of the interface (by promise)
console.info("===============>subscriberCallBack0500========event: " + data.event); */
console.info("===============>subscriberCallBack0500========bundleName: " + data.bundleName); it ('ActsSubscriberTestOrder_0500', 0, async function (done) {
console.info("===============>subscriberCallBack0500=========code: " + data.code); console.info("===============ActsSubscriberTestOrder_0500===============>");
console.info("===============>subscriberCallBack0500=========data: " + data.data);
expect(data.event).assertEqual("publish_event0500"); var commonEventSubscribeInfo1 = {
expect(data.code).assertEqual(10); events: ["publish_event0500"],
expect(data.data).assertEqual("publish_event0500_init"); priority: 1001
expect(data.bundleName).assertEqual("publish_event0500_bundleName"); };
commonEventSubscriber0500.finishCommonEvent().then(() => {
console.info("===============>subscriberCallBack0500 finishCommonEvent promise"); var commonEventSubscribeInfo2 = {
}); events: ["publish_event0500"],
} priority: -101
};
async function subscriberCallBack0501(err, data) {
console.info("===============>subscriberCallBack0501========event: " + data.event); var commonEventPublishData = {
console.info("===============>subscriberCallBack0501========bundleName: " + data.bundleName); bundleName: "publish_event0500_bundleName",
console.info("===============>subscriberCallBack0501=========code: " + data.code); code: 10,
console.info("===============>subscriberCallBack0501========data: " + data.data); data: "publish_event0500_init",
expect(data.event).assertEqual("publish_event0500"); isOrdered: true,
expect(data.code).assertEqual(10); }
expect(data.data).assertEqual("publish_event0500_init");
expect(data.bundleName).assertEqual("publish_event0500_bundleName"); async function subscriberCallBack0500(err, data) {
commonEventSubscriber0501.finishCommonEvent().then(() => { console.info("===============>subscriberCallBack0500========event: " + data.event);
console.info("===============>subscriberCallBack0501 finishCommonEvent promise"); console.info("===============>subscriberCallBack0500========bundleName: " + data.bundleName);
}); console.info("===============>subscriberCallBack0500=========code: " + data.code);
done(); console.info("===============>subscriberCallBack0500=========data: " + data.data);
} expect(data.event).assertEqual("publish_event0500");
expect(data.code).assertEqual(10);
Subscriber.createSubscriber( expect(data.data).assertEqual("publish_event0500_init");
commonEventSubscribeInfo1 expect(data.bundleName).assertEqual("publish_event0500_bundleName");
).then(function (data) { commonEventSubscriber0500.finishCommonEvent().then(() => {
console.info("===============ActsSubscriberTestOrder_0500==========createSubscriber promise1"); console.info("===============>subscriberCallBack0500 finishCommonEvent promise");
commonEventSubscriber0500 = data; });
data.getSubscribeInfo().then(function (data) { }
console.info("===============ActsSubscriberTestOrder_0500==========getSubscribeInfo promise1");
expect(data.events[0]).assertEqual("publish_event0500"); async function subscriberCallBack0501(err, data) {
Subscriber.subscribe(commonEventSubscriber0500, subscriberCallBack0500); console.info("===============>subscriberCallBack0501========event: " + data.event);
}) console.info("===============>subscriberCallBack0501========bundleName: " + data.bundleName);
}) console.info("===============>subscriberCallBack0501=========code: " + data.code);
console.info("===============>subscriberCallBack0501========data: " + data.data);
Subscriber.createSubscriber( expect(data.event).assertEqual("publish_event0500");
commonEventSubscribeInfo2 expect(data.code).assertEqual(10);
).then(function (data) { expect(data.data).assertEqual("publish_event0500_init");
console.info("===============ActsSubscriberTestOrder_0500==========createSubscriber promise2"); expect(data.bundleName).assertEqual("publish_event0500_bundleName");
commonEventSubscriber0501 = data; commonEventSubscriber0501.finishCommonEvent().then(() => {
data.getSubscribeInfo().then(function (data) { console.info("===============>subscriberCallBack0501 finishCommonEvent promise");
console.info("===============ActsSubscriberTestOrder_0500==========getSubscribeInfo promise2"); });
expect(data.events[0]).assertEqual("publish_event0500"); done();
Subscriber.subscribe(commonEventSubscriber0501, subscriberCallBack0501); }
Subscriber.publish("publish_event0500", commonEventPublishData, publishCallback);
}) 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);
})
})
})
})
notification/ces_standard/subscribeandpublish/actssubscriberunordersystemtest/entry/src/main/js/default/pages/index/index.js
浏览文件 @ d4ba8ea5
...@@ -34,6 +34,7 @@ export default { ...@@ -34,6 +34,7 @@ export default {
core.addService('expect', expectExtend) core.addService('expect', expectExtend)
core.init() core.init()
const configService = core.getDefaultService('config') const configService = core.getDefaultService('config')
this.timeout = 100000;
configService.setConfig(this) configService.setConfig(this)
require('../../../test/List.test') require('../../../test/List.test')
......
notification/ces_standard/subscribeandpublish/actssubscriberunordersystemtest/entry/src/main/js/test/ActsSubscriber_test_unorder.js
浏览文件 @ d4ba8ea5
/* /*
* Copyright (c) 2021 Huawei Device Co., Ltd. * Copyright (c) 2021 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
* You may obtain a copy of the License at * You may obtain a copy of the License at
* *
* http://www.apache.org/licenses/LICENSE-2.0 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
import Subscriber from '@ohos.commonevent' import Subscriber from '@ohos.commonevent'
import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index' import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index'
describe('ActsSubscriberTestUnorderSystem', async function (done) { describe('ActsSubscriberTestUnorderSystem', async function (done) {
console.info("===========ActsSubscriberTestUnorderSystem start====================>"); console.info("===========ActsSubscriberTestUnorderSystem start====================>");
var commonEventSubscriber1; var commonEventSubscriber1;
var commonEventSubscriber2; var commonEventSubscriber2;
var array = [ var array = [
Subscriber.Support.COMMON_EVENT_SHUTDOWN, Subscriber.Support.COMMON_EVENT_SHUTDOWN,
Subscriber.Support.COMMON_EVENT_BATTERY_CHANGED, Subscriber.Support.COMMON_EVENT_BATTERY_CHANGED,
Subscriber.Support.COMMON_EVENT_BATTERY_LOW, Subscriber.Support.COMMON_EVENT_BATTERY_LOW,
Subscriber.Support.COMMON_EVENT_BATTERY_OKAY, Subscriber.Support.COMMON_EVENT_BATTERY_OKAY,
Subscriber.Support.COMMON_EVENT_POWER_CONNECTED, Subscriber.Support.COMMON_EVENT_POWER_CONNECTED,
Subscriber.Support.COMMON_EVENT_POWER_DISCONNECTED, Subscriber.Support.COMMON_EVENT_POWER_DISCONNECTED,
Subscriber.Support.COMMON_EVENT_SCREEN_OFF, Subscriber.Support.COMMON_EVENT_SCREEN_OFF,
Subscriber.Support.COMMON_EVENT_SCREEN_ON, Subscriber.Support.COMMON_EVENT_SCREEN_ON,
Subscriber.Support.COMMON_EVENT_USER_PRESENT, Subscriber.Support.COMMON_EVENT_USER_PRESENT,
Subscriber.Support.COMMON_EVENT_TIME_TICK, Subscriber.Support.COMMON_EVENT_TIME_TICK,
Subscriber.Support.COMMON_EVENT_TIME_CHANGED, Subscriber.Support.COMMON_EVENT_TIME_CHANGED,
Subscriber.Support.COMMON_EVENT_DATE_CHANGED, Subscriber.Support.COMMON_EVENT_DATE_CHANGED,
Subscriber.Support.COMMON_EVENT_TIMEZONE_CHANGED, Subscriber.Support.COMMON_EVENT_TIMEZONE_CHANGED,
Subscriber.Support.COMMON_EVENT_CLOSE_SYSTEM_DIALOGS, Subscriber.Support.COMMON_EVENT_CLOSE_SYSTEM_DIALOGS,
Subscriber.Support.COMMON_EVENT_PACKAGE_ADDED, Subscriber.Support.COMMON_EVENT_PACKAGE_ADDED,
Subscriber.Support.COMMON_EVENT_PACKAGE_REPLACED, Subscriber.Support.COMMON_EVENT_PACKAGE_REPLACED,
Subscriber.Support.COMMON_EVENT_MY_PACKAGE_REPLACED, Subscriber.Support.COMMON_EVENT_MY_PACKAGE_REPLACED,
Subscriber.Support.COMMON_EVENT_PACKAGE_REMOVED, Subscriber.Support.COMMON_EVENT_PACKAGE_REMOVED,
Subscriber.Support.COMMON_EVENT_BUNDLE_REMOVED, Subscriber.Support.COMMON_EVENT_BUNDLE_REMOVED,
Subscriber.Support.COMMON_EVENT_PACKAGE_FULLY_REMOVED, Subscriber.Support.COMMON_EVENT_PACKAGE_FULLY_REMOVED,
Subscriber.Support.COMMON_EVENT_PACKAGE_CHANGED, Subscriber.Support.COMMON_EVENT_PACKAGE_CHANGED,
Subscriber.Support.COMMON_EVENT_PACKAGE_RESTARTED, Subscriber.Support.COMMON_EVENT_PACKAGE_RESTARTED,
Subscriber.Support.COMMON_EVENT_PACKAGE_DATA_CLEARED, Subscriber.Support.COMMON_EVENT_PACKAGE_DATA_CLEARED,
Subscriber.Support.COMMON_EVENT_PACKAGES_SUSPENDED, Subscriber.Support.COMMON_EVENT_PACKAGES_SUSPENDED,
Subscriber.Support.COMMON_EVENT_PACKAGES_UNSUSPENDED, Subscriber.Support.COMMON_EVENT_PACKAGES_UNSUSPENDED,
Subscriber.Support.COMMON_EVENT_MY_PACKAGE_SUSPENDED, Subscriber.Support.COMMON_EVENT_MY_PACKAGE_SUSPENDED,
Subscriber.Support.COMMON_EVENT_MY_PACKAGE_UNSUSPENDED, Subscriber.Support.COMMON_EVENT_MY_PACKAGE_UNSUSPENDED,
Subscriber.Support.COMMON_EVENT_UID_REMOVED, Subscriber.Support.COMMON_EVENT_UID_REMOVED,
Subscriber.Support.COMMON_EVENT_PACKAGE_FIRST_LAUNCH, Subscriber.Support.COMMON_EVENT_PACKAGE_FIRST_LAUNCH,
Subscriber.Support.COMMON_EVENT_PACKAGE_NEEDS_VERIFICATION, Subscriber.Support.COMMON_EVENT_PACKAGE_NEEDS_VERIFICATION,
Subscriber.Support.COMMON_EVENT_PACKAGE_VERIFIED, Subscriber.Support.COMMON_EVENT_PACKAGE_VERIFIED,
Subscriber.Support.COMMON_EVENT_EXTERNAL_APPLICATIONS_AVAILABLE, Subscriber.Support.COMMON_EVENT_EXTERNAL_APPLICATIONS_AVAILABLE,
Subscriber.Support.COMMON_EVENT_EXTERNAL_APPLICATIONS_UNAVAILABLE, Subscriber.Support.COMMON_EVENT_EXTERNAL_APPLICATIONS_UNAVAILABLE,
Subscriber.Support.COMMON_EVENT_CONFIGURATION_CHANGED, Subscriber.Support.COMMON_EVENT_CONFIGURATION_CHANGED,
Subscriber.Support.COMMON_EVENT_LOCALE_CHANGED, Subscriber.Support.COMMON_EVENT_LOCALE_CHANGED,
Subscriber.Support.COMMON_EVENT_MANAGE_PACKAGE_STORAGE, Subscriber.Support.COMMON_EVENT_MANAGE_PACKAGE_STORAGE,
Subscriber.Support.COMMON_EVENT_DRIVE_MODE, Subscriber.Support.COMMON_EVENT_DRIVE_MODE,
Subscriber.Support.COMMON_EVENT_HOME_MODE, Subscriber.Support.COMMON_EVENT_HOME_MODE,
Subscriber.Support.COMMON_EVENT_OFFICE_MODE, Subscriber.Support.COMMON_EVENT_OFFICE_MODE,
Subscriber.Support.COMMON_EVENT_USER_STARTED, Subscriber.Support.COMMON_EVENT_USER_STARTED,
Subscriber.Support.COMMON_EVENT_USER_BACKGROUND, Subscriber.Support.COMMON_EVENT_USER_BACKGROUND,
Subscriber.Support.COMMON_EVENT_USER_FOREGROUND, Subscriber.Support.COMMON_EVENT_USER_FOREGROUND,
Subscriber.Support.COMMON_EVENT_USER_UNLOCKED, Subscriber.Support.COMMON_EVENT_USER_UNLOCKED,
Subscriber.Support.COMMON_EVENT_USER_STOPPED, Subscriber.Support.COMMON_EVENT_USER_STOPPED,
Subscriber.Support.COMMON_EVENT_HWID_LOGIN, Subscriber.Support.COMMON_EVENT_HWID_LOGIN,
Subscriber.Support.COMMON_EVENT_HWID_LOGOUT, Subscriber.Support.COMMON_EVENT_HWID_LOGOUT,
Subscriber.Support.COMMON_EVENT_HWID_TOKEN_INVALID, Subscriber.Support.COMMON_EVENT_HWID_TOKEN_INVALID,
Subscriber.Support.COMMON_EVENT_HWID_LOGOFF, Subscriber.Support.COMMON_EVENT_HWID_LOGOFF,
Subscriber.Support.COMMON_EVENT_WIFI_POWER_STATE, Subscriber.Support.COMMON_EVENT_WIFI_POWER_STATE,
Subscriber.Support.COMMON_EVENT_WIFI_CONN_STATE, Subscriber.Support.COMMON_EVENT_WIFI_CONN_STATE,
Subscriber.Support.COMMON_EVENT_WIFI_HOTSPOT_STATE, Subscriber.Support.COMMON_EVENT_WIFI_HOTSPOT_STATE,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_A2DPSOURCE_AVRCP_CONNECT_STATE_UPDATE, Subscriber.Support.COMMON_EVENT_BLUETOOTH_A2DPSOURCE_AVRCP_CONNECT_STATE_UPDATE,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_SDP_RESULT, Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_SDP_RESULT,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_PAIRING_CANCEL, Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_PAIRING_CANCEL,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_REQ, Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_REQ,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_REPLY, Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_REPLY,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_CANCEL, Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_CANCEL,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_CONNECT_STATE_UPDATE, Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_CONNECT_STATE_UPDATE,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AUDIO_STATE_UPDATE, Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AUDIO_STATE_UPDATE,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AG_COMMON_EVENT, Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AG_COMMON_EVENT,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AG_CALL_STATE_UPDATE, Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AG_CALL_STATE_UPDATE,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_HOST_REQ_DISCOVERABLE, Subscriber.Support.COMMON_EVENT_BLUETOOTH_HOST_REQ_DISCOVERABLE,
Subscriber.Support.COMMON_EVENT_NFC_ACTION_ADAPTER_STATE_CHANGED, Subscriber.Support.COMMON_EVENT_NFC_ACTION_ADAPTER_STATE_CHANGED,
Subscriber.Support.COMMON_EVENT_DISCHARGING, Subscriber.Support.COMMON_EVENT_DISCHARGING,
Subscriber.Support.COMMON_EVENT_CHARGING, Subscriber.Support.COMMON_EVENT_CHARGING,
Subscriber.Support.COMMON_EVENT_DEVICE_IDLE_MODE_CHANGED, Subscriber.Support.COMMON_EVENT_DEVICE_IDLE_MODE_CHANGED,
Subscriber.Support.COMMON_EVENT_POWER_SAVE_MODE_CHANGED, Subscriber.Support.COMMON_EVENT_POWER_SAVE_MODE_CHANGED,
Subscriber.Support.COMMON_EVENT_LOCATION_MODE_STATE_CHANGED, Subscriber.Support.COMMON_EVENT_LOCATION_MODE_STATE_CHANGED,
Subscriber.Support.COMMON_EVENT_IVI_SLEEP, Subscriber.Support.COMMON_EVENT_IVI_SLEEP,
Subscriber.Support.COMMON_EVENT_IVI_PAUSE, Subscriber.Support.COMMON_EVENT_IVI_PAUSE,
Subscriber.Support.COMMON_EVENT_IVI_STANDBY, Subscriber.Support.COMMON_EVENT_IVI_STANDBY,
Subscriber.Support.COMMON_EVENT_IVI_LASTMODE_SAVE, Subscriber.Support.COMMON_EVENT_IVI_LASTMODE_SAVE,
Subscriber.Support.COMMON_EVENT_IVI_VOLTAGE_ABNORMAL, Subscriber.Support.COMMON_EVENT_IVI_VOLTAGE_ABNORMAL,
Subscriber.Support.COMMON_EVENT_IVI_HIGH_TEMPERATURE, Subscriber.Support.COMMON_EVENT_IVI_HIGH_TEMPERATURE,
Subscriber.Support.COMMON_EVENT_IVI_EXTREME_TEMPERATURE, Subscriber.Support.COMMON_EVENT_IVI_EXTREME_TEMPERATURE,
Subscriber.Support.COMMON_EVENT_IVI_TEMPERATURE_ABNORMAL, Subscriber.Support.COMMON_EVENT_IVI_TEMPERATURE_ABNORMAL,
Subscriber.Support.COMMON_EVENT_IVI_VOLTAGE_RECOVERY, Subscriber.Support.COMMON_EVENT_IVI_VOLTAGE_RECOVERY,
Subscriber.Support.COMMON_EVENT_IVI_TEMPERATURE_RECOVERY, Subscriber.Support.COMMON_EVENT_IVI_TEMPERATURE_RECOVERY,
Subscriber.Support.COMMON_EVENT_IVI_ACTIVE, Subscriber.Support.COMMON_EVENT_IVI_ACTIVE,
Subscriber.Support.COMMON_EVENT_USB_DEVICE_ATTACHED, Subscriber.Support.COMMON_EVENT_USB_DEVICE_ATTACHED,
Subscriber.Support.COMMON_EVENT_USB_DEVICE_DETACHED, Subscriber.Support.COMMON_EVENT_USB_DEVICE_DETACHED,
Subscriber.Support.COMMON_EVENT_USB_ACCESSORY_ATTACHED, Subscriber.Support.COMMON_EVENT_USB_ACCESSORY_ATTACHED,
Subscriber.Support.COMMON_EVENT_USB_ACCESSORY_DETACHED, Subscriber.Support.COMMON_EVENT_USB_ACCESSORY_DETACHED,
Subscriber.Support.COMMON_EVENT_AIRPLANE_MODE_CHANGED, Subscriber.Support.COMMON_EVENT_AIRPLANE_MODE_CHANGED,
Subscriber.Support.COMMON_EVENT_SMS_RECEIVE_COMPLETED, Subscriber.Support.COMMON_EVENT_SMS_RECEIVE_COMPLETED,
Subscriber.Support.COMMON_EVENT_SPN_INFO_UPDATED, Subscriber.Support.COMMON_EVENT_SPN_INFO_UPDATED,
]; ];
function publishCallback(err) { function publishCallback(err) {
console.info("==========================>publishCallback"); console.info("==========================>publishCallback");
} }
function sleep(delay) { function sleep(delay) {
var start = (new Date()).getTime(); var start = (new Date()).getTime();
while((new Date()).getTime() - start < delay) {} while((new Date()).getTime() - start < delay) {}
} }
function findArray(str) { function findArray(str) {
var value = false; var value = false;
var index1 = 0; var index1 = 0;
var length = array.length; var length = array.length;
for(; index1 < length; ++index1) { for(; index1 < length; ++index1) {
if (array[index1] == str) { if (array[index1] == str) {
value = true; value = true;
break; break;
} }
} }
return value; return value;
} }
/* /*
* @tc.number : ActsSubscriberTestUnorderSystem_0100 * @tc.number : ActsSubscriberTestUnorderSystem_0100
* @tc.name : verify subscribe and publish : Check subscribe and publish system event data without permission * @tc.name : verify subscribe and publish : Check subscribe and publish system event data without permission
* @tc.desc : Check the subscriber can receive event "publish_event0100" type of the interface (by Promise) * @tc.desc : Check the subscriber can receive event "publish_event0100" type of the interface (by Promise)
*/ */
it('ActsSubscriberTestUnorderSystem_0100', 0, async function (done) { it('ActsSubscriberTestUnorderSystem_0100', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorderSystem_0100 start==========================>"); console.info("===============ActsSubscriberTestUnorderSystem_0100 start==========================>");
var commonEventSubscribeInfo = { var commonEventSubscribeInfo = {
events: [ events: [
Subscriber.Support.COMMON_EVENT_SHUTDOWN, Subscriber.Support.COMMON_EVENT_SHUTDOWN,
Subscriber.Support.COMMON_EVENT_BATTERY_CHANGED, Subscriber.Support.COMMON_EVENT_BATTERY_CHANGED,
Subscriber.Support.COMMON_EVENT_BATTERY_LOW, Subscriber.Support.COMMON_EVENT_BATTERY_LOW,
Subscriber.Support.COMMON_EVENT_BATTERY_OKAY, Subscriber.Support.COMMON_EVENT_BATTERY_OKAY,
Subscriber.Support.COMMON_EVENT_POWER_CONNECTED, Subscriber.Support.COMMON_EVENT_POWER_CONNECTED,
Subscriber.Support.COMMON_EVENT_POWER_DISCONNECTED, Subscriber.Support.COMMON_EVENT_POWER_DISCONNECTED,
Subscriber.Support.COMMON_EVENT_SCREEN_OFF, Subscriber.Support.COMMON_EVENT_SCREEN_OFF,
Subscriber.Support.COMMON_EVENT_SCREEN_ON, Subscriber.Support.COMMON_EVENT_SCREEN_ON,
Subscriber.Support.COMMON_EVENT_USER_PRESENT, Subscriber.Support.COMMON_EVENT_USER_PRESENT,
Subscriber.Support.COMMON_EVENT_TIME_TICK, Subscriber.Support.COMMON_EVENT_TIME_TICK,
Subscriber.Support.COMMON_EVENT_TIME_CHANGED, Subscriber.Support.COMMON_EVENT_TIME_CHANGED,
Subscriber.Support.COMMON_EVENT_DATE_CHANGED, Subscriber.Support.COMMON_EVENT_DATE_CHANGED,
Subscriber.Support.COMMON_EVENT_TIMEZONE_CHANGED, Subscriber.Support.COMMON_EVENT_TIMEZONE_CHANGED,
Subscriber.Support.COMMON_EVENT_CLOSE_SYSTEM_DIALOGS, Subscriber.Support.COMMON_EVENT_CLOSE_SYSTEM_DIALOGS,
Subscriber.Support.COMMON_EVENT_PACKAGE_ADDED, Subscriber.Support.COMMON_EVENT_PACKAGE_ADDED,
Subscriber.Support.COMMON_EVENT_PACKAGE_REPLACED, Subscriber.Support.COMMON_EVENT_PACKAGE_REPLACED,
Subscriber.Support.COMMON_EVENT_MY_PACKAGE_REPLACED, Subscriber.Support.COMMON_EVENT_MY_PACKAGE_REPLACED,
Subscriber.Support.COMMON_EVENT_PACKAGE_REMOVED, Subscriber.Support.COMMON_EVENT_PACKAGE_REMOVED,
Subscriber.Support.COMMON_EVENT_BUNDLE_REMOVED, Subscriber.Support.COMMON_EVENT_BUNDLE_REMOVED,
Subscriber.Support.COMMON_EVENT_PACKAGE_FULLY_REMOVED, Subscriber.Support.COMMON_EVENT_PACKAGE_FULLY_REMOVED,
Subscriber.Support.COMMON_EVENT_PACKAGE_CHANGED, Subscriber.Support.COMMON_EVENT_PACKAGE_CHANGED,
Subscriber.Support.COMMON_EVENT_PACKAGE_RESTARTED, Subscriber.Support.COMMON_EVENT_PACKAGE_RESTARTED,
Subscriber.Support.COMMON_EVENT_PACKAGE_DATA_CLEARED, Subscriber.Support.COMMON_EVENT_PACKAGE_DATA_CLEARED,
Subscriber.Support.COMMON_EVENT_PACKAGES_SUSPENDED, Subscriber.Support.COMMON_EVENT_PACKAGES_SUSPENDED,
Subscriber.Support.COMMON_EVENT_PACKAGES_UNSUSPENDED, Subscriber.Support.COMMON_EVENT_PACKAGES_UNSUSPENDED,
Subscriber.Support.COMMON_EVENT_MY_PACKAGE_SUSPENDED, Subscriber.Support.COMMON_EVENT_MY_PACKAGE_SUSPENDED,
Subscriber.Support.COMMON_EVENT_MY_PACKAGE_UNSUSPENDED, Subscriber.Support.COMMON_EVENT_MY_PACKAGE_UNSUSPENDED,
Subscriber.Support.COMMON_EVENT_UID_REMOVED, Subscriber.Support.COMMON_EVENT_UID_REMOVED,
Subscriber.Support.COMMON_EVENT_PACKAGE_FIRST_LAUNCH, Subscriber.Support.COMMON_EVENT_PACKAGE_FIRST_LAUNCH,
Subscriber.Support.COMMON_EVENT_PACKAGE_NEEDS_VERIFICATION, Subscriber.Support.COMMON_EVENT_PACKAGE_NEEDS_VERIFICATION,
Subscriber.Support.COMMON_EVENT_PACKAGE_VERIFIED, Subscriber.Support.COMMON_EVENT_PACKAGE_VERIFIED,
Subscriber.Support.COMMON_EVENT_EXTERNAL_APPLICATIONS_AVAILABLE, Subscriber.Support.COMMON_EVENT_EXTERNAL_APPLICATIONS_AVAILABLE,
Subscriber.Support.COMMON_EVENT_EXTERNAL_APPLICATIONS_UNAVAILABLE, Subscriber.Support.COMMON_EVENT_EXTERNAL_APPLICATIONS_UNAVAILABLE,
Subscriber.Support.COMMON_EVENT_CONFIGURATION_CHANGED, Subscriber.Support.COMMON_EVENT_CONFIGURATION_CHANGED,
Subscriber.Support.COMMON_EVENT_LOCALE_CHANGED, Subscriber.Support.COMMON_EVENT_LOCALE_CHANGED,
Subscriber.Support.COMMON_EVENT_MANAGE_PACKAGE_STORAGE, Subscriber.Support.COMMON_EVENT_MANAGE_PACKAGE_STORAGE,
Subscriber.Support.COMMON_EVENT_DRIVE_MODE, Subscriber.Support.COMMON_EVENT_DRIVE_MODE,
Subscriber.Support.COMMON_EVENT_HOME_MODE, Subscriber.Support.COMMON_EVENT_HOME_MODE,
Subscriber.Support.COMMON_EVENT_OFFICE_MODE, Subscriber.Support.COMMON_EVENT_OFFICE_MODE,
Subscriber.Support.COMMON_EVENT_USER_STARTED, Subscriber.Support.COMMON_EVENT_USER_STARTED,
Subscriber.Support.COMMON_EVENT_USER_BACKGROUND, Subscriber.Support.COMMON_EVENT_USER_BACKGROUND,
Subscriber.Support.COMMON_EVENT_USER_FOREGROUND, Subscriber.Support.COMMON_EVENT_USER_FOREGROUND,
Subscriber.Support.COMMON_EVENT_USER_UNLOCKED, Subscriber.Support.COMMON_EVENT_USER_UNLOCKED,
Subscriber.Support.COMMON_EVENT_USER_STOPPED, Subscriber.Support.COMMON_EVENT_USER_STOPPED,
Subscriber.Support.COMMON_EVENT_HWID_LOGIN, Subscriber.Support.COMMON_EVENT_HWID_LOGIN,
Subscriber.Support.COMMON_EVENT_HWID_LOGOUT, Subscriber.Support.COMMON_EVENT_HWID_LOGOUT,
Subscriber.Support.COMMON_EVENT_HWID_TOKEN_INVALID, Subscriber.Support.COMMON_EVENT_HWID_TOKEN_INVALID,
Subscriber.Support.COMMON_EVENT_HWID_LOGOFF, Subscriber.Support.COMMON_EVENT_HWID_LOGOFF,
Subscriber.Support.COMMON_EVENT_WIFI_POWER_STATE, Subscriber.Support.COMMON_EVENT_WIFI_POWER_STATE,
Subscriber.Support.COMMON_EVENT_WIFI_CONN_STATE, Subscriber.Support.COMMON_EVENT_WIFI_CONN_STATE,
], ],
}; };
var result = 0; var result = 0;
function subscriberCallBack001(err, data) { function subscriberCallBack001(err, data) {
console.info("==========================>subscriberCallBack001 event = "+ data.event); console.info("==========================>subscriberCallBack001 event = "+ data.event);
result = findArray(data.event); result = findArray(data.event);
if (result == true) { if (result == true) {
console.info("==========================>subscriberCallBack001 result == true"); console.info("==========================>subscriberCallBack001 result == true");
if (data.event == Subscriber.Support.COMMON_EVENT_WIFI_CONN_STATE) { if (data.event == Subscriber.Support.COMMON_EVENT_WIFI_CONN_STATE) {
done(); done();
} }
} }
console.info("==========================>subscriberCallBack001 end"); console.info("==========================>subscriberCallBack001 end");
} }
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo commonEventSubscribeInfo
).then(function (data) { ).then(function (data) {
console.info("===============>ActsSubscriberTestUnorderSystem_0100=========createSubscriber promise"); console.info("===============>ActsSubscriberTestUnorderSystem_0100=========createSubscriber promise");
commonEventSubscriber1 = data; commonEventSubscriber1 = data;
Subscriber.subscribe(commonEventSubscriber1, subscriberCallBack001); Subscriber.subscribe(commonEventSubscriber1, subscriberCallBack001);
for (var i = 0; i < 50; ++i) { for (var i = 0; i < 50; ++i) {
sleep(1000); sleep(1000);
Subscriber.publish(commonEventSubscribeInfo.events[i], publishCallback); Subscriber.publish(commonEventSubscribeInfo.events[i], publishCallback);
} }
}) })
setTimeout(function (){ })
console.debug("===================>ActsSubscriberTestUnorderSystem_0100 end==================");
}, 30000); /*
}) * @tc.number : ActsSubscriberTestUnorderSystem_0200
* @tc.name : verify subscribe and publish : Check subscribe and publish system event data without permission
/* * @tc.desc : Check the subscriber can receive event "publish_event0100" type of the interface (by Promise)
* @tc.number : ActsSubscriberTestUnorderSystem_0200 */
* @tc.name : verify subscribe and publish : Check subscribe and publish system event data without permission it('ActsSubscriberTestUnorderSystem_0200', 0, async function (done) {
* @tc.desc : Check the subscriber can receive event "publish_event0100" type of the interface (by Promise) console.info("===============ActsSubscriberTestUnorderSystem_0200 start==========================>");
*/ var commonEventSubscribeInfo = {
it('ActsSubscriberTestUnorderSystem_0200', 0, async function (done) { events: [
console.info("===============ActsSubscriberTestUnorderSystem_0200 start==========================>"); Subscriber.Support.COMMON_EVENT_WIFI_HOTSPOT_STATE,
var commonEventSubscribeInfo = { Subscriber.Support.COMMON_EVENT_BLUETOOTH_A2DPSOURCE_AVRCP_CONNECT_STATE_UPDATE,
events: [ Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_SDP_RESULT,
Subscriber.Support.COMMON_EVENT_WIFI_HOTSPOT_STATE, Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_PAIRING_CANCEL,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_A2DPSOURCE_AVRCP_CONNECT_STATE_UPDATE, Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_REQ,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_SDP_RESULT, Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_REPLY,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_PAIRING_CANCEL, Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_CANCEL,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_REQ, Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_CONNECT_STATE_UPDATE,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_REPLY, Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AUDIO_STATE_UPDATE,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_REMOTEDEVICE_CONNECT_CANCEL, Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AG_COMMON_EVENT,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_CONNECT_STATE_UPDATE, Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AG_CALL_STATE_UPDATE,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AUDIO_STATE_UPDATE, Subscriber.Support.COMMON_EVENT_BLUETOOTH_HOST_REQ_DISCOVERABLE,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AG_COMMON_EVENT, Subscriber.Support.COMMON_EVENT_NFC_ACTION_ADAPTER_STATE_CHANGED,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_HANDSFREEUNIT_AG_CALL_STATE_UPDATE, Subscriber.Support.COMMON_EVENT_DISCHARGING,
Subscriber.Support.COMMON_EVENT_BLUETOOTH_HOST_REQ_DISCOVERABLE, Subscriber.Support.COMMON_EVENT_CHARGING,
Subscriber.Support.COMMON_EVENT_NFC_ACTION_ADAPTER_STATE_CHANGED, Subscriber.Support.COMMON_EVENT_DEVICE_IDLE_MODE_CHANGED,
Subscriber.Support.COMMON_EVENT_DISCHARGING, Subscriber.Support.COMMON_EVENT_POWER_SAVE_MODE_CHANGED,
Subscriber.Support.COMMON_EVENT_CHARGING, Subscriber.Support.COMMON_EVENT_LOCATION_MODE_STATE_CHANGED,
Subscriber.Support.COMMON_EVENT_DEVICE_IDLE_MODE_CHANGED, Subscriber.Support.COMMON_EVENT_IVI_SLEEP,
Subscriber.Support.COMMON_EVENT_POWER_SAVE_MODE_CHANGED, Subscriber.Support.COMMON_EVENT_IVI_PAUSE,
Subscriber.Support.COMMON_EVENT_LOCATION_MODE_STATE_CHANGED, Subscriber.Support.COMMON_EVENT_IVI_STANDBY,
Subscriber.Support.COMMON_EVENT_IVI_SLEEP, Subscriber.Support.COMMON_EVENT_IVI_LASTMODE_SAVE,
Subscriber.Support.COMMON_EVENT_IVI_PAUSE, Subscriber.Support.COMMON_EVENT_IVI_VOLTAGE_ABNORMAL,
Subscriber.Support.COMMON_EVENT_IVI_STANDBY, Subscriber.Support.COMMON_EVENT_IVI_HIGH_TEMPERATURE,
Subscriber.Support.COMMON_EVENT_IVI_LASTMODE_SAVE, Subscriber.Support.COMMON_EVENT_IVI_EXTREME_TEMPERATURE,
Subscriber.Support.COMMON_EVENT_IVI_VOLTAGE_ABNORMAL, Subscriber.Support.COMMON_EVENT_IVI_TEMPERATURE_ABNORMAL,
Subscriber.Support.COMMON_EVENT_IVI_HIGH_TEMPERATURE, Subscriber.Support.COMMON_EVENT_IVI_VOLTAGE_RECOVERY,
Subscriber.Support.COMMON_EVENT_IVI_EXTREME_TEMPERATURE, Subscriber.Support.COMMON_EVENT_IVI_TEMPERATURE_RECOVERY,
Subscriber.Support.COMMON_EVENT_IVI_TEMPERATURE_ABNORMAL, Subscriber.Support.COMMON_EVENT_IVI_ACTIVE,
Subscriber.Support.COMMON_EVENT_IVI_VOLTAGE_RECOVERY, Subscriber.Support.COMMON_EVENT_USB_DEVICE_ATTACHED,
Subscriber.Support.COMMON_EVENT_IVI_TEMPERATURE_RECOVERY, Subscriber.Support.COMMON_EVENT_USB_DEVICE_DETACHED,
Subscriber.Support.COMMON_EVENT_IVI_ACTIVE, Subscriber.Support.COMMON_EVENT_USB_ACCESSORY_ATTACHED,
Subscriber.Support.COMMON_EVENT_USB_DEVICE_ATTACHED, Subscriber.Support.COMMON_EVENT_USB_ACCESSORY_DETACHED,
Subscriber.Support.COMMON_EVENT_USB_DEVICE_DETACHED, Subscriber.Support.COMMON_EVENT_AIRPLANE_MODE_CHANGED,
Subscriber.Support.COMMON_EVENT_USB_ACCESSORY_ATTACHED, Subscriber.Support.COMMON_EVENT_SMS_RECEIVE_COMPLETED,
Subscriber.Support.COMMON_EVENT_USB_ACCESSORY_DETACHED, Subscriber.Support.COMMON_EVENT_SPN_INFO_UPDATED,
Subscriber.Support.COMMON_EVENT_AIRPLANE_MODE_CHANGED, ],
Subscriber.Support.COMMON_EVENT_SMS_RECEIVE_COMPLETED, };
Subscriber.Support.COMMON_EVENT_SPN_INFO_UPDATED,
], var result = 0;
};
function subscriberCallBack002(err, data) {
var result = 0; console.info("==========================>subscriberCallBack002 event = "+ data.event);
result = findArray(data.event);
function subscriberCallBack002(err, data) { if (result == true) {
console.info("==========================>subscriberCallBack002 event = "+ data.event); console.info("==========================>subscriberCallBack002 result == true");
result = findArray(data.event); if (data.event == Subscriber.Support.COMMON_EVENT_SPN_INFO_UPDATED) {
if (result == true) { done();
console.info("==========================>subscriberCallBack002 result == true"); }
if (data.event == Subscriber.Support.COMMON_EVENT_SPN_INFO_UPDATED) { }
done(); console.info("==========================>subscriberCallBack002 end");
} }
}
console.info("==========================>subscriberCallBack002 end"); Subscriber.createSubscriber(
} commonEventSubscribeInfo
).then(function (data) {
Subscriber.createSubscriber( console.info("===============>ActsSubscriberTestUnorderSystem_0200=========createSubscriber promise");
commonEventSubscribeInfo commonEventSubscriber2 = data;
).then(function (data) { Subscriber.subscribe(commonEventSubscriber2, subscriberCallBack002);
console.info("===============>ActsSubscriberTestUnorderSystem_0200=========createSubscriber promise"); for (var i = 0; i < 36; ++i) {
commonEventSubscriber2 = data; sleep(1000);
Subscriber.subscribe(commonEventSubscriber2, subscriberCallBack002); Subscriber.publish(commonEventSubscribeInfo.events[i], publishCallback);
for (var i = 0; i < 36; ++i) { }
sleep(1000); })
Subscriber.publish(commonEventSubscribeInfo.events[i], publishCallback); })
} })
})
setTimeout(function (){
console.debug("===================>ActsSubscriberTestUnorderSystem_0200 end==================");
}, 30000);
})
})
notification/ces_standard/subscribeandpublish/actssubscriberunordertest/entry/src/main/js/test/ActsSubscriber_test_unorder.js
浏览文件 @ d4ba8ea5
/* /*
* Copyright (c) 2021 Huawei Device Co., Ltd. * Copyright (c) 2021 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
* You may obtain a copy of the License at * You may obtain a copy of the License at
* *
* http://www.apache.org/licenses/LICENSE-2.0 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
import Subscriber from '@ohos.commonevent' import Subscriber from '@ohos.commonevent'
import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index' import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index'
describe('ActsSubscriberTestUnorder', async function (done) { describe('ActsSubscriberTestUnorder', async function (done) {
console.info("===========ActsSubscriberTestUnorder start====================>"); console.info("===========ActsSubscriberTestUnorder start====================>");
var commonEventSubscriber001; var commonEventSubscriber001;
var commonEventSubscriber002; var commonEventSubscriber002;
var commonEventSubscriber003; var commonEventSubscriber003;
var commonEventSubscriber004; var commonEventSubscriber004;
var commonEventSubscriber005_1; var commonEventSubscriber0051;
var commonEventSubscriber005_2; var commonEventSubscriber0052;
var commonEventSubscriber006; var commonEventSubscriber006;
var commonEventSubscriber007; var commonEventSubscriber007;
var commonEventSubscriber008; var commonEventSubscriber008;
var commonEventSubscriber009; var commonEventSubscriber009;
var commonEventSubscriber010_1; var commonEventSubscriber0101;
var commonEventSubscriber010_2; var commonEventSubscriber0102;
var commonEventSubscriber011; var commonEventSubscriber011;
var commonEventSubscriber012; var commonEventSubscriber012;
function publishCallback(err) { function publishCallback(err) {
console.info("==========================>publishCallback"); console.info("==========================>publishCallback");
} }
function publishCallback1000_1(err) { function publishCallback10001(err) {
console.info("==========================>publishCallback"); console.info("==========================>publishCallback");
} }
function publishCallback1000_2(err) { function publishCallback10002(err) {
console.info("==========================>publishCallback"); console.info("==========================>publishCallback");
} }
function unsubscriberCallBack(err) { function unsubscriberCallBack(err) {
console.info("==========================>unsubscriberCallBack"); console.info("==========================>unsubscriberCallBack");
} }
/* /*
* @tc.number : ActsSubscriberTestUnorder_0100 * @tc.number : ActsSubscriberTestUnorder_0100
* @tc.name : verify subscribe and publish : Check subscribe and publish common event data * @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) * @tc.desc : Check the subscriber can receive event "publish_event0100" type of the interface (by Promise)
*/ */
it('ActsSubscriberTestUnorder_0100', 0, async function (done) { it('ActsSubscriberTestUnorder_0100', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_0100=============================>"); console.info("===============ActsSubscriberTestUnorder_0100=============================>");
function subscriberCallBack001(err, data) { function subscriberCallBack001(err, data) {
console.info("==========================>subscriberCallBack001"); console.info("==========================>subscriberCallBack001");
expect(data.event).assertEqual("publish_event0100"); expect(data.event).assertEqual("publish_event0100");
expect(data.bundleName).assertEqual(""); expect(data.bundleName).assertEqual("");
expect(data.code).assertEqual(0); expect(data.code).assertEqual(0);
expect(data.data).assertEqual(""); expect(data.data).assertEqual("");
done(); done();
} }
var commonEventSubscribeInfo = { var commonEventSubscribeInfo = {
events: ["publish_event0100"], events: ["publish_event0100"],
}; };
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo commonEventSubscribeInfo
).then(function (data) { ).then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0100=========createSubscriber promise"); console.info("===============ActsSubscriberTestUnorder_0100=========createSubscriber promise");
commonEventSubscriber001 = data; commonEventSubscriber001 = data;
data.getSubscribeInfo().then(function (data){ data.getSubscribeInfo().then(function (data){
console.info("===============ActsSubscriberTestUnorder_0100=========getSubscribeInfo promise"); console.info("===============ActsSubscriberTestUnorder_0100=========getSubscribeInfo promise");
Subscriber.subscribe(commonEventSubscriber001, subscriberCallBack001); Subscriber.subscribe(commonEventSubscriber001, subscriberCallBack001);
setTimeout(function (){ setTimeout(function (){
console.info("==========ActsSubscriberTestUnorder_0100 publish start============"); console.info("==========ActsSubscriberTestUnorder_0100 publish start============");
Subscriber.publish("publish_event0100", publishCallback); Subscriber.publish("publish_event0100", publishCallback);
}, 1000); }, 1000);
}); });
}) })
}) })
/* /*
* @tc.number : ActsSubscriberTestUnorder_0200 * @tc.number : ActsSubscriberTestUnorder_0200
* @tc.name : verify subscribe and publish : Check subscribe and publish common event data * @tc.name : verify subscribe and publish : Check subscribe and publish common event data
* of containing special characters * of containing special characters
* @tc.desc : Check the subscriber can receive event "@#￥#3243adsafdf_" type of the interface (by Promise) * @tc.desc : Check the subscriber can receive event "@#￥#3243adsafdf_" type of the interface (by Promise)
*/ */
it('ActsSubscriberTestUnorder_0200', 0, async function (done) { it('ActsSubscriberTestUnorder_0200', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_0200==========================>"); console.info("===============ActsSubscriberTestUnorder_0200==========================>");
function subscriberCallBack002(err, data) { function subscriberCallBack002(err, data) {
console.info("==========================>subscriberCallBack002"); console.info("==========================>subscriberCallBack002");
expect(data.event).assertEqual("@#￥#3243adsafdf_"); expect(data.event).assertEqual("@#￥#3243adsafdf_");
expect(data.bundleName).assertEqual(""); expect(data.bundleName).assertEqual("");
expect(data.code).assertEqual(0); expect(data.code).assertEqual(0);
expect(data.data).assertEqual(""); expect(data.data).assertEqual("");
done(); done();
} }
var commonEventSubscribeInfo = { var commonEventSubscribeInfo = {
events: ["@#￥#3243adsafdf_"], events: ["@#￥#3243adsafdf_"],
}; };
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo commonEventSubscribeInfo
).then(function (data) { ).then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0200=========createSubscriber promise"); console.info("===============ActsSubscriberTestUnorder_0200=========createSubscriber promise");
commonEventSubscriber002 = data; commonEventSubscriber002 = data;
data.getSubscribeInfo().then(function (data){ data.getSubscribeInfo().then(function (data){
console.info("===============ActsSubscriberTestUnorder_0200=========getSubscribeInfo promise"); console.info("===============ActsSubscriberTestUnorder_0200=========getSubscribeInfo promise");
Subscriber.subscribe(commonEventSubscriber002, subscriberCallBack002); Subscriber.subscribe(commonEventSubscriber002, subscriberCallBack002);
setTimeout(function (){ setTimeout(function (){
console.info("==========ActsSubscriberTestUnorder_0200 publish start============"); console.info("==========ActsSubscriberTestUnorder_0200 publish start============");
Subscriber.publish("@#￥#3243adsafdf_", publishCallback); Subscriber.publish("@#￥#3243adsafdf_", publishCallback);
}, 1000); }, 1000);
}); });
}) })
}) })
/* /*
* @tc.number : ActsSubscriberTestUnorder_0300 * @tc.number : ActsSubscriberTestUnorder_0300
* @tc.name : verify subscribe and publish : Check subscribe and publish common event data * @tc.name : verify subscribe and publish : Check subscribe and publish common event data
* with publishInfo data * with publishInfo data
* @tc.desc : Check the subscriber can receive event "publish_event0300" type of the interface (by Promise) * @tc.desc : Check the subscriber can receive event "publish_event0300" type of the interface (by Promise)
*/ */
it('ActsSubscriberTestUnorder_0300', 0, async function (done) { it('ActsSubscriberTestUnorder_0300', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_0300==========================>"); console.info("===============ActsSubscriberTestUnorder_0300==========================>");
var commonEventSubscribeInfo = { var commonEventSubscribeInfo = {
events: ["publish_event0300"], events: ["publish_event0300"],
publisherDeviceId: "PublishDeviceId0300", publisherDeviceId: "PublishDeviceId0300",
priority: 10, priority: 10,
}; };
var commonEventPublishData = { var commonEventPublishData = {
isOrdered: false, isOrdered: false,
bundleName: "PublishBundleName0300", bundleName: "PublishBundleName0300",
code: 55, code: 55,
data: "PublishData0300", data: "PublishData0300",
} }
function isOrderedCommonEventCallback003(err, data) { function isOrderedCommonEventCallback003(err, data) {
console.info("==========================>isOrderedCommonEventCallback003"); console.info("==========================>isOrderedCommonEventCallback003");
expect(data).assertEqual(false); expect(data).assertEqual(false);
done(); done();
} }
function subscriberCallBack003(err, data) { function subscriberCallBack003(err, data) {
console.info("==========================>subscriberCallBack003"); console.info("==========================>subscriberCallBack003");
expect(data.event).assertEqual("publish_event0300"); expect(data.event).assertEqual("publish_event0300");
expect(data.bundleName).assertEqual("PublishBundleName0300"); expect(data.bundleName).assertEqual("PublishBundleName0300");
expect(data.code).assertEqual(55); expect(data.code).assertEqual(55);
expect(data.data).assertEqual("PublishData0300"); expect(data.data).assertEqual("PublishData0300");
commonEventSubscriber003.isOrderedCommonEvent(isOrderedCommonEventCallback003); commonEventSubscriber003.isOrderedCommonEvent(isOrderedCommonEventCallback003);
} }
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo commonEventSubscribeInfo
).then(function (data) { ).then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0300=========createSubscriber promise"); console.info("===============ActsSubscriberTestUnorder_0300=========createSubscriber promise");
commonEventSubscriber003 = data; commonEventSubscriber003 = data;
data.getSubscribeInfo().then(function (data) { data.getSubscribeInfo().then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0300=========getSubscribeInfo promise"); console.info("===============ActsSubscriberTestUnorder_0300=========getSubscribeInfo promise");
Subscriber.subscribe(commonEventSubscriber003, subscriberCallBack003); Subscriber.subscribe(commonEventSubscriber003, subscriberCallBack003);
setTimeout(function (){ setTimeout(function (){
console.info("==========ActsSubscriberTestUnorder_0300 publish start============"); console.info("==========ActsSubscriberTestUnorder_0300 publish start============");
Subscriber.publish("publish_event0300", commonEventPublishData, publishCallback); Subscriber.publish("publish_event0300", commonEventPublishData, publishCallback);
}, 1000); }, 1000);
}); });
}) })
}) })
/* /*
* @tc.number : ActsSubscriberTestUnorder_0400 * @tc.number : ActsSubscriberTestUnorder_0400
* @tc.name : verify subscribe and publish : Check subscribe and publish sticky event * @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) * @tc.desc : Check the subscriber can receive event "publish_event0400" type of the interface (by Promise)
*/ */
it('ActsSubscriberTestUnorder_0400', 0, async function (done) { it('ActsSubscriberTestUnorder_0400', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_0400==========================>"); console.info("===============ActsSubscriberTestUnorder_0400==========================>");
var commonEventSubscribeInfo = { var commonEventSubscribeInfo = {
events: ["publish_event0400"] events: ["publish_event0400"]
}; };
var commonEventPublishData = { var commonEventPublishData = {
isOrdered: false, isOrdered: false,
isSticky: true, isSticky: true,
} }
function isStickyCommonEventCallback004(err, data) { function isStickyCommonEventCallback004(err, data) {
console.info("==========================>isStickyCommonEventCallback004 isSticky:"+ data); console.info("==========================>isStickyCommonEventCallback004 isSticky:"+ data);
expect(data).assertEqual(true); expect(data).assertEqual(true);
done(); done();
} }
function subscriberCallBack004(err, data) { function subscriberCallBack004(err, data) {
console.info("==========================>subscriberCallBack0400"); console.info("==========================>subscriberCallBack0400");
expect(data.event).assertEqual("publish_event0400"); expect(data.event).assertEqual("publish_event0400");
expect(data.bundleName).assertEqual(""); expect(data.bundleName).assertEqual("");
expect(data.code).assertEqual(0); expect(data.code).assertEqual(0);
expect(data.data).assertEqual(""); expect(data.data).assertEqual("");
commonEventSubscriber004.isStickyCommonEvent(isStickyCommonEventCallback004); commonEventSubscriber004.isStickyCommonEvent(isStickyCommonEventCallback004);
} }
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo commonEventSubscribeInfo
).then(function (data) { ).then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0400=========createSubscriber promise"); console.info("===============ActsSubscriberTestUnorder_0400=========createSubscriber promise");
commonEventSubscriber004 = data; commonEventSubscriber004 = data;
data.getSubscribeInfo().then(function (data){ data.getSubscribeInfo().then(function (data){
console.info("===============ActsSubscriberTestUnorder_0400=========getSubscribeInfo promise"); console.info("===============ActsSubscriberTestUnorder_0400=========getSubscribeInfo promise");
Subscriber.subscribe(commonEventSubscriber004, subscriberCallBack004); Subscriber.subscribe(commonEventSubscriber004, subscriberCallBack004);
setTimeout(function (){ setTimeout(function (){
console.info("==========ActsSubscriberTestUnorder_0400 publish start============"); console.info("==========ActsSubscriberTestUnorder_0400 publish start============");
Subscriber.publish("publish_event0400", commonEventPublishData, publishCallback); Subscriber.publish("publish_event0400", commonEventPublishData, publishCallback);
}, 1000); }, 1000);
}); });
}) })
}) })
/* /*
* @tc.number : ActsSubscriberTestUnorder_0500 * @tc.number : ActsSubscriberTestUnorder_0500
* @tc.name : verify subscribe and publish : Check the two different subscribe and one publish, * @tc.name : verify subscribe and publish : Check the two different subscribe and one publish,
* and check unsubscribe event * and check unsubscribe event
* @tc.desc : Check the subscriber can receive event "publish_event0500" type of the interface (by Promise) * @tc.desc : Check the subscriber can receive event "publish_event0500" type of the interface (by Promise)
*/ */
it('ActsSubscriberTestUnorder_0500', 0, async function (done) { it('ActsSubscriberTestUnorder_0500', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_0500==========================>"); console.info("===============ActsSubscriberTestUnorder_0500==========================>");
var commonEventSubscribeInfo = { var commonEventSubscribeInfo = {
events: ["publish_event0500"] events: ["publish_event0500"]
}; };
var commonEventPublishData = { var commonEventPublishData = {
isOrdered: false, isOrdered: false,
isSticky: false, isSticky: false,
} }
function subscriberCallBack005(err, data) { function subscriberCallBack005(err, data) {
console.info("==========================>subscriberCallBack0500"); console.info("==========================>subscriberCallBack0500");
expect(data.event).assertEqual("publish_event0500"); expect(data.event).assertEqual("publish_event0500");
expect(data.bundleName).assertEqual(""); expect(data.bundleName).assertEqual("");
expect(data.code).assertEqual(0); expect(data.code).assertEqual(0);
expect(data.data).assertEqual(""); expect(data.data).assertEqual("");
done(); done();
} }
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo commonEventSubscribeInfo
).then(function (data) { ).then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0500_1=========createSubscriber promise"); console.info("===============ActsSubscriberTestUnorder_0500_1=========createSubscriber promise");
commonEventSubscriber005_1 = data; commonEventSubscriber0051 = data;
data.getSubscribeInfo().then(function (data) { data.getSubscribeInfo().then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0500_1=========getSubscribeInfo promise"); console.info("===============ActsSubscriberTestUnorder_0500_1=========getSubscribeInfo promise");
Subscriber.subscribe(commonEventSubscriber005_1, subscriberCallBack005); Subscriber.subscribe(commonEventSubscriber0051, subscriberCallBack005);
}); });
}) })
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo commonEventSubscribeInfo
).then(function (data) { ).then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0500_2=========createSubscriber promise"); console.info("===============ActsSubscriberTestUnorder_0500_2=========createSubscriber promise");
commonEventSubscriber005_2 = data; commonEventSubscriber0052 = data;
data.getSubscribeInfo().then(function (data) { data.getSubscribeInfo().then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0500_2=========getSubscribeInfo promise"); console.info("===============ActsSubscriberTestUnorder_0500_2=========getSubscribeInfo promise");
Subscriber.subscribe(commonEventSubscriber005_2, subscriberCallBack005); Subscriber.subscribe(commonEventSubscriber0052, subscriberCallBack005);
Subscriber.unsubscribe(commonEventSubscriber005_1, unsubscriberCallBack); Subscriber.unsubscribe(commonEventSubscriber0051, unsubscriberCallBack);
setTimeout(function (){ setTimeout(function (){
console.info("==========ActsSubscriberTestUnorder_0500 publish start============"); console.info("==========ActsSubscriberTestUnorder_0500 publish start============");
Subscriber.publish("publish_event0500", commonEventPublishData, publishCallback); Subscriber.publish("publish_event0500", commonEventPublishData, publishCallback);
}, 1000); }, 1000);
}); });
}) })
}) })
/* /*
* @tc.number : ActsSubscriberTestUnorder_0600 * @tc.number : ActsSubscriberTestUnorder_0600
* @tc.name : verify subscribe and publish : Check one subscribe and twice publish common events * @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) * @tc.desc : Check the subscriber can receive event "publish_event0600" type of the interface (by Promise)
*/ */
it('ActsSubscriberTestUnorder_0600', 0, async function (done) { it('ActsSubscriberTestUnorder_0600', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_0600==========================>"); console.info("===============ActsSubscriberTestUnorder_0600==========================>");
var num = 0; var num = 0;
var commonEventSubscribeInfo = { var commonEventSubscribeInfo = {
events: ["publish_event0600"] events: ["publish_event0600"]
}; };
var commonEventPublishData = { var commonEventPublishData = {
isOrdered: false, isOrdered: false,
isSticky: false, isSticky: false,
} }
function subscriberCallBack006(err, data) { function subscriberCallBack006(err, data) {
console.info("==========================>subscriberCallBack0600"); console.info("==========================>subscriberCallBack0600");
expect(data.event).assertEqual("publish_event0600"); expect(data.event).assertEqual("publish_event0600");
expect(data.bundleName).assertEqual(""); expect(data.bundleName).assertEqual("");
expect(data.code).assertEqual(0); expect(data.code).assertEqual(0);
expect(data.data).assertEqual(""); expect(data.data).assertEqual("");
console.info("==========================>subscriberCallBack0600 num = " + num); console.info("==========================>subscriberCallBack0600 num = " + num);
if (num == 0) { if (num == 0) {
num++; num++;
} else if(num == 1) { } else if(num == 1) {
num = 0; num = 0;
done(); done();
} }
} }
console.info("===============ActsSubscriberTestUnorder_0600 11111111111111==========================>"); console.info("===============ActsSubscriberTestUnorder_0600 11111111111111==========================>");
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo commonEventSubscribeInfo
).then(function (data) { ).then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0600=========createSubscriber promise"); console.info("===============ActsSubscriberTestUnorder_0600=========createSubscriber promise");
commonEventSubscriber006 = data; commonEventSubscriber006 = data;
console.info("===============ActsSubscriberTestUnorder_0600 22222222222222==========================>"); console.info("===============ActsSubscriberTestUnorder_0600 22222222222222==========================>");
data.getSubscribeInfo().then(function (data) { data.getSubscribeInfo().then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0700=========getSubscribeInfo promise"); console.info("===============ActsSubscriberTestUnorder_0700=========getSubscribeInfo promise");
Subscriber.subscribe(commonEventSubscriber006, subscriberCallBack006); Subscriber.subscribe(commonEventSubscriber006, subscriberCallBack006);
setTimeout(function (){ setTimeout(function (){
console.info("==========ActsSubscriberTestUnorder_0600 publish start============"); console.info("==========ActsSubscriberTestUnorder_0600 publish start============");
Subscriber.publish("publish_event0600", commonEventPublishData, publishCallback); Subscriber.publish("publish_event0600", commonEventPublishData, publishCallback);
Subscriber.publish("publish_event0600", commonEventPublishData, publishCallback); Subscriber.publish("publish_event0600", commonEventPublishData, publishCallback);
}, 1000); }, 1000);
}); });
}) })
}) })
/* /*
* @tc.number : ActsSubscriberTestUnorder_0700 * @tc.number : ActsSubscriberTestUnorder_0700
* @tc.name : verify subscribe and publish : Check subscribe and publish common event with permission * @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) * @tc.desc : Check the subscriber can receive event "publish_event0700" type of the interface (by Promise)
*/ */
it('ActsSubscriberTestUnorder_0700', 0, async function (done) { it('ActsSubscriberTestUnorder_0700', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_0700==========================>"); console.info("===============ActsSubscriberTestUnorder_0700==========================>");
var commonEventSubscribeInfo = { var commonEventSubscribeInfo = {
events: ["publish_event0700"], events: ["publish_event0700"],
publisherPermission:"publish_event0700_permission" publisherPermission:"publish_event0700_permission"
}; };
var commonEventPublishData = { var commonEventPublishData = {
subscriberPermissions:["publish_event0700_permission"], subscriberPermissions:["publish_event0700_permission"],
isOrdered: false, isOrdered: false,
isSticky: false, isSticky: false,
} }
function subscriberCallBack007(err, data) { function subscriberCallBack007(err, data) {
console.info("==========================>subscriberCallBack0700"); console.info("==========================>subscriberCallBack0700");
expect(data.event).assertEqual("publish_event0700"); expect(data.event).assertEqual("publish_event0700");
expect(data.bundleName).assertEqual(""); expect(data.bundleName).assertEqual("");
expect(data.code).assertEqual(0); expect(data.code).assertEqual(0);
expect(data.data).assertEqual(""); expect(data.data).assertEqual("");
done(); done();
} }
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo commonEventSubscribeInfo
).then(function (data) { ).then(function (data) {
console.info("=================ActsSubscriberTestUnorder_0700=========createSubscriberPromise0700"); console.info("=================ActsSubscriberTestUnorder_0700=========createSubscriberPromise0700");
commonEventSubscriber007 = data; commonEventSubscriber007 = data;
data.getSubscribeInfo().then(function (data) { data.getSubscribeInfo().then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0700=========getSubscribeInfo promise"); console.info("===============ActsSubscriberTestUnorder_0700=========getSubscribeInfo promise");
Subscriber.subscribe(commonEventSubscriber007, subscriberCallBack007); Subscriber.subscribe(commonEventSubscriber007, subscriberCallBack007);
setTimeout(function (){ setTimeout(function (){
console.info("==========ActsSubscriberTestUnorder_0700 publish start============"); console.info("==========ActsSubscriberTestUnorder_0700 publish start============");
Subscriber.publish("publish_event0700", commonEventPublishData, publishCallback); Subscriber.publish("publish_event0700", commonEventPublishData, publishCallback);
}, 1000); }, 1000);
}); });
}); });
}) })
/* /*
* @tc.number : ActsSubscriberTestUnorder_0800 * @tc.number : ActsSubscriberTestUnorder_0800
* @tc.name : verify subscribe and publish : Check subscribe and publish common event * @tc.name : verify subscribe and publish : Check subscribe and publish common event
* with permission and check IsOrderedCommonEvent * with permission and check IsOrderedCommonEvent
* @tc.desc : Check the subscriber can receive event "publish_event0800" type of the interface (by Promise) * @tc.desc : Check the subscriber can receive event "publish_event0800" type of the interface (by Promise)
*/ */
it('ActsSubscriberTestUnorder_0800', 0, async function (done) { it('ActsSubscriberTestUnorder_0800', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_0800==========================>"); console.info("===============ActsSubscriberTestUnorder_0800==========================>");
var commonEventSubscribeInfo = { var commonEventSubscribeInfo = {
events: ["publish_event0800"], events: ["publish_event0800"],
publisherPermission:"publish_event0800_publisherPermission" publisherPermission:"publish_event0800_publisherPermission"
}; };
var commonEventPublishData = { var commonEventPublishData = {
subscriberPermissions:["publish_event0800_subscriberPermissions"], subscriberPermissions:["publish_event0800_subscriberPermissions"],
isOrdered: false, isOrdered: false,
isSticky: false isSticky: false
} }
function isOrderedCommonEventCallback009(err, data) { function isOrderedCommonEventCallback009(err, data) {
console.info("==========================>isOrderedCommonEventCallback008"); console.info("==========================>isOrderedCommonEventCallback008");
expect(data).assertEqual(false); expect(data).assertEqual(false);
done(); done();
} }
function sleep(delay) { function sleep(delay) {
var start = (new Date()).getTime(); var start = (new Date()).getTime();
while((new Date()).getTime() - start < delay) { while((new Date()).getTime() - start < delay) {
continue; continue;
} }
done(); done();
} }
function subscriberCallBack008(err, data) { function subscriberCallBack008(err, data) {
console.info("==========================>subscriberCallBack0800"); console.info("==========================>subscriberCallBack0800");
expect(data.event).assertEqual("publish_event0800"); expect(data.event).assertEqual("publish_event0800");
expect(data.bundleName).assertEqual(""); expect(data.bundleName).assertEqual("");
expect(data.code).assertEqual(0); expect(data.code).assertEqual(0);
expect(data.data).assertEqual(""); expect(data.data).assertEqual("");
expect().assertFail(); expect().assertFail();
commonEventSubscriber008.isOrderedCommonEvent(isOrderedCommonEventCallback009); commonEventSubscriber008.isOrderedCommonEvent(isOrderedCommonEventCallback009);
} }
Subscriber.createSubscriber( Subscriber.createSubscriber(
commonEventSubscribeInfo commonEventSubscribeInfo
).then(function (data) { ).then(function (data) {
console.info("==========================>createSubscriberPromise0800=======================>"); console.info("==========================>createSubscriberPromise0800=======================>");
commonEventSubscriber008 = data; commonEventSubscriber008 = data;
data.getSubscribeInfo().then(function (data) { data.getSubscribeInfo().then(function (data) {
console.info("===============ActsSubscriberTestUnorder_0800=========getSubscribeInfo promise"); console.info("===============ActsSubscriberTestUnorder_0800=========getSubscribeInfo promise");
Subscriber.subscribe(commonEventSubscriber008, subscriberCallBack008); Subscriber.subscribe(commonEventSubscriber008, subscriberCallBack008);
setTimeout(function (){ setTimeout(function (){
console.debug("==========ActsSubscriberTestUnorder_0800 publish start============"); console.debug("==========ActsSubscriberTestUnorder_0800 publish start============");
Subscriber.publish("publish_event0800", commonEventPublishData, publishCallback); Subscriber.publish("publish_event0800", commonEventPublishData, publishCallback);
}, 1000); }, 1000);
}); });
}); });
sleep(5);
}) sleep(1000);
})
/*
* @tc.number : ActsSubscriberTestUnorder_0900 /*
* @tc.name : verify subscribe and publish : Check subscribe and publish sticky event * @tc.number : ActsSubscriberTestUnorder_0900
* with publishpermission and check IsStickyCommonEvent * @tc.name : verify subscribe and publish : Check subscribe and publish sticky event
* @tc.desc : Check the subscriber can receive event "publish_event0900" type of the interface (by Promise) * 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==========================>"); it('ActsSubscriberTestUnorder_0900', 0, async function (done) {
var commonEventSubscribeInfo = { console.info("===============ActsSubscriberTestUnorder_0900==========================>");
events: ["publish_event0900"] var commonEventSubscribeInfo = {
}; events: ["publish_event0900"]
};
var commonEventPublishData = {
subscriberPermissions:["publish_event0900_permission"], var commonEventPublishData = {
isOrdered: false, subscriberPermissions:["publish_event0900_permission"],
isSticky: true isOrdered: false,
} isSticky: true
}
function isStickyCommonEventCallback009(err, data) {
console.info("==========================>isStickyCommonEventCallback009"); function isStickyCommonEventCallback009(err, data) {
expect(data).assertEqual(true); console.info("==========================>isStickyCommonEventCallback009");
done(); expect(data).assertEqual(true);
} done();
}
function subscriberCallBack009(err, data) {
console.info("==========================>subscriberCallBack0900"); function subscriberCallBack009(err, data) {
expect(data.event).assertEqual("publish_event0900"); console.info("==========================>subscriberCallBack0900");
expect(data.bundleName).assertEqual(""); expect(data.event).assertEqual("publish_event0900");
expect(data.code).assertEqual(0); expect(data.bundleName).assertEqual("");
expect(data.data).assertEqual(""); expect(data.code).assertEqual(0);
commonEventSubscriber009.isStickyCommonEvent(isStickyCommonEventCallback009); expect(data.data).assertEqual("");
} commonEventSubscriber009.isStickyCommonEvent(isStickyCommonEventCallback009);
}
Subscriber.createSubscriber(
commonEventSubscribeInfo Subscriber.createSubscriber(
).then(function (data) { commonEventSubscribeInfo
console.info("==========================>createSubscriberPromise0900=======================>"); ).then(function (data) {
commonEventSubscriber009 = data; console.info("==========================>createSubscriberPromise0900=======================>");
data.getSubscribeInfo().then(function (data) { commonEventSubscriber009 = data;
console.info("===============ActsSubscriberTestUnorder_0900=========getSubscribeInfo promise="); data.getSubscribeInfo().then(function (data) {
Subscriber.subscribe(commonEventSubscriber009, subscriberCallBack009); console.info("===============ActsSubscriberTestUnorder_0900=========getSubscribeInfo promise=");
setTimeout(function (){ Subscriber.subscribe(commonEventSubscriber009, subscriberCallBack009);
console.info("==========ActsSubscriberTestUnorder_0900 publish start============"); setTimeout(function (){
Subscriber.publish("publish_event0900", commonEventPublishData, publishCallback); console.info("==========ActsSubscriberTestUnorder_0900 publish start============");
}, 1000); 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.number : ActsSubscriberTestUnorder_1000
* @tc.desc : Check the subscriber can receive event "publish_event1000" type of the interface * @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==========================>"); it('ActsSubscriberTestUnorder_1000', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_1000==========================>");
var num = 0;
var num = 0;
var commonEventSubscribeInfo_1 = {
events: ["publish_event1000_1"], var commonEventSubscribeInfo1 = {
priority: 5 events: ["publish_event1000_1"],
}; priority: 5
};
var commonEventSubscribeInfo_2 = {
events: ["publish_event1000_2"], var commonEventSubscribeInfo2 = {
priority: 10 events: ["publish_event1000_2"],
}; priority: 10
};
var commonEventPublishData_1 = {
bundleName: "publish_event1000_bundleName1", var commonEventPublishData1 = {
code: 3, bundleName: "publish_event1000_bundleName1",
data: "publish_event1000_data", code: 3,
isOrdered: false, data: "publish_event1000_data",
isSticky: false, isOrdered: false,
} isSticky: false,
}
var commonEventPublishData_2 = {
bundleName: "publish_event1000_bundleName2", var commonEventPublishData2 = {
code: 5, bundleName: "publish_event1000_bundleName2",
data: "publish_event1000_data", code: 5,
isOrdered: false, data: "publish_event1000_data",
isSticky: false, isOrdered: false,
} isSticky: false,
}
async function subscriberCallBack010_1(err, data) {
console.info("==========================>subscriberCallBack010_1"); async function subscriberCallBack0101(err, data) {
console.info("==========================>subscriberCallBack010_1 event:"+data.event); console.info("==========================>subscriberCallBack0101");
console.info("==========================>subscriberCallBack010_1 bundleName:"+data.bundleName); console.info("==========================>subscriberCallBack0101 event:"+data.event);
expect(data.event).assertEqual("publish_event1000_1"); console.info("==========================>subscriberCallBack0101 bundleName:"+data.bundleName);
expect(data.bundleName).assertEqual("publish_event1000_bundleName1"); expect(data.event).assertEqual("publish_event1000_1");
expect(data.code).assertEqual(3); expect(data.bundleName).assertEqual("publish_event1000_bundleName1");
expect(data.data).assertEqual("publish_event1000_data"); expect(data.code).assertEqual(3);
if (num == 0) { expect(data.data).assertEqual("publish_event1000_data");
num++; if (num == 0) {
}else if (num == 1) { num++;
done(); }else if (num == 1) {
} done();
} }
}
function subscriberCallBack010_2(err, data) {
console.info("==========================>subscriberCallBack010_2"); function subscriberCallBack0102(err, data) {
console.info("==========================>subscriberCallBack010_2 event:"+data.event); console.info("==========================>subscriberCallBack0102");
console.info("==========================>subscriberCallBack010_2 bundleName:"+data.bundleName); console.info("==========================>subscriberCallBack0102 event:"+data.event);
expect(data.event).assertEqual("publish_event1000_2"); console.info("==========================>subscriberCallBack0102 bundleName:"+data.bundleName);
expect(data.bundleName).assertEqual("publish_event1000_bundleName2"); expect(data.event).assertEqual("publish_event1000_2");
expect(data.code).assertEqual(5); expect(data.bundleName).assertEqual("publish_event1000_bundleName2");
expect(data.data).assertEqual("publish_event1000_data"); expect(data.code).assertEqual(5);
if (num == 0) { expect(data.data).assertEqual("publish_event1000_data");
num++; if (num == 0) {
}else if (num == 1) { num++;
done(); }else if (num == 1) {
} done();
} }
}
Subscriber.createSubscriber(
commonEventSubscribeInfo_1 Subscriber.createSubscriber(
).then(function (data) { commonEventSubscribeInfo1
console.info("=================ActsSubscriberTestUnorder_1000=========>createSubscriber Promise1000_1"); ).then(function (data) {
commonEventSubscriber010_1 = data; console.info("=================ActsSubscriberTestUnorder_1000=========>createSubscriber Promise1000_1");
data.getSubscribeInfo().then(function (data) { commonEventSubscriber0101 = data;
console.info("===============ActsSubscriberTestUnorder_1000=========getSubscribeInfo promise1000_1"); data.getSubscribeInfo().then(function (data) {
Subscriber.subscribe(commonEventSubscriber010_1, subscriberCallBack010_1); console.info("===============ActsSubscriberTestUnorder_1000=========getSubscribeInfo promise1000_1");
}); Subscriber.subscribe(commonEventSubscriber0101, subscriberCallBack0101);
}); });
});
Subscriber.createSubscriber(
commonEventSubscribeInfo_2 Subscriber.createSubscriber(
).then(function (data) { commonEventSubscribeInfo2
console.info("=================ActsSubscriberTestUnorder_1000=========>createSubscriber Promise1000_2"); ).then(function (data) {
commonEventSubscriber010_2 = data; console.info("=================ActsSubscriberTestUnorder_1000=========>createSubscriber Promise1000_2");
data.getSubscribeInfo().then(function (data) { commonEventSubscriber0102 = data;
console.info("===============ActsSubscriberTestUnorder_1000=========getSubscribeInfo promise1000_2"); data.getSubscribeInfo().then(function (data) {
Subscriber.subscribe(commonEventSubscriber010_2, subscriberCallBack010_2); console.info("===============ActsSubscriberTestUnorder_1000=========getSubscribeInfo promise1000_2");
setTimeout(function (){ Subscriber.subscribe(commonEventSubscriber0102, subscriberCallBack0102);
console.info("==========ActsSubscriberTestUnorder_1000 publish start============"); setTimeout(function (){
Subscriber.publish("publish_event1000_1", commonEventPublishData_1, publishCallback1000_1); console.info("==========ActsSubscriberTestUnorder_1000 publish start============");
Subscriber.publish("publish_event1000_2", commonEventPublishData_2, publishCallback1000_2); Subscriber.publish("publish_event1000_1", commonEventPublishData1, publishCallback10001);
}, 1000); Subscriber.publish("publish_event1000_2", commonEventPublishData2, publishCallback10002);
}); }, 1000);
}); });
}) });
})
/*
* @tc.number : ActsSubscriberTestUnorder_1100 /*
* @tc.name : verify subscribe and publish : Check one subscribes and publish one common event * @tc.number : ActsSubscriberTestUnorder_1100
* @tc.desc : Check the subscriber can receive event "publish_event1100" type of the callback interface * @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==========================>"); it('ActsSubscriberTestUnorder_1100', 0, async function (done) {
function subscriberCallBack011(err, data) { console.info("===============ActsSubscriberTestUnorder_1100==========================>");
console.info("==========================>subscriberCallBack011"); function subscriberCallBack011(err, data) {
expect(data.event).assertEqual("publish_event1100"); console.info("==========================>subscriberCallBack011");
expect(data.bundleName).assertEqual(""); expect(data.event).assertEqual("publish_event1100");
expect(data.code).assertEqual(0); expect(data.bundleName).assertEqual("");
expect(data.data).assertEqual(""); expect(data.code).assertEqual(0);
done(); expect(data.data).assertEqual("");
} done();
}
var commonEventSubscribeInfo = {
events: ["publish_event1100"], var commonEventSubscribeInfo = {
}; events: ["publish_event1100"],
};
function getSubscribeInfo1100CallBack(err, data) {
console.info("==========================>getSubscribeInfo1100CallBack=======================>"); function getSubscribeInfo1100CallBack(err, data) {
expect(data.events[0]).assertEqual("publish_event1100"); console.info("==========================>getSubscribeInfo1100CallBack=======================>");
Subscriber.subscribe(commonEventSubscriber011, subscriberCallBack011); expect(data.events[0]).assertEqual("publish_event1100");
setTimeout(function (){ Subscriber.subscribe(commonEventSubscriber011, subscriberCallBack011);
console.debug("==========ActsSubscriberTestUnorder_1100 publish start============"); setTimeout(function (){
Subscriber.publish("publish_event1100", publishCallback); console.debug("==========ActsSubscriberTestUnorder_1100 publish start============");
}, 1000); Subscriber.publish("publish_event1100", publishCallback);
} }, 1000);
}
function createSubscriber1100CallBack(err, data) {
console.info("==========================>createSubscriber1100CallBack=======================>"); function createSubscriber1100CallBack(err, data) {
commonEventSubscriber011 = data; console.info("==========================>createSubscriber1100CallBack=======================>");
data.getSubscribeInfo(getSubscribeInfo1100CallBack); commonEventSubscriber011 = data;
} data.getSubscribeInfo(getSubscribeInfo1100CallBack);
}
Subscriber.createSubscriber(commonEventSubscribeInfo, createSubscriber1100CallBack);
}) 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.number : ActsSubscriberTestUnorder_1200
* @tc.desc : Check the subscriber can receive event "publish_event1200" type of the callback interface * @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==========================>"); it('ActsSubscriberTestUnorder_1200', 0, async function (done) {
function subscriberCallBack012(err, data) { console.info("===============ActsSubscriberTestUnorder_1200==========================>");
console.info("==========================>subscriberCallBack012"); function subscriberCallBack012(err, data) {
console.info("==========================>subscriberCallBack012 " + JSON.stringify(data)); console.info("==========================>subscriberCallBack012");
expect(data.event).assertEqual("publish_event1200"); console.info("==========================>subscriberCallBack012 " + JSON.stringify(data));
expect(data.bundleName).assertEqual(""); expect(data.event).assertEqual("publish_event1200");
expect(data.code).assertEqual(0); expect(data.bundleName).assertEqual("");
expect(data.data).assertEqual(""); expect(data.code).assertEqual(0);
console.info("==========================>subscriberCallBack012:key1-value = "+ data.parameters["key1"]); expect(data.data).assertEqual("");
console.info("==========================>subscriberCallBack012:key2-value = "+ data.parameters["key2"][0]); console.info("==========================>subscriberCallBack012:key1-value = "+ data.parameters["key1"]);
console.info("==========================>subscriberCallBack012:key2-value = "+ data.parameters["key2"][1]); console.info("==========================>subscriberCallBack012:key2-value = "+ data.parameters["key2"][0]);
console.info("==========================>subscriberCallBack012:key3-value = "+ data.parameters["key3"]); console.info("==========================>subscriberCallBack012:key2-value = "+ data.parameters["key2"][1]);
done(); console.info("==========================>subscriberCallBack012:key3-value = "+ data.parameters["key3"]);
} done();
}
var commonEventSubscribeInfo = {
events: ["publish_event1200"], var commonEventSubscribeInfo = {
}; events: ["publish_event1200"],
};
var commonEventPublishData = {
isOrdered: false, var commonEventPublishData = {
isSticky: false, isOrdered: false,
parameters: { isSticky: false,
key1: "ActsSubscriberTestUnorder_1200_key", parameters: {
key2: [100,200], key1: "ActsSubscriberTestUnorder_1200_key",
key3: 44 key2: [100,200],
} key3: 44
} }
}
function getSubscribeInfo1200CallBack(err, data) {
console.info("==========================>getSubscribeInfo1200CallBack=======================>"); function getSubscribeInfo1200CallBack(err, data) {
expect(data.events[0]).assertEqual("publish_event1200"); console.info("==========================>getSubscribeInfo1200CallBack=======================>");
Subscriber.subscribe(commonEventSubscriber012, subscriberCallBack012); expect(data.events[0]).assertEqual("publish_event1200");
setTimeout(function (){ Subscriber.subscribe(commonEventSubscriber012, subscriberCallBack012);
console.info("==========ActsSubscriberTestUnorder_1200 publish start============"); setTimeout(function (){
Subscriber.publish("publish_event1200", commonEventPublishData, publishCallback); console.info("==========ActsSubscriberTestUnorder_1200 publish start============");
}, 1000); Subscriber.publish("publish_event1200", commonEventPublishData, publishCallback);
} }, 1000);
}
function createSubscriber1200CallBack(err, data) {
console.info("==========================>createSubscriber1200CallBack=======================>"); function createSubscriber1200CallBack(err, data) {
commonEventSubscriber012 = data; console.info("==========================>createSubscriber1200CallBack=======================>");
data.getSubscribeInfo(getSubscribeInfo1200CallBack); commonEventSubscriber012 = data;
} data.getSubscribeInfo(getSubscribeInfo1200CallBack);
}
Subscriber.createSubscriber(commonEventSubscribeInfo, createSubscriber1200CallBack);
}) Subscriber.createSubscriber(commonEventSubscribeInfo, createSubscriber1200CallBack);
}) })
})
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或