add minimal rfq relayer query interface

contrib/opbot/botmd/botmd.go

@@ -27,11 +27,17 @@
 
 	bot.signozClient = signoz.NewClientFromUser(handler, cfg.SignozBaseURL, cfg.SignozEmail, cfg.SignozPassword)
 
-	server.AddCommand(bot.traceCommand())
+	bot.addCommands(bot.traceCommand(), bot.rfqLookupCommand())
 
 	return bot
 }
 
+func (b *Bot) addCommands(commands ...*slacker.CommandDefinition) {
+	for _, command := range commands {
+		b.server.AddCommand(command)
+	}
+}
+
 // Start starts the bot server.
 // nolint: wrapcheck
 func (b *Bot) Start(ctx context.Context) error {

contrib/opbot/botmd/commands.go

@@ -4,12 +4,16 @@
 
 import (
 	"fmt"
+	"github.com/ethereum/go-ethereum/common"
 	"github.com/hako/durafmt"
 	"github.com/slack-go/slack"
 	"github.com/slack-io/slacker"
 	"github.com/synapsecns/sanguine/contrib/opbot/signoz"
+	"github.com/synapsecns/sanguine/ethergo/chaindata"
+	"github.com/synapsecns/sanguine/services/rfq/relayer/relapi"
 	"log"
 	"strings"
+	"sync"
 	"time"
 )
 
@@ -73,7 +77,7 @@
 				return
 			}
 
-			slackBlocks := []slack.Block{slack.NewHeaderBlock(slack.NewTextBlockObject(slack.PlainTextType, "Traces", false, false))}
+			slackBlocks := []slack.Block{slack.NewHeaderBlock(slack.NewTextBlockObject(slack.PlainTextType, fmt.Sprintf("Traces for %s", tags), false, false))}
 
 			for _, results := range traceList {
 				trace := results.Data["traceID"].(string)
@@ -109,3 +113,132 @@
 		},
 	}
 }
+
+func (b *Bot) rfqLookupCommand() *slacker.CommandDefinition {
+	return &slacker.CommandDefinition{
+		Command:     "rfq <tx>",
+		Description: "find a rfq transaction by either tx hash or txid on all configured relayers",
+		Examples: []string{
+			"rfq 0x30f96b45ba689c809f7e936c140609eb31c99b182bef54fccf49778716a7e1ca",
+		},
+		Handler: func(ctx *slacker.CommandContext) {
+			type Status struct {
+				relayer string
+				*relapi.GetQuoteRequestStatusResponse
+			}
+
+			var statuses []Status
+			var sliceMux sync.Mutex
+
+			if len(b.cfg.RelayerURLS) == 0 {
+				_, err := ctx.Response().Reply("no relayer urls configured")
+				if err != nil {
+					log.Println(err)
+				}
+				return
+			}
+
+			tx := ctx.Request().Param("tx")
+
+			var wg sync.WaitGroup
+			// 2 routines per relayer, one for tx hashh one for tx id
+			wg.Add(len(b.cfg.RelayerURLS) * 2)
+			for _, relayer := range b.cfg.RelayerURLS {
+				client := relapi.NewRelayerClient(b.handler, relayer)
+				go func() {
+					defer wg.Done()
+					res, err := client.GetQuoteRequestStatusByTxHash(ctx.Context(), tx)
+					if err != nil {
+						log.Printf("error fetching quote request status by tx hash: %v\n", err)
+						return
+					}
+					sliceMux.Lock()
+					defer sliceMux.Unlock()
+					statuses = append(statuses, Status{relayer: relayer, GetQuoteRequestStatusResponse: res})
+				}()
+
+				go func() {
+					defer wg.Done()
+					res, err := client.GetQuoteRequestStatusByTxID(ctx.Context(), tx)
+					if err != nil {
+						log.Printf("error fetching quote request status by tx id: %v\n", err)
+						return
+					}
+					sliceMux.Lock()
+					defer sliceMux.Unlock()
+					statuses = append(statuses, Status{relayer: relayer, GetQuoteRequestStatusResponse: res})
+				}()
+			}
+			wg.Wait()
+
+			if len(statuses) == 0 {
+				_, err := ctx.Response().Reply("no quote request found")
+				if err != nil {
+					log.Println(err)
+				}
+				return
+			}
+
+			var slackBlocks []slack.Block
+			for _, status := range statuses {
+				objects := []*slack.TextBlockObject{
+					{
+						Type: slack.MarkdownType,
+						Text: fmt.Sprintf("*Relayer*: %s", status.relayer),
+					},
+					{
+						Type: slack.MarkdownType,
+						Text: fmt.Sprintf("*Status*: %s", status.Status),
+					},
+					{
+						Type: slack.MarkdownType,
+						Text: fmt.Sprintf("*TxID*: %s", toExplorerSlackLink(status.TxID)),
+					},
+					{
+						Type: slack.MarkdownType,
+						Text: fmt.Sprintf("*OriginTxHash*: %s", toTXSlackLink(status.OriginTxHash, status.OriginChainID)),
+					},
+				}
+
+				if status.DestTxHash == (common.Hash{}).String() {
+					objects = append(objects, &slack.TextBlockObject{
+						Type: slack.MarkdownType,
+						Text: "*DestTxHash*: not available",
+					})
+				} else {
+					objects = append(objects, &slack.TextBlockObject{
+						Type: slack.MarkdownType,
+						Text: fmt.Sprintf("*DestTxHash*: %s", toTXSlackLink(status.DestTxHash, status.DestChainID)),
+					})
+				}
+
+				slackBlocks = append(slackBlocks, slack.NewSectionBlock(nil, objects, nil))
+			}
+
+			_, err := ctx.Response().ReplyBlocks(slackBlocks)
+			if err != nil {
+				log.Println(err)
+			}
+		}}
+}
+
+func toExplorerSlackLink(ogHash string) string {
+	rfqHash := strings.ToUpper(ogHash)
+	// cut off 0x
+	if len(rfqHash) > 0 {
+		rfqHash = strings.ToUpper(rfqHash[2:])
+	}
+
+	return fmt.Sprintf("<https://anon.to/?https://explorer.synapseprotocol.com/tx/%s|%s>", rfqHash, ogHash)
+}
+
+// produce a salck link if the explorer exists.
+func toTXSlackLink(txHash string, chainID uint32) string {
+	url := chaindata.ToTXLink(int64(chainID), txHash)
+	if url == "" {
+		return txHash
+	}
+
+	// TODO: remove when we can contorl unfurl
+	return fmt.Sprintf("<https://anon.to/?%s|%s>", url, txHash)
+}

contrib/opbot/config/config.go

@@ -15,5 +15,6 @@ type Config struct {
 	// inject only with init container!
 	SignozPassword string `yaml:"signoz_password"`
 	// SignozBaseURL is the base url of the signoz instance.
-	SignozBaseURL string `yaml:"signoz_base_url"`
+	SignozBaseURL string   `yaml:"signoz_base_url"`
+	RelayerURLS   []string `yaml:"rfq_relayer_urls"`
 }