10884794182

Committed 16 Sep 2024 01:25PM UTC coverage: 13.691% (-0.02%) from 13.711%

Build # 10884794182

Build Type

Pull #9226

github

Committed by

web-flow

Commit Message

Merge be309cbb8 into 889a63dbc

Pull Request Pull Request #9226: Multi-Adapter Ports

Run Details

3031 of 20612 branches covered (14.71%)

Branch coverage included in aggregate %.

5 of 63 new or added lines in 12 files covered. (7.94%)

75 existing lines in 10 files now uncovered.

3966 of 30495 relevant lines covered (13.01%)

3.92 hits per line

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

0.0

/packages/commonwealth/scripts/refresh-all-memberships.ts

import { RedisCache } from '@hicommonwealth/adapters';
import { cache, dispose, logger, query } from '@hicommonwealth/core';
import { Community, models } from '@hicommonwealth/model';
import { config } from '../server/config';
import { ServerGroupsController } from '../server/controllers/server_groups_controller';

const log = logger(import.meta);

async function main() {
  config.CACHE.REDIS_URL &&
    cache({
      adapter: new RedisCache(config.CACHE.REDIS_URL),
      isDefault: true,
    });

  const groupsController = new ServerGroupsController(models);

  // fetch all communities via pagination
  const limit = 50;
  let cursor = 1;
  const communitiesResult = await query(Community.GetCommunities(), {
    // no need for an actor, but argument is mandatory
    actor: { user: { email: '' } },
    payload: { has_groups: true, cursor, limit },
  });
  const totalPages = communitiesResult!.totalPages;
  const communities = communitiesResult!.results;
  while (cursor < totalPages) {
    cursor += 1;
    const cr = await query(Community.GetCommunities(), {
      actor: { user: { email: '' } },
      payload: { has_groups: true, cursor, limit },
    });
    communities.push(...cr!.results);
  }

  // refresh memberships on all fetched communities
  for (const community of communities) {
    if (process.env.COMMUNITY_ID && process.env.COMMUNITY_ID !== community.id)
      continue;
    await groupsController.refreshCommunityMemberships({
      communityId: community.id,
    });
  }

  log.info(
    `done- refreshed ${
      process.env.COMMUNITY_ID ? 1 : communities.length
    } communities`,
  );
}

main()
  .then(
    async () =>
      // eslint-disable-next-line @typescript-eslint/no-floating-promises
      await dispose()('EXIT', true),
  )
  .catch((err) => {
    log.error('Failed to refresh all membership', err);
    // eslint-disable-next-line @typescript-eslint/no-floating-promises
    dispose()('ERROR', true);
  });

1	import { RedisCache } from '@hicommonwealth/adapters';
2	import { cache, dispose, logger, query } from '@hicommonwealth/core';
3	import { Community, models } from '@hicommonwealth/model';
4	import { config } from '../server/config';
5	import { ServerGroupsController } from '../server/controllers/server_groups_controller';
6
7	const log = logger(import.meta);	×
8
9	async function main() {
NEW 10	config.CACHE.REDIS_URL &&	×
11	cache({
12	adapter: new RedisCache(config.CACHE.REDIS_URL),
13	isDefault: true,
14	});
15
16	const groupsController = new ServerGroupsController(models);	×
17
18	// fetch all communities via pagination
19	const limit = 50;	×
20	let cursor = 1;	×
21	const communitiesResult = await query(Community.GetCommunities(), {	×
22	// no need for an actor, but argument is mandatory
23	actor: { user: { email: '' } },
24	payload: { has_groups: true, cursor, limit },
25	});
26	const totalPages = communitiesResult!.totalPages;	×
27	const communities = communitiesResult!.results;	×
28	while (cursor < totalPages) {	×
29	cursor += 1;	×
30	const cr = await query(Community.GetCommunities(), {	×
31	actor: { user: { email: '' } },
32	payload: { has_groups: true, cursor, limit },
33	});
34	communities.push(...cr!.results);	×
35	}
36
37	// refresh memberships on all fetched communities
38	for (const community of communities) {	×
39	if (process.env.COMMUNITY_ID && process.env.COMMUNITY_ID !== community.id)	×
40	continue;	×
41	await groupsController.refreshCommunityMemberships({	×
42	communityId: community.id,
43	});
44	}
45
46	log.info(	×
47	`done- refreshed ${
48	process.env.COMMUNITY_ID ? 1 : communities.length	×
49	} communities`,
50	);
51	}
52
53	main()	×
54	.then(
55	async () =>
56	// eslint-disable-next-line @typescript-eslint/no-floating-promises
57	await dispose()('EXIT', true),	×
58	)
59	.catch((err) => {
60	log.error('Failed to refresh all membership', err);	×
61	// eslint-disable-next-line @typescript-eslint/no-floating-promises
62	dispose()('ERROR', true);	×
63	});

hicommonwealth / commonwealth / 10884794182

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