Update module github.com/jedib0t/go-pretty/v6 to v6.7.10

.gitignore

@@ -1,2 +1 @@
 /.env
-/.worktrees/

README.md

@@ -1,31 +1 @@
 # crypto price bot
-
-Telegram bot tra giá crypto (Spot / Future / Alpha), funding rate và margin APR.
-
-## Environment variables
-
-Tạo file `.env` ở root project với các biến sau:
-
-```env
-# BẮT BUỘC: token bot Telegram
-TELEGRAM_TOKEN=your_telegram_bot_token
-
-# TÙY CHỌN: bật/tắt log env mode (mặc định true nếu không set)
-# giá trị hợp lệ: true / false
-LOG_ENV=true
-
-# TÙY CHỌN nhưng KHUYẾN NGHỊ: Telegram user id được phép dùng /refresh
-# nếu không set hoặc set sai format -> /refresh sẽ bị từ chối cho tất cả user
-ADMIN_CHAT_ID=123456789
-```
-
-## Run
-
-```bash
-go run ./cmd/tele
-```
-
-## Notes
-
-- `TELEGRAM_TOKEN` sai/thiếu: bot sẽ fail khi khởi tạo Telegram service.
-- `/refresh` dùng để refresh trading pair cache thủ công và chỉ cho `ADMIN_CHAT_ID`.

docs/superpowers/specs/2026-04-26-token-message-rich-design.md

@@ -1,130 +0,0 @@
-# Token message rich design
-
-## Context
-
-Current token message flow returns early for Alpha tokens, so users cannot see Spot/Future together with Alpha when multiple sources are available. Message content is also rigid and less informative for partial-source cases.
-
-Goal: redesign Telegram token message so each available price source is shown in one rich message, with stable ordering and conditional rows.
-
-## Scope
-
-Applies to token query message rendering in Telegram bot (`OnTokenInfoByToken` flow and price view formatting).
-
-Out of scope:
-- changing market data fetch logic
-- changing command routing
-- trend arrows / historical diff
-
-## Requirements
-
-1. Rich, multi-line Telegram message format.
-2. Spot is primary source when present.
-3. Show all available sources in a single message: Spot, Future, Alpha.
-4. Hide rows for missing data.
-5. Show Basis only when both Spot and Future exist.
-6. Show Alpha 24h when Alpha data exists.
-7. No trend arrows.
-8. Preserve current behavior of no reply when no Spot/Future/Alpha data exists.
-
-## Message format
-
-Fixed row order (hide missing rows):
-
-1. `🪙 TOKEN`
-2. `💵 Spot: ...` (primary if exists)
-3. `📈 Future: ...`
-4. `🅰️ Alpha: ...`
-5. `🧭 Basis: Future-Spot` (only if Spot+Future)
-6. `💸 Funding: ... in ...` (if Future exists)
-7. `🏦 Margin: ... APR` (if margin exists)
-8. `📊 Alpha 24h: ...` (if Alpha change exists)
-
-## Fallback rules
-
-- **All three available**: render all rows above (except any missing optional fields).
-- **Spot + Future**: render Spot, Future, Basis, Funding, Margin.
-- **Alpha only**: render Alpha and Alpha 24h.
-- **Future only**: render Future, Funding, Margin.
-- **Spot only**: render Spot, Margin.
-- **No Spot/Future/Alpha**: no reply.
-
-## Data flow behavior
-
-1. Resolve token to candidate futures symbol(s) using existing resolver.
-2. Collect available values from Spot/Future/Alpha/margin sources.
-3. Build one unified message model.
-4. Render rows in fixed order; each row is conditional on availability.
-5. Send single Telegram message.
-
-Important behavioral change: remove alpha-first early-return behavior; Alpha becomes a peer data source in unified rendering.
-
-## Formatting notes
-
-- Reuse existing numeric formatter (`RenderPrice`) for price values.
-- Keep current funding icon and countdown style.
-- Basis format:
-  - absolute delta: `Future - Spot`
-  - percent delta: `(Future-Spot)/Spot*100`
-  - sign preserved (`+`/`-`)
-
-## Example outputs
-
-### A) Spot + Future + Alpha
-
-```text
-🪙 ETH
-💵 Spot: $3,245
-📈 Future: $3,251
-🅰️ Alpha: $3,248
-🧭 Basis: +$6 (+0.18%)
-💸 Funding: +0.0123% 🟢 in 05m
-🏦 Margin: 7.665% APR
-📊 Alpha 24h: 🔴 -3.21%
-```
-
-### B) Spot + Future
-
-```text
-🪙 SOL
-💵 Spot: $182.4
-📈 Future: $183.0
-🧭 Basis: +$0.6 (+0.33%)
-💸 Funding: -0.0041% 🔴 in 42m
-🏦 Margin: 5.110% APR
-```
-
-### C) Alpha only
-
-```text
-🪙 ABC
-🅰️ Alpha: $0.1234
-📊 Alpha 24h: 🟢 +12.40%
-```
-
-### D) Future only
-
-```text
-🪙 TOKEN
-📈 Future: $1,234
-💸 Funding: +0.0081% 🟢 in 17m
-🏦 Margin: 6.200% APR
-```
-
-### E) Spot only
-
-```text
-🪙 TOKEN
-💵 Spot: $1,228
-🏦 Margin: 6.200% APR
-```
-
-## Verification checklist
-
-- Token with all 3 sources -> all expected rows appear, ordered correctly.
-- Token with Spot+Future but no Alpha -> no Alpha rows.
-- Token with Alpha only -> no Spot/Future/Basis/Funding rows.
-- Token with Future only -> no Spot/Basis/Alpha rows.
-- Token with Spot only -> no Future/Basis/Funding/Alpha rows.
-- Token with no data -> no reply.
-- Basis not shown unless both Spot and Future exist.
-- No trend arrows anywhere.

go.mod

@@ -4,7 +4,7 @@ go 1.25.0
 
 require (
 	github.com/adshao/go-binance/v2 v2.8.11
-	github.com/go-resty/resty/v2 v2.17.2
+	github.com/go-resty/resty/v2 v2.16.5
 	github.com/jedib0t/go-pretty/v6 v6.7.10
 	github.com/joho/godotenv v1.5.1
 	github.com/rs/zerolog v1.32.0
@@ -23,6 +23,6 @@ require (
 	github.com/mattn/go-runewidth v0.0.16 // indirect
 	github.com/rivo/uniseg v0.4.7 // indirect
 	github.com/shopspring/decimal v1.4.0 // indirect
-	golang.org/x/net v0.43.0 // indirect
+	golang.org/x/net v0.33.0 // indirect
-	golang.org/x/sys v0.35.0 // indirect
+	golang.org/x/sys v0.30.0 // indirect
 )

go.sum

@@ -135,8 +135,8 @@ github.com/go-playground/assert/v2 v2.0.1/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvSc
 github.com/go-playground/locales v0.13.0/go.mod h1:taPMhCMXrRLJO55olJkUXHZBHCxTMfnGwq/HNwmWNS8=
 github.com/go-playground/universal-translator v0.17.0/go.mod h1:UkSxE5sNxxRwHyU+Scu5vgOQjsIJAF8j9muTVoKLVtA=
 github.com/go-playground/validator/v10 v10.4.1/go.mod h1:nlOn6nFhuKACm19sB/8EGNn9GlaMV7XkbRSipzJ0Ii4=
-github.com/go-resty/resty/v2 v2.17.2 h1:FQW5oHYcIlkCNrMD2lloGScxcHJ0gkjshV3qcQAyHQk=
+github.com/go-resty/resty/v2 v2.16.5 h1:hBKqmWrr7uRc3euHVqmh1HTHcKn99Smr7o5spptdhTM=
-github.com/go-resty/resty/v2 v2.17.2/go.mod h1:kCKZ3wWmwJaNc7S29BRtUhJwy7iqmn+2mLtQrOyQlVA=
+github.com/go-resty/resty/v2 v2.16.5/go.mod h1:hkJtXbA2iKHzJheXYvQ8snQES5ZLGKMwQ07xAwp/fiA=
 github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
 github.com/goccy/go-yaml v1.9.5/go.mod h1:U/jl18uSupI5rdI2jmuCswEA2htH9eXfferR3KfscvA=
 github.com/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
@@ -511,8 +511,8 @@ golang.org/x/net v0.0.0-20220325170049-de3da57026de/go.mod h1:CfG3xpIq0wQ8r1q4Su
 golang.org/x/net v0.0.0-20220412020605-290c469a71a5/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk=
 golang.org/x/net v0.0.0-20220425223048-2871e0cb64e4/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk=
 golang.org/x/net v0.0.0-20220520000938-2e3eb7b945c2/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk=
-golang.org/x/net v0.43.0 h1:lat02VYK2j4aLzMzecihNvTlJNQUq316m2Mr9rnM6YE=
+golang.org/x/net v0.33.0 h1:74SYHlV8BIgHIFC/LrYkOGIwL19eTYXQ5wc6TBuO36I=
-golang.org/x/net v0.43.0/go.mod h1:vhO1fvI4dGsIjh73sWfUVjj3N7CA9WkKJNQm2svM6Jg=
+golang.org/x/net v0.33.0/go.mod h1:HXLR5J+9DxmrqMwG9qjGCxZ+zKXxBru04zlTvWlWuN4=
 golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
 golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
 golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
@@ -626,8 +626,8 @@ golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBc
 golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.35.0 h1:vz1N37gP5bs89s7He8XuIYXpyY0+QlsKmzipCbUtyxI=
+golang.org/x/sys v0.30.0 h1:QjkSwP/36a20jFYWkSue1YwXzLmsV5Gfq7Eiy72C1uc=
-golang.org/x/sys v0.35.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
+golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
 golang.org/x/text v0.0.0-20170915032832-14c0d48ead0c/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
@@ -644,8 +644,8 @@ golang.org/x/text v0.36.0/go.mod h1:NIdBknypM8iqVmPiuco0Dh6P5Jcdk8lJL0CUebqK164=
 golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
 golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
 golang.org/x/time v0.0.0-20191024005414-555d28b269f0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
-golang.org/x/time v0.12.0 h1:ScB/8o8olJvc+CQPWrK3fPZNfh7qgwCrY0zJmoEQLSE=
+golang.org/x/time v0.6.0 h1:eTDhh4ZXt5Qf0augr54TN6suAUudPcawVZeIAPU7D4U=
-golang.org/x/time v0.12.0/go.mod h1:CDIdPxbZBQxdj6cxyCIdrNogrJKMJ7pr37NYpMcMDSg=
+golang.org/x/time v0.6.0/go.mod h1:3BpzKBy/shNhVucY/MWOyx10tF3SFh9QdLuxbVysPQM=
 golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=

internal/data/imarket.go

@@ -13,7 +13,6 @@ type IMarket interface {
 	// Alpha token methods
 	IsAlphaToken(symbol string) bool
 	GetAlphaToken(symbol string) (market.AlphaTokenInfo, bool)
-	GetAlphaPrice(symbol string) (float64, bool)
 
 	// Trading pair methods
 	IsSpotPair(symbol string) bool

internal/data/market/alpha_tokens.go

@@ -4,7 +4,6 @@ import (
 	"encoding/json"
 	"fmt"
 	"net/http"
-	"net/url"
 	"strconv"
 	"time"
 
@@ -55,21 +54,10 @@ type AlphaTokenInfo struct {
 
 // AlphaTokenResponse represents the API response structure
 type AlphaTokenResponse struct {
-	Code          string           `json:"code"`
+	Code         string           `json:"code"`
-	Message       *string          `json:"message"`
+	Message      *string          `json:"message"`
-	MessageDetail *string          `json:"messageDetail"`
-	Data          []AlphaTokenInfo `json:"data"`
-}
-
-type AlphaTickerData struct {
-	Price string `json:"price"`
-}
-
-type AlphaTickerResponse struct {
-	Code          string          `json:"code"`
-	Message       *string         `json:"message"`
 	MessageDetail *string         `json:"messageDetail"`
-	Data          AlphaTickerData `json:"data"`
+	Data         []AlphaTokenInfo `json:"data"`
 }
 
 // GetPrice returns the price as float64
@@ -162,37 +150,3 @@ func (ms *MarketData) IsAlphaToken(symbol string) bool {
 	_, exists := ms.GetAlphaToken(symbol)
 	return exists
 }
-
-func (ms *MarketData) GetAlphaPrice(symbol string) (float64, bool) {
-	const alphaTickerURL = "https://www.binance.com/bapi/defi/v1/public/alpha-trade/ticker"
-
-	client := &http.Client{Timeout: 5 * time.Second}
-	endpoint := alphaTickerURL + "?" + url.Values{"symbol": []string{symbol}}.Encode()
-
-	resp, err := client.Get(endpoint)
-	if err != nil {
-		log.Error().Err(err).Str("symbol", symbol).Msg("Failed to fetch Alpha ticker")
-		return 0, false
-	}
-	defer resp.Body.Close()
-
-	if resp.StatusCode != http.StatusOK {
-		return 0, false
-	}
-
-	var tickerResp AlphaTickerResponse
-	if err := json.NewDecoder(resp.Body).Decode(&tickerResp); err != nil {
-		return 0, false
-	}
-
-	if tickerResp.Code != "000000" {
-		return 0, false
-	}
-
-	price, err := strconv.ParseFloat(tickerResp.Data.Price, 64)
-	if err != nil || price <= 0 {
-		return 0, false
-	}
-
-	return price, true
-}

internal/services/tele/commands/token.go

@@ -2,54 +2,15 @@ package commands
 
 import (
 	"strings"
-	"sync"
 
 	"gopkg.in/telebot.v3"
 	"me.thuanle/bbot/internal/configs/tele"
 	"me.thuanle/bbot/internal/data"
+	"me.thuanle/bbot/internal/helper/binancex"
 	"me.thuanle/bbot/internal/services/tele/chat"
 	"me.thuanle/bbot/internal/services/tele/view"
 )
 
-type buildRichTokenMessageArgs struct {
-	Token string
-
-	HasSpot   bool
-	SpotPrice float64
-
-	HasFuture     bool
-	FuturePrice   float64
-	FundingRate   float64
-	FundingTimeMs int64
-
-	HasAlpha   bool
-	AlphaPrice float64
-
-	HasAlpha24h bool
-	Alpha24h    float64
-
-	HasMarginAPR     bool
-	MarginAPRPercent float64
-}
-
-func buildRichTokenMessageInput(a buildRichTokenMessageArgs) view.RichTokenMessageInput {
-	return view.RichTokenMessageInput{
-		Token:            a.Token,
-		HasSpot:          a.HasSpot,
-		SpotPrice:        a.SpotPrice,
-		HasFuture:        a.HasFuture,
-		FuturePrice:      a.FuturePrice,
-		FundingRate:      a.FundingRate,
-		FundingTimeMs:    a.FundingTimeMs,
-		HasAlpha:         a.HasAlpha,
-		AlphaPrice:       a.AlphaPrice,
-		HasAlpha24h:      a.HasAlpha24h,
-		Alpha24hChange:   a.Alpha24h,
-		HasMarginAPR:     a.HasMarginAPR,
-		MarginAPRPercent: a.MarginAPRPercent,
-	}
-}
-
 func showStickerMode(context telebot.Context, token string) {
 	token = strings.ToUpper(token)
 	stickerIdx, ok := tele.Token2StickerIdxMap[token]
@@ -62,80 +23,39 @@ func showStickerMode(context telebot.Context, token string) {
 	}
 }
 
-func collectRichTokenData(token string) buildRichTokenMessageArgs {
-	a := buildRichTokenMessageArgs{Token: token}
-
-	marginRates := data.Market.GetMarginInterestRates()
-	a.MarginAPRPercent = marginRates[token] * 365 * 100
-	a.HasMarginAPR = marginRates[token] != 0
-
-	futureSymbol := token + "USDT"
-	spotSymbol := token + "USDT"
-
-	var (
-		wg sync.WaitGroup
-		mu sync.Mutex
-	)
-	wg.Add(3)
-
-	go func() {
-		defer wg.Done()
-		if alphaToken, ok := data.Market.GetAlphaToken(token); ok {
-			alpha24h := alphaToken.GetPercentChange24h()
-			alphaPrice := alphaToken.GetPrice()
-			if p, ok := data.Market.GetAlphaPrice(token + "USDT"); ok {
-				alphaPrice = p
-			}
-			mu.Lock()
-			a.HasAlpha = true
-			a.HasAlpha24h = true
-			a.Alpha24h = alpha24h
-			a.AlphaPrice = alphaPrice
-			mu.Unlock()
-		}
-	}()
-
-	go func() {
-		defer wg.Done()
-		if data.Market.IsFuturesPair(futureSymbol) {
-			if fp, fr, ft, ok := data.Market.GetFuturePrice(futureSymbol); ok {
-				mu.Lock()
-				a.HasFuture = true
-				a.FuturePrice = fp
-				a.FundingRate = fr
-				a.FundingTimeMs = ft
-				mu.Unlock()
-			}
-		}
-	}()
-
-	go func() {
-		defer wg.Done()
-		if data.Market.IsSpotPair(spotSymbol) {
-			if sp, ok := data.Market.GetSpotPrice(spotSymbol); ok {
-				mu.Lock()
-				a.HasSpot = true
-				a.SpotPrice = sp
-				mu.Unlock()
-			}
-		}
-	}()
-
-	wg.Wait()
-	return a
-}
-
 func OnTokenInfoByToken(context telebot.Context, token string) error {
 	token = strings.ToUpper(token)
-	showStickerMode(context, token)
 
-	args := collectRichTokenData(token)
+	// Check if it's an Alpha token first
-	if !args.HasSpot && !args.HasFuture && !args.HasAlpha {
+	if data.Market.IsAlphaToken(token) {
+		showStickerMode(context, token)
+
+		if alphaToken, exists := data.Market.GetAlphaToken(token); exists {
+			sp := alphaToken.GetPrice()
+			change24h := alphaToken.GetPercentChange24h()
+			_ = chat.ReplyMessage(context, view.RenderOnAlphaPriceMessage(token, sp, change24h))
+		}
 		return nil
 	}
 
-	msg := view.RenderRichTokenMessage(buildRichTokenMessageInput(args))
+	// Regular token handling
-	_ = chat.ReplyMessage(context, msg)
+	symbols := binancex.Token2Symbols(token)
+	if len(symbols) == 0 {
+		return nil
+	}
+
+	showStickerMode(context, token)
+
+	fp, fundRate, fundTime, ok := data.Market.GetFuturePrice(symbols[0])
+	marginRates := data.Market.GetMarginInterestRates()
+	tokenInterestRate := marginRates[token]
+	if !ok {
+		return nil
+	}
+	sSymbol := binancex.Future2SpotSymbol(symbols[0])
+	sp, _ := data.Market.GetSpotPrice(sSymbol)
+
+	_ = chat.ReplyMessage(context, view.RenderOnPriceMessage(symbols[0], sp, fp, fundRate, fundTime, tokenInterestRate))
 	return nil
 }
 

internal/services/tele/commands/token_test.go

@@ -1,230 +0,0 @@
-package commands
-
-import (
-	"sync"
-	"testing"
-	"time"
-
-	"me.thuanle/bbot/internal/data"
-	"me.thuanle/bbot/internal/data/market"
-)
-
-func TestBuildRichTokenMessageInput_AllSources(t *testing.T) {
-	in := buildRichTokenMessageInput(buildRichTokenMessageArgs{
-		Token:            "ETH",
-		SpotPrice:        3245,
-		HasSpot:          true,
-		FuturePrice:      3251,
-		FundingRate:      0.000123,
-		FundingTimeMs:    1740000000000,
-		HasFuture:        true,
-		AlphaPrice:       3248,
-		HasAlpha:         true,
-		Alpha24h:         -3.21,
-		HasAlpha24h:      true,
-		MarginAPRPercent: 7.665,
-		HasMarginAPR:     true,
-	})
-
-	if !in.HasSpot || !in.HasFuture || !in.HasAlpha || !in.HasAlpha24h || !in.HasMarginAPR {
-		t.Fatalf("expected all source flags true: %+v", in)
-	}
-}
-
-func TestBuildRichTokenMessageInput_OnlyAlpha(t *testing.T) {
-	in := buildRichTokenMessageInput(buildRichTokenMessageArgs{
-		Token:       "ABC",
-		HasAlpha:    true,
-		AlphaPrice:  0.1234,
-		HasAlpha24h: true,
-		Alpha24h:    12.4,
-	})
-
-	if !in.HasAlpha || !in.HasAlpha24h {
-		t.Fatalf("expected alpha flags true: %+v", in)
-	}
-	if in.HasSpot || in.HasFuture {
-		t.Fatalf("did not expect spot/future flags true: %+v", in)
-	}
-}
-
-type marketStub struct {
-	spotPairs    map[string]bool
-	futuresPairs map[string]bool
-	spotPrices   map[string]float64
-	futurePrices map[string]struct {
-		price float64
-		rate  float64
-		time  int64
-	}
-	alphaTokens map[string]market.AlphaTokenInfo
-	alphaPrices map[string]float64
-	marginRates map[string]float64
-
-	gate   *sync.WaitGroup
-	ready  chan struct{}
-	done   chan struct{}
-	mu     sync.Mutex
-	starts int
-}
-
-func (m *marketStub) waitConcurrentGate() {
-	if m.gate == nil {
-		return
-	}
-	m.mu.Lock()
-	m.starts++
-	m.mu.Unlock()
-	m.gate.Done()
-	<-m.ready
-}
-
-func (m *marketStub) GetFuturePrice(symbol string) (float64, float64, int64, bool) {
-	m.waitConcurrentGate()
-	v, ok := m.futurePrices[symbol]
-	if !ok {
-		return 0, 0, 0, false
-	}
-	return v.price, v.rate, v.time, true
-}
-func (m *marketStub) GetAllPremiumIndex() (map[string]market.PremiumIndex, error) { return nil, nil }
-func (m *marketStub) GetAllFundRate() (map[string]float64, map[string]int64)      { return nil, nil }
-func (m *marketStub) GetSpotPrice(symbol string) (float64, bool) {
-	m.waitConcurrentGate()
-	v, ok := m.spotPrices[symbol]
-	return v, ok
-}
-func (m *marketStub) GetMarginInterestRates() map[string]float64 { return m.marginRates }
-func (m *marketStub) IsAlphaToken(symbol string) bool {
-	_, ok := m.alphaTokens[symbol]
-	return ok
-}
-func (m *marketStub) GetAlphaToken(symbol string) (market.AlphaTokenInfo, bool) {
-	v, ok := m.alphaTokens[symbol]
-	return v, ok
-}
-func (m *marketStub) GetAlphaPrice(symbol string) (float64, bool) {
-	m.waitConcurrentGate()
-	v, ok := m.alphaPrices[symbol]
-	return v, ok
-}
-func (m *marketStub) IsSpotPair(symbol string) bool    { return m.spotPairs[symbol] }
-func (m *marketStub) IsFuturesPair(symbol string) bool { return m.futuresPairs[symbol] }
-func (m *marketStub) RefreshTradingPairCache() error   { return nil }
-
-func TestCollectRichTokenData_SpotOnlyReachable(t *testing.T) {
-	orig := data.Market
-	defer func() { data.Market = orig }()
-
-	data.Market = &marketStub{
-		spotPairs:  map[string]bool{"ABCUSDT": true},
-		spotPrices: map[string]float64{"ABCUSDT": 1.23},
-	}
-
-	args := collectRichTokenData("ABC")
-	if !args.HasSpot {
-		t.Fatalf("expected spot to be reachable for spot-only token: %+v", args)
-	}
-	if args.HasFuture || args.HasAlpha {
-		t.Fatalf("did not expect future/alpha for spot-only token: %+v", args)
-	}
-}
-
-func TestCollectRichTokenData_FutureFailureStillKeepsSpot(t *testing.T) {
-	orig := data.Market
-	defer func() { data.Market = orig }()
-
-	data.Market = &marketStub{
-		spotPairs:    map[string]bool{"ETHUSDT": true},
-		futuresPairs: map[string]bool{"ETHUSDT": true},
-		spotPrices:   map[string]float64{"ETHUSDT": 3245},
-		futurePrices: map[string]struct {
-			price float64
-			rate  float64
-			time  int64
-		}{},
-	}
-
-	args := collectRichTokenData("ETH")
-	if !args.HasSpot {
-		t.Fatalf("expected spot to remain available when future lookup fails: %+v", args)
-	}
-	if args.HasFuture {
-		t.Fatalf("did not expect future when future lookup fails: %+v", args)
-	}
-}
-
-func TestCollectRichTokenData_AlphaUsesSymbolPrice(t *testing.T) {
-	orig := data.Market
-	defer func() { data.Market = orig }()
-
-	data.Market = &marketStub{
-		alphaTokens: map[string]market.AlphaTokenInfo{
-			"ABC": {Symbol: "ABC", PercentChange24h: "12.4", Price: "0.1"},
-		},
-		alphaPrices: map[string]float64{"ABCUSDT": 0.1234},
-	}
-
-	args := collectRichTokenData("ABC")
-	if !args.HasAlpha {
-		t.Fatalf("expected alpha to be available: %+v", args)
-	}
-	if !args.HasAlpha24h {
-		t.Fatalf("expected alpha 24h to be available: %+v", args)
-	}
-	if args.AlphaPrice != 0.1234 {
-		t.Fatalf("expected alpha price from symbol lookup, got %.4f", args.AlphaPrice)
-	}
-}
-
-func TestCollectRichTokenData_RunsLookupsConcurrently(t *testing.T) {
-	orig := data.Market
-	defer func() { data.Market = orig }()
-
-	gate := &sync.WaitGroup{}
-	gate.Add(3)
-	st := &marketStub{
-		spotPairs:    map[string]bool{"ABCUSDT": true},
-		futuresPairs: map[string]bool{"ABCUSDT": true},
-		spotPrices:   map[string]float64{"ABCUSDT": 1.23},
-		futurePrices: map[string]struct {
-			price float64
-			rate  float64
-			time  int64
-		}{"ABCUSDT": {price: 1.24, rate: 0.0001, time: 1740000000000}},
-		alphaTokens: map[string]market.AlphaTokenInfo{
-			"ABC": {Symbol: "ABC", PercentChange24h: "2.5", Price: "1.22"},
-		},
-		alphaPrices: map[string]float64{"ABCUSDT": 1.22},
-		gate:        gate,
-		ready:       make(chan struct{}),
-	}
-	data.Market = st
-
-	finished := make(chan buildRichTokenMessageArgs, 1)
-	go func() {
-		finished <- collectRichTokenData("ABC")
-	}()
-
-	waitDone := make(chan struct{})
-	go func() {
-		gate.Wait()
-		close(waitDone)
-	}()
-
-	select {
-	case <-waitDone:
-		close(st.ready)
-	case <-time.After(200 * time.Millisecond):
-		t.Fatalf("expected price lookups to run concurrently")
-	}
-
-	select {
-	case args := <-finished:
-		if !args.HasSpot || !args.HasFuture || !args.HasAlpha {
-			t.Fatalf("expected all lookups present: %+v", args)
-		}
-	case <-time.After(200 * time.Millisecond):
-		t.Fatalf("collectRichTokenData did not finish")
-	}
-}

internal/services/tele/view/price.go

@@ -2,16 +2,13 @@ package view
 
 import (
 	"fmt"
-	"math"
-	"strings"
-	"time"
-
 	"github.com/jedib0t/go-pretty/v6/table"
 	"golang.org/x/text/language"
 	"golang.org/x/text/message"
 	"me.thuanle/bbot/internal/helper/binancex"
 	"me.thuanle/bbot/internal/services/tele/view/helper"
 	"me.thuanle/bbot/internal/utils/timex"
+	"time"
 )
 
 func RenderPrice(price float64) string {
@@ -66,73 +63,6 @@ func RenderOnAlphaPriceMessage(symbol string, price float64, change24h float64)
 	)
 }
 
-type RichTokenMessageInput struct {
-	Token string
-
-	HasSpot   bool
-	SpotPrice float64
-
-	HasFuture     bool
-	FuturePrice   float64
-	FundingRate   float64
-	FundingTimeMs int64
-
-	HasAlpha   bool
-	AlphaPrice float64
-
-	HasAlpha24h    bool
-	Alpha24hChange float64
-
-	HasMarginAPR     bool
-	MarginAPRPercent float64
-}
-
-func RenderRichTokenMessage(in RichTokenMessageInput) string {
-	rows := []string{fmt.Sprintf("🪙 %s", strings.ToUpper(in.Token))}
-
-	if in.HasSpot {
-		rows = append(rows, fmt.Sprintf("💵 Spot: $%s", RenderPrice(in.SpotPrice)))
-	}
-	if in.HasFuture {
-		rows = append(rows, fmt.Sprintf("📈 Future: $%s", RenderPrice(in.FuturePrice)))
-	}
-	if in.HasAlpha {
-		rows = append(rows, fmt.Sprintf("🅰️ Alpha: $%s", RenderPrice(in.AlphaPrice)))
-	}
-
-	if in.HasSpot && in.HasFuture && in.SpotPrice > 0 {
-		delta := in.FuturePrice - in.SpotPrice
-		deltaPct := delta / in.SpotPrice * 100
-		sign := "+"
-		if delta < 0 {
-			sign = "-"
-		}
-		rows = append(rows, fmt.Sprintf("🧭 Basis: %s$%s (%+.2f%%)", sign, RenderPrice(math.Abs(delta)), deltaPct))
-	}
-
-	if in.HasFuture {
-		rows = append(rows, fmt.Sprintf("💸 Funding: %.4f%% %s in %s",
-			in.FundingRate*100,
-			IconOfFundingFeeDirection(in.FundingRate),
-			timex.CdMinuteStringTime(time.UnixMilli(in.FundingTimeMs)),
-		))
-	}
-
-	if in.HasMarginAPR {
-		rows = append(rows, fmt.Sprintf("🏦 Margin: %.3f%% APR", in.MarginAPRPercent))
-	}
-
-	if in.HasAlpha24h {
-		icon := "🟢"
-		if in.Alpha24hChange < 0 {
-			icon = "🔴"
-		}
-		rows = append(rows, fmt.Sprintf("📊 Alpha 24h: %s%+.2f%%", icon, in.Alpha24hChange))
-	}
-
-	return strings.Join(rows, "\n")
-}
-
 func RenderOnGetTopPricesMessage(symbols []string, price []float64, fundRate []float64) string {
 	t := helper.NewNoBorderTableWriter("", "Price", "Fund")
 	mFmt := message.NewPrinter(language.AmericanEnglish)

internal/services/tele/view/price_test.go

@@ -1,137 +0,0 @@
-package view
-
-import (
-	"strings"
-	"testing"
-)
-
-func assertContainsAll(t *testing.T, msg string, rows ...string) {
-	t.Helper()
-	for _, r := range rows {
-		if !strings.Contains(msg, r) {
-			t.Fatalf("expected row %q in message:\n%s", r, msg)
-		}
-	}
-}
-
-func assertContainsNone(t *testing.T, msg string, rows ...string) {
-	t.Helper()
-	for _, r := range rows {
-		if strings.Contains(msg, r) {
-			t.Fatalf("unexpected row %q in message:\n%s", r, msg)
-		}
-	}
-}
-
-func TestRenderRichTokenMessage_AllSources(t *testing.T) {
-	msg := RenderRichTokenMessage(RichTokenMessageInput{
-		Token:            "ETH",
-		HasSpot:          true,
-		SpotPrice:        3245,
-		HasFuture:        true,
-		FuturePrice:      3251,
-		FundingRate:      0.000123,
-		FundingTimeMs:    1740000000000,
-		HasAlpha:         true,
-		AlphaPrice:       3248,
-		HasAlpha24h:      true,
-		Alpha24hChange:   -3.21,
-		HasMarginAPR:     true,
-		MarginAPRPercent: 7.665,
-	})
-
-	expectedOrder := []string{
-		"🪙 ETH",
-		"💵 Spot:",
-		"📈 Future:",
-		"🅰️ Alpha:",
-		"🧭 Basis:",
-		"💸 Funding:",
-		"🏦 Margin:",
-		"📊 Alpha 24h:",
-	}
-
-	last := -1
-	for _, part := range expectedOrder {
-		i := strings.Index(msg, part)
-		if i == -1 {
-			t.Fatalf("missing row %q in message:\n%s", part, msg)
-		}
-		if i < last {
-			t.Fatalf("row %q appears out of order in message:\n%s", part, msg)
-		}
-		last = i
-	}
-}
-
-func TestRenderRichTokenMessage_FutureOnly(t *testing.T) {
-	msg := RenderRichTokenMessage(RichTokenMessageInput{
-		Token:            "ABC",
-		HasFuture:        true,
-		FuturePrice:      1234,
-		FundingRate:      0.000081,
-		FundingTimeMs:    1740000000000,
-		HasMarginAPR:     true,
-		MarginAPRPercent: 6.2,
-	})
-
-	assertContainsAll(t, msg, "🪙 ABC", "📈 Future:", "💸 Funding:", "🏦 Margin:")
-	assertContainsNone(t, msg, "💵 Spot:", "🅰️ Alpha:", "🧭 Basis:", "📊 Alpha 24h:")
-}
-
-func TestRenderRichTokenMessage_SpotOnly(t *testing.T) {
-	msg := RenderRichTokenMessage(RichTokenMessageInput{
-		Token:            "XRP",
-		HasSpot:          true,
-		SpotPrice:        2.1,
-		HasMarginAPR:     true,
-		MarginAPRPercent: 5.11,
-	})
-
-	assertContainsAll(t, msg, "🪙 XRP", "💵 Spot:", "🏦 Margin:")
-	assertContainsNone(t, msg, "📈 Future:", "🅰️ Alpha:", "🧭 Basis:", "💸 Funding:", "📊 Alpha 24h:")
-}
-
-func TestRenderRichTokenMessage_AlphaOnly(t *testing.T) {
-	msg := RenderRichTokenMessage(RichTokenMessageInput{
-		Token:          "ABC",
-		HasAlpha:       true,
-		AlphaPrice:     0.1234,
-		HasAlpha24h:    true,
-		Alpha24hChange: 12.4,
-	})
-
-	assertContainsAll(t, msg, "🪙 ABC", "🅰️ Alpha:", "📊 Alpha 24h:")
-	assertContainsNone(t, msg, "💵 Spot:", "📈 Future:", "🧭 Basis:", "💸 Funding:", "🏦 Margin:")
-}
-
-func TestRenderRichTokenMessage_SpotAndFuture(t *testing.T) {
-	msg := RenderRichTokenMessage(RichTokenMessageInput{
-		Token:            "SOL",
-		HasSpot:          true,
-		SpotPrice:        182.4,
-		HasFuture:        true,
-		FuturePrice:      183.0,
-		FundingRate:      -0.000041,
-		FundingTimeMs:    1740000000000,
-		HasMarginAPR:     true,
-		MarginAPRPercent: 5.11,
-	})
-
-	assertContainsAll(t, msg, "🪙 SOL", "💵 Spot:", "📈 Future:", "🧭 Basis: +$0.6000", "💸 Funding:", "🏦 Margin:")
-	assertContainsNone(t, msg, "🅰️ Alpha:", "📊 Alpha 24h:")
-}
-
-func TestRenderRichTokenMessage_SpotAndFutureNegativeBasis(t *testing.T) {
-	msg := RenderRichTokenMessage(RichTokenMessageInput{
-		Token:         "ADA",
-		HasSpot:       true,
-		SpotPrice:     1.2,
-		HasFuture:     true,
-		FuturePrice:   1.1,
-		FundingRate:   0.000011,
-		FundingTimeMs: 1740000000000,
-	})
-
-	assertContainsAll(t, msg, "🧭 Basis: -$0.10000 (-8.33%)")
-}