Page MenuHomePhabricator
Differential D9329

[lib] Remove convertClientToServerInfos from spec
ClosedPublic
Actions

Authored by michal on Sep 29 2023, 5:38 AM.
Tags
None
Referenced Files
Unknown Object (File)
Tue, Mar 11, 5:59 AM
Unknown Object (File)
Sat, Mar 8, 9:51 AM
Unknown Object (File)
Tue, Mar 4, 8:42 PM
Unknown Object (File)
Mon, Feb 24, 8:06 PM
Unknown Object (File)
Mon, Feb 24, 7:51 PM
Unknown Object (File)
Mon, Feb 24, 7:05 AM
Unknown Object (File)
Feb 16 2025, 1:56 AM
Unknown Object (File)
Feb 16 2025, 1:56 AM
View All Files
Subscribers
ashoat

Details

Reviewers
tomek
inka
kamil
Commits
rCOMMe8d666ff6bd5: [lib] Remove convertClientToServerInfos from spec
Summary

Part of ENG-4959
Depends on D9328

convertClientToServerInfos stopped being used after changes in D9328.

Test Plan

yarn flow-all

Diff Detail

Repository
rCOMM Comm
Lint
No Lint Coverage
Unit
No Test Coverage

Revision Contents
Changeset List

Diff 31810

View Options

lib/shared/state-sync/current-user-state-sync-spec.js

// @flow // @flow
import fs from 'fs'; import fs from 'fs';
import { policyTypes } from 'lib/facts/policies.js'; import { policyTypes } from 'lib/facts/policies.js';
import { messageTypes } from 'lib/types/message-types.js';
import { dbQuery, SQL } from '../database/database.js'; import { dbQuery, SQL } from '../database/database.js';
import { processMessagesInDBForSearch } from '../database/search-utils.js'; import { processMessagesInDBForSearch } from '../database/search-utils.js';
import { updateRolesAndPermissionsForAllThreads } from '../updaters/thread-permission-updaters.js'; import { updateRolesAndPermissionsForAllThreads } from '../updaters/thread-permission-updaters.js';
const migrations: $ReadOnlyMap<number, () => Promise<void>> = new Map([ const migrations: $ReadOnlyMap<number, () => Promise<void>> = new Map([
[ [
0, 0,
▲ Show 20 Lines • Show All 139 Lines • ▼ Show 20 Lines [
async () => { async () => {
await dbQuery( await dbQuery(
SQL` SQL`
ALTER TABLE uploads ALTER TABLE uploads
ADD COLUMN IF NOT EXISTS thread bigint(20) DEFAULT NULL, ADD COLUMN IF NOT EXISTS thread bigint(20) DEFAULT NULL,
ADD INDEX IF NOT EXISTS thread (thread); ADD INDEX IF NOT EXISTS thread (thread);
UPDATE uploads UPDATE uploads
SET thread = ( SET thread = (
SELECT thread FROM messages SELECT thread FROM messages
WHERE messages.id = uploads.container WHERE messages.id = uploads.container
); );
`, `,
{ multipleStatements: true }, { multipleStatements: true },
); );
}, },
], ],
[ [
16, 16,
async () => { async () => {
▲ Show 20 Lines • Show All 171 Lines • ▼ Show 20 Lines async () => {
ADD PRIMARY KEY (id), ADD PRIMARY KEY (id),
ADD UNIQUE KEY (name), ADD UNIQUE KEY (name),
ADD INDEX community_primary (community, \`primary\`); ADD INDEX community_primary (community, \`primary\`);
`, `,
{ multipleStatements: true }, { multipleStatements: true },
); );
}, },
], ],
[
32,
async () => {
await dbQuery(SQL`
UPDATE messages
SET target_message = JSON_VALUE(content, "$.sourceMessageID")
WHERE type = ${messageTypes.SIDEBAR_SOURCE};
`);
},
],
]); ]);
const newDatabaseVersion: number = Math.max(...migrations.keys()); const newDatabaseVersion: number = Math.max(...migrations.keys());
async function writeJSONToFile(data: any, filePath: string): Promise<void> { async function writeJSONToFile(data: any, filePath: string): Promise<void> {
console.warn(`updating ${filePath} to ${JSON.stringify(data)}`); console.warn(`updating ${filePath} to ${JSON.stringify(data)}`);
const fileHandle = await fs.promises.open(filePath, 'w'); const fileHandle = await fs.promises.open(filePath, 'w');
await fileHandle.writeFile(JSON.stringify(data, null, ' '), 'utf8'); await fileHandle.writeFile(JSON.stringify(data, null, ' '), 'utf8');
await fileHandle.close(); await fileHandle.close();
▲ Show 20 Lines • Show All 89 Lines • Show Last 20 Lines
View Options

lib/shared/state-sync/entries-state-sync-spec.js

// @flow // @flow
import fs from 'fs'; import fs from 'fs';
import { policyTypes } from 'lib/facts/policies.js'; import { policyTypes } from 'lib/facts/policies.js';
import { messageTypes } from 'lib/types/message-types.js';
import { dbQuery, SQL } from '../database/database.js'; import { dbQuery, SQL } from '../database/database.js';
import { processMessagesInDBForSearch } from '../database/search-utils.js'; import { processMessagesInDBForSearch } from '../database/search-utils.js';
import { updateRolesAndPermissionsForAllThreads } from '../updaters/thread-permission-updaters.js'; import { updateRolesAndPermissionsForAllThreads } from '../updaters/thread-permission-updaters.js';
const migrations: $ReadOnlyMap<number, () => Promise<void>> = new Map([ const migrations: $ReadOnlyMap<number, () => Promise<void>> = new Map([
[ [
0, 0,
▲ Show 20 Lines • Show All 139 Lines • ▼ Show 20 Lines [
async () => { async () => {
await dbQuery( await dbQuery(
SQL` SQL`
ALTER TABLE uploads ALTER TABLE uploads
ADD COLUMN IF NOT EXISTS thread bigint(20) DEFAULT NULL, ADD COLUMN IF NOT EXISTS thread bigint(20) DEFAULT NULL,
ADD INDEX IF NOT EXISTS thread (thread); ADD INDEX IF NOT EXISTS thread (thread);
UPDATE uploads UPDATE uploads
SET thread = ( SET thread = (
SELECT thread FROM messages SELECT thread FROM messages
WHERE messages.id = uploads.container WHERE messages.id = uploads.container
); );
`, `,
{ multipleStatements: true }, { multipleStatements: true },
); );
}, },
], ],
[ [
16, 16,
async () => { async () => {
▲ Show 20 Lines • Show All 171 Lines • ▼ Show 20 Lines async () => {
ADD PRIMARY KEY (id), ADD PRIMARY KEY (id),
ADD UNIQUE KEY (name), ADD UNIQUE KEY (name),
ADD INDEX community_primary (community, \`primary\`); ADD INDEX community_primary (community, \`primary\`);
`, `,
{ multipleStatements: true }, { multipleStatements: true },
); );
}, },
], ],
[
32,
async () => {
await dbQuery(SQL`
UPDATE messages
SET target_message = JSON_VALUE(content, "$.sourceMessageID")
WHERE type = ${messageTypes.SIDEBAR_SOURCE};
`);
},
],
]); ]);
const newDatabaseVersion: number = Math.max(...migrations.keys()); const newDatabaseVersion: number = Math.max(...migrations.keys());
async function writeJSONToFile(data: any, filePath: string): Promise<void> { async function writeJSONToFile(data: any, filePath: string): Promise<void> {
console.warn(`updating ${filePath} to ${JSON.stringify(data)}`); console.warn(`updating ${filePath} to ${JSON.stringify(data)}`);
const fileHandle = await fs.promises.open(filePath, 'w'); const fileHandle = await fs.promises.open(filePath, 'w');
await fileHandle.writeFile(JSON.stringify(data, null, ' '), 'utf8'); await fileHandle.writeFile(JSON.stringify(data, null, ' '), 'utf8');
await fileHandle.close(); await fileHandle.close();
▲ Show 20 Lines • Show All 89 Lines • Show Last 20 Lines
View Options

lib/shared/state-sync/state-sync-spec.js

// @flow // @flow
import fs from 'fs'; import fs from 'fs';
import { policyTypes } from 'lib/facts/policies.js'; import { policyTypes } from 'lib/facts/policies.js';
import { messageTypes } from 'lib/types/message-types.js';
import { dbQuery, SQL } from '../database/database.js'; import { dbQuery, SQL } from '../database/database.js';
import { processMessagesInDBForSearch } from '../database/search-utils.js'; import { processMessagesInDBForSearch } from '../database/search-utils.js';
import { updateRolesAndPermissionsForAllThreads } from '../updaters/thread-permission-updaters.js'; import { updateRolesAndPermissionsForAllThreads } from '../updaters/thread-permission-updaters.js';
const migrations: $ReadOnlyMap<number, () => Promise<void>> = new Map([ const migrations: $ReadOnlyMap<number, () => Promise<void>> = new Map([
[ [
0, 0,
▲ Show 20 Lines • Show All 139 Lines • ▼ Show 20 Lines [
async () => { async () => {
await dbQuery( await dbQuery(
SQL` SQL`
ALTER TABLE uploads ALTER TABLE uploads
ADD COLUMN IF NOT EXISTS thread bigint(20) DEFAULT NULL, ADD COLUMN IF NOT EXISTS thread bigint(20) DEFAULT NULL,
ADD INDEX IF NOT EXISTS thread (thread); ADD INDEX IF NOT EXISTS thread (thread);
UPDATE uploads UPDATE uploads
SET thread = ( SET thread = (
SELECT thread FROM messages SELECT thread FROM messages
WHERE messages.id = uploads.container WHERE messages.id = uploads.container
); );
`, `,
{ multipleStatements: true }, { multipleStatements: true },
); );
}, },
], ],
[ [
16, 16,
async () => { async () => {
▲ Show 20 Lines • Show All 171 Lines • ▼ Show 20 Lines async () => {
ADD PRIMARY KEY (id), ADD PRIMARY KEY (id),
ADD UNIQUE KEY (name), ADD UNIQUE KEY (name),
ADD INDEX community_primary (community, \`primary\`); ADD INDEX community_primary (community, \`primary\`);
`, `,
{ multipleStatements: true }, { multipleStatements: true },
); );
}, },
], ],
[
32,
async () => {
await dbQuery(SQL`
UPDATE messages
SET target_message = JSON_VALUE(content, "$.sourceMessageID")
WHERE type = ${messageTypes.SIDEBAR_SOURCE};
`);
},
],
]); ]);
const newDatabaseVersion: number = Math.max(...migrations.keys()); const newDatabaseVersion: number = Math.max(...migrations.keys());
async function writeJSONToFile(data: any, filePath: string): Promise<void> { async function writeJSONToFile(data: any, filePath: string): Promise<void> {
console.warn(`updating ${filePath} to ${JSON.stringify(data)}`); console.warn(`updating ${filePath} to ${JSON.stringify(data)}`);
const fileHandle = await fs.promises.open(filePath, 'w'); const fileHandle = await fs.promises.open(filePath, 'w');
await fileHandle.writeFile(JSON.stringify(data, null, ' '), 'utf8'); await fileHandle.writeFile(JSON.stringify(data, null, ' '), 'utf8');
await fileHandle.close(); await fileHandle.close();
▲ Show 20 Lines • Show All 89 Lines • Show Last 20 Lines
View Options

lib/shared/state-sync/threads-state-sync-spec.js

// @flow // @flow
import fs from 'fs'; import fs from 'fs';
import { policyTypes } from 'lib/facts/policies.js'; import { policyTypes } from 'lib/facts/policies.js';
import { messageTypes } from 'lib/types/message-types.js';
import { dbQuery, SQL } from '../database/database.js'; import { dbQuery, SQL } from '../database/database.js';
import { processMessagesInDBForSearch } from '../database/search-utils.js'; import { processMessagesInDBForSearch } from '../database/search-utils.js';
import { updateRolesAndPermissionsForAllThreads } from '../updaters/thread-permission-updaters.js'; import { updateRolesAndPermissionsForAllThreads } from '../updaters/thread-permission-updaters.js';
const migrations: $ReadOnlyMap<number, () => Promise<void>> = new Map([ const migrations: $ReadOnlyMap<number, () => Promise<void>> = new Map([
[ [
0, 0,
▲ Show 20 Lines • Show All 139 Lines • ▼ Show 20 Lines [
async () => { async () => {
await dbQuery( await dbQuery(
SQL` SQL`
ALTER TABLE uploads ALTER TABLE uploads
ADD COLUMN IF NOT EXISTS thread bigint(20) DEFAULT NULL, ADD COLUMN IF NOT EXISTS thread bigint(20) DEFAULT NULL,
ADD INDEX IF NOT EXISTS thread (thread); ADD INDEX IF NOT EXISTS thread (thread);
UPDATE uploads UPDATE uploads
SET thread = ( SET thread = (
SELECT thread FROM messages SELECT thread FROM messages
WHERE messages.id = uploads.container WHERE messages.id = uploads.container
); );
`, `,
{ multipleStatements: true }, { multipleStatements: true },
); );
}, },
], ],
[ [
16, 16,
async () => { async () => {
▲ Show 20 Lines • Show All 171 Lines • ▼ Show 20 Lines async () => {
ADD PRIMARY KEY (id), ADD PRIMARY KEY (id),
ADD UNIQUE KEY (name), ADD UNIQUE KEY (name),
ADD INDEX community_primary (community, \`primary\`); ADD INDEX community_primary (community, \`primary\`);
`, `,
{ multipleStatements: true }, { multipleStatements: true },
); );
}, },
], ],
[
32,
async () => {
await dbQuery(SQL`
UPDATE messages
SET target_message = JSON_VALUE(content, "$.sourceMessageID")
WHERE type = ${messageTypes.SIDEBAR_SOURCE};
`);
},
],
]); ]);
const newDatabaseVersion: number = Math.max(...migrations.keys()); const newDatabaseVersion: number = Math.max(...migrations.keys());
async function writeJSONToFile(data: any, filePath: string): Promise<void> { async function writeJSONToFile(data: any, filePath: string): Promise<void> {
console.warn(`updating ${filePath} to ${JSON.stringify(data)}`); console.warn(`updating ${filePath} to ${JSON.stringify(data)}`);
const fileHandle = await fs.promises.open(filePath, 'w'); const fileHandle = await fs.promises.open(filePath, 'w');
await fileHandle.writeFile(JSON.stringify(data, null, ' '), 'utf8'); await fileHandle.writeFile(JSON.stringify(data, null, ' '), 'utf8');
await fileHandle.close(); await fileHandle.close();
▲ Show 20 Lines • Show All 89 Lines • Show Last 20 Lines
View Options

lib/shared/state-sync/users-state-sync-spec.js

Loading...