10095196965

Committed 25 Jul 2024 01:37PM UTC coverage: 31.846% (-0.01%) from 31.858%

Build # 10095196965

Build Type

Pull #9521

github

Committed by

oetherington

Commit Message

Fix playwright test selectors

Pull Request Pull Request #9521: Crossposting e2e tests

Run Details

4903 of 40265 branches covered (12.18%)

Branch coverage included in aggregate %.

3 of 5 new or added lines in 2 files covered. (60.0%)

1124 existing lines in 63 files now uncovered.

28607 of 64961 relevant lines covered (44.04%)

180.2 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

31.25

/packages/lesswrong/server/search/elastic/elasticCallbacks.ts

import {
  SearchIndexCollectionName,
  searchIndexedCollectionNames,
} from "../../../lib/search/searchUtil";
import { getCollectionHooks } from "../../mutationCallbacks";
import { UsersRepo } from "../../repos";
import ElasticClient from "./ElasticClient";
import ElasticExporter from "./ElasticExporter";
import { isElasticEnabled } from "./elasticSettings";

export const elasticSyncDocument = (
  collectionName: SearchIndexCollectionName,
  documentId: string,
) => {
  try {
    const client = new ElasticClient();
    const exporter = new ElasticExporter(client);
    void exporter.updateDocument(collectionName, documentId);
  } catch (e) {
    // eslint-disable-next-line no-console
    console.error(`[${collectionName}] Failed to index Elasticsearch document:`, e);
  }
}

if (isElasticEnabled) {
  for (const collectionName of searchIndexedCollectionNames) {
    const callback = ({_id}: DbObject) => elasticSyncDocument(collectionName, _id);
    getCollectionHooks(collectionName).createAfter.add(callback);
    getCollectionHooks(collectionName).updateAfter.add(callback);
  }

  getCollectionHooks("Users").editAsync.add(async function reindexDeletedUserContent(
    newUser: DbUser,
    oldUser: DbUser,
  ) {
    if (!!newUser.deleted !== !!oldUser.deleted) {
      const repo = new UsersRepo();
      const [
        postIds,
        commentIds,
        sequenceIds,
      ] = await Promise.all([
        repo.getAllUserPostIds(newUser._id),
        repo.getAllUserCommentIds(newUser._id),
        repo.getAllUserSequenceIds(newUser._id),
      ]);

      const client = new ElasticClient();
      const exporter = new ElasticExporter(client);
      await Promise.all([
        ...postIds.map((id) => exporter.updateDocument("Posts", id)),
        ...commentIds.map((id) => exporter.updateDocument("Comments", id)),
        ...sequenceIds.map((id) => exporter.updateDocument("Sequences", id)),
      ]);
    }
  });
}

1	import {	54✔
2	SearchIndexCollectionName,
3	searchIndexedCollectionNames,
4	} from "../../../lib/search/searchUtil";	18✔
5	import { getCollectionHooks } from "../../mutationCallbacks";	18✔
6	import { UsersRepo } from "../../repos";	18✔
7	import ElasticClient from "./ElasticClient";	18✔
8	import ElasticExporter from "./ElasticExporter";	18✔
9	import { isElasticEnabled } from "./elasticSettings";	18✔
10
11	export const elasticSyncDocument = (	18✔
12	collectionName: SearchIndexCollectionName,
13	documentId: string,
14	) => {
UNCOV 15	try {	×
UNCOV 16	const client = new ElasticClient();	×
17	const exporter = new ElasticExporter(client);	×
18	void exporter.updateDocument(collectionName, documentId);	×
19	} catch (e) {
20	// eslint-disable-next-line no-console
UNCOV 21	console.error(`[${collectionName}] Failed to index Elasticsearch document:`, e);	×
22	}
23	}
24
25	if (isElasticEnabled) {	18!
UNCOV 26	for (const collectionName of searchIndexedCollectionNames) {	×
UNCOV 27	const callback = ({_id}: DbObject) => elasticSyncDocument(collectionName, _id);	×
UNCOV 28	getCollectionHooks(collectionName).createAfter.add(callback);	×
UNCOV 29	getCollectionHooks(collectionName).updateAfter.add(callback);	×
30	}
31
32	getCollectionHooks("Users").editAsync.add(async function reindexDeletedUserContent(	×
33	newUser: DbUser,
34	oldUser: DbUser,
35	) {
36	if (!!newUser.deleted !== !!oldUser.deleted) {	×
UNCOV 37	const repo = new UsersRepo();	×
38	const [
39	postIds,
40	commentIds,
41	sequenceIds,
UNCOV 42	] = await Promise.all([	×
43	repo.getAllUserPostIds(newUser._id),
44	repo.getAllUserCommentIds(newUser._id),
45	repo.getAllUserSequenceIds(newUser._id),
46	]);
47
UNCOV 48	const client = new ElasticClient();	×
UNCOV 49	const exporter = new ElasticExporter(client);	×
UNCOV 50	await Promise.all([	×
UNCOV 51	...postIds.map((id) => exporter.updateDocument("Posts", id)),	×
52	...commentIds.map((id) => exporter.updateDocument("Comments", id)),	×
53	...sequenceIds.map((id) => exporter.updateDocument("Sequences", id)),	×
54	]);
55	}
56	});
57	}

ForumMagnum / ForumMagnum / 10095196965

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous