9567721967

Committed 18 Jun 2024 03:16PM UTC coverage: 8.328% (-4.5%) from 12.845%

Build # 9567721967

Build Type

Pull #8041

github

Committed by

web-flow

Commit Message

Merge 66793418f into a9b530a5c

Pull Request Pull Request #8041: Refactor version history (PART 1/2)

Run Details

1925 of 24425 branches covered (7.88%)

Branch coverage included in aggregate %.

7 of 76 new or added lines in 9 files covered. (9.21%)

2190 existing lines in 243 files now uncovered.

2997 of 34675 relevant lines covered (8.64%)

2.07 hits per line

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

6.67

/packages/commonwealth/server/workers/cosmosGovNotifications/proposalFetching/allProposalFetching.ts

import { logger } from '@hicommonwealth/core';
import { CommunityInstance } from '@hicommonwealth/model';
import { fileURLToPath } from 'url';
import { AllCosmosProposals } from './types';
import {
  filterV1GovCommunities,
  mapCommunitiesToProposals,
  processProposalSettledPromises,
} from './util';
import {
  fetchLatestCosmosProposalV1Beta1,
  fetchUpToLatestCosmosProposalV1Beta1,
} from './v1Beta1ProposalFetching';
import {
  fetchLatestCosmosProposalV1,
  fetchUpToLatestCosmosProposalV1,
} from './v1ProposalFetching';

const __filename = fileURLToPath(import.meta.url);
const log = logger(__filename);

/**
 * Fetches all proposals from the given proposal ids to the latest proposal for each community. Works for both v1 and
 * v1beta1 gov modules.
 */
export async function fetchUpToLatestCosmosProposals(
  communities: CommunityInstance[],
  latestProposalIds: Record<string, number>,
): Promise<AllCosmosProposals> {
  if (communities.length === 0) return { v1: {}, v1Beta1: {} };

  const { v1Communities, v1Beta1Communities } = await filterV1GovCommunities(
    communities,
  );
  log.info(
    `Fetching up to the latest proposals from ${JSON.stringify(
      // @ts-expect-error StrictNullChecks
      v1Communities.map((c) => c.id),
    )} v1 gov communities` +
      ` and ${JSON.stringify(
        // @ts-expect-error StrictNullChecks
        v1Beta1Communities.map((c) => c.id),
      )} v1beta1 gov communities`,
  );

  const [v1ProposalResults, v1BetaProposalResults] = await Promise.all([
    Promise.allSettled(
      v1Communities.map((c) =>
        // @ts-expect-error StrictNullChecks
        fetchUpToLatestCosmosProposalV1(latestProposalIds[c.id] + 1, c),
      ),
    ),
    Promise.allSettled(
      v1Beta1Communities.map((c) =>
        // @ts-expect-error StrictNullChecks
        fetchUpToLatestCosmosProposalV1Beta1(latestProposalIds[c.id] + 1, c),
      ),
    ),
  ]);

  const { v1Proposals, v1Beta1Proposals } = processProposalSettledPromises(
    v1ProposalResults,
    v1BetaProposalResults,
  );

  return mapCommunitiesToProposals(
    v1Communities,
    v1Beta1Communities,
    v1Proposals,
    v1Beta1Proposals,
  );
}

/**
 * Fetches the last/latest proposal for each chain. Works for both v1 and v1beta1 gov modules.
 */
export async function fetchLatestProposals(
  chains: CommunityInstance[],
): Promise<AllCosmosProposals> {
  if (chains.length === 0) return { v1: {}, v1Beta1: {} };

  const { v1Communities, v1Beta1Communities } = await filterV1GovCommunities(
    chains,
  );
  log.info(
    `Fetching the latest proposals from ${JSON.stringify(
      // @ts-expect-error StrictNullChecks
      v1Communities.map((c) => c.id),
    )} v1 gov chains` +
      ` and ${JSON.stringify(
        // @ts-expect-error StrictNullChecks
        v1Beta1Communities.map((c) => c.id),
      )} v1beta1 gov chains`,
  );
  const [v1ProposalResults, v1Beta1ProposalResults] = await Promise.all([
    Promise.allSettled(
      v1Communities.map((c) => fetchLatestCosmosProposalV1(c)),
    ),
    Promise.allSettled(
      v1Beta1Communities.map((c) => fetchLatestCosmosProposalV1Beta1(c)),
    ),
  ]);

  const { v1Proposals, v1Beta1Proposals } = processProposalSettledPromises(
    v1ProposalResults,
    v1Beta1ProposalResults,
  );

  return mapCommunitiesToProposals(
    v1Communities,
    v1Beta1Communities,
    v1Proposals,
    v1Beta1Proposals,
  );
}

1	import { logger } from '@hicommonwealth/core';
2	import { CommunityInstance } from '@hicommonwealth/model';
3	import { fileURLToPath } from 'url';
4	import { AllCosmosProposals } from './types';
5	import {
6	filterV1GovCommunities,
7	mapCommunitiesToProposals,
8	processProposalSettledPromises,
9	} from './util';
10	import {
11	fetchLatestCosmosProposalV1Beta1,
12	fetchUpToLatestCosmosProposalV1Beta1,
13	} from './v1Beta1ProposalFetching';
14	import {
15	fetchLatestCosmosProposalV1,
16	fetchUpToLatestCosmosProposalV1,
17	} from './v1ProposalFetching';
18
19	const __filename = fileURLToPath(import.meta.url);	1✔
20	const log = logger(__filename);	1✔
21
22	/**
23	* Fetches all proposals from the given proposal ids to the latest proposal for each community. Works for both v1 and
24	* v1beta1 gov modules.
25	*/
26	export async function fetchUpToLatestCosmosProposals(
27	communities: CommunityInstance[],
28	latestProposalIds: Record<string, number>,
29	): Promise<AllCosmosProposals> {
UNCOV 30	if (communities.length === 0) return { v1: {}, v1Beta1: {} };	×
31
UNCOV 32	const { v1Communities, v1Beta1Communities } = await filterV1GovCommunities(	×
33	communities,
34	);
UNCOV 35	log.info(	×
36	`Fetching up to the latest proposals from ${JSON.stringify(
37	// @ts-expect-error StrictNullChecks
UNCOV 38	v1Communities.map((c) => c.id),	×
39	)} v1 gov communities` +
40	` and ${JSON.stringify(
41	// @ts-expect-error StrictNullChecks
UNCOV 42	v1Beta1Communities.map((c) => c.id),	×
43	)} v1beta1 gov communities`,
44	);
45
UNCOV 46	const [v1ProposalResults, v1BetaProposalResults] = await Promise.all([	×
47	Promise.allSettled(
48	v1Communities.map((c) =>
49	// @ts-expect-error StrictNullChecks
UNCOV 50	fetchUpToLatestCosmosProposalV1(latestProposalIds[c.id] + 1, c),	×
51	),
52	),
53	Promise.allSettled(
54	v1Beta1Communities.map((c) =>
55	// @ts-expect-error StrictNullChecks
UNCOV 56	fetchUpToLatestCosmosProposalV1Beta1(latestProposalIds[c.id] + 1, c),	×
57	),
58	),
59	]);
60
UNCOV 61	const { v1Proposals, v1Beta1Proposals } = processProposalSettledPromises(	×
62	v1ProposalResults,
63	v1BetaProposalResults,
64	);
65
UNCOV 66	return mapCommunitiesToProposals(	×
67	v1Communities,
68	v1Beta1Communities,
69	v1Proposals,
70	v1Beta1Proposals,
71	);
72	}
73
74	/**
75	* Fetches the last/latest proposal for each chain. Works for both v1 and v1beta1 gov modules.
76	*/
77	export async function fetchLatestProposals(
78	chains: CommunityInstance[],
79	): Promise<AllCosmosProposals> {
UNCOV 80	if (chains.length === 0) return { v1: {}, v1Beta1: {} };	×
81
UNCOV 82	const { v1Communities, v1Beta1Communities } = await filterV1GovCommunities(	×
83	chains,
84	);
UNCOV 85	log.info(	×
86	`Fetching the latest proposals from ${JSON.stringify(
87	// @ts-expect-error StrictNullChecks
UNCOV 88	v1Communities.map((c) => c.id),	×
89	)} v1 gov chains` +
90	` and ${JSON.stringify(
91	// @ts-expect-error StrictNullChecks
UNCOV 92	v1Beta1Communities.map((c) => c.id),	×
93	)} v1beta1 gov chains`,
94	);
UNCOV 95	const [v1ProposalResults, v1Beta1ProposalResults] = await Promise.all([	×
96	Promise.allSettled(
UNCOV 97	v1Communities.map((c) => fetchLatestCosmosProposalV1(c)),	×
98	),
99	Promise.allSettled(
UNCOV 100	v1Beta1Communities.map((c) => fetchLatestCosmosProposalV1Beta1(c)),	×
101	),
102	]);
103
UNCOV 104	const { v1Proposals, v1Beta1Proposals } = processProposalSettledPromises(	×
105	v1ProposalResults,
106	v1Beta1ProposalResults,
107	);
108
UNCOV 109	return mapCommunitiesToProposals(	×
110	v1Communities,
111	v1Beta1Communities,
112	v1Proposals,
113	v1Beta1Proposals,
114	);
115	}

hicommonwealth / commonwealth / 9567721967

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