575 lines
19 KiB
JavaScript
575 lines
19 KiB
JavaScript
"use strict";
|
|
|
|
var _interopRequireWildcard = require("@babel/runtime/helpers/interopRequireWildcard");
|
|
|
|
Object.defineProperty(exports, "__esModule", {
|
|
value: true
|
|
});
|
|
exports.LocalIndexedDBStoreBackend = LocalIndexedDBStoreBackend;
|
|
|
|
var _syncAccumulator = require("../sync-accumulator");
|
|
|
|
var utils = _interopRequireWildcard(require("../utils"));
|
|
|
|
var IndexedDBHelpers = _interopRequireWildcard(require("../indexeddb-helpers"));
|
|
|
|
var _logger = require("../logger");
|
|
|
|
/*
|
|
Copyright 2017 Vector Creations Ltd
|
|
Copyright 2018 New Vector Ltd
|
|
Copyright 2019 The Matrix.org Foundation C.I.C.
|
|
|
|
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.
|
|
*/
|
|
const VERSION = 3;
|
|
|
|
function createDatabase(db) {
|
|
// Make user store, clobber based on user ID. (userId property of User objects)
|
|
db.createObjectStore("users", {
|
|
keyPath: ["userId"]
|
|
}); // Make account data store, clobber based on event type.
|
|
// (event.type property of MatrixEvent objects)
|
|
|
|
db.createObjectStore("accountData", {
|
|
keyPath: ["type"]
|
|
}); // Make /sync store (sync tokens, room data, etc), always clobber (const key).
|
|
|
|
db.createObjectStore("sync", {
|
|
keyPath: ["clobber"]
|
|
});
|
|
}
|
|
|
|
function upgradeSchemaV2(db) {
|
|
const oobMembersStore = db.createObjectStore("oob_membership_events", {
|
|
keyPath: ["room_id", "state_key"]
|
|
});
|
|
oobMembersStore.createIndex("room", "room_id");
|
|
}
|
|
|
|
function upgradeSchemaV3(db) {
|
|
db.createObjectStore("client_options", {
|
|
keyPath: ["clobber"]
|
|
});
|
|
}
|
|
/**
|
|
* Helper method to collect results from a Cursor and promiseify it.
|
|
* @param {ObjectStore|Index} store The store to perform openCursor on.
|
|
* @param {IDBKeyRange=} keyRange Optional key range to apply on the cursor.
|
|
* @param {Function} resultMapper A function which is repeatedly called with a
|
|
* Cursor.
|
|
* Return the data you want to keep.
|
|
* @return {Promise<T[]>} Resolves to an array of whatever you returned from
|
|
* resultMapper.
|
|
*/
|
|
|
|
|
|
function selectQuery(store, keyRange, resultMapper) {
|
|
const query = store.openCursor(keyRange);
|
|
return new Promise((resolve, reject) => {
|
|
const results = [];
|
|
|
|
query.onerror = event => {
|
|
reject(new Error("Query failed: " + event.target.errorCode));
|
|
}; // collect results
|
|
|
|
|
|
query.onsuccess = event => {
|
|
const cursor = event.target.result;
|
|
|
|
if (!cursor) {
|
|
resolve(results);
|
|
return; // end of results
|
|
}
|
|
|
|
results.push(resultMapper(cursor));
|
|
cursor.continue();
|
|
};
|
|
});
|
|
}
|
|
|
|
function txnAsPromise(txn) {
|
|
return new Promise((resolve, reject) => {
|
|
txn.oncomplete = function (event) {
|
|
resolve(event);
|
|
};
|
|
|
|
txn.onerror = function (event) {
|
|
reject(event.target.error);
|
|
};
|
|
});
|
|
}
|
|
|
|
function reqAsEventPromise(req) {
|
|
return new Promise((resolve, reject) => {
|
|
req.onsuccess = function (event) {
|
|
resolve(event);
|
|
};
|
|
|
|
req.onerror = function (event) {
|
|
reject(event.target.error);
|
|
};
|
|
});
|
|
}
|
|
|
|
function reqAsPromise(req) {
|
|
return new Promise((resolve, reject) => {
|
|
req.onsuccess = () => resolve(req);
|
|
|
|
req.onerror = err => reject(err);
|
|
});
|
|
}
|
|
|
|
function reqAsCursorPromise(req) {
|
|
return reqAsEventPromise(req).then(event => event.target.result);
|
|
}
|
|
/**
|
|
* Does the actual reading from and writing to the indexeddb
|
|
*
|
|
* Construct a new Indexed Database store backend. This requires a call to
|
|
* <code>connect()</code> before this store can be used.
|
|
* @constructor
|
|
* @param {Object} indexedDBInterface The Indexed DB interface e.g
|
|
* <code>window.indexedDB</code>
|
|
* @param {string=} dbName Optional database name. The same name must be used
|
|
* to open the same database.
|
|
*/
|
|
|
|
|
|
function LocalIndexedDBStoreBackend(indexedDBInterface, dbName) {
|
|
this.indexedDB = indexedDBInterface;
|
|
this._dbName = "matrix-js-sdk:" + (dbName || "default");
|
|
this.db = null;
|
|
this._disconnected = true;
|
|
this._syncAccumulator = new _syncAccumulator.SyncAccumulator();
|
|
this._isNewlyCreated = false;
|
|
}
|
|
|
|
LocalIndexedDBStoreBackend.exists = function (indexedDB, dbName) {
|
|
dbName = "matrix-js-sdk:" + (dbName || "default");
|
|
return IndexedDBHelpers.exists(indexedDB, dbName);
|
|
};
|
|
|
|
LocalIndexedDBStoreBackend.prototype = {
|
|
/**
|
|
* Attempt to connect to the database. This can fail if the user does not
|
|
* grant permission.
|
|
* @return {Promise} Resolves if successfully connected.
|
|
*/
|
|
connect: function () {
|
|
if (!this._disconnected) {
|
|
_logger.logger.log(`LocalIndexedDBStoreBackend.connect: already connected or connecting`);
|
|
|
|
return Promise.resolve();
|
|
}
|
|
|
|
this._disconnected = false;
|
|
|
|
_logger.logger.log(`LocalIndexedDBStoreBackend.connect: connecting...`);
|
|
|
|
const req = this.indexedDB.open(this._dbName, VERSION);
|
|
|
|
req.onupgradeneeded = ev => {
|
|
const db = ev.target.result;
|
|
const oldVersion = ev.oldVersion;
|
|
|
|
_logger.logger.log(`LocalIndexedDBStoreBackend.connect: upgrading from ${oldVersion}`);
|
|
|
|
if (oldVersion < 1) {
|
|
// The database did not previously exist.
|
|
this._isNewlyCreated = true;
|
|
createDatabase(db);
|
|
}
|
|
|
|
if (oldVersion < 2) {
|
|
upgradeSchemaV2(db);
|
|
}
|
|
|
|
if (oldVersion < 3) {
|
|
upgradeSchemaV3(db);
|
|
} // Expand as needed.
|
|
|
|
};
|
|
|
|
req.onblocked = () => {
|
|
_logger.logger.log(`can't yet open LocalIndexedDBStoreBackend because it is open elsewhere`);
|
|
};
|
|
|
|
_logger.logger.log(`LocalIndexedDBStoreBackend.connect: awaiting connection...`);
|
|
|
|
return reqAsEventPromise(req).then(ev => {
|
|
_logger.logger.log(`LocalIndexedDBStoreBackend.connect: connected`);
|
|
|
|
this.db = ev.target.result; // add a poorly-named listener for when deleteDatabase is called
|
|
// so we can close our db connections.
|
|
|
|
this.db.onversionchange = () => {
|
|
this.db.close();
|
|
};
|
|
|
|
return this._init();
|
|
});
|
|
},
|
|
|
|
/** @return {bool} whether or not the database was newly created in this session. */
|
|
isNewlyCreated: function () {
|
|
return Promise.resolve(this._isNewlyCreated);
|
|
},
|
|
|
|
/**
|
|
* Having connected, load initial data from the database and prepare for use
|
|
* @return {Promise} Resolves on success
|
|
*/
|
|
_init: function () {
|
|
return Promise.all([this._loadAccountData(), this._loadSyncData()]).then(([accountData, syncData]) => {
|
|
_logger.logger.log(`LocalIndexedDBStoreBackend: loaded initial data`);
|
|
|
|
this._syncAccumulator.accumulate({
|
|
next_batch: syncData.nextBatch,
|
|
rooms: syncData.roomsData,
|
|
groups: syncData.groupsData,
|
|
account_data: {
|
|
events: accountData
|
|
}
|
|
});
|
|
});
|
|
},
|
|
|
|
/**
|
|
* Returns the out-of-band membership events for this room that
|
|
* were previously loaded.
|
|
* @param {string} roomId
|
|
* @returns {Promise<event[]>} the events, potentially an empty array if OOB loading didn't yield any new members
|
|
* @returns {null} in case the members for this room haven't been stored yet
|
|
*/
|
|
getOutOfBandMembers: function (roomId) {
|
|
return new Promise((resolve, reject) => {
|
|
const tx = this.db.transaction(["oob_membership_events"], "readonly");
|
|
const store = tx.objectStore("oob_membership_events");
|
|
const roomIndex = store.index("room");
|
|
const range = IDBKeyRange.only(roomId);
|
|
const request = roomIndex.openCursor(range);
|
|
const membershipEvents = []; // did we encounter the oob_written marker object
|
|
// amongst the results? That means OOB member
|
|
// loading already happened for this room
|
|
// but there were no members to persist as they
|
|
// were all known already
|
|
|
|
let oobWritten = false;
|
|
|
|
request.onsuccess = event => {
|
|
const cursor = event.target.result;
|
|
|
|
if (!cursor) {
|
|
// Unknown room
|
|
if (!membershipEvents.length && !oobWritten) {
|
|
return resolve(null);
|
|
}
|
|
|
|
return resolve(membershipEvents);
|
|
}
|
|
|
|
const record = cursor.value;
|
|
|
|
if (record.oob_written) {
|
|
oobWritten = true;
|
|
} else {
|
|
membershipEvents.push(record);
|
|
}
|
|
|
|
cursor.continue();
|
|
};
|
|
|
|
request.onerror = err => {
|
|
reject(err);
|
|
};
|
|
}).then(events => {
|
|
_logger.logger.log(`LL: got ${events && events.length}` + ` membershipEvents from storage for room ${roomId} ...`);
|
|
|
|
return events;
|
|
});
|
|
},
|
|
|
|
/**
|
|
* Stores the out-of-band membership events for this room. Note that
|
|
* it still makes sense to store an empty array as the OOB status for the room is
|
|
* marked as fetched, and getOutOfBandMembers will return an empty array instead of null
|
|
* @param {string} roomId
|
|
* @param {event[]} membershipEvents the membership events to store
|
|
*/
|
|
setOutOfBandMembers: async function (roomId, membershipEvents) {
|
|
_logger.logger.log(`LL: backend about to store ${membershipEvents.length}` + ` members for ${roomId}`);
|
|
|
|
const tx = this.db.transaction(["oob_membership_events"], "readwrite");
|
|
const store = tx.objectStore("oob_membership_events");
|
|
membershipEvents.forEach(e => {
|
|
store.put(e);
|
|
}); // aside from all the events, we also write a marker object to the store
|
|
// to mark the fact that OOB members have been written for this room.
|
|
// It's possible that 0 members need to be written as all where previously know
|
|
// but we still need to know whether to return null or [] from getOutOfBandMembers
|
|
// where null means out of band members haven't been stored yet for this room
|
|
|
|
const markerObject = {
|
|
room_id: roomId,
|
|
oob_written: true,
|
|
state_key: 0
|
|
};
|
|
store.put(markerObject);
|
|
await txnAsPromise(tx);
|
|
|
|
_logger.logger.log(`LL: backend done storing for ${roomId}!`);
|
|
},
|
|
clearOutOfBandMembers: async function (roomId) {
|
|
// the approach to delete all members for a room
|
|
// is to get the min and max state key from the index
|
|
// for that room, and then delete between those
|
|
// keys in the store.
|
|
// this should be way faster than deleting every member
|
|
// individually for a large room.
|
|
const readTx = this.db.transaction(["oob_membership_events"], "readonly");
|
|
const store = readTx.objectStore("oob_membership_events");
|
|
const roomIndex = store.index("room");
|
|
const roomRange = IDBKeyRange.only(roomId);
|
|
const minStateKeyProm = reqAsCursorPromise(roomIndex.openKeyCursor(roomRange, "next")).then(cursor => cursor && cursor.primaryKey[1]);
|
|
const maxStateKeyProm = reqAsCursorPromise(roomIndex.openKeyCursor(roomRange, "prev")).then(cursor => cursor && cursor.primaryKey[1]);
|
|
const [minStateKey, maxStateKey] = await Promise.all([minStateKeyProm, maxStateKeyProm]);
|
|
const writeTx = this.db.transaction(["oob_membership_events"], "readwrite");
|
|
const writeStore = writeTx.objectStore("oob_membership_events");
|
|
const membersKeyRange = IDBKeyRange.bound([roomId, minStateKey], [roomId, maxStateKey]);
|
|
|
|
_logger.logger.log(`LL: Deleting all users + marker in storage for ` + `room ${roomId}, with key range:`, [roomId, minStateKey], [roomId, maxStateKey]);
|
|
|
|
await reqAsPromise(writeStore.delete(membersKeyRange));
|
|
},
|
|
|
|
/**
|
|
* Clear the entire database. This should be used when logging out of a client
|
|
* to prevent mixing data between accounts.
|
|
* @return {Promise} Resolved when the database is cleared.
|
|
*/
|
|
clearDatabase: function () {
|
|
return new Promise((resolve, reject) => {
|
|
_logger.logger.log(`Removing indexeddb instance: ${this._dbName}`);
|
|
|
|
const req = this.indexedDB.deleteDatabase(this._dbName);
|
|
|
|
req.onblocked = () => {
|
|
_logger.logger.log(`can't yet delete indexeddb ${this._dbName}` + ` because it is open elsewhere`);
|
|
};
|
|
|
|
req.onerror = ev => {
|
|
// in firefox, with indexedDB disabled, this fails with a
|
|
// DOMError. We treat this as non-fatal, so that we can still
|
|
// use the app.
|
|
_logger.logger.warn(`unable to delete js-sdk store indexeddb: ${ev.target.error}`);
|
|
|
|
resolve();
|
|
};
|
|
|
|
req.onsuccess = () => {
|
|
_logger.logger.log(`Removed indexeddb instance: ${this._dbName}`);
|
|
|
|
resolve();
|
|
};
|
|
});
|
|
},
|
|
|
|
/**
|
|
* @param {boolean=} copy If false, the data returned is from internal
|
|
* buffers and must not be mutated. Otherwise, a copy is made before
|
|
* returning such that the data can be safely mutated. Default: true.
|
|
*
|
|
* @return {Promise} Resolves with a sync response to restore the
|
|
* client state to where it was at the last save, or null if there
|
|
* is no saved sync data.
|
|
*/
|
|
getSavedSync: function (copy) {
|
|
if (copy === undefined) copy = true;
|
|
|
|
const data = this._syncAccumulator.getJSON();
|
|
|
|
if (!data.nextBatch) return Promise.resolve(null);
|
|
|
|
if (copy) {
|
|
// We must deep copy the stored data so that the /sync processing code doesn't
|
|
// corrupt the internal state of the sync accumulator (it adds non-clonable keys)
|
|
return Promise.resolve(utils.deepCopy(data));
|
|
} else {
|
|
return Promise.resolve(data);
|
|
}
|
|
},
|
|
getNextBatchToken: function () {
|
|
return Promise.resolve(this._syncAccumulator.getNextBatchToken());
|
|
},
|
|
setSyncData: function (syncData) {
|
|
return Promise.resolve().then(() => {
|
|
this._syncAccumulator.accumulate(syncData);
|
|
});
|
|
},
|
|
syncToDatabase: function (userTuples) {
|
|
const syncData = this._syncAccumulator.getJSON();
|
|
|
|
return Promise.all([this._persistUserPresenceEvents(userTuples), this._persistAccountData(syncData.accountData), this._persistSyncData(syncData.nextBatch, syncData.roomsData, syncData.groupsData)]);
|
|
},
|
|
|
|
/**
|
|
* Persist rooms /sync data along with the next batch token.
|
|
* @param {string} nextBatch The next_batch /sync value.
|
|
* @param {Object} roomsData The 'rooms' /sync data from a SyncAccumulator
|
|
* @param {Object} groupsData The 'groups' /sync data from a SyncAccumulator
|
|
* @return {Promise} Resolves if the data was persisted.
|
|
*/
|
|
_persistSyncData: function (nextBatch, roomsData, groupsData) {
|
|
_logger.logger.log("Persisting sync data up to ", nextBatch);
|
|
|
|
return utils.promiseTry(() => {
|
|
const txn = this.db.transaction(["sync"], "readwrite");
|
|
const store = txn.objectStore("sync");
|
|
store.put({
|
|
clobber: "-",
|
|
// constant key so will always clobber
|
|
nextBatch: nextBatch,
|
|
roomsData: roomsData,
|
|
groupsData: groupsData
|
|
}); // put == UPSERT
|
|
|
|
return txnAsPromise(txn);
|
|
});
|
|
},
|
|
|
|
/**
|
|
* Persist a list of account data events. Events with the same 'type' will
|
|
* be replaced.
|
|
* @param {Object[]} accountData An array of raw user-scoped account data events
|
|
* @return {Promise} Resolves if the events were persisted.
|
|
*/
|
|
_persistAccountData: function (accountData) {
|
|
return utils.promiseTry(() => {
|
|
const txn = this.db.transaction(["accountData"], "readwrite");
|
|
const store = txn.objectStore("accountData");
|
|
|
|
for (let i = 0; i < accountData.length; i++) {
|
|
store.put(accountData[i]); // put == UPSERT
|
|
}
|
|
|
|
return txnAsPromise(txn);
|
|
});
|
|
},
|
|
|
|
/**
|
|
* Persist a list of [user id, presence event] they are for.
|
|
* Users with the same 'userId' will be replaced.
|
|
* Presence events should be the event in its raw form (not the Event
|
|
* object)
|
|
* @param {Object[]} tuples An array of [userid, event] tuples
|
|
* @return {Promise} Resolves if the users were persisted.
|
|
*/
|
|
_persistUserPresenceEvents: function (tuples) {
|
|
return utils.promiseTry(() => {
|
|
const txn = this.db.transaction(["users"], "readwrite");
|
|
const store = txn.objectStore("users");
|
|
|
|
for (const tuple of tuples) {
|
|
store.put({
|
|
userId: tuple[0],
|
|
event: tuple[1]
|
|
}); // put == UPSERT
|
|
}
|
|
|
|
return txnAsPromise(txn);
|
|
});
|
|
},
|
|
|
|
/**
|
|
* Load all user presence events from the database. This is not cached.
|
|
* FIXME: It would probably be more sensible to store the events in the
|
|
* sync.
|
|
* @return {Promise<Object[]>} A list of presence events in their raw form.
|
|
*/
|
|
getUserPresenceEvents: function () {
|
|
return utils.promiseTry(() => {
|
|
const txn = this.db.transaction(["users"], "readonly");
|
|
const store = txn.objectStore("users");
|
|
return selectQuery(store, undefined, cursor => {
|
|
return [cursor.value.userId, cursor.value.event];
|
|
});
|
|
});
|
|
},
|
|
|
|
/**
|
|
* Load all the account data events from the database. This is not cached.
|
|
* @return {Promise<Object[]>} A list of raw global account events.
|
|
*/
|
|
_loadAccountData: function () {
|
|
_logger.logger.log(`LocalIndexedDBStoreBackend: loading account data...`);
|
|
|
|
return utils.promiseTry(() => {
|
|
const txn = this.db.transaction(["accountData"], "readonly");
|
|
const store = txn.objectStore("accountData");
|
|
return selectQuery(store, undefined, cursor => {
|
|
return cursor.value;
|
|
}).then(result => {
|
|
_logger.logger.log(`LocalIndexedDBStoreBackend: loaded account data`);
|
|
|
|
return result;
|
|
});
|
|
});
|
|
},
|
|
|
|
/**
|
|
* Load the sync data from the database.
|
|
* @return {Promise<Object>} An object with "roomsData" and "nextBatch" keys.
|
|
*/
|
|
_loadSyncData: function () {
|
|
_logger.logger.log(`LocalIndexedDBStoreBackend: loading sync data...`);
|
|
|
|
return utils.promiseTry(() => {
|
|
const txn = this.db.transaction(["sync"], "readonly");
|
|
const store = txn.objectStore("sync");
|
|
return selectQuery(store, undefined, cursor => {
|
|
return cursor.value;
|
|
}).then(results => {
|
|
_logger.logger.log(`LocalIndexedDBStoreBackend: loaded sync data`);
|
|
|
|
if (results.length > 1) {
|
|
_logger.logger.warn("loadSyncData: More than 1 sync row found.");
|
|
}
|
|
|
|
return results.length > 0 ? results[0] : {};
|
|
});
|
|
});
|
|
},
|
|
getClientOptions: function () {
|
|
return Promise.resolve().then(() => {
|
|
const txn = this.db.transaction(["client_options"], "readonly");
|
|
const store = txn.objectStore("client_options");
|
|
return selectQuery(store, undefined, cursor => {
|
|
if (cursor.value && cursor.value && cursor.value.options) {
|
|
return cursor.value.options;
|
|
}
|
|
}).then(results => results[0]);
|
|
});
|
|
},
|
|
storeClientOptions: async function (options) {
|
|
const txn = this.db.transaction(["client_options"], "readwrite");
|
|
const store = txn.objectStore("client_options");
|
|
store.put({
|
|
clobber: "-",
|
|
// constant key so will always clobber
|
|
options: options
|
|
}); // put == UPSERT
|
|
|
|
await txnAsPromise(txn);
|
|
}
|
|
}; |