data.coop/pinafore
8
0
Fork 0
Code Issues 1 Pull requests Packages Projects Releases Wiki Activity

use workerize

Browse source
This commit is contained in:
Nolan Lawson 2018-01-19 01:32:23 -08:00
parent 3da20697ca
commit 7799dafef8
5 changed files with 20 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
package-lock.json generated
View file

@ -7826,6 +7826,14 @@
"xtend": "4.0.1" "xtend": "4.0.1"
} }
}, },
"workerize-loader": {
"version": "1.0.1",
"resolved": "https://registry.npmjs.org/workerize-loader/-/workerize-loader-1.0.1.tgz",
"integrity": "sha512-OwkHyCnSrxnVXDJhyYlM2wcYW9RfE/DH76EmWLYJDcfWyiw53tyrs+WAUEBzRmiaf6f2W1ZNQ/Lky+PRcqDwew==",
"requires": {
"loader-utils": "1.1.0"
}
},
"wrap-ansi": { "wrap-ansi": {
"version": "2.1.0", "version": "2.1.0",
"resolved": "https://registry.npmjs.org/wrap-ansi/-/wrap-ansi-2.1.0.tgz", "resolved": "https://registry.npmjs.org/wrap-ansi/-/wrap-ansi-2.1.0.tgz",

1
package.json
View file

@ -47,6 +47,7 @@
"url-search-params": "^0.10.0", "url-search-params": "^0.10.0",
"webpack": "^3.10.0", "webpack": "^3.10.0",
"webpack-bundle-analyzer": "^2.9.2", "webpack-bundle-analyzer": "^2.9.2",
"workerize-loader": "^1.0.1",
"yargs": "^10.1.1" "yargs": "^10.1.1"
}, },
"engines": { "engines": {

15
routes/_components/Timeline.html
View file

@ -15,14 +15,13 @@
import StatusListItem from './StatusListItem.html' import StatusListItem from './StatusListItem.html'
import VirtualList from './VirtualList.html' import VirtualList from './VirtualList.html'
import { splice, push } from 'svelte-extras' import { splice, push } from 'svelte-extras'
import { import worker from 'workerize-loader!../_utils/database/statuses'
insertStatuses as insertStatusesIntoDatabase,
getTimeline as getTimelineFromDatabase
} from '../_utils/database/statuses'
import { mergeStatuses } from '../_utils/statuses' import { mergeStatuses } from '../_utils/statuses'
import { mark, stop } from '../_utils/marks' import { mark, stop } from '../_utils/marks'
import { timelines } from '../_static/timelines' import { timelines } from '../_static/timelines'
const database = worker()
const FETCH_LIMIT = 20 const FETCH_LIMIT = 20
export default { export default {
@ -33,9 +32,9 @@
let timeline = this.get('timeline') let timeline = this.get('timeline')
let statuses = online ? let statuses = online ?
await getTimeline(instanceName, instanceData.access_token, timeline, null, FETCH_LIMIT) : await getTimeline(instanceName, instanceData.access_token, timeline, null, FETCH_LIMIT) :
await getTimelineFromDatabase(instanceName, timeline, null, FETCH_LIMIT) await database.getTimeline(instanceName, timeline, null, FETCH_LIMIT)
if (online) { if (online) {
insertStatusesIntoDatabase(instanceName, timeline, statuses) database.insertStatuses(instanceName, timeline, statuses)
} }
this.addStatuses(statuses) this.addStatuses(statuses)
this.set({initialized: true}) this.set({initialized: true})
@ -78,9 +77,9 @@
let timeline = this.get('timeline') let timeline = this.get('timeline')
let newStatuses = online ? let newStatuses = online ?
await getTimeline(instanceName, instanceData.access_token, timeline, lastStatusId, FETCH_LIMIT) : await getTimeline(instanceName, instanceData.access_token, timeline, lastStatusId, FETCH_LIMIT) :
await getTimelineFromDatabase(instanceName, timeline, lastStatusId, FETCH_LIMIT) await database.getTimeline(instanceName, timeline, lastStatusId, FETCH_LIMIT)
if (online) { if (online) {
insertStatusesIntoDatabase(instanceName, timeline, newStatuses) database.insertStatuses(instanceName, timeline, newStatuses)
} }
let statuses = this.get('statuses') let statuses = this.get('statuses')
if (statuses) { if (statuses) {

2
routes/_utils/database/keyval.js
View file

@ -1,2 +0,0 @@
import keyval from 'idb-keyval'
export { keyval }

8
routes/_utils/database/statuses.js
View file

@ -1,4 +1,4 @@
import { keyval } from './keyval' import keyval from 'idb-keyval'
import cloneDeep from 'lodash/cloneDeep' import cloneDeep from 'lodash/cloneDeep'
import padStart from 'lodash/padStart' import padStart from 'lodash/padStart'
@ -73,7 +73,7 @@ export async function getTimeline(instanceName, timeline, max_id = null, limit =
} }
tx.oncomplete = () => resolve(res) tx.oncomplete = () => resolve(res)
tx.onerror = reject tx.onerror = () => reject(tx.error.name + ' ' + tx.error.message)
}) })
} }
@ -85,7 +85,7 @@ export async function insertStatuses(instanceName, timeline, statuses) {
for (let status of statuses) { for (let status of statuses) {
store.put(transformStatusForStorage(status)) store.put(transformStatusForStorage(status))
} }
tx.oncomplete = resolve tx.oncomplete = () => resolve()
tx.onerror = reject tx.onerror = () => reject(tx.error.name + ' ' + tx.error.message)
}) })
} }