feat: initial cut of job versioning, without npx-import usage

Author: MaximusHaximus

packages/dca-backend/package.json

@@ -49,10 +49,12 @@
     "@lit-protocol/contracts-sdk": "^7.3.0",
     "@lit-protocol/lit-node-client": "^7.3.0",
     "@lit-protocol/types": "^7.3.0",
-    "@lit-protocol/vincent-ability-uniswap-swap": "8.0.0",
-    "@lit-protocol/vincent-app-sdk": "2.2.2",
-    "@lit-protocol/vincent-contracts-sdk": "^1.0.1",
+    "@lit-protocol/vincent-app-sdk": "2.2.3",
+    "@lit-protocol/vincent-contracts-sdk": "^2.0.0",
     "@lit-protocol/vincent-scaffold-sdk": "1.1.9-mma",
+    "@lit-protocol/vincent-ability-erc20-approval": "3.1.0",
+    "@lit-protocol/vincent-ability-uniswap-swap-v5": "npm:@lit-protocol/vincent-ability-uniswap-swap@5.0.0",
+    "@lit-protocol/vincent-ability-uniswap-swap-v8": "npm:@lit-protocol/vincent-ability-uniswap-swap@8.0.0",
     "@noble/secp256k1": "^2.2.3",
     "@sentry/cli": "^2.52.0",
     "@sentry/node": "^10.5.0",

packages/dca-backend/src/lib/agenda/jobs/dcaSwapJobManager.ts

@@ -1,8 +1,9 @@
 import consola from 'consola';
 import { Types } from 'mongoose';
 
-import * as executeDCASwapJobDef from './executeDCASwap';
 import { getAgenda } from '../agendaClient';
+import { jobName } from './executeDCASwap';
+import { JobParams, JobType } from './executeDCASwap/types';
 
 interface FindSpecificScheduledJobParams {
   ethAddress: string;
@@ -18,26 +19,22 @@ export async function listJobsByEthAddress({ ethAddress }: { ethAddress: string
 
   return (await agendaClient.jobs({
     'data.pkpInfo.ethAddress': ethAddress,
-  })) as executeDCASwapJobDef.JobType[];
+  })) as JobType[];
 }
 
-export async function findJob(
-  params: FindSpecificScheduledJobParams
-): Promise<executeDCASwapJobDef.JobType>;
-export async function findJob(
-  params: FindSpecificScheduledJobParams
-): Promise<executeDCASwapJobDef.JobType | undefined>;
+export async function findJob(params: FindSpecificScheduledJobParams): Promise<JobType>;
+export async function findJob(params: FindSpecificScheduledJobParams): Promise<JobType | undefined>;
 export async function findJob({
   ethAddress,
   mustExist,
   scheduleId,
-}: FindSpecificScheduledJobParams): Promise<executeDCASwapJobDef.JobType | undefined> {
+}: FindSpecificScheduledJobParams): Promise<JobType | undefined> {
   const agendaClient = getAgenda();
 
   const jobs = (await agendaClient.jobs({
     _id: new Types.ObjectId(scheduleId),
     'data.pkpInfo.ethAddress': ethAddress,
-  })) as executeDCASwapJobDef.JobType[];
+  })) as JobType[];
 
   logger.log(`Found ${jobs.length} jobs with ID ${scheduleId}`);
   if (mustExist && !jobs.length) {
@@ -51,7 +48,7 @@ export async function editJob({
   data,
   scheduleId,
 }: {
-  data: Omit<executeDCASwapJobDef.JobParams, 'updatedAt'>;
+  data: Omit<JobParams, 'updatedAt'>;
   scheduleId: string;
 }) {
   const {
@@ -70,7 +67,7 @@ export async function editJob({
 
   job.attrs.data = { ...data, updatedAt: new Date() };
 
-  return (await job.save()) as unknown as executeDCASwapJobDef.JobType;
+  return (await job.save()) as unknown as JobType;
 }
 
 export async function disableJob({
@@ -113,7 +110,7 @@ export async function cancelJob({
 }
 
 export async function createJob(
-  data: Omit<executeDCASwapJobDef.JobParams, 'updatedAt'>,
+  data: Omit<JobParams, 'updatedAt'>,
   options: {
     interval?: string;
     schedule?: string;
@@ -122,7 +119,7 @@ export async function createJob(
   const agenda = getAgenda();
 
   // Create a new job instance
-  const job = agenda.create<executeDCASwapJobDef.JobParams>(executeDCASwapJobDef.jobName, {
+  const job = agenda.create<JobParams>(jobName, {
     ...data,
     updatedAt: new Date(),
   });

packages/dca-backend/src/lib/agenda/jobs/executeDCASwap/constants.ts

@@ -0,0 +1,4 @@
+export const BASE_CHAIN_ID = 8453;
+export const BASE_USDC_ADDRESS = '0x833589fcd6edb6e08f4c7c32d4f71b54bda02913';
+export const BASE_WBTC_ADDRESS = '0x0555E30da8f98308EdB960aa94C0Db47230d2B9c';
+export const BASE_UNISWAP_V3_ROUTER = '0x2626664c2603336E57B271c5C0b26F421741e481';