no args = help, add marks to live orders

Author: Graeme22

ttcli/__init__.py

@@ -4,5 +4,5 @@
 
 CUSTOM_CONFIG_PATH = ".config/ttcli/ttcli.cfg"
 TOKEN_PATH = ".config/ttcli/.session"
-VERSION = "0.6.0"
+VERSION = "0.6.1"
 __version__ = VERSION

ttcli/app.py

@@ -14,7 +14,7 @@
 from ttcli.utils import config_path
 from ttcli.watchlist import watchlist
 
-cli = Typer()
+cli = Typer(no_args_is_help=True)
 
 
 @cli.callback(invoke_without_command=True, no_args_is_help=True)

ttcli/option.py

@@ -113,12 +113,13 @@ def choose_futures_expiration(
     return exps[choice - 1]
 
 
-option = AsyncTyper(help="Buy, sell, and analyze options.")
+option = AsyncTyper(help="Buy, sell, and analyze options.", no_args_is_help=True)
 
 
 @option.command(
     help="Buy or sell calls with the given parameters.",
     context_settings={"ignore_unknown_options": True},
+    no_args_is_help=True,
 )
 async def call(
     symbol: str,
@@ -353,6 +354,7 @@ async def call(
 @option.command(
     help="Buy or sell puts with the given parameters.",
     context_settings={"ignore_unknown_options": True},
+    no_args_is_help=True,
 )
 async def put(
     symbol: str,
@@ -588,6 +590,7 @@ async def put(
 @option.command(
     help="Buy or sell strangles with the given parameters.",
     context_settings={"ignore_unknown_options": True},
+    no_args_is_help=True,
 )
 async def strangle(
     symbol: str,
@@ -905,7 +908,7 @@ async def strangle(
         acc.place_order(sesh, order, dry_run=False)
 
 
-@option.command(help="Fetch and display an options chain.")
+@option.command(help="Fetch and display an options chain.", no_args_is_help=True)
 async def chain(
     symbol: str,
     strikes: Annotated[

ttcli/order.py

@@ -1,9 +1,12 @@
+from collections import defaultdict
 from datetime import datetime
 from decimal import Decimal
+from math import gcd
 from typing import Annotated
 
 from rich.console import Console
 from rich.table import Table
+from tastytrade.market_data import get_market_data_by_type
 from tastytrade.order import InstrumentType, NewOrder, OrderStatus
 from tastytrade.utils import TastytradeError
 from typer import Option, Typer
@@ -17,7 +20,7 @@
     print_error,
 )
 
-order = Typer(help="List, adjust, or cancel orders.")
+order = Typer(help="List, adjust, or cancel orders.", no_args_is_help=True)
 
 
 @order.command(help="List, adjust, or cancel live orders.")
@@ -39,6 +42,19 @@ def live(
         for o in orders
         if o.status == OrderStatus.LIVE or o.status == OrderStatus.RECEIVED
     ]
+    instrument_dict: dict[InstrumentType, set[str]] = defaultdict(set)
+    for o in orders:
+        for leg in o.legs:
+            instrument_dict[leg.instrument_type].add(leg.symbol)
+    data = get_market_data_by_type(
+        sesh,
+        cryptocurrencies=list(instrument_dict[InstrumentType.CRYPTOCURRENCY]) or None,
+        equities=list(instrument_dict[InstrumentType.EQUITY]) or None,
+        futures=list(instrument_dict[InstrumentType.FUTURE]) or None,
+        future_options=list(instrument_dict[InstrumentType.FUTURE_OPTION]) or None,
+        options=list(instrument_dict[InstrumentType.EQUITY_OPTION]) or None,
+    )
+    marks = {d.symbol: d.mark for d in data}
     console = Console()
     table = Table(
         show_header=True,
@@ -55,11 +71,19 @@ def live(
     table.add_column("Type")
     table.add_column("TIF")
     table.add_column("Price", justify="right")
+    table.add_column("Mark", justify="right")
     # leg info
     table.add_column("Qty", justify="right")
     table.add_column("Legs")
 
     for i, order in enumerate(orders):
+        total_price = ZERO
+        # handle ratio spreads
+        quantity = gcd(*[int(leg.quantity or 0) for leg in order.legs])
+        for leg in order.legs:
+            if leg.quantity:
+                m = 1 if "Sell" in leg.action.value else -1
+                total_price += m * marks[leg.symbol] * leg.quantity / quantity
         row = [
             str(i + 1),
             order.updated_at.strftime("%Y-%m-%d %H:%M"),
@@ -68,6 +92,7 @@ def live(
             order.order_type.value,
             order.time_in_force.value,
             conditional_color(order.price) if order.price else "--",
+            conditional_color(total_price),
             conditional_quantity(order.legs[0].quantity or ZERO, order.legs[0].action),
             order.legs[0].symbol,
         ]
@@ -83,6 +108,7 @@ def live(
                 "",
                 "",
                 "",
+                "",
                 conditional_quantity(
                     order.legs[i].quantity or ZERO, order.legs[i].action
                 ),

ttcli/plot.py

@@ -1,4 +1,5 @@
 import os
+import shutil
 import tempfile
 from datetime import datetime, time, timedelta
 from enum import Enum
@@ -13,7 +14,7 @@
 
 from ttcli.utils import AsyncTyper, RenewableSession, print_error
 
-plot = AsyncTyper(help="Plot candle charts, portfolio P&L, or net liquidating value.")
+plot = AsyncTyper(help="Plot candle charts for any symbol.", no_args_is_help=True)
 fmt = "%Y-%m-%d %H:%M:%S"
 
 
@@ -49,6 +50,12 @@ def get_start_time(width: CandleType) -> datetime:
 
 
 def gnuplot(sesh: RenewableSession, symbol: str, candles: list[str]) -> None:
+    if not shutil.which("gnuplot"):
+        print_error(
+            "Please install gnuplot on your system to use the plot module: "
+            "[link=http://www.gnuplot.info]http://www.gnuplot.info[/link]"
+        )
+        return
     gnu = Gnuplot()
     tmp = tempfile.NamedTemporaryFile(delete=False)
     with open(tmp.name, "w") as f:
@@ -84,7 +91,7 @@ def gnuplot(sesh: RenewableSession, symbol: str, candles: list[str]) -> None:
     os.system("clear")
 
 
-@plot.command(help="Plot candle chart for the given symbol.")
+@plot.command(help="Plot candle chart for the given symbol.", no_args_is_help=True)
 async def stock(
     symbol: str,
     width: Annotated[
@@ -111,7 +118,7 @@ async def stock(
     gnuplot(sesh, symbol, candles)
 
 
-@plot.command(help="Plot candle chart for the given symbol.")
+@plot.command(help="Plot candle chart for the given symbol.", no_args_is_help=True)
 async def crypto(
     symbol: str,
     width: Annotated[
@@ -148,7 +155,7 @@ async def crypto(
     gnuplot(sesh, crypto.symbol, candles)
 
 
-@plot.command(help="Plot candle chart for the given symbol.")
+@plot.command(help="Plot candle chart for the given symbol.", no_args_is_help=True)
 async def future(
     symbol: str,
     width: Annotated[

ttcli/portfolio.py

@@ -41,7 +41,9 @@
     round_to_tick_size,
 )
 
-portfolio = AsyncTyper(help="View positions and stats for your portfolio.")
+portfolio = AsyncTyper(
+    help="View positions and stats for your portfolio.", no_args_is_help=True
+)
 
 
 def get_indicators(today: date, metrics: MarketMetricInfo) -> str:
@@ -186,7 +188,7 @@ async def positions(
     table.add_column("Net Liq", justify="right")
     table.add_column("Indicators", justify="center")
     sums = defaultdict(lambda: ZERO)
-    closing: dict[int, TradeableTastytradeData] = {}
+    closing: list[TradeableTastytradeData] = []
     for i, pos in enumerate(positions):
         row = [f"{i + 1}"]
         mark = pos.mark or ZERO
@@ -199,7 +201,7 @@ async def positions(
         # instrument-specific calculations
         if pos.instrument_type == InstrumentType.EQUITY_OPTION:
             o = options_dict[pos.symbol]
-            closing[i + 1] = o
+            closing.append(o)
             # BWD = beta * stock price * delta / index price
             delta = greeks_dict[o.streamer_symbol].delta * 100 * m
             theta = greeks_dict[o.streamer_symbol].theta * 100 * m
@@ -216,7 +218,7 @@ async def positions(
             pnl_day = day_change * pos.quantity * pos.multiplier
         elif pos.instrument_type == InstrumentType.FUTURE_OPTION:
             o = future_options_dict[pos.symbol]
-            closing[i + 1] = o
+            closing.append(o)
             delta = greeks_dict[o.streamer_symbol].delta * 100 * m
             theta = greeks_dict[o.streamer_symbol].theta * 100 * m
             gamma = greeks_dict[o.streamer_symbol].gamma * 100 * m
@@ -243,7 +245,7 @@ async def positions(
             metrics = metrics_dict[pos.symbol]
             e = equity_dict[pos.symbol]
             ticks = e.tick_sizes or []
-            closing[i + 1] = e
+            closing.append(e)
             beta = metrics.beta or 0
             indicators = get_indicators(today, metrics)
             bwd = beta * mark_price * delta / spy
@@ -258,7 +260,7 @@ async def positions(
             delta = pos.quantity * m * 100
             f = futures_dict[pos.symbol]
             ticks = f.tick_sizes or []
-            closing[i + 1] = f
+            closing.append(f)
             # BWD = beta * stock price * delta / index price
             metrics = metrics_dict[f.future_product.root_symbol]  # type: ignore
             indicators = get_indicators(today, metrics)
@@ -281,7 +283,7 @@ async def positions(
             pos.quantity = round(pos.quantity, 2)
             c = crypto_dict[pos.symbol]
             ticks = [TickSize(value=c.tick_size)]
-            closing[i + 1] = c
+            closing.append(c)
             day_change = mark_price - prev_close(c.symbol)
             pnl_day = day_change * pos.quantity * pos.multiplier
         else:
@@ -350,14 +352,18 @@ async def positions(
     close = get_confirmation("Close out a position? y/N ", default=False)
     if not close:
         return
-    # get the position(s) to close
-    to_close = input(
-        "Enter the number(s) of the leg(s) to include in closing order, separated by commas: "
-    )
-    if not to_close:
-        return
-    to_close = [int(i) for i in to_close.split(",")]
-    close_objs = [closing[i] for i in to_close]
+    if len(closing) > 1:
+        # get the position(s) to close
+        to_close = input(
+            "Enter the number(s) of the leg(s) to include in closing order, separated by commas: "
+        )
+        if not to_close:
+            return
+        to_close = [int(i) for i in to_close.split(",")]
+        close_objs = [closing[i - 1] for i in to_close]
+    else:
+        print("Auto-selected the only position available.")
+        close_objs = [closing[0]]
     account_number = pos_dict[close_objs[0].symbol].account_number
     if any(pos_dict[o.symbol].account_number != account_number for o in close_objs):
         print("All legs must be in the same account!")

ttcli/trade.py

@@ -26,12 +26,15 @@
     round_to_width,
 )
 
-trade = Typer(help="Buy or sell stocks/ETFs, crypto, and futures.")
+trade = Typer(
+    help="Buy or sell stocks/ETFs, crypto, and futures.", no_args_is_help=True
+)
 
 
 @trade.command(
     help="Buy or sell stocks/ETFs.",
     context_settings={"ignore_unknown_options": True},
+    no_args_is_help=True,
 )
 def stock(
     symbol: str,
@@ -125,7 +128,7 @@ def stock(
         acc.place_order(sesh, order, dry_run=False)
 
 
-@trade.command(help="Buy cryptocurrency.")
+@trade.command(help="Buy cryptocurrency.", no_args_is_help=True)
 def crypto(symbol: str, quantity: Annotated[Decimal, Argument(parser=decimalify)]):
     sesh = RenewableSession()
     symbol = symbol.upper()
@@ -219,6 +222,7 @@ def crypto(symbol: str, quantity: Annotated[Decimal, Argument(parser=decimalify)
 @trade.command(
     help="Buy or sell futures.",
     context_settings={"ignore_unknown_options": True},
+    no_args_is_help=True,
 )
 def future(
     symbol: str,

ttcli/watchlist.py

@@ -7,7 +7,9 @@
 
 
 @watchlist.command(
-    name="wl", help="Show prices and metrics for symbols in the given watchlist."
+    name="wl",
+    help="Show prices and metrics for symbols in the given watchlist.",
+    no_args_is_help=True,
 )
 def filter(name: str):
     print_warning("This functionality hasn't been implemented yet!")