Merge pull request #12131 from hicommonwealth/ryan/create-launchpad-trade-bigint-fix

Fix bigint serialization error

Author: rbennettcw

libs/model/src/aggregates/token/utils.ts

@@ -95,6 +95,9 @@ export async function handleCapReached(
         privateKey: config.WEB3.LAUNCHPAD_PRIVATE_KEY!,
       });
 
+      token.liquidity_transferred = true;
+      log.debug(`Liquidity transferred to ${token_address}`);
+
       if (notifyUsers.length > 0) {
         await provider.triggerWorkflow({
           key: WorkflowKeys.LaunchpadCapReached,
@@ -105,9 +108,6 @@ export async function handleCapReached(
           },
         });
       }
-
-      token.liquidity_transferred = true;
-      log.debug(`Liquidity transferred to ${token_address}`);
     }
 
     await models.sequelize.transaction(async (transaction) => {
@@ -119,7 +119,6 @@ export async function handleCapReached(
               event_name: 'LaunchpadTokenGraduated',
               event_payload: {
                 token: token.toJSON(),
-                ...onChainTokenData,
               },
             },
           ],

libs/model/src/policies/EventStream.policy.ts

@@ -183,6 +183,10 @@ const eventStreamMappers: EventStreamMappers = {
     };
   },
   LaunchpadTokenTraded: async (payload) => {
+    // TODO: the LaunchpadToken usually hasn't been projected by this point,
+    // so only the transaction data is available. Refactor to use tokenData
+    // and make sure bigint is serialized correctly, then re-enable in policy.
+
     const launchpadToken = await models.LaunchpadToken.findOne({
       where: { token_address: payload.token_address },
     });
@@ -266,9 +270,9 @@ export function EventStreamPolicy(): Policy<{
         );
       },
       LaunchpadTokenTraded: async ({ payload }) => {
-        await pushToEventStream(
-          await eventStreamMappers.LaunchpadTokenTraded(payload),
-        );
+        // await pushToEventStream(
+        //   await eventStreamMappers.LaunchpadTokenTraded(payload),
+        // );
       },
       LaunchpadTokenGraduated: async ({ payload }) => {
         await pushToEventStream(

libs/model/test/policies/eventStream.policy.spec.ts

@@ -339,20 +339,20 @@ describe('EventStream Policy Integration Tests', () => {
           block_timestamp: 1n,
         } satisfies z.infer<typeof events.LaunchpadTokenCreated>),
       },
-      {
-        event_name: 'LaunchpadTokenTraded',
-        event_payload: serializeBigIntObj({
-          block_timestamp: 1n,
-          transaction_hash: '0x1111111111111111111111111111111111111111',
-          trader_address: '0x1111111111111111111111111111111111111111',
-          token_address: '0x7777777777777777777777777777777777777777',
-          is_buy: true,
-          eth_chain_id: 1,
-          eth_amount: 1n,
-          community_token_amount: 1n,
-          floating_supply: 1n,
-        } satisfies z.infer<typeof events.LaunchpadTokenTraded>),
-      },
+      // {
+      //   event_name: 'LaunchpadTokenTraded',
+      //   event_payload: serializeBigIntObj({
+      //     block_timestamp: 1n,
+      //     transaction_hash: '0x1111111111111111111111111111111111111111',
+      //     trader_address: '0x1111111111111111111111111111111111111111',
+      //     token_address: '0x7777777777777777777777777777777777777777',
+      //     is_buy: true,
+      //     eth_chain_id: 1,
+      //     eth_amount: 1n,
+      //     community_token_amount: 1n,
+      //     floating_supply: 1n,
+      //   } satisfies z.infer<typeof events.LaunchpadTokenTraded>),
+      // },
       {
         event_name: 'LaunchpadTokenGraduated',
         event_payload: serializeBigIntObj({
@@ -366,13 +366,6 @@ describe('EventStream Policy Integration Tests', () => {
             launchpad_liquidity: 1n,
             eth_market_cap_target: 1000,
           },
-          launchpadLiquidity: 1n,
-          poolLiquidity: 1n,
-          curveId: 1n,
-          scalar: 1n,
-          reserveRation: 1n,
-          LPhook: '0x123',
-          funded: true,
         } satisfies z.infer<typeof events.LaunchpadTokenGraduated>),
       },
     ];
@@ -386,7 +379,7 @@ describe('EventStream Policy Integration Tests', () => {
       'CommunityCreated',
       'ThreadCreated',
       'LaunchpadTokenCreated',
-      'LaunchpadTokenTraded',
+      // 'LaunchpadTokenTraded',
       'LaunchpadTokenGraduated',
     ] satisfies Events[];
 

libs/schemas/src/events/events.schemas.ts

@@ -400,14 +400,7 @@ export const events = {
   }),
 
   LaunchpadTokenGraduated: z.object({
-    token: LaunchpadToken.extend({}),
-    launchpadLiquidity: z.coerce.bigint(),
-    poolLiquidity: z.coerce.bigint(),
-    curveId: z.coerce.bigint(),
-    scalar: z.coerce.bigint(),
-    reserveRation: z.coerce.bigint(),
-    LPhook: z.string(),
-    funded: z.boolean(),
+    token: LaunchpadToken,
   }),
 
   LaunchpadTokenTraded: z.object({