Merge branch 'multi-cron-jobs'

Author: jtomada

.gitignore

@@ -1,4 +1,5 @@
 .env
 node_modules
 .parcel-cache
-dist
+dist
+src/dcaconfig.ts

src/constants/index.ts

@@ -1,6 +1,5 @@
-import { Cluster } from "@solana/web3.js";
+import { Cluster, Keypair } from "@solana/web3.js";
 import bs58 from "bs58";
-import { Keypair } from "@solana/web3.js";
 
 import 'dotenv/config'
 
@@ -20,16 +19,6 @@ export const WALLET_PRIVATE_KEY =
 export const USER_PRIVATE_KEY = bs58.decode(WALLET_PRIVATE_KEY);
 export const USER_KEYPAIR = Keypair.fromSecretKey(USER_PRIVATE_KEY);
 
-// Token Mints
-export const INPUT_MINT_ADDRESS =
-  ENV === "devnet"
-    ? "So11111111111111111111111111111111111111112" // SOL
-    : "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"; // USDC
-export const OUTPUT_MINT_ADDRESS =
-  ENV === "devnet"
-    ? "SRMuApVNdxXokk5GT7XD5cUUgXMBCoAz2LHeuAoKWRt" // SRM
-    : "Es9vMFrzaCERmJfrF4H2FYD4KCoNkY11McCe8BenwNYB"; // USDT
-
 // Interface
 export interface Token {
   chainId: number; // 101,
@@ -40,3 +29,12 @@ export interface Token {
   logoURI: string; // 'https://i.ibb.co/pKTWrwP/true.jpg',
   tags: string[]; // [ 'utility-token', 'capital-token' ]
 }
+
+export interface DcaConfig {
+  name?: string;
+  inputMint: string;
+  outputMint: string;
+  amount: number;
+  slippage: number;
+  cron: string;
+}

src/dcaconfig-example.ts

@@ -0,0 +1,20 @@
+import { DcaConfig } from './constants';
+
+export const dcaconfig: DcaConfig[] = [
+    {
+        name: "USDC to USDT",
+        inputMint: "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v", // USDC
+        outputMint: "Es9vMFrzaCERmJfrF4H2FYD4KCoNkY11McCe8BenwNYB", // USDT
+        amount: 0.01,
+        slippage: 1,
+        cron: "*/1 * * * *"
+    },
+    {
+        name: "0.01 USDT -> USDC",
+        inputMint: "Es9vMFrzaCERmJfrF4H2FYD4KCoNkY11McCe8BenwNYB", // USDT
+        outputMint: "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v", // USDC
+        amount: 0.01,
+        slippage: 1,
+        cron: "*/1 * * * *"
+    },
+];

src/index.ts

@@ -4,12 +4,11 @@ import { PublicKey, Connection } from "@solana/web3.js";
 import * as cron from "node-cron";
 import {
   ENV,
-  INPUT_MINT_ADDRESS,
-  OUTPUT_MINT_ADDRESS,
   SOLANA_RPC_ENDPOINT,
   Token,
   USER_KEYPAIR,
 } from "./constants";
+import { dcaconfig } from './dcaconfig'
 
 const jupiterSwap = async ({
   jupiter,
@@ -87,27 +86,32 @@ const main = async () => {
     });
 
     // Fetch token list from Jupiter API
-    const tokens: Token[] = await (await fetch(TOKEN_LIST_URL[ENV])).json(); 
+    const tokens: Token[] = await (await fetch(TOKEN_LIST_URL[ENV])).json();
 
-    // If you know which input/output pair you want
-    const inputToken = tokens.find((t) => t.address == INPUT_MINT_ADDRESS); // USDC Mint Info
-    const outputToken = tokens.find((t) => t.address == OUTPUT_MINT_ADDRESS); // USDT Mint Info
+    const filteredJobs = dcaconfig.filter(dcajob => {
+      return cron.validate(dcajob.cron);
+    });
 
-    // Create cron job
+    console.log("Valid jobs to be scheduled: ", filteredJobs.map(job => {
+      return job.name;
+    }));
 
-    // Validate cron job
+    const scheduledJobs = filteredJobs.map(dcajob => {
+      const inputToken = tokens.find((t) => t.address == dcajob.inputMint);
+      const outputToken = tokens.find((t) => t.address == dcajob.outputMint);
 
-    const task = cron.schedule('*/2 * * * *', async () => {
-      console.log('SWAPPING @!!!!!');
-      const routes = await jupiterSwap({
-        jupiter,
-        inputToken,
-        outputToken,
-        inputAmount: .01,
-        slippage: 1, // % slippage
+      return cron.schedule(dcajob.cron, async () => {
+        console.log('SWAPPING @!!!!!');
+        const routes = await jupiterSwap({
+          jupiter,
+          inputToken,
+          outputToken,
+          inputAmount: dcajob.amount,
+          slippage: dcajob.slippage, // % slippage
+        });
       });
     });
-    
+
     console.log('started!!!');
   } catch (error) {
     console.log({ error });