keejef
/
session-desktop
mirror of https://github.com/oxen-io/session-desktop
2
0
Fork 0
Code Issues 8 Projects Releases Wiki Activity

cleanup unused prekeys table

Browse Source
pull/1693/head
Audric Ackermann 4 years ago
parent 9cff53a256
commit 27fb732f50
No known key found for this signature in database
GPG Key ID: 999F434D76324AD4
6 changed files with 61 additions and 211 deletions
Show Stats Download Patch File Download Diff File

172
app/sql.js
Unescape Escape View File

@ -25,12 +25,6 @@ module.exports = {
getIdentityKeyById, getIdentityKeyById,
removeAllSignedPreKeys,
removeAllContactPreKeys,
removeAllContactSignedPreKeys,
removeAllPreKeys,
removeAllSessions,
createOrUpdateItem, createOrUpdateItem,
getItemById, getItemById,
getAllItems, getAllItems,
@ -44,8 +38,6 @@ module.exports = {
getConversationCount, getConversationCount,
saveConversation, saveConversation,
getConversationById, getConversationById,
savePublicServerToken,
getPublicServerTokenByServerUrl,
updateConversation, updateConversation,
removeConversation, removeConversation,
getAllConversations, getAllConversations,
@ -125,16 +117,10 @@ module.exports = {
const CONVERSATIONS_TABLE = 'conversations'; const CONVERSATIONS_TABLE = 'conversations';
const MESSAGES_TABLE = 'messages'; const MESSAGES_TABLE = 'messages';
const SENDER_KEYS_TABLE = 'senderKeys'; const MESSAGES_FTS_TABLE = 'messages_fts';
const SERVERS_TOKEN_TABLE = 'servers';
const NODES_FOR_PUBKEY_TABLE = 'nodesForPubkey'; const NODES_FOR_PUBKEY_TABLE = 'nodesForPubkey';
const OPEN_GROUP_ROOMS_V2_TABLE = 'openGroupRoomsV2'; const OPEN_GROUP_ROOMS_V2_TABLE = 'openGroupRoomsV2';
const IDENTITY_KEYS_TABLE = 'identityKeys'; const IDENTITY_KEYS_TABLE = 'identityKeys';
const PRE_KEYS_TABLE = 'preKeys';
const CONTACT_PRE_KEYS_TABLE = 'contactPreKeys';
const CONTACT_SIGNED_PRE_KEYS_TABLE = 'contactSignedPreKeys';
const SIGNED_PRE_KEYS_TABLE = 'signedPreKeys';
const SESSIONS_TABLE = 'sessions';
const GUARD_NODE_TABLE = 'guardNodes'; const GUARD_NODE_TABLE = 'guardNodes';
const ITEMS_TABLE = 'items'; const ITEMS_TABLE = 'items';
const ATTACHMENT_DOWNLOADS_TABLE = 'attachment_downloads'; const ATTACHMENT_DOWNLOADS_TABLE = 'attachment_downloads';
@ -403,7 +389,7 @@ async function updateToSchemaVersion4(currentVersion, instance) {
await instance.run('BEGIN TRANSACTION;'); await instance.run('BEGIN TRANSACTION;');
await instance.run( await instance.run(
`CREATE TABLE conversations( `CREATE TABLE ${CONVERSATIONS_TABLE}(
id STRING PRIMARY KEY ASC, id STRING PRIMARY KEY ASC,
json TEXT, json TEXT,
@ -415,11 +401,11 @@ async function updateToSchemaVersion4(currentVersion, instance) {
);` );`
); );
await instance.run(`CREATE INDEX conversations_active ON conversations ( await instance.run(`CREATE INDEX conversations_active ON ${CONVERSATIONS_TABLE} (
active_at active_at
) WHERE active_at IS NOT NULL;`); ) WHERE active_at IS NOT NULL;`);
await instance.run(`CREATE INDEX conversations_type ON conversations ( await instance.run(`CREATE INDEX conversations_type ON ${CONVERSATIONS_TABLE} (
type type
) WHERE type IS NOT NULL;`); ) WHERE type IS NOT NULL;`);
@ -438,7 +424,7 @@ async function updateToSchemaVersion6(currentVersion, instance) {
// friendRequestStatus is no longer needed. So no need to add the column on new apps // friendRequestStatus is no longer needed. So no need to add the column on new apps
// await instance.run( // await instance.run(
// `ALTER TABLE conversations // `ALTER TABLE ${CONVERSATIONS_TABLE}
// ADD COLUMN friendRequestStatus INTEGER;` // ADD COLUMN friendRequestStatus INTEGER;`
// ); // );
@ -478,13 +464,13 @@ async function updateToSchemaVersion6(currentVersion, instance) {
);` );`
); );
await instance.run( await instance.run(
`CREATE TABLE identityKeys( `CREATE TABLE ${IDENTITY_KEYS_TABLE}(
id STRING PRIMARY KEY ASC, id STRING PRIMARY KEY ASC,
json TEXT json TEXT
);` );`
); );
await instance.run( await instance.run(
`CREATE TABLE items( `CREATE TABLE ${ITEMS_TABLE}(
id STRING PRIMARY KEY ASC, id STRING PRIMARY KEY ASC,
json TEXT json TEXT
);` );`
@ -590,18 +576,18 @@ async function updateToSchemaVersion8(currentVersion, instance) {
// Then we create our full-text search table and populate it // Then we create our full-text search table and populate it
await instance.run(` await instance.run(`
CREATE VIRTUAL TABLE messages_fts CREATE VIRTUAL TABLE ${MESSAGES_FTS_TABLE}
USING fts5(id UNINDEXED, body); USING fts5(id UNINDEXED, body);
`); `);
await instance.run(` await instance.run(`
INSERT INTO messages_fts(id, body) INSERT INTO ${MESSAGES_FTS_TABLE}(id, body)
SELECT id, body FROM ${MESSAGES_TABLE}; SELECT id, body FROM ${MESSAGES_TABLE};
`); `);
// Then we set up triggers to keep the full-text search table up to date // Then we set up triggers to keep the full-text search table up to date
await instance.run(` await instance.run(`
CREATE TRIGGER messages_on_insert AFTER INSERT ON ${MESSAGES_TABLE} BEGIN CREATE TRIGGER messages_on_insert AFTER INSERT ON ${MESSAGES_TABLE} BEGIN
INSERT INTO messages_fts ( INSERT INTO ${MESSAGES_FTS_TABLE} (
id, id,
body body
) VALUES ( ) VALUES (
@ -612,13 +598,13 @@ async function updateToSchemaVersion8(currentVersion, instance) {
`); `);
await instance.run(` await instance.run(`
CREATE TRIGGER messages_on_delete AFTER DELETE ON ${MESSAGES_TABLE} BEGIN CREATE TRIGGER messages_on_delete AFTER DELETE ON ${MESSAGES_TABLE} BEGIN
DELETE FROM messages_fts WHERE id = old.id; DELETE FROM ${MESSAGES_FTS_TABLE} WHERE id = old.id;
END; END;
`); `);
await instance.run(` await instance.run(`
CREATE TRIGGER messages_on_update AFTER UPDATE ON ${MESSAGES_TABLE} BEGIN CREATE TRIGGER messages_on_update AFTER UPDATE ON ${MESSAGES_TABLE} BEGIN
DELETE FROM messages_fts WHERE id = old.id; DELETE FROM ${MESSAGES_FTS_TABLE} WHERE id = old.id;
INSERT INTO messages_fts( INSERT INTO ${MESSAGES_FTS_TABLE}(
id, id,
body body
) VALUES ( ) VALUES (
@ -644,7 +630,7 @@ async function updateToSchemaVersion9(currentVersion, instance) {
console.log('updateToSchemaVersion9: starting...'); console.log('updateToSchemaVersion9: starting...');
await instance.run('BEGIN TRANSACTION;'); await instance.run('BEGIN TRANSACTION;');
await instance.run(`CREATE TABLE attachment_downloads( await instance.run(`CREATE TABLE ${ATTACHMENT_DOWNLOADS_TABLE}(
id STRING primary key, id STRING primary key,
timestamp INTEGER, timestamp INTEGER,
pending INTEGER, pending INTEGER,
@ -652,11 +638,11 @@ async function updateToSchemaVersion9(currentVersion, instance) {
);`); );`);
await instance.run(`CREATE INDEX attachment_downloads_timestamp await instance.run(`CREATE INDEX attachment_downloads_timestamp
ON attachment_downloads ( ON ${ATTACHMENT_DOWNLOADS_TABLE} (
timestamp timestamp
) WHERE pending = 0;`); ) WHERE pending = 0;`);
await instance.run(`CREATE INDEX attachment_downloads_pending await instance.run(`CREATE INDEX attachment_downloads_pending
ON attachment_downloads ( ON ${ATTACHMENT_DOWNLOADS_TABLE} (
pending pending
) WHERE pending != 0;`); ) WHERE pending != 0;`);
@ -789,6 +775,7 @@ const LOKI_SCHEMA_VERSIONS = [
updateToLokiSchemaVersion11, updateToLokiSchemaVersion11,
updateToLokiSchemaVersion12, updateToLokiSchemaVersion12,
updateToLokiSchemaVersion13, updateToLokiSchemaVersion13,
updateToLokiSchemaVersion14,
]; ];
async function updateToLokiSchemaVersion1(currentVersion, instance) { async function updateToLokiSchemaVersion1(currentVersion, instance) {
@ -803,8 +790,9 @@ async function updateToLokiSchemaVersion1(currentVersion, instance) {
`ALTER TABLE ${MESSAGES_TABLE} `ALTER TABLE ${MESSAGES_TABLE}
ADD COLUMN serverId INTEGER;` ADD COLUMN serverId INTEGER;`
); );
// servers is removed later
await instance.run( await instance.run(
`CREATE TABLE ${SERVERS_TOKEN_TABLE}( `CREATE TABLE servers(
serverUrl STRING PRIMARY KEY ASC, serverUrl STRING PRIMARY KEY ASC,
token TEXT token TEXT
);` );`
@ -904,16 +892,6 @@ async function updateToLokiSchemaVersion4(currentVersion, instance) {
);` );`
); );
// Create a table for Sender Keys
await instance.run(
`CREATE TABLE ${SENDER_KEYS_TABLE} (
groupId TEXT,
senderIdentity TEXT,
json TEXT,
PRIMARY KEY (groupId, senderIdentity)
);`
);
// Add senderIdentity field to `unprocessed` needed // Add senderIdentity field to `unprocessed` needed
// for medium size groups // for medium size groups
await instance.run(`ALTER TABLE unprocessed ADD senderIdentity TEXT`); await instance.run(`ALTER TABLE unprocessed ADD senderIdentity TEXT`);
@ -1087,7 +1065,7 @@ async function updateToLokiSchemaVersion11(currentVersion, instance) {
console.log(`updateToLokiSchemaVersion${targetVersion}: starting...`); console.log(`updateToLokiSchemaVersion${targetVersion}: starting...`);
await instance.run('BEGIN TRANSACTION;'); await instance.run('BEGIN TRANSACTION;');
await updateExistingClosedGroupToClosedGroup(instance); await updateExistingClosedGroupV1ToClosedGroupV2(instance);
await instance.run( await instance.run(
`INSERT INTO loki_schema ( `INSERT INTO loki_schema (
@ -1152,6 +1130,33 @@ async function updateToLokiSchemaVersion13(currentVersion, instance) {
console.log(`updateToLokiSchemaVersion${targetVersion}: success!`); console.log(`updateToLokiSchemaVersion${targetVersion}: success!`);
} }
async function updateToLokiSchemaVersion14(currentVersion, instance) {
const targetVersion = 14;
if (currentVersion >= targetVersion) {
return;
}
console.log(`updateToLokiSchemaVersion${targetVersion}: starting...`);
await instance.run('BEGIN TRANSACTION;');
await instance.run('DROP TABLE IF EXISTS servers;');
await instance.run('DROP TABLE IF EXISTS sessions;');
await instance.run('DROP TABLE IF EXISTS preKeys;');
await instance.run('DROP TABLE IF EXISTS contactPreKeys;');
await instance.run('DROP TABLE IF EXISTS contactSignedPreKeys;');
await instance.run('DROP TABLE IF EXISTS signedPreKeys;');
await instance.run('DROP TABLE IF EXISTS senderKeys;');
await instance.run(
`INSERT INTO loki_schema (
version
) values (
${targetVersion}
);`
);
await instance.run('COMMIT TRANSACTION;');
console.log(`updateToLokiSchemaVersion${targetVersion}: success!`);
}
async function updateLokiSchema(instance) { async function updateLokiSchema(instance) {
const result = await instance.get( const result = await instance.get(
"SELECT name FROM sqlite_master WHERE type = 'table' AND name='loki_schema';" "SELECT name FROM sqlite_master WHERE type = 'table' AND name='loki_schema';"
@ -1334,25 +1339,6 @@ async function getIdentityKeyById(id, instance) {
return getById(IDENTITY_KEYS_TABLE, id, instance); return getById(IDENTITY_KEYS_TABLE, id, instance);
} }
// those removeAll calls are currently only used to cleanup the db from old data
// TODO remove those and move those removeAll in a migration
async function removeAllPreKeys() {
return removeAllFromTable(PRE_KEYS_TABLE);
}
async function removeAllContactPreKeys() {
return removeAllFromTable(CONTACT_PRE_KEYS_TABLE);
}
async function removeAllContactSignedPreKeys() {
return removeAllFromTable(CONTACT_SIGNED_PRE_KEYS_TABLE);
}
async function removeAllSignedPreKeys() {
return removeAllFromTable(SIGNED_PRE_KEYS_TABLE);
}
async function removeAllSessions() {
return removeAllFromTable(SESSIONS_TABLE);
}
async function getGuardNodes() { async function getGuardNodes() {
const nodes = await db.all(`SELECT ed25519PubKey FROM ${GUARD_NODE_TABLE};`); const nodes = await db.all(`SELECT ed25519PubKey FROM ${GUARD_NODE_TABLE};`);
@ -1394,7 +1380,7 @@ async function getItemById(id) {
return getById(ITEMS_TABLE, id); return getById(ITEMS_TABLE, id);
} }
async function getAllItems() { async function getAllItems() {
const rows = await db.all('SELECT json FROM items ORDER BY id ASC;'); const rows = await db.all(`SELECT json FROM ${ITEMS_TABLE} ORDER BY id ASC;`);
return map(rows, row => jsonToObject(row.json)); return map(rows, row => jsonToObject(row.json));
} }
async function removeItemById(id) { async function removeItemById(id) {
@ -1589,37 +1575,6 @@ async function removeConversation(id) {
); );
} }
// open groups v1 only
async function savePublicServerToken(data) {
const { serverUrl, token } = data;
await db.run(
`INSERT OR REPLACE INTO ${SERVERS_TOKEN_TABLE} (
serverUrl,
token
) values (
$serverUrl,
$token
)`,
{
$serverUrl: serverUrl,
$token: token,
}
);
}
// open groups v1 only
async function getPublicServerTokenByServerUrl(serverUrl) {
const row = await db.get(`SELECT * FROM ${SERVERS_TOKEN_TABLE} WHERE serverUrl = $serverUrl;`, {
$serverUrl: serverUrl,
});
if (!row) {
return null;
}
return row.token;
}
async function getConversationById(id) { async function getConversationById(id) {
const row = await db.get(`SELECT * FROM ${CONVERSATIONS_TABLE} WHERE id = $id;`, { const row = await db.get(`SELECT * FROM ${CONVERSATIONS_TABLE} WHERE id = $id;`, {
$id: id, $id: id,
@ -1720,7 +1675,7 @@ async function searchMessages(query, { limit } = {}) {
`SELECT `SELECT
messages.json, messages.json,
snippet(messages_fts, -1, '<<left>>', '<<right>>', '...', 15) as snippet snippet(messages_fts, -1, '<<left>>', '<<right>>', '...', 15) as snippet
FROM messages_fts FROM ${MESSAGES_FTS_TABLE}
INNER JOIN ${MESSAGES_TABLE} on messages_fts.id = messages.id INNER JOIN ${MESSAGES_TABLE} on messages_fts.id = messages.id
WHERE WHERE
messages_fts match $query messages_fts match $query
@ -2323,7 +2278,7 @@ async function getNextAttachmentDownloadJobs(limit, options = {}) {
const timestamp = options.timestamp || Date.now(); const timestamp = options.timestamp || Date.now();
const rows = await db.all( const rows = await db.all(
`SELECT json FROM attachment_downloads `SELECT json FROM ${ATTACHMENT_DOWNLOADS_TABLE}
WHERE pending = 0 AND timestamp < $timestamp WHERE pending = 0 AND timestamp < $timestamp
ORDER BY timestamp DESC ORDER BY timestamp DESC
LIMIT $limit;`, LIMIT $limit;`,
@ -2342,7 +2297,7 @@ async function saveAttachmentDownloadJob(job) {
} }
await db.run( await db.run(
`INSERT OR REPLACE INTO attachment_downloads ( `INSERT OR REPLACE INTO ${ATTACHMENT_DOWNLOADS_TABLE} (
id, id,
pending, pending,
timestamp, timestamp,
@ -2362,13 +2317,13 @@ async function saveAttachmentDownloadJob(job) {
); );
} }
async function setAttachmentDownloadJobPending(id, pending) { async function setAttachmentDownloadJobPending(id, pending) {
await db.run('UPDATE attachment_downloads SET pending = $pending WHERE id = $id;', { await db.run(`UPDATE ${ATTACHMENT_DOWNLOADS_TABLE} SET pending = $pending WHERE id = $id;`, {
$id: id, $id: id,
$pending: pending, $pending: pending,
}); });
} }
async function resetAttachmentDownloadPending() { async function resetAttachmentDownloadPending() {
await db.run('UPDATE attachment_downloads SET pending = 0 WHERE pending != 0;'); await db.run(`UPDATE ${ATTACHMENT_DOWNLOADS_TABLE} SET pending = 0 WHERE pending != 0;`);
} }
async function removeAttachmentDownloadJob(id) { async function removeAttachmentDownloadJob(id) {
return removeById(ATTACHMENT_DOWNLOADS_TABLE, id); return removeById(ATTACHMENT_DOWNLOADS_TABLE, id);
@ -2384,24 +2339,17 @@ async function removeAll() {
db.serialize(() => { db.serialize(() => {
promise = Promise.all([ promise = Promise.all([
db.run('BEGIN TRANSACTION;'), db.run('BEGIN TRANSACTION;'),
db.run('DELETE FROM identityKeys;'), db.run(`DELETE FROM ${IDENTITY_KEYS_TABLE};`),
db.run('DELETE FROM items;'), db.run(`DELETE FROM ${ITEMS_TABLE};`),
db.run('DELETE FROM preKeys;'),
db.run('DELETE FROM sessions;'),
db.run('DELETE FROM signedPreKeys;'),
db.run('DELETE FROM unprocessed;'), db.run('DELETE FROM unprocessed;'),
db.run('DELETE FROM contactPreKeys;'),
db.run('DELETE FROM contactSignedPreKeys;'),
db.run(`DELETE FROM ${SERVERS_TOKEN_TABLE};`),
db.run('DELETE FROM lastHashes;'), db.run('DELETE FROM lastHashes;'),
db.run(`DELETE FROM ${SENDER_KEYS_TABLE};`),
db.run(`DELETE FROM ${NODES_FOR_PUBKEY_TABLE};`), db.run(`DELETE FROM ${NODES_FOR_PUBKEY_TABLE};`),
db.run(`DELETE FROM ${CLOSED_GROUP_V2_KEY_PAIRS_TABLE};`), db.run(`DELETE FROM ${CLOSED_GROUP_V2_KEY_PAIRS_TABLE};`),
db.run('DELETE FROM seenMessages;'), db.run('DELETE FROM seenMessages;'),
db.run(`DELETE FROM ${CONVERSATIONS_TABLE};`), db.run(`DELETE FROM ${CONVERSATIONS_TABLE};`),
db.run(`DELETE FROM ${MESSAGES_TABLE};`), db.run(`DELETE FROM ${MESSAGES_TABLE};`),
db.run('DELETE FROM attachment_downloads;'), db.run(`DELETE FROM ${ATTACHMENT_DOWNLOADS_TABLE};`),
db.run('DELETE FROM messages_fts;'), db.run(`DELETE FROM ${MESSAGES_FTS_TABLE};`),
db.run('COMMIT TRANSACTION;'), db.run('COMMIT TRANSACTION;'),
]); ]);
}); });
@ -2562,7 +2510,7 @@ async function removeKnownAttachments(allAttachments) {
const conversationTotal = await getConversationCount(); const conversationTotal = await getConversationCount();
console.log( console.log(
`removeKnownAttachments: About to iterate through ${conversationTotal} conversations` `removeKnownAttachments: About to iterate through ${conversationTotal} ${CONVERSATIONS_TABLE}`
); );
while (!complete) { while (!complete) {
@ -2594,7 +2542,7 @@ async function removeKnownAttachments(allAttachments) {
count += conversations.length; count += conversations.length;
} }
console.log(`removeKnownAttachments: Done processing ${count} conversations`); console.log(`removeKnownAttachments: Done processing ${count} ${CONVERSATIONS_TABLE}`);
return Object.keys(lookup); return Object.keys(lookup);
} }
@ -2698,7 +2646,7 @@ function remove05PrefixFromStringIfNeeded(str) {
return str; return str;
} }
async function updateExistingClosedGroupToClosedGroup(instance) { async function updateExistingClosedGroupV1ToClosedGroupV2(instance) {
// the migration is called only once, so all current groups not being open groups are v1 closed group. // the migration is called only once, so all current groups not being open groups are v1 closed group.
const allClosedGroupV1 = (await getAllClosedGroupConversations(instance)) || []; const allClosedGroupV1 = (await getAllClosedGroupConversations(instance)) || [];

3
js/modules/backup.js
Unescape Escape View File

@ -213,10 +213,7 @@ async function importFromJsonString(jsonString, targetPath, options) {
result.fullImport = false; result.fullImport = false;
delete importObject.items; delete importObject.items;
delete importObject.signedPreKeys;
delete importObject.preKeys;
delete importObject.identityKeys; delete importObject.identityKeys;
delete importObject.sessions;
delete importObject.unprocessed; delete importObject.unprocessed;
window.log.info('This is a light import; contacts, groups and messages only'); window.log.info('This is a light import; contacts, groups and messages only');

4
ts/components/session/ActionsPanel.tsx
Unescape Escape View File

@ -18,7 +18,6 @@ import {
} from '../../data/data'; } from '../../data/data';
import { OnionPaths } from '../../session/onions'; import { OnionPaths } from '../../session/onions';
import { getMessageQueue } from '../../session/sending'; import { getMessageQueue } from '../../session/sending';
import { clearSessionsAndPreKeys } from '../../util/accountManager';
import { useDispatch, useSelector } from 'react-redux'; import { useDispatch, useSelector } from 'react-redux';
import { getOurNumber } from '../../state/selectors/user'; import { getOurNumber } from '../../state/selectors/user';
import { import {
@ -274,9 +273,6 @@ const doAppStartUp = (dispatch: Dispatch<any>) => {
// keep that one to make sure our users upgrade to new sessionIDS // keep that one to make sure our users upgrade to new sessionIDS
void showResetSessionIDDialogIfNeeded(); void showResetSessionIDDialogIfNeeded();
// remove existing prekeys, sign prekeys and sessions
// FIXME audric, make this in a migration so we can remove this line
void clearSessionsAndPreKeys();
void removeAllV1OpenGroups(); void removeAllV1OpenGroups();
// this generates the key to encrypt attachments locally // this generates the key to encrypt attachments locally

52
ts/data/data.ts
Unescape Escape View File

@ -71,12 +71,6 @@ const channelsToMake = {
removeDB, removeDB,
getPasswordHash, getPasswordHash,
getIdentityKeyById,
removeAllPreKeys,
removeAllSignedPreKeys,
removeAllContactPreKeys,
removeAllContactSignedPreKeys,
getGuardNodes, getGuardNodes,
updateGuardNodes, updateGuardNodes,
@ -85,8 +79,6 @@ const channelsToMake = {
getAllItems, getAllItems,
removeItemById, removeItemById,
removeAllSessions,
getSwarmNodesForPubkey, getSwarmNodesForPubkey,
updateSwarmNodesForPubkey, updateSwarmNodesForPubkey,
@ -99,8 +91,6 @@ const channelsToMake = {
getAllConversationIds, getAllConversationIds,
getAllOpenGroupV1Conversations, getAllOpenGroupV1Conversations,
getPubkeysInPublicConversation, getPubkeysInPublicConversation,
savePublicServerToken,
getPublicServerTokenByServerUrl,
getAllGroupsInvolvingId, getAllGroupsInvolvingId,
searchConversations, searchConversations,
@ -408,34 +398,6 @@ export async function getPasswordHash(): Promise<string | null> {
return channels.getPasswordHash(); return channels.getPasswordHash();
} }
// Identity Keys
const IDENTITY_KEY_KEYS = ['publicKey'];
// Identity Keys
// TODO: identity key has different shape depending on how it is called,
// so we need to come up with a way to make TS work with all of them
export async function getIdentityKeyById(id: string): Promise<IdentityKey | null> {
const data = await channels.getIdentityKeyById(id);
return keysToArrayBuffer(IDENTITY_KEY_KEYS, data);
}
// Those removeAll are not used anymore except to cleanup the app since we removed all of those tables
export async function removeAllPreKeys(): Promise<void> {
await channels.removeAllPreKeys();
}
const PRE_KEY_KEYS = ['privateKey', 'publicKey', 'signature'];
export async function removeAllSignedPreKeys(): Promise<void> {
await channels.removeAllSignedPreKeys();
}
export async function removeAllContactPreKeys(): Promise<void> {
await channels.removeAllContactPreKeys();
}
export async function removeAllContactSignedPreKeys(): Promise<void> {
await channels.removeAllContactSignedPreKeys();
}
// Guard Nodes // Guard Nodes
export async function getGuardNodes(): Promise<Array<GuardNode>> { export async function getGuardNodes(): Promise<Array<GuardNode>> {
return channels.getGuardNodes(); return channels.getGuardNodes();
@ -493,10 +455,6 @@ export async function getAllItems(): Promise<Array<StorageItem>> {
export async function removeItemById(id: string): Promise<void> { export async function removeItemById(id: string): Promise<void> {
await channels.removeItemById(id); await channels.removeItemById(id);
} }
// Sessions
export async function removeAllSessions(): Promise<void> {
await channels.removeAllSessions();
}
// Swarm nodes // Swarm nodes
export async function getSwarmNodesForPubkey(pubkey: string): Promise<Array<string>> { export async function getSwarmNodesForPubkey(pubkey: string): Promise<Array<string>> {
@ -602,16 +560,6 @@ export async function getPubkeysInPublicConversation(id: string): Promise<Array<
return channels.getPubkeysInPublicConversation(id); return channels.getPubkeysInPublicConversation(id);
} }
// open groups v1 only
export async function savePublicServerToken(data: ServerToken): Promise<void> {
await channels.savePublicServerToken(data);
}
// open groups v1 only
export async function getPublicServerTokenByServerUrl(serverUrl: string): Promise<string> {
const token = await channels.getPublicServerTokenByServerUrl(serverUrl);
return token;
}
export async function getAllGroupsInvolvingId(id: string): Promise<ConversationCollection> { export async function getAllGroupsInvolvingId(id: string): Promise<ConversationCollection> {
const conversations = await channels.getAllGroupsInvolvingId(id); const conversations = await channels.getAllGroupsInvolvingId(id);

19
ts/session/group/index.ts
Unescape Escape View File

@ -2,14 +2,12 @@ import { PubKey } from '../types';
import _ from 'lodash'; import _ from 'lodash';
import { fromHex, fromHexToArray, toHex } from '../utils/String'; import { fromHexToArray, toHex } from '../utils/String';
import { BlockedNumberController } from '../../util/blockedNumberController'; import { BlockedNumberController } from '../../util/blockedNumberController';
import { ConversationController } from '../conversations'; import { ConversationController } from '../conversations';
import { import {
addClosedGroupEncryptionKeyPair, addClosedGroupEncryptionKeyPair,
getIdentityKeyById,
getLatestClosedGroupEncryptionKeyPair, getLatestClosedGroupEncryptionKeyPair,
removeAllClosedGroupEncryptionKeyPairs,
} from '../../../ts/data/data'; } from '../../../ts/data/data';
import uuid from 'uuid'; import uuid from 'uuid';
import { SignalService } from '../../protobuf'; import { SignalService } from '../../protobuf';
@ -65,21 +63,6 @@ export interface MemberChanges {
leavingMembers?: Array<string>; leavingMembers?: Array<string>;
} }
export async function getGroupSecretKey(groupId: string): Promise<Uint8Array> {
const groupIdentity = await getIdentityKeyById(groupId);
if (!groupIdentity) {
throw new Error(`Could not load secret key for group ${groupId}`);
}
const secretKey = groupIdentity.secretKey;
if (!secretKey) {
throw new Error(`Secret key not found in identity key record for group ${groupId}`);
}
return new Uint8Array(fromHex(secretKey));
}
export async function initiateGroupUpdate( export async function initiateGroupUpdate(
groupId: string, groupId: string,
groupName: string, groupName: string,

22
ts/util/accountManager.ts
Unescape Escape View File

@ -4,13 +4,6 @@ import { UserUtils } from '../session/utils';
import { fromArrayBufferToBase64, fromHex, toHex } from '../session/utils/String'; import { fromArrayBufferToBase64, fromHex, toHex } from '../session/utils/String';
import { getOurPubKeyStrFromCache } from '../session/utils/User'; import { getOurPubKeyStrFromCache } from '../session/utils/User';
import { trigger } from '../shims/events'; import { trigger } from '../shims/events';
import {
removeAllContactPreKeys,
removeAllContactSignedPreKeys,
removeAllPreKeys,
removeAllSessions,
removeAllSignedPreKeys,
} from '../data/data';
import { forceSyncConfigurationNowIfNeeded } from '../session/utils/syncUtils'; import { forceSyncConfigurationNowIfNeeded } from '../session/utils/syncUtils';
import { actions as userActions } from '../state/ducks/user'; import { actions as userActions } from '../state/ducks/user';
import { mn_decode, mn_encode } from '../session/crypto/mnemonic'; import { mn_decode, mn_encode } from '../session/crypto/mnemonic';
@ -86,7 +79,6 @@ export async function signInByLinkingDevice(mnemonic: string, mnemonicLanguage:
UserUtils.setSignInByLinking(true); UserUtils.setSignInByLinking(true);
await createAccount(identityKeyPair); await createAccount(identityKeyPair);
UserUtils.saveRecoveryPhrase(mnemonic); UserUtils.saveRecoveryPhrase(mnemonic);
await clearSessionsAndPreKeys();
const pubKeyString = toHex(identityKeyPair.pubKey); const pubKeyString = toHex(identityKeyPair.pubKey);
// await for the first configuration message to come in. // await for the first configuration message to come in.
@ -117,7 +109,6 @@ export async function registerSingleDevice(
await createAccount(identityKeyPair); await createAccount(identityKeyPair);
UserUtils.saveRecoveryPhrase(generatedMnemonic); UserUtils.saveRecoveryPhrase(generatedMnemonic);
await clearSessionsAndPreKeys();
await UserUtils.setLastProfileUpdateTimestamp(Date.now()); await UserUtils.setLastProfileUpdateTimestamp(Date.now());
const pubKeyString = toHex(identityKeyPair.pubKey); const pubKeyString = toHex(identityKeyPair.pubKey);
@ -133,19 +124,6 @@ export async function generateMnemonic() {
return mn_encode(hex); return mn_encode(hex);
} }
export async function clearSessionsAndPreKeys() {
window?.log?.info('clearing all sessions');
// During secondary device registration we need to keep our prekeys sent
// to other pubkeys
await Promise.all([
removeAllPreKeys(),
removeAllSignedPreKeys(),
removeAllContactPreKeys(),
removeAllContactSignedPreKeys(),
removeAllSessions(),
]);
}
async function bouncyDeleteAccount(reason?: string) { async function bouncyDeleteAccount(reason?: string) {
const deleteEverything = async () => { const deleteEverything = async () => {
window?.log?.info('configuration message sent successfully. Deleting everything'); window?.log?.info('configuration message sent successfully. Deleting everything');

Write Preview
Loading…
Cancel
Save