Merge branch 'main' into feature/reportSubcommandFunctionality

pagu-project · Mar 2, 2025 · ba67159 · ba67159
2 parents d48d062 + 5d7a431
commit ba67159
Show file tree

Hide file tree

Showing 4 changed files with 29 additions and 4 deletions.
diff --git a/internal/engine/command/market/market.gen.go b/internal/engine/command/market/market.gen.go
diff --git a/internal/engine/command/market/market.yml b/internal/engine/command/market/market.yml
@@ -7,6 +7,9 @@ sub_commands:
   help: Shows the latest price of PAC coin across different markets
   result_template: |
   
+    Xeggex Price: **{{.xeggexPrice}} USDT**
+    [Xeggex](https://xeggex.com/market/PACTUS_USDT)
+
     Tradeogre Price: **{{.tradeOgre}} USDT**
     [Trade Ogre](https://tradeogre.com/exchange/PAC-USDT)
 

diff --git a/internal/engine/command/market/price.go b/internal/engine/command/market/price.go
@@ -15,10 +15,19 @@ func (m *MarketCmd) priceHandler(_ *entity.User, cmd *command.Command, _ map[str
 		return cmd.RenderFailedTemplate("failed to get price from markets. please try again later")
 	}
 
+	xeggexPrice, err := strconv.ParseFloat(priceData.XeggexPacToUSDT.LastPrice, 64)
+	if err != nil {
+		log.Error("unable to parse float", "error", err)
+	}
+
 	tradeOgre, err := strconv.ParseFloat(priceData.TradeOgrePacToUSDT.Price, 64)
 	if err != nil {
 		log.Error("unable to parse float", "error", err)
 	}
 
-	return cmd.RenderResultTemplate("tradeOgre", tradeOgre, "azbitPrice", priceData.AzbitPacToUSDT.Price)
+	return cmd.RenderResultTemplate(
+		"xeggexPrice", xeggexPrice,
+		"tradeOgre", tradeOgre,
+		"azbitPrice", priceData.AzbitPacToUSDT.Price,
+	)
 }
diff --git a/internal/job/price.go b/internal/job/price.go
@@ -15,8 +15,9 @@ import (
 )
 
 const (
-	_defaultTradeOgreEndpoint  = "https://tradeogre.com/api/v1/ticker/PAC-USDT"
-	_defaultAzbitPriceEndpoint = "https://data.azbit.com/api/tickers?currencyPairCode=PAC_USDT"
+	_defaultXeggexPriceEndpoint = "https://api.xeggex.com/api/v2/market/getbysymbol/Pactus%2Fusdt"
+	_defaultTradeOgreEndpoint   = "https://tradeogre.com/api/v1/ticker/PAC-USDT"
+	_defaultAzbitPriceEndpoint  = "https://data.azbit.com/api/tickers?currencyPairCode=PAC_USDT"
 )
 
 type price struct {
@@ -48,12 +49,23 @@ func (p *price) start() {
 	var (
 		wg        sync.WaitGroup
 		price     entity.Price
+		xeggex    entity.XeggexPriceResponse
 		tradeOgre entity.TradeOgrePriceResponse
 		azbit     []entity.AzbitPriceResponse
 	)
 
 	ctx := context.Background()
 
+	wg.Add(1)
+	go func() {
+		defer wg.Done()
+		if err := p.getPrice(ctx, _defaultXeggexPriceEndpoint, &xeggex); err != nil {
+			log.Error(err.Error())
+
+			return
+		}
+	}()
+
 	wg.Add(1)
 	go func() {
 		defer wg.Done()
@@ -76,6 +88,7 @@ func (p *price) start() {
 
 	wg.Wait()
 
+	price.XeggexPacToUSDT = xeggex
 	price.TradeOgrePacToUSDT = tradeOgre
 	if len(azbit) > 0 {
 		price.AzbitPacToUSDT = azbit[0]