12836841493

Committed 17 Jan 2025 09:05PM UTC coverage: 47.347% (-0.8%) from 48.168%

Build # 12836841493

Build Type

Pull #10529

github

Committed by

web-flow

Commit Message

Merge a9484bc40 into b33480fd0

Pull Request Pull Request #10529: Add contest bot webhook

Run Details

1353 of 3206 branches covered (42.2%)

Branch coverage included in aggregate %.

7 of 61 new or added lines in 6 files covered. (11.48%)

47 existing lines in 5 files now uncovered.

2690 of 5333 relevant lines covered (50.44%)

36.27 hits per line

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

2.04

/libs/model/src/bot/CreateBotContest.command.ts

import {
  InvalidState,
  logger,
  ServerError,
  type Command,
} from '@hicommonwealth/core';
import {
  commonProtocol as cp,
  deployERC20Contest,
  getTokenAttributes,
} from '@hicommonwealth/evm-protocols';
import { config, publishCast } from '@hicommonwealth/model';
import * as schemas from '@hicommonwealth/schemas';
import { buildFarcasterContestFrameUrl } from '@hicommonwealth/shared';
import { models } from '../database';
import { mustExist } from '../middleware/guards';
import { TokenAttributes } from '../services';
import {
  ContestMetadataResponse,
  parseBotCommand,
  ParseBotCommandError,
} from '../services/openai/parseBotCommand';

const log = logger(import.meta);

export function CreateBotContest(): Command<typeof schemas.CreateBotContest> {
  return {
    ...schemas.CreateBotContest,
    auth: [],
    body: async ({ payload }) => {
      const { prompt } = payload;
      let contestMetadata: ContestMetadataResponse | null = null;
      try {
        contestMetadata = await parseBotCommand(prompt);
      } catch (err) {
        log.warn(`failed to parse bot command: ${(err as Error).message}`);
        if (payload.castHash) {
          const prettyError =
            err instanceof ParseBotCommandError
              ? err.getPrettyError()
              : 'Failed to create contest. Please check your prompt and try again.';
          await publishCast(
            payload.castHash,
            ({ username }) => `Hey @${username}. ${prettyError}`,
          );
        }
        return;
      }
      mustExist('Parsed Contest Metadata', contestMetadata);

      const botNamespace = config.BOT.CONTEST_BOT_NAMESPACE;

      if (!botNamespace || botNamespace === '') {
        new InvalidState('bot not enabled on given chain');
      }

      const community = await models.Community.findOne({
        where: {
          namespace: botNamespace as string,
        },
        include: [
          {
            model: models.ChainNode.scope('withPrivateData'),
            required: true,
          },
        ],
      });

      mustExist('Community', community);

      let tokenMetadata: TokenAttributes;
      try {
        tokenMetadata = await getTokenAttributes(
          contestMetadata.tokenAddress,
          community!.ChainNode!.private_url!,
          false,
        );
      } catch (err) {
        if (payload.castHash) {
          await publishCast(
            payload.castHash,
            ({ username }) =>
              // eslint-disable-next-line max-len
              `Hey @${username}. Failed to create contest. Unable to fetch the correct token. Check the address of the token and try again.`,
          );
        }
        log.warn(`token validation failed: ${(err as Error).message}`);
        return;
      }

      // use short duration for testnet contests
      const contestDurationSecs =
        community.ChainNode!.eth_chain_id === cp.ValidChains.SepoliaBase
          ? 60 * 60
          : 60 * 60 * 24 * 7;

      const namespaceFactory =
        cp.factoryContracts[
          community!.ChainNode!.eth_chain_id as cp.ValidChains
        ].factory;

      if (!config.WEB3.CONTEST_BOT_PRIVATE_KEY)
        throw new ServerError('Contest bot private key not set!');

      const contestAddress = await deployERC20Contest({
        privateKey: config.WEB3.CONTEST_BOT_PRIVATE_KEY,
        namespaceName: botNamespace!,
        contestInterval: contestDurationSecs,
        winnerShares: contestMetadata.payoutStructure,
        voteToken: contestMetadata.tokenAddress,
        voterShare: contestMetadata.voterShare,
        exchangeToken: contestMetadata.tokenAddress,
        namespaceFactory,
        rpc: community!.ChainNode!.private_url!,
      });
      mustExist('Deployed Contest', contestAddress);

      await models.sequelize.transaction(async (transaction) => {
        const manager = await models.ContestManager.create(
          {
            name: contestMetadata.contestName,
            community_id: community!.id,
            created_at: new Date(),
            cancelled: false,
            farcaster_frame_url: buildFarcasterContestFrameUrl(contestAddress),
            is_farcaster_contest: true,
            image_url: contestMetadata.image_url,
            interval: contestDurationSecs,
            funding_token_address: contestMetadata.tokenAddress,
            payout_structure: contestMetadata.payoutStructure,
            ticker: tokenMetadata.ticker,
            decimals: tokenMetadata.decimals,
            contest_address: contestAddress,
          },
          { transaction },
        );
        return manager;
      });
      return contestAddress;
    },
  };
}

1	import {
2	InvalidState,
3	logger,
4	ServerError,
5	type Command,
6	} from '@hicommonwealth/core';
7	import {
8	commonProtocol as cp,
9	deployERC20Contest,
10	getTokenAttributes,
11	} from '@hicommonwealth/evm-protocols';
12	import { config, publishCast } from '@hicommonwealth/model';
13	import * as schemas from '@hicommonwealth/schemas';
14	import { buildFarcasterContestFrameUrl } from '@hicommonwealth/shared';
15	import { models } from '../database';
16	import { mustExist } from '../middleware/guards';
17	import { TokenAttributes } from '../services';
18	import {
19	ContestMetadataResponse,
20	parseBotCommand,
21	ParseBotCommandError,
22	} from '../services/openai/parseBotCommand';
23
24	const log = logger(import.meta);	28✔
25
26	export function CreateBotContest(): Command<typeof schemas.CreateBotContest> {
27	return {	×
28	...schemas.CreateBotContest,
29	auth: [],
30	body: async ({ payload }) => {
NEW 31	const { prompt } = payload;	×
NEW 32	let contestMetadata: ContestMetadataResponse \| null = null;	×
NEW 33	try {	×
NEW 34	contestMetadata = await parseBotCommand(prompt);	×
35	} catch (err) {
NEW 36	log.warn(`failed to parse bot command: ${(err as Error).message}`);	×
NEW 37	if (payload.castHash) {	×
38	const prettyError =
NEW 39	err instanceof ParseBotCommandError	×
40	? err.getPrettyError()
41	: 'Failed to create contest. Please check your prompt and try again.';
NEW 42	await publishCast(	×
43	payload.castHash,
NEW 44	({ username }) => `Hey @${username}. ${prettyError}`,	×
45	);
46	}
NEW 47	return;	×
48	}
NEW 49	mustExist('Parsed Contest Metadata', contestMetadata);	×
50
51	const botNamespace = config.BOT.CONTEST_BOT_NAMESPACE;	×
52
53	if (!botNamespace \|\| botNamespace === '') {	×
54	new InvalidState('bot not enabled on given chain');	×
55	}
56
NEW 57	const community = await models.Community.findOne({	×
58	where: {
59	namespace: botNamespace as string,
60	},
61	include: [
62	{
63	model: models.ChainNode.scope('withPrivateData'),
64	required: true,
65	},
66	],
67	});
68
69	mustExist('Community', community);	×
70
71	let tokenMetadata: TokenAttributes;
72	try {	×
73	tokenMetadata = await getTokenAttributes(	×
74	contestMetadata.tokenAddress,
75	community!.ChainNode!.private_url!,
76	false,
77	);
78	} catch (err) {
NEW 79	if (payload.castHash) {	×
NEW 80	await publishCast(	×
81	payload.castHash,
82	({ username }) =>
83	// eslint-disable-next-line max-len
NEW 84	`Hey @${username}. Failed to create contest. Unable to fetch the correct token. Check the address of the token and try again.`,	×
85	);
86	}
NEW 87	log.warn(`token validation failed: ${(err as Error).message}`);	×
NEW 88	return;	×
89	}
90
91	// use short duration for testnet contests
92	const contestDurationSecs =
NEW 93	community.ChainNode!.eth_chain_id === cp.ValidChains.SepoliaBase	×
94	? 60 * 60
95	: 60 * 60 * 24 * 7;
96
97	const namespaceFactory =
NEW 98	cp.factoryContracts[	×
99	community!.ChainNode!.eth_chain_id as cp.ValidChains
100	].factory;
101
102	if (!config.WEB3.CONTEST_BOT_PRIVATE_KEY)	×
103	throw new ServerError('Contest bot private key not set!');	×
104
105	const contestAddress = await deployERC20Contest({	×
106	privateKey: config.WEB3.CONTEST_BOT_PRIVATE_KEY,
107	namespaceName: botNamespace!,
108	contestInterval: contestDurationSecs,
109	winnerShares: contestMetadata.payoutStructure,
110	voteToken: contestMetadata.tokenAddress,
111	voterShare: contestMetadata.voterShare,
112	exchangeToken: contestMetadata.tokenAddress,
113	namespaceFactory,
114	rpc: community!.ChainNode!.private_url!,
115	});
NEW 116	mustExist('Deployed Contest', contestAddress);	×
117
118	await models.sequelize.transaction(async (transaction) => {	×
119	const manager = await models.ContestManager.create(	×
120	{
121	name: contestMetadata.contestName,
122	community_id: community!.id,
123	created_at: new Date(),
124	cancelled: false,
125	farcaster_frame_url: buildFarcasterContestFrameUrl(contestAddress),
126	is_farcaster_contest: true,
127	image_url: contestMetadata.image_url,
128	interval: contestDurationSecs,
129	funding_token_address: contestMetadata.tokenAddress,
130	payout_structure: contestMetadata.payoutStructure,
131	ticker: tokenMetadata.ticker,
132	decimals: tokenMetadata.decimals,
133	contest_address: contestAddress,
134	},
135	{ transaction },
136	);
137	return manager;	×
138	});
139	return contestAddress;	×
140	},
141	};
142	}

hicommonwealth / commonwealth / 12836841493

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