ok didnt really like bree bloat. back to node-cron

Author: jtomada

README.md

@@ -2,3 +2,9 @@
 Based on the [Jupiter Core Example](https://github.com/jup-ag/jupiter-core-example)
 
 A bot for dollar cost averaging using on-chain swaps through the [Jupiter Aggregator](https://jup.ag).
+
+Install
+```
+yarn add --dev node-cron
+yarn add --dev @types/node-cron
+```

package.json

@@ -7,7 +7,6 @@
   "module": "dist/module.js",
   "types": "dist/types.d.ts",
   "scripts": {
-    "dev": "TS_NODE=true NODE_OPTIONS=\"--loader ts-node/esm --experimental-specifier-resolution=node\" node .",
     "start": "ts-node ./src/index.ts"
   },
   "keywords": [],
@@ -26,11 +25,11 @@
   },
   "devDependencies": {
     "@solana/web3.js": "^1.36.0",
-    "bree": "^7.2.0",
+    "@types/node-cron": "^3.0.1",
+    "node-cron": "^3.0.0",
     "typescript": "^4.5.3"
   },
   "resolutions": {
     "@solana/buffer-layout": "4.0.0"
-  },
-  "type": "module"
+  }
 }

src/index.ts

@@ -1,35 +1,114 @@
-import * as path from 'node:path';
-import * as process from 'node:process';
-import { fileURLToPath } from 'node:url';
-import Bree from 'bree';
+import fetch from "isomorphic-fetch";
+import { Jupiter, RouteInfo, TOKEN_LIST_URL } from "@jup-ag/core";
+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";
+
+const jupiterSwap = async ({
+  jupiter,
+  inputToken,
+  outputToken,
+  inputAmount,
+  slippage,
+}: {
+  jupiter: Jupiter;
+  inputToken?: Token;
+  outputToken?: Token;
+  inputAmount: number;
+  slippage: number;
+}) => {
+  try {
+      if (!inputToken || !outputToken) {
+          return null;
+      }
+
+      console.log(
+      `Getting routes for ${inputAmount} ${inputToken.symbol} -> ${outputToken.symbol}...`
+      );
+      const inputAmountInSmallestUnits = inputToken
+      ? Math.round(inputAmount * 10 ** inputToken.decimals)
+      : 0;
+      const routes =
+      inputToken && outputToken
+          ? await jupiter.computeRoutes({
+              inputMint: new PublicKey(inputToken.address),
+              outputMint: new PublicKey(outputToken.address),
+              inputAmount: inputAmountInSmallestUnits, // raw input amount of tokens
+              slippage,
+              forceFetch: true,
+          })
+          : null;
+
+      if (routes && routes.routesInfos) {
+      console.log("Possible number of routes:", routes.routesInfos.length);
+      console.log(
+          "Best quote: ",
+          routes.routesInfos[0].outAmount / 10 ** outputToken.decimals,
+          `(${outputToken.symbol})`
+      );
+        // Prepare execute exchange
+        const { execute } = await jupiter.exchange({
+          routeInfo: routes!.routesInfos[0],
+        });
+        // Execute swap
+        // Force any to ignore TS misidentifying SwapResult type
+        const swapResult: any = await execute();
+        if (swapResult.error) {
+          console.log(swapResult.error);
+          return null;
+        } else {
+          console.log(`https://explorer.solana.com/tx/${swapResult.txid}`);
+          console.log(
+              `inputAmount=${swapResult.inputAmount} outputAmount=${swapResult.outputAmount}`
+          );
+        }
+      } else {
+        return null;
+      }
+  } catch (error) {
+    throw error;
+  }
+};
 
 const main = async () => {
   try {
-    const bree = new Bree({
-      /**
-       * Always set the root option when doing any type of
-       * compiling with bree. This just makes it clearer where
-       * bree should resolve the jobs folder from. By default it
-       * resolves to the jobs folder relative to where the program
-       * is executed.
-       */
-      root: path.join(path.dirname(fileURLToPath(import.meta.url)), 'jobs'),
-      /**
-       * We only need the default extension to be "ts"
-       * when we are running the app with ts-node - otherwise
-       * the compiled-to-js code still needs to use JS
-       */
-      defaultExtension: process.env.TS_NODE ? 'ts' : 'js',
-      jobs: [
-        {
-            name: 'job',
-            interval: 'every 15 seconds'
-        },
-      ]
+    const connection = new Connection(SOLANA_RPC_ENDPOINT); // Setup Solana
+    const jupiter = await Jupiter.load({
+        connection,
+        cluster: ENV,
+        user: USER_KEYPAIR, // or public key
     });
 
-    bree.start();
-      
+    // Fetch token list from Jupiter API
+    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
+
+    // Create cron job
+
+    // Validate cron job
+
+    const task = cron.schedule('*/2 * * * *', async () => {
+      console.log('SWAPPING @!!!!!');
+      const routes = await jupiterSwap({
+        jupiter,
+        inputToken,
+        outputToken,
+        inputAmount: .01,
+        slippage: 1, // % slippage
+      });
+    });
+    
+    console.log('started!!!');
   } catch (error) {
     console.log({ error });
   }

src/jobs/job.ts

@@ -1,6 +1,8 @@
 {
   "compilerOptions": {
-    "target": "ES6",
+    "target": "ES2020",
+    "module": "CommonJS",
+    "esModuleInterop": true,
     "lib": [
       "dom",
       "dom.iterable",
@@ -11,8 +13,6 @@
     "strict": true,
     "forceConsistentCasingInFileNames": true,
     "noEmit": true,
-    "esModuleInterop": true,
-    "module": "ES2020",
     "moduleResolution": "node",
     "resolveJsonModule": true,
     "isolatedModules": true,