Fetch gRPC URL from the about API response (#28)

cmd/about.go

@@ -30,6 +30,7 @@ type About struct {
 	Mode            string `json:"mode"`
 	Staging         string `json:"staging"`
 	Store           string `json:"store"`
+	GrpcPort        uint16 `json:"grpcPort"`
 	UpdateAvailable bool   `json:"updateAvailable"`
 	Version         string `json:"version"`
 }

cmd/tail.go

@@ -22,7 +22,6 @@ import (
 	"encoding/base64"
 	"encoding/json"
 	"fmt"
-
 	"pb/pkg/config"
 
 	"github.com/apache/arrow/go/v13/arrow/array"
@@ -52,7 +51,16 @@ func tail(profile config.Profile, stream string) error {
 	}{
 		Stream: stream,
 	})
-	client, err := flight.NewClientWithMiddleware("localhost:8001", nil, nil, grpc.WithTransportCredentials(insecure.NewCredentials()))
+
+	// get grpc url for this request
+	httpClient := DefaultClient()
+	about, err := FetchAbout(&httpClient)
+	if err != nil {
+		return err
+	}
+	url := profile.GrpcAddr(fmt.Sprint(about.GrpcPort))
+
+	client, err := flight.NewClientWithMiddleware(url, nil, nil, grpc.WithTransportCredentials(insecure.NewCredentials()))
 	if err != nil {
 		return err
 	}

pkg/config/config.go

@@ -18,6 +18,8 @@ package config
 
 import (
 	"fmt"
+	"net"
+	"net/url"
 	"os"
 	path "path/filepath"
 
@@ -51,6 +53,11 @@ type Profile struct {
 	Password string
 }
 
+func (p *Profile) GrpcAddr(port string) string {
+	urlv, _ := url.Parse(p.URL)
+	return net.JoinHostPort(urlv.Hostname(), port)
+}
+
 // WriteConfigToFile writes the configuration to the config file
 func WriteConfigToFile(config *Config) error {
 	tomlData, _ := toml.Marshal(config)