modify ces js

Signed-off-by: Nzhaoyuan17 <zhaoyuan17@huawei.com>

notification/ces_standard/subscribeandpublish/actssubscriberorderedtest/entry/src/main/js/test/ActsSubscriber_test_ordered.js

@@ -18,6 +18,7 @@ import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from '
 describe('ActsSubscriberTestOrder', function () {
     console.info("===========ActsSubscriberTestOrder start====================>");
     var num = 0, num2 = 0;
+    var order = false;
     var commonEventSubscriber0100;
     var commonEventSubscriber0101;
     var commonEventSubscriber0200_1;
@@ -26,6 +27,8 @@ describe('ActsSubscriberTestOrder', function () {
     var commonEventSubscriber0300_2;
     var commonEventSubscriber0400_1;
     var commonEventSubscriber0400_2;
+    var commonEventSubscriber0500_1;
+    var commonEventSubscriber0500_2;
 
     async function unsubscriber2_()
     {
@@ -74,7 +77,7 @@ describe('ActsSubscriberTestOrder', function () {
             console.info("===============>subscriberCallBack0100 getAbortCommonEventCallback2 promise abort: " + data);
         })
 
-        await commonEventSubscriber0100.finishCommonEvent().then(()=>{
+        commonEventSubscriber0100.finishCommonEvent().then(()=>{
             console.info("===============>subscriberCallBack0100 finishCommonEvent promise");
         })
     }
@@ -148,11 +151,17 @@ describe('ActsSubscriberTestOrder', function () {
         console.info("===============>subscriberCallBack0300_1========bundleName: " + data.bundleName);
         console.info("===============>subscriberCallBack0300_1=========code: " + data.code);
         console.info("===============>subscriberCallBack0300_1=========dat: " + data.data);
+        console.info("===============>subscriberCallBack0300_1=========order: " + order);
 
         expect(data.event).assertEqual("publish_event0301");
         expect(data.code).assertEqual(1);
         expect(data.data).assertEqual("publish_event0301_init");
         expect(data.bundleName).assertEqual("publish_event0301_bundleName");
+        expect(order).assertEqual(1);
+
+        if (order == true) {
+            order = false;
+        }
         await commonEventSubscriber0300_1.isOrderedCommonEvent().then((data)=>{
             console.info("========>subscriberCallBack0300_1 publish_event0301 isOrderedCommonEvent promise " + data);
             expect(data).assertEqual(1);
@@ -167,11 +176,17 @@ describe('ActsSubscriberTestOrder', function () {
         console.info("===============>subscriberCallBack0300_2========bundleName: " + data.bundleName);
         console.info("===============>subscriberCallBack0300_2=========code: " + data.code);
         console.info("===============>subscriberCallBack0300_2=========data: " + data.data);
+        console.info("===============>subscriberCallBack0300_2=========order: " + order);
 
         expect(data.event).assertEqual("publish_event0301");
         expect(data.code).assertEqual(1);
         expect(data.data).assertEqual("publish_event0301_init");
         expect(data.bundleName).assertEqual("publish_event0301_bundleName");
+
+        if (order == false) {
+            order = true;
+        }
+
         await commonEventSubscriber0300_2.isOrderedCommonEvent().then((data)=>{
             console.info("===============>subscriberCallBack0300_2 isOrderedCommonEvent promise " + data);
             expect(data).assertEqual(1);
@@ -209,6 +224,31 @@ describe('ActsSubscriberTestOrder', function () {
         expect().assertFail();
     }
 
+    async function subscriberCallBack0500_1(err, data) {
+        console.info("===============>SubscriberPromise0500_1========event: " + data.event);
+        console.info("===============>SubscriberPromise0500_1========bundleName: " + data.bundleName);
+        console.info("===============>SubscriberPromise0500_1=========code: " + data.code);
+        console.info("===============>SubscriberPromise0500_1=========data: " + data.data);
+        expect(data.event).assertEqual("publish_event0500");
+        expect(data.code).assertEqual(10);
+        expect(data.data).assertEqual("publish_event0500_init");
+        expect(data.bundleName).assertEqual("publish_event0500_bundleName");
+        commonEventSubscriber0500_1.finishCommonEvent().then(() => {
+            console.info("===============>SubscriberPromise0500_1==========>finishCommonEventPromise0500_1");
+        });
+    }
+
+    async function subscriberCallBack0500_2(err, data) {
+        console.info("===============>SubscriberPromise0500_2========event: " + data.event);
+        console.info("===============>SubscriberPromise0500_2========bundleName: " + data.bundleName);
+        console.info("===============>SubscriberPromise0500_2=========code: " + data.code);
+        console.info("===============>SubscriberPromise0500_2========data: " + data.data);
+        expect(data.event).assertEqual("publish_event0500");
+        expect(data.code).assertEqual(10);
+        expect(data.data).assertEqual("publish_event0500_init");
+        expect(data.bundleName).assertEqual("publish_event0500_bundleName");
+    }
+
     async function GetSubscribeInfoCallBack(data) {
         console.info("===============>GetSubscribeInfoCallBack event = " + data.events[0]);
         switch (data.events[0]) {
@@ -279,43 +319,46 @@ describe('ActsSubscriberTestOrder', function () {
             priority: 9
         };
 
-        await Subscriber.createSubscriber(
+        var commonEventPublishData = {
+            bundleName: "publish_event0100_bundleName",
+            code: 1,
+            data: "publish_event1001_init",
+            isOrdered: true,
+            isSticky: false,
+        }
+
+        Subscriber.createSubscriber(
             commonEventSubscribeInfo_1
-        ).then(async (data)=>{
+        ).then(function (data) {
             console.info("===============ActsSubscriberTestOrder_0100==========createSubscriber promise1");
             commonEventSubscriber0100 = data;
-            await commonEventSubscriber0100.getSubscribeInfo().then(async (data)=>{
+            data.getSubscribeInfo().then(function (data) {
                 console.info("===============ActsSubscriberTestOrder_0100=========getSubscribeInfo promise1");
-                await GetSubscribeInfoCallBack(data);
+                Subscriber.subscribe(commonEventSubscriber0100, subscriberCallBack0100);
             });
         })
 
-        await Subscriber.createSubscriber(
+        Subscriber.createSubscriber(
             commonEventSubscribeInfo_2
-        ).then(async (data)=>{
+        ).then(function (data) {
             console.info("===============ActsSubscriberTestOrder_0100==========createSubscriber promise2");
             commonEventSubscriber0101 = data;
-            await commonEventSubscriber0100.getSubscribeInfo().then(async (data)=>{
+            data.getSubscribeInfo().then(function (data) {
                 console.info("===============ActsSubscriberTestOrder_0100=========getSubscribeInfo promise2");
-                await GetSubscribeInfoCallBack(data);
+                Subscriber.subscribe(commonEventSubscriber0101, subscriberCallBack0101);
+                Subscriber.publish("publish_event0100", commonEventPublishData, publishCallback);
             });
         })
 
-        var commonEventPublishData = {
-            bundleName: "publish_event0100_bundleName",
-            code: 1,
-            data: "publish_event1001_init",
-            isOrdered: true,
-            isSticky: false,
-        }
-
-        Subscriber.publish("publish_event0100", commonEventPublishData, publishCallback);
-        done();
+        setTimeout(function (){
+            console.debug("===================ActsSubscriberTestOrder_0100 end==================");
+            done();
+        }, 30000);
     })
 
     /*
      * @tc.number    : ActsSubscriberTestOrder_0200
-     * @tc.name      : verify subscribe and publish : Check subscribe different event 
+     * @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)
      */
@@ -333,28 +376,6 @@ describe('ActsSubscriberTestOrder', function () {
             priority: 9
         };
 
-        await Subscriber.createSubscriber(
-            commonEventSubscribeInfo_1,
-        ).then(async (data)=>{
-            console.info("===============ActsSubscriberTestOrder_0200==========createSubscriber promise1");
-            commonEventSubscriber0200_1 = data;
-            await data.getSubscribeInfo().then(async (data)=>{
-                console.info("===============ActsSubscriberTestOrder_0200=========getSubscribeInfo promise1");
-                await getSubscribeInfoCallBack0200_1(data);
-            });
-        })
-
-        await Subscriber.createSubscriber(
-            commonEventSubscribeInfo_2,
-        ).then(async (data)=>{
-            console.info("===============ActsSubscriberTestOrder_0200==========createSubscriber promise2");
-            commonEventSubscriber0200_2 = data;
-            await data.getSubscribeInfo().then(async (data)=>{
-                console.info("===============ActsSubscriberTestOrder_0200=========getSubscribeInfo promise2");
-                await getSubscribeInfoCallBack0200_2(data);
-            });
-        })
-
         var commonEventPublishData1 = {
             bundleName: "publish_event0200_bundleName",
             code: 1,
@@ -371,16 +392,41 @@ describe('ActsSubscriberTestOrder', function () {
             isSticky: false,
         }
 
-        await unsubscriber2_();
+        Subscriber.createSubscriber(
+            commonEventSubscribeInfo_1,
+        ).then(function (data) {
+            console.info("===============ActsSubscriberTestOrder_0200==========createSubscriber promise1");
+            commonEventSubscriber0200_1 = data;
+            data.getSubscribeInfo().then(function (data) {
+                console.info("===============ActsSubscriberTestOrder_0200=========getSubscribeInfo promise1");
+                Subscriber.subscribe(commonEventSubscriber0200_1, subscriberCallBack0200_1);
+            });
+        })
+
+        Subscriber.createSubscriber(
+            commonEventSubscribeInfo_2,
+        ).then(function (data) {
+            console.info("===============ActsSubscriberTestOrder_0200==========createSubscriber promise2");
+            commonEventSubscriber0200_2 = data;
+            data.getSubscribeInfo().then(function (data) {
+                console.info("===============ActsSubscriberTestOrder_0200=========getSubscribeInfo promise2");
+                Subscriber.subscribe(commonEventSubscriber0200_2, subscriberCallBack0200_2);
+                Subscriber.unsubscribe(commonEventSubscriber0200_1,unsubscribeCallback);
+                Subscriber.publish("publish_event0200", commonEventPublishData1, publishCallback);
+                Subscriber.publish("publish_event0201", commonEventPublishData2, publishCallback);
+
+            });
+        })
 
-        Subscriber.publish("publish_event0200", commonEventPublishData1, publishCallback);
-        Subscriber.publish("publish_event0201", commonEventPublishData2, publishCallback);
-        done();
+        setTimeout(function (){
+            console.debug("===================ActsSubscriberTestOrder_0200 end==================");
+            done();
+        }, 30000);
     })
 
     /*
      * @tc.number    : ActsSubscriberTestOrder_0300
-     * @tc.name      : verify subscribe and publish : Check subscribe different events 
+     * @tc.name      : verify subscribe and publish : Check subscribe different events
      *                 and some publish common ordered events
      * @tc.desc      : Check the subscriber can receive event "publish_event0301" type of the interface (by Promise)
      */
@@ -397,46 +443,49 @@ describe('ActsSubscriberTestOrder', function () {
             priority: 10
         };
 
-        await Subscriber.createSubscriber(
+        var commonEventPublishData2 = {
+            bundleName: "publish_event0301_bundleName",
+            code: 1,
+            data: "publish_event0301_init",
+            isOrdered: true,
+            isSticky: false,
+        }
+
+        Subscriber.createSubscriber(
             commonEventSubscribeInfo_1,
-        ).then(async (data)=>{
+        ).then(function (data) {
             console.info("===============ActsSubscriberTestOrder_0300==========createSubscriber promise1");
             commonEventSubscriber0300_1 = data;
-            await data.getSubscribeInfo().then(async (data)=>{
+            data.getSubscribeInfo().then(function (data) {
                 console.info("===============ActsSubscriberTestOrder_0300=========getSubscribeInfo promise1");
-                await getSubscribeInfoCallBack0300_1(data);
+                Subscriber.subscribe(commonEventSubscriber0300_1, subscriberCallBack0300_1);
             });
         })
 
-        await Subscriber.createSubscriber(
+        Subscriber.createSubscriber(
             commonEventSubscribeInfo_2,
-        ).then(async (data)=>{
+        ).then(function (data) {
             console.info("===============ActsSubscriberTestOrder_0300==========createSubscriber promise2");
             commonEventSubscriber0300_2 = data;
-            await data.getSubscribeInfo().then(async (data)=>{
+            data.getSubscribeInfo().then(function (data) {
                 console.info("===============ActsSubscriberTestOrder_0300=========getSubscribeInfo promise2");
-                await getSubscribeInfoCallBack0300_2(data);
+                Subscriber.subscribe(commonEventSubscriber0300_2, subscriberCallBack0300_2);
+                var numindex = 0;
+                for (; numindex < 3; ++numindex) {
+                    Subscriber.publish("publish_event0301", commonEventPublishData2, publishCallback);
+                }
             });
         })
 
-        var commonEventPublishData2 = {
-            bundleName: "publish_event0301_bundleName",
-            code: 1,
-            data: "publish_event0301_init",
-            isOrdered: true,
-            isSticky: false,
-        }
-        var numindex = 0;
-        for (; numindex < 3; ++numindex) {
-            Subscriber.publish("publish_event0301", commonEventPublishData2, publishCallback);
-        }
-        done();
-
+        setTimeout(function (){
+            console.debug("===================ActsSubscriberTestOrder_0300 end==================");
+            done();
+        }, 30000);
     })
 
     /*
      * @tc.number    : ActsSubscriberTestOrder_0400
-     * @tc.name      : verify subscribe and publish : Check subscribe same events 
+     * @tc.name      : verify subscribe and publish : Check subscribe same events
      *                 and publish common ordered events and check abort event
      * @tc.desc      : Check the subscriber can receive event "publish_event0400" type of the interface (by promise)
      */
@@ -453,38 +502,100 @@ describe('ActsSubscriberTestOrder', function () {
             priority: 9
         };
 
-        await Subscriber.createSubscriber(
+        var commonEventPublishData = {
+            bundleName: "publish_event0400_bundleName",
+            code: 1,
+            data: "publish_event0400_init",
+            isOrdered: true,
+            isSticky: false,
+        }
+
+        Subscriber.createSubscriber(
             commonEventSubscribeInfo_1
-        ).then(async (data) => {
+        ).then(function (data) {
             console.info("===============createSubscriberPromise0400_1:1");
             commonEventSubscriber0400_1 = data;
-            await data.getSubscribeInfo().then(async (data)=>{
+            data.getSubscribeInfo().then(function (data) {
                 console.info("=============GetSubscribeInfoPromisek0400_1 data.events[0]: " + data.events[0]);
                 expect(data.events[0]).assertEqual("publish_event0400");
-                await Subscriber.subscribe(commonEventSubscriber0400_1, subscriberCallBack0400_1);
+                Subscriber.subscribe(commonEventSubscriber0400_1, subscriberCallBack0400_1);
             })
         })
 
-        await Subscriber.createSubscriber(
+        Subscriber.createSubscriber(
             commonEventSubscribeInfo_2
-        ).then(async (data) => {
+        ).then(function (data) {
             console.info("==================createSubscriberPromise0400_1:2");
             commonEventSubscriber0400_2 = data;
-            await data.getSubscribeInfo().then(async (data)=>{
+            data.getSubscribeInfo().then(function (data) {
                 console.info("==============GetSubscribeInfoPromisek0400_1 data.events[0] : " + data.events[0]);
                 expect(data.events[0]).assertEqual("publish_event0400");
-                await Subscriber.subscribe(commonEventSubscriber0400_2, subscriberCallBack0400_2);
+                Subscriber.subscribe(commonEventSubscriber0400_2, subscriberCallBack0400_2);
+                Subscriber.publish("publish_event0400", commonEventPublishData, publishCallback);
             })
         })
 
+        setTimeout(function (){
+            console.debug("===================ActsSubscriberTestOrder_0400 end==================");
+            done();
+        }, 30000);
+    })
+
+    /*
+     * @tc.number    : ActsSubscriberTestOrder_0500
+     * @tc.name      : verify subscribe and publish : Check subscriber same events
+     *                 and publish common ordered events and check subscriberInfo priority
+     * @tc.desc      : Check the subscriber can receive event "publish_event0500" type of the interface (by promise)
+     */
+    it ('ActsSubscriberTestOrder_0500', 0, async function (done) {
+        console.info("===============ActsSubscriberTestOrder_0500===============>");
+
+        var commonEventSubscribeInfo_1 = {
+            events: ["publish_event0500"],
+            priority: 1001
+        };
+
+        var commonEventSubscribeInfo_2 = {
+            events: ["publish_event0500"],
+            priority: -101
+        };
+
         var commonEventPublishData = {
-            bundleName: "publish_event0400_bundleName",
-            code: 1,
-            data: "publish_event0400_init",
+            bundleName: "publish_event0500_bundleName",
+            code: 10,
+            data: "publish_event0500_init",
             isOrdered: true,
             isSticky: false,
         }
-        Subscriber.publish("publish_event0400", commonEventPublishData, publishCallback);
-        done();
+
+        Subscriber.createSubscriber(
+            commonEventSubscribeInfo_1
+        ).then(function (data) {
+            console.info("===============createSubscriberPromise0500_1:1");
+            commonEventSubscriber0500_1 = data;
+            data.getSubscribeInfo().then(function (data) {
+                console.info("=============GetSubscribeInfoPromisek0500_1:1 data.events[0]: " + data.events[0]);
+                expect(data.events[0]).assertEqual("publish_event0500");
+                Subscriber.subscribe(commonEventSubscriber0500_1, subscriberCallBack0500_1);
+            })
+        })
+
+        Subscriber.createSubscriber(
+            commonEventSubscribeInfo_2
+        ).then(function (data) {
+            console.info("==================createSubscriberPromise0500_1:2");
+            commonEventSubscriber0500_2 = data;
+            data.getSubscribeInfo().then(function (data) {
+                console.info("==============GetSubscribeInfoPromisek0500_1:2 data.events[0] : " + data.events[0]);
+                expect(data.events[0]).assertEqual("publish_event0500");
+                Subscriber.subscribe(commonEventSubscriber0500_2, subscriberCallBack0500_2);
+                Subscriber.publish("publish_event0500", commonEventPublishData, publishCallback);
+            })
+        })
+        
+        setTimeout(function (){
+            console.debug("===================ActsSubscriberTestOrder_0500 end==================");
+            done();
+        }, 30000);
     })
 })

notification/ces_standard/subscribeandpublish/actssubscriberunordertest/entry/src/main/config.json

@@ -30,11 +30,6 @@
       "grantMode": "system_grant",
       "name": "publish_event0800_permission"
     },
-      {
-        "availableScope": [],
-        "grantMode": "system_grant",
-        "name": "publish_event0900_subscriberPermissions"
-      },
       {
         "availableScope": [],
         "grantMode": "system_grant",
@@ -48,7 +43,7 @@
       {
         "availableScope": [],
         "grantMode": "system_grant",
-        "name": "permission.COMMONEVENT_STICKY"
+        "name": "ohos.permission.COMMONEVENT_STICKY"
       }
     ],
     "reqPermissions": [
@@ -56,10 +51,6 @@
         "name": "publish_event0800_permission",
         "reason": "ceshi"
       },
-      {
-        "name": "publish_event0900_subscriberPermissions",
-        "reason": "ceshi"
-      },
       {
         "name": "publish_event0900_publisherPermission",
         "reason": "ceshi"
@@ -69,7 +60,7 @@
         "reason": "ceshi"
       },
       {
-        "name": "permission.COMMONEVENT_STICKY",
+        "name": "ohos.permission.COMMONEVENT_STICKY",
         "reason": "ceshi"
       }
     ],
@@ -107,4 +98,4 @@
       }
     ]
   }
-}
\ No newline at end of file
+}