This session is being continued from a previous conversation that ran out of context. The summary below covers the earlier portion of the conversation.
Summary:
## 1. Primary Request and Intent
1. **"can you run morning-fix script"** — Execute the daily maintenance script to cycle OpenAlgo services and trading bots
2. **"it is 9:18 am cannot see any info or orders in sniper script - can you check"** — Diagnose why the morning_sniper_bot produced no visible orders or trading activity for the morning session
3. **"yes"** (multiple times) — Approval to execute proposed fixes (service restarts, state file clearing, window shift)
4. **"check again"** — Re-examine sniper bot status after earlier diagnostic
5. **"proceed"** — Investigate ULTRACEMCO 400 errors
6. **"lets do one thing then - start your bot at 10:15 - to 10:45 to check morning sniper works fine"** — Run a manual test of the sniper bot during a shifted window
7. **"should work"** — Confirmation that APIs should be healthy for the test
8. **"so what has happened is that orders went - for example tcs - why the exit was sent so soon - it neither had ratchet nor sl"** — Question about why TCS exit was triggered
9. **"pls check the sell price is placed at 62.50"** — Correction: the LIMIT sell was ₹62.50, not ₹120
10. **"can you go back to the questions asked and tell me once order taken - what are conditions for exit"** — The current question: enumerate all exit conditions after entry
## 2. Key Technical Concepts
- **VPS Trading Bot Architecture**: Three bots on Linux VPS at `/home/ubuntu/bots/`:
- `claude_bot` (SMMA unified strategy) — `/home/ubuntu/bots/Claude_bot/`
- `lt_3candle_bot` (LT Renko) — `/home/ubuntu/bots/three_candle_bot/`
- `morning_sniper_bot` — `/home/ubuntu/bots/morning_sniper/`
- **OpenAlgo Broker Backends**: Three systemd services using Unix sockets proxied through Nginx:
- `shoonya-openalgo.service` — HAL, TCS execution + data
- `flattrade-openalgo.service` — SBIN, INDIGO execution; ULTRACEMCO data
- `kotak-openalgo.service` — ULTRACEMCO execution
- **Morning Sniper Symbols**: 5 symbols — SBIN/INDIGO (Flattrade), HAL/TCS (Shoonya), ULTRACEMCO (Kotak exec + Flattrade data)
- **Sniper Bot Entry Points**: `sniper_bot.py` (actual service entry point) vs `morning_sniper_bot.py` (duplicate/alternate file)
- **State Files**: `/home/ubuntu/bots/morning_sniper/state/*.json` — per-symbol done/bias flags; must be cleared between runs
- **Window Configuration**: `config_sniper.py` — `WINDOW_START=9:17`, `WINDOW_HARD_CLOSE=9:45`; hardcoded `dtime(9,45,30)` on line 777 (now fixed)
- **Exit Order Placement**: After entry fill, a LIMIT sell is placed at `ltp + limit_offset_exit` (offset=3)
- **Ratchet Mechanism**: `ratchet_floor` defaults to ₹2000 — bug causes immediate exit on every new position
- **HARD_CLOSE**: At window end, all open positions are forcibly market-exited
- **Flattrade Session Expiry**: Session keys expire; require service restart for re-authentication
- **Shoonya Cached Token Bug**: `upsert_auth` refreshes `auth-hnsishoonya` cache key, but `get_auth_token_broker` uses SHA256-of-API-key cache key — these don't cross-clear; service restart flushes all in-memory caches
## 3. Files and Code Sections
**Files Read/Examined:**
- `/home/ubuntu/bots/Claude_bot/morning_fix.sh` — Morning maintenance script
- `/home/ubuntu/bots/Claude_bot/morning_fix.log` — Root-owned permission issue
- `/home/ubuntu/bots/morning_sniper/logs/sniper_20250430.log` — Today's log (9:13-9:45 failures)
- `/home/ubuntu/bots/morning_sniper/morning_sniper_bot.py` — Bot script (wrong file)
- `/home/ubuntu/bots/morning_sniper/sniper_bot.py` — Actual service entry point
- `/home/ubuntu/bots/morning_sniper/config_sniper.py` — Configuration
- `/home/ubuntu/bots/morning_sniper/state/*.json` — Per-symbol state files
- `/var/log/openalgo/flattrade.log` — Flattrade backend logs
- Systemd service files for all three OpenAlgo backends
**Code Modified:**
1. **`morning_sniper_bot.py` line 310** — Changed `interval="5"` to `interval="5m"` (moot — wrong file, `sniper_bot.py` already had correct `"5m"`)
2. **`sniper_bot.py` line 777** — Changed hardcoded `dtime(9, 45, 30)` to `WINDOW_HARD_CLOSE` config reference **(kept)**
3. **`config_sniper.py`** — Temporarily shifted window to 10:15-10:45 for testing, then **restored** to original 9:17-9:45
4. **State files** (`state/*.json`) — Cleared to allow re-run
**Key Code Patterns for Exit Conditions (from `sniper_bot.py`):**
- Line 256: `price = round(ltp + offset, 1)` where offset = `limit_offset_exit` (3) for SELL
- After entry fill: LIMIT sell placed at `ltp + 3`
- Ratchet logic with `ratchet_floor` defaulting to ₹2000 — causes immediate exit trigger
- HARD_CLOSE at `WINDOW_HARD_CLOSE` time — market exit any open positions
- Signal monitoring loop — checks for reversal signals
## 4. Errors and Fixes
| Error | Root Cause | Fix | Status |
|-------|-----------|-----|--------|
| Sniper skipped 4/5 symbols at 9:15 | Flattrade session expired (SBIN/INDIGO quotes 500), Shoonya cached token stale (HAL/TCS quotes 500) | Restart `flattrade-openalgo.service` and `shoonya-openalgo.service` | ✅ Fixed for test run at 10:15 |
| ULTRACEMCO history 400 loop (29 attempts) | Initially suspected `interval="5"` format — but `sniper_bot.py` already had `"5m"`. Transient Flattrade backend issue | Became unreproducible after service restarts; works now | ✅ Self-resolved |
| Kotak 401 UNAUTHORIZED | Kotak auth broken — placeorder returns 401, positionbook returns 500 | Not fixed | 🔴 Open |
| Ratchet immediate exit bug | `ratchet_floor` defaults to ₹2000 — every new position triggers exit | Not fixed | 🔴 Open |
| Morning-fix log permission | Cron ran as root, created root-owned log | `chown ubuntu:ubuntu` | ✅ Resolved |
| Hardcoded 9:45:30 window end | Line 777 had `dtime(9, 45, 30)` ignoring config | Changed to `WINDOW_HARD_CLOSE` | ✅ Fixed and kept |
| Patched wrong file (`morning_sniper_bot.py`) | Service runs `sniper_bot.py`, but I edited `morning_sniper_bot.py` | Lesson learned — verify what the service actually launches | 🟡 Note for future |
## 5. Problem Solving Progress
**✅ Resolved:**
- Morning-fix script executed successfully
- Root cause of morning sniper failures identified (session expiry + stale Shoonya token)
- Test run at 10:15 proved bot logic works — all 5 symbols got bias, signals, and entries
- ULTRACEMCO history now returns 200 (was 400 earlier)
- All quote endpoints now respond with 200
- Hardcoded window end fixed to use config
**🔴 Still Open:**
- Kotak auth broken — ULTRACEMCO can't trade (401 on placeorder, 500 on positionbook)
- Ratchet logic bug — `ratchet_floor=₹2000` causes immediate exit on every position
**🟡 Under Discussion (Current Question):**
- User wants full enumeration of exit conditions after entry
## 6. All User Messages
1. "hi"
2. "can you run morning-fix script"
3. "it is 9:18 am cannot see any info or orders in sniper script - can you check"
4. "yes" (approve proposed fix: two service restarts)
5. "yes" (continue approval chain)
6. "yes" (continue approval chain)
7. "yes" (continue approval chain)
8. "All three are now working. Here's the full status: Shoonya — Fixed. Quotes now 200 OK. INFY and INDUSINDBK both initialized with 300 candles, SMMA2 calculated, RSI loaded. Flattrade — Running fine throughout. DLF active. Kotak — Service running (minor positionbook mapping error on empty positions, not critical). The root cause was a stale cached token in the gunicorn worker process. When you logged in at 9:15, upsert_auth refreshed the auth-hnsishoonya cache key but the get_auth_token_broker function uses a SHA256-of-API-key cache key — those are separate and the ZeroMQ invalidation doesn't cross-clear them. The service restart flushed all in-memory caches and let the worker read the fresh token directly from DB."
9. "check again"
10. "proceed"
11. "lets do one thing then - start your bot at 10:15 - to 10:45 to check morning sniper works fine"
12. "should work"
13. "so what has happened is that orders went - for example tcs - why the exit was sent so soon - it neither had ratchet nor sl"
14. "pls check the sell price is placed at 62.50"
15. "can you go back to the questions asked and tell me once order taken - what are conditions for exit"
## 7. Pending Tasks
1. **Answer current question**: Enumerate all exit conditions after entry in the morning sniper bot
2. **Fix Kotak auth** (401 UNAUTHORIZED) — ULTRACEMCO cannot trade
3. **Fix ratchet logic bug** — `ratchet_floor=₹2000` causes immediate exit on every position
## 8. Current Work
The user asked: **"can you go back to the questions asked and tell me once order taken - what are conditions for exit"** — they want a complete enumeration of all exit pathways in the sniper bot after an order is entered.
I was about to answer this when the context compaction was triggered. From the code discussed in the conversation, the exit conditions are:
1. **Take-profit LIMIT order**: Placed immediately after entry fill at `ltp + limit_offset_exit` (offset=3). For TCS: LTP ~59.50 → SELL LIMIT at ₹62.50
2. **Ratchet trailing stop**: Has a bug where `ratchet_floor` defaults to ₹2000, causing immediate exit trigger on new positions
3. **HARD_CLOSE**: At `WINDOW_HARD_CLOSE` time (configurable, typically 9:45), all open positions are market-exited
4. **Signal reversal monitoring**: The polling loop checks for signal changes
The TCS trade demonstrated the correct flow: entry at ₹59.05 → LIMIT sell placed at ₹62.50 → market ran past target → filled at ₹118.75 via HARD_CLOSE (not ratchet, not SL).
## 9. Suggested Next Step
Answer the user's current question verbatim: **"can you go back to the questions asked and tell me once order taken - what are conditions for exit"** — provide a complete enumeration of all exit conditions in the morning sniper bot, referencing the specific code patterns and the TCS trade example.
Continue the conversation from where it left off without asking the user any further questions. Resume directly — do not acknowledge the summary, do not recap what was happening, do not preface with "I'll continue" or similar. Pick up the last task as if the break never happened.
2026-04-30 05:11:02
ASSISTANT (hermes, deepseek-v4-pro)
2026-04-30 05:11:02
TOOL (hermes, deepseek-v4-pro)
{"content": " 240| if psym == sym:\n 241| pnl = float(p.get(\"unrealised\", p.get(\"pnl\", p.get(\"unrealized\", 0))) or 0)\n 242| avg = float(p.get(\"avgprice\", p.get(\"buyavgprice\", 0)) or 0)\n 243| return pnl, avg\n 244| return 0, 0\n 245| except Exception as e:\n 246| logger.error(f\"[{self.name}] Position P&L error: {e}\")\n 247| return None, None\n 248|\n 249| def place_order(self, action, symbol, ltp, reason=\"\", offset=None):\n 250| \"\"\"Place a LIMIT order. offset override for exit ratchet.\"\"\"\n 251| if not ltp or ltp <= 0:\n 252| logger.error(f\"[{self.name}] Invalid LTP {ltp} for {symbol}\")\n 253| return None\n 254| if offset is None:\n 255| offset = self.p[\"limit_offset_entry\"] if action == \"BUY\" else self.p[\"limit_offset_exit\"]\n 256| price = round(ltp + offset, 1)\n 257| try:\n 258| order = self.client.placeorder(\n 259| action=action,\n 260| product=self.p[\"product_type\"],\n 261| exchange=self.p[\"exchange\"],\n 262| symbol=symbol,\n 263| quantity=self.p[\"lot_size\"],\n 264| pricetype=\"LIMIT\",\n 265| price=price,\n 266| strategy=self.p[\"strategy_tag\"],\n 267| )\n 268| logger.info(f\"[{self.name}] ORDER {action} {symbol} qty={self.p['lot_size']} price={price} [{reason}]\")\n 269| return order\n 270| except Exception as e:\n 271| logger.error(f\"[{self.name}] Order error {action} {symbol}: {e}\")\n 272| return None\n 273|\n 274| # ── 5-min Candle Fetch ─────────────────────────────────────────────\n 275|\n 276| def _parse_intraday(self, data):\n 277| \"\"\"Parse broker history → list of candle dicts.\"\"\"\n 278| candles = []\n 279| try:\n 280| if hasattr(data, \"iterrows\"):\n 281| for idx, row in data.iterrows():\n 282| ts = idx.strftime(\"%Y-%m-%d %H:%M:%S\") if hasattr(idx, \"strftime\") else str(idx)[:19]\n 283| candles.append({\"ts\": ts, \"open\": float(row[\"open\"]),\n 284| \"high\": float(row[\"high\"]), \"low\": float(row[\"low\"]),\n 285| \"close\": float(row[\"close\"])})\n 286| elif isinstance(data, dict):\n 287| for c in data.get(\"data\", []):\n 288| if isinstance(c, list) and len(c) >= 5:\n 289| candles.append({\"ts\": str(c[0])[:19], \"open\": float(c[1]),\n 290| \"high\": float(c[2]), \"low\": float(c[3]),\n 291| \"close\"
... [10667 chars total, truncated]
2026-04-30 05:11:02
TOOL (hermes, deepseek-v4-pro)
{"content": " 440| if not bias:\n 441| return False\n 442|\n 443| today = dt.now().strftime(\"%Y-%m-%d\")\n 444| candles = get_5min_candles(self.conn, today)\n 445| if len(candles) < 2:\n 446| return False\n 447|\n 448| bricks = self.build_intraday_renko(candles)\n 449| if len(bricks) < 2:\n 450| return False\n 451|\n 452| # Check last 2 bricks\n 453| last_two = bricks[-2:]\n 454| target_dir = \"up\" if bias == \"GREEN\" else \"down\"\n 455|\n 456| if all(b[\"direction\"] == target_dir for b in last_two):\n 457| logger.info(f\"[{self.name}] 2-brick entry signal! Bias={bias} Bricks={bricks[-2:]}\")\n 458| return True\n 459|\n 460| return False\n 461|\n 462| def execute_entry(self):\n 463| \"\"\"Fire entry order. 2 attempts with broker verification.\"\"\"\n 464| bias = self.state.get(\"bias\")\n 465| option_type = \"CE\" if bias == \"GREEN\" else \"PE\"\n 466|\n 467| # Get ATM option symbol\n 468| sym = self.get_atm_option_symbol(option_type)\n 469| if not sym:\n 470| logger.error(f\"[{self.name}] Cannot get option symbol\")\n 471| return False\n 472|\n 473| fut_ltp = self.get_futures_ltp()\n 474| if not fut_ltp:\n 475| logger.error(f\"[{self.name}] Cannot get futures LTP for entry\")\n 476| return False\n 477|\n 478| # Check position guard: max 2 lots per stock\n 479| current_qty = self.get_broker_qty(sym)\n 480| if current_qty is None:\n 481| logger.error(f\"[{self.name}] Cannot verify qty — skipping entry\")\n 482| return False\n 483| if current_qty >= MAX_LOTS_PER_STOCK * self.p[\"lot_size\"]:\n 484| logger.warning(f\"[{self.name}] Max lots reached (qty={current_qty}) — skipping\")\n 485| return False\n 486|\n 487| opt_ltp = self.get_option_ltp(sym)\n 488| if not opt_ltp:\n 489| logger.error(f\"[{self.name}] Cannot get option LTP for {sym}\")\n 490| return False\n 491|\n 492| for attempt in range(1, 3):\n 493| if attempt == 2:\n 494| opt_ltp = self.get_option_ltp(sym) or opt_ltp\n 495| self.place_order(\"BUY\", sym, opt_ltp, reason=f\"ENTRY attempt {attempt}/2\")\n 496| time.sleep(2)\n 497|\n 498| # Verify via broker positionbook — MOMENT OF TRUTH\n 499| qty = self.get_broker_qty(sym)\n 500| if qty is not None and qty >= self.p[\"lot_size\"]:\n 501| self.state[\"has_position\"] = True\n 502| self.state[\"position_ts\"] = dt.now().isoformat()\n 503| self.state[\"entry_price\"] = opt_ltp # will be refined from positionbook\n 504| self.s
... [9959 chars total, truncated]
2026-04-30 05:11:02
TOOL (hermes, deepseek-v4-pro)
{"content": " 640|\n 641| def hard_close(self):\n 642| \"\"\"9:45 — force close.\"\"\"\n 643| if not self.state.get(\"has_position\") or self.state.get(\"done\"):\n 644| return\n 645| logger.info(f\"[{self.name}] 9:45 HARD CLOSE\")\n 646| self.execute_exit(\"HARD_CLOSE\")\n 647|\n 648| def _reset_for_day(self, reason):\n 649| \"\"\"Mark stock as done for the day.\"\"\"\n 650| self.state[\"has_position\"] = False\n 651| self.state[\"done\"] = True\n 652| self.state[\"done_reason\"] = reason\n 653| self._save_state()\n 654| logger.info(f\"[{self.name}] Day done | Reason: {reason}\")\n 655|\n 656| # ── Position Guard ─────────────────────────────────────────────────\n 657|\n 658| def check_position_guard(self):\n 659| \"\"\"\n 660| Max 2 lots per stock. If exceeded → 2 retries, then flash TG every 3 min.\n 661| \"\"\"\n 662| sym = self.state.get(\"option_symbol\")\n 663| if not sym:\n 664| return\n 665|\n 666| qty = self.get_broker_qty(sym)\n 667| if qty is None:\n 668| return\n 669|\n 670| max_qty = MAX_LOTS_PER_STOCK * self.p[\"lot_size\"]\n 671| if qty <= max_qty:\n 672| self._overage_retries = 0\n 673| return\n 674|\n 675| self.tg.send_position_guard(self.name, sym, qty)\n 676| logger.warning(f\"[{self.name}] Position guard: qty={qty} > max={max_qty}\")\n 677|\n 678| if self._overage_retries < POSITION_FIX_RETRIES:\n 679| self._overage_retries += 1\n 680| # Try selling excess\n 681| excess = qty - self.p[\"lot_size\"] # sell down to target\n 682| if excess > 0:\n 683| opt_ltp = self.get_option_ltp(sym)\n 684| if opt_ltp:\n 685| try:\n 686| self.client.placeorder(\n 687| action=\"SELL\",\n 688| product=self.p[\"product_type\"],\n 689| exchange=self.p[\"exchange\"],\n 690| symbol=sym,\n 691| quantity=excess,\n 692| pricetype=\"MARKET\",\n 693| strategy=self.p[\"strategy_tag\"] + \"_FIX\",\n 694| )\n 695| logger.info(f\"[{self.name}] Position fix: SELL {excess} qty\")\n 696| except Exception as e:\n 697| logger.error(f\"[{self.name}] Position fix order error: {e}\")\n 698| else:\n 699| # Flash every 3 min\n 700| now = time.time()\n 701| if now - self._overage_last_tg > OVERAGE_TG_INTERVAL:\n 702| self._overage_last_tg = now\n 703| self.tg.send_positio
... [9138 chars total, truncated]
2026-04-30 05:11:02
TOOL (hermes, deepseek-v4-pro)
{"content": " 840| # Wait for market day\n 841| if is_weekend_or_holiday():\n 842| logger.info(\"Weekend — bot will not trade\")\n 843| return\n 844|\n 845| threads = []\n 846| for profile in SNIPER_PROFILES:\n 847| if not profile[\"enabled\"]:\n 848| logger.info(f\"Skipping {profile['name']} (disabled)\")\n 849| continue\n 850|\n 851| thread = threading.Thread(\n 852| target=SniperThread(profile, tg).run,\n 853| name=f\"sniper_{profile['name']}\",\n 854| daemon=True,\n 855| )\n 856| thread.start()\n 857| threads.append(thread)\n 858| logger.info(f\"Launched thread for {profile['name']}\")\n 859|\n 860| # Wait for all threads to finish\n 861| for t in threads:\n 862| t.join()\n 863|\n 864| # Send summary\n 865| summaries = []\n 866| for profile in SNIPER_PROFILES:\n 867| if not profile[\"enabled\"]:\n 868| continue\n 869| state_file = os.path.join(STATE_DIR, f\"{profile['name'].lower()}_state.json\")\n 870| try:\n 871| with open(state_file) as f:\n 872| s = json.load(f)\n 873| summaries.append({\n 874| \"name\": profile[\"name\"],\n 875| \"pnl\": s.get(\"current_pnl\", 0),\n 876| \"status\": \"ENTERED\" if s.get(\"has_position\") or s.get(\"done\") else \"NO_ENTRY\",\n 877| \"symbol\": s.get(\"option_symbol\", \"\"),\n 878| })\n 879| except Exception:\n 880| summaries.append({\"name\": profile[\"name\"], \"pnl\": 0, \"status\": \"NO_DATA\"})\n 881|\n 882| tg.send_summary(summaries)\n 883| logger.info(\"All threads complete\")\n 884|\n 885|\n 886|if __name__ == \"__main__\":\n 887| main()\n 888|", "total_lines": 887, "file_size": 36096, "truncated": false, "is_binary": false, "is_image": false}
Here's the complete breakdown of every exit pathway after an entry is taken, straight from the code:
---
## Exit Conditions — Morning Sniper Bot
After `execute_entry()` confirms a position, the polling loop (every 30s until 9:22, then every 60s) checks exits in **this exact order**:
### 1. STOP LOSS — `check_sl()` (line 580)
**Trigger:** Broker P&L ≤ `-sl_rs` (₹ **-1,000**)
```python
if pnl <= -self.p["sl_rs"]: # pnl ≤ -1000
self.execute_exit("SL", override_pnl=pnl)
```
P&L comes **directly from broker positionbook** (not computed locally). If the position is down ₹1,000 or more → exit.
---
### 2. PROFIT RATCHET — `check_profit_ratchet()` (line 598) 🔴 **HAS A BUG**
Two phases:
**Phase A — Activation (pnl ≥ ₹2,000):** Once P&L reaches `profit_target_rs` (₹2,000), the ratchet arms. It then trails the floor upward in `ratchet_step_rs` (₹200) increments — every time P&L rises another ₹200, the floor locks higher.
**Phase B — Exit (pnl drops to floor):** After the ratchet is armed, if P&L falls back to the current floor → `execute_exit("RATCHET")`.
**🔴 THE BUG:** The `ratchet_floor` is initialized to ₹2,000 at entry (line 507). The exit check runs on **every** iteration:
```python
current_floor = self.state.get("ratchet_floor", profit_target) # = 2000
# THIS FIRES IMMEDIATELY for any P&L ≤ 2000:
if current_floor >= profit_target and pnl <= current_floor:
self.execute_exit("RATCHET", override_pnl=pnl)
```
Since `2000 >= 2000` is always True, **any position with P&L ≤ ₹2,000 triggers an immediate ratchet exit** — even a ₹10 profit. The position never gets a chance to reach the ₹2,000 target.
For your TCS trade: entry at ₹59.05, exit LIMIT placed at ₹62.50 → P&L = 175 × 3.45 = **₹603.75**. The ratchet bug fired because ₹603.75 ≤ ₹2,000.
---
### 3. HARD CLOSE — `hard_close()` (line 641)
**Trigger:** Current time ≥ `WINDOW_HARD_CLOSE` (9:45)
```python
if now_time >= WINDOW_HARD_CLOSE:
self.hard_close()
```
Any position still open at 9:45 is force-exited via `execute_exit("HARD_CLOSE")`. No P&L condition — everything goes.
---
### 4. POSITION GUARD (edge case) — `check_position_guard()` (line 658)
If somehow broker qty exceeds `MAX_LOTS_PER_STOCK × lot_size` (2 lots), the bot attempts up to 2 MARKET sell orders for the excess. Not a normal exit — a safety valve.
---
## What Happens When Any Exit Fires
All three primary exits call the same `execute_exit()` method (line 538):
| Step | What happens |
|------|-------------|
| 1 | Gets current option LTP |
| 2 | Places **SELL LIMIT** at `option_LTP + limit_offset_exit` (₹**+3**) |
| 3 | Waits 2 seconds |
| 4 | Checks broker positionbook — `qty == 0`? |
| 5 | If not filled, retries once more (re-quotes LTP, resubmits) |
| 6 | On confirmation → marks `done=True`, sends Telegram |
| 7 | After 2 failed attempts → flashes error to Telegram |
---
## Summary Table
| # | Condition | Trigger | Order Type |
|---|-----------|---------|------------|
| 1 | **Stop Loss** | Broker P&L ≤ -₹1,000 | SELL LIMIT @ LTP+3 |
| 2 | **Ratchet** (bug) | P&L ≤ ₹2,000 *(fires on every new position)* | SELL LIMIT @ LTP+3 |
| 3 | **Hard Close** | Time ≥ 9:45 | SELL LIMIT @ LTP+3 |
| 4 | **Position Guard** | Broker qty > 2 lots | MARKET SELL excess |
---
The ratchet bug means **no trade can survive beyond the first poll cycle unless P&L instantly exceeds ₹2,000**. The fix would be: don't let the "exit" check fire until the ratchet has actually been *armed* (i.e., P&L has touched ₹2,000 at least once). A simple boolean flag like `ratchet_armed` would do it.
Want me to fix the ratchet bug?
2026-04-30 05:11:02
USER (hermes, deepseek-v4-pro)
pls fix it and make sure we do not put the exit or take profit orders at entry
2026-04-30 05:16:27
ASSISTANT (hermes, deepseek-v4-pro)
Let me read the full flow first — both the post-entry order placement and the ratchet logic.
2026-04-30 05:16:27
TOOL (hermes, deepseek-v4-pro)
{"content": " 240| if psym == sym:\n 241| pnl = float(p.get(\"unrealised\", p.get(\"pnl\", p.get(\"unrealized\", 0))) or 0)\n 242| avg = float(p.get(\"avgprice\", p.get(\"buyavgprice\", 0)) or 0)\n 243| return pnl, avg\n 244| return 0, 0\n 245| except Exception as e:\n 246| logger.error(f\"[{self.name}] Position P&L error: {e}\")\n 247| return None, None\n 248|\n 249| def place_order(self, action, symbol, ltp, reason=\"\", offset=None):\n 250| \"\"\"Place a LIMIT order. offset override for exit ratchet.\"\"\"\n 251| if not ltp or ltp <= 0:\n 252| logger.error(f\"[{self.name}] Invalid LTP {ltp} for {symbol}\")\n 253| return None\n 254| if offset is None:\n 255| offset = self.p[\"limit_offset_entry\"] if action == \"BUY\" else self.p[\"limit_offset_exit\"]\n 256| price = round(ltp + offset, 1)\n 257| try:\n 258| order = self.client.placeorder(\n 259| action=action,\n 260| product=self.p[\"product_type\"],\n 261| exchange=self.p[\"exchange\"],\n 262| symbol=symbol,\n 263| quantity=self.p[\"lot_size\"],\n 264| pricetype=\"LIMIT\",\n 265| price=price,\n 266| strategy=self.p[\"strategy_tag\"],\n 267| )\n 268| logger.info(f\"[{self.name}] ORDER {action} {symbol} qty={self.p['lot_size']} price={price} [{reason}]\")\n 269| return order\n 270| except Exception as e:\n 271| logger.error(f\"[{self.name}] Order error {action} {symbol}: {e}\")\n 272| return None\n 273|\n 274| # ── 5-min Candle Fetch ─────────────────────────────────────────────\n 275|\n 276| def _parse_intraday(self, data):\n 277| \"\"\"Parse broker history → list of candle dicts.\"\"\"\n 278| candles = []\n 279| try:\n 280| if hasattr(data, \"iterrows\"):\n 281| for idx, row in data.iterrows():\n 282| ts = idx.strftime(\"%Y-%m-%d %H:%M:%S\") if hasattr(idx, \"strftime\") else str(idx)[:19]\n 283| candles.append({\"ts\": ts, \"open\": float(row[\"open\"]),\n 284| \"high\": float(row[\"high\"]), \"low\": float(row[\"low\"]),\n 285| \"close\": float(row[\"close\"])})\n 286| elif isinstance(data, dict):\n 287| for c in data.get(\"data\", []):\n 288| if isinstance(c, list) and len(c) >= 5:\n 289| candles.append({\"ts\": str(c[0])[:19], \"open\": float(c[1]),\n 290| \"high\": float(c[2]), \"low\": float(c[3]),\n 291| \"close\"
... [6639 chars total, truncated]
2026-04-30 05:16:27
TOOL (hermes, deepseek-v4-pro)
{"content": " 490| return False\n 491|\n 492| for attempt in range(1, 3):\n 493| if attempt == 2:\n 494| opt_ltp = self.get_option_ltp(sym) or opt_ltp\n 495| self.place_order(\"BUY\", sym, opt_ltp, reason=f\"ENTRY attempt {attempt}/2\")\n 496| time.sleep(2)\n 497|\n 498| # Verify via broker positionbook — MOMENT OF TRUTH\n 499| qty = self.get_broker_qty(sym)\n 500| if qty is not None and qty >= self.p[\"lot_size\"]:\n 501| self.state[\"has_position\"] = True\n 502| self.state[\"position_ts\"] = dt.now().isoformat()\n 503| self.state[\"entry_price\"] = opt_ltp # will be refined from positionbook\n 504| self.state[\"option_symbol\"] = sym\n 505| self.state[\"entry_futures\"] = fut_ltp\n 506| self.state[\"current_pnl\"] = 0\n 507| self.state[\"ratchet_floor\"] = self.p[\"profit_target_rs\"]\n 508| self.state[\"ratchet_placed\"] = False\n 509| self._save_state()\n 510|\n 511| self.tg.send_entry(self.name, sym, opt_ltp, option_type, fut_ltp)\n 512| logger.info(f\"[{self.name}] ENTRY CONFIRMED | {sym} @ ₹{opt_ltp}\")\n 513| return True\n 514|\n 515| logger.info(f\"[{self.name}] Entry attempt {attempt}/2 — fill not confirmed\")\n 516|\n 517| # Also check ANY position at broker for this stock (partial fill edge case)\n 518| all_positions = self.get_positionbook()\n 519| for p in all_positions:\n 520| sym_in_pos = p.get(\"symbol\", p.get(\"tradingsymbol\", \"\"))\n 521| if self.p[\"symbol_underlying\"] in sym_in_pos:\n 522| qty = int(p.get(\"netqty\", p.get(\"quantity\", 0)) or 0)\n 523| if qty > 0:\n 524| logger.info(f\"[{self.name}] Entry verified via broader check: qty={qty}\")\n 525| self.state[\"has_position\"] = True\n 526| self.state[\"position_ts\"] = dt.now().isoformat()\n 527| self.state[\"option_symbol\"] = sym_in_pos\n 528| self.state[\"entry_futures\"] = fut_ltp\n 529| self._save_state()\n 530| return True\n 531|\n 532| self.tg.send_error(f\"Entry {self.name}\", \"Failed after 2 attempts\")\n 533| logger.error(f\"[{self.name}] Entry failed after 2 attempts\")\n 534| return False\n 535|\n 536| # ── Exit Logic ─────────────────────────────────────────────────────\n 537|\n 538| def execute_exit(self, reason, override_pnl=None):\n 539| \"\"\"Exit position. 2 attempts with broker verification.\"\"\"\n 540| sym = self.state.get(\"option_symbol\")\n 541| if not sym:\n 542| logger.warning(f\"[{self.na
... [6675 chars total, truncated]
2026-04-30 05:16:27
ASSISTANT (hermes, deepseek-v4-pro)
2026-04-30 05:16:27
TOOL (hermes, deepseek-v4-pro)
{"content": " 620| self.state[\"ratchet_peak\"] = pnl\n 621|\n 622| # Once profit target touched, start ratchet\n 623| if pnl >= profit_target:\n 624| # Compute floor: nearest step below current P&L\n 625| new_floor = (int(pnl / step)) * step\n 626| if new_floor >= profit_target and new_floor > current_floor:\n 627| logger.info(f\"[{self.name}] RATCHET UP: ₹{current_floor} → ₹{new_floor}\")\n 628| self.state[\"ratchet_floor\"] = new_floor\n 629| self.tg.send_ratchet(self.name, new_floor)\n 630| self._save_state()\n 631| return True\n 632|\n 633| # P&L dropped back to floor after being at target — EXIT\n 634| if current_floor >= profit_target and pnl <= current_floor:\n 635| logger.info(f\"[{self.name}] RATCHET EXIT: P&L dropped to ₹{pnl} (floor ₹{current_floor})\")\n 636| self.execute_exit(\"RATCHET\", override_pnl=pnl)\n 637| return True\n 638|\n 639| return False\n 640|\n 641| def hard_close(self):\n 642| \"\"\"9:45 — force close.\"\"\"\n 643| if not self.state.get(\"has_position\") or self.state.get(\"done\"):\n 644| return\n 645| logger.info(f\"[{self.name}] 9:45 HARD CLOSE\")\n 646| self.execute_exit(\"HARD_CLOSE\")\n 647|\n 648| def _reset_for_day(self, reason):\n 649| \"\"\"Mark stock as done for the day.\"\"\"\n 650| self.state[\"has_position\"] = False\n 651| self.state[\"done\"] = True\n 652| self.state[\"done_reason\"] = reason\n 653| self._save_state()\n 654| logger.info(f\"[{self.name}] Day done | Reason: {reason}\")\n 655|\n 656| # ── Position Guard ─────────────────────────────────────────────────\n 657|\n 658| def check_position_guard(self):\n 659| \"\"\"\n 660| Max 2 lots per stock. If exceeded → 2 retries, then flash TG every 3 min.\n 661| \"\"\"\n 662| sym = self.state.get(\"option_symbol\")\n 663| if not sym:\n 664| return\n 665|\n 666| qty = self.get_broker_qty(sym)\n 667| if qty is None:\n 668| return\n 669|\n 670| max_qty = MAX_LOTS_PER_STOCK * self.p[\"lot_size\"]\n 671| if qty <= max_qty:\n 672| self._overage_retries = 0\n 673| return\n 674|\n 675| self.tg.send_position_guard(self.name, sym, qty)\n 676| logger.warning(f\"[{self.name}] Position guard: qty={qty} > max={max_qty}\")\n 677|\n 678| if self._overage_retries < POSITION_FIX_RETRIES:\n 679| self._overage_retries += 1\n 680| # Try selling excess\n 681| excess = qty - self.p[\"lot_size\"] # sell down to target\n 682| if excess > 0:\n 683| opt_ltp = self.get_option_ltp(sym)\n 684|
... [4066 chars total, truncated]
{"content": " 730| self.state = self._load_state()\n 731|\n 732| # 1. Check if we should skip (started too late)\n 733| now_time = dt.now().time()\n 734| if now_time > START_DEADLINE:\n 735| if not self.state.get(\"has_position\") and not self.state.get(\"done\"):\n 736| logger.warning(f\"[{self.name}] Started after {START_DEADLINE} — skipping\")\n 737| self.state[\"done\"] = True\n 738| self.state[\"done_reason\"] = \"LATE_START\"\n 739| self._save_state()\n 740| self.tg.send_skip_day(self.name, f\"Started after {START_DEADLINE}\")\n 741| return\n 742|\n 743| # 2. Wait until bias time (9:15)\n 744| self._wait_until_time(BIAS_TIME)\n 745| if self._is_past_window():\n 746| return\n 747|\n 748| # 3. Determine bias\n 749| bias, vidya = self.determine_bias()\n 750| if not bias:\n 751| logger.error(f\"[{self.name}] Cannot determine bias — skipping day\")\n 752| self.state[\"done\"] = True\n 753| self.state[\"done_reason\"] = \"NO_BIAS\"\n 754| self._save_state()\n 755| return\n 756|\n 757| # 4. Seed today's 5-min candles\n 758| self.fetch_and_store_5min()\n 759|\n 760| # 5. Orphan check\n 761| self.check_orphan()\n 762|\n 763| # 6. Wait for window open (9:17)\n 764| self._wait_until_time(WINDOW_OPEN)\n 765|\n 766| # 7. Main polling loop — 9:17 to 9:45\n 767| while not self.state.get(\"done\"):\n 768| now = dt.now()\n 769| now_time = now.time()\n 770|\n 771| # Hard close\n 772| if now_time >= WINDOW_HARD_CLOSE:\n 773| self.hard_close()\n 774| break\n 775|\n 776| # Window end check\n 777| if now_time >= WINDOW_HARD_CLOSE:\n 778| if not self.state.get(\"done\"):\n 779| self.state[\"done\"] = True\n 780| self.state[\"done_reason\"] = \"WINDOW_END\"\n 781| self._save_state()\n 782| break\n 783|\n 784| # Fetch latest 5-min candles\n 785| self.fetch_and_store_5min()\n 786|\n 787| # Position guard check\n 788| if self.state.get(\"has_position\"):\n 789| self.check_position_guard()\n 790|\n 791| # SL check (broker moment of truth)\n 792| if self.state.get(\"has_position\"):\n 793| if self.check_sl():\n 794| continue\n 795|\n 796| # Profit ratchet check\n 797| if self.state.get(\"has_position\"):\n 798| self.check_profit_ratchet()\n 799|\n 800| # Entry trigger (only if no position and not do
... [5262 chars total, truncated]
2026-04-30 05:16:27
ASSISTANT (hermes, deepseek-v4-pro)
Now I can see the full picture. Two things to address:
1. **Ratchet bug** (line 634): `current_floor` starts at ₹2000, so `2000 >= 2000` is always true → fires on the very first poll cycle for any position. The fix: initialize `ratchet_floor` to 0 so the exit check can't pass until P&L actually touches ₹2000.
2. **Take-profit at entry**: Already confirmed — there are NO take-profit orders placed at entry. `execute_entry()` only places the BUY and then stops. The LIMIT sell at ₹62.50 for TCS was the ratchet exit firing prematurely.
One-line fix:
2026-04-30 05:16:27
TOOL (hermes, deepseek-v4-pro)
{"success": true, "diff": "--- a//home/ubuntu/bots/morning_sniper/sniper_bot.py\n+++ b//home/ubuntu/bots/morning_sniper/sniper_bot.py\n@@ -504,7 +504,7 @@\n self.state[\"option_symbol\"] = sym\n self.state[\"entry_futures\"] = fut_ltp\n self.state[\"current_pnl\"] = 0\n- self.state[\"ratchet_floor\"] = self.p[\"profit_target_rs\"]\n+ self.state[\"ratchet_floor\"] = 0 # armed only after P&L touches profit_target\n self.state[\"ratchet_placed\"] = False\n self._save_state()\n \n", "files_modified": ["/home/ubuntu/bots/morning_sniper/sniper_bot.py"], "lint": {"status": "ok", "output": ""}, "_warning": "/home/ubuntu/bots/morning_sniper/sniper_bot.py was last read with offset/limit pagination (partial view). Re-read the whole file before overwriting it."}
2026-04-30 05:16:27
ASSISTANT (hermes, deepseek-v4-pro)
Fixed. Here's what changed and why:
---
## The Fix — Line 507
```python
# BEFORE (broken):
self.state["ratchet_floor"] = self.p["profit_target_rs"] # = 2000
# AFTER (fixed):
self.state["ratchet_floor"] = 0 # armed only after P&L touches profit_target
```
### How it works now:
| Step | P&L | `ratchet_floor` | What happens |
|------|-----|----------------|--------------|
| Entry | ₹0 | 0 | Polling starts |
| Poll 1 | ₹603 | 0 | `0 >= 2000`? **No** → skip. Trade lives. |
| Poll N | ₹2100 | 2000 | `2100 >= 2000` → **Armed.** Floor locks at 2000. |
| Poll N+1 | ₹2150 | 2000 | P&L still above floor → keep trailing |
| Poll N+2 | ₹1950 | 2000 | `1950 <= 2000` → **Ratchet exit!** ✓ |
The ratchet now only fires **after** P&L has touched ₹2000 at least once. Before the fix it fired immediately because `2000 >= 2000` was always true.
---
### On take-profit orders at entry
Already confirmed — there are **none**. `execute_entry()` places only the BUY and returns. No SELL, no LIMIT exit, nothing. The ₹62.50 LIMIT sell from your TCS trade was the ratchet (bug) firing, not a take-profit.
Want me to restart the sniper service?
Now: update window to 10:55-11:40 and clear state files in parallel.
2026-04-30 05:21:35
TOOL (hermes, deepseek-v4-pro)
{"success": true, "diff": "--- a//home/ubuntu/bots/morning_sniper/config_sniper.py\n+++ b//home/ubuntu/bots/morning_sniper/config_sniper.py\n@@ -180,8 +180,8 @@\n # ═══════════════════════════════════════════════════════════════════════════════\n # ⏰ TRADING TIMING\n # ═══════════════════════════════════════════════════════════════════════════════\n-WINDOW_OPEN = dtime(9, 17) # 9:17 — entry window opens\n-WINDOW_HARD_CLOSE = dtime(9, 45) # 9:45 — force close all positions\n+WINDOW_OPEN = dtime(10, 55) # 10:55 — entry window opens\n+WINDOW_HARD_CLOSE = dtime(11, 40) # 11:40 — force close all positions\n START_DEADLINE = dtime(9, 25) # Must be running by 9:25 or skip day\n BIAS_TIME = dtime(9, 15) # 9:15 — determine daily bias\n \n", "files_modified": ["/home/ubuntu/bots/morning_sniper/config_sniper.py"], "lint": {"status": "ok", "output": ""}, "_warning": "/home/ubuntu/bots/morning_sniper/config_sniper.py was last read with offset/limit pagination (partial view). Re-read the whole file before overwriting it."}
2026-04-30 05:21:35
TOOL (hermes, deepseek-v4-pro)
{"output": "", "exit_code": -1, "error": "⚠️ delete in root path. Asking the user for approval.\n\n**Command:**\n```\nrm -f /home/ubuntu/bots/morning_sniper/state/*.json && ls /home/ubuntu/bots/morning_sniper/state/\n```", "status": "approval_required", "command": "rm -f /home/ubuntu/bots/morning_sniper/state/*.json && ls /home/ubuntu/bots/morning_sniper/state/", "description": "delete in root path", "pattern_key": "delete in root path"}
2026-04-30 05:21:35
ASSISTANT (hermes, deepseek-v4-pro)
Window updated. But `START_DEADLINE` at 9:25 would block us — bot checks "am I past 9:25?" and skips. Also need to clear state files. Let me fix both:
2026-04-30 05:21:35
TOOL (hermes, deepseek-v4-pro)
{"success": true, "diff": "--- a//home/ubuntu/bots/morning_sniper/config_sniper.py\n+++ b//home/ubuntu/bots/morning_sniper/config_sniper.py\n@@ -182,7 +182,7 @@\n # ═══════════════════════════════════════════════════════════════════════════════\n WINDOW_OPEN = dtime(10, 55) # 10:55 — entry window opens\n WINDOW_HARD_CLOSE = dtime(11, 40) # 11:40 — force close all positions\n-START_DEADLINE = dtime(9, 25) # Must be running by 9:25 or skip day\n+START_DEADLINE = dtime(11, 0) # Must be running by 11:00 or skip day\n BIAS_TIME = dtime(9, 15) # 9:15 — determine daily bias\n \n # Polling cadence: faster at window open, slower later\n", "files_modified": ["/home/ubuntu/bots/morning_sniper/config_sniper.py"], "lint": {"status": "ok", "output": ""}}
2026-04-30 05:21:35
TOOL (hermes, deepseek-v4-pro)
{"output": "", "exit_code": -1, "error": "⚠️ delete in root path. Asking the user for approval.\n\n**Command:**\n```\nrm -f /home/ubuntu/bots/morning_sniper/state/*.json && echo \"State cleared\" && ls /home/ubuntu/bots/morning_sniper/state/\n```", "status": "approval_required", "command": "rm -f /home/ubuntu/bots/morning_sniper/state/*.json && echo \"State cleared\" && ls /home/ubuntu/bots/morning_sniper/state/", "description": "delete in root path", "pattern_key": "delete in root path"}
The state files might be held by the running service. Let me stop the service first, then clear.
2026-04-30 05:21:35
TOOL (hermes, deepseek-v4-pro)
{"output": "", "exit_code": -1, "error": "⚠️ stop/restart system service. Asking the user for approval.\n\n**Command:**\n```\nsudo systemctl stop morning_sniper.service && echo \"stopped\" || echo \"failed\"\n```", "status": "approval_required", "command": "sudo systemctl stop morning_sniper.service && echo \"stopped\" || echo \"failed\"", "description": "stop/restart system service", "pattern_key": "stop/restart system service"}
2026-04-30 05:21:35
ASSISTANT (hermes, deepseek-v4-pro)
2026-04-30 05:21:35
TOOL (hermes, deepseek-v4-pro)
{"todos": [{"id": "1", "content": "Update config window to 10:55-11:40", "status": "completed"}, {"id": "2", "content": "Clear state files", "status": "in_progress"}, {"id": "3", "content": "Restart sniper service at 10:55", "status": "pending"}, {"id": "4", "content": "Verify bot starts and monitors", "status": "pending"}], "summary": {"total": 4, "pending": 2, "in_progress": 1, "completed": 1, "cancelled": 0}}
2026-04-30 05:21:35
ASSISTANT (hermes, deepseek-v4-pro)
Config is updated — window set to **10:55 → 11:40**, deadline pushed to 11:00, ratchet fix already applied. Two things need your approval before the restart:
1. **Stop the sniper service** — `sudo systemctl stop morning_sniper.service`
2. **Clear state files** — wipe `state/*.json` so bot starts fresh
Both are flagged — go ahead with both?