summaryrefslogtreecommitdiff
path: root/internal/client/client.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/client/client.go')
-rw-r--r--internal/client/client.go21
1 files changed, 10 insertions, 11 deletions
diff --git a/internal/client/client.go b/internal/client/client.go
index c2ef6e1..3345a9f 100644
--- a/internal/client/client.go
+++ b/internal/client/client.go
@@ -6,11 +6,10 @@ import (
"crypto/x509"
_ "embed"
"fmt"
+ "log"
"os"
"strings"
"time"
-
- "github.com/kyren223/eko/internal/utils/log"
)
//go:embed server.crt
@@ -19,7 +18,7 @@ var certPEM []byte
func Run() {
certPool := x509.NewCertPool()
if !certPool.AppendCertsFromPEM(certPEM) {
- log.Fatal("failed to append server certificate")
+ log.Fatalf("failed to append server certificate")
}
tlsConfig := &tls.Config{
@@ -27,7 +26,7 @@ func Run() {
ServerName: "localhost",
}
- log.Info("Client started, waiting for user input...")
+ log.Println("client started, waiting for user input...")
for {
fmt.Print("> ")
input, _ := bufio.NewReader(os.Stdin).ReadString('\n')
@@ -37,32 +36,32 @@ func Run() {
}
err := processRequest(input, tlsConfig)
if err != nil {
- log.Error("%v", err)
+ log.Println(err)
}
}
}
func processRequest(request string, tlsConfig *tls.Config) error {
- conn, err := tls.Dial("tcp", ":7223", tlsConfig)
+ conn, err := tls.Dial("tcp4", ":7223", tlsConfig)
if err != nil {
- return fmt.Errorf("Unable to establish connection with server: %v", err)
+ return fmt.Errorf("error establishing connection with server: %v", err)
}
defer conn.Close()
conn.SetDeadline(time.Now().Add(time.Second))
- log.Info("Established connection to server: %v", conn.RemoteAddr().String())
+ log.Println("established connection with server:", conn.RemoteAddr().String())
_, err = conn.Write([]byte(request))
if err != nil {
- return fmt.Errorf("Unable to send request: %v", err)
+ return fmt.Errorf("error sending request: %v", err)
}
buffer := make([]byte, 1024)
n, err := conn.Read(buffer)
if err != nil {
- return fmt.Errorf("Unable to receive response: %v", err)
+ return fmt.Errorf("error receiving response: %v", err)
}
- log.Info("Response from server: %v", string(buffer[:n]))
+ log.Println("server response:", string(buffer[:n]))
return nil
}