11693405968

Committed 05 Nov 2024 10:15PM UTC coverage: 43.367% (-0.3%) from 43.665%

Build # 11693405968

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #9514 from hicommonwealth/ryan/contest-topic-one-one

Remove ContestTopics table + Add Neynar webhook validation

Run Details

979 of 2597 branches covered (37.7%)

Branch coverage included in aggregate %.

21 of 69 new or added lines in 12 files covered. (30.43%)

14 existing lines in 8 files now uncovered.

2133 of 4579 relevant lines covered (46.58%)

22.4 hits per line

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

2.0

/libs/model/src/policies/contest-utils.ts

import { logger } from '@hicommonwealth/core';
import { ContestAction } from '@hicommonwealth/schemas';
import { z } from 'zod';
import { config } from '..';
import { contestHelper } from '../services/commonProtocol';

const log = logger(import.meta);

export async function createOnchainContestContent(payload: {
  contestManagers: Array<{
    url: string;
    contest_address: string;
    actions: Array<z.infer<typeof ContestAction>>;
  }>;
  bypass_quota: boolean;
  content_url: string;
  author_address: string;
}) {
  const addressesToProcess = payload.contestManagers
    .filter((c) => {
      if (payload.bypass_quota) {
        return true;
      }
      // if a projection exists with the same content url, don't add it onchain again
      const duplicatePosts = c.actions.filter(
        (action) =>
          action.action === 'added' &&
          action.content_url === payload.content_url,
      );
      if (duplicatePosts.length > 0) {
        log.warn('createContestContent: duplicate content found by url');
        return false;
      }
      // only process contest managers for which
      // the user has not exceeded the post limit
      // on the latest contest
      const userPostsInContest = c.actions.filter(
        (action) =>
          action.actor_address === payload.author_address &&
          action.action === 'added',
      );
      const quotaReached =
        userPostsInContest.length >= config.CONTESTS.MAX_USER_POSTS_PER_CONTEST;
      if (quotaReached) {
        log.warn(
          `createContestContent: user reached post limit for contest ${c.contest_address}`,
        );
      }
      return !quotaReached;
    })
    .map((c) => c.contest_address);

  log.debug(
    `createContestContent: addresses to process: ${JSON.stringify(
      addressesToProcess,
      null,
      2,
    )}`,
  );

  console.log(JSON.stringify(payload.contestManagers[0]));

  const results = await contestHelper.addContentBatch(
    payload.contestManagers[0].url,
    addressesToProcess,
    payload.author_address!,
    payload.content_url,
  );

  const errors = results
    .filter(({ status }) => status === 'rejected')
    .map(
      (result) =>
        (result as PromiseRejectedResult).reason || '<unknown reason>',
    );

  if (errors.length > 0) {
    throw new Error(`addContent failed with errors: ${errors.join(', ')}"`);
  }
}

export async function createOnchainContestVote(payload: {
  contestManagers: Array<{
    url: string;
    contest_address: string;
    content_id: number;
  }>;
  content_url: string;
  author_address: string;
}) {
  log.debug(
    `createOnchainContestVote: contest managers to process: ${JSON.stringify(
      payload.contestManagers,
      null,
      2,
    )}`,
  );

  const results = await contestHelper.voteContentBatch(
    payload.contestManagers[0].url,
    payload.author_address,
    payload.contestManagers.map((m) => ({
      contestAddress: m.contest_address,
      contentId: m.content_id.toString(),
    })),
  );

  const errors = results
    .filter(({ status }) => status === 'rejected')
    .map(
      (result) =>
        (result as PromiseRejectedResult).reason || '<unknown reason>',
    );

  if (errors.length > 0) {
    throw new Error(
      `voteContent failed ${errors.length} times: ${errors.join(', ')}"`,
    );
  }
}

1	import { logger } from '@hicommonwealth/core';
2	import { ContestAction } from '@hicommonwealth/schemas';
3	import { z } from 'zod';
4	import { config } from '..';
5	import { contestHelper } from '../services/commonProtocol';
6
7	const log = logger(import.meta);	21✔
8
9	export async function createOnchainContestContent(payload: {
10	contestManagers: Array<{
11	url: string;
12	contest_address: string;
13	actions: Array<z.infer<typeof ContestAction>>;
14	}>;
15	bypass_quota: boolean;
16	content_url: string;
17	author_address: string;
18	}) {
NEW 19	const addressesToProcess = payload.contestManagers	×
20	.filter((c) => {
NEW 21	if (payload.bypass_quota) {	×
NEW 22	return true;	×
23	}
24	// if a projection exists with the same content url, don't add it onchain again
25	const duplicatePosts = c.actions.filter(	×
26	(action) =>
27	action.action === 'added' &&	×
28	action.content_url === payload.content_url,
29	);
30	if (duplicatePosts.length > 0) {	×
31	log.warn('createContestContent: duplicate content found by url');	×
32	return false;	×
33	}
34	// only process contest managers for which
35	// the user has not exceeded the post limit
36	// on the latest contest
37	const userPostsInContest = c.actions.filter(	×
38	(action) =>
39	action.actor_address === payload.author_address &&	×
40	action.action === 'added',
41	);
42	const quotaReached =
43	userPostsInContest.length >= config.CONTESTS.MAX_USER_POSTS_PER_CONTEST;	×
44	if (quotaReached) {	×
45	log.warn(	×
46	`createContestContent: user reached post limit for contest ${c.contest_address}`,
47	);
48	}
49	return !quotaReached;	×
50	})
51	.map((c) => c.contest_address);	×
52
53	log.debug(	×
54	`createContestContent: addresses to process: ${JSON.stringify(
55	addressesToProcess,
56	null,
57	2,
58	)}`,
59	);
60
NEW 61	console.log(JSON.stringify(payload.contestManagers[0]));	×
62
UNCOV 63	const results = await contestHelper.addContentBatch(	×
64	payload.contestManagers[0].url,
65	addressesToProcess,
66	payload.author_address!,
67	payload.content_url,
68	);
69
70	const errors = results	×
71	.filter(({ status }) => status === 'rejected')	×
72	.map(
73	(result) =>
74	(result as PromiseRejectedResult).reason \|\| '<unknown reason>',	×
75	);
76
77	if (errors.length > 0) {	×
UNCOV 78	throw new Error(`addContent failed with errors: ${errors.join(', ')}"`);	×
79	}
80	}
81
82	export async function createOnchainContestVote(payload: {
83	contestManagers: Array<{
84	url: string;
85	contest_address: string;
86	content_id: number;
87	}>;
88	content_url: string;
89	author_address: string;
90	}) {
UNCOV 91	log.debug(	×
92	`createOnchainContestVote: contest managers to process: ${JSON.stringify(
93	payload.contestManagers,
94	null,
95	2,
96	)}`,
97	);
98
99	const results = await contestHelper.voteContentBatch(	×
100	payload.contestManagers[0].url,
101	payload.author_address,
NEW 102	payload.contestManagers.map((m) => ({	×
103	contestAddress: m.contest_address,
104	contentId: m.content_id.toString(),
105	})),
106	);
107
108	const errors = results	×
109	.filter(({ status }) => status === 'rejected')	×
110	.map(
111	(result) =>
112	(result as PromiseRejectedResult).reason \|\| '<unknown reason>',	×
113	);
114
115	if (errors.length > 0) {	×
116	throw new Error(	×
117	`voteContent failed ${errors.length} times: ${errors.join(', ')}"`,
118	);
119	}
120	}

hicommonwealth / commonwealth / 11693405968

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