Refactor chainId from number to string in contractSubscriptions (#759)

Author: d4mr

src/db/contractSubscriptions/createContractSubscription.ts

@@ -21,7 +21,7 @@ export const createContractSubscription = async ({
 }: CreateContractSubscriptionParams) => {
   return prisma.contractSubscriptions.create({
     data: {
-      chainId,
+      chainId: chainId.toString(),
       contractAddress,
       webhookId,
       processEventLogs,

src/db/contractSubscriptions/getContractSubscriptions.ts

@@ -11,7 +11,7 @@ export const isContractSubscribed = async ({
 }: GetContractSubscriptionsParams) => {
   const contractSubscription = await prisma.contractSubscriptions.findFirst({
     where: {
-      chainId,
+      chainId: chainId.toString(),
       contractAddress,
       deletedAt: null,
     },
@@ -25,7 +25,7 @@ export const getContractSubscriptionsByChainId = async (
 ) => {
   return await prisma.contractSubscriptions.findMany({
     where: {
-      chainId,
+      chainId: chainId.toString(),
       deletedAt: null,
     },
     include: {
@@ -56,5 +56,5 @@ export const getContractSubscriptionsUniqueChainIds = async () => {
     },
   });
 
-  return uniqueChainIds.map((contract) => contract.chainId);
+  return uniqueChainIds.map((contract) => Number.parseInt(contract.chainId));
 };

src/prisma/migrations/20241105091733_chain_id_from_int_to_string/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "contract_subscriptions" ALTER COLUMN "chainId" SET DATA TYPE TEXT;

src/prisma/schema.prisma

@@ -202,7 +202,7 @@ model Relayers {
 
 model ContractSubscriptions {
   id                         String   @id @default(uuid()) @map("id")
-  chainId                    Int
+  chainId                    String
   contractAddress            String
   webhookId                  Int?
   processEventLogs           Boolean  @default(true)

src/server/schemas/contractSubscription.ts

@@ -22,7 +22,7 @@ export const toContractSubscriptionSchema = (
   contractSubscription: ContractSubscriptions & { webhook: Webhooks | null },
 ): Static<typeof contractSubscriptionSchema> => ({
   id: contractSubscription.id,
-  chainId: contractSubscription.chainId,
+  chainId: Number.parseInt(contractSubscription.chainId),
   contractAddress: contractSubscription.contractAddress,
   webhook: contractSubscription.webhook
     ? toWebhookSchema(contractSubscription.webhook)