Skip to content

X
Xts Acts

OpenHarmony / Xts Acts
大约 1 年 前同步成功

通知 9
Star 22
Fork 0
X
Xts Acts

体验新版 GitCode，发现更多精彩内容 >>

You need to sign in or sign up before continuing.
提交 fa528c0f 编写于 作者: Z zhijianwen
浏览文件
操作

xts修改 

Signed-off-by: Nzhijianwen <zhijianwen@huawei.com>
上级 e00b9d52
展开全部 隐藏空白更改
内联 并排
Showing with 1124 addition and 578 deletion
notification/ans_standard/actsansslottest/actsansslotbybundle/entry/src/main/js/test/ExampleJsunit.test.js
浏览文件 @ fa528c0f
......@@ -359,6 +359,41 @@ describe('ActsAnsSlotByBundle', function () {
})
})
/*
* @tc.number : ActsAnsGetSlotsByBundle_1100
* @tc.name : Verify getSlot OTHER_TYPES
* @tc.desc : After adding slottype to OTHER_TYPES's slot,
* call getsbybundle for information.(callback)
*/
it('ActsAnsGetSlotsByBundle_1100', 0, async function (done) {
console.debug("====>ActsAnsGetSlotsByBundle_1100 start====>");
var bundleoption = {
bundle: "com.example.actsansslotbybundle"
}
console.debug("====>addSlotByTypePromise OTHER_TYPES enter====>");
await notification.addSlot(notification.SlotType.OTHER_TYPES);
console.debug("====>getSlotsByBundle1 start====>");
notification.getSlotsByBundle(bundleoption, (err, data) => {
console.debug("====>ActsAnsGetSlotsByBundle_1100====>" + JSON.stringify(data) );
expect(data[0].type).assertEqual(65535)
expect(data[0].level).assertEqual(1)
expect(data[0].badgeFlag).assertEqual(true)
expect(data[0].bypassDnd).assertEqual(false)
expect(data[0].lockscreenVisibility).assertEqual(3)
expect(data[0].vibrationEnabled).assertEqual(false)
expect(data[0].lightEnabled).assertEqual(false)
expect(data[0].enabled).assertEqual(true)
expect(data[0].lightColor).assertEqual(0)
console.debug("====>getSlotsByBundle1 finish====>");
console.debug("====>setSlotByBundle start====>");
notification.removeSlot(notification.SlotType.OTHER_TYPES, (err)=>{
console.debug("====>removeSlot OTHER_TYPES====>");
expect(err.code).assertEqual(0);
done();
})
})
})
/*
* @tc.number : ActsAnsSetSlotByBundle_0100
* @tc.name : Verify getSlot SERVICE_INFORMATION
......@@ -1534,8 +1569,8 @@ describe('ActsAnsSlotByBundle', function () {
console.debug("====>setSlotsByBundle1====>")
console.debug("====>getSlotsByBundle1.1 start====>");
notification.getSlotsByBundle(bundleoption,(err,data) => {
console.debug("====>ActsAnsSetSlotByBundle_2100.1====>" + JSON.stringify(data));
expect(data).assertEqual(0)
console.debug("====>ActsAnsSetSlotByBundle_2100====>" + JSON.stringify(data));
expect(typeof(data)).assertEqual("object")
console.debug("====>getSlotsByBundle1.1 finish====>");
done();
})
......@@ -1555,15 +1590,16 @@ describe('ActsAnsSlotByBundle', function () {
}
var notificationslot = {
type: notification.SlotType.OTHER_TYPES,
level: 4
level: 4,
}
notification.setSlotByBundle(bundleoption, notificationslot).then(() => {
}).catch((err)=>{
console.debug("====>setSlotsByBundle1====>")
console.debug("====>getSlotsByBundle1.1 start====>");
notification.getSlotsByBundle(bundleoption, (err,data) => {
console.debug("====>ActsAnsSetSlotByBundle_2200.1====>" + JSON.stringify(data));
expect(data).assertEqual(0)
console.debug("====>ActsAnsSetSlotByBundle_2200====>" + JSON.stringify(data));
expect(typeof(data)).assertEqual("object")
console.debug("====>getSlotsByBundle1.1 finish====>");
done();
})
......
notification/ans_standard/publish_test/actsansdistributedtest/entry/src/main/js/test/actsansdistributedtest.js
浏览文件 @ fa528c0f
......@@ -80,10 +80,10 @@ describe('ActsAnsDistributeTest', function () {
it('ActsDistribute_test_0400', 0, async function (done) {
function onConsume0100(data) {
console.info("========ActsDistribute_test_0400 onConsume data:=======>" + JSON.stringify(data));
if (data.request.distributedOption.remindType != notify.DeviceRemindType.IDLE_DONOT_REMIND
&& data.request.distributedOption.remindType != notify.DeviceRemindType.IDLE_REMIND
&& data.request.distributedOption.remindType != notify.DeviceRemindType.ACTIVE_DONOT_REMIND
&& data.request.distributedOption.remindType != notify.DeviceRemindType.ACTIVE_REMIND )
if (data.request.distributedOptions.remindType != notify.DeviceRemindType.IDLE_DONOT_REMIND
&& data.request.distributedOptions.remindType != notify.DeviceRemindType.IDLE_REMIND
&& data.request.distributedOptions.remindType != notify.DeviceRemindType.ACTIVE_DONOT_REMIND
&& data.request.distributedOptions.remindType != notify.DeviceRemindType.ACTIVE_REMIND )
{
expect().assertFail();
}
......@@ -110,7 +110,7 @@ describe('ActsAnsDistributeTest', function () {
id: 4,
label: "ANS_PublishBasicText_0100",
slotType : notify.SlotType.CONTENT_INFORMATION,
distributedOption:{isDistributed: true, supportDisplayDevices: ["0"], supportOperateDevices: ["0"]}
distributedOptions:{isDistributed: true, supportDisplayDevices: ["0"], supportOperateDevices: ["0"]}
}
await notify.publish(notificationRequest);
console.info("===========ActsDistribute_test_0400 publish promise========>");
......@@ -158,6 +158,46 @@ describe('ActsAnsDistributeTest', function () {
done();
}),timeout);
})
/*
* @tc.number: ActsDistribute_test_0600
* @tc.name: Query whether the template exists
* @tc.desc: isSupportTemplate(templateName: string, callback: AsyncCallback<boolean>): void
*/
it('ActsDistribute_test_0600', 0, async function (done) {
console.info("==>ActsDistribute_test_0600 start==>");
var templateName = '/system/etc/notification_template/assets/js/downloadTemplate.js';
function isSupportTemplateCallback(err, data) {
if(err) {
console.error("isSupportTemplateCallback" + err.code);
} else {
expect(true).assertTrue();
console.info("isSupportTemplateCallback" + JSON.stringify(data));
done();
}
}
notify.isSupportTemplate(templateName, isSupportTemplateCallback);
done();
})
/*
* @tc.number: ActsDistribute_test_0700
* @tc.name: Query whether the template exists
* @tc.desc: isSupportTemplate(templateName: string): Promise<boolean>
*/
it('ActsDistribute_test_0700', 0, async function (done) {
console.info("==>ActsDistribute_test_0700 start==>");
var templateName = '/system/etc/notification_template/assets/js/downloadTemplate.js';
notify.isSupportTemplate(templateName).then ((data) => {
expect(data).assertEqual(false);
console.info("isSupportTemplatePromise");
console.info("==>ActsDistribute_test_0700 success==>" + JSON.stringify(data));
done();
})
done();
})
})
notification/ans_standard/publish_test/wantagent/wantagent1/entry/src/main/js/test/WantAgent.test.js
浏览文件 @ fa528c0f
......@@ -311,5 +311,354 @@ describe('ActsAnsWantAgentOneTest', function () {
);
console.info('----getWantAgent after----');
})
/*
* @tc.number: ACTS_SetWant_0600
* @tc.name: getWantAgent(OperationType.START_ABILITY)
* @tc.desc: verify the function of getWantAgent(OperationType.START_ABILITY)[REPLACE_ELEMENT]
*/
it('ACTS_SetWant_0600', 0, async function (done) {
console.info('----ACTS_SetWant_0600 start----');
var agentInfo = {
wants: [
{
deviceId: "",
bundleName: "com.example.WantAgentTest1",
abilityName: "com.example.test.MainAbility",
action: "action1",
entities: ["entity1"],
type: "MIMETYPE",
uri: "key={true,true,false}",
parameters:
{
mykey0: 2222,
mykey1: [1, 2, 3],
mykey2: "[1, 2, 3]",
mykey3: "ssssssssssssssssssssssssss",
mykey4: [false, true, false],
mykey5: ["qqqqq", "wwwwww", "aaaaaaaaaaaaaaaaa"],
mykey6: true,
}
},
],
operationType: wantAgent.OperationType.START_ABILITY,
requestCode: 0,
wantAgentFlags:[wantAgent.WantAgentFlags.REPLACE_ELEMENT]
}
console.info('----getWantAgent before----');
await wantAgent.getWantAgent(agentInfo,
(err, data) => {
if (err.code == 0) {
WantAgent = data;
console.info('----getWantAgent success!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
} else {
console.info('----getWantAgent failed!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
}
done();
}
);
console.info('----getWantAgent after----');
})
/*
* @tc.number: ACTS_SetWant_0700
* @tc.name: getWantAgent(OperationType.START_ABILITY)
* @tc.desc: verify the function of getWantAgent(OperationType.START_ABILITY)[REPLACE_ACTION]
*/
it('ACTS_SetWant_0700', 0, async function (done) {
console.info('----ACTS_SetWant_0700 start----');
var agentInfo = {
wants: [
{
deviceId: "",
bundleName: "com.example.WantAgentTest1",
abilityName: "com.example.test.MainAbility",
action: "action1",
entities: ["entity1"],
type: "MIMETYPE",
uri: "key={true,true,false}",
parameters:
{
mykey0: 2222,
mykey1: [1, 2, 3],
mykey2: "[1, 2, 3]",
mykey3: "ssssssssssssssssssssssssss",
mykey4: [false, true, false],
mykey5: ["qqqqq", "wwwwww", "aaaaaaaaaaaaaaaaa"],
mykey6: true,
}
},
],
operationType: wantAgent.OperationType.START_ABILITY,
requestCode: 0,
wantAgentFlags:[wantAgent.WantAgentFlags.REPLACE_ACTION]
}
console.info('----getWantAgent before----');
await wantAgent.getWantAgent(agentInfo,
(err, data) => {
if (err.code == 0) {
WantAgent = data;
console.info('----getWantAgent success!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
} else {
console.info('----getWantAgent failed!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
}
done();
}
);
console.info('----getWantAgent after----');
})
/*
* @tc.number: ACTS_SetWant_0800
* @tc.name: getWantAgent(OperationType.START_ABILITY)
* @tc.desc: verify the function of getWantAgent(OperationType.START_ABILITY)[REPLACE_URI]
*/
it('ACTS_SetWant_0800', 0, async function (done) {
console.info('----ACTS_SetWant_0800 start----');
var agentInfo = {
wants: [
{
deviceId: "",
bundleName: "com.example.WantAgentTest1",
abilityName: "com.example.test.MainAbility",
action: "action1",
entities: ["entity1"],
type: "MIMETYPE",
uri: "key={true,true,false}",
parameters:
{
mykey0: 2222,
mykey1: [1, 2, 3],
mykey2: "[1, 2, 3]",
mykey3: "ssssssssssssssssssssssssss",
mykey4: [false, true, false],
mykey5: ["qqqqq", "wwwwww", "aaaaaaaaaaaaaaaaa"],
mykey6: true,
}
},
],
operationType: wantAgent.OperationType.START_ABILITY,
requestCode: 0,
wantAgentFlags:[wantAgent.WantAgentFlags.REPLACE_URI]
}
console.info('----getWantAgent before----');
await wantAgent.getWantAgent(agentInfo,
(err, data) => {
if (err.code == 0) {
WantAgent = data;
console.info('----getWantAgent success!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
} else {
console.info('----getWantAgent failed!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
}
done();
}
);
console.info('----getWantAgent after----');
})
/*
* @tc.number: ACTS_SetWant_0900
* @tc.name: getWantAgent(OperationType.START_ABILITY)
* @tc.desc: verify the function of getWantAgent(OperationType.START_ABILITY)[REPLACE_ENTITIES]
*/
it('ACTS_SetWant_0900', 0, async function (done) {
console.info('----ACTS_SetWant_0900 start----');
var agentInfo = {
wants: [
{
deviceId: "",
bundleName: "com.example.WantAgentTest1",
abilityName: "com.example.test.MainAbility",
action: "action1",
entities: ["entity1"],
type: "MIMETYPE",
uri: "key={true,true,false}",
parameters:
{
mykey0: 2222,
mykey1: [1, 2, 3],
mykey2: "[1, 2, 3]",
mykey3: "ssssssssssssssssssssssssss",
mykey4: [false, true, false],
mykey5: ["qqqqq", "wwwwww", "aaaaaaaaaaaaaaaaa"],
mykey6: true,
}
},
],
operationType: wantAgent.OperationType.START_ABILITY,
requestCode: 0,
wantAgentFlags:[wantAgent.WantAgentFlags.REPLACE_ENTITIES]
}
console.info('----getWantAgent before----');
await wantAgent.getWantAgent(agentInfo,
(err, data) => {
if (err.code == 0) {
WantAgent = data;
console.info('----getWantAgent success!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
} else {
console.info('----getWantAgent failed!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
}
done();
}
);
console.info('----getWantAgent after----');
})
/*
* @tc.number: ACTS_SetWant_1000
* @tc.name: getWantAgent(OperationType.START_ABILITY)
* @tc.desc: verify the function of getWantAgent(OperationType.START_ABILITY)[REPLACE_BUNDLE]
*/
it('ACTS_SetWant_1000', 0, async function (done) {
console.info('----ACTS_SetWant_1000 start----');
var agentInfo = {
wants: [
{
deviceId: "",
bundleName: "com.example.WantAgentTest1",
abilityName: "com.example.test.MainAbility",
action: "action1",
entities: ["entity1"],
type: "MIMETYPE",
uri: "key={true,true,false}",
parameters:
{
mykey0: 2222,
mykey1: [1, 2, 3],
mykey2: "[1, 2, 3]",
mykey3: "ssssssssssssssssssssssssss",
mykey4: [false, true, false],
mykey5: ["qqqqq", "wwwwww", "aaaaaaaaaaaaaaaaa"],
mykey6: true,
}
},
],
operationType: wantAgent.OperationType.START_ABILITY,
requestCode: 0,
wantAgentFlags:[wantAgent.WantAgentFlags.REPLACE_BUNDLE]
}
console.info('----getWantAgent before----');
await wantAgent.getWantAgent(agentInfo,
(err, data) => {
if (err.code == 0) {
WantAgent = data;
console.info('----getWantAgent success!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
} else {
console.info('----getWantAgent failed!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
}
done();
}
);
console.info('----getWantAgent after----');
})
/*
* @tc.number: ACTS_SetWant_1100
* @tc.name: getWantAgent(OperationType.START_ABILITY)
* @tc.desc: verify the function of getWantAgent(OperationType.START_ABILITY)
*/
it('ACTS_SetWant_1100', 0, async function (done) {
console.info('----ACTS_SetWant_1100 start----');
var agentInfo = {
wants: [
{
deviceId: "",
bundleName: "com.example.WantAgentTest1",
abilityName: "com.example.WantAgentTest1.MainAbility",
action: "action1",
entities: ["entity1"],
type: "MIMETYPE",
uri: "key={true,true,false}",
parameters:
{
mykey0: 2222,
mykey1: [1, 2, 3],
mykey2: "[1, 2, 3]",
mykey3: "ssssssssssssssssssssssssss",
mykey4: [false, true, false],
mykey5: ["qqqqq", "wwwwww", "aaaaaaaaaaaaaaaaa"],
mykey6: true,
}
},
],
operationType: wantAgent.OperationType.START_ABILITY,
requestCode: 0,
wantAgentFlags:[wantAgent.WantAgentFlags.UPDATE_PRESENT_FLAG]
}
console.info('----getWantAgent before----');
await wantAgent.getWantAgent(agentInfo,
(err, data) => {
if (err.code == 0) {
WantAgent = data;
console.info('----getWantAgent success!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
var triggerInfo = {
code:0
}
wantAgent.trigger(WantAgent, triggerInfo,
(err, data) => {
if (err.code == 0) {
console.info('----trigger success!----');
console.info('== trigger data ' + JSON.stringify(data) );
expect(data.info).assertEqual(WantAgent);
expect(data.want).assertEqual(Want);
expect(typeof(data.extraInfo)).assertEqual("object");
expect(data.finalCode).assertEqual(0);
expect(data.finalData).assertEqual("");
expect(data.want.deviceId).assertEqual("");
expect(data.want.bundleName).assertEqual("com.example.WantAgentTest1");
expect(data.want.abilityName).assertEqual("com.example.WantAgentTest1.MainAbility");
expect(data.want.uri).assertEqual("key={true,true,false}");
expect(JSON.stringify(data.want.entities)).assertEqual(JSON.stringify(["entity1"]));
expect(data.want.action).assertEqual("action1");
} else {
console.info('----trigger failed!----');
console.info('== trigger data ' + JSON.stringify(data) );
}
done();
}
);
} else {
console.info('----getWantAgent failed!----');
console.info(data);
expect(typeof(data)).assertEqual("object");
}
done();
}
);
setTimeout(function(){
console.debug("====>time out ACTS_SetWant_0700====>");
}, 100);
console.info('----getWantAgent after----');
})
})
notification/ans_standard/publish_test/wantagent/wantagent2promise/entry/src/main/js/test/WantAgent.test.js
浏览文件 @ fa528c0f
......@@ -25,6 +25,7 @@ describe('ActsAnsWantAgentTwoProTest', function () {
* @tc.desc: verify the function of getWantAgent(OperationType.START_ABILITIES)
*/
it('ACTS_SetWant_0400', 0, async function (done) {
expect(3).assertEqual(wantAgent.OperationType.START_SERVICE)
var agentInfo = {
wants: [
{
......
notification/ces_standard/subscribeandpublish/actssubscriberunordersystemtest/entry/src/main/js/test/ActsSubscriber_test_unorder.js
浏览文件 @ fa528c0f
......@@ -12,7 +12,7 @@
* See the License for the specific language governing permissions and
* 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'
describe('ActsSubscriberTestUnorderSystem', async function (done) {
......@@ -108,7 +108,14 @@ describe('ActsSubscriberTestUnorderSystem', async function (done) {
Subscriber.Support.COMMON_EVENT_SMS_RECEIVE_COMPLETED,
Subscriber.Support.COMMON_EVENT_SPN_INFO_UPDATED,
Subscriber.Support.COMMON_EVENT_BOOT_COMPLETED,
Subscriber.Support.COMMON_EVENT_SPLIT_SCREEN
Subscriber.Support.COMMON_EVENT_SPLIT_SCREEN,
Subscriber.Support.COMMON_EVENT_THERMAL_LEVEL_CHANGED,
Subscriber.Support.COMMON_EVENT_VOLUME_REMOVED,
Subscriber.Support.COMMON_EVENT_VOLUME_UNMOUNTED,
Subscriber.Support.COMMON_EVENT_VOLUME_MOUNTED,
Subscriber.Support.COMMON_EVENT_VOLUME_BAD_REMOVAL,
Subscriber.Support.COMMON_EVENT_VOLUME_EJECT,
Subscriber.Support.COMMON_EVENT_SLOT_CHANGE
];
function publishCallback(err) {
......@@ -187,6 +194,13 @@ describe('ActsSubscriberTestUnorderSystem', async function (done) {
Subscriber.Support.COMMON_EVENT_HWID_LOGOFF,
Subscriber.Support.COMMON_EVENT_WIFI_POWER_STATE,
Subscriber.Support.COMMON_EVENT_WIFI_CONN_STATE,
Subscriber.Support.COMMON_EVENT_THERMAL_LEVEL_CHANGED,
Subscriber.Support.COMMON_EVENT_VOLUME_REMOVED,
Subscriber.Support.COMMON_EVENT_VOLUME_UNMOUNTED,
Subscriber.Support.COMMON_EVENT_VOLUME_MOUNTED,
Subscriber.Support.COMMON_EVENT_VOLUME_BAD_REMOVAL,
Subscriber.Support.COMMON_EVENT_VOLUME_EJECT,
Subscriber.Support.COMMON_EVENT_SLOT_CHANGE
],
};
......@@ -287,7 +301,15 @@ describe('ActsSubscriberTestUnorderSystem', async function (done) {
Subscriber.Support.COMMON_EVENT_ABILITY_UPDATED,
Subscriber.Support.COMMON_EVENT_VISIBLE_ACCOUNTS_UPDATED,
Subscriber.Support.COMMON_EVENT_ACCOUNT_DELETED,
Subscriber.Support.COMMON_EVENT_FOUNDATION_READY
Subscriber.Support.COMMON_EVENT_FOUNDATION_READY,
Subscriber.Support.COMMON_EVENT_BATTERY_CHANGED,
Subscriber.Support.COMMON_EVENT_THERMAL_LEVEL_CHANGED,
Subscriber.Support.COMMON_EVENT_VOLUME_REMOVED,
Subscriber.Support.COMMON_EVENT_VOLUME_UNMOUNTED,
Subscriber.Support.COMMON_EVENT_VOLUME_MOUNTED,
Subscriber.Support.COMMON_EVENT_VOLUME_BAD_REMOVAL,
Subscriber.Support.COMMON_EVENT_VOLUME_EJECT,
Subscriber.Support.COMMON_EVENT_SLOT_CHANGE
],
};
......
notification/ces_standard/subscribeandpublish/actssubscriberunordertest/entry/src/main/js/test/ActsSubscriber_test_unorder.js
浏览文件 @ fa528c0f
......@@ -12,23 +12,23 @@
* See the License for the specific language governing permissions and
* 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'
describe('ActsSubscriberTestUnorder', async function (done) {
console.info("===========ActsSubscriberTestUnorder start====================>");
var commonEventSubscriber001;
var commonEventSubscriber002;
var commonEventSubscriber003;
var commonEventSubscriber004;
var commonEventSubscriber0051;
var commonEventSubscriber0052;
var commonEventSubscriber006;
var commonEventSubscriber008;
var commonEventSubscriber0101;
var commonEventSubscriber0102;
var commonEventSubscriber011;
var commonEventSubscriber012;
let commonEventSubscriber001;
let commonEventSubscriber002;
let commonEventSubscriber003;
let commonEventSubscriber004;
let commonEventSubscriber0051;
let commonEventSubscriber0052;
let commonEventSubscriber006;
let commonEventSubscriber008;
let commonEventSubscriber0101;
let commonEventSubscriber0102;
let commonEventSubscriber011;
let commonEventSubscriber012;
function publishCallback(err) {
console.info("==========================>publishCallback");
......@@ -62,7 +62,7 @@ describe('ActsSubscriberTestUnorder', async function (done) {
done();
}
var commonEventSubscribeInfo = {
let commonEventSubscribeInfo = {
events: ["publish_event0100"],
};
......@@ -100,7 +100,7 @@ describe('ActsSubscriberTestUnorder', async function (done) {
done();
}
var commonEventSubscribeInfo = {
let commonEventSubscribeInfo = {
events: ["@#￥#3243adsafdf_"],
};
......@@ -128,15 +128,14 @@ describe('ActsSubscriberTestUnorder', async function (done) {
*/
it('ActsSubscriberTestUnorder_0300', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_0300==========================>");
var commonEventSubscribeInfo = {
let commonEventSubscribeInfo = {
events: ["publish_event0300"],
publisherDeviceId: "PublishDeviceId0300",
priority: 10,
};
var commonEventPublishData = {
let commonEventPublishData = {
isOrdered: false,
bundleName: "PublishBundleName0300",
code: 55,
data: "PublishData0300",
}
......@@ -150,7 +149,6 @@ describe('ActsSubscriberTestUnorder', async function (done) {
function subscriberCallBack003(err, data) {
console.info("==========================>subscriberCallBack003");
expect(data.event).assertEqual("publish_event0300");
expect(data.bundleName).assertEqual("PublishBundleName0300");
expect(data.code).assertEqual(55);
expect(data.data).assertEqual("PublishData0300");
commonEventSubscriber003.isOrderedCommonEvent(isOrderedCommonEventCallback003);
......@@ -172,6 +170,7 @@ describe('ActsSubscriberTestUnorder', async function (done) {
})
})
/*
* @tc.number : ActsSubscriberTestUnorder_0500
* @tc.name : verify subscribe and publish : Check the two different subscribe and one publish,
......@@ -180,11 +179,11 @@ describe('ActsSubscriberTestUnorder', async function (done) {
*/
it('ActsSubscriberTestUnorder_0500', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_0500==========================>");
var commonEventSubscribeInfo = {
let commonEventSubscribeInfo = {
events: ["publish_event0500"]
};
var commonEventPublishData = {
let commonEventPublishData = {
isOrdered: false,
isSticky: false,
}
......@@ -225,5 +224,51 @@ describe('ActsSubscriberTestUnorder', async function (done) {
});
})
})
/*
* @tc.number : ActsSubscriberTestUnorder_0600
* @tc.name : verify subscribe and publish : Check whether the current public event is a sticky event
* @tc.desc : isStickyCommonEvent(callback: AsyncCallback<boolean>): void
*/
it('ActsSubscriberTestUnorder_0600', 0, async function (done) {
console.info("===============ActsSubscriberTestUnorder_0600==========================>");
let commonEventSubscribeInfo = {
events: ["publish_event0600"]
};
let commonEventPublishData = {
isOrdered: false,
isSticky: false,
}
function isStickyCallback(err, data) {
console.info("==========================>isStickyCallback");
expect(data).assertEqual(false);
done();
}
function subscriberCallBack006(err, data) {
console.info("==========================>subscriberCallBack006");
commonEventSubscriber006.isStickyCommonEvent(isStickyCallback);
}
Subscriber.createSubscriber(
commonEventSubscribeInfo
).then((data)=>{
console.info("===============ActsSubscriberTestUnorder_0600=========createSubscriber promise");
commonEventSubscriber006 = data;
data.getSubscribeInfo().then(()=>{
console.info("===============ActsSubscriberTestUnorder_0600=========getSubscribeInfo promise");
Subscriber.subscribe(commonEventSubscriber006, subscriberCallBack006);
Subscriber.unsubscribe(commonEventSubscriber006, unsubscriberCallBack);
setTimeout(function (){
console.info("==========ActsSubscriberTestUnorder_0600 publish start============");
Subscriber.publish("publish_event0600", commonEventPublishData, publishCallback);
}, 1000);
});
})
})
})
notification/ces_standard/subscribeandpublish/emittertest/entry/src/main/js/test/EmitterTest.js
浏览文件 @ fa528c0f
......@@ -92,6 +92,18 @@ describe('EmitterTest', function () {
done();
})
/*
* @tc.number : EmitterOffTest
* @tc.name : verify off : Check subscribe same off common ordered event
* @tc.desc : Check the subscriber can receive event "EmitterOffTest" type of the interface (by Promise)
*/
it('EmitterOffTest', 0, async function (done){
console.info("===========EmitterOffTest111====================>");
emitter.once(InnerEventLow, callback01);
emitter.emit(InnerEventImmediate, eventData);
emitter.off(1);
done();
})
})
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或