feat: Rename oracle to slinky, refactor mm provider factory

.goreleaser.yml

@@ -8,7 +8,7 @@ release:
   prerelease: true
 
 builds:
-  - main: 'cmd/oracle/main.go'
+  - main: 'cmd/slinky/main.go'
     goos:
     - 'linux'
     - 'darwin'

Makefile

@@ -30,7 +30,7 @@ build: tidy
 	@go build -o ./build/ ./...
 
 run-oracle-server: build
-	@./build/oracle --oracle-config-path ${ORACLE_CONFIG_FILE} --market-config-path ${MARKET_CONFIG_FILE}
+	@./build/slinky --oracle-config-path ${ORACLE_CONFIG_FILE} --market-config-path ${MARKET_CONFIG_FILE}
 
 run-oracle-client: build
 	@./build/client --host localhost --port 8080
@@ -54,7 +54,7 @@ stop-oracle:
 	@$(DOCKER_COMPOSE) -f docker-compose.yml down
 
 install: tidy
-	@go install -mod=readonly $(BUILD_FLAGS) ./cmd/oracle
+	@go install -mod=readonly $(BUILD_FLAGS) ./cmd/slinky
 
 .PHONY: build run-oracle-server install
 

cmd/client/main.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"flag"
 	"fmt"
 	"log"
 	"os"
@@ -11,72 +10,97 @@
 	"syscall"
 	"time"
 
+	"github.com/spf13/cobra"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials/insecure"
 
 	"github.com/skip-mev/slinky/service/servers/oracle/types"
 )
 
 var (
-	host = flag.String("host", "localhost", "host for the grpc-service to listen on")
-	port = flag.String("port", "8080", "port for the grpc-service to listen on")
-)
+	rootCmd = &cobra.Command{
+		Use:   "client",
+		Short: "Continuously calls the Prices RPC on the sidecar.",
+		Args:  cobra.NoArgs,
+		Run: func(_ *cobra.Command, _ []string) {
+			// Channel with width for termination signal.
+			sigs := make(chan os.Signal, 1)
 
-func main() {
-	// Channel with width for termination signal.
-	sigs := make(chan os.Signal, 1)
+			// Gracefully trigger close on interrupt or terminate signals.
+			signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
 
-	// Gracefully trigger close on interrupt or terminate signals.
-	signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
+			// Set up a connection to the server.
+			url := fmt.Sprintf("%s:%s", host, port)
+			conn, err := grpc.Dial(url, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithBlock())
+			if err != nil {
+				log.Fatalf("did not connect: %v", err)
+			}
+			defer conn.Close()
 
-	// Parse flags.
-	flag.Parse()
+			// Create a new client
+			client := types.NewOracleClient(conn)
 
-	// Set up a connection to the server.
-	url := fmt.Sprintf("%s:%s", *host, *port)
-	conn, err := grpc.Dial(url, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithBlock())
-	if err != nil {
-		log.Fatalf("did not connect: %v", err)
-	}
-	defer conn.Close()
+			// Continuous loop
+			for {
+				select {
+				case <-sigs:
+					log.Printf("Received interrupt or terminate signal, exiting...\n")
+					return
+				default:
+					// Call Prices RPC
+					log.Printf("Calling Prices RPC...\n")
+					resp, err := client.Prices(context.Background(), &types.QueryPricesRequest{})
+					if err != nil {
+						log.Fatalf("could not get prices: %v", err)
+					}
 
-	// Create a new client
-	client := types.NewOracleClient(conn)
+					prices := resp.GetPrices()
 
-	// Continuous loop
-	for {
-		select {
-		case <-sigs:
-			log.Printf("Received interrupt or terminate signal, exiting...\n")
-			return
-		default:
-			// Call Prices RPC
-			log.Printf("Calling Prices RPC...\n")
-			resp, err := client.Prices(context.Background(), &types.QueryPricesRequest{})
-			if err != nil {
-				log.Fatalf("could not get prices: %v", err) //nolint
-			}
+					var keys []string
+					for k := range prices {
+						keys = append(keys, k)
+					}
 
-			prices := resp.GetPrices()
+					// Sort the prices by the currency pair
+					sort.Slice(keys, func(i, j int) bool {
+						return keys[i] < keys[j]
+					})
 
-			var keys []string
-			for k := range prices {
-				keys = append(keys, k)
-			}
+					// Log the response
+					for _, key := range keys {
+						log.Printf("Currency Pair, Price: (%s, %s)", key, prices[key])
+					}
 
-			// Sort the prices by the currency pair
-			sort.Slice(keys, func(i, j int) bool {
-				return keys[i] < keys[j]
-			})
-
-			// Log the response
-			for _, key := range keys {
-				log.Printf("Currency Pair, Price: (%s, %s)", key, prices[key])
+					// Wait for a bit before making the next request
+					log.Printf("Sleeping for 10 seconds...\n\n")
+					time.Sleep(time.Second * 10) // Adjust the interval as needed
+				}
 			}
-
-			// Wait for a bit before making the next request
-			log.Printf("Sleeping for 10 seconds...\n\n")
-			time.Sleep(time.Second * 10) // Adjust the interval as needed
-		}
+		},
 	}
+	// host stores the host portion of the sidecar RPC to query.
+	host string
+	// port stores the port of the sidecar RPC to query.
+	port string
+)
+
+func init() {
+	rootCmd.Flags().StringVarP(
+		&host,
+		"host",
+		"",
+		"localhost",
+		"host of the grpc-service, which the client will connect to",
+	)
+	rootCmd.Flags().StringVarP(
+		&port,
+		"port",
+		"",
+		"8080",
+		"port the grpc-service, which the client will connect to",
+	)
+}
+
+func main() {
+	rootCmd.Execute()
 }