liangzhenyu6@huawei.com

Signed-off-by: liangzhenyu123 <liangzhenyu6@huawei.com>

distributeddatamgr/jstest/distributed_kv_store/client/hap/src/main/js/default/test/ExampleJsunit.test.js

@@ -1,48 +0,0 @@
-/*
- * Copyright (C) 2022 Huawei Device Co., Ltd.
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-import app from '@system.app'
-import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index'
-import ApiMessage from '../../../../../../../../../../testtools/disjsTest/common/apiMessage.js'
-import TestService from '../../../../../../../../../../testtools/disjsTest/client/testService.js'
-import RemoteHelper from '../../../../../../../../../../testtools/disjsTest/client/remoteHelper.js'
-
-var logTag = 'RpcClient'
-var testservice = null
-var gIRemoteObject = null;
-var remoteHelpers = null;
-
-describe('addTest', function () {
-
-    beforeAll(async function (done) {
-        console.info(logTag + 'beforeAll')
-        testservice = new TestService();
-        await testservice.toConnectAbility().then(data=>{
-            gIRemoteObject = data;
-            console.log(logTag + "toConnectAbility data is" + data);
-            remoteHelpers = new RemoteHelper(testservice,gIRemoteObject);
-        })
-        done();
-    })
-
-    it('add_test_001', 0, async function (done) {
-        console.log(logTag + "test_add");
-        await remoteHelpers.add(2,3).then(result=>{
-        console.log(logTag + "test_add reult " + result);
-        expect(result).assertEqual(5);
-    })
-    done();
-    })
-}) 

distributeddatamgr/jstest/distributed_kv_store/client/hap/src/main/js/default/test/List.test.js

@@ -13,4 +13,4 @@
  * limitations under the License.
  */
 
-require('./ExampleJsunit.test.js')
+require('./KvStoreSecurityLevelJsunit.test.js') 

distributeddatamgr/jstest/distributed_kv_store/server/hap/Test.json

@@ -3,7 +3,7 @@
     "driver": {
         "type": "JSUnitTest",
         "test-timeout": "1200000",
-        "package": "ohos.dcts.distributedisjsserver",
+        "package": "com.ohos.distributekvdisjs",
         "shell-timeout": "60000"
     },
     "kits": [

distributeddatamgr/jstest/distributed_kv_store/server/hap/src/main/config.json

@@ -1,6 +1,6 @@
 {
   "app": {
-    "bundleName": "ohos.dcts.distributedisjsserver",
+    "bundleName": "com.ohos.distributekvdisjs",
     "vendor": "rpc",
     "version": {
       "code": 1000000,
@@ -27,7 +27,7 @@
         "name":"ohos.permission.KEEP_BACKGROUND_RUNNING"
       }
     ],
-    "package": "ohos.dcts.distributedisjsserver",
+    "package": "com.ohos.distributekvdisjs",
     "name": ".MyApplication",
     "mainAbility": ".MainAbility",
     "deviceType": [

testtools/disjsTest/client/remoteHelper.js

@@ -26,7 +26,45 @@ export default class RemoteHelper{
         this.testservice = testservice
 	this.gIRemoteObject = gIRemoteObject
     }
-    
+
+
+    async startBackgroundRunning(){
+        console.info(logTag + "_methodName is startBackgroundRunning");
+        let message = new ApiMessage("openHarmony","testApi","startBackgroundRunning"," ",[],[]," ");
+        var messageParcel = rpc.MessageParcel.create();
+        console.log(logTag + "create object successfully.");
+        var messageParcelreply = rpc.MessageParcel.create();
+        var option = new rpc.MessageOption();
+        var writeResult = messageParcel.writeSequenceable(message);
+        await this.gIRemoteObject.sendRequest(CODE_INVOKE, messageParcel, messageParcelreply, option);
+        console.log(logTag + "sendRequest got result");
+        var ret = new ApiMessage(null, null, null, null, null, null,null);
+        var dataReply = messageParcelreply.readSequenceable(ret);
+        console.log(logTag + "run readSequenceable success, result is" + dataReply);
+        results = JSON.parse(ret._apiResult);
+
+        console.log(logTag + " read success, results is" + results._result);
+        return results._result;
+    }
+
+    async stopBackgroundRunning(){
+        console.info(logTag + "_methodName is stopBackgroundRunning");
+        let message = new ApiMessage("openHarmony","testApi","stopBackgroundRunning"," ",[],[]," ");
+        var messageParcel = rpc.MessageParcel.create();
+        console.log(logTag + "create object successfully.");
+        var messageParcelreply = rpc.MessageParcel.create();
+        var option = new rpc.MessageOption();
+        var writeResult = messageParcel.writeSequenceable(message);
+        await this.gIRemoteObject.sendRequest(CODE_INVOKE, messageParcel, messageParcelreply, option);
+        console.log(logTag + "sendRequest got result");
+        var ret = new ApiMessage(null, null, null, null, null, null,null);
+        var dataReply = messageParcelreply.readSequenceable(ret);
+        console.log(logTag + "run readSequenceable success, result is" + dataReply);
+        results = JSON.parse(ret._apiResult);
+
+        console.log(logTag + " read success, results is" + results._result);
+        return results._result;
+    }
    async add(a,b) {
             console.log(logTag+"_methodName is add");
 	    let message = new ApiMessage("openHarmony","testApi","add"," ",
@@ -47,7 +85,7 @@ export default class RemoteHelper{
 	    console.log(logTag + " read success, results is" + results._result);
 	    return results._result;
     }
-	 
+
 
     async sub(a,b) {
         console.log(logTag+"_methodName is sub");
@@ -68,4 +106,173 @@ export default class RemoteHelper{
             console.log(logTag + " read success, results is" + results._result);
             return results._result;
     }
+    async createKvManager(){
+        console.info(logTag + "_methodName is createKvManager");
+        let message = new ApiMessage("openHarmony","testApi","createKvManager"," ",[],[]," ");
+        var messageParcel = rpc.MessageParcel.create();
+        console.log(logTag + "create object successfully.");
+        var messageParcelreply = rpc.MessageParcel.create();
+        var option = new rpc.MessageOption();
+        var writeResult = messageParcel.writeSequenceable(message);
+        await this.gIRemoteObject.sendRequest(CODE_INVOKE, messageParcel, messageParcelreply, option);
+        console.log(logTag + "sendRequest got result");
+        var ret = new ApiMessage(null, null, null, null, null, null,null);
+        var dataReply = messageParcelreply.readSequenceable(ret);
+        console.log(logTag + "run readSequenceable success, result is" + dataReply);
+        results = JSON.parse(ret._apiResult);
+
+        console.log(logTag + " read success, results is" + results._result);
+        return results._result;
+    }
+
+    async getKvStore(storeId,SecurityLevel,encrypt){
+        // if SecurityLevel in ["S0","S1","S2","S3","S4"],the kvstore corresponding to the security level will be created
+        // if SecurityLevel not in ["S0","S1","S2","S3","S4"],  the kvstore with security level is NO_LEVEL will be created
+        // if encrypt is true,it will create encrypt kvStore,otherwise it weill create unencrypt kvStore
+        console.info(logTag + "_methodName is getKvStore");
+        let message = new ApiMessage("openHarmony","testApi","getKvStore"," ",
+        ["string","string","string"],[String(storeId),String(SecurityLevel),String(encrypt)]," ");
+        var messageParcel = rpc.MessageParcel.create();
+        console.log(logTag + "create object successfully.");
+        var messageParcelreply = rpc.MessageParcel.create();
+        var option = new rpc.MessageOption();
+        var writeResult = messageParcel.writeSequenceable(message);
+        await this.gIRemoteObject.sendRequest(CODE_INVOKE, messageParcel, messageParcelreply, option);
+        console.log(logTag + "sendRequest got result");
+        var ret = new ApiMessage(null, null, null, null, null, null,null);
+        var dataReply = messageParcelreply.readSequenceable(ret);
+        console.log(logTag + "run readSequenceable success, result is" + dataReply);
+        results = JSON.parse(ret._apiResult);
+
+        console.log(logTag + " read success, results is" + results._result);
+        return results._result;
+    }
+    async closeKvStore(storeId){
+        console.info(logTag + "_methodName is closeKvStore");
+        let message = new ApiMessage("openHarmony","testApi","closeKvStore"," ",
+        ["string"],[String(storeId)]," ");
+        var messageParcel = rpc.MessageParcel.create();
+        console.log(logTag + "create object successfully.");
+        var messageParcelreply = rpc.MessageParcel.create();
+        var option = new rpc.MessageOption();
+        var writeResult = messageParcel.writeSequenceable(message);
+        await this.gIRemoteObject.sendRequest(CODE_INVOKE, messageParcel, messageParcelreply, option);
+        console.log(logTag + "sendRequest got result");
+        var ret = new ApiMessage(null, null, null, null, null, null,null);
+        var dataReply = messageParcelreply.readSequenceable(ret);
+        console.log(logTag + "run readSequenceable success, result is" + dataReply);
+        results = JSON.parse(ret._apiResult);
+
+        console.log(logTag + " read success, results is" + results._result);
+        return results._result;
+    }
+
+    async kvPut(key,value,valueType){
+        // valueType<string>: The type of value.
+        // Available values:["String","Number","Uint8Array","Boolean"]
+        // To avoid unknown errors, it is recommended to pass in only values of string type
+        // If insert data successful,it will return true, otherwise it will return errInfo
+        console.info(logTag + "_methodName is kvPut");
+        let message = new ApiMessage("openHarmony","testApi","kvPut"," ",
+		    ["string",valueType,"string"],[String(key),value.toString(),String(valueType)]," ");
+        console.info(logTag + " test key is: " + key + " value is " + value.toString())
+        var messageParcel = rpc.MessageParcel.create();
+        console.log(logTag + "create object successfully.");
+        var messageParcelreply = rpc.MessageParcel.create();
+        var option = new rpc.MessageOption();
+        var writeResult = messageParcel.writeSequenceable(message);
+        await this.gIRemoteObject.sendRequest(CODE_INVOKE, messageParcel, messageParcelreply, option);
+        console.log(logTag + "sendRequest got result");
+        var ret = new ApiMessage(null, null, null, null, null, null,null);
+        var dataReply = messageParcelreply.readSequenceable(ret);
+        console.log(logTag + "run readSequenceable success, result is" + dataReply);
+        results = JSON.parse(ret._apiResult);
+
+        console.log(logTag + " read success, results is" + results._result);
+        return results._result;
+    }
+
+    async kvGet(key){
+        console.info(logTag + "_methodName is kvGet");
+        let message = new ApiMessage("openHarmony","testApi","kvGet"," ",
+		    ["string"],[String(key)]," ");
+        var messageParcel = rpc.MessageParcel.create();
+        console.log(logTag + "create object successfully.");
+        var messageParcelreply = rpc.MessageParcel.create();
+        var option = new rpc.MessageOption();
+        var writeResult = messageParcel.writeSequenceable(message);
+        await this.gIRemoteObject.sendRequest(CODE_INVOKE, messageParcel, messageParcelreply, option);
+        console.log(logTag + "sendRequest got result");
+        var ret = new ApiMessage(null, null, null, null, null, null,null);
+        var dataReply = messageParcelreply.readSequenceable(ret);
+        console.log(logTag + "run readSequenceable success, result is" + dataReply);
+        results = JSON.parse(ret._apiResult);
+
+        console.log(logTag + " read success, results is" + results._result);
+        return results._result;
+    }
+
+    async kvDelete(key){
+        console.info(logTag + "_methodName is kvDelete");
+        let message = new ApiMessage("openHarmony","testApi","kvDelete"," ",
+		    ["string"],[String(key)]," ");
+        var messageParcel = rpc.MessageParcel.create();
+        console.log(logTag + "create object successfully.");
+        var messageParcelreply = rpc.MessageParcel.create();
+        var option = new rpc.MessageOption();
+        var writeResult = messageParcel.writeSequenceable(message);
+        await this.gIRemoteObject.sendRequest(CODE_INVOKE, messageParcel, messageParcelreply, option);
+        console.log(logTag + "sendRequest got result");
+        var ret = new ApiMessage(null, null, null, null, null, null,null);
+        var dataReply = messageParcelreply.readSequenceable(ret);
+        console.log(logTag + "run readSequenceable success, result is" + dataReply);
+        results = JSON.parse(ret._apiResult);
+
+        console.log(logTag + " read success, results is" + results._result);
+        return results._result;
+    }
+
+    async kvSync(deviceID,mode){
+        // deviceID<string>
+        // mode<string>,Available values:["PUSH","PUSH_PULL"]
+        console.info(logTag + "_methodName is kvDelete");
+        let message = new ApiMessage("openHarmony","testApi","kvSync"," ",
+		    ["string","string"],[String(deviceID),String(mode)]," ");
+        var messageParcel = rpc.MessageParcel.create();
+        console.log(logTag + "create object successfully.");
+        var messageParcelreply = rpc.MessageParcel.create();
+        var option = new rpc.MessageOption();
+        var writeResult = messageParcel.writeSequenceable(message);
+        await this.gIRemoteObject.sendRequest(CODE_INVOKE, messageParcel, messageParcelreply, option);
+        console.log(logTag + "sendRequest got result");
+        var ret = new ApiMessage(null, null, null, null, null, null,null);
+        var dataReply = messageParcelreply.readSequenceable(ret);
+        console.log(logTag + "run readSequenceable success, result is" + dataReply);
+        results = JSON.parse(ret._apiResult);
+
+        console.log(logTag + " read success, results is" + results._result);
+        return results._result;
+    }
+
+    async getRdbStore(rdbStoreName){
+        // rdbStoreName<string>: Name of relational store.Example: "UpdataTest.db"
+        console.info(logTag + "_methodName is getRdbStore");
+        let message = new ApiMessage("openHarmony","testApi","getRdbStore"," ",
+		    ["string"],[String(rdbStoreName)]," ");
+        var messageParcel = rpc.MessageParcel.create();
+        console.log(logTag + "create object successfully.");
+        var messageParcelreply = rpc.MessageParcel.create();
+        var option = new rpc.MessageOption();
+        var writeResult = messageParcel.writeSequenceable(message);
+        await this.gIRemoteObject.sendRequest(CODE_INVOKE, messageParcel, messageParcelreply, option);
+        console.log(logTag + "sendRequest got result");
+        var ret = new ApiMessage(null, null, null, null, null, null,null);
+        var dataReply = messageParcelreply.readSequenceable(ret);
+        console.log(logTag + "run readSequenceable success, result is" + dataReply);
+        results = JSON.parse(ret._apiResult);
+
+        console.log(logTag + " read success, results is" + results._result);
+        return results._result;
+    }
+
 }

testtools/disjsTest/client/testService.js

@@ -25,8 +25,8 @@ import featureAbility from '@ohos.ability.featureAbility';
 
 var results;
 var isConnected = false;
-var bundleName = "ohos.dcts.distributedisjsserver";
-var abilityName = "ohos.dcts.distributedisjsserver.ServiceAbility";
+var bundleName = "com.ohos.distributekvdisjs";
+var abilityName = "com.ohos.distributekvdisjs.ServiceAbility";
 var deviceList;
 
 export default class TestService {
@@ -76,10 +76,11 @@ export default class TestService {
         console.info(logTag + " toConnectAbility")
         return new Promise(resolve=>{
             let self = this;
-            deviceManager.createDeviceManager('ohos.dcts.distributedisjsserver', (error, deviceManager) => {
+            deviceManager.createDeviceManager('com.ohos.distributekvdisjs', (error, deviceManager) => {
                 self.getDeviceList(deviceManager);
                 console.info(logTag + "got deviceManager: " + deviceManager)
                 let deviceId = deviceList[0].deviceId
+                console.info(logTag + "deviceid : " + deviceId)
                 console.info(logTag + "online deviceList id: " + JSON.stringify(deviceList))
                 let want = {
                     "bundleName": bundleName,

testtools/disjsTest/server/service.js

@@ -41,7 +41,7 @@ export default class Stub extends rpc.RemoteObject {
                     console.log( logTag +" invoke result is " + JSON.stringify(testBundleResult));
 
                     testBundle._apiResult=JSON.stringify(testBundleResult);
-		    console.log(logTag +" The testBundle is " + JSON.stringify(testBundle));
+		            console.log(logTag +" The testBundle is " + JSON.stringify(testBundle));
                     let result = reply.writeSequenceable(testBundle);
                     console.log(logTag +" writeSequenceable result is " + result);
                     return true

testtools/disjsTest/server/testApi.js

@@ -12,8 +12,19 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
+import disData from '@ohos.data.distributedData';
+import backgroundTaskManager from '@ohos.backgroundTaskManager';
+import featureAbility from '@ohos.ability.featureAbility';
+import wantAgent from '@ohos.wantAgent';
+import dataRdb from '@ohos.data.rdb';
+import ApiResult from '../common/apiResult';
+const TEST_BUNDLE_NAME = 'com.ohos.distributekvdisjs'
 var logTag = "RpcServer";
+var kvManager = undefined;
+var kvStore = undefined;
+var rdbStore = undefined;
+
+
 export default class TestApi{
     constructor(){
 
@@ -26,4 +37,180 @@ export default class TestApi{
         console.log(logTag+"_methodName is sub");
          return Number(a)-Number(b);
     }
+
+    async startBackgroundRunning(){
+        console.info(logTag + " Server start background running started")
+        let wantAgentInfo = {
+            wants: [
+                {
+                    bundleName: TEST_BUNDLE_NAME,
+                    abilityName: "com.ohos.distributekvdisjs.ServiceAbility"
+                }
+            ],
+            operationType: wantAgent.OperationType.START_ABILITY,
+            requestCode: 0,
+            wantAgentFlags: [wantAgent.WantAgentFlags.UPDATE_PRESENT_FLAG]
+        };
+
+        await wantAgent.getWantAgent(wantAgentInfo).then(async (wantAgentObj) => {
+            console.info(logTag + " Server startBackgroundRunning get want agent success")
+            await backgroundTaskManager.startBackgroundRunning(featureAbility.getContext(),
+                backgroundTaskManager.BackgroundMode.DATA_TRANSFER, wantAgentObj).then(() => {
+                console.info("Operation startBackgroundRunning succeeded");
+            }).catch((err) => {
+                console.error("Operation startBackgroundRunning failed Cause: " + err);
+            });
+        }).catch((err) => {
+            console.info(logTag + " Server startBackgroundRunning get want agent err: " + err)
+        });
+    }
+
+    async stopBackgroundRunning(){
+        backgroundTaskManager.stopBackgroundRunning(featureAbility.getContext()).then(() => {
+            console.info("Operation stopBackgroundRunning succeeded");
+        }).catch((err) => {
+            console.error("Operation stopBackgroundRunning failed Cause: " + err);
+        });
+    }
+
+    async createKvManager(){
+        const config = {
+            bundleName: TEST_BUNDLE_NAME,
+            userInfo: {
+                userId: '0',
+                userType: disData.UserType.SAME_USER_ID
+            }
+        }
+        console.info(logTag + "_methodName is createKvManager")
+        await disData.createKVManager(config).then((manager) =>{
+            console.log("Created KVManager success");
+            kvManager = manager;
+            return
+        }).catch((err) => {
+            console.log("Failed to create KVManager: " + err );
+                return;
+        })
+    }
+    async getKvStore(storeId,SecurityLevel,encrypt){
+        var optionsInfo = {
+            createIfMissing : true,
+            encrypt : false,
+            backup : false,
+            autoSync : true,
+            kvStoreType : disData.KVStoreType.SINGLE_VERSION,
+            schema : '',
+            securityLevel : disData.SecurityLevel.NO_LEVEL,
+        }
+        if(encrypt == "true"){
+            optionsInfo.encrypt = true
+        }else{
+            optionsInfo.encrypt = false
+        }
+        if(SecurityLevel == "S0"){
+            optionsInfo.securityLevel=disData.SecurityLevel.S0
+        }else if(SecurityLevel == "S1"){
+            optionsInfo.securityLevel=disData.SecurityLevel.S1
+        }else if(SecurityLevel == "S2"){
+            optionsInfo.securityLevel=disData.SecurityLevel.S2
+        }else if(SecurityLevel == "S3"){
+            optionsInfo.securityLevel=disData.SecurityLevel.S3
+        }else if(SecurityLevel == "S4"){
+            optionsInfo.securityLevel=disData.SecurityLevel.S4
+        }else{
+            optionsInfo.securityLevel=disData.SecurityLevel.NO_LEVEL
+        }
+
+        await kvManager.getKVStore(storeId,optionsInfo).then((store) =>{
+            kvStore = store
+            console.info(logTag + " get kvStore success, security level is: " + optionsInfo.securityLevel)
+            return String(true)
+        }).catch((err) => {
+            return String(err)
+        })
+    }
+    async closeKvStore(storeId){
+        await kvManager.closeKVStore(TEST_BUNDLE_NAME,storeId,kvStore).then(async () => {
+            await kvManager.deleteKVStore(TEST_BUNDLE_NAME,storeId).then(() => {
+                console.info(logTag + " Server delete KVStore success")
+                return String(true)
+            })
+        }).catch((err) => {
+            return String(err)
+        })
+    }
+
+    async kvPut(key,value,valueType){
+        var putValue = undefined;
+        if(valueType == "String"){
+            putValue = value;
+        }else if(valueType = "Number"){
+            putValue = Number(value)
+        }else if(valueType = "Uint8Array"){
+            putValue = value.split(',')
+        }else if(valueType = "Boolean"){
+            if(value == "false"){
+                putValue = false;
+            }else{
+                putValue = Boolean(value);
+            }
+        }
+        await kvStore.put(key,putValue).then(() =>  {
+            console.info(logTag + " Server  put data success ,key is : " + key + " value is: " + putValue)
+            return String(true)
+        }).catch((err) => {
+            console.info(logTag + "Server put data fail,err: " + err)
+            return String(err)
+        })
+    }
+     async kvGet(key,callback){
+        console.info(logTag + " kvGet start")
+        let errInfo = undefined;
+        let result = undefined
+        kvStore.get(key, function (err, data){
+            errInfo = err;
+            result = data;
+        })
+        if(err != null){
+            console.info(logTag + " kvGet get data error: " + err)
+            callback(err)
+        }else{
+            console.info(logTag + " kvGet get data success")
+            callback(data)
+        }
+    }
+    async kvDelete(key){
+        await kvStore.delete(key).then(() => {
+            console.info(logTag + "Delete data success")
+            return String(true)
+        }).catch((err) => {
+            console.info(logTag + "Delete data error,errorInfo: " + err)
+            return String(err)
+
+        })
+    }
+
+    kvSync(deviceid,mode){
+        let syncMode = undefined;
+        if(mode == "PUSH"){
+            syncMode = disData.SyncMode.PUSH_ONLY
+        }else if(mode == "PUSH_PULL"){
+            syncMode = disData.SyncMode.PUSH_PULL
+        }
+        kvStore.Sync([deviceid],syncMode)
+        return JSON.stringify(syncMode)
+    }
+
+    async getRdbStore(rdbStoreName){
+        var storeConfig = {
+            name: rdbStoreName,
+        }
+        await dataRdb.getRdbStore(storeConfig,1).then((store) => {
+            console.info(logTag + " get rdbStore success")
+            rdbStore = store;
+            return String(true)
+        }).catch((err) => {
+            console.info(logTag + " get rdbStore error, err: " + err)
+            return String(err)
+        })
+    }
 }

testtools/disjsTest/server/testBundleManager.js

@@ -15,6 +15,13 @@
 import TestApi from './testApi.js'
 import ApiResult from '../common/apiResult.js'
 
+function sleep(ms) {
+    var start = (new Date()).getTime();
+    while ((new Date()).getTime() - start < ms) {
+      continue;
+    }
+  }
+
 var logTag = "RpcServer";
 export default class TestBundleManager{
     _classname;
@@ -36,7 +43,7 @@ export default class TestBundleManager{
         if(this._methodName == "add") {
             let test = new TestApi();
             let resultNum = test.add(this._parameters[0], this._parameters[1]);
-            console.log(logTag+"_methodName  invoke success,result is"+resultNum);
+            console.log(logTag+"_methodName  invoke success,result is "+resultNum);
             result._resultCode = true;
             result._result = resultNum;
             return result;
@@ -45,11 +52,119 @@ export default class TestBundleManager{
         {
             let test = new TestApi();
             let resultNum = test.sub(this._parameters[0], this._parameters[1]);
-            console.log(logTag+"_methodName  invoke success,result is"+resultNum);
+            console.log(logTag+"_methodName  invoke success,result is "+resultNum);
             result._resultCode = true;
             result._result = resultNum;
             return result;
         }
+        else if(this._methodName == "startBackgroundRunning"){
+            let test = new TestApi();
+            test.startBackgroundRunning()
+            console.info(logTag + "_methodName invoke success");
+            result._resultCode = true;
+            result._result = createResult
+            return true
+        }
+        else if(this._methodName == "stopBackgroundRunning"){
+            let test = new TestApi();
+            test.stopBackgroundRunning()
+            console.info(logTag + "_methodName invoke success");
+            result._resultCode = true;
+            result._result = createResult
+            return true
+        }
+        else if(this._methodName == "createKvManager"){
+            let test = new TestApi();
+            let createResult = undefined;
+            test.createKvManager()
+            console.info(logTag + "_methodName invoke success " + createResult);
+            result._resultCode = true;
+            result._result = createResult
+            return true
+        }
+        else if(this._methodName == "getKvStore"){
+            let test = new TestApi();
+            let getKvStoreResult = undefined;
+            test.getKvStore(this._parameters[0],this._parameters[1],this._methodName[2]);
+            console.info(logTag + "_methodName invoke success "  + getKvStoreResult);
+            result._resultCode = true;
+            result._result = getKvStoreResult;
+            console.info(logTag + " Result is: " + result._result);;
+            return true
+        }
+        else if(this._methodName == "closeKvStore"){
+            let test = new TestApi();
+            let colseKvStoreResult = undefined;
+            test.closeKvStore(this._parameters[0]);
+            console.info(logTag + "_methodName invoke success " + colseKvStoreResult);
+            result._resultCode = true;
+            result._result = colseKvStoreResult;
+            console.info(logTag + " Result is: " + result._result);
+            return true
+        }
+        else if(this._methodName == "deleteKvStore"){
+            let test = new TestApi();
+            let deleteKvStoreResult = undefined;
+            test.closeKvStore(this._parameters[0]);
+            console.info(logTag + "_methodName invoke success " + deleteKvStoreResult);
+            result._resultCode = true;
+            result._result = deleteKvStoreResult;
+            console.info(logTag + " Result is: " + result._result);
+            return true
+        }
+        else if(this._methodName == "kvPut"){
+            let test = new TestApi();
+            let putResult = undefined;
+            test.kvPut(this._parameters[0], this._parameters[1],this._parameters[2]);
+            console.info(logTag + "_methodName invoke success " + putResult);
+            result._resultCode = true;
+            result._result = putResult;
+            console.info(logTag + " Result is: " + result._result);
+            return true
+        }
+
+        else if(this._methodName == "kvGet"){
+            let test = new TestApi();
+            let getResult = undefined
+            test.kvGet(this._parameters[0])
+            console.info(logTag + " _methodName kvGet invoke success"  + getResult);
+            result._resultCode = true;
+            result._result = getResult
+            console.info(logTag + " Result is: " + result._result)
+            return result;
+        }
+
+        else if(this._methodName == "kvDelete"){
+            let test = new TestApi();
+            let deleteResult = undefined;
+            test.kvDelete(this._parameters[0]);
+            console.info(logTag + "_methodName invoke success " + deleteResult);
+            result._resultCode = true;
+            result._result = deleteResult;
+            console.info(logTag + " Result is: " + result._result);
+            return result;
+        }
+
+        else if(this._methodName == "kvSync"){
+            let test = new TestApi();
+            let syncResult = undefined;
+            syncResult= test.kvSync(this._parameters[0],this._parameters[1]);
+            console.info(logTag + "_methodName invoke success " + deleteResult);
+            result._resultCode = true;
+            result._result = syncResult;
+            console.info(logTag + " Result is: " + result._result);
+            return result;
+        }
+
+        else if(this._methodName == "getRdbStore"){
+            let test = new TestApi();
+            let getRdbStoreResult = test.kvGet(this._parameters[0]);
+            console.info(logTag + "_methodName invoke success " + getRdbStoreResult);
+            result._resultCode = true;
+            result._result = getRdbStoreResult;
+            console.info(logTag + " Result is: " + result._result);
+            return result;
+        }
         else
         {
             console.log(logTag+"_methodName not support");