10454888333

Committed 19 Aug 2024 02:04PM UTC coverage: 15.247% (-0.2%) from 15.445%

Build # 10454888333

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #8799 from hicommonwealth/marcin/farcaster-init

Farcaster frames initial setup

Run Details

3506 of 21395 branches covered (16.39%)

Branch coverage included in aggregate %.

17 of 34 new or added lines in 9 files covered. (50.0%)

82 existing lines in 6 files now uncovered.

4514 of 31207 relevant lines covered (14.46%)

5.32 hits per line

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

0.0

/packages/commonwealth/scripts/async-migrate-comment-version-history.ts

//TODO: This should be deleted after comment version histories are fixed
import { dispose } from '@hicommonwealth/core';
import { CommentVersionHistoryInstance, models } from '@hicommonwealth/model';
import { QueryTypes } from 'sequelize';

async function run() {
  const commentCount = (
    await models.sequelize.query(
      `SELECT COUNT(*) FROM "Comments" WHERE version_history_updated = false`,
      {
        raw: true,
        type: QueryTypes.SELECT,
      },
    )
  )[0];

  const count = parseInt(commentCount['count']);
  let i = 0;
  while (i < count) {
    try {
      await models.sequelize.transaction(async (transaction) => {
        const commentVersionHistory: {
          id: number;
          versionHistories: { timestamp: string; body: string }[];
        }[] = (
          await models.sequelize.query(
            `SELECT id, version_history FROM "Comments" where version_history_updated = false
             FOR UPDATE SKIP LOCKED LIMIT 1`,
            {
              raw: true,
              type: QueryTypes.SELECT,
              transaction,
            },
          )
        ).map((c) => ({
          id: parseInt(c['id']),
          versionHistories: c['version_history'].map((v) => JSON.parse(v)),
        }));

        if (commentVersionHistory.length === 0) {
          return;
        }

        for (const versionHistory of commentVersionHistory) {
          console.log(
            `${i}/${count} Updating comment version_histories for id ${versionHistory.id}`,
          );

          const formattedValues = versionHistory.versionHistories.map((v) => {
            const { body, ...rest } = v;
            return {
              comment_id: versionHistory.id,
              ...rest,
              text: body,
            };
          }) as unknown as CommentVersionHistoryInstance[];

          await models.sequelize.query(
            `UPDATE "Comments" SET version_history_updated = true WHERE id = $id`,
            {
              bind: { id: versionHistory.id },
              transaction,
            },
          );
          return await models.CommentVersionHistory.bulkCreate(
            formattedValues,
            {
              transaction,
            },
          );
        }
      });
    } catch (error) {
      console.error('Error:', error.message);
      throw error;
    }

    i += 1;
  }

  console.log('Finished migration');
}

run()
  .then(() => {
    void dispose()('EXIT', true);
  })
  .catch((error) => {
    console.error('Failed to migrate community counts:', error);
  });

1	//TODO: This should be deleted after comment version histories are fixed
2	import { dispose } from '@hicommonwealth/core';
3	import { CommentVersionHistoryInstance, models } from '@hicommonwealth/model';
4	import { QueryTypes } from 'sequelize';
5
6	async function run() {
7	const commentCount = (	×
8	await models.sequelize.query(
9	`SELECT COUNT(*) FROM "Comments" WHERE version_history_updated = false`,
10	{
11	raw: true,
12	type: QueryTypes.SELECT,
13	},
14	)
15	)[0];
16
17	const count = parseInt(commentCount['count']);	×
18	let i = 0;	×
19	while (i < count) {	×
20	try {	×
21	await models.sequelize.transaction(async (transaction) => {	×
22	const commentVersionHistory: {	×
23	id: number;
24	versionHistories: { timestamp: string; body: string }[];
UNCOV 25	}[] = (	×
26	await models.sequelize.query(
27	`SELECT id, version_history FROM "Comments" where version_history_updated = false
28	FOR UPDATE SKIP LOCKED LIMIT 1`,
29	{
30	raw: true,
31	type: QueryTypes.SELECT,
32	transaction,
33	},
34	)
35	).map((c) => ({	×
36	id: parseInt(c['id']),
37	versionHistories: c['version_history'].map((v) => JSON.parse(v)),	×
38	}));
39
40	if (commentVersionHistory.length === 0) {	×
41	return;	×
42	}
43
44	for (const versionHistory of commentVersionHistory) {	×
45	console.log(	×
46	`${i}/${count} Updating comment version_histories for id ${versionHistory.id}`,
47	);
48
49	const formattedValues = versionHistory.versionHistories.map((v) => {	×
50	const { body, ...rest } = v;	×
51	return {	×
52	comment_id: versionHistory.id,
53	...rest,
54	text: body,
55	};
56	}) as unknown as CommentVersionHistoryInstance[];
57
58	await models.sequelize.query(	×
59	`UPDATE "Comments" SET version_history_updated = true WHERE id = $id`,
60	{
61	bind: { id: versionHistory.id },
62	transaction,
63	},
64	);
65	return await models.CommentVersionHistory.bulkCreate(	×
66	formattedValues,
67	{
68	transaction,
69	},
70	);
71	}
72	});
73	} catch (error) {
74	console.error('Error:', error.message);	×
75	throw error;	×
76	}
77
78	i += 1;	×
79	}
80
81	console.log('Finished migration');	×
82	}
83
84	run()	×
85	.then(() => {
86	void dispose()('EXIT', true);	×
87	})
88	.catch((error) => {
89	console.error('Failed to migrate community counts:', error);	×
90	});

hicommonwealth / commonwealth / 10454888333

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