mirror of
https://github.com/kremalicious/metamask-extension.git
synced 2024-12-23 09:52:26 +01:00
Merge branch 'UseStorageLocal' into i3076-UseStorageLocalInstead
This commit is contained in:
commit
7c4a9c32fa
@ -4,6 +4,7 @@ const pump = require('pump')
|
|||||||
const log = require('loglevel')
|
const log = require('loglevel')
|
||||||
const extension = require('extensionizer')
|
const extension = require('extensionizer')
|
||||||
const LocalStorageStore = require('obs-store/lib/localStorage')
|
const LocalStorageStore = require('obs-store/lib/localStorage')
|
||||||
|
const LocalStore = require('./lib/local-store')
|
||||||
const storeTransform = require('obs-store/lib/transform')
|
const storeTransform = require('obs-store/lib/transform')
|
||||||
const asStream = require('obs-store/lib/asStream')
|
const asStream = require('obs-store/lib/asStream')
|
||||||
const ExtensionPlatform = require('./platforms/extension')
|
const ExtensionPlatform = require('./platforms/extension')
|
||||||
@ -33,6 +34,7 @@ let popupIsOpen = false
|
|||||||
|
|
||||||
// state persistence
|
// state persistence
|
||||||
const diskStore = new LocalStorageStore({ storageKey: STORAGE_KEY })
|
const diskStore = new LocalStorageStore({ storageKey: STORAGE_KEY })
|
||||||
|
const localStore = new LocalStore()
|
||||||
|
|
||||||
// initialization flow
|
// initialization flow
|
||||||
initialize().catch(log.error)
|
initialize().catch(log.error)
|
||||||
@ -52,6 +54,14 @@ async function loadStateFromPersistence () {
|
|||||||
const migrator = new Migrator({ migrations })
|
const migrator = new Migrator({ migrations })
|
||||||
// read from disk
|
// read from disk
|
||||||
let versionedData = diskStore.getState() || migrator.generateInitialState(firstTimeState)
|
let versionedData = diskStore.getState() || migrator.generateInitialState(firstTimeState)
|
||||||
|
// fetch from extension store and merge in data
|
||||||
|
|
||||||
|
if (localStore.isSupported) {
|
||||||
|
const localData = await localStore.get()
|
||||||
|
// TODO: handle possible exceptions (https://developer.chrome.com/apps/runtime#property-lastError)
|
||||||
|
versionedData = Object.keys(localData).length > 0 ? localData : versionedData
|
||||||
|
}
|
||||||
|
|
||||||
// migrate data
|
// migrate data
|
||||||
versionedData = await migrator.migrateData(versionedData)
|
versionedData = await migrator.migrateData(versionedData)
|
||||||
// write to disk
|
// write to disk
|
||||||
@ -91,6 +101,7 @@ function setupController (initState) {
|
|||||||
pump(
|
pump(
|
||||||
asStream(controller.store),
|
asStream(controller.store),
|
||||||
storeTransform(versionifyData),
|
storeTransform(versionifyData),
|
||||||
|
storeTransform(syncDataWithExtension),
|
||||||
asStream(diskStore)
|
asStream(diskStore)
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -100,6 +111,13 @@ function setupController (initState) {
|
|||||||
return versionedData
|
return versionedData
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function syncDataWithExtension(state) {
|
||||||
|
if (localStore.isSupported) {
|
||||||
|
localStore.set(state) // TODO: handle possible exceptions (https://developer.chrome.com/apps/runtime#property-lastError)
|
||||||
|
}
|
||||||
|
return state
|
||||||
|
}
|
||||||
|
|
||||||
//
|
//
|
||||||
// connect to other contexts
|
// connect to other contexts
|
||||||
//
|
//
|
||||||
|
39
app/scripts/lib/extension-store.js
Normal file
39
app/scripts/lib/extension-store.js
Normal file
@ -0,0 +1,39 @@
|
|||||||
|
const extension = require('extensionizer')
|
||||||
|
|
||||||
|
const KEYS_TO_SYNC = ['KeyringController', 'PreferencesController']
|
||||||
|
const FIREFOX_SYNC_DISABLED_MESSAGE = 'Please set webextensions.storage.sync.enabled to true in about:config'
|
||||||
|
|
||||||
|
const handleDisabledSyncAndResolve = (resolve, toResolve) => {
|
||||||
|
// Firefox 52 has sync available on extension.storage, but it is disabled by default
|
||||||
|
const lastError = extension.runtime.lastError
|
||||||
|
if (lastError && lastError.message.includes(FIREFOX_SYNC_DISABLED_MESSAGE)) {
|
||||||
|
resolve({})
|
||||||
|
} else {
|
||||||
|
resolve(toResolve)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = class ExtensionStore {
|
||||||
|
constructor() {
|
||||||
|
this.isSupported = !!(extension.storage.sync)
|
||||||
|
this.isEnabled = true // TODO: get value from user settings
|
||||||
|
}
|
||||||
|
async fetch() {
|
||||||
|
return new Promise((resolve) => {
|
||||||
|
extension.storage.sync.get(KEYS_TO_SYNC, (data) => {
|
||||||
|
handleDisabledSyncAndResolve(resolve, data)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
}
|
||||||
|
async sync(state) {
|
||||||
|
const dataToSync = KEYS_TO_SYNC.reduce((result, key) => {
|
||||||
|
result[key] = state.data[key]
|
||||||
|
return result
|
||||||
|
}, {})
|
||||||
|
return new Promise((resolve) => {
|
||||||
|
extension.storage.sync.set(dataToSync, () => {
|
||||||
|
handleDisabledSyncAndResolve(resolve)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
25
app/scripts/lib/local-store.js
Normal file
25
app/scripts/lib/local-store.js
Normal file
@ -0,0 +1,25 @@
|
|||||||
|
// We should not rely on local storage in an extension!
|
||||||
|
// We should use this instead!
|
||||||
|
// https://developer.mozilla.org/en-US/Add-ons/WebExtensions/API/storage/local
|
||||||
|
|
||||||
|
const extension = require('extensionizer')
|
||||||
|
const STORAGE_KEY = 'metamask-config'
|
||||||
|
|
||||||
|
module.exports = class ExtensionStore {
|
||||||
|
constructor() {
|
||||||
|
this.isSupported = !!(extension.storage.local)
|
||||||
|
if (!this.isSupported) {
|
||||||
|
log.error('Storage local API not available.')
|
||||||
|
}
|
||||||
|
}
|
||||||
|
async get() {
|
||||||
|
return new Promise((resolve) => {
|
||||||
|
extension.storage.local.get(STORAGE_KEY, resolve)
|
||||||
|
})
|
||||||
|
}
|
||||||
|
async set(state) {
|
||||||
|
return new Promise((resolve) => {
|
||||||
|
extension.storage.local.set(state, resolve)
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
29
test/unit/extension-store-test.js
Normal file
29
test/unit/extension-store-test.js
Normal file
@ -0,0 +1,29 @@
|
|||||||
|
const assert = require('assert')
|
||||||
|
|
||||||
|
const ExtensionStore = require('../../app/scripts/lib/extension-store')
|
||||||
|
|
||||||
|
describe('Extension Store', function () {
|
||||||
|
let extensionStore
|
||||||
|
|
||||||
|
beforeEach(function () {
|
||||||
|
extensionStore = new ExtensionStore()
|
||||||
|
})
|
||||||
|
|
||||||
|
describe('#fetch', function () {
|
||||||
|
it('should return a promise', function () {
|
||||||
|
|
||||||
|
})
|
||||||
|
it('after promise resolution, should have loaded the proper data from the extension', function () {
|
||||||
|
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
describe('#sync', function () {
|
||||||
|
it('should return a promise', function () {
|
||||||
|
|
||||||
|
})
|
||||||
|
it('after promise resolution, should have synced the proper data from the extension', function () {
|
||||||
|
|
||||||
|
})
|
||||||
|
})
|
||||||
|
})
|
Loading…
x
Reference in New Issue
Block a user