9551559677

Committed 17 Jun 2024 04:48PM UTC coverage: 12.844% (-0.001%) from 12.845%

Build # 9551559677

Build Type

Pull #8138

github

Committed by

web-flow

Commit Message

Merge e96dfe1ab into ea44a68a7

Pull Request Pull Request #8138: Contest rollover fix

Run Details

3843 of 35372 branches covered (10.86%)

Branch coverage included in aggregate %.

4 of 36 new or added lines in 5 files covered. (11.11%)

6 existing lines in 3 files now uncovered.

5187 of 34935 relevant lines covered (14.85%)

4.79 hits per line

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

57.14

/libs/model/src/contest/GetAllContests.query.ts

import { Query, logger } from '@hicommonwealth/core';
import * as schemas from '@hicommonwealth/schemas';
import { QueryTypes } from 'sequelize';
import { fileURLToPath } from 'url';
import { z } from 'zod';
import { models } from '../database';
import { rollOverContest } from '../services/commonProtocol/contestHelper';

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

// TODO: replace with proper scheduled solution
// find community contests that are ended and trigger rollover
export async function performContestRollovers() {
  const contestManagersWithEndedContest = await models.sequelize.query<{
    contest_address: string;
    interval: number;
    url: string;
  }>(
    `
    SELECT cm.contest_address, cm.interval, co.contest_id, co.end_time, COALESCE(cn.private_url, cn.url) as url
    FROM "ContestManagers" cm
    JOIN (
        SELECT *
        FROM "Contests"
        WHERE (contest_address, contest_id) IN (
            SELECT contest_address, MAX(contest_id) AS contest_id
            FROM "Contests"
            GROUP BY contest_address
        )
    ) co ON co.contest_address = cm.contest_address AND NOW() > co.end_time
    JOIN "Communities" cu ON cm.community_id = cu.id
    JOIN "ChainNodes" cn ON cu.chain_node_id = cn.id;
  `,
    {
      type: QueryTypes.SELECT,
      raw: true,
    },
  );

  const contestRolloverPromises = contestManagersWithEndedContest.map(
    async ({ url, contest_address, interval }) => {
      log.debug(`ROLLOVER: ${contest_address}`);
      return rollOverContest(url, contest_address, interval === 0);
    },
  );

  const promiseResults = await Promise.allSettled(contestRolloverPromises);

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

  if (errors.length > 0) {
    log.warn(
      `GetAllContests performContestRollovers: failed with errors: ${errors.join(
        ', ',
      )}"`,
    );
  }
}

export function GetAllContests(): Query<typeof schemas.GetAllContests> {
  return {
    ...schemas.GetAllContests,
    auth: [],
    secure: false,
    body: async ({ payload }) => {
      const results = await models.sequelize.query<
        z.infer<typeof schemas.ContestResults>
      >(
        `
select
  cm.community_id,
  cm.contest_address,
  cm.interval,
  cm.ticker,
  cm.decimals,
  cm.created_at,
  cm.name,
  cm.image_url,
  cm.funding_token_address,
  cm.prize_percentage,
  cm.payout_structure,
  cm.cancelled,
  coalesce((
    select jsonb_agg(json_build_object('id', t.id, 'name', t.name) order by t.name)
    from "ContestTopics" ct
    left join "Topics" t on ct.topic_id = t.id
    where cm.contest_address = ct.contest_address
  ), '[]'::jsonb) as topics,
  coalesce(c.contests, '[]'::jsonb) as contests
from
"ContestManagers" cm left join (
        select
          c.contest_address,
    jsonb_agg(json_build_object(
      'contest_id', c.contest_id,
      'start_time', c.start_time,
      'end_time', c.end_time,
      'score_updated_at', c.score_updated_at,
      'score', c.score --,
--      'actions', coalesce(ca.actions, '[]'::jsonb)
                ) order by c.contest_id desc) as contests
        from "Contests" c
--    left join (
--      select
--        a.contest_id,
--        jsonb_agg(jsonb_build_object(
--          'content_id', a.content_id,
--          'actor_address', a.actor_address,
--          'action', a.action,
--          'content_url', a.content_url,
--          'thread_id', a.thread_id,
--          'thread_title', tr.title,
--          'voting_power', a.voting_power,
--          'created_at', a.created_at
--        ) order by a.created_at) as actions
--      from "ContestActions" a left join "Threads" tr on a.thread_id = tr.id
--      group by a.contest_id
--    ) as ca on c.contest_id = ca.contest_id
    ${payload.contest_id ? `where c.contest_id = ${payload.contest_id}` : ''}
          group by c.contest_address
  ) as c on cm.contest_address = c.contest_address
where
  cm.community_id = :community_id
  ${
    payload.contest_address
      ? `and cm.contest_address = '${payload.contest_address}'`
      : ''
  }
group by
  cm.community_id,
  cm.contest_address,
  cm.interval,
  cm.ticker,
  cm.decimals,
  cm.created_at,
  cm.name,
  cm.image_url,
  cm.funding_token_address,
  cm.prize_percentage,
  cm.payout_structure,
  cm.cancelled,
  c.contests
order by
  cm.name;
`,
        {
          type: QueryTypes.SELECT,
          raw: true,
          replacements: { community_id: payload.community_id },
        },
      );
      results.forEach((r) =>
        r.contests.forEach((c) => {
          c.score?.forEach((w) => {
            w.tickerPrize = Number(w.prize) / 10 ** r.decimals;
          });
          c.start_time = new Date(c.start_time);
          c.end_time = new Date(c.end_time);
          c.score_updated_at =
            c.score_updated_at && new Date(c.score_updated_at);
          // c.actions.forEach((a) => (a.created_at = new Date(a.created_at)));
        }),
      );

      return results;
    },
  };
}

1	import { Query, logger } from '@hicommonwealth/core';
2	import * as schemas from '@hicommonwealth/schemas';
3	import { QueryTypes } from 'sequelize';
4	import { fileURLToPath } from 'url';
5	import { z } from 'zod';
6	import { models } from '../database';
7	import { rollOverContest } from '../services/commonProtocol/contestHelper';
8
9	const __filename = fileURLToPath(import.meta.url);	12✔
10	const log = logger(__filename);	12✔
11
12	// TODO: replace with proper scheduled solution
13	// find community contests that are ended and trigger rollover
14	export async function performContestRollovers() {
NEW 15	const contestManagersWithEndedContest = await models.sequelize.query<{	×
16	contest_address: string;
17	interval: number;
18	url: string;
19	}>(
20	`
21	SELECT cm.contest_address, cm.interval, co.contest_id, co.end_time, COALESCE(cn.private_url, cn.url) as url
22	FROM "ContestManagers" cm
23	JOIN (
24	SELECT *
25	FROM "Contests"
26	WHERE (contest_address, contest_id) IN (
27	SELECT contest_address, MAX(contest_id) AS contest_id
28	FROM "Contests"
29	GROUP BY contest_address
30	)
31	) co ON co.contest_address = cm.contest_address AND NOW() > co.end_time
32	JOIN "Communities" cu ON cm.community_id = cu.id
33	JOIN "ChainNodes" cn ON cu.chain_node_id = cn.id;
34	`,
35	{
36	type: QueryTypes.SELECT,
37	raw: true,
38	},
39	);
40
NEW 41	const contestRolloverPromises = contestManagersWithEndedContest.map(	×
42	async ({ url, contest_address, interval }) => {
NEW 43	log.debug(`ROLLOVER: ${contest_address}`);	×
NEW 44	return rollOverContest(url, contest_address, interval === 0);	×
45	},
46	);
47
NEW 48	const promiseResults = await Promise.allSettled(contestRolloverPromises);	×
49
NEW 50	const errors = promiseResults	×
NEW 51	.filter(({ status }) => status === 'rejected')	×
52	.map(
53	(result) =>
NEW 54	(result as PromiseRejectedResult).reason \|\| '<unknown reason>',	×
55	);
56
NEW 57	if (errors.length > 0) {	×
NEW 58	log.warn(	×
59	`GetAllContests performContestRollovers: failed with errors: ${errors.join(
60	', ',
61	)}"`,
62	);
63	}
64	}
65
66	export function GetAllContests(): Query<typeof schemas.GetAllContests> {
67	return {	2✔
68	...schemas.GetAllContests,
69	auth: [],
70	secure: false,
71	body: async ({ payload }) => {
72	const results = await models.sequelize.query<	2✔
73	z.infer<typeof schemas.ContestResults>
74	>(
75	`
76	select
77	cm.community_id,
78	cm.contest_address,
79	cm.interval,
80	cm.ticker,
81	cm.decimals,
82	cm.created_at,
83	cm.name,
84	cm.image_url,
85	cm.funding_token_address,
86	cm.prize_percentage,
87	cm.payout_structure,
88	cm.cancelled,
89	coalesce((
90	select jsonb_agg(json_build_object('id', t.id, 'name', t.name) order by t.name)
91	from "ContestTopics" ct
92	left join "Topics" t on ct.topic_id = t.id
93	where cm.contest_address = ct.contest_address
94	), '[]'::jsonb) as topics,
95	coalesce(c.contests, '[]'::jsonb) as contests
96	from
97	"ContestManagers" cm left join (
98	select
99	c.contest_address,
100	jsonb_agg(json_build_object(
101	'contest_id', c.contest_id,
102	'start_time', c.start_time,
103	'end_time', c.end_time,
104	'score_updated_at', c.score_updated_at,
105	'score', c.score --,
106	-- 'actions', coalesce(ca.actions, '[]'::jsonb)
107	) order by c.contest_id desc) as contests
108	from "Contests" c
109	-- left join (
110	-- select
111	-- a.contest_id,
112	-- jsonb_agg(jsonb_build_object(
113	-- 'content_id', a.content_id,
114	-- 'actor_address', a.actor_address,
115	-- 'action', a.action,
116	-- 'content_url', a.content_url,
117	-- 'thread_id', a.thread_id,
118	-- 'thread_title', tr.title,
119	-- 'voting_power', a.voting_power,
120	-- 'created_at', a.created_at
121	-- ) order by a.created_at) as actions
122	-- from "ContestActions" a left join "Threads" tr on a.thread_id = tr.id
123	-- group by a.contest_id
124	-- ) as ca on c.contest_id = ca.contest_id
125	${payload.contest_id ? `where c.contest_id = ${payload.contest_id}` : ''}	4✔
126	group by c.contest_address
127	) as c on cm.contest_address = c.contest_address
128	where
129	cm.community_id = :community_id
130	${
131	payload.contest_address	4✔
132	? `and cm.contest_address = '${payload.contest_address}'`
133	: ''
134	}
135	group by
136	cm.community_id,
137	cm.contest_address,
138	cm.interval,
139	cm.ticker,
140	cm.decimals,
141	cm.created_at,
142	cm.name,
143	cm.image_url,
144	cm.funding_token_address,
145	cm.prize_percentage,
146	cm.payout_structure,
147	cm.cancelled,
148	c.contests
149	order by
150	cm.name;
151	`,
152	{
153	type: QueryTypes.SELECT,
154	raw: true,
155	replacements: { community_id: payload.community_id },
156	},
157	);
158	results.forEach((r) =>	2✔
159	r.contests.forEach((c) => {	3✔
160	c.score?.forEach((w) => {	5✔
161	w.tickerPrize = Number(w.prize) / 10 ** r.decimals;	6✔
162	});
163	c.start_time = new Date(c.start_time);	5✔
164	c.end_time = new Date(c.end_time);	5✔
165	c.score_updated_at =	5✔
166	c.score_updated_at && new Date(c.score_updated_at);	16✔
167	// c.actions.forEach((a) => (a.created_at = new Date(a.created_at)));
168	}),
169	);
170
171	return results;	2✔
172	},
173	};
174	}

hicommonwealth / commonwealth / 9551559677

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