79 lines
2.9 KiB
JavaScript
79 lines
2.9 KiB
JavaScript
import {iterateCursor, reqAsPromise} from "./utils.js";
|
|
import {RoomMember, EVENT_TYPE as MEMBER_EVENT_TYPE} from "../../room/members/RoomMember.js";
|
|
import {RoomMemberStore} from "./stores/RoomMemberStore.js";
|
|
import {SessionStore} from "./stores/SessionStore.js";
|
|
|
|
// FUNCTIONS SHOULD ONLY BE APPENDED!!
|
|
// the index in the array is the database version
|
|
export const schema = [
|
|
createInitialStores,
|
|
createMemberStore,
|
|
migrateSession,
|
|
createIdentityStores,
|
|
createOlmSessionStore,
|
|
];
|
|
// TODO: how to deal with git merge conflicts of this array?
|
|
|
|
|
|
// how do we deal with schema updates vs existing data migration in a way that
|
|
//v1
|
|
function createInitialStores(db) {
|
|
db.createObjectStore("session", {keyPath: "key"});
|
|
// any way to make keys unique here? (just use put?)
|
|
db.createObjectStore("roomSummary", {keyPath: "roomId"});
|
|
|
|
// need index to find live fragment? prooobably ok without for now
|
|
//key = room_id | fragment_id
|
|
db.createObjectStore("timelineFragments", {keyPath: "key"});
|
|
//key = room_id | fragment_id | event_index
|
|
const timelineEvents = db.createObjectStore("timelineEvents", {keyPath: "key"});
|
|
//eventIdKey = room_id | event_id
|
|
timelineEvents.createIndex("byEventId", "eventIdKey", {unique: true});
|
|
//key = room_id | event.type | event.state_key,
|
|
db.createObjectStore("roomState", {keyPath: "key"});
|
|
db.createObjectStore("pendingEvents", {keyPath: "key"});
|
|
}
|
|
//v2
|
|
async function createMemberStore(db, txn) {
|
|
const roomMembers = new RoomMemberStore(db.createObjectStore("roomMembers", {keyPath: "key"}));
|
|
// migrate existing member state events over
|
|
const roomState = txn.objectStore("roomState");
|
|
await iterateCursor(roomState.openCursor(), entry => {
|
|
if (entry.event.type === MEMBER_EVENT_TYPE) {
|
|
roomState.delete(entry.key);
|
|
const member = RoomMember.fromMemberEvent(entry.roomId, entry.event);
|
|
if (member) {
|
|
roomMembers.set(member.serialize());
|
|
}
|
|
}
|
|
});
|
|
}
|
|
//v3
|
|
async function migrateSession(db, txn) {
|
|
const session = txn.objectStore("session");
|
|
try {
|
|
const PRE_MIGRATION_KEY = 1;
|
|
const entry = await reqAsPromise(session.get(PRE_MIGRATION_KEY));
|
|
if (entry) {
|
|
session.delete(PRE_MIGRATION_KEY);
|
|
const {syncToken, syncFilterId, serverVersions} = entry.value;
|
|
const store = new SessionStore(session);
|
|
store.set("sync", {token: syncToken, filterId: syncFilterId});
|
|
store.set("serverVersions", serverVersions);
|
|
}
|
|
} catch (err) {
|
|
txn.abort();
|
|
console.error("could not migrate session", err.stack);
|
|
}
|
|
}
|
|
//v4
|
|
function createIdentityStores(db) {
|
|
db.createObjectStore("userIdentities", {keyPath: "userId"});
|
|
db.createObjectStore("deviceIdentities", {keyPath: "key"});
|
|
}
|
|
|
|
//v5
|
|
function createOlmSessionStore(db) {
|
|
db.createObjectStore("olmSessions", {keyPath: "key"});
|
|
}
|