Page MenuHomePhabricator
Differential D9473

[keyserver] change function names for getting clients to be more intuitive
ClosedPublic
Actions

Authored by varun on Oct 12 2023, 11:57 AM.
Tags
None
Referenced Files
Unknown Object (File)
Wed, Apr 2, 4:33 PM
Unknown Object (File)
Tue, Apr 1, 8:29 PM
Unknown Object (File)
Wed, Mar 19, 1:37 PM
Unknown Object (File)
Tue, Mar 18, 10:14 PM
Unknown Object (File)
Sat, Mar 15, 8:12 AM
Unknown Object (File)
Mon, Mar 10, 3:58 AM
Unknown Object (File)
Mon, Mar 10, 3:58 AM
Unknown Object (File)
Mon, Mar 10, 3:58 AM
View All 81 Files
Subscribers
ashoat
tomek
will

Details

Reviewers
bartek
michal
Commits
rCOMMae8f251a5b77: [keyserver] change function names for getting clients to be more intuitive
Summary

i also added back a module that we made dead code for some reason in https://phab.comm.dev/D8820 ... we definitely need this function so i think it was a mistake. i should've reviewed this more carefully before commandeering the diff.

Depends on D9472

Test Plan

cargo build, also called the function i added back from js and confirmed it still worked as expected

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

PathSize
keyserver/
addons/
rust-node-addon/
src/
identity_client/
2 lines
7 lines
2 lines
5 lines
10 lines
2 lines
2 lines
2 lines

Diff 32165

View Options

keyserver/addons/rust-node-addon/src/identity_client/add_reserved_usernames.rs

Show First 20 Lines • Show All 1,023 Lines • ▼ Show 20 Lines): ReduceMessageStoreResult {
) { ) {
const payload = ensureRealizedThreadIDIsUsedWhenPossible( const payload = ensureRealizedThreadIDIsUsedWhenPossible(
action.payload, action.payload,
newThreadInfos, newThreadInfos,
); );
const { localID, threadID } = payload; const { localID, threadID } = payload;
invariant(localID, `localID should be set on ${action.type}`); invariant(localID, `localID should be set on ${action.type}`);
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? [];
if (!messageStore.messages[localID]) {
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
}
const messageStoreOperations = [ const messageStoreOperations = [
{ {
type: 'replace', type: 'replace',
payload: { id: localID, messageInfo: payload }, payload: { id: localID, messageInfo: payload },
}, },
]; ];
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const now = Date.now(); const now = Date.now();
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? []; let updatedThreads;
let local = { ...messageStore.local };
if (messageStore.messages[localID]) { if (messageStore.messages[localID]) {
const messages = { ...messageStore.messages, [localID]: payload }; const messages = { ...messageStore.messages, [localID]: payload };
const local = _pickBy( local = _pickBy(
(localInfo: LocalMessageInfo, key: string) => key !== localID, (localInfo: LocalMessageInfo, key: string) => key !== localID,
)(messageStore.local); )(messageStore.local);
const thread = messageStore.threads[threadID]; const thread = messageStore.threads[threadID];
const threads = { updatedThreads = {
...messageStore.threads,
[threadID]: { [threadID]: {
messageIDs: sortMessageIDs(messages)(messageIDs), messageIDs: sortMessageIDs(messages)(messageIDs),
startReached: thread?.startReached ?? true, startReached: thread?.startReached ?? true,
lastNavigatedTo: thread?.lastNavigatedTo ?? now, lastNavigatedTo: thread?.lastNavigatedTo ?? now,
lastPruned: thread?.lastPruned ?? now, lastPruned: thread?.lastPruned ?? now,
}, },
}; };
return { } else {
messageStoreOperations, updatedThreads = {
messageStore: { [threadID]: messageStore.threads[threadID]
...messageStore,
messages: processedMessageStore.messages,
threads,
local,
},
};
}
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
const threadState: ThreadMessageInfo = messageStore.threads[threadID]
? { ? {
...messageStore.threads[threadID], ...messageStore.threads[threadID],
messageIDs: [localID, ...messageIDs], messageIDs: [localID, ...messageIDs],
} }
: { : {
messageIDs: [localID], messageIDs: [localID],
startReached: true, startReached: true,
lastNavigatedTo: now, lastNavigatedTo: now,
lastPruned: now, lastPruned: now,
},
}; };
}
return { const threads = {
messageStoreOperations,
messageStore: {
messages: processedMessageStore.messages,
threads: {
...messageStore.threads, ...messageStore.threads,
[threadID]: threadState, ...updatedThreads,
};
messageStoreOperations.push({
type: 'replace_threads',
payload: {
threads: { ...updatedThreads },
}, },
local: messageStore.local, });
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const newMessageStore = {
messages: processedMessageStore.messages,
threads,
local,
currentAsOf: messageStore.currentAsOf, currentAsOf: messageStore.currentAsOf,
}, };
assertMessageStoreThreadsAreEqual(
processedMessageStore,
newMessageStore,
action.type,
);
return {
messageStoreOperations,
messageStore: newMessageStore,
}; };
} else if ( } else if (
action.type === sendTextMessageActionTypes.failed || action.type === sendTextMessageActionTypes.failed ||
action.type === sendMultimediaMessageActionTypes.failed action.type === sendMultimediaMessageActionTypes.failed
) { ) {
const { localID } = action.payload; const { localID } = action.payload;
return { return {
messageStoreOperations: [], messageStoreOperations: [],
▲ Show 20 Lines • Show All 565 Lines • Show Last 20 Lines
View Options

keyserver/addons/rust-node-addon/src/identity_client/get_inbound_keys_for_user.rs

Show First 20 Lines • Show All 1,023 Lines • ▼ Show 20 Lines): ReduceMessageStoreResult {
) { ) {
const payload = ensureRealizedThreadIDIsUsedWhenPossible( const payload = ensureRealizedThreadIDIsUsedWhenPossible(
action.payload, action.payload,
newThreadInfos, newThreadInfos,
); );
const { localID, threadID } = payload; const { localID, threadID } = payload;
invariant(localID, `localID should be set on ${action.type}`); invariant(localID, `localID should be set on ${action.type}`);
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? [];
if (!messageStore.messages[localID]) {
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
}
const messageStoreOperations = [ const messageStoreOperations = [
{ {
type: 'replace', type: 'replace',
payload: { id: localID, messageInfo: payload }, payload: { id: localID, messageInfo: payload },
}, },
]; ];
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const now = Date.now(); const now = Date.now();
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? []; let updatedThreads;
let local = { ...messageStore.local };
if (messageStore.messages[localID]) { if (messageStore.messages[localID]) {
const messages = { ...messageStore.messages, [localID]: payload }; const messages = { ...messageStore.messages, [localID]: payload };
const local = _pickBy( local = _pickBy(
(localInfo: LocalMessageInfo, key: string) => key !== localID, (localInfo: LocalMessageInfo, key: string) => key !== localID,
)(messageStore.local); )(messageStore.local);
const thread = messageStore.threads[threadID]; const thread = messageStore.threads[threadID];
const threads = { updatedThreads = {
...messageStore.threads,
[threadID]: { [threadID]: {
messageIDs: sortMessageIDs(messages)(messageIDs), messageIDs: sortMessageIDs(messages)(messageIDs),
startReached: thread?.startReached ?? true, startReached: thread?.startReached ?? true,
lastNavigatedTo: thread?.lastNavigatedTo ?? now, lastNavigatedTo: thread?.lastNavigatedTo ?? now,
lastPruned: thread?.lastPruned ?? now, lastPruned: thread?.lastPruned ?? now,
}, },
}; };
return { } else {
messageStoreOperations, updatedThreads = {
messageStore: { [threadID]: messageStore.threads[threadID]
...messageStore,
messages: processedMessageStore.messages,
threads,
local,
},
};
}
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
const threadState: ThreadMessageInfo = messageStore.threads[threadID]
? { ? {
...messageStore.threads[threadID], ...messageStore.threads[threadID],
messageIDs: [localID, ...messageIDs], messageIDs: [localID, ...messageIDs],
} }
: { : {
messageIDs: [localID], messageIDs: [localID],
startReached: true, startReached: true,
lastNavigatedTo: now, lastNavigatedTo: now,
lastPruned: now, lastPruned: now,
},
}; };
}
return { const threads = {
messageStoreOperations,
messageStore: {
messages: processedMessageStore.messages,
threads: {
...messageStore.threads, ...messageStore.threads,
[threadID]: threadState, ...updatedThreads,
};
messageStoreOperations.push({
type: 'replace_threads',
payload: {
threads: { ...updatedThreads },
}, },
local: messageStore.local, });
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const newMessageStore = {
messages: processedMessageStore.messages,
threads,
local,
currentAsOf: messageStore.currentAsOf, currentAsOf: messageStore.currentAsOf,
}, };
assertMessageStoreThreadsAreEqual(
processedMessageStore,
newMessageStore,
action.type,
);
return {
messageStoreOperations,
messageStore: newMessageStore,
}; };
} else if ( } else if (
action.type === sendTextMessageActionTypes.failed || action.type === sendTextMessageActionTypes.failed ||
action.type === sendMultimediaMessageActionTypes.failed action.type === sendMultimediaMessageActionTypes.failed
) { ) {
const { localID } = action.payload; const { localID } = action.payload;
return { return {
messageStoreOperations: [], messageStoreOperations: [],
▲ Show 20 Lines • Show All 565 Lines • Show Last 20 Lines
View Options

keyserver/addons/rust-node-addon/src/identity_client/login.rs

Show First 20 Lines • Show All 1,023 Lines • ▼ Show 20 Lines): ReduceMessageStoreResult {
) { ) {
const payload = ensureRealizedThreadIDIsUsedWhenPossible( const payload = ensureRealizedThreadIDIsUsedWhenPossible(
action.payload, action.payload,
newThreadInfos, newThreadInfos,
); );
const { localID, threadID } = payload; const { localID, threadID } = payload;
invariant(localID, `localID should be set on ${action.type}`); invariant(localID, `localID should be set on ${action.type}`);
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? [];
if (!messageStore.messages[localID]) {
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
}
const messageStoreOperations = [ const messageStoreOperations = [
{ {
type: 'replace', type: 'replace',
payload: { id: localID, messageInfo: payload }, payload: { id: localID, messageInfo: payload },
}, },
]; ];
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const now = Date.now(); const now = Date.now();
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? []; let updatedThreads;
let local = { ...messageStore.local };
if (messageStore.messages[localID]) { if (messageStore.messages[localID]) {
const messages = { ...messageStore.messages, [localID]: payload }; const messages = { ...messageStore.messages, [localID]: payload };
const local = _pickBy( local = _pickBy(
(localInfo: LocalMessageInfo, key: string) => key !== localID, (localInfo: LocalMessageInfo, key: string) => key !== localID,
)(messageStore.local); )(messageStore.local);
const thread = messageStore.threads[threadID]; const thread = messageStore.threads[threadID];
const threads = { updatedThreads = {
...messageStore.threads,
[threadID]: { [threadID]: {
messageIDs: sortMessageIDs(messages)(messageIDs), messageIDs: sortMessageIDs(messages)(messageIDs),
startReached: thread?.startReached ?? true, startReached: thread?.startReached ?? true,
lastNavigatedTo: thread?.lastNavigatedTo ?? now, lastNavigatedTo: thread?.lastNavigatedTo ?? now,
lastPruned: thread?.lastPruned ?? now, lastPruned: thread?.lastPruned ?? now,
}, },
}; };
return { } else {
messageStoreOperations, updatedThreads = {
messageStore: { [threadID]: messageStore.threads[threadID]
...messageStore,
messages: processedMessageStore.messages,
threads,
local,
},
};
}
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
const threadState: ThreadMessageInfo = messageStore.threads[threadID]
? { ? {
...messageStore.threads[threadID], ...messageStore.threads[threadID],
messageIDs: [localID, ...messageIDs], messageIDs: [localID, ...messageIDs],
} }
: { : {
messageIDs: [localID], messageIDs: [localID],
startReached: true, startReached: true,
lastNavigatedTo: now, lastNavigatedTo: now,
lastPruned: now, lastPruned: now,
},
}; };
}
return { const threads = {
messageStoreOperations,
messageStore: {
messages: processedMessageStore.messages,
threads: {
...messageStore.threads, ...messageStore.threads,
[threadID]: threadState, ...updatedThreads,
};
messageStoreOperations.push({
type: 'replace_threads',
payload: {
threads: { ...updatedThreads },
}, },
local: messageStore.local, });
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const newMessageStore = {
messages: processedMessageStore.messages,
threads,
local,
currentAsOf: messageStore.currentAsOf, currentAsOf: messageStore.currentAsOf,
}, };
assertMessageStoreThreadsAreEqual(
processedMessageStore,
newMessageStore,
action.type,
);
return {
messageStoreOperations,
messageStore: newMessageStore,
}; };
} else if ( } else if (
action.type === sendTextMessageActionTypes.failed || action.type === sendTextMessageActionTypes.failed ||
action.type === sendMultimediaMessageActionTypes.failed action.type === sendMultimediaMessageActionTypes.failed
) { ) {
const { localID } = action.payload; const { localID } = action.payload;
return { return {
messageStoreOperations: [], messageStoreOperations: [],
▲ Show 20 Lines • Show All 565 Lines • Show Last 20 Lines
View Options

keyserver/addons/rust-node-addon/src/identity_client/mod.rs

Show First 20 Lines • Show All 1,023 Lines • ▼ Show 20 Lines): ReduceMessageStoreResult {
) { ) {
const payload = ensureRealizedThreadIDIsUsedWhenPossible( const payload = ensureRealizedThreadIDIsUsedWhenPossible(
action.payload, action.payload,
newThreadInfos, newThreadInfos,
); );
const { localID, threadID } = payload; const { localID, threadID } = payload;
invariant(localID, `localID should be set on ${action.type}`); invariant(localID, `localID should be set on ${action.type}`);
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? [];
if (!messageStore.messages[localID]) {
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
}
const messageStoreOperations = [ const messageStoreOperations = [
{ {
type: 'replace', type: 'replace',
payload: { id: localID, messageInfo: payload }, payload: { id: localID, messageInfo: payload },
}, },
]; ];
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const now = Date.now(); const now = Date.now();
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? []; let updatedThreads;
let local = { ...messageStore.local };
if (messageStore.messages[localID]) { if (messageStore.messages[localID]) {
const messages = { ...messageStore.messages, [localID]: payload }; const messages = { ...messageStore.messages, [localID]: payload };
const local = _pickBy( local = _pickBy(
(localInfo: LocalMessageInfo, key: string) => key !== localID, (localInfo: LocalMessageInfo, key: string) => key !== localID,
)(messageStore.local); )(messageStore.local);
const thread = messageStore.threads[threadID]; const thread = messageStore.threads[threadID];
const threads = { updatedThreads = {
...messageStore.threads,
[threadID]: { [threadID]: {
messageIDs: sortMessageIDs(messages)(messageIDs), messageIDs: sortMessageIDs(messages)(messageIDs),
startReached: thread?.startReached ?? true, startReached: thread?.startReached ?? true,
lastNavigatedTo: thread?.lastNavigatedTo ?? now, lastNavigatedTo: thread?.lastNavigatedTo ?? now,
lastPruned: thread?.lastPruned ?? now, lastPruned: thread?.lastPruned ?? now,
}, },
}; };
return { } else {
messageStoreOperations, updatedThreads = {
messageStore: { [threadID]: messageStore.threads[threadID]
...messageStore,
messages: processedMessageStore.messages,
threads,
local,
},
};
}
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
const threadState: ThreadMessageInfo = messageStore.threads[threadID]
? { ? {
...messageStore.threads[threadID], ...messageStore.threads[threadID],
messageIDs: [localID, ...messageIDs], messageIDs: [localID, ...messageIDs],
} }
: { : {
messageIDs: [localID], messageIDs: [localID],
startReached: true, startReached: true,
lastNavigatedTo: now, lastNavigatedTo: now,
lastPruned: now, lastPruned: now,
},
}; };
}
return { const threads = {
messageStoreOperations,
messageStore: {
messages: processedMessageStore.messages,
threads: {
...messageStore.threads, ...messageStore.threads,
[threadID]: threadState, ...updatedThreads,
};
messageStoreOperations.push({
type: 'replace_threads',
payload: {
threads: { ...updatedThreads },
}, },
local: messageStore.local, });
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const newMessageStore = {
messages: processedMessageStore.messages,
threads,
local,
currentAsOf: messageStore.currentAsOf, currentAsOf: messageStore.currentAsOf,
}, };
assertMessageStoreThreadsAreEqual(
processedMessageStore,
newMessageStore,
action.type,
);
return {
messageStoreOperations,
messageStore: newMessageStore,
}; };
} else if ( } else if (
action.type === sendTextMessageActionTypes.failed || action.type === sendTextMessageActionTypes.failed ||
action.type === sendMultimediaMessageActionTypes.failed action.type === sendMultimediaMessageActionTypes.failed
) { ) {
const { localID } = action.payload; const { localID } = action.payload;
return { return {
messageStoreOperations: [], messageStoreOperations: [],
▲ Show 20 Lines • Show All 565 Lines • Show Last 20 Lines
View Options

keyserver/addons/rust-node-addon/src/identity_client/prekey.rs

Show First 20 Lines • Show All 1,023 Lines • ▼ Show 20 Lines): ReduceMessageStoreResult {
) { ) {
const payload = ensureRealizedThreadIDIsUsedWhenPossible( const payload = ensureRealizedThreadIDIsUsedWhenPossible(
action.payload, action.payload,
newThreadInfos, newThreadInfos,
); );
const { localID, threadID } = payload; const { localID, threadID } = payload;
invariant(localID, `localID should be set on ${action.type}`); invariant(localID, `localID should be set on ${action.type}`);
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? [];
if (!messageStore.messages[localID]) {
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
}
const messageStoreOperations = [ const messageStoreOperations = [
{ {
type: 'replace', type: 'replace',
payload: { id: localID, messageInfo: payload }, payload: { id: localID, messageInfo: payload },
}, },
]; ];
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const now = Date.now(); const now = Date.now();
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? []; let updatedThreads;
let local = { ...messageStore.local };
if (messageStore.messages[localID]) { if (messageStore.messages[localID]) {
const messages = { ...messageStore.messages, [localID]: payload }; const messages = { ...messageStore.messages, [localID]: payload };
const local = _pickBy( local = _pickBy(
(localInfo: LocalMessageInfo, key: string) => key !== localID, (localInfo: LocalMessageInfo, key: string) => key !== localID,
)(messageStore.local); )(messageStore.local);
const thread = messageStore.threads[threadID]; const thread = messageStore.threads[threadID];
const threads = { updatedThreads = {
...messageStore.threads,
[threadID]: { [threadID]: {
messageIDs: sortMessageIDs(messages)(messageIDs), messageIDs: sortMessageIDs(messages)(messageIDs),
startReached: thread?.startReached ?? true, startReached: thread?.startReached ?? true,
lastNavigatedTo: thread?.lastNavigatedTo ?? now, lastNavigatedTo: thread?.lastNavigatedTo ?? now,
lastPruned: thread?.lastPruned ?? now, lastPruned: thread?.lastPruned ?? now,
}, },
}; };
return { } else {
messageStoreOperations, updatedThreads = {
messageStore: { [threadID]: messageStore.threads[threadID]
...messageStore,
messages: processedMessageStore.messages,
threads,
local,
},
};
}
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
const threadState: ThreadMessageInfo = messageStore.threads[threadID]
? { ? {
...messageStore.threads[threadID], ...messageStore.threads[threadID],
messageIDs: [localID, ...messageIDs], messageIDs: [localID, ...messageIDs],
} }
: { : {
messageIDs: [localID], messageIDs: [localID],
startReached: true, startReached: true,
lastNavigatedTo: now, lastNavigatedTo: now,
lastPruned: now, lastPruned: now,
},
}; };
}
return { const threads = {
messageStoreOperations,
messageStore: {
messages: processedMessageStore.messages,
threads: {
...messageStore.threads, ...messageStore.threads,
[threadID]: threadState, ...updatedThreads,
};
messageStoreOperations.push({
type: 'replace_threads',
payload: {
threads: { ...updatedThreads },
}, },
local: messageStore.local, });
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const newMessageStore = {
messages: processedMessageStore.messages,
threads,
local,
currentAsOf: messageStore.currentAsOf, currentAsOf: messageStore.currentAsOf,
}, };
assertMessageStoreThreadsAreEqual(
processedMessageStore,
newMessageStore,
action.type,
);
return {
messageStoreOperations,
messageStore: newMessageStore,
}; };
} else if ( } else if (
action.type === sendTextMessageActionTypes.failed || action.type === sendTextMessageActionTypes.failed ||
action.type === sendMultimediaMessageActionTypes.failed action.type === sendMultimediaMessageActionTypes.failed
) { ) {
const { localID } = action.payload; const { localID } = action.payload;
return { return {
messageStoreOperations: [], messageStoreOperations: [],
▲ Show 20 Lines • Show All 565 Lines • Show Last 20 Lines
View Options

keyserver/addons/rust-node-addon/src/identity_client/register_user.rs

Show First 20 Lines • Show All 1,023 Lines • ▼ Show 20 Lines): ReduceMessageStoreResult {
) { ) {
const payload = ensureRealizedThreadIDIsUsedWhenPossible( const payload = ensureRealizedThreadIDIsUsedWhenPossible(
action.payload, action.payload,
newThreadInfos, newThreadInfos,
); );
const { localID, threadID } = payload; const { localID, threadID } = payload;
invariant(localID, `localID should be set on ${action.type}`); invariant(localID, `localID should be set on ${action.type}`);
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? [];
if (!messageStore.messages[localID]) {
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
}
const messageStoreOperations = [ const messageStoreOperations = [
{ {
type: 'replace', type: 'replace',
payload: { id: localID, messageInfo: payload }, payload: { id: localID, messageInfo: payload },
}, },
]; ];
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const now = Date.now(); const now = Date.now();
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? []; let updatedThreads;
let local = { ...messageStore.local };
if (messageStore.messages[localID]) { if (messageStore.messages[localID]) {
const messages = { ...messageStore.messages, [localID]: payload }; const messages = { ...messageStore.messages, [localID]: payload };
const local = _pickBy( local = _pickBy(
(localInfo: LocalMessageInfo, key: string) => key !== localID, (localInfo: LocalMessageInfo, key: string) => key !== localID,
)(messageStore.local); )(messageStore.local);
const thread = messageStore.threads[threadID]; const thread = messageStore.threads[threadID];
const threads = { updatedThreads = {
...messageStore.threads,
[threadID]: { [threadID]: {
messageIDs: sortMessageIDs(messages)(messageIDs), messageIDs: sortMessageIDs(messages)(messageIDs),
startReached: thread?.startReached ?? true, startReached: thread?.startReached ?? true,
lastNavigatedTo: thread?.lastNavigatedTo ?? now, lastNavigatedTo: thread?.lastNavigatedTo ?? now,
lastPruned: thread?.lastPruned ?? now, lastPruned: thread?.lastPruned ?? now,
}, },
}; };
return { } else {
messageStoreOperations, updatedThreads = {
messageStore: { [threadID]: messageStore.threads[threadID]
...messageStore,
messages: processedMessageStore.messages,
threads,
local,
},
};
}
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
const threadState: ThreadMessageInfo = messageStore.threads[threadID]
? { ? {
...messageStore.threads[threadID], ...messageStore.threads[threadID],
messageIDs: [localID, ...messageIDs], messageIDs: [localID, ...messageIDs],
} }
: { : {
messageIDs: [localID], messageIDs: [localID],
startReached: true, startReached: true,
lastNavigatedTo: now, lastNavigatedTo: now,
lastPruned: now, lastPruned: now,
},
}; };
}
return { const threads = {
messageStoreOperations,
messageStore: {
messages: processedMessageStore.messages,
threads: {
...messageStore.threads, ...messageStore.threads,
[threadID]: threadState, ...updatedThreads,
};
messageStoreOperations.push({
type: 'replace_threads',
payload: {
threads: { ...updatedThreads },
}, },
local: messageStore.local, });
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const newMessageStore = {
messages: processedMessageStore.messages,
threads,
local,
currentAsOf: messageStore.currentAsOf, currentAsOf: messageStore.currentAsOf,
}, };
assertMessageStoreThreadsAreEqual(
processedMessageStore,
newMessageStore,
action.type,
);
return {
messageStoreOperations,
messageStore: newMessageStore,
}; };
} else if ( } else if (
action.type === sendTextMessageActionTypes.failed || action.type === sendTextMessageActionTypes.failed ||
action.type === sendMultimediaMessageActionTypes.failed action.type === sendMultimediaMessageActionTypes.failed
) { ) {
const { localID } = action.payload; const { localID } = action.payload;
return { return {
messageStoreOperations: [], messageStoreOperations: [],
▲ Show 20 Lines • Show All 565 Lines • Show Last 20 Lines
View Options

keyserver/addons/rust-node-addon/src/identity_client/remove_reserved_usernames.rs

Show First 20 Lines • Show All 1,023 Lines • ▼ Show 20 Lines): ReduceMessageStoreResult {
) { ) {
const payload = ensureRealizedThreadIDIsUsedWhenPossible( const payload = ensureRealizedThreadIDIsUsedWhenPossible(
action.payload, action.payload,
newThreadInfos, newThreadInfos,
); );
const { localID, threadID } = payload; const { localID, threadID } = payload;
invariant(localID, `localID should be set on ${action.type}`); invariant(localID, `localID should be set on ${action.type}`);
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? [];
if (!messageStore.messages[localID]) {
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
}
const messageStoreOperations = [ const messageStoreOperations = [
{ {
type: 'replace', type: 'replace',
payload: { id: localID, messageInfo: payload }, payload: { id: localID, messageInfo: payload },
}, },
]; ];
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const now = Date.now(); const now = Date.now();
const messageIDs = messageStore.threads[threadID]?.messageIDs ?? []; let updatedThreads;
let local = { ...messageStore.local };
if (messageStore.messages[localID]) { if (messageStore.messages[localID]) {
const messages = { ...messageStore.messages, [localID]: payload }; const messages = { ...messageStore.messages, [localID]: payload };
const local = _pickBy( local = _pickBy(
(localInfo: LocalMessageInfo, key: string) => key !== localID, (localInfo: LocalMessageInfo, key: string) => key !== localID,
)(messageStore.local); )(messageStore.local);
const thread = messageStore.threads[threadID]; const thread = messageStore.threads[threadID];
const threads = { updatedThreads = {
...messageStore.threads,
[threadID]: { [threadID]: {
messageIDs: sortMessageIDs(messages)(messageIDs), messageIDs: sortMessageIDs(messages)(messageIDs),
startReached: thread?.startReached ?? true, startReached: thread?.startReached ?? true,
lastNavigatedTo: thread?.lastNavigatedTo ?? now, lastNavigatedTo: thread?.lastNavigatedTo ?? now,
lastPruned: thread?.lastPruned ?? now, lastPruned: thread?.lastPruned ?? now,
}, },
}; };
return { } else {
messageStoreOperations, updatedThreads = {
messageStore: { [threadID]: messageStore.threads[threadID]
...messageStore,
messages: processedMessageStore.messages,
threads,
local,
},
};
}
for (const existingMessageID of messageIDs) {
const existingMessageInfo = messageStore.messages[existingMessageID];
if (existingMessageInfo && existingMessageInfo.localID === localID) {
return { messageStoreOperations: [], messageStore };
}
}
const threadState: ThreadMessageInfo = messageStore.threads[threadID]
? { ? {
...messageStore.threads[threadID], ...messageStore.threads[threadID],
messageIDs: [localID, ...messageIDs], messageIDs: [localID, ...messageIDs],
} }
: { : {
messageIDs: [localID], messageIDs: [localID],
startReached: true, startReached: true,
lastNavigatedTo: now, lastNavigatedTo: now,
lastPruned: now, lastPruned: now,
},
}; };
}
return { const threads = {
messageStoreOperations,
messageStore: {
messages: processedMessageStore.messages,
threads: {
...messageStore.threads, ...messageStore.threads,
[threadID]: threadState, ...updatedThreads,
};
messageStoreOperations.push({
type: 'replace_threads',
payload: {
threads: { ...updatedThreads },
}, },
local: messageStore.local, });
const processedMessageStore = processMessageStoreOperations(
messageStore,
messageStoreOperations,
);
const newMessageStore = {
messages: processedMessageStore.messages,
threads,
local,
currentAsOf: messageStore.currentAsOf, currentAsOf: messageStore.currentAsOf,
}, };
assertMessageStoreThreadsAreEqual(
processedMessageStore,
newMessageStore,
action.type,
);
return {
messageStoreOperations,
messageStore: newMessageStore,
}; };
} else if ( } else if (
action.type === sendTextMessageActionTypes.failed || action.type === sendTextMessageActionTypes.failed ||
action.type === sendMultimediaMessageActionTypes.failed action.type === sendMultimediaMessageActionTypes.failed
) { ) {
const { localID } = action.payload; const { localID } = action.payload;
return { return {
messageStoreOperations: [], messageStoreOperations: [],
▲ Show 20 Lines • Show All 565 Lines • Show Last 20 Lines
View Options

keyserver/addons/rust-node-addon/src/identity_client/upload_one_time_keys.rs

Loading...