Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Test for webworker concurrency & error on Ready() using multiple storeName [indexedDb] #1009

Open
wants to merge 5 commits into
base: master
Choose a base branch
from
Open

Test for webworker concurrency & error on Ready() using multiple storeName [indexedDb] #1009

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
7a677b6
test concurrency for client
disarticulate Dec 31, 2020
5e03e83
fix test for concurrency
disarticulate Dec 31, 2020
ecf36a8
test multiple stores
disarticulate Dec 31, 2020
7487ec6
errors at multiple storeNames in concurrent webworkers
disarticulate Dec 31, 2020
b3c65b4
clean up
disarticulate Dec 31, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
98 changes: 98 additions & 0 deletions test/test.webworkers.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -63,5 +63,103 @@ DRIVERS.forEach(function(driverName) {
value: 'I have been set'
});
});
it('saves multiple data concurrently in workers', function() {
var webWorker1 = new Worker('/test/webworker-client.js');
var webWorker2 = new Worker('/test/webworker-client.js');
var webWorker3 = new Worker('/test/webworker-client.js');
var workers = [webWorker1, webWorker2, webWorker3];
return Promise.all(
workers.map(function(webWorker, index) {
var message = 'I have been set: ' + index;
var promise = new Promise(function(resolve, reject) {
webWorker.addEventListener('message', function(e) {
var body = e.data.body;

window.console.log(body);
expect(body).to.be(message);
resolve();
});

webWorker.addEventListener('error', function(e) {
window.console.log(e);
reject();
});

webWorker.postMessage({
driver: driverName,
value: message
});
});
return promise;
})
);
});
it('saves multiple data & databases concurrently in workers', function() {
var webWorker1 = new Worker('/test/webworker-client.js');
var webWorker2 = new Worker('/test/webworker-client.js');
var webWorker3 = new Worker('/test/webworker-client.js');
var workers = [webWorker1, webWorker2, webWorker3];
return Promise.all(
workers.map(function(webWorker, index) {
var store = 'test-' + index;
var message = 'I have been set: ' + index;
var promise = new Promise(function(resolve, reject) {
webWorker.addEventListener('message', function(e) {
var body = e.data.body;

window.console.log(body);
expect(body).to.be(message);
resolve();
});

webWorker.addEventListener('error', function(e) {
window.console.log(e);
reject();
});

webWorker.postMessage({
store,
driver: driverName,
value: message
});
});
return promise;
})
);
});

it('saves multiple data, single database, multiple stores, concurrently in workers', function() {
var webWorker1 = new Worker('/test/webworker-client.js');
var webWorker2 = new Worker('/test/webworker-client.js');
var webWorker3 = new Worker('/test/webworker-client.js');
var workers = [webWorker1, webWorker2, webWorker3];
return Promise.all(
workers.map(function(webWorker, index) {
var storeName = 'test-' + index;
var message = 'I have been set: ' + index;
var promise = new Promise(function(resolve, reject) {
webWorker.addEventListener('message', function(e) {
var body = e.data.body;

window.console.log(body);
expect(body).to.be(message);
resolve();
});

webWorker.addEventListener('error', function(e) {
window.console.log(e);
reject();
});

webWorker.postMessage({
storeName: storeName,
driver: driverName,
value: message
});
});
return promise;
})
);
});
});
});
43 changes: 19 additions & 24 deletions test/webworker-client.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,30 +11,25 @@ self.addEventListener(
fail: true
});
}

localforage.setDriver(
e.data.driver,
function() {
localforage
.setItem(
'web worker',
e.data.value,
function() {
localforage.getItem('web worker', function(
err,
value
) {
self.postMessage({
body: value
});
});
},
handleError
)
.catch(handleError);
},
handleError
);
localforage.config({
name: e.data.name || 'test',
storeName: e.data.storeName || 'test',
driver: e.data.driver
});
localforage
.setItem(
'web worker',
e.data.value,
function() {
localforage.getItem('web worker', function(err, value) {
self.postMessage({
body: value
});
});
},
handleError
)
.catch(handleError);
},
false
);