Page MenuHomePhabricator
Differential D9353

[lib] Refactor actions in activity-actions.js
ClosedPublic
Actions

Authored by inka on Oct 4 2023, 3:19 AM.
Tags
None
Referenced Files
Unknown Object (File)
Tue, Mar 18, 3:00 AM
Unknown Object (File)
Tue, Mar 18, 3:00 AM
Unknown Object (File)
Tue, Mar 18, 3:00 AM
Unknown Object (File)
Tue, Mar 18, 2:48 AM
Unknown Object (File)
Wed, Feb 26, 2:45 PM
Unknown Object (File)
Tue, Feb 25, 11:10 PM
Unknown Object (File)
Tue, Feb 25, 5:06 AM
Unknown Object (File)
Feb 22 2025, 6:30 PM
View All 96 Files
Subscribers
ashoat
tomek
will

Details

Reviewers
michal
kamil
ginsu
Commits
rCOMM5105c6e04b8d: [lib] Refactor actions in activity-actions.js
Summary

issue: https://linear.app/comm/issue/ENG-4681/create-action-objects-for-all-actions

Test Plan

Tested that the actions work as expected

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

PathSize
lib/
actions/
74 lines
hooks/
11 lines
socket/
11 lines

Diff 32756

View Options

lib/actions/activity-actions.js

// @flow // @flow
import type { Account as OlmAccount } from '@commapp/olm';
import cluster from 'cluster'; import cluster from 'cluster';
import schedule from 'node-schedule'; import schedule from 'node-schedule';
import { backupDB } from './backups.js'; import { backupDB } from './backups.js';
import { createDailyUpdatesThread } from './daily-updates.js'; import { createDailyUpdatesThread } from './daily-updates.js';
import { updateAndReloadGeoipDB } from './update-geoip-db.js'; import { updateAndReloadGeoipDB } from './update-geoip-db.js';
import { updateIdentityReservedUsernames } from './update-identity-reserved-usernames.js'; import { updateIdentityReservedUsernames } from './update-identity-reserved-usernames.js';
import { deleteOrphanedActivity } from '../deleters/activity-deleters.js'; import { deleteOrphanedActivity } from '../deleters/activity-deleters.js';
Show All 9 Linesimport {
deleteOrphanedSessions, deleteOrphanedSessions,
deleteOldWebSessions, deleteOldWebSessions,
} from '../deleters/session-deleters.js'; } from '../deleters/session-deleters.js';
import { deleteStaleSIWENonceEntries } from '../deleters/siwe-nonce-deleters.js'; import { deleteStaleSIWENonceEntries } from '../deleters/siwe-nonce-deleters.js';
import { deleteInaccessibleThreads } from '../deleters/thread-deleters.js'; import { deleteInaccessibleThreads } from '../deleters/thread-deleters.js';
import { deleteExpiredUpdates } from '../deleters/update-deleters.js'; import { deleteExpiredUpdates } from '../deleters/update-deleters.js';
import { deleteUnassignedUploads } from '../deleters/upload-deleters.js'; import { deleteUnassignedUploads } from '../deleters/upload-deleters.js';
import { fetchCallUpdateOlmAccount } from '../updaters/olm-account-updater.js'; import { fetchCallUpdateOlmAccount } from '../updaters/olm-account-updater.js';
import { validateAccountPrekey } from '../utils/olm-utils.js'; import { revalidateAccountPrekeys } from '../utils/olm-utils.js';
if (cluster.isMaster) { if (cluster.isMaster) {
schedule.scheduleJob( schedule.scheduleJob(
'30 3 * * *', // every day at 3:30 AM in the keyserver's timezone '30 3 * * *', // every day at 3:30 AM in the keyserver's timezone
async () => { async () => {
try { try {
// Do everything one at a time to reduce load since we're in no hurry, // Do everything one at a time to reduce load since we're in no hurry,
// and since some queries depend on previous ones. // and since some queries depend on previous ones.
▲ Show 20 Lines • Show All 69 Lines • ▼ Show 20 Lines async () => {
); );
} }
}, },
); );
schedule.scheduleJob( schedule.scheduleJob(
'0 0 * * *', // every day at midnight in the keyserver's timezone '0 0 * * *', // every day at midnight in the keyserver's timezone
async () => { async () => {
try { try {
await fetchCallUpdateOlmAccount('content', validateAccountPrekey); await fetchCallUpdateOlmAccount(
await fetchCallUpdateOlmAccount('notifications', validateAccountPrekey); 'content',
(contentAccount: OlmAccount) =>
fetchCallUpdateOlmAccount(
'notifications',
(notifAccount: OlmAccount) =>
revalidateAccountPrekeys(contentAccount, notifAccount),
),
);
} catch (e) { } catch (e) {
console.warn('encountered error while trying to validate prekeys', e); console.warn('encountered error while trying to validate prekeys', e);
} }
}, },
); );
} }
View Options

lib/hooks/toggle-unread-status.js

// @flow // @flow
import type { Account as OlmAccount } from '@commapp/olm';
import cluster from 'cluster'; import cluster from 'cluster';
import schedule from 'node-schedule'; import schedule from 'node-schedule';
import { backupDB } from './backups.js'; import { backupDB } from './backups.js';
import { createDailyUpdatesThread } from './daily-updates.js'; import { createDailyUpdatesThread } from './daily-updates.js';
import { updateAndReloadGeoipDB } from './update-geoip-db.js'; import { updateAndReloadGeoipDB } from './update-geoip-db.js';
import { updateIdentityReservedUsernames } from './update-identity-reserved-usernames.js'; import { updateIdentityReservedUsernames } from './update-identity-reserved-usernames.js';
import { deleteOrphanedActivity } from '../deleters/activity-deleters.js'; import { deleteOrphanedActivity } from '../deleters/activity-deleters.js';
Show All 9 Linesimport {
deleteOrphanedSessions, deleteOrphanedSessions,
deleteOldWebSessions, deleteOldWebSessions,
} from '../deleters/session-deleters.js'; } from '../deleters/session-deleters.js';
import { deleteStaleSIWENonceEntries } from '../deleters/siwe-nonce-deleters.js'; import { deleteStaleSIWENonceEntries } from '../deleters/siwe-nonce-deleters.js';
import { deleteInaccessibleThreads } from '../deleters/thread-deleters.js'; import { deleteInaccessibleThreads } from '../deleters/thread-deleters.js';
import { deleteExpiredUpdates } from '../deleters/update-deleters.js'; import { deleteExpiredUpdates } from '../deleters/update-deleters.js';
import { deleteUnassignedUploads } from '../deleters/upload-deleters.js'; import { deleteUnassignedUploads } from '../deleters/upload-deleters.js';
import { fetchCallUpdateOlmAccount } from '../updaters/olm-account-updater.js'; import { fetchCallUpdateOlmAccount } from '../updaters/olm-account-updater.js';
import { validateAccountPrekey } from '../utils/olm-utils.js'; import { revalidateAccountPrekeys } from '../utils/olm-utils.js';
if (cluster.isMaster) { if (cluster.isMaster) {
schedule.scheduleJob( schedule.scheduleJob(
'30 3 * * *', // every day at 3:30 AM in the keyserver's timezone '30 3 * * *', // every day at 3:30 AM in the keyserver's timezone
async () => { async () => {
try { try {
// Do everything one at a time to reduce load since we're in no hurry, // Do everything one at a time to reduce load since we're in no hurry,
// and since some queries depend on previous ones. // and since some queries depend on previous ones.
▲ Show 20 Lines • Show All 69 Lines • ▼ Show 20 Lines async () => {
); );
} }
}, },
); );
schedule.scheduleJob( schedule.scheduleJob(
'0 0 * * *', // every day at midnight in the keyserver's timezone '0 0 * * *', // every day at midnight in the keyserver's timezone
async () => { async () => {
try { try {
await fetchCallUpdateOlmAccount('content', validateAccountPrekey); await fetchCallUpdateOlmAccount(
await fetchCallUpdateOlmAccount('notifications', validateAccountPrekey); 'content',
(contentAccount: OlmAccount) =>
fetchCallUpdateOlmAccount(
'notifications',
(notifAccount: OlmAccount) =>
revalidateAccountPrekeys(contentAccount, notifAccount),
),
);
} catch (e) { } catch (e) {
console.warn('encountered error while trying to validate prekeys', e); console.warn('encountered error while trying to validate prekeys', e);
} }
}, },
); );
} }
View Options

lib/socket/activity-handler.react.js

// @flow // @flow
import type { Account as OlmAccount } from '@commapp/olm';
import cluster from 'cluster'; import cluster from 'cluster';
import schedule from 'node-schedule'; import schedule from 'node-schedule';
import { backupDB } from './backups.js'; import { backupDB } from './backups.js';
import { createDailyUpdatesThread } from './daily-updates.js'; import { createDailyUpdatesThread } from './daily-updates.js';
import { updateAndReloadGeoipDB } from './update-geoip-db.js'; import { updateAndReloadGeoipDB } from './update-geoip-db.js';
import { updateIdentityReservedUsernames } from './update-identity-reserved-usernames.js'; import { updateIdentityReservedUsernames } from './update-identity-reserved-usernames.js';
import { deleteOrphanedActivity } from '../deleters/activity-deleters.js'; import { deleteOrphanedActivity } from '../deleters/activity-deleters.js';
Show All 9 Linesimport {
deleteOrphanedSessions, deleteOrphanedSessions,
deleteOldWebSessions, deleteOldWebSessions,
} from '../deleters/session-deleters.js'; } from '../deleters/session-deleters.js';
import { deleteStaleSIWENonceEntries } from '../deleters/siwe-nonce-deleters.js'; import { deleteStaleSIWENonceEntries } from '../deleters/siwe-nonce-deleters.js';
import { deleteInaccessibleThreads } from '../deleters/thread-deleters.js'; import { deleteInaccessibleThreads } from '../deleters/thread-deleters.js';
import { deleteExpiredUpdates } from '../deleters/update-deleters.js'; import { deleteExpiredUpdates } from '../deleters/update-deleters.js';
import { deleteUnassignedUploads } from '../deleters/upload-deleters.js'; import { deleteUnassignedUploads } from '../deleters/upload-deleters.js';
import { fetchCallUpdateOlmAccount } from '../updaters/olm-account-updater.js'; import { fetchCallUpdateOlmAccount } from '../updaters/olm-account-updater.js';
import { validateAccountPrekey } from '../utils/olm-utils.js'; import { revalidateAccountPrekeys } from '../utils/olm-utils.js';
if (cluster.isMaster) { if (cluster.isMaster) {
schedule.scheduleJob( schedule.scheduleJob(
'30 3 * * *', // every day at 3:30 AM in the keyserver's timezone '30 3 * * *', // every day at 3:30 AM in the keyserver's timezone
async () => { async () => {
try { try {
// Do everything one at a time to reduce load since we're in no hurry, // Do everything one at a time to reduce load since we're in no hurry,
// and since some queries depend on previous ones. // and since some queries depend on previous ones.
▲ Show 20 Lines • Show All 69 Lines • ▼ Show 20 Lines async () => {
); );
} }
}, },
); );
schedule.scheduleJob( schedule.scheduleJob(
'0 0 * * *', // every day at midnight in the keyserver's timezone '0 0 * * *', // every day at midnight in the keyserver's timezone
async () => { async () => {
try { try {
await fetchCallUpdateOlmAccount('content', validateAccountPrekey); await fetchCallUpdateOlmAccount(
await fetchCallUpdateOlmAccount('notifications', validateAccountPrekey); 'content',
(contentAccount: OlmAccount) =>
fetchCallUpdateOlmAccount(
'notifications',
(notifAccount: OlmAccount) =>
revalidateAccountPrekeys(contentAccount, notifAccount),
),
);
} catch (e) { } catch (e) {
console.warn('encountered error while trying to validate prekeys', e); console.warn('encountered error while trying to validate prekeys', e);
} }
}, },
); );
} }