commit c9daaddb7722a7ae06f8bc31cae14c4818d13e6d Author: Louis-Sinan Date: Sun Dec 21 12:22:16 2025 +0100 first commit diff --git a/.dockerignore b/.dockerignore new file mode 100644 index 0000000..e5a44ae --- /dev/null +++ b/.dockerignore @@ -0,0 +1,7 @@ +.env +node_modules +dist +coverage +Dockerfile +Makefile +README.md diff --git a/.env.example b/.env.example new file mode 100644 index 0000000..d82d787 --- /dev/null +++ b/.env.example @@ -0,0 +1,8 @@ +RPC_URL=https://api.mainnet-beta.solana.com +PRIVATE_KEY=[VOTRE_CLE_PRIVEE] +PAIR_ADDRESS=G7ixPyiyNeggVf1VanSetFMNbVuVCPtimJmd9axfQqng +TARGET_RATIO=0.5 +CHECK_INTERVAL_CRON="*/5 * * * *" +COMPOUND_INTERVAL_CRON="0 0 * * *" +REBALANCE_THRESHOLD_PERCENT=0.15 +LOG_LEVEL=info diff --git a/.eslintrc.json b/.eslintrc.json new file mode 100644 index 0000000..e95371f --- /dev/null +++ b/.eslintrc.json @@ -0,0 +1,22 @@ +{ + "parser": "@typescript-eslint/parser", + "extends": [ + "plugin:@typescript-eslint/recommended", + "prettier", + "plugin:prettier/recommended" + ], + "parserOptions": { + "ecmaVersion": 2018, + "sourceType": "module" + }, + "rules": { + "@typescript-eslint/explicit-function-return-type": "off", + "@typescript-eslint/no-explicit-any": "off", + "@typescript-eslint/no-unused-vars": [ + "error", + { + "argsIgnorePattern": "^_" + } + ] + } +} \ No newline at end of file diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..9f09369 --- /dev/null +++ b/.gitignore @@ -0,0 +1,10 @@ +node_modules/ +dist/ +.env +.DS_Store +*.log +npm-debug.log* +yarn-debug.log* +yarn-error.log* +.idea/ +.vscode/ diff --git a/Dockerfile b/Dockerfile new file mode 100644 index 0000000..cb3e5a5 --- /dev/null +++ b/Dockerfile @@ -0,0 +1,16 @@ +FROM node:20-slim AS base +WORKDIR /app +COPY package*.json ./ + +FROM base AS dependencies +RUN npm install + +FROM dependencies AS build +COPY . . +RUN npm run build + +# Production stage +FROM base AS release +COPY --from=dependencies /app/node_modules ./node_modules +COPY --from=build /app/dist ./dist +CMD ["node", "dist/index.js"] diff --git a/Makefile b/Makefile new file mode 100644 index 0000000..e558dad --- /dev/null +++ b/Makefile @@ -0,0 +1,32 @@ +# Variables +IMAGE_NAME=meteora-dlmm-bot + +.PHONY: build test lint docker-build docker-test docker-lint docker-run clean install + +install: + npm install + +lint-fix: + npm run lint:fix + +build: + docker build -t meteora-dlmm-bot . + +test: build + docker run --rm meteora-dlmm-bot npm run test + +lint: build + docker run --rm meteora-dlmm-bot npm run lint + +run: build + docker run --rm --name meteora-dlmm-bot --env-file .env meteora-dlmm-bot + +stop: + docker stop meteora-dlmm-bot || true + docker rm meteora-dlmm-bot || true + +withdraw: build + docker run --rm --name meteora-dlmm-bot-withdraw --env-file .env meteora-dlmm-bot npm run withdraw:prod + +clean: + rm -rf dist coverage diff --git a/README.md b/README.md new file mode 100644 index 0000000..918a56a --- /dev/null +++ b/README.md @@ -0,0 +1,75 @@ +# Meteora DLMM Automated Trading Bot + +A high-performance TypeScript trading bot designed for Meteora's Dynamic Liquidity Market Maker (DLMM) on Solana. The bot optimizes yield through precision rebalancing, native SOL management, and resilient transaction handling. + +## 🚀 Key Features + +- **Precision Rebalancing (15% Rule)**: Instead of fixed intervals, the bot rebalances when the active price bin enters the outer 15% of your position's range. This ensures your liquidity stays centered and productive. +- **Micro-Frequency Monitoring**: Checks your portfolio every 5 minutes (`*/5 * * * *`) to react quickly to market volatility. +- **Native SOL Awareness**: Seamlessly handles SOL-only accounts. It detects SOL in your wallet, reserves a **0.1 SOL gas buffer**, and automatically performs initial deposits. +- **Balanced Entry (50/50 Swap)**: If you enter with only SOL, the bot uses Jupiter to automatically swap ~50% for the opposite asset, ensuring your position is productive in both directions from the start. +- **Dust Retention (ATA optimization)**: Leaves a tiny amount of tokens (0.0001) in your wallet to keep the Associated Token Accounts open, preventing repetitive SOL rent fees. +- **Value-Based Compounding**: Monitors your wallet and triggers a re-deposit whenever uninvested fees/balance exceed **$1.00 USD**. +- **Transaction Resilience**: Built-in retry logic (2 retries per operation) and exponential backoff to handle Solana network congestion. +- **Dockerized Environment**: Runs on Node 20 within a controlled Docker container to eliminate "it works on my machine" issues. + +## 🛠 Prerequisites + +- **Docker** (Highly Recommended) +- A Solana wallet with SOL (the bot will handle the rest). +- A reliable Solana RPC URL (Mainnet). + +## 📦 Quick Start + +1. **Clone & Configure**: + ```bash + git clone + cd meteora-dlmm-bot + cp .env.example .env + ``` + Edit `.env` with your `RPC_URL`, `PRIVATE_KEY` (Base58), and `PAIR_ADDRESS`. + +2. **Run with Docker**: + ```bash + make docker-build + make docker-run + ``` + +## 🧠 How It Works (Internal Logic) + +### 1. The 5-Minute Cycle +Every 5 minutes, the bot wakes up and recalculates your entire portfolio state: +- Fetches the current `Active Bin` from the DLMM pool. +- Retrieves all your open positions for that specific pair. +- Queries wallet balances for both tokens (including Native SOL). + +### 2. Rebalance Trigger +For each position, the bot calculates a "Healthy Range": +- If the `Active Bin` is within the middle 70% of your range, it does nothing. +- If the `Active Bin` hits the bottom 15% or top 15% "Danger Zones", a rebalance is triggered. + +### 3. The Rebalance Process +When triggered, the bot: +1. **Withdraws** all liquidity from the current position. +2. **Claims** all accrued fees. +3. **Consolidates** the tokens in your wallet. +4. **Redeposits** a new position exactly centered around the new `Active Bin`, providing immediate "Spot" liquidity. + +### 4. Resilience Features +- **Retries**: If a transaction fails (e.g., blockhash expired), it retries up to 2 times automatically. +- **Safety Buffer**: Always leaves 0.1 SOL in your wallet to ensure you can always pay for future rebalances and withdrawals. +- **Cycle-Level Safety**: If the RPC fails or the API is down, the bot logs the error but keeps running, attempting the check again in 5 minutes. + +## 💡 Configuration Tips + +- `DRY_RUN=true`: Use this to see what the bot *would* do without spending any SOL. +- `CHECK_INTERVAL_CRON`: Adjust frequency (e.g., `*/1 * * * *` for 1-minute checks). +- `REBALANCE_THRESHOLD_PERCENT`: Default is `0.15` (15%). Decrease for tighter ranges, increase for more "passive" management. + +## 📜 Project Structure + +- `src/bot.ts`: Core strategy logic and decision engine. +- `src/meteora.ts`: Low-level Meteora SDK interactions and retry logic. +- `src/utils/config.ts`: Environment validation and sanitization. +- `tests/`: Comprehensive test suite for rebalancing math and balance detection. + diff --git a/coverage/clover.xml b/coverage/clover.xml new file mode 100644 index 0000000..dd8eb0b --- /dev/null +++ b/coverage/clover.xml @@ -0,0 +1,6 @@ + + + + + + diff --git a/coverage/coverage-final.json b/coverage/coverage-final.json new file mode 100644 index 0000000..0967ef4 --- /dev/null +++ b/coverage/coverage-final.json @@ -0,0 +1 @@ +{} diff --git a/coverage/lcov-report/base.css b/coverage/lcov-report/base.css new file mode 100644 index 0000000..f418035 --- /dev/null +++ b/coverage/lcov-report/base.css @@ -0,0 +1,224 @@ +body, html { + margin:0; padding: 0; + height: 100%; +} +body { + font-family: Helvetica Neue, Helvetica, Arial; + font-size: 14px; + color:#333; +} +.small { font-size: 12px; } +*, *:after, *:before { + -webkit-box-sizing:border-box; + -moz-box-sizing:border-box; + box-sizing:border-box; + } +h1 { font-size: 20px; margin: 0;} +h2 { font-size: 14px; } +pre { + font: 12px/1.4 Consolas, "Liberation Mono", Menlo, Courier, monospace; + margin: 0; + padding: 0; + -moz-tab-size: 2; + -o-tab-size: 2; + tab-size: 2; +} +a { color:#0074D9; text-decoration:none; } +a:hover { text-decoration:underline; } +.strong { font-weight: bold; } +.space-top1 { padding: 10px 0 0 0; } +.pad2y { padding: 20px 0; } +.pad1y { padding: 10px 0; } +.pad2x { padding: 0 20px; } +.pad2 { padding: 20px; } +.pad1 { padding: 10px; } +.space-left2 { padding-left:55px; } +.space-right2 { padding-right:20px; } +.center { text-align:center; } +.clearfix { display:block; } +.clearfix:after { + content:''; + display:block; + height:0; + clear:both; + visibility:hidden; + } +.fl { float: left; } +@media only screen and (max-width:640px) { + .col3 { width:100%; max-width:100%; } + .hide-mobile { display:none!important; } +} + +.quiet { + color: #7f7f7f; + color: rgba(0,0,0,0.5); +} +.quiet a { opacity: 0.7; } + +.fraction { + font-family: Consolas, 'Liberation Mono', Menlo, Courier, monospace; + font-size: 10px; + color: #555; + background: #E8E8E8; + padding: 4px 5px; + border-radius: 3px; + vertical-align: middle; +} + +div.path a:link, div.path a:visited { color: #333; } +table.coverage { + border-collapse: collapse; + margin: 10px 0 0 0; + padding: 0; +} + +table.coverage td { + margin: 0; + padding: 0; + vertical-align: top; +} +table.coverage td.line-count { + text-align: right; + padding: 0 5px 0 20px; +} +table.coverage td.line-coverage { + text-align: right; + padding-right: 10px; + min-width:20px; +} + +table.coverage td span.cline-any { + display: inline-block; + padding: 0 5px; + width: 100%; +} +.missing-if-branch { + display: inline-block; + margin-right: 5px; + border-radius: 3px; + position: relative; + padding: 0 4px; + background: #333; + color: yellow; +} + +.skip-if-branch { + display: none; + margin-right: 10px; + position: relative; + padding: 0 4px; + background: #ccc; + color: white; +} +.missing-if-branch .typ, .skip-if-branch .typ { + color: inherit !important; +} +.coverage-summary { + border-collapse: collapse; + width: 100%; +} +.coverage-summary tr { border-bottom: 1px solid #bbb; } +.keyline-all { border: 1px solid #ddd; } +.coverage-summary td, .coverage-summary th { padding: 10px; } +.coverage-summary tbody { border: 1px solid #bbb; } +.coverage-summary td { border-right: 1px solid #bbb; } +.coverage-summary td:last-child { border-right: none; } +.coverage-summary th { + text-align: left; + font-weight: normal; + white-space: nowrap; +} +.coverage-summary th.file { border-right: none !important; } +.coverage-summary th.pct { } +.coverage-summary th.pic, +.coverage-summary th.abs, +.coverage-summary td.pct, +.coverage-summary td.abs { text-align: right; } +.coverage-summary td.file { white-space: nowrap; } +.coverage-summary td.pic { min-width: 120px !important; } +.coverage-summary tfoot td { } + +.coverage-summary .sorter { + height: 10px; + width: 7px; + display: inline-block; + margin-left: 0.5em; + background: url(sort-arrow-sprite.png) no-repeat scroll 0 0 transparent; +} +.coverage-summary .sorted .sorter { + background-position: 0 -20px; +} +.coverage-summary .sorted-desc .sorter { + background-position: 0 -10px; +} +.status-line { height: 10px; } +/* yellow */ +.cbranch-no { background: yellow !important; color: #111; } +/* dark red */ +.red.solid, .status-line.low, .low .cover-fill { background:#C21F39 } +.low .chart { border:1px solid #C21F39 } +.highlighted, +.highlighted .cstat-no, .highlighted .fstat-no, .highlighted .cbranch-no{ + background: #C21F39 !important; +} +/* medium red */ +.cstat-no, .fstat-no, .cbranch-no, .cbranch-no { background:#F6C6CE } +/* light red */ +.low, .cline-no { background:#FCE1E5 } +/* light green */ +.high, .cline-yes { background:rgb(230,245,208) } +/* medium green */ +.cstat-yes { background:rgb(161,215,106) } +/* dark green */ +.status-line.high, .high .cover-fill { background:rgb(77,146,33) } +.high .chart { border:1px solid rgb(77,146,33) } +/* dark yellow (gold) */ +.status-line.medium, .medium .cover-fill { background: #f9cd0b; } +.medium .chart { border:1px solid #f9cd0b; } +/* light yellow */ +.medium { background: #fff4c2; } + +.cstat-skip { background: #ddd; color: #111; } +.fstat-skip { background: #ddd; color: #111 !important; } +.cbranch-skip { background: #ddd !important; color: #111; } + +span.cline-neutral { background: #eaeaea; } + +.coverage-summary td.empty { + opacity: .5; + padding-top: 4px; + padding-bottom: 4px; + line-height: 1; + color: #888; +} + +.cover-fill, .cover-empty { + display:inline-block; + height: 12px; +} +.chart { + line-height: 0; +} +.cover-empty { + background: white; +} +.cover-full { + border-right: none !important; +} +pre.prettyprint { + border: none !important; + padding: 0 !important; + margin: 0 !important; +} +.com { color: #999 !important; } +.ignore-none { color: #999; font-weight: normal; } + +.wrapper { + min-height: 100%; + height: auto !important; + height: 100%; + margin: 0 auto -48px; +} +.footer, .push { + height: 48px; +} diff --git a/coverage/lcov-report/block-navigation.js b/coverage/lcov-report/block-navigation.js new file mode 100644 index 0000000..530d1ed --- /dev/null +++ b/coverage/lcov-report/block-navigation.js @@ -0,0 +1,87 @@ +/* eslint-disable */ +var jumpToCode = (function init() { + // Classes of code we would like to highlight in the file view + var missingCoverageClasses = ['.cbranch-no', '.cstat-no', '.fstat-no']; + + // Elements to highlight in the file listing view + var fileListingElements = ['td.pct.low']; + + // We don't want to select elements that are direct descendants of another match + var notSelector = ':not(' + missingCoverageClasses.join('):not(') + ') > '; // becomes `:not(a):not(b) > ` + + // Selector that finds elements on the page to which we can jump + var selector = + fileListingElements.join(', ') + + ', ' + + notSelector + + missingCoverageClasses.join(', ' + notSelector); // becomes `:not(a):not(b) > a, :not(a):not(b) > b` + + // The NodeList of matching elements + var missingCoverageElements = document.querySelectorAll(selector); + + var currentIndex; + + function toggleClass(index) { + missingCoverageElements + .item(currentIndex) + .classList.remove('highlighted'); + missingCoverageElements.item(index).classList.add('highlighted'); + } + + function makeCurrent(index) { + toggleClass(index); + currentIndex = index; + missingCoverageElements.item(index).scrollIntoView({ + behavior: 'smooth', + block: 'center', + inline: 'center' + }); + } + + function goToPrevious() { + var nextIndex = 0; + if (typeof currentIndex !== 'number' || currentIndex === 0) { + nextIndex = missingCoverageElements.length - 1; + } else if (missingCoverageElements.length > 1) { + nextIndex = currentIndex - 1; + } + + makeCurrent(nextIndex); + } + + function goToNext() { + var nextIndex = 0; + + if ( + typeof currentIndex === 'number' && + currentIndex < missingCoverageElements.length - 1 + ) { + nextIndex = currentIndex + 1; + } + + makeCurrent(nextIndex); + } + + return function jump(event) { + if ( + document.getElementById('fileSearch') === document.activeElement && + document.activeElement != null + ) { + // if we're currently focused on the search input, we don't want to navigate + return; + } + + switch (event.which) { + case 78: // n + case 74: // j + goToNext(); + break; + case 66: // b + case 75: // k + case 80: // p + goToPrevious(); + break; + } + }; +})(); +window.addEventListener('keydown', jumpToCode); diff --git a/coverage/lcov-report/favicon.png b/coverage/lcov-report/favicon.png new file mode 100644 index 0000000..c1525b8 Binary files /dev/null and b/coverage/lcov-report/favicon.png differ diff --git a/coverage/lcov-report/index.html b/coverage/lcov-report/index.html new file mode 100644 index 0000000..d8f46d4 --- /dev/null +++ b/coverage/lcov-report/index.html @@ -0,0 +1,101 @@ + + + + + + Code coverage report for All files + + + + + + + + + +
+
+

All files

+
+ +
+ Unknown% + Statements + 0/0 +
+ + +
+ Unknown% + Branches + 0/0 +
+ + +
+ Unknown% + Functions + 0/0 +
+ + +
+ Unknown% + Lines + 0/0 +
+ + +
+

+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +

+ +
+
+
+ + + + + + + + + + + + + + + + +
FileStatementsBranchesFunctionsLines
+
+
+
+
+ Code coverage generated by + istanbul + at 2025-12-20T12:11:01.527Z +
+ + + + + + + \ No newline at end of file diff --git a/coverage/lcov-report/prettify.css b/coverage/lcov-report/prettify.css new file mode 100644 index 0000000..b317a7c --- /dev/null +++ b/coverage/lcov-report/prettify.css @@ -0,0 +1 @@ +.pln{color:#000}@media screen{.str{color:#080}.kwd{color:#008}.com{color:#800}.typ{color:#606}.lit{color:#066}.pun,.opn,.clo{color:#660}.tag{color:#008}.atn{color:#606}.atv{color:#080}.dec,.var{color:#606}.fun{color:red}}@media print,projection{.str{color:#060}.kwd{color:#006;font-weight:bold}.com{color:#600;font-style:italic}.typ{color:#404;font-weight:bold}.lit{color:#044}.pun,.opn,.clo{color:#440}.tag{color:#006;font-weight:bold}.atn{color:#404}.atv{color:#060}}pre.prettyprint{padding:2px;border:1px solid #888}ol.linenums{margin-top:0;margin-bottom:0}li.L0,li.L1,li.L2,li.L3,li.L5,li.L6,li.L7,li.L8{list-style-type:none}li.L1,li.L3,li.L5,li.L7,li.L9{background:#eee} diff --git a/coverage/lcov-report/prettify.js b/coverage/lcov-report/prettify.js new file mode 100644 index 0000000..b322523 --- /dev/null +++ b/coverage/lcov-report/prettify.js @@ -0,0 +1,2 @@ +/* eslint-disable */ +window.PR_SHOULD_USE_CONTINUATION=true;(function(){var h=["break,continue,do,else,for,if,return,while"];var u=[h,"auto,case,char,const,default,double,enum,extern,float,goto,int,long,register,short,signed,sizeof,static,struct,switch,typedef,union,unsigned,void,volatile"];var p=[u,"catch,class,delete,false,import,new,operator,private,protected,public,this,throw,true,try,typeof"];var l=[p,"alignof,align_union,asm,axiom,bool,concept,concept_map,const_cast,constexpr,decltype,dynamic_cast,explicit,export,friend,inline,late_check,mutable,namespace,nullptr,reinterpret_cast,static_assert,static_cast,template,typeid,typename,using,virtual,where"];var x=[p,"abstract,boolean,byte,extends,final,finally,implements,import,instanceof,null,native,package,strictfp,super,synchronized,throws,transient"];var R=[x,"as,base,by,checked,decimal,delegate,descending,dynamic,event,fixed,foreach,from,group,implicit,in,interface,internal,into,is,lock,object,out,override,orderby,params,partial,readonly,ref,sbyte,sealed,stackalloc,string,select,uint,ulong,unchecked,unsafe,ushort,var"];var r="all,and,by,catch,class,else,extends,false,finally,for,if,in,is,isnt,loop,new,no,not,null,of,off,on,or,return,super,then,true,try,unless,until,when,while,yes";var w=[p,"debugger,eval,export,function,get,null,set,undefined,var,with,Infinity,NaN"];var s="caller,delete,die,do,dump,elsif,eval,exit,foreach,for,goto,if,import,last,local,my,next,no,our,print,package,redo,require,sub,undef,unless,until,use,wantarray,while,BEGIN,END";var I=[h,"and,as,assert,class,def,del,elif,except,exec,finally,from,global,import,in,is,lambda,nonlocal,not,or,pass,print,raise,try,with,yield,False,True,None"];var f=[h,"alias,and,begin,case,class,def,defined,elsif,end,ensure,false,in,module,next,nil,not,or,redo,rescue,retry,self,super,then,true,undef,unless,until,when,yield,BEGIN,END"];var H=[h,"case,done,elif,esac,eval,fi,function,in,local,set,then,until"];var A=[l,R,w,s+I,f,H];var e=/^(DIR|FILE|vector|(de|priority_)?queue|list|stack|(const_)?iterator|(multi)?(set|map)|bitset|u?(int|float)\d*)/;var C="str";var z="kwd";var j="com";var O="typ";var G="lit";var L="pun";var F="pln";var m="tag";var E="dec";var J="src";var P="atn";var n="atv";var N="nocode";var M="(?:^^\\.?|[+-]|\\!|\\!=|\\!==|\\#|\\%|\\%=|&|&&|&&=|&=|\\(|\\*|\\*=|\\+=|\\,|\\-=|\\->|\\/|\\/=|:|::|\\;|<|<<|<<=|<=|=|==|===|>|>=|>>|>>=|>>>|>>>=|\\?|\\@|\\[|\\^|\\^=|\\^\\^|\\^\\^=|\\{|\\||\\|=|\\|\\||\\|\\|=|\\~|break|case|continue|delete|do|else|finally|instanceof|return|throw|try|typeof)\\s*";function k(Z){var ad=0;var S=false;var ac=false;for(var V=0,U=Z.length;V122)){if(!(al<65||ag>90)){af.push([Math.max(65,ag)|32,Math.min(al,90)|32])}if(!(al<97||ag>122)){af.push([Math.max(97,ag)&~32,Math.min(al,122)&~32])}}}}af.sort(function(av,au){return(av[0]-au[0])||(au[1]-av[1])});var ai=[];var ap=[NaN,NaN];for(var ar=0;arat[0]){if(at[1]+1>at[0]){an.push("-")}an.push(T(at[1]))}}an.push("]");return an.join("")}function W(al){var aj=al.source.match(new RegExp("(?:\\[(?:[^\\x5C\\x5D]|\\\\[\\s\\S])*\\]|\\\\u[A-Fa-f0-9]{4}|\\\\x[A-Fa-f0-9]{2}|\\\\[0-9]+|\\\\[^ux0-9]|\\(\\?[:!=]|[\\(\\)\\^]|[^\\x5B\\x5C\\(\\)\\^]+)","g"));var ah=aj.length;var an=[];for(var ak=0,am=0;ak=2&&ai==="["){aj[ak]=X(ag)}else{if(ai!=="\\"){aj[ak]=ag.replace(/[a-zA-Z]/g,function(ao){var ap=ao.charCodeAt(0);return"["+String.fromCharCode(ap&~32,ap|32)+"]"})}}}}return aj.join("")}var aa=[];for(var V=0,U=Z.length;V=0;){S[ac.charAt(ae)]=Y}}var af=Y[1];var aa=""+af;if(!ag.hasOwnProperty(aa)){ah.push(af);ag[aa]=null}}ah.push(/[\0-\uffff]/);V=k(ah)})();var X=T.length;var W=function(ah){var Z=ah.sourceCode,Y=ah.basePos;var ad=[Y,F];var af=0;var an=Z.match(V)||[];var aj={};for(var ae=0,aq=an.length;ae=5&&"lang-"===ap.substring(0,5);if(am&&!(ai&&typeof ai[1]==="string")){am=false;ap=J}if(!am){aj[ag]=ap}}var ab=af;af+=ag.length;if(!am){ad.push(Y+ab,ap)}else{var al=ai[1];var ak=ag.indexOf(al);var ac=ak+al.length;if(ai[2]){ac=ag.length-ai[2].length;ak=ac-al.length}var ar=ap.substring(5);B(Y+ab,ag.substring(0,ak),W,ad);B(Y+ab+ak,al,q(ar,al),ad);B(Y+ab+ac,ag.substring(ac),W,ad)}}ah.decorations=ad};return W}function i(T){var W=[],S=[];if(T.tripleQuotedStrings){W.push([C,/^(?:\'\'\'(?:[^\'\\]|\\[\s\S]|\'{1,2}(?=[^\']))*(?:\'\'\'|$)|\"\"\"(?:[^\"\\]|\\[\s\S]|\"{1,2}(?=[^\"]))*(?:\"\"\"|$)|\'(?:[^\\\']|\\[\s\S])*(?:\'|$)|\"(?:[^\\\"]|\\[\s\S])*(?:\"|$))/,null,"'\""])}else{if(T.multiLineStrings){W.push([C,/^(?:\'(?:[^\\\']|\\[\s\S])*(?:\'|$)|\"(?:[^\\\"]|\\[\s\S])*(?:\"|$)|\`(?:[^\\\`]|\\[\s\S])*(?:\`|$))/,null,"'\"`"])}else{W.push([C,/^(?:\'(?:[^\\\'\r\n]|\\.)*(?:\'|$)|\"(?:[^\\\"\r\n]|\\.)*(?:\"|$))/,null,"\"'"])}}if(T.verbatimStrings){S.push([C,/^@\"(?:[^\"]|\"\")*(?:\"|$)/,null])}var Y=T.hashComments;if(Y){if(T.cStyleComments){if(Y>1){W.push([j,/^#(?:##(?:[^#]|#(?!##))*(?:###|$)|.*)/,null,"#"])}else{W.push([j,/^#(?:(?:define|elif|else|endif|error|ifdef|include|ifndef|line|pragma|undef|warning)\b|[^\r\n]*)/,null,"#"])}S.push([C,/^<(?:(?:(?:\.\.\/)*|\/?)(?:[\w-]+(?:\/[\w-]+)+)?[\w-]+\.h|[a-z]\w*)>/,null])}else{W.push([j,/^#[^\r\n]*/,null,"#"])}}if(T.cStyleComments){S.push([j,/^\/\/[^\r\n]*/,null]);S.push([j,/^\/\*[\s\S]*?(?:\*\/|$)/,null])}if(T.regexLiterals){var X=("/(?=[^/*])(?:[^/\\x5B\\x5C]|\\x5C[\\s\\S]|\\x5B(?:[^\\x5C\\x5D]|\\x5C[\\s\\S])*(?:\\x5D|$))+/");S.push(["lang-regex",new RegExp("^"+M+"("+X+")")])}var V=T.types;if(V){S.push([O,V])}var U=(""+T.keywords).replace(/^ | $/g,"");if(U.length){S.push([z,new RegExp("^(?:"+U.replace(/[\s,]+/g,"|")+")\\b"),null])}W.push([F,/^\s+/,null," \r\n\t\xA0"]);S.push([G,/^@[a-z_$][a-z_$@0-9]*/i,null],[O,/^(?:[@_]?[A-Z]+[a-z][A-Za-z_$@0-9]*|\w+_t\b)/,null],[F,/^[a-z_$][a-z_$@0-9]*/i,null],[G,new RegExp("^(?:0x[a-f0-9]+|(?:\\d(?:_\\d+)*\\d*(?:\\.\\d*)?|\\.\\d\\+)(?:e[+\\-]?\\d+)?)[a-z]*","i"),null,"0123456789"],[F,/^\\[\s\S]?/,null],[L,/^.[^\s\w\.$@\'\"\`\/\#\\]*/,null]);return g(W,S)}var K=i({keywords:A,hashComments:true,cStyleComments:true,multiLineStrings:true,regexLiterals:true});function Q(V,ag){var U=/(?:^|\s)nocode(?:\s|$)/;var ab=/\r\n?|\n/;var ac=V.ownerDocument;var S;if(V.currentStyle){S=V.currentStyle.whiteSpace}else{if(window.getComputedStyle){S=ac.defaultView.getComputedStyle(V,null).getPropertyValue("white-space")}}var Z=S&&"pre"===S.substring(0,3);var af=ac.createElement("LI");while(V.firstChild){af.appendChild(V.firstChild)}var W=[af];function ae(al){switch(al.nodeType){case 1:if(U.test(al.className)){break}if("BR"===al.nodeName){ad(al);if(al.parentNode){al.parentNode.removeChild(al)}}else{for(var an=al.firstChild;an;an=an.nextSibling){ae(an)}}break;case 3:case 4:if(Z){var am=al.nodeValue;var aj=am.match(ab);if(aj){var ai=am.substring(0,aj.index);al.nodeValue=ai;var ah=am.substring(aj.index+aj[0].length);if(ah){var ak=al.parentNode;ak.insertBefore(ac.createTextNode(ah),al.nextSibling)}ad(al);if(!ai){al.parentNode.removeChild(al)}}}break}}function ad(ak){while(!ak.nextSibling){ak=ak.parentNode;if(!ak){return}}function ai(al,ar){var aq=ar?al.cloneNode(false):al;var ao=al.parentNode;if(ao){var ap=ai(ao,1);var an=al.nextSibling;ap.appendChild(aq);for(var am=an;am;am=an){an=am.nextSibling;ap.appendChild(am)}}return aq}var ah=ai(ak.nextSibling,0);for(var aj;(aj=ah.parentNode)&&aj.nodeType===1;){ah=aj}W.push(ah)}for(var Y=0;Y=S){ah+=2}if(V>=ap){Z+=2}}}var t={};function c(U,V){for(var S=V.length;--S>=0;){var T=V[S];if(!t.hasOwnProperty(T)){t[T]=U}else{if(window.console){console.warn("cannot override language handler %s",T)}}}}function q(T,S){if(!(T&&t.hasOwnProperty(T))){T=/^\s*]*(?:>|$)/],[j,/^<\!--[\s\S]*?(?:-\->|$)/],["lang-",/^<\?([\s\S]+?)(?:\?>|$)/],["lang-",/^<%([\s\S]+?)(?:%>|$)/],[L,/^(?:<[%?]|[%?]>)/],["lang-",/^]*>([\s\S]+?)<\/xmp\b[^>]*>/i],["lang-js",/^]*>([\s\S]*?)(<\/script\b[^>]*>)/i],["lang-css",/^]*>([\s\S]*?)(<\/style\b[^>]*>)/i],["lang-in.tag",/^(<\/?[a-z][^<>]*>)/i]]),["default-markup","htm","html","mxml","xhtml","xml","xsl"]);c(g([[F,/^[\s]+/,null," \t\r\n"],[n,/^(?:\"[^\"]*\"?|\'[^\']*\'?)/,null,"\"'"]],[[m,/^^<\/?[a-z](?:[\w.:-]*\w)?|\/?>$/i],[P,/^(?!style[\s=]|on)[a-z](?:[\w:-]*\w)?/i],["lang-uq.val",/^=\s*([^>\'\"\s]*(?:[^>\'\"\s\/]|\/(?=\s)))/],[L,/^[=<>\/]+/],["lang-js",/^on\w+\s*=\s*\"([^\"]+)\"/i],["lang-js",/^on\w+\s*=\s*\'([^\']+)\'/i],["lang-js",/^on\w+\s*=\s*([^\"\'>\s]+)/i],["lang-css",/^style\s*=\s*\"([^\"]+)\"/i],["lang-css",/^style\s*=\s*\'([^\']+)\'/i],["lang-css",/^style\s*=\s*([^\"\'>\s]+)/i]]),["in.tag"]);c(g([],[[n,/^[\s\S]+/]]),["uq.val"]);c(i({keywords:l,hashComments:true,cStyleComments:true,types:e}),["c","cc","cpp","cxx","cyc","m"]);c(i({keywords:"null,true,false"}),["json"]);c(i({keywords:R,hashComments:true,cStyleComments:true,verbatimStrings:true,types:e}),["cs"]);c(i({keywords:x,cStyleComments:true}),["java"]);c(i({keywords:H,hashComments:true,multiLineStrings:true}),["bsh","csh","sh"]);c(i({keywords:I,hashComments:true,multiLineStrings:true,tripleQuotedStrings:true}),["cv","py"]);c(i({keywords:s,hashComments:true,multiLineStrings:true,regexLiterals:true}),["perl","pl","pm"]);c(i({keywords:f,hashComments:true,multiLineStrings:true,regexLiterals:true}),["rb"]);c(i({keywords:w,cStyleComments:true,regexLiterals:true}),["js"]);c(i({keywords:r,hashComments:3,cStyleComments:true,multilineStrings:true,tripleQuotedStrings:true,regexLiterals:true}),["coffee"]);c(g([],[[C,/^[\s\S]+/]]),["regex"]);function d(V){var U=V.langExtension;try{var S=a(V.sourceNode);var T=S.sourceCode;V.sourceCode=T;V.spans=S.spans;V.basePos=0;q(U,T)(V);D(V)}catch(W){if("console" in window){console.log(W&&W.stack?W.stack:W)}}}function y(W,V,U){var S=document.createElement("PRE");S.innerHTML=W;if(U){Q(S,U)}var T={langExtension:V,numberLines:U,sourceNode:S};d(T);return S.innerHTML}function b(ad){function Y(af){return document.getElementsByTagName(af)}var ac=[Y("pre"),Y("code"),Y("xmp")];var T=[];for(var aa=0;aa=0){var ah=ai.match(ab);var am;if(!ah&&(am=o(aj))&&"CODE"===am.tagName){ah=am.className.match(ab)}if(ah){ah=ah[1]}var al=false;for(var ak=aj.parentNode;ak;ak=ak.parentNode){if((ak.tagName==="pre"||ak.tagName==="code"||ak.tagName==="xmp")&&ak.className&&ak.className.indexOf("prettyprint")>=0){al=true;break}}if(!al){var af=aj.className.match(/\blinenums\b(?::(\d+))?/);af=af?af[1]&&af[1].length?+af[1]:true:false;if(af){Q(aj,af)}S={langExtension:ah,sourceNode:aj,numberLines:af};d(S)}}}if(X]*(?:>|$)/],[PR.PR_COMMENT,/^<\!--[\s\S]*?(?:-\->|$)/],[PR.PR_PUNCTUATION,/^(?:<[%?]|[%?]>)/],["lang-",/^<\?([\s\S]+?)(?:\?>|$)/],["lang-",/^<%([\s\S]+?)(?:%>|$)/],["lang-",/^]*>([\s\S]+?)<\/xmp\b[^>]*>/i],["lang-handlebars",/^]*type\s*=\s*['"]?text\/x-handlebars-template['"]?\b[^>]*>([\s\S]*?)(<\/script\b[^>]*>)/i],["lang-js",/^]*>([\s\S]*?)(<\/script\b[^>]*>)/i],["lang-css",/^]*>([\s\S]*?)(<\/style\b[^>]*>)/i],["lang-in.tag",/^(<\/?[a-z][^<>]*>)/i],[PR.PR_DECLARATION,/^{{[#^>/]?\s*[\w.][^}]*}}/],[PR.PR_DECLARATION,/^{{&?\s*[\w.][^}]*}}/],[PR.PR_DECLARATION,/^{{{>?\s*[\w.][^}]*}}}/],[PR.PR_COMMENT,/^{{![^}]*}}/]]),["handlebars","hbs"]);PR.registerLangHandler(PR.createSimpleLexer([[PR.PR_PLAIN,/^[ \t\r\n\f]+/,null," \t\r\n\f"]],[[PR.PR_STRING,/^\"(?:[^\n\r\f\\\"]|\\(?:\r\n?|\n|\f)|\\[\s\S])*\"/,null],[PR.PR_STRING,/^\'(?:[^\n\r\f\\\']|\\(?:\r\n?|\n|\f)|\\[\s\S])*\'/,null],["lang-css-str",/^url\(([^\)\"\']*)\)/i],[PR.PR_KEYWORD,/^(?:url|rgb|\!important|@import|@page|@media|@charset|inherit)(?=[^\-\w]|$)/i,null],["lang-css-kw",/^(-?(?:[_a-z]|(?:\\[0-9a-f]+ ?))(?:[_a-z0-9\-]|\\(?:\\[0-9a-f]+ ?))*)\s*:/i],[PR.PR_COMMENT,/^\/\*[^*]*\*+(?:[^\/*][^*]*\*+)*\//],[PR.PR_COMMENT,/^(?:)/],[PR.PR_LITERAL,/^(?:\d+|\d*\.\d+)(?:%|[a-z]+)?/i],[PR.PR_LITERAL,/^#(?:[0-9a-f]{3}){1,2}/i],[PR.PR_PLAIN,/^-?(?:[_a-z]|(?:\\[\da-f]+ ?))(?:[_a-z\d\-]|\\(?:\\[\da-f]+ ?))*/i],[PR.PR_PUNCTUATION,/^[^\s\w\'\"]+/]]),["css"]);PR.registerLangHandler(PR.createSimpleLexer([],[[PR.PR_KEYWORD,/^-?(?:[_a-z]|(?:\\[\da-f]+ ?))(?:[_a-z\d\-]|\\(?:\\[\da-f]+ ?))*/i]]),["css-kw"]);PR.registerLangHandler(PR.createSimpleLexer([],[[PR.PR_STRING,/^[^\)\"\']+/]]),["css-str"]); diff --git a/coverage/lcov-report/sort-arrow-sprite.png b/coverage/lcov-report/sort-arrow-sprite.png new file mode 100644 index 0000000..6ed6831 Binary files /dev/null and b/coverage/lcov-report/sort-arrow-sprite.png differ diff --git a/coverage/lcov-report/sorter.js b/coverage/lcov-report/sorter.js new file mode 100644 index 0000000..4ed70ae --- /dev/null +++ b/coverage/lcov-report/sorter.js @@ -0,0 +1,210 @@ +/* eslint-disable */ +var addSorting = (function() { + 'use strict'; + var cols, + currentSort = { + index: 0, + desc: false + }; + + // returns the summary table element + function getTable() { + return document.querySelector('.coverage-summary'); + } + // returns the thead element of the summary table + function getTableHeader() { + return getTable().querySelector('thead tr'); + } + // returns the tbody element of the summary table + function getTableBody() { + return getTable().querySelector('tbody'); + } + // returns the th element for nth column + function getNthColumn(n) { + return getTableHeader().querySelectorAll('th')[n]; + } + + function onFilterInput() { + const searchValue = document.getElementById('fileSearch').value; + const rows = document.getElementsByTagName('tbody')[0].children; + + // Try to create a RegExp from the searchValue. If it fails (invalid regex), + // it will be treated as a plain text search + let searchRegex; + try { + searchRegex = new RegExp(searchValue, 'i'); // 'i' for case-insensitive + } catch (error) { + searchRegex = null; + } + + for (let i = 0; i < rows.length; i++) { + const row = rows[i]; + let isMatch = false; + + if (searchRegex) { + // If a valid regex was created, use it for matching + isMatch = searchRegex.test(row.textContent); + } else { + // Otherwise, fall back to the original plain text search + isMatch = row.textContent + .toLowerCase() + .includes(searchValue.toLowerCase()); + } + + row.style.display = isMatch ? '' : 'none'; + } + } + + // loads the search box + function addSearchBox() { + var template = document.getElementById('filterTemplate'); + var templateClone = template.content.cloneNode(true); + templateClone.getElementById('fileSearch').oninput = onFilterInput; + template.parentElement.appendChild(templateClone); + } + + // loads all columns + function loadColumns() { + var colNodes = getTableHeader().querySelectorAll('th'), + colNode, + cols = [], + col, + i; + + for (i = 0; i < colNodes.length; i += 1) { + colNode = colNodes[i]; + col = { + key: colNode.getAttribute('data-col'), + sortable: !colNode.getAttribute('data-nosort'), + type: colNode.getAttribute('data-type') || 'string' + }; + cols.push(col); + if (col.sortable) { + col.defaultDescSort = col.type === 'number'; + colNode.innerHTML = + colNode.innerHTML + ''; + } + } + return cols; + } + // attaches a data attribute to every tr element with an object + // of data values keyed by column name + function loadRowData(tableRow) { + var tableCols = tableRow.querySelectorAll('td'), + colNode, + col, + data = {}, + i, + val; + for (i = 0; i < tableCols.length; i += 1) { + colNode = tableCols[i]; + col = cols[i]; + val = colNode.getAttribute('data-value'); + if (col.type === 'number') { + val = Number(val); + } + data[col.key] = val; + } + return data; + } + // loads all row data + function loadData() { + var rows = getTableBody().querySelectorAll('tr'), + i; + + for (i = 0; i < rows.length; i += 1) { + rows[i].data = loadRowData(rows[i]); + } + } + // sorts the table using the data for the ith column + function sortByIndex(index, desc) { + var key = cols[index].key, + sorter = function(a, b) { + a = a.data[key]; + b = b.data[key]; + return a < b ? -1 : a > b ? 1 : 0; + }, + finalSorter = sorter, + tableBody = document.querySelector('.coverage-summary tbody'), + rowNodes = tableBody.querySelectorAll('tr'), + rows = [], + i; + + if (desc) { + finalSorter = function(a, b) { + return -1 * sorter(a, b); + }; + } + + for (i = 0; i < rowNodes.length; i += 1) { + rows.push(rowNodes[i]); + tableBody.removeChild(rowNodes[i]); + } + + rows.sort(finalSorter); + + for (i = 0; i < rows.length; i += 1) { + tableBody.appendChild(rows[i]); + } + } + // removes sort indicators for current column being sorted + function removeSortIndicators() { + var col = getNthColumn(currentSort.index), + cls = col.className; + + cls = cls.replace(/ sorted$/, '').replace(/ sorted-desc$/, ''); + col.className = cls; + } + // adds sort indicators for current column being sorted + function addSortIndicators() { + getNthColumn(currentSort.index).className += currentSort.desc + ? ' sorted-desc' + : ' sorted'; + } + // adds event listeners for all sorter widgets + function enableUI() { + var i, + el, + ithSorter = function ithSorter(i) { + var col = cols[i]; + + return function() { + var desc = col.defaultDescSort; + + if (currentSort.index === i) { + desc = !currentSort.desc; + } + sortByIndex(i, desc); + removeSortIndicators(); + currentSort.index = i; + currentSort.desc = desc; + addSortIndicators(); + }; + }; + for (i = 0; i < cols.length; i += 1) { + if (cols[i].sortable) { + // add the click event handler on the th so users + // dont have to click on those tiny arrows + el = getNthColumn(i).querySelector('.sorter').parentElement; + if (el.addEventListener) { + el.addEventListener('click', ithSorter(i)); + } else { + el.attachEvent('onclick', ithSorter(i)); + } + } + } + } + // adds sorting functionality to the UI + return function() { + if (!getTable()) { + return; + } + cols = loadColumns(); + loadData(); + addSearchBox(); + addSortIndicators(); + enableUI(); + }; +})(); + +window.addEventListener('load', addSorting); diff --git a/coverage/lcov.info b/coverage/lcov.info new file mode 100644 index 0000000..e69de29 diff --git a/docs/resources.md b/docs/resources.md new file mode 100644 index 0000000..5dbae60 --- /dev/null +++ b/docs/resources.md @@ -0,0 +1,5 @@ + + +https://fikunmi.substack.com/p/making-680-apr-with-meteoras-dlmms +https://www.youtube.com/watch?v=HV-Enxuet60 + diff --git a/jest.config.js b/jest.config.js new file mode 100644 index 0000000..d1f666a --- /dev/null +++ b/jest.config.js @@ -0,0 +1,8 @@ +module.exports = { + preset: 'ts-jest', + testEnvironment: 'node', + testMatch: ['**/tests/**/*.test.ts'], + collectCoverage: true, + coverageDirectory: 'coverage', + coveragePathIgnorePatterns: ['/node_modules/'], +}; diff --git a/package.json b/package.json new file mode 100644 index 0000000..872963c --- /dev/null +++ b/package.json @@ -0,0 +1,47 @@ +{ + "name": "meteora-dlmm-bot", + "version": "1.0.0", + "description": "", + "main": "index.js", + "directories": { + "doc": "docs" + }, + "scripts": { + "start": "ts-node src/index.ts", + "build": "tsc", + "test": "jest", + "test:watch": "jest --watch", + "lint": "eslint 'src/**/*.ts' 'tests/**/*.ts'", + "lint:fix": "eslint 'src/**/*.ts' 'tests/**/*.ts' --fix", + "withdraw": "ts-node src/withdraw.ts", + "withdraw:prod": "node dist/withdraw.js" + }, + "keywords": [], + "author": "", + "license": "ISC", + "dependencies": { + "@jup-ag/api": "^6.0.47", + "@meteora-ag/dlmm": "^1.9.0", + "@solana/web3.js": "^1.98.4", + "@types/node": "^25.0.3", + "bs58": "^5.0.0", + "decimal.js": "^10.6.0", + "dotenv": "^17.2.3", + "node-cron": "^4.2.1", + "pino": "^10.1.0", + "pino-pretty": "^13.1.3" + }, + "devDependencies": { + "@types/jest": "^29.5.12", + "@typescript-eslint/eslint-plugin": "^7.18.0", + "@typescript-eslint/parser": "^7.18.0", + "eslint": "^8.57.0", + "eslint-config-prettier": "^9.1.0", + "eslint-plugin-prettier": "^5.2.1", + "jest": "^29.7.0", + "prettier": "^3.3.3", + "ts-jest": "^29.2.5", + "ts-node": "^10.9.2", + "typescript": "^5.5.4" + } +} \ No newline at end of file diff --git a/report.md b/report.md new file mode 100644 index 0000000..e69de29 diff --git a/src/bot.ts b/src/bot.ts new file mode 100644 index 0000000..7454c54 --- /dev/null +++ b/src/bot.ts @@ -0,0 +1,191 @@ +import { MeteoraWrapper } from "./meteora"; +import logger from "./utils/logger"; +import { REBALANCE_THRESHOLD_PERCENT, COMPOUND_THRESHOLD_USD, JLP_USD_ESTIMATE, SOL_USD_ESTIMATE } from "./utils/config"; +import { getSwapQuote, executeSwap } from "./swap"; +import { PublicKey } from "@solana/web3.js"; +import { BN } from "@coral-xyz/anchor"; + +export class DLMMBot { + private meteora: MeteoraWrapper; + + constructor() { + this.meteora = new MeteoraWrapper(); + } + + async init(): Promise { + await this.meteora.init(); + } + + async rebalance(): Promise { + const startTime = new Date().toISOString(); + try { + logger.info(`--- Portfolio Status Report [${startTime}] ---`); + + // Force refresh of pool data in each cycle + await this.meteora.init(); + + const activeBin = await this.meteora.getActiveBin(); + const positions = await this.meteora.getPositions(); + + logger.info(`Active Bin ID: ${activeBin.binId}`); + logger.info(`Number of active positions: ${positions.length}`); + + if (positions.length === 0) { + logger.info( + "No active positions found. Checking for tokens to deposit..." + ); + await this.handleInitialDeposit(activeBin.binId); + return; + } + + let priceRangeRebalance = false; + for (const position of positions) { + const lowerBinId = position.positionData.lowerBinId; + const upperBinId = position.positionData.upperBinId; + const range = upperBinId - lowerBinId; + + const threshold = Math.floor(range * REBALANCE_THRESHOLD_PERCENT); + const lowerBoundary = lowerBinId + threshold; + const upperBoundary = upperBinId - threshold; + + const distanceToLower = activeBin.binId - lowerBoundary; + const distanceToUpper = upperBoundary - activeBin.binId; + + logger.info(`Position ${position.publicKey.toBase58()}: Range [${lowerBinId}, ${upperBinId}], Threshold Boundary [${lowerBoundary}, ${upperBoundary}]`); + logger.info(`Distance to boundaries: Lower=+${distanceToLower}, Upper=+${distanceToUpper}`); + + if (activeBin.binId <= lowerBoundary || activeBin.binId >= upperBoundary) { + logger.info("Active bin reached boundary. Price range rebalance required."); + priceRangeRebalance = true; + break; + } + } + + let rebalanceRequired = priceRangeRebalance; + let totalValueUSD = 0; + let hasSubstantialBalance = false; + + if (!rebalanceRequired) { + // Value-based compound check + const { balanceX, balanceY } = await this.meteora.getBalances(); + const tokenX = this.meteora.dlmmPool?.tokenX; + const tokenY = this.meteora.dlmmPool?.tokenY; + + if (!tokenX || !tokenY) { + logger.warn("Pool tokens not available for value calculation."); + return; + } + + const totalX = balanceX.toNumber() / 10 ** (tokenX.mint as any).decimals; + const totalY = balanceY.toNumber() / 10 ** (tokenY.mint as any).decimals; + + const isXSol = tokenX.mint.address.toBase58() === "So11111111111111111111111111111111111111112"; + const isYSol = tokenY.mint.address.toBase58() === "So11111111111111111111111111111111111111112"; + + let valueX = 0; + let valueY = 0; + + if (isXSol) { + valueX = totalX * SOL_USD_ESTIMATE; + valueY = totalY * JLP_USD_ESTIMATE; + } else if (isYSol) { + valueY = totalY * SOL_USD_ESTIMATE; + valueX = totalX * JLP_USD_ESTIMATE; + } else { + valueX = totalX * JLP_USD_ESTIMATE; + valueY = totalY * JLP_USD_ESTIMATE; + } + + totalValueUSD = valueX + valueY; + hasSubstantialBalance = totalValueUSD >= COMPOUND_THRESHOLD_USD; + + if (hasSubstantialBalance) { + logger.info(`Substantial wallet balance detected ($${totalValueUSD.toFixed(2)}). Triggering value-based compounding...`); + rebalanceRequired = true; + } else { + logger.info(`Portfolio healthy. Uninvested balance ($${totalValueUSD.toFixed(2)}) is below threshold ($${COMPOUND_THRESHOLD_USD}).`); + logger.info(`--- Cycle Complete [${new Date().toISOString()}] ---`); + return; + } + } + + await this.meteora.withdrawAll(); + // Claim fees after withdrawal to consolidate balances + await this.meteora.claimFees(); + + const { balanceX, balanceY } = await this.meteora.getBalances(); + if (balanceX.isZero() && balanceY.isZero()) { + logger.warn("No balances available to re-deposit after withdrawal."); + return; + } + + // Financial Safety: Only skip if NOT a price-range rebalance and value is too low + const estimatedFeeUSD = 0.005 * SOL_USD_ESTIMATE; + if (!priceRangeRebalance && totalValueUSD < estimatedFeeUSD) { + logger.warn(`Skipping compounding: Total uninvested value ($${totalValueUSD.toFixed(2)}) is less than estimated transaction fees ($${estimatedFeeUSD.toFixed(2)}).`); + return; + } + + await this.meteora.deposit(balanceX, balanceY, activeBin.binId); + logger.info("Rebalance/Compounding completed successfully."); + + logger.info(`--- Cycle Complete [${new Date().toISOString()}] ---`); + } catch (error: any) { + logger.error(`CRITICAL: Error during rebalance cycle: ${error.message}`); + } + } + + private async handleInitialDeposit(activeBinId: number): Promise { + let { balanceX, balanceY } = await this.meteora.getBalances(); + + if (balanceX.isZero() && balanceY.isZero()) { + logger.info("No token balances found for initial deposit."); + return; + } + + // Balanced investment logic: if one side is zero, swap 50% + const SOL_MINT = "So11111111111111111111111111111111111111112"; + const pool = this.meteora.dlmmPool; + if (!pool) { + logger.error("Pool not initialized during handleInitialDeposit."); + return; + } + const isXSol = pool.tokenX.mint.address.toBase58() === SOL_MINT; + const isYSol = pool.tokenY.mint.address.toBase58() === SOL_MINT; + + if (balanceX.isZero() || balanceY.isZero()) { + logger.info("Single asset detected. Performing 50/50 swap to balance the position..."); + try { + if (isXSol && !balanceX.isZero()) { + const swapAmount = balanceX.div(new BN(2)).toNumber(); + logger.info(`Swapping ${swapAmount / 1e9} SOL for TokenY...`); + const quote = await getSwapQuote(SOL_MINT, pool.tokenY.mint.address.toBase58(), swapAmount); + await executeSwap(quote); + } else if (isYSol && !balanceY.isZero()) { + const swapAmount = balanceY.div(new BN(2)).toNumber(); + logger.info(`Swapping ${swapAmount / 1e9} SOL for TokenX...`); + const quote = await getSwapQuote(SOL_MINT, pool.tokenX.mint.address.toBase58(), swapAmount); + await executeSwap(quote); + } else { + logger.warn("Only non-SOL asset detected. Proceeding with single-sided deposit (no auto-swap for non-SOL yet)."); + } + + // Refetch balances after swap + ({ balanceX, balanceY } = await this.meteora.getBalances()); + } catch (error: any) { + logger.error(`Swap failed during initial deposit: ${error.message}. Proceeding with current balances.`); + } + } + + logger.info( + `Initial deposit: X=${balanceX.toString()}, Y=${balanceY.toString()}` + ); + await this.meteora.deposit(balanceX, balanceY, activeBinId); + } + + async compound(): Promise { + logger.info("Starting compounding..."); + await this.meteora.claimFees(); + logger.info("Compounding finished."); + } +} diff --git a/src/index.ts b/src/index.ts new file mode 100644 index 0000000..4fd7275 --- /dev/null +++ b/src/index.ts @@ -0,0 +1,45 @@ +import cron from "node-cron"; +import { DLMMBot } from "./bot"; +import { CHECK_INTERVAL_CRON, COMPOUND_INTERVAL_CRON } from "./utils/config"; +import logger from "./utils/logger"; + +async function main() { + logger.info("Meteora DLMM Bot starting..."); + const bot = new DLMMBot(); + await bot.init(); + + logger.info("Running initial rebalance check..."); + try { + await bot.rebalance(); + } catch (error: any) { + logger.error(`Initial rebalance check failed: ${error.message}`); + } + + // Schedule rebalance (hourly by default) + cron.schedule(CHECK_INTERVAL_CRON, async () => { + try { + await bot.rebalance(); + } catch (error: any) { + logger.error(`Error during rebalance: ${error.message}`); + } + }); + + // Schedule compound (daily by default) + cron.schedule(COMPOUND_INTERVAL_CRON, async () => { + try { + await bot.compound(); + } catch (error: any) { + logger.error(`Error during compounding: ${error.message}`); + } + }); + + logger.info(`Bot scheduled with check interval: ${CHECK_INTERVAL_CRON}`); + logger.info( + `Bot scheduled with compound interval: ${COMPOUND_INTERVAL_CRON}` + ); +} + +main().catch((err) => { + logger.error(`Fatal error: ${err.message}`); + process.exit(1); +}); diff --git a/src/meteora.ts b/src/meteora.ts new file mode 100644 index 0000000..c82a098 --- /dev/null +++ b/src/meteora.ts @@ -0,0 +1,234 @@ +import DLMM, { StrategyType } from "@meteora-ag/dlmm"; +import { + sendAndConfirmTransaction, + Keypair, + PublicKey, +} from "@solana/web3.js"; +import { DRY_RUN, wallet, connection, poolAddress, MIN_SOL_FOR_GAS, SLIPPAGE_BPS, MAX_RETRIES } from "./utils/config"; +import logger from "./utils/logger"; +import { BN } from "@coral-xyz/anchor"; +import { getAccount, getAssociatedTokenAddress } from "@solana/spl-token"; + +export class MeteoraWrapper { + public dlmmPool: DLMM | null = null; + + async init() { + this.dlmmPool = await DLMM.create(connection, poolAddress); + logger.info(`DLMM Pool initialized: ${poolAddress.toBase58()}`); + } + + async getActiveBin() { + if (!this.dlmmPool) throw new Error("Pool not initialized"); + return await this.dlmmPool.getActiveBin(); + } + + async getPositions() { + if (!this.dlmmPool) throw new Error("Pool not initialized"); + const { userPositions } = await this.dlmmPool.getPositionsByUserAndLbPair( + wallet.publicKey + ); + return userPositions; + } + + async withdrawAll() { + if (!this.dlmmPool) throw new Error("Pool not initialized"); + const positions = await this.getPositions(); + + for (const position of positions) { + logger.info( + `Withdrawing from position: ${position.publicKey.toBase58()}` + ); + + const minBinId = position.positionData.lowerBinId; + const maxBinId = position.positionData.upperBinId; + + try { + const transactions = await this.dlmmPool.removeLiquidity({ + position: position.publicKey, + user: wallet.publicKey, + fromBinId: minBinId, + toBinId: maxBinId, + bps: new BN(10000), // 100% + shouldClaimAndClose: true, + }); + + for (const tx of transactions) { + if (DRY_RUN) { + logger.info("[DRY RUN] Withdrawal transaction part skipped."); + continue; + } + const txHash = await this.sendTransactionWithRetry(tx); + logger.info(`Withdrawal part successful: ${txHash}`); + } + } catch (error: any) { + logger.error( + `Failed to withdraw from position ${position.publicKey.toBase58()}: ${error?.message || "Unknown error"}` + ); + throw error; + } + } + } + + async deposit(amountX: BN, amountY: BN, activeBinId: number) { + if (!this.dlmmPool) throw new Error("Pool not initialized"); + + const range = 15; + const minBinId = activeBinId - range; + const maxBinId = activeBinId + range; + + const tokenXSymbol = this.dlmmPool.tokenX.mint.address.equals(new PublicKey("So11111111111111111111111111111111111111112")) ? "SOL" : "TokenX"; + const tokenYSymbol = this.dlmmPool.tokenY.mint.address.equals(new PublicKey("So11111111111111111111111111111111111111112")) ? "SOL" : "TokenY"; + + logger.info( + `Depositing liquidity: ${amountX.toString()} ${tokenXSymbol}, ${amountY.toString()} ${tokenYSymbol} in range [${minBinId}, ${maxBinId}] around bin ${activeBinId}` + ); + + try { + const positionKeypair = Keypair.generate(); + const tx = + await this.dlmmPool.initializePositionAndAddLiquidityByStrategy({ + positionPubKey: positionKeypair.publicKey, + user: wallet.publicKey, + totalXAmount: amountX, + totalYAmount: amountY, + strategy: { + maxBinId, + minBinId, + strategyType: StrategyType.Spot, + }, + slippage: SLIPPAGE_BPS / 100, // Convert BPS to percentage (100 BPS = 1%) + }); + + if (DRY_RUN) { + logger.info("[DRY RUN] Deposit transaction created but not sent."); + return; + } + + const txHash = await this.sendTransactionWithRetry(tx, [positionKeypair]); + logger.info(`Deposit successful! Transaction Hash: ${txHash}`); + } catch (error: any) { + logger.error(`Deposit failed: ${error?.message || "Unknown error"}`); + throw error; + } + } + + private async sendTransactionWithRetry(tx: any, additionalSigners: Keypair[] = [], retries: number = MAX_RETRIES): Promise { + let lastError: any; + const signers = [wallet, ...additionalSigners]; + for (let i = 0; i < retries + 1; i++) { + try { + return await sendAndConfirmTransaction(connection, tx, signers); + } catch (error: any) { + lastError = error; + if (i < retries) { + const delay = Math.pow(2, i) * 2000; + logger.warn(`Transaction failed, retrying in ${delay / 1000}s (${i + 1}/${retries})... Error: ${error.message}`); + await new Promise(res => setTimeout(res, delay)); + } + } + } + throw lastError; + } + + async getBalances(): Promise<{ balanceX: BN; balanceY: BN }> { + if (!this.dlmmPool) throw new Error("Pool not initialized"); + + const tokenXMint = this.dlmmPool.tokenX.mint.address; + const tokenYMint = this.dlmmPool.tokenY.mint.address; + const SOL_MINT = new PublicKey("So11111111111111111111111111111111111111112"); + + let balanceX = new BN(0); + let balanceY = new BN(0); + + const tokenXLabel = tokenXMint.equals(SOL_MINT) ? "SOL" : tokenXMint.toBase58().slice(0, 4) + "..."; + const tokenYLabel = tokenYMint.equals(SOL_MINT) ? "SOL" : tokenYMint.toBase58().slice(0, 4) + "..."; + + // Fetch Token X balance + if (tokenXMint.equals(SOL_MINT)) { + const solBalance = await connection.getBalance(wallet.publicKey); + // Reserve MIN_SOL_FOR_GAS for fees and rent + const buffer = MIN_SOL_FOR_GAS * 10 ** 9; + balanceX = new BN(Math.max(0, solBalance - buffer)); + logger.info(`Wallet Balance (Native SOL): ${(solBalance / 10 ** 9).toFixed(4)} SOL (${solBalance} lamports). Available for deposit: ${(balanceX.toNumber() / 10 ** 9).toFixed(4)} SOL`); + + if (solBalance < 0.2 * 10 ** 9) { + logger.warn("CRITICAL: Wallet SOL balance is below 0.2 SOL. Transactions may fail soon due to rent!"); + } + } else { + try { + const tokenXATA = await getAssociatedTokenAddress(tokenXMint, wallet.publicKey); + const accountX = await getAccount(connection, tokenXATA); + const rawAmount = new BN(accountX.amount.toString()); + // Subtract dust (0.0001 tokens) to keep ATA alive if amount > 0.0001 + const decimals = (this.dlmmPool.tokenX.mint as any).decimals || 0; + const dust = new BN(0.0001 * 10 ** decimals); + balanceX = rawAmount.gt(dust) ? rawAmount.sub(dust) : new BN(0); + logger.info(`Wallet Balance (${tokenXLabel}): ${(balanceX.toNumber() / 10 ** decimals).toFixed(4)} (Total: ${rawAmount.toString()} lamports)`); + } catch { + logger.debug(`Token X ATA not found: ${tokenXMint.toBase58()}`); + } + } + + // Fetch Token Y balance + if (tokenYMint.equals(SOL_MINT)) { + const solBalance = await connection.getBalance(wallet.publicKey); + const buffer = MIN_SOL_FOR_GAS * 10 ** 9; + balanceY = new BN(Math.max(0, solBalance - buffer)); + // Only log if not already logged (in case both are SOL, though unlikely in a pair) + if (!tokenXMint.equals(SOL_MINT)) { + logger.info(`Wallet Balance (Native SOL): ${(solBalance / 10 ** 9).toFixed(4)} SOL (${solBalance} lamports). Available for deposit: ${(balanceY.toNumber() / 10 ** 9).toFixed(4)} SOL`); + + if (solBalance < 0.2 * 10 ** 9) { + logger.warn("CRITICAL: Wallet SOL balance is below 0.2 SOL. Transactions may fail soon due to rent!"); + } + } + } else { + try { + const tokenYATA = await getAssociatedTokenAddress(tokenYMint, wallet.publicKey); + const accountY = await getAccount(connection, tokenYATA); + const rawAmount = new BN(accountY.amount.toString()); + const decimals = (this.dlmmPool.tokenY.mint as any).decimals || 0; + const dust = new BN(0.0001 * 10 ** decimals); + balanceY = rawAmount.gt(dust) ? rawAmount.sub(dust) : new BN(0); + logger.info(`Wallet Balance (${tokenYLabel}): ${(balanceY.toNumber() / 10 ** decimals).toFixed(4)} (Total: ${rawAmount.toString()} lamports)`); + } catch { + logger.debug(`Token Y ATA not found: ${tokenYMint.toBase58()}`); + } + } + + return { balanceX, balanceY }; + } + + async claimFees() { + if (!this.dlmmPool) throw new Error("Pool not initialized"); + const positions = await this.getPositions(); + + for (const position of positions) { + logger.info( + `Claiming fees from position: ${position.publicKey.toBase58()}` + ); + const transactions = await this.dlmmPool.claimAllRewardsByPosition({ + owner: wallet.publicKey, + position, + }); + for (const tx of transactions) { + if (DRY_RUN) { + logger.info("[DRY RUN] Fee claim transaction part skipped."); + continue; + } + const txHash = await this.sendTransactionWithRetry(tx); + logger.info(`Fees claimed part: ${txHash}`); + } + } + } + + /** + * Returns the current price of TokenX in terms of TokenY. + * E.g., if X is SOL and Y is USDC, returns USDC price of 1 SOL. + */ + async getTokenPrice(): Promise { + if (!this.dlmmPool) throw new Error("Pool not initialized"); + const activeBin = await this.dlmmPool.getActiveBin(); + return parseFloat(activeBin.price); + } +} diff --git a/src/swap.ts b/src/swap.ts new file mode 100644 index 0000000..403541e --- /dev/null +++ b/src/swap.ts @@ -0,0 +1,53 @@ +import { createJupiterApiClient } from "@jup-ag/api"; +import { wallet, connection } from "./utils/config"; +import { VersionedTransaction } from "@solana/web3.js"; +import logger from "./utils/logger"; + +const jupiterQuoteApi = createJupiterApiClient(); + +export async function getSwapQuote( + inputMint: string, + outputMint: string, + amount: number, + slippageBps = 50 +) { + const quote = await jupiterQuoteApi.quoteGet({ + inputMint, + outputMint, + amount, + slippageBps, + }); + return quote; +} + +export async function executeSwap(quoteResponse: any): Promise { + const { swapTransaction } = await jupiterQuoteApi.swapPost({ + swapRequest: { + quoteResponse, + userPublicKey: wallet.publicKey.toBase58(), + wrapAndUnwrapSol: true, + }, + }); + + const swapTransactionBuf = Buffer.from(swapTransaction, "base64"); + const transaction = VersionedTransaction.deserialize(swapTransactionBuf); + transaction.sign([wallet]); + + const txid = await connection.sendTransaction(transaction, { + skipPreflight: true, + maxRetries: 2, + }); + + logger.info(`Swap executed: https://solscan.io/tx/${txid}`); + + logger.info("Waiting for swap confirmation..."); + const latestBlockhash = await connection.getLatestBlockhash(); + await connection.confirmTransaction({ + signature: txid, + blockhash: latestBlockhash.blockhash, + lastValidBlockHeight: latestBlockhash.lastValidBlockHeight + }); + logger.info("Swap confirmed."); + + return txid; +} diff --git a/src/utils/config.ts b/src/utils/config.ts new file mode 100644 index 0000000..38742f4 --- /dev/null +++ b/src/utils/config.ts @@ -0,0 +1,43 @@ +import dotenv from "dotenv"; +import { Connection, Keypair, PublicKey } from "@solana/web3.js"; +import bs58 from "bs58"; + +dotenv.config(); + +export const RPC_URL = + process.env.RPC_URL || "https://api.mainnet-beta.solana.com"; +export const PRIVATE_KEY = process.env.PRIVATE_KEY || ""; +export const PAIR_ADDRESS = process.env.PAIR_ADDRESS || ""; +export const REBALANCE_THRESHOLD_PERCENT = parseFloat( + process.env.REBALANCE_THRESHOLD_PERCENT || "0.15" +); +export const COMPOUND_THRESHOLD_USD = parseFloat( + process.env.COMPOUND_THRESHOLD_USD || "1.0" +); +export const MIN_SOL_FOR_GAS = 0.1; // Reserved for gas and rent +export const TARGET_RATIO = parseFloat(process.env.TARGET_RATIO || "0.5"); +export const CHECK_INTERVAL_CRON = ( + process.env.CHECK_INTERVAL_CRON || "*/5 * * * *" +).replace(/^["']|["']$/g, "").trim(); +export const COMPOUND_INTERVAL_CRON = ( + process.env.COMPOUND_INTERVAL_CRON || "0 0 * * *" +).replace(/^["']|["']$/g, "").trim(); +export const DRY_RUN = process.env.DRY_RUN === "true"; +export const SLIPPAGE_BPS = parseInt(process.env.SLIPPAGE_BPS || "100"); // 1% default, but user can change +export const MAX_RETRIES = parseInt(process.env.MAX_RETRIES || "3"); + +// Fallback USD estimates for value calculation (JLP: $3, SOL: $100) +export const JLP_USD_ESTIMATE = 3.0; +export const SOL_USD_ESTIMATE = 100.0; + +if (!PRIVATE_KEY) { + throw new Error("PRIVATE_KEY is not defined in .env"); +} + +if (!PAIR_ADDRESS) { + throw new Error("PAIR_ADDRESS is not defined in .env"); +} + +export const wallet = Keypair.fromSecretKey(bs58.decode(PRIVATE_KEY)); +export const connection = new Connection(RPC_URL, "confirmed"); +export const poolAddress = new PublicKey(PAIR_ADDRESS); diff --git a/src/utils/logger.ts b/src/utils/logger.ts new file mode 100644 index 0000000..5d62f76 --- /dev/null +++ b/src/utils/logger.ts @@ -0,0 +1,15 @@ +import pino from "pino"; + +const logger = pino({ + level: process.env.LOG_LEVEL || "info", + transport: { + target: "pino-pretty", + options: { + colorize: true, + translateTime: "HH:MM:ss Z", + ignore: "pid,hostname", + }, + }, +}); + +export default logger; diff --git a/src/withdraw.ts b/src/withdraw.ts new file mode 100644 index 0000000..a7dfda9 --- /dev/null +++ b/src/withdraw.ts @@ -0,0 +1,24 @@ +import { MeteoraWrapper } from "./meteora"; +import logger from "./utils/logger"; + +async function withdraw() { + logger.info("Starting emergency withdrawal..."); + const meteora = new MeteoraWrapper(); + + try { + await meteora.init(); + + logger.info("Withdrawing all liquidity positions..."); + await meteora.withdrawAll(); + + logger.info("Claiming all fees..."); + await meteora.claimFees(); + + logger.info("Emergency withdrawal completed successfully."); + } catch (error: any) { + logger.error(`Emergency withdrawal failed: ${error.message}`); + process.exit(1); + } +} + +withdraw(); diff --git a/tests/integration/meteora_mock.test.ts b/tests/integration/meteora_mock.test.ts new file mode 100644 index 0000000..ff9e365 --- /dev/null +++ b/tests/integration/meteora_mock.test.ts @@ -0,0 +1,25 @@ +import { Connection, PublicKey } from "@solana/web3.js"; +import DLMM from "@meteora-ag/dlmm"; + +// Mocking the whole DLMM module +jest.mock("@meteora-ag/dlmm"); + +describe("Meteora SDK Mock Test", () => { + it("should mock DLMM.create", async () => { + const mockPool = { + getActiveBin: jest.fn().mockResolvedValue({ binId: 100, price: "1.23" }), + }; + (DLMM.create as jest.Mock).mockResolvedValue(mockPool); + + const connection = new Connection("https://api.mainnet-beta.solana.com"); + const poolAddress = new PublicKey( + "LbVRzDTvBDEcrthxfZ4RL6yiq3uZw8bS6MwtdY6UhFQ" + ); + + const pool = await DLMM.create(connection, poolAddress); + const activeBin = await pool.getActiveBin(); + + expect(activeBin.binId).toBe(100); + expect(DLMM.create).toHaveBeenCalledWith(connection, poolAddress); + }); +}); diff --git a/tests/unit/bot.test.ts b/tests/unit/bot.test.ts new file mode 100644 index 0000000..2851f02 --- /dev/null +++ b/tests/unit/bot.test.ts @@ -0,0 +1,81 @@ +import { DLMMBot } from "../../src/bot"; +import { MeteoraWrapper } from "../../src/meteora"; +import logger from "../../src/utils/logger"; +import { BN } from "@coral-xyz/anchor"; + +jest.mock("../../src/utils/config", () => ({ + connection: { getActiveBin: jest.fn() }, + wallet: { publicKey: { toBase58: () => "wallet1" } }, + REBALANCE_THRESHOLD_PERCENT: 0.15, + poolAddress: { toBase58: () => "pool1" }, + DRY_RUN: false, + SLIPPAGE_BPS: 100, + MAX_RETRIES: 3, + JLP_USD_ESTIMATE: 3.0, + SOL_USD_ESTIMATE: 100.0, + COMPOUND_THRESHOLD_USD: 1.0, +})); +jest.mock("../../src/utils/logger", () => ({ + info: jest.fn(), + error: jest.fn(), + debug: jest.fn(), + warn: jest.fn(), +})); +jest.mock("../../src/meteora"); + +describe("DLMMBot Rebalance Logic", () => { + let bot: DLMMBot; + let mockMeteora: jest.Mocked; + + beforeEach(() => { + jest.clearAllMocks(); + bot = new DLMMBot(); + mockMeteora = (bot as any).meteora; + mockMeteora.getBalances.mockResolvedValue({ balanceX: new BN(0), balanceY: new BN(0) }); + mockMeteora.getTokenPrice.mockResolvedValue(1.0); + mockMeteora.dlmmPool = { + tokenX: { mint: { decimals: 9, address: { toBase58: () => "So11111111111111111111111111111111111111112" } } }, + tokenY: { mint: { decimals: 6, address: { toBase58: () => "JLP" } } } + } as any; + }); + + it("should not rebalance if within range", async () => { + mockMeteora.getActiveBin.mockResolvedValue({ binId: 100 } as any); + mockMeteora.getPositions.mockResolvedValue([ + { + publicKey: { toBase58: () => "pos1" }, + positionData: { lowerBinId: 90, upperBinId: 110 }, + }, + ] as any); + + await bot.rebalance(); + + expect(logger.info).toHaveBeenCalledWith( + expect.stringContaining("Portfolio healthy") + ); + expect(mockMeteora.withdrawAll).not.toHaveBeenCalled(); + }); + + it("should trigger rebalance if out of range", async () => { + mockMeteora.getActiveBin.mockResolvedValue({ binId: 120 } as any); + mockMeteora.getPositions.mockResolvedValue([ + { + publicKey: { toBase58: () => "pos1" }, + positionData: { lowerBinId: 90, upperBinId: 110 }, + }, + ] as any); + mockMeteora.getBalances.mockResolvedValue({ balanceX: new BN(100), balanceY: new BN(100) }); + mockMeteora.getTokenPrice.mockResolvedValue(1.0); + // dlmmPool already mocked in beforeEach + + await bot.rebalance(); + + expect(mockMeteora.withdrawAll).toHaveBeenCalled(); + expect(mockMeteora.getBalances).toHaveBeenCalled(); + expect(mockMeteora.deposit).toHaveBeenCalledWith( + new BN(100), + new BN(100), + 120 + ); + }); +}); diff --git a/tests/unit/meteora.test.ts b/tests/unit/meteora.test.ts new file mode 100644 index 0000000..a4edf4c --- /dev/null +++ b/tests/unit/meteora.test.ts @@ -0,0 +1,132 @@ +import { PublicKey } from "@solana/web3.js"; +import { BN } from "@coral-xyz/anchor"; + +// Objects prefixed with 'mock' are hoisted and allowed in jest.mock factory +const mockInternalConfig = { + connection: {}, + wallet: { publicKey: new PublicKey("LbVRzDTvBDEcrthxfZ4RL6yiq3uZw8bS6MwtdY6UhFQ") }, + poolAddress: new PublicKey("LbVRzDTvBDEcrthxfZ4RL6yiq3uZw8bS6MwtdY6UhFQ"), + DRY_RUN: false, + SLIPPAGE_BPS: 100, + MAX_RETRIES: 3, + MIN_SOL_FOR_GAS: 0.1, +}; + +jest.mock("../../src/utils/config", () => mockInternalConfig); + +jest.mock("@meteora-ag/dlmm"); +jest.mock("@solana/web3.js", () => ({ + ...jest.requireActual("@solana/web3.js"), + sendAndConfirmTransaction: jest.fn(), +})); +jest.mock("../../src/utils/logger", () => ({ + info: jest.fn(), + error: jest.fn(), + debug: jest.fn(), + warn: jest.fn(), +})); + +import { MeteoraWrapper } from "../../src/meteora"; +import DLMM from "@meteora-ag/dlmm"; +import { sendAndConfirmTransaction } from "@solana/web3.js"; +import logger from "../../src/utils/logger"; + +describe("MeteoraWrapper", () => { + let wrapper: MeteoraWrapper; + let mockDlmm: any; + + beforeEach(async () => { + jest.clearAllMocks(); + wrapper = new MeteoraWrapper(); + mockDlmm = { + getActiveBin: jest.fn(), + getPositionsByUserAndLbPair: jest.fn(), + removeLiquidity: jest.fn(), + initializePositionAndAddLiquidityByStrategy: jest.fn(), + claimAllRewardsByPosition: jest.fn(), + tokenX: { mint: { address: new PublicKey("LbVRzDTvBDEcrthxfZ4RL6yiq3uZw8bS6MwtdY6UhFQ") } }, + tokenY: { mint: { address: new PublicKey("LbVRzDTvBDEcrthxfZ4RL6yiq3uZw8bS6MwtdY6UhFQ") } }, + }; + (DLMM.create as jest.Mock).mockResolvedValue(mockDlmm); + await wrapper.init(); + }); + + it("should get active bin", async () => { + mockDlmm.getActiveBin.mockResolvedValue({ binId: 100 }); + const bin = await wrapper.getActiveBin(); + expect(bin.binId).toBe(100); + }); + + it("should withdraw all liquidity from positions", async () => { + const mockPosition = { + publicKey: new PublicKey("LbVRzDTvBDEcrthxfZ4RL6yiq3uZw8bS6MwtdY6UhFQ"), + positionData: { lowerBinId: 90, upperBinId: 110 }, + }; + mockDlmm.getPositionsByUserAndLbPair.mockResolvedValue({ + userPositions: [mockPosition], + }); + mockDlmm.removeLiquidity.mockResolvedValue([{}]); + (sendAndConfirmTransaction as jest.Mock).mockResolvedValue("txHash"); + + await wrapper.withdrawAll(); + + expect(mockDlmm.removeLiquidity).toHaveBeenCalled(); + expect(sendAndConfirmTransaction).toHaveBeenCalled(); + }); + + it("should deposit liquidity", async () => { + mockDlmm.initializePositionAndAddLiquidityByStrategy.mockResolvedValue({}); + (sendAndConfirmTransaction as jest.Mock).mockResolvedValue("txHash"); + + await wrapper.deposit( + new BN(100), + new BN(100), + 100 + ); + + expect( + mockDlmm.initializePositionAndAddLiquidityByStrategy + ).toHaveBeenCalled(); + expect(sendAndConfirmTransaction).toHaveBeenCalled(); + }); + + it("should skip transactions in DRY_RUN mode", async () => { + mockInternalConfig.DRY_RUN = true; + + mockDlmm.initializePositionAndAddLiquidityByStrategy.mockResolvedValue({}); + + await wrapper.deposit( + new BN(100), + new BN(100), + 100 + ); + + expect(sendAndConfirmTransaction).not.toHaveBeenCalled(); + expect(logger.info).toHaveBeenCalledWith( + expect.stringContaining("[DRY RUN]") + ); + + mockInternalConfig.DRY_RUN = false; // Reset + }); + + it("should get token balances", async () => { + mockDlmm.tokenX = { mint: { address: new PublicKey("LbVRzDTvBDEcrthxfZ4RL6yiq3uZw8bS6MwtdY6UhFQ") } }; + mockDlmm.tokenY = { mint: { address: new PublicKey("LbVRzDTvBDEcrthxfZ4RL6yiq3uZw8bS6MwtdY6UhFQ") } }; + + const balances = await wrapper.getBalances(); + expect(balances).toBeDefined(); + }); + + it("should log deposit details", async () => { + mockDlmm.initializePositionAndAddLiquidityByStrategy.mockResolvedValue({}); + mockDlmm.tokenX = { mint: { address: new PublicKey("LbVRzDTvBDEcrthxfZ4RL6yiq3uZw8bS6MwtdY6UhFQ") } }; + mockDlmm.tokenY = { mint: { address: new PublicKey("LbVRzDTvBDEcrthxfZ4RL6yiq3uZw8bS6MwtdY6UhFQ") } }; + (sendAndConfirmTransaction as jest.Mock).mockResolvedValue("txHash"); + + await wrapper.deposit(new BN(100), new BN(100), 100); + + expect(logger.info).toHaveBeenCalledWith( + expect.stringContaining("Depositing liquidity") + ); + }); +}); diff --git a/tests/unit/sanity.test.ts b/tests/unit/sanity.test.ts new file mode 100644 index 0000000..697ab79 --- /dev/null +++ b/tests/unit/sanity.test.ts @@ -0,0 +1,13 @@ +import { BN } from "@coral-xyz/anchor"; + +describe("Basic Setup Test", () => { + it("should handle BN correctly", () => { + const amount = new BN(100); + expect(amount.toString()).toBe("100"); + }); + + it("should be able to import from src (sanity check)", () => { + // We'll add more complex tests once we mock external dependencies + expect(true).toBe(true); + }); +}); diff --git a/tsconfig.json b/tsconfig.json new file mode 100644 index 0000000..92159c2 --- /dev/null +++ b/tsconfig.json @@ -0,0 +1,17 @@ +{ + "compilerOptions": { + "target": "ESNext", + "module": "CommonJS", + "lib": ["ESNext"], + "strict": true, + "esModuleInterop": true, + "skipLibCheck": true, + "forceConsistentCasingInFileNames": true, + "outDir": "./dist", + "rootDir": "./src", + "moduleResolution": "node", + "resolveJsonModule": true + }, + "include": ["src/**/*"], + "exclude": ["node_modules"] +}