提交 fa5dc10a 编写于 作者: L liangzhenyu123

适配接口变更

Signed-off-by: Nliangzhenyu123 <liangzhenyu6@huawei.com>
上级 caaf5743
...@@ -76,12 +76,7 @@ describe('deviceKvStoreCallbackTest', function () { ...@@ -76,12 +76,7 @@ describe('deviceKvStoreCallbackTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll config:'+ JSON.stringify(config)); console.info('beforeAll config:'+ JSON.stringify(config));
await factory.createKVManager(config).then((manager) => { kvManager = factory.createKVManager(config)
kvManager = manager;
console.info('beforeAll createKVManager success');
}).catch((err) => {
console.error('beforeAll createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`);
});
await kvManager.getKVStore(TEST_STORE_ID, options).then((store) => { await kvManager.getKVStore(TEST_STORE_ID, options).then((store) => {
kvStore = store; kvStore = store;
console.info('beforeAll getKVStore for getDeviceId success'); console.info('beforeAll getKVStore for getDeviceId success');
......
...@@ -76,12 +76,7 @@ describe('deviceKvStorePromiseTest', function () { ...@@ -76,12 +76,7 @@ describe('deviceKvStorePromiseTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll config:'+ JSON.stringify(config)); console.info('beforeAll config:'+ JSON.stringify(config));
await factory.createKVManager(config).then((manager) => { kvManager = factory.createKVManager(config);
kvManager = manager;
console.info('beforeAll createKVManager success');
}).catch((err) => {
console.error('beforeAll createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`);
});
await kvManager.getKVStore(TEST_STORE_ID, options).then((store) => { await kvManager.getKVStore(TEST_STORE_ID, options).then((store) => {
kvStore = store; kvStore = store;
console.info('beforeAll getKVStore for getDeviceId success'); console.info('beforeAll getKVStore for getDeviceId success');
......
...@@ -42,11 +42,9 @@ describe('kvManagerCallbackTest', function () { ...@@ -42,11 +42,9 @@ describe('kvManagerCallbackTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll'); console.info('beforeAll');
await factory.createKVManager(config, function (err, manager) { kvManager = factory.createKVManager(config);
kvManager = manager;
done();
});
console.info('beforeAll end'); console.info('beforeAll end');
done();
}) })
afterAll(async function (done) { afterAll(async function (done) {
......
...@@ -45,17 +45,12 @@ describe('KVManagerPromiseTest', function () { ...@@ -45,17 +45,12 @@ describe('KVManagerPromiseTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll'); console.info('beforeAll');
await factory.createKVManager(config).then((manager) => { kvManager = factory.createKVManager(config)
kvManager = manager; kvManager.getKVStore(TEST_STORE_ID, options).then((store) => {
console.info('beforeAll createKVManager success'); console.info("beforeAll getKVStore success");
kvManager.getKVStore(TEST_STORE_ID, options).then((store) => { kvStoreNew = store;
console.info("beforeAll getKVStore success");
kvStoreNew = store;
}).catch((err) => {
console.info("beforeAll getKVStore err: " + JSON.stringify(err));
});
}).catch((err) => { }).catch((err) => {
console.error('beforeAll createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`); console.info("beforeAll getKVStore err: " + JSON.stringify(err));
}); });
console.info('beforeAll end'); console.info('beforeAll end');
done(); done();
...@@ -394,36 +389,30 @@ describe('KVManagerPromiseTest', function () { ...@@ -394,36 +389,30 @@ describe('KVManagerPromiseTest', function () {
context:context context:context
} }
try { try {
await factory.createKVManager(config).then(async (manager) => { kvManager = factory.createKVManager(config)
kvManager = manager; kvManager.getKVStore(TEST_STORE_ID, options).then(async (store) => {
expect(manager !=null).assertTrue(); console.info("testcreateKVManager001 getKVStore success");
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 createKVManager success'); store.put(STORE_KEY, STORE_VALUE).then(async (data) => {
await kvManager.getKVStore(TEST_STORE_ID, options).then(async (store) => { console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 put data success');
console.info("testcreateKVManager001 getKVStore success"); store.get(STORE_KEY).then((data) => {
await store.put(STORE_KEY, STORE_VALUE).then(async (data) => { console.info("testcreateKVManager001 get data success");
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 put data success'); expect(data).assertEqual(STORE_VALUE);
await store.get(STORE_KEY).then((data) => { done();
console.info("testcreateKVManager001 get data success");
expect(data).assertEqual(STORE_VALUE);
}).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 get data err' + `, error code is ${err.code}, message is ${err.message}`);
});
}).catch((err) => { }).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 put data err' + `, error code is ${err.code}, message is ${err.message}`); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 get data err' + `, error code is ${err.code}, message is ${err.message}`);
}); });
}).catch((err) => { }).catch((err) => {
console.info("testcreateKVManager001 getKVStore err: " + JSON.stringify(err)); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 put data err' + `, error code is ${err.code}, message is ${err.message}`);
expect(null).assertFail();
}); });
}).catch((err) => { }).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`); console.info("testcreateKVManager001 getKVStore err: " + JSON.stringify(err));
expect(null).assertFail() expect(null).assertFail();
}); });
}catch (e) { }catch (e) {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 promise delete fail err' + `, error code is ${err.code}, message is ${err.message}`); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 promise delete fail err' + `, error code is ${e.code}, message is ${e.message}`);
expect(null).assertFail(); expect(null).assertFail();
} }
done();
}) })
/** /**
...@@ -439,35 +428,31 @@ describe('KVManagerPromiseTest', function () { ...@@ -439,35 +428,31 @@ describe('KVManagerPromiseTest', function () {
context:contextApplication context:contextApplication
} }
try { try {
await factory.createKVManager(config).then(async (manager) => { kvManager = factory.createKVManager(config)
kvManager = manager; kvManager.getKVStore(TEST_STORE_ID, options).then(async (store) => {
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 createKVManager success'); console.info("testcreateKVManager002 getKVStore success");
await kvManager.getKVStore(TEST_STORE_ID, options).then(async (store) => { store.put(STORE_KEY, STORE_VALUE).then(async (data) => {
console.info("testcreateKVManager002 getKVStore success"); console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 put data success');
await store.put(STORE_KEY, STORE_VALUE).then(async (data) => { store.get(STORE_KEY).then((data) => {
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 put data success'); console.info("testcreateKVManager002 get data success");
await store.get(STORE_KEY).then((data) => { expect(data).assertEqual(STORE_VALUE);
console.info("testcreateKVManager002 get data success"); done();
expect(data).assertEqual(STORE_VALUE);
}).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 get data err' + `, error code is ${err.code}, message is ${err.message}`);
});
}).catch((err) => { }).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 put data err' + `, error code is ${err.code}, message is ${err.message}`); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 get data err' + `, error code is ${err.code}, message is ${err.message}`);
}); });
}).catch((err) => { }).catch((err) => {
console.info("testcreateKVManager002 getKVStore err: " + JSON.stringify(err)); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 put data err' + `, error code is ${err.code}, message is ${err.message}`);
expect(null).assertFail();
}); });
}).catch((err) => { }).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`); console.info("testcreateKVManager002 getKVStore err: " + JSON.stringify(err));
expect(null).assertFail() expect(null).assertFail();
}); });
}catch (e) { }catch (e) {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 promise delete fail err' + `, error code is ${err.code}, message is ${err.message}`); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 promise delete fail err' + `, error code is ${err.code}, message is ${err.message}`);
expect(null).assertFail(); expect(null).assertFail();
} }
done();
}) })
}) })
} }
\ No newline at end of file
...@@ -35,25 +35,16 @@ function sleep(ms) { ...@@ -35,25 +35,16 @@ function sleep(ms) {
function publicgetKvStore(optionsp){ function publicgetKvStore(optionsp){
console.log(`Test getKvStore `) console.log(`Test getKvStore `)
return new Promise(function(resolve, reject) { return new Promise(function(resolve, reject) {
distributedData.createKVManager(mKVMgrConfig, (err, data) => { kvManager = distributedData.createKVManager(mKVMgrConfig);
console.info('Test createKVManager begin') kvManager.getKVStore(STORE_ID, optionsp, (err, data) => {
console.info('Test getKVStore begin')
if (err) { if (err) {
console.info('Test createKVManager err = ' + err ); console.info('Test getKVStore err = ' + err);
reject(err); reject(err);
} }
console.info('Test createKVManager data = ' + data); console.info('Test getKVStore data = ' + data);
kvStore = data;
kvManager = data; resolve(data);
data.getKVStore(STORE_ID, optionsp, (err, data) => {
console.info('Test getKVStore begin')
if (err) {
console.info('Test getKVStore err = ' + err);
reject(err);
}
console.info('Test getKVStore data = ' + data);
kvStore = data;
resolve(data);
});
}); });
}) })
} }
......
...@@ -32,25 +32,16 @@ let mKVMgrConfig = { ...@@ -32,25 +32,16 @@ let mKVMgrConfig = {
function publicgetKvStore(optionsp){ function publicgetKvStore(optionsp){
console.log(`Test getKvStore `) console.log(`Test getKvStore `)
return new Promise(function(resolve, reject) { return new Promise(function(resolve, reject) {
distributedData.createKVManager(mKVMgrConfig, (err, data) => { kvManager = distributedData.createKVManager(mKVMgrConfig);
console.info('Test createKVManager begin') kvManager.getKVStore(STORE_ID, optionsp, (err, data) => {
console.info('Test getKVStore begin')
if (err) { if (err) {
console.info('Test createKVManager err = ' + err ); console.info('Test getKVStore err = ' + err);
reject(err); reject(err);
} }
console.info('Test createKVManager data = ' + data); console.info('Test getKVStore data = ' + data);
kvStore = data;
kvManager = data; resolve(data);
data.getKVStore(STORE_ID, optionsp, (err, data) => {
console.info('Test getKVStore begin')
if (err) {
console.info('Test getKVStore err = ' + err);
reject(err);
}
console.info('Test getKVStore data = ' + data);
kvStore = data;
resolve(data);
});
}); });
}) })
} }
......
...@@ -42,12 +42,7 @@ export default function KvStoreResultSetTest(){ ...@@ -42,12 +42,7 @@ export default function KvStoreResultSetTest(){
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll'); console.info('beforeAll');
console.info('beforeAll config:' + JSON.stringify(config)); console.info('beforeAll config:' + JSON.stringify(config));
await factory.createKVManager(config).then((manager) => { kvManager = factory.createKVManager(config);
kvManager = manager;
console.info('beforeAll createKVManager success');
}).catch((err) => {
console.error('beforeAll createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`);
});
await kvManager.getAllKVStoreId(TEST_BUNDLE_NAME).then(async (data) => { await kvManager.getAllKVStoreId(TEST_BUNDLE_NAME).then(async (data) => {
console.info('beforeAll getAllKVStoreId size = ' + data.length); console.info('beforeAll getAllKVStoreId size = ' + data.length);
for (var i = 0; i < data.length; i++) { for (var i = 0; i < data.length; i++) {
......
...@@ -104,18 +104,14 @@ describe('schemaTest', function() { ...@@ -104,18 +104,14 @@ describe('schemaTest', function() {
beforeAll(async function (done) { beforeAll(async function (done) {
try { try {
console.info("beforeAll: createKVManager (single) with " + JSON.stringify(options)); console.info("beforeAll: createKVManager (single) with " + JSON.stringify(config));
await ddm.createKVManager(config).then((manager) => { kvManager = ddm.createKVManager(config)
kvManager = manager; done();
console.info('beforeAll createKVManager success');
}).catch((err) => {
console.info('beforeAll createKVManager err ' + err);
});
} catch (e) { } catch (e) {
console.info("fail on exception: " + e); console.info("fail on exception: " + e);
expect(null).assertFail(); expect(null).assertFail();
} }
done();
}) })
afterAll(async function (done) { afterAll(async function (done) {
......
...@@ -75,11 +75,8 @@ describe('SingleKvStoreCallbackTest', function () { ...@@ -75,11 +75,8 @@ describe('SingleKvStoreCallbackTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll config:'+ JSON.stringify(config)); console.info('beforeAll config:'+ JSON.stringify(config));
await factory.createKVManager(config, function (err, manager) { kvManager = factory.createKVManager(config)
kvManager = manager; done();
console.info('beforeAll createKVManager success');
done();
})
}) })
afterAll(async function (done) { afterAll(async function (done) {
...@@ -2337,6 +2334,7 @@ describe('SingleKvStoreCallbackTest', function () { ...@@ -2337,6 +2334,7 @@ describe('SingleKvStoreCallbackTest', function () {
*/ */
it('SUB_DDM_DKV_SINGLEKVSTORE_CLOSERESULT_CALLBACK_8200', 0, async function (done) { it('SUB_DDM_DKV_SINGLEKVSTORE_CLOSERESULT_CALLBACK_8200', 0, async function (done) {
console.info('SingleKvStoreCloseResultSetCallbackTest004'); console.info('SingleKvStoreCloseResultSetCallbackTest004');
try{ try{
kvStore.closeResultSet("",(err, data) => { kvStore.closeResultSet("",(err, data) => {
console.info('SingleKvStoreCloseResultSetCallbackTest004 close result finish') console.info('SingleKvStoreCloseResultSetCallbackTest004 close result finish')
......
...@@ -75,12 +75,7 @@ describe('SingleKvStorePromiseTest', function () { ...@@ -75,12 +75,7 @@ describe('SingleKvStorePromiseTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll config:'+ JSON.stringify(config)); console.info('beforeAll config:'+ JSON.stringify(config));
await factory.createKVManager(config).then((manager) => { kvManager = factory.createKVManager(config)
kvManager = manager;
console.info('beforeAll createKVManager success');
}).catch((err) => {
console.error('beforeAll createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`);
});
console.info('beforeAll end'); console.info('beforeAll end');
done(); done();
}) })
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册