Page MenuHomePhabricator
Differential D7907

[lib] Allow calling link-disabling endpoint
ClosedPublic
Actions

Authored by tomek on May 22 2023, 6:29 AM.
Tags
None
Referenced Files
Unknown Object (File)
Thu, Apr 24, 5:54 PM
Unknown Object (File)
Sun, Apr 20, 1:08 AM
Unknown Object (File)
Sat, Apr 19, 12:54 PM
Unknown Object (File)
Fri, Apr 18, 12:21 PM
Unknown Object (File)
Fri, Apr 18, 6:56 AM
Unknown Object (File)
Fri, Apr 18, 3:51 AM
Unknown Object (File)
Thu, Apr 17, 1:30 AM
Unknown Object (File)
Wed, Apr 9, 1:10 AM
View All Files
Subscribers
ashoat
atul

Details

Reviewers
bartek
kamil
inka
Commits
rCOMMa9c78258205c: [lib] Allow calling link-disabling endpoint
Summary

The reducer deletes an entry in the store. In the future we will have to do more here, as not only public links can be disabled.

Depends on D7906

Test Plan

Confirm disabling a link and check if it was deleted, e.g. by verifying that disable link button disappears.

Diff Detail

Repository
rCOMM Comm
Lint
No Lint Coverage
Unit
No Test Coverage

Event Timeline

tomek created this revision.May 22 2023, 6:29 AM
Herald added subscribers: atul, ashoat. · View Herald TranscriptMay 22 2023, 6:29 AM
tomek added a child revision: D7908: [native] Introduce disable link button.May 22 2023, 6:32 AM
Harbormaster completed remote builds in B19589: Diff 26774.May 22 2023, 6:47 AM
tomek requested review of this revision.May 22 2023, 6:47 AM
kamil accepted this revision.May 22 2023, 10:44 AM

I think the differential name is not complete and confusing a bit

lib/reducers/invite-links-reducer.js
44 ↗(On Diff #26774)

I would move currentPrimaryLink?.name === action.payload.name condition to if upper, and avoid modifying the state if it's falsy

This revision is now accepted and ready to land.May 22 2023, 10:44 AM
tomek edited parent revisions, added: D7944: [keyserver] Use mixed as an input type in inviteLinkVerificationResponder; removed: D7906: [keyserver] Create an endpoint that allows disabling links.May 23 2023, 6:49 AM
In D7907#234718, @kamil wrote:

I think the differential name is not complete and confusing a bit

It seems so... not sure what happened

tomek retitled this revision from [lib] Add reducer and endpoint calling code to [lib] Allow calling link-disabling endpoint.May 23 2023, 6:52 AM
tomek added a parent revision: D7906: [keyserver] Create an endpoint that allows disabling links.
tomek updated this revision to Diff 26885.May 23 2023, 6:59 AM

Make reducer more efficient

Harbormaster completed remote builds in B19677: Diff 26885.May 23 2023, 7:18 AM
Closed by commit rCOMMa9c78258205c: [lib] Allow calling link-disabling endpoint (authored by tomek). · Explain WhyMay 24 2023, 4:23 AM
This revision was automatically updated to reflect the committed changes.
tomek added a commit: rCOMMa9c78258205c: [lib] Allow calling link-disabling endpoint.

Revision Contents
Changeset List

PathSize
lib/
actions/
24 lines
reducers/
19 lines
types/
5 lines
17 lines

Diff 26885

View Options

lib/actions/link-actions.js

Show All 26 Lines
import type { UpdatesForCurrentSession } from './update-creator.js'; import type { UpdatesForCurrentSession } from './update-creator.js';
import { createUpdates } from './update-creator.js'; import { createUpdates } from './update-creator.js';
import { import {
dbQuery, dbQuery,
SQL, SQL,
appendSQLArray, appendSQLArray,
mergeOrConditions, mergeOrConditions,
} from '../database/database.js'; } from '../database/database.js';
import { processMessagesForSearch } from '../database/search-utils.js';
import { import {
fetchMessageInfoForLocalID, fetchMessageInfoForLocalID,
fetchMessageInfoByID, fetchMessageInfoByID,
} from '../fetchers/message-fetchers.js'; } from '../fetchers/message-fetchers.js';
import { fetchOtherSessionsForViewer } from '../fetchers/session-fetchers.js'; import { fetchOtherSessionsForViewer } from '../fetchers/session-fetchers.js';
import { fetchServerThreadInfos } from '../fetchers/thread-fetchers.js'; import { fetchServerThreadInfos } from '../fetchers/thread-fetchers.js';
import { sendPushNotifs, sendRescindNotifs } from '../push/send.js'; import { sendPushNotifs, sendRescindNotifs } from '../push/send.js';
import { handleAsyncPromise } from '../responders/handlers.js'; import { handleAsyncPromise } from '../responders/handlers.js';
▲ Show 20 Lines • Show All 240 Lines • ▼ Show 20 Lines if (updatedThreads.length > 0) {
await createUpdates(updates); await createUpdates(updates);
} }
} }
// Handles: // Handles:
// (1) Sending push notifs // (1) Sending push notifs
// (2) Setting threads to unread and generating corresponding UpdateInfos // (2) Setting threads to unread and generating corresponding UpdateInfos
// (3) Publishing to Redis so that active sockets pass on new messages // (3) Publishing to Redis so that active sockets pass on new messages
// (4) Processing messages for search
async function postMessageSend( async function postMessageSend(
viewer: Viewer, viewer: Viewer,
threadsToMessageIndices: Map<string, number[]>, threadsToMessageIndices: Map<string, number[]>,
subthreadPermissionsToCheck: Set<string>, subthreadPermissionsToCheck: Set<string>,
messageInfos: RawMessageInfo[], messageInfos: RawMessageInfo[],
messageDatas: MessageData[], messageDatas: MessageData[],
updatesForCurrentSession: UpdatesForCurrentSession, updatesForCurrentSession: UpdatesForCurrentSession,
) { ) {
const processForSearch = processMessagesForSearch(messageInfos);
let joinIndex = 0; let joinIndex = 0;
let subthreadSelects = ''; let subthreadSelects = '';
const subthreadJoins = []; const subthreadJoins = [];
for (const subthread of subthreadPermissionsToCheck) { for (const subthread of subthreadPermissionsToCheck) {
const index = joinIndex++; const index = joinIndex++;
subthreadSelects += ` subthreadSelects += `
, ,
stm${index}.permissions AS subthread${subthread}_permissions, stm${index}.permissions AS subthread${subthread}_permissions,
▲ Show 20 Lines • Show All 186 Lines • ▼ Show 20 Lines) {
const latestMessages = flattenLatestMessagesPerUser(latestMessagesPerUser); const latestMessages = flattenLatestMessagesPerUser(latestMessagesPerUser);
const [pushInfo, rescindInfo] = await Promise.all([ const [pushInfo, rescindInfo] = await Promise.all([
promiseAll(userPushInfoPromises), promiseAll(userPushInfoPromises),
promiseAll(userRescindInfoPromises), promiseAll(userRescindInfoPromises),
createReadStatusUpdates(latestMessages), createReadStatusUpdates(latestMessages),
redisPublish(viewer, messageInfosPerUser, updatesForCurrentSession), redisPublish(viewer, messageInfosPerUser, updatesForCurrentSession),
updateLatestMessages(latestMessages), updateLatestMessages(latestMessages),
processForSearch,
]); ]);
await Promise.all([ await Promise.all([
sendPushNotifs(_pickBy(Boolean)(pushInfo)), sendPushNotifs(_pickBy(Boolean)(pushInfo)),
sendRescindNotifs(_pickBy(Boolean)(rescindInfo)), sendRescindNotifs(_pickBy(Boolean)(rescindInfo)),
]); ]);
} }
▲ Show 20 Lines • Show All 174 Lines • Show Last 20 Lines
View Options

lib/reducers/invite-links-reducer.js

Show All 26 Lines
import type { UpdatesForCurrentSession } from './update-creator.js'; import type { UpdatesForCurrentSession } from './update-creator.js';
import { createUpdates } from './update-creator.js'; import { createUpdates } from './update-creator.js';
import { import {
dbQuery, dbQuery,
SQL, SQL,
appendSQLArray, appendSQLArray,
mergeOrConditions, mergeOrConditions,
} from '../database/database.js'; } from '../database/database.js';
import { processMessagesForSearch } from '../database/search-utils.js';
import { import {
fetchMessageInfoForLocalID, fetchMessageInfoForLocalID,
fetchMessageInfoByID, fetchMessageInfoByID,
} from '../fetchers/message-fetchers.js'; } from '../fetchers/message-fetchers.js';
import { fetchOtherSessionsForViewer } from '../fetchers/session-fetchers.js'; import { fetchOtherSessionsForViewer } from '../fetchers/session-fetchers.js';
import { fetchServerThreadInfos } from '../fetchers/thread-fetchers.js'; import { fetchServerThreadInfos } from '../fetchers/thread-fetchers.js';
import { sendPushNotifs, sendRescindNotifs } from '../push/send.js'; import { sendPushNotifs, sendRescindNotifs } from '../push/send.js';
import { handleAsyncPromise } from '../responders/handlers.js'; import { handleAsyncPromise } from '../responders/handlers.js';
▲ Show 20 Lines • Show All 240 Lines • ▼ Show 20 Lines if (updatedThreads.length > 0) {
await createUpdates(updates); await createUpdates(updates);
} }
} }
// Handles: // Handles:
// (1) Sending push notifs // (1) Sending push notifs
// (2) Setting threads to unread and generating corresponding UpdateInfos // (2) Setting threads to unread and generating corresponding UpdateInfos
// (3) Publishing to Redis so that active sockets pass on new messages // (3) Publishing to Redis so that active sockets pass on new messages
// (4) Processing messages for search
async function postMessageSend( async function postMessageSend(
viewer: Viewer, viewer: Viewer,
threadsToMessageIndices: Map<string, number[]>, threadsToMessageIndices: Map<string, number[]>,
subthreadPermissionsToCheck: Set<string>, subthreadPermissionsToCheck: Set<string>,
messageInfos: RawMessageInfo[], messageInfos: RawMessageInfo[],
messageDatas: MessageData[], messageDatas: MessageData[],
updatesForCurrentSession: UpdatesForCurrentSession, updatesForCurrentSession: UpdatesForCurrentSession,
) { ) {
const processForSearch = processMessagesForSearch(messageInfos);
let joinIndex = 0; let joinIndex = 0;
let subthreadSelects = ''; let subthreadSelects = '';
const subthreadJoins = []; const subthreadJoins = [];
for (const subthread of subthreadPermissionsToCheck) { for (const subthread of subthreadPermissionsToCheck) {
const index = joinIndex++; const index = joinIndex++;
subthreadSelects += ` subthreadSelects += `
, ,
stm${index}.permissions AS subthread${subthread}_permissions, stm${index}.permissions AS subthread${subthread}_permissions,
▲ Show 20 Lines • Show All 186 Lines • ▼ Show 20 Lines) {
const latestMessages = flattenLatestMessagesPerUser(latestMessagesPerUser); const latestMessages = flattenLatestMessagesPerUser(latestMessagesPerUser);
const [pushInfo, rescindInfo] = await Promise.all([ const [pushInfo, rescindInfo] = await Promise.all([
promiseAll(userPushInfoPromises), promiseAll(userPushInfoPromises),
promiseAll(userRescindInfoPromises), promiseAll(userRescindInfoPromises),
createReadStatusUpdates(latestMessages), createReadStatusUpdates(latestMessages),
redisPublish(viewer, messageInfosPerUser, updatesForCurrentSession), redisPublish(viewer, messageInfosPerUser, updatesForCurrentSession),
updateLatestMessages(latestMessages), updateLatestMessages(latestMessages),
processForSearch,
]); ]);
await Promise.all([ await Promise.all([
sendPushNotifs(_pickBy(Boolean)(pushInfo)), sendPushNotifs(_pickBy(Boolean)(pushInfo)),
sendRescindNotifs(_pickBy(Boolean)(rescindInfo)), sendRescindNotifs(_pickBy(Boolean)(rescindInfo)),
]); ]);
} }
▲ Show 20 Lines • Show All 174 Lines • Show Last 20 Lines
View Options

lib/types/link-types.js

Show All 26 Lines
import type { UpdatesForCurrentSession } from './update-creator.js'; import type { UpdatesForCurrentSession } from './update-creator.js';
import { createUpdates } from './update-creator.js'; import { createUpdates } from './update-creator.js';
import { import {
dbQuery, dbQuery,
SQL, SQL,
appendSQLArray, appendSQLArray,
mergeOrConditions, mergeOrConditions,
} from '../database/database.js'; } from '../database/database.js';
import { processMessagesForSearch } from '../database/search-utils.js';
import { import {
fetchMessageInfoForLocalID, fetchMessageInfoForLocalID,
fetchMessageInfoByID, fetchMessageInfoByID,
} from '../fetchers/message-fetchers.js'; } from '../fetchers/message-fetchers.js';
import { fetchOtherSessionsForViewer } from '../fetchers/session-fetchers.js'; import { fetchOtherSessionsForViewer } from '../fetchers/session-fetchers.js';
import { fetchServerThreadInfos } from '../fetchers/thread-fetchers.js'; import { fetchServerThreadInfos } from '../fetchers/thread-fetchers.js';
import { sendPushNotifs, sendRescindNotifs } from '../push/send.js'; import { sendPushNotifs, sendRescindNotifs } from '../push/send.js';
import { handleAsyncPromise } from '../responders/handlers.js'; import { handleAsyncPromise } from '../responders/handlers.js';
▲ Show 20 Lines • Show All 240 Lines • ▼ Show 20 Lines if (updatedThreads.length > 0) {
await createUpdates(updates); await createUpdates(updates);
} }
} }
// Handles: // Handles:
// (1) Sending push notifs // (1) Sending push notifs
// (2) Setting threads to unread and generating corresponding UpdateInfos // (2) Setting threads to unread and generating corresponding UpdateInfos
// (3) Publishing to Redis so that active sockets pass on new messages // (3) Publishing to Redis so that active sockets pass on new messages
// (4) Processing messages for search
async function postMessageSend( async function postMessageSend(
viewer: Viewer, viewer: Viewer,
threadsToMessageIndices: Map<string, number[]>, threadsToMessageIndices: Map<string, number[]>,
subthreadPermissionsToCheck: Set<string>, subthreadPermissionsToCheck: Set<string>,
messageInfos: RawMessageInfo[], messageInfos: RawMessageInfo[],
messageDatas: MessageData[], messageDatas: MessageData[],
updatesForCurrentSession: UpdatesForCurrentSession, updatesForCurrentSession: UpdatesForCurrentSession,
) { ) {
const processForSearch = processMessagesForSearch(messageInfos);
let joinIndex = 0; let joinIndex = 0;
let subthreadSelects = ''; let subthreadSelects = '';
const subthreadJoins = []; const subthreadJoins = [];
for (const subthread of subthreadPermissionsToCheck) { for (const subthread of subthreadPermissionsToCheck) {
const index = joinIndex++; const index = joinIndex++;
subthreadSelects += ` subthreadSelects += `
, ,
stm${index}.permissions AS subthread${subthread}_permissions, stm${index}.permissions AS subthread${subthread}_permissions,
▲ Show 20 Lines • Show All 186 Lines • ▼ Show 20 Lines) {
const latestMessages = flattenLatestMessagesPerUser(latestMessagesPerUser); const latestMessages = flattenLatestMessagesPerUser(latestMessagesPerUser);
const [pushInfo, rescindInfo] = await Promise.all([ const [pushInfo, rescindInfo] = await Promise.all([
promiseAll(userPushInfoPromises), promiseAll(userPushInfoPromises),
promiseAll(userRescindInfoPromises), promiseAll(userRescindInfoPromises),
createReadStatusUpdates(latestMessages), createReadStatusUpdates(latestMessages),
redisPublish(viewer, messageInfosPerUser, updatesForCurrentSession), redisPublish(viewer, messageInfosPerUser, updatesForCurrentSession),
updateLatestMessages(latestMessages), updateLatestMessages(latestMessages),
processForSearch,
]); ]);
await Promise.all([ await Promise.all([
sendPushNotifs(_pickBy(Boolean)(pushInfo)), sendPushNotifs(_pickBy(Boolean)(pushInfo)),
sendRescindNotifs(_pickBy(Boolean)(rescindInfo)), sendRescindNotifs(_pickBy(Boolean)(rescindInfo)),
]); ]);
} }
▲ Show 20 Lines • Show All 174 Lines • Show Last 20 Lines
View Options

lib/types/redux-types.js

Show All 26 Lines
import type { UpdatesForCurrentSession } from './update-creator.js'; import type { UpdatesForCurrentSession } from './update-creator.js';
import { createUpdates } from './update-creator.js'; import { createUpdates } from './update-creator.js';
import { import {
dbQuery, dbQuery,
SQL, SQL,
appendSQLArray, appendSQLArray,
mergeOrConditions, mergeOrConditions,
} from '../database/database.js'; } from '../database/database.js';
import { processMessagesForSearch } from '../database/search-utils.js';
import { import {
fetchMessageInfoForLocalID, fetchMessageInfoForLocalID,
fetchMessageInfoByID, fetchMessageInfoByID,
} from '../fetchers/message-fetchers.js'; } from '../fetchers/message-fetchers.js';
import { fetchOtherSessionsForViewer } from '../fetchers/session-fetchers.js'; import { fetchOtherSessionsForViewer } from '../fetchers/session-fetchers.js';
import { fetchServerThreadInfos } from '../fetchers/thread-fetchers.js'; import { fetchServerThreadInfos } from '../fetchers/thread-fetchers.js';
import { sendPushNotifs, sendRescindNotifs } from '../push/send.js'; import { sendPushNotifs, sendRescindNotifs } from '../push/send.js';
import { handleAsyncPromise } from '../responders/handlers.js'; import { handleAsyncPromise } from '../responders/handlers.js';
▲ Show 20 Lines • Show All 240 Lines • ▼ Show 20 Lines if (updatedThreads.length > 0) {
await createUpdates(updates); await createUpdates(updates);
} }
} }
// Handles: // Handles:
// (1) Sending push notifs // (1) Sending push notifs
// (2) Setting threads to unread and generating corresponding UpdateInfos // (2) Setting threads to unread and generating corresponding UpdateInfos
// (3) Publishing to Redis so that active sockets pass on new messages // (3) Publishing to Redis so that active sockets pass on new messages
// (4) Processing messages for search
async function postMessageSend( async function postMessageSend(
viewer: Viewer, viewer: Viewer,
threadsToMessageIndices: Map<string, number[]>, threadsToMessageIndices: Map<string, number[]>,
subthreadPermissionsToCheck: Set<string>, subthreadPermissionsToCheck: Set<string>,
messageInfos: RawMessageInfo[], messageInfos: RawMessageInfo[],
messageDatas: MessageData[], messageDatas: MessageData[],
updatesForCurrentSession: UpdatesForCurrentSession, updatesForCurrentSession: UpdatesForCurrentSession,
) { ) {
const processForSearch = processMessagesForSearch(messageInfos);
let joinIndex = 0; let joinIndex = 0;
let subthreadSelects = ''; let subthreadSelects = '';
const subthreadJoins = []; const subthreadJoins = [];
for (const subthread of subthreadPermissionsToCheck) { for (const subthread of subthreadPermissionsToCheck) {
const index = joinIndex++; const index = joinIndex++;
subthreadSelects += ` subthreadSelects += `
, ,
stm${index}.permissions AS subthread${subthread}_permissions, stm${index}.permissions AS subthread${subthread}_permissions,
▲ Show 20 Lines • Show All 186 Lines • ▼ Show 20 Lines) {
const latestMessages = flattenLatestMessagesPerUser(latestMessagesPerUser); const latestMessages = flattenLatestMessagesPerUser(latestMessagesPerUser);
const [pushInfo, rescindInfo] = await Promise.all([ const [pushInfo, rescindInfo] = await Promise.all([
promiseAll(userPushInfoPromises), promiseAll(userPushInfoPromises),
promiseAll(userRescindInfoPromises), promiseAll(userRescindInfoPromises),
createReadStatusUpdates(latestMessages), createReadStatusUpdates(latestMessages),
redisPublish(viewer, messageInfosPerUser, updatesForCurrentSession), redisPublish(viewer, messageInfosPerUser, updatesForCurrentSession),
updateLatestMessages(latestMessages), updateLatestMessages(latestMessages),
processForSearch,
]); ]);
await Promise.all([ await Promise.all([
sendPushNotifs(_pickBy(Boolean)(pushInfo)), sendPushNotifs(_pickBy(Boolean)(pushInfo)),
sendRescindNotifs(_pickBy(Boolean)(rescindInfo)), sendRescindNotifs(_pickBy(Boolean)(rescindInfo)),
]); ]);
} }
▲ Show 20 Lines • Show All 174 Lines • Show Last 20 Lines